@PublicEvolving public interface StatementSet
StatementSet
accepts DML statements or Table
s, the planner can optimize all
added statements and Tables together and then submit as one job.
The added statements and Tables will be cleared when calling the `execute` method.
Modifier and Type | Method and Description |
---|---|
StatementSet |
addInsert(String targetPath,
Table table)
add Table with the given sink table name to the set.
|
StatementSet |
addInsert(String targetPath,
Table table,
boolean overwrite)
add
Table with the given sink table name to the set. |
StatementSet |
addInsertSql(String statement)
add insert statement to the set.
|
TableResult |
execute()
execute all statements and Tables as a batch.
|
String |
explain(ExplainDetail... extraDetails)
returns the AST and the execution plan to compute the result of the all statements and
Tables.
|
StatementSet addInsertSql(String statement)
StatementSet addInsert(String targetPath, Table table)
StatementSet addInsert(String targetPath, Table table, boolean overwrite)
Table
with the given sink table name to the set.String explain(ExplainDetail... extraDetails)
extraDetails
- The extra explain details which the explain result should include, e.g.
estimated cost, changelog mode for streaming, displaying execution plan in json formatTableResult execute()
The added statements and Tables will be cleared when executing this method.
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.