Class PslDataWriter (1.0.0) 

public class PslDataWriter implements DataWriter<InternalRow>

Inheritance

java.lang.Object > PslDataWriter

Implements

org.apache.spark.sql.connector.write.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
NameDescription
partitionIdlong
taskIdlong
epochIdlong
schemaorg.apache.spark.sql.types.StructType
publisherFactoryPublisherFactory

Methods

abort()

public synchronized void abort()

close()

public void close()
Exceptions
TypeDescription
IOException

commit()

public synchronized WriterCommitMessage commit()
Returns
TypeDescription
org.apache.spark.sql.connector.write.WriterCommitMessage
Exceptions
TypeDescription
IOException

write(InternalRow record)

public synchronized void write(InternalRow record)
Parameter
NameDescription
recordorg.apache.spark.sql.catalyst.InternalRow