Class PslDataWriter (0.3.4) 

public class PslDataWriter implements DataWriter<InternalRow>

Inheritance

java.lang.Object > PslDataWriter

Implements

org.apache.spark.sql.sources.v2.writer.DataWriter<org.apache.spark.sql.catalyst.InternalRow>

Constructors

PslDataWriter(long partitionId, long taskId, long epochId, StructType schema, PublisherFactory publisherFactory)

public PslDataWriter(long partitionId, long taskId, long epochId, StructType schema, PublisherFactory publisherFactory)
Parameters
Name Description
partitionId long
taskId long
epochId long
schema org.apache.spark.sql.types.StructType
publisherFactory PublisherFactory

Methods

abort()

public synchronized void abort()

commit()

public synchronized WriterCommitMessage commit()
Returns
Type Description
org.apache.spark.sql.sources.v2.writer.WriterCommitMessage
Exceptions
Type Description
IOException

write(InternalRow record)

public synchronized void write(InternalRow record)
Parameter
Name Description
record org.apache.spark.sql.catalyst.InternalRow