Class PslDataWriterFactory (0.3.4)

Version 0.3.4

• 1.0.0 (latest)
• 0.4.5
• 0.3.4

public class PslDataWriterFactory implements Serializable, DataWriterFactory<InternalRow>

Inheritance

java.lang.Object > PslDataWriterFactory

Implements

Serializable, org.apache.spark.sql.sources.v2.writer.DataWriterFactory<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

PslDataWriterFactory(StructType inputSchema, PslWriteDataSourceOptions writeOptions)

public PslDataWriterFactory(StructType inputSchema, PslWriteDataSourceOptions writeOptions)

Parameters

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

Methods

createDataWriter(int partitionId, long taskId, long epochId)

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

Parameters

Name	Description
partitionId	int
taskId	long
epochId	long

Returns

Type	Description
org.apache.spark.sql.sources.v2.writer.DataWriter<org.apache.spark.sql.catalyst.InternalRow>