public class BatchWriteBuilderImpl extends Object implements BatchWriteBuilder
WriteBuilder
.COMMIT_IDENTIFIER
Constructor and Description |
---|
BatchWriteBuilderImpl(InnerTable table) |
Modifier and Type | Method and Description |
---|---|
BatchTableCommit |
newCommit()
Create a
TableCommit to commit CommitMessage s. |
BatchTableWrite |
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.
|
BatchWriteBuilder |
withOverwrite(Map<String,String> staticPartition)
Overwrite writing, same as the 'INSERT OVERWRITE T PARTITION (...)' semantics of SQL.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
withOverwrite
public BatchWriteBuilderImpl(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 BatchWriteBuilder withOverwrite(@Nullable Map<String,String> staticPartition)
BatchWriteBuilder
withOverwrite
in interface BatchWriteBuilder
public BatchTableWrite newWrite()
BatchWriteBuilder
TableWrite
to write InternalRow
s.newWrite
in interface BatchWriteBuilder
newWrite
in interface WriteBuilder
public BatchTableCommit newCommit()
BatchWriteBuilder
TableCommit
to commit CommitMessage
s.newCommit
in interface BatchWriteBuilder
newCommit
in interface WriteBuilder
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.