Package | Description |
---|---|
org.apache.flink.table.api.bridge.java | |
org.apache.flink.table.api.bridge.java.internal |
Modifier and Type | Method and Description |
---|---|
StreamStatementSet |
StreamStatementSet.add(TablePipeline tablePipeline) |
StreamStatementSet |
StreamStatementSet.addInsert(String targetPath,
Table table) |
StreamStatementSet |
StreamStatementSet.addInsert(String targetPath,
Table table,
boolean overwrite) |
StreamStatementSet |
StreamStatementSet.addInsert(TableDescriptor targetDescriptor,
Table table) |
StreamStatementSet |
StreamStatementSet.addInsert(TableDescriptor targetDescriptor,
Table table,
boolean overwrite) |
StreamStatementSet |
StreamStatementSet.addInsertSql(String statement) |
StreamStatementSet |
StreamTableEnvironment.createStatementSet()
Returns a
StatementSet that integrates with the Java-specific DataStream API. |
StreamStatementSet |
StreamStatementSet.printExplain(ExplainDetail... extraDetails) |
Modifier and Type | Class and Description |
---|---|
class |
StreamStatementSetImpl
Implementation for
StreamStatementSet . |
Modifier and Type | Method and Description |
---|---|
StreamStatementSet |
StreamStatementSetImpl.add(TablePipeline tablePipeline) |
StreamStatementSet |
StreamStatementSetImpl.addInsert(String targetPath,
Table table) |
StreamStatementSet |
StreamStatementSetImpl.addInsert(String targetPath,
Table table,
boolean overwrite) |
StreamStatementSet |
StreamStatementSetImpl.addInsert(TableDescriptor targetDescriptor,
Table table) |
StreamStatementSet |
StreamStatementSetImpl.addInsert(TableDescriptor targetDescriptor,
Table table,
boolean overwrite) |
StreamStatementSet |
StreamStatementSetImpl.addInsertSql(String statement) |
StreamStatementSet |
StreamTableEnvironmentImpl.createStatementSet() |
StreamStatementSet |
StreamStatementSetImpl.printExplain(ExplainDetail... extraDetails) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.