Class PslStreamWriter

Version latest

• 1.0.0 (latest)
• 0.4.5
• 0.3.4

public class PslStreamWriter implements StreamWriter

Inheritance

java.lang.Object > PslStreamWriter

Implements

org.apache.spark.sql.sources.v2.writer.streaming.StreamWriter

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

PslStreamWriter(StructType inputSchema, PslWriteDataSourceOptions writeOptions)

public PslStreamWriter(StructType inputSchema, PslWriteDataSourceOptions writeOptions)

Parameters

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

Methods

abort(long epochId, WriterCommitMessage[] messages)

public void abort(long epochId, WriterCommitMessage[] messages)

Parameters

Name	Description
epochId	long
messages	org.apache.spark.sql.sources.v2.writer.WriterCommitMessage[]

commit(long epochId, WriterCommitMessage[] messages)

public void commit(long epochId, WriterCommitMessage[] messages)

Parameters

Name	Description
epochId	long
messages	org.apache.spark.sql.sources.v2.writer.WriterCommitMessage[]

createWriterFactory()

public DataWriterFactory<InternalRow> createWriterFactory()

Returns

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