Class PslDataWriter (0.3.4)

Version 0.3.4

• 1.0.0 (latest)
• 0.4.5
• 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>

Inherited Members

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

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