public class StreamWriteBuilderImpl extends Object implements StreamWriteBuilder
WriteBuilder
.Constructor and Description |
---|
StreamWriteBuilderImpl(InnerTable table) |
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 CommitMessage s. |
StreamTableWrite |
newWrite()
Create a
TableWrite to write InternalRow s. |
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.
|
public StreamWriteBuilderImpl(InnerTable table)
public String tableName()
WriteBuilder
tableName
in interface WriteBuilder
public RowType rowType()
WriteBuilder
rowType
in interface WriteBuilder
public Optional<WriteSelector> newWriteSelector()
WriteBuilder
WriteSelector
to partition records before writers.newWriteSelector
in interface WriteBuilder
public String commitUser()
StreamWriteBuilder
StreamWriteBuilder.withCommitUser(java.lang.String)
.commitUser
in interface StreamWriteBuilder
public StreamWriteBuilder withCommitUser(String commitUser)
StreamWriteBuilder
TableWrite
and TableCommit
must be the same, otherwise there will be some conflicts.withCommitUser
in interface StreamWriteBuilder
public StreamTableWrite newWrite()
StreamWriteBuilder
TableWrite
to write InternalRow
s.newWrite
in interface StreamWriteBuilder
newWrite
in interface WriteBuilder
public StreamTableCommit newCommit()
StreamWriteBuilder
TableCommit
to commit CommitMessage
s.newCommit
in interface StreamWriteBuilder
newCommit
in interface WriteBuilder
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.