Package | Description |
---|---|
org.apache.flink.table.api | |
org.apache.flink.table.api.java | |
org.apache.flink.table.api.java.internal |
Modifier and Type | Method and Description |
---|---|
StreamQueryConfig |
StreamQueryConfig.withIdleStateRetentionTime(Time minTime,
Time maxTime)
Deprecated.
Specifies a minimum and a maximum time interval for how long idle state, i.e., state which
was not updated, will be retained.
|
Modifier and Type | Method and Description |
---|---|
void |
StreamTableEnvironment.insertInto(Table table,
StreamQueryConfig queryConfig,
String sinkPath,
String... sinkPathContinued)
|
void |
StreamTableEnvironment.sqlUpdate(String stmt,
StreamQueryConfig config)
Evaluates a SQL statement such as INSERT, UPDATE or DELETE; or a DDL statement;
NOTE: Currently only SQL INSERT statements are supported.
|
<T> DataStream<T> |
StreamTableEnvironment.toAppendStream(Table table,
Class<T> clazz,
StreamQueryConfig queryConfig)
Converts the given
Table into an append DataStream of a specified type. |
<T> DataStream<T> |
StreamTableEnvironment.toAppendStream(Table table,
TypeInformation<T> typeInfo,
StreamQueryConfig queryConfig)
Converts the given
Table into an append DataStream of a specified type. |
<T> DataStream<Tuple2<Boolean,T>> |
StreamTableEnvironment.toRetractStream(Table table,
Class<T> clazz,
StreamQueryConfig queryConfig)
Converts the given
Table into a DataStream of add and retract messages. |
<T> DataStream<Tuple2<Boolean,T>> |
StreamTableEnvironment.toRetractStream(Table table,
TypeInformation<T> typeInfo,
StreamQueryConfig queryConfig)
Converts the given
Table into a DataStream of add and retract messages. |
Modifier and Type | Method and Description |
---|---|
void |
StreamTableEnvironmentImpl.insertInto(Table table,
StreamQueryConfig queryConfig,
String sinkPath,
String... sinkPathContinued) |
void |
StreamTableEnvironmentImpl.sqlUpdate(String stmt,
StreamQueryConfig config) |
<T> DataStream<T> |
StreamTableEnvironmentImpl.toAppendStream(Table table,
Class<T> clazz,
StreamQueryConfig queryConfig) |
<T> DataStream<T> |
StreamTableEnvironmentImpl.toAppendStream(Table table,
TypeInformation<T> typeInfo,
StreamQueryConfig queryConfig) |
<T> DataStream<Tuple2<Boolean,T>> |
StreamTableEnvironmentImpl.toRetractStream(Table table,
Class<T> clazz,
StreamQueryConfig queryConfig) |
<T> DataStream<Tuple2<Boolean,T>> |
StreamTableEnvironmentImpl.toRetractStream(Table table,
TypeInformation<T> typeInfo,
StreamQueryConfig queryConfig) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.