Modifier and Type | Method and Description |
---|---|
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 |
---|---|
DataStream<CRow> |
DataStreamOverAggregate.createBoundedAndCurrentRowOverWindow(StreamQueryConfig queryConfig,
CodeGenerator generator,
DataStream<CRow> inputDS,
boolean isRowTimeType,
boolean isRowsClause) |
DataStream<CRow> |
DataStreamOverAggregate.createUnboundedAndCurrentRowOverWindow(StreamQueryConfig queryConfig,
CodeGenerator generator,
DataStream<CRow> inputDS,
boolean isRowTimeType,
boolean isRowsClause) |
Modifier and Type | Method and Description |
---|---|
CRow |
CRowOutputMapRunner.map(Object in) |
CRow |
CRowWrappingCollector.outCRow() |
Modifier and Type | Method and Description |
---|---|
TypeInformation<CRow> |
CRowProcessRunner.getProducedType() |
TypeInformation<CRow> |
CRowCorrelateProcessRunner.getProducedType() |
TypeInformation<CRow> |
CRowOutputMapRunner.getProducedType() |
Collector<CRow> |
CRowWrappingCollector.out() |
TypeInformation<CRow> |
CRowProcessRunner.returnType() |
TypeInformation<CRow> |
CRowCorrelateProcessRunner.returnType() |
TypeInformation<CRow> |
CRowOutputMapRunner.returnType() |
Modifier and Type | Method and Description |
---|---|
Tuple2<Boolean,Object> |
CRowInputJavaTupleOutputMapRunner.map(CRow in) |
OUT |
CRowInputMapRunner.map(CRow in) |
scala.Tuple2<Object,Object> |
CRowInputScalaTupleOutputMapRunner.map(CRow in) |
void |
CRowProcessRunner.processElement(CRow in,
ProcessFunction.Context ctx,
Collector<CRow> out) |
void |
CRowCorrelateProcessRunner.processElement(CRow in,
ProcessFunction.Context ctx,
Collector<CRow> out) |
Modifier and Type | Method and Description |
---|---|
void |
CRowProcessRunner.processElement(CRow in,
ProcessFunction.Context ctx,
Collector<CRow> out) |
void |
CRowCorrelateProcessRunner.processElement(CRow in,
ProcessFunction.Context ctx,
Collector<CRow> out) |
Constructor and Description |
---|
CRowCorrelateProcessRunner(String processName,
String processCode,
String collectorName,
String collectorCode,
TypeInformation<CRow> returnType) |
CRowOutputMapRunner(String name,
String code,
TypeInformation<CRow> returnType) |
CRowProcessRunner(String name,
String code,
TypeInformation<CRow> returnType) |
Modifier and Type | Method and Description |
---|---|
protected CRow |
RowTimeUnboundedOver.output() |
Modifier and Type | Method and Description |
---|---|
static AllWindowFunction<Row,CRow,Window> |
AggregateUtil.createAggregationAllWindowFunction(LogicalWindow window,
int finalRowArity,
scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> properties)
Create an
AllWindowFunction for non-partitioned window aggregates. |
AllWindowFunction<Row,CRow,Window> |
AggregateUtil$.createAggregationAllWindowFunction(LogicalWindow window,
int finalRowArity,
scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> properties)
Create an
AllWindowFunction for non-partitioned window aggregates. |
static WindowFunction<Row,CRow,Tuple,Window> |
AggregateUtil.createAggregationGroupWindowFunction(LogicalWindow window,
int numGroupingKeys,
int numAggregates,
int finalRowArity,
scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> properties)
Create a
WindowFunction for group window aggregates. |
WindowFunction<Row,CRow,Tuple,Window> |
AggregateUtil$.createAggregationGroupWindowFunction(LogicalWindow window,
int numGroupingKeys,
int numAggregates,
int finalRowArity,
scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> properties)
Create a
WindowFunction for group window aggregates. |
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. |
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. |
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 scala.Tuple3<AggregateFunction<CRow,Row,Row>,RowTypeInfo,RowTypeInfo> |
AggregateUtil.createDataStreamAggregateFunction(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,
scala.collection.Seq<TypeInformation<?>> inputFieldTypeInfo,
org.apache.calcite.rel.type.RelDataType outputType,
int[] groupingKeys,
boolean needMerge) |
scala.Tuple3<AggregateFunction<CRow,Row,Row>,RowTypeInfo,RowTypeInfo> |
AggregateUtil$.createDataStreamAggregateFunction(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,
scala.collection.Seq<TypeInformation<?>> inputFieldTypeInfo,
org.apache.calcite.rel.type.RelDataType outputType,
int[] groupingKeys,
boolean needMerge) |
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. |
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. |
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. |
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. |
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 |
---|---|
void |
AggregateAggFunction.add(CRow value,
Row accumulatorRow) |
Row |
CRowTimeWindowPropertyCollector.getRow(CRow record) |
void |
RowTimeBoundedRangeOver.processElement(CRow inputC,
ProcessFunction.Context ctx,
Collector<CRow> out) |
void |
ProcTimeBoundedRowsOver.processElement(CRow inputC,
ProcessFunction.Context ctx,
Collector<CRow> out) |
void |
ProcTimeBoundedRangeOver.processElement(CRow input,
ProcessFunction.Context ctx,
Collector<CRow> out) |
void |
RowTimeBoundedRowsOver.processElement(CRow inputC,
ProcessFunction.Context ctx,
Collector<CRow> out) |
void |
GroupAggProcessFunction.processElement(CRow inputC,
ProcessFunction.Context ctx,
Collector<CRow> out) |
void |
ProcTimeUnboundedOver.processElement(CRow inputC,
ProcessFunction.Context ctx,
Collector<CRow> out) |
void |
RowTimeUnboundedOver.processElement(CRow inputC,
ProcessFunction.Context ctx,
Collector<CRow> out)
Puts an element from the input stream into state if it is not late.
|
Modifier and Type | Method and Description |
---|---|
void |
IncrementalAggregateAllTimeWindowFunction.apply(TimeWindow window,
Iterable<Row> records,
Collector<CRow> out) |
void |
IncrementalAggregateTimeWindowFunction.apply(Tuple key,
TimeWindow window,
Iterable<Row> records,
Collector<CRow> out) |
void |
IncrementalAggregateWindowFunction.apply(Tuple key,
W window,
Iterable<Row> records,
Collector<CRow> out)
Calculate aggregated values output by aggregate buffer, and set them into output
Row based on the mapping relation between intermediate aggregate data and output data.
|
void |
IncrementalAggregateAllWindowFunction.apply(W window,
Iterable<Row> records,
Collector<CRow> out)
Calculate aggregated values output by aggregate buffer, and set them into output
Row based on the mapping relation between intermediate aggregate data and output data.
|
void |
RowTimeBoundedRangeOver.onTimer(long timestamp,
ProcessFunction.OnTimerContext ctx,
Collector<CRow> out) |
void |
ProcTimeBoundedRowsOver.onTimer(long timestamp,
ProcessFunction.OnTimerContext ctx,
Collector<CRow> out) |
void |
ProcTimeBoundedRangeOver.onTimer(long timestamp,
ProcessFunction.OnTimerContext ctx,
Collector<CRow> out) |
void |
RowTimeBoundedRowsOver.onTimer(long timestamp,
ProcessFunction.OnTimerContext ctx,
Collector<CRow> out) |
void |
GroupAggProcessFunction.onTimer(long timestamp,
ProcessFunction.OnTimerContext ctx,
Collector<CRow> out) |
void |
ProcTimeUnboundedOver.onTimer(long timestamp,
ProcessFunction.OnTimerContext ctx,
Collector<CRow> out) |
void |
RowTimeUnboundedOver.onTimer(long timestamp,
ProcessFunction.OnTimerContext ctx,
Collector<CRow> out)
Called when a watermark arrived.
|
void |
RowTimeBoundedRangeOver.processElement(CRow inputC,
ProcessFunction.Context ctx,
Collector<CRow> out) |
void |
ProcTimeBoundedRowsOver.processElement(CRow inputC,
ProcessFunction.Context ctx,
Collector<CRow> out) |
void |
ProcTimeBoundedRangeOver.processElement(CRow input,
ProcessFunction.Context ctx,
Collector<CRow> out) |
void |
RowTimeBoundedRowsOver.processElement(CRow inputC,
ProcessFunction.Context ctx,
Collector<CRow> out) |
void |
GroupAggProcessFunction.processElement(CRow inputC,
ProcessFunction.Context ctx,
Collector<CRow> out) |
void |
ProcTimeUnboundedOver.processElement(CRow inputC,
ProcessFunction.Context ctx,
Collector<CRow> out) |
void |
RowTimeUnboundedOver.processElement(CRow inputC,
ProcessFunction.Context ctx,
Collector<CRow> out)
Puts an element from the input stream into state if it is not late.
|
void |
RowTimeUnboundedRangeOver.processElementsWithSameTimestamp(List<Row> curRowList,
Row lastAccumulator,
Collector<CRow> out) |
void |
RowTimeUnboundedRowsOver.processElementsWithSameTimestamp(List<Row> curRowList,
Row lastAccumulator,
Collector<CRow> out) |
abstract void |
RowTimeUnboundedOver.processElementsWithSameTimestamp(List<Row> curRowList,
Row lastAccumulator,
Collector<CRow> out)
Process the same timestamp datas, the mechanism is different between
rows and range window.
|
Modifier and Type | Method and Description |
---|---|
CRow |
CRowValuesInputFormat.nextRecord(CRow reuse) |
Modifier and Type | Method and Description |
---|---|
TypeInformation<CRow> |
CRowValuesInputFormat.getProducedType() |
TypeInformation<CRow> |
CRowValuesInputFormat.returnType() |
Modifier and Type | Method and Description |
---|---|
CRow |
CRowValuesInputFormat.nextRecord(CRow reuse) |
Constructor and Description |
---|
CRowValuesInputFormat(String name,
String code,
TypeInformation<CRow> returnType) |
Modifier and Type | Method and Description |
---|---|
CRow |
CRow$.apply() |
static CRow |
CRow.apply() |
CRow |
CRow$.apply(Row row,
boolean change) |
static CRow |
CRow.apply(Row row,
boolean change) |
CRow |
CRowSerializer.copy(CRow from) |
CRow |
CRowSerializer.copy(CRow from,
CRow reuse) |
CRow |
CRowSerializer.createInstance() |
CRow |
CRowSerializer.deserialize(CRow reuse,
DataInputView source) |
CRow |
CRowSerializer.deserialize(DataInputView source) |
CRow |
CRowComparator.readWithKeyDenormalization(CRow reuse,
DataInputView source) |
Modifier and Type | Method and Description |
---|---|
TypeComparator<CRow> |
CRowTypeInfo.createComparator(int[] logicalKeyFields,
boolean[] orders,
int logicalFieldOffset,
ExecutionConfig config) |
TypeSerializer<CRow> |
CRowTypeInfo.createSerializer(ExecutionConfig config) |
protected CompositeType.TypeComparatorBuilder<CRow> |
CRowTypeInfo.createTypeComparatorBuilder() |
TypeComparator<CRow> |
CRowComparator.duplicate() |
TypeSerializer<CRow> |
CRowSerializer.duplicate() |
CompatibilityResult<CRow> |
CRowSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
Modifier and Type | Method and Description |
---|---|
int |
CRowComparator.compare(CRow first,
CRow second) |
CRow |
CRowSerializer.copy(CRow from) |
CRow |
CRowSerializer.copy(CRow from,
CRow reuse) |
CRow |
CRowSerializer.deserialize(CRow reuse,
DataInputView source) |
boolean |
CRowComparator.equalToReference(CRow candidate) |
int |
CRowComparator.hash(CRow record) |
void |
CRowComparator.putNormalizedKey(CRow record,
MemorySegment target,
int offset,
int numBytes) |
CRow |
CRowComparator.readWithKeyDenormalization(CRow reuse,
DataInputView source) |
void |
CRowSerializer.serialize(CRow record,
DataOutputView target) |
void |
CRowComparator.setReference(CRow toCompare) |
void |
CRowComparator.writeWithKeyNormalization(CRow record,
DataOutputView target) |
Modifier and Type | Method and Description |
---|---|
int |
CRowComparator.compareToReference(TypeComparator<CRow> otherComp) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.