Class PslDataWriterFactory (0.4.5)

Version 0.4.5

• 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>