org.apache.paimon.table.sink

Class BatchWriteBuilderImpl

java.lang.Object

org.apache.paimon.table.sink.BatchWriteBuilderImpl

All Implemented Interfaces:

Serializable, BatchWriteBuilder, WriteBuilder

public class BatchWriteBuilderImpl
extends Object
implements BatchWriteBuilder

Implementation for WriteBuilder.

See Also:

Serialized Form

Field Summary

Fields inherited from interface org.apache.paimon.table.sink.BatchWriteBuilder

COMMIT_IDENTIFIER

Constructor Summary

Constructors

Constructor and Description
BatchWriteBuilderImpl(InnerTable table)

Method Summary

Modifier and Type	Method and Description
BatchTableCommit	newCommit() Create a TableCommit to commit CommitMessages.
BatchTableWrite	newWrite() Create a TableWrite to write InternalRows.
Optional<WriteSelector>	newWriteSelector() Create a WriteSelector to partition records before writers.
RowType	rowType() Returns the row type of this table.
String	tableName() A name to identify this table.
BatchWriteBuilder	withOverwrite(Map<String,String> staticPartition) Overwrite writing, same as the 'INSERT OVERWRITE T PARTITION (...)' semantics of SQL.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.paimon.table.sink.BatchWriteBuilder

withOverwrite

Constructor Detail

BatchWriteBuilderImpl

public BatchWriteBuilderImpl(InnerTable table)

Method Detail

tableName

public String tableName()

Description copied from interface: WriteBuilder

A name to identify this table.

Specified by:

tableName in interface WriteBuilder

rowType

public RowType rowType()

Description copied from interface: WriteBuilder

Returns the row type of this table.

Specified by:

rowType in interface WriteBuilder

newWriteSelector

public Optional<WriteSelector> newWriteSelector()

Description copied from interface: WriteBuilder

Create a WriteSelector to partition records before writers.

Specified by:

newWriteSelector in interface WriteBuilder

Returns:

empty if no data distribution is required.

withOverwrite

public BatchWriteBuilder withOverwrite(@Nullable
                                       Map<String,String> staticPartition)

Description copied from interface: BatchWriteBuilder

Overwrite writing, same as the 'INSERT OVERWRITE T PARTITION (...)' semantics of SQL.

Specified by:

withOverwrite in interface BatchWriteBuilder

newWrite

public BatchTableWrite newWrite()

Description copied from interface: BatchWriteBuilder

Create a TableWrite to write InternalRows.

Specified by:

newWrite in interface BatchWriteBuilder

Specified by:

newWrite in interface WriteBuilder

newCommit

public BatchTableCommit newCommit()

Description copied from interface: BatchWriteBuilder

Create a TableCommit to commit CommitMessages.

Specified by:

newCommit in interface BatchWriteBuilder

Specified by:

newCommit in interface WriteBuilder