Uses of Interface
org.apache.flink.table.api.bridge.java.StreamStatementSet
-
Packages that use StreamStatementSet Package Description org.apache.flink.table.api.bridge.java org.apache.flink.table.api.bridge.java.internal -
-
Uses of StreamStatementSet in org.apache.flink.table.api.bridge.java
Methods in org.apache.flink.table.api.bridge.java that return StreamStatementSet Modifier and Type Method Description StreamStatementSetStreamStatementSet. add(org.apache.flink.table.api.TablePipeline tablePipeline)StreamStatementSetStreamStatementSet. addInsert(String targetPath, org.apache.flink.table.api.Table table)StreamStatementSetStreamStatementSet. addInsert(String targetPath, org.apache.flink.table.api.Table table, boolean overwrite)StreamStatementSetStreamStatementSet. addInsert(org.apache.flink.table.api.TableDescriptor targetDescriptor, org.apache.flink.table.api.Table table)StreamStatementSetStreamStatementSet. addInsert(org.apache.flink.table.api.TableDescriptor targetDescriptor, org.apache.flink.table.api.Table table, boolean overwrite)StreamStatementSetStreamStatementSet. addInsertSql(String statement)StreamStatementSetStreamTableEnvironment. createStatementSet()Returns aStatementSetthat integrates with the Java-specificDataStreamAPI.StreamStatementSetStreamStatementSet. printExplain(org.apache.flink.table.api.ExplainDetail... extraDetails) -
Uses of StreamStatementSet in org.apache.flink.table.api.bridge.java.internal
Classes in org.apache.flink.table.api.bridge.java.internal that implement StreamStatementSet Modifier and Type Class Description classStreamStatementSetImplImplementation forStreamStatementSet.Methods in org.apache.flink.table.api.bridge.java.internal that return StreamStatementSet Modifier and Type Method Description StreamStatementSetStreamStatementSetImpl. add(org.apache.flink.table.api.TablePipeline tablePipeline)StreamStatementSetStreamStatementSetImpl. addInsert(String targetPath, org.apache.flink.table.api.Table table)StreamStatementSetStreamStatementSetImpl. addInsert(String targetPath, org.apache.flink.table.api.Table table, boolean overwrite)StreamStatementSetStreamStatementSetImpl. addInsert(org.apache.flink.table.api.TableDescriptor targetDescriptor, org.apache.flink.table.api.Table table)StreamStatementSetStreamStatementSetImpl. addInsert(org.apache.flink.table.api.TableDescriptor targetDescriptor, org.apache.flink.table.api.Table table, boolean overwrite)StreamStatementSetStreamStatementSetImpl. addInsertSql(String statement)StreamStatementSetStreamTableEnvironmentImpl. createStatementSet()StreamStatementSetStreamStatementSetImpl. printExplain(org.apache.flink.table.api.ExplainDetail... extraDetails)
-