org.apache.paimon.table.sink

Class StreamWriteBuilderImpl

java.lang.Object

org.apache.paimon.table.sink.StreamWriteBuilderImpl

All Implemented Interfaces:

Serializable, StreamWriteBuilder, WriteBuilder

public class StreamWriteBuilderImpl
extends Object
implements StreamWriteBuilder

Implementation for WriteBuilder.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
StreamWriteBuilderImpl(InnerTable table)

Method Summary

Modifier and Type	Method and Description
String	commitUser() Get commit user, set by StreamWriteBuilder.withCommitUser(java.lang.String).
StreamTableCommit	newCommit() Create a TableCommit to commit CommitMessages.
StreamTableWrite	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.
StreamWriteBuilder	withCommitUser(String commitUser) Set commit user, the default value is a random UUID.

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamWriteBuilderImpl

public StreamWriteBuilderImpl(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.

commitUser

public String commitUser()

Description copied from interface: StreamWriteBuilder

Get commit user, set by StreamWriteBuilder.withCommitUser(java.lang.String).

Specified by:

commitUser in interface StreamWriteBuilder

withCommitUser

public StreamWriteBuilder withCommitUser(String commitUser)

Description copied from interface: StreamWriteBuilder

Set commit user, the default value is a random UUID. The commit user used by TableWrite and TableCommit must be the same, otherwise there will be some conflicts.

Specified by:

withCommitUser in interface StreamWriteBuilder

newWrite

public StreamTableWrite newWrite()

Description copied from interface: StreamWriteBuilder

Create a TableWrite to write InternalRows.

Specified by:

newWrite in interface StreamWriteBuilder

Specified by:

newWrite in interface WriteBuilder

newCommit

public StreamTableCommit newCommit()

Description copied from interface: StreamWriteBuilder

Create a TableCommit to commit CommitMessages.

Specified by:

newCommit in interface StreamWriteBuilder

Specified by:

newCommit in interface WriteBuilder