Class PslDataWriter (1.0.0)

public class PslDataWriter implements DataWriter<InternalRow>

Inheritance

java.lang.Object > PslDataWriter

org.apache.spark.sql.connector.write.DataWriter<org.apache.spark.sql.catalyst.InternalRow>

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`

public synchronized void abort()

public void close()

Exceptions
Type	Description
`IOException`

public synchronized WriterCommitMessage commit()

Returns
Type	Description
`org.apache.spark.sql.connector.write.WriterCommitMessage`

Exceptions
Type	Description
`IOException`

public synchronized void write(InternalRow record)

Parameter
Name	Description
`record`	`org.apache.spark.sql.catalyst.InternalRow`