Class PslDataWriterFactory (1.0.0)

Version latest

• 1.0.0 (latest)
• 0.4.5
• 0.3.4

public class PslDataWriterFactory implements Serializable, DataWriterFactory, StreamingDataWriterFactory

Inheritance

java.lang.Object > PslDataWriterFactory

Implements

Serializable, org.apache.spark.sql.connector.write.DataWriterFactory, org.apache.spark.sql.connector.write.streaming.StreamingDataWriterFactory

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

PslDataWriterFactory(StructType inputSchema, PslWriteDataSourceOptions writeOptions)

public PslDataWriterFactory(StructType inputSchema, PslWriteDataSourceOptions writeOptions)

Parameters
Name	Description
inputSchema	org.apache.spark.sql.types.StructType
writeOptions	PslWriteDataSourceOptions

Methods

createWriter(int partitionId, long taskId)

public DataWriter<InternalRow> createWriter(int partitionId, long taskId)

Parameters
Name	Description
partitionId	int
taskId	long

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

createWriter(int partitionId, long taskId, long epochId)

public DataWriter<InternalRow> createWriter(int partitionId, long taskId, long epochId)

Parameters
Name	Description
partitionId	int
taskId	long
epochId	long

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