Modifier and Type | Method and Description |
---|---|
StreamQueryConfig |
StreamTableEnvironment.queryConfig() |
StreamQueryConfig |
StreamQueryConfig.withIdleStateRetentionTime(Time time)
Specifies the time interval for how long idle state, i.e., state which was not updated, will
be retained.
|
StreamQueryConfig |
StreamQueryConfig.withIdleStateRetentionTime(Time minTime,
Time maxTime)
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 |
---|---|
protected <A> DataStream<A> |
StreamTableEnvironment.translate(org.apache.calcite.rel.RelNode logicalPlan,
org.apache.calcite.rel.type.RelDataType logicalType,
StreamQueryConfig queryConfig,
boolean withChangeFlag,
TypeInformation<A> tpe)
Translates a logical
RelNode into a DataStream . |
protected <A> DataStream<A> |
StreamTableEnvironment.translate(Table table,
StreamQueryConfig queryConfig,
boolean updatesAsRetraction,
boolean withChangeFlag,
TypeInformation<A> tpe)
Translates a
Table into a DataStream . |
protected DataStream<CRow> |
StreamTableEnvironment.translateToCRow(org.apache.calcite.rel.RelNode logicalPlan,
StreamQueryConfig queryConfig)
Translates a logical
RelNode plan into a DataStream of type CRow . |
Modifier and Type | Method and Description |
---|---|
<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<T> |
StreamTableEnvironment.toDataStream(Table table,
Class<T> clazz,
StreamQueryConfig queryConfig)
Deprecated.
This method only supports conversion of append-only tables. In order to
make this more explicit in the future, please use toAppendStream() instead.
|
<T> DataStream<T> |
StreamTableEnvironment.toDataStream(Table table,
TypeInformation<T> typeInfo,
StreamQueryConfig queryConfig)
Deprecated.
This method only supports conversion of append-only tables. In order to
make this more explicit in the future, please use toAppendStream() instead.
|
<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 |
---|---|
<T> DataStream<T> |
TableConversions.toAppendStream(StreamQueryConfig queryConfig,
TypeInformation<T> evidence$5)
Converts the given
Table into an append DataStream of a specified type. |
<T> DataStream<T> |
StreamTableEnvironment.toAppendStream(Table table,
StreamQueryConfig queryConfig,
TypeInformation<T> evidence$4)
Converts the given
Table into an append DataStream of a specified type. |
<T> DataStream<T> |
TableConversions.toDataStream(StreamQueryConfig queryConfig,
TypeInformation<T> evidence$3)
Deprecated.
This method only supports conversion of append-only tables. In order to make this more explicit in the future, please use toAppendStream() instead. Since .
|
<T> DataStream<T> |
StreamTableEnvironment.toDataStream(Table table,
StreamQueryConfig queryConfig,
TypeInformation<T> evidence$2)
Deprecated.
This method only supports conversion of append-only tables. In order to make this more explicit in the future, please use toAppendStream() instead. Since .
|
<T> DataStream<scala.Tuple2<Object,T>> |
TableConversions.toRetractStream(StreamQueryConfig queryConfig,
TypeInformation<T> evidence$7)
Converts the
Table to a DataStream of add and retract messages. |
<T> DataStream<scala.Tuple2<Object,T>> |
StreamTableEnvironment.toRetractStream(Table table,
StreamQueryConfig queryConfig,
TypeInformation<T> evidence$6)
Converts the given
Table into a DataStream of add and retract messages. |
Modifier and Type | Method and Description |
---|---|
static ProcessFunction<CRow,CRow> |
AggregateUtil.createBoundedOverProcessFunction(CodeGenerator generator,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType inputType,
TypeInformation<Row> inputTypeInfo,
scala.collection.Seq<TypeInformation<?>> inputFieldTypeInfo,
long precedingOffset,
StreamQueryConfig queryConfig,
boolean isRowsClause,
boolean isRowTimeType)
Create an
ProcessFunction for ROWS clause
bounded OVER window to evaluate final aggregate value. |
ProcessFunction<CRow,CRow> |
AggregateUtil$.createBoundedOverProcessFunction(CodeGenerator generator,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType inputType,
TypeInformation<Row> inputTypeInfo,
scala.collection.Seq<TypeInformation<?>> inputFieldTypeInfo,
long precedingOffset,
StreamQueryConfig queryConfig,
boolean isRowsClause,
boolean isRowTimeType)
Create an
ProcessFunction for ROWS clause
bounded OVER window to evaluate final aggregate value. |
static ProcessFunction<CRow,CRow> |
AggregateUtil.createGroupAggregateFunction(CodeGenerator generator,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType inputRowType,
scala.collection.Seq<TypeInformation<?>> inputFieldTypes,
int[] groupings,
StreamQueryConfig queryConfig,
boolean generateRetraction,
boolean consumeRetraction)
Create an
ProcessFunction for group (without
window) aggregate to evaluate final aggregate value. |
ProcessFunction<CRow,CRow> |
AggregateUtil$.createGroupAggregateFunction(CodeGenerator generator,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType inputRowType,
scala.collection.Seq<TypeInformation<?>> inputFieldTypes,
int[] groupings,
StreamQueryConfig queryConfig,
boolean generateRetraction,
boolean consumeRetraction)
Create an
ProcessFunction for group (without
window) aggregate to evaluate final aggregate value. |
static ProcessFunction<CRow,CRow> |
AggregateUtil.createUnboundedOverProcessFunction(CodeGenerator generator,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType inputType,
TypeInformation<Row> inputTypeInfo,
scala.collection.Seq<TypeInformation<?>> inputFieldTypeInfo,
StreamQueryConfig queryConfig,
boolean isRowTimeType,
boolean isPartitioned,
boolean isRowsClause)
Create an
ProcessFunction for unbounded OVER
window to evaluate final aggregate value. |
ProcessFunction<CRow,CRow> |
AggregateUtil$.createUnboundedOverProcessFunction(CodeGenerator generator,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType inputType,
TypeInformation<Row> inputTypeInfo,
scala.collection.Seq<TypeInformation<?>> inputFieldTypeInfo,
StreamQueryConfig queryConfig,
boolean isRowTimeType,
boolean isPartitioned,
boolean isRowsClause)
Create an
ProcessFunction for unbounded OVER
window to evaluate final aggregate value. |
Modifier and Type | Method and Description |
---|---|
StateCleaningCountTrigger |
StateCleaningCountTrigger$.of(StreamQueryConfig queryConfig,
long maxCount)
Create a
StateCleaningCountTrigger instance. |
static StateCleaningCountTrigger |
StateCleaningCountTrigger.of(StreamQueryConfig queryConfig,
long maxCount)
Create a
StateCleaningCountTrigger instance. |
Constructor and Description |
---|
StateCleaningCountTrigger(StreamQueryConfig queryConfig,
long maxCount) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.