Package | Description |
---|---|
org.apache.flink.table.codegen | |
org.apache.flink.table.runtime | |
org.apache.flink.table.runtime.aggregate | |
org.apache.flink.table.runtime.io |
Modifier and Type | Class and Description |
---|---|
class |
ExpressionReducer
Evaluates constant expressions using Flink's
CodeGenerator . |
Modifier and Type | Class and Description |
---|---|
class |
CorrelateFlatMapRunner<IN,OUT> |
class |
CRowCorrelateProcessRunner
A CorrelateProcessRunner with
CRow input and CRow output. |
class |
CRowInputJavaTupleOutputMapRunner
Convert
CRow to a JTuple2 |
class |
CRowInputMapRunner<OUT>
MapRunner with
CRow input. |
class |
CRowInputScalaTupleOutputMapRunner
Convert
CRow to a Tuple2 |
class |
CRowOutputMapRunner
MapRunner with
CRow output. |
class |
CRowProcessRunner
ProcessRunner with
CRow input and CRow output. |
class |
FlatJoinRunner<IN1,IN2,OUT> |
class |
FlatMapRunner |
class |
MapJoinLeftRunner<IN1,IN2,OUT> |
class |
MapJoinRightRunner<IN1,IN2,OUT> |
class |
MapRunner<IN,OUT> |
class |
MapSideJoinRunner<IN1,IN2,SINGLE_IN,MULTI_IN,OUT> |
Modifier and Type | Class and Description |
---|---|
class |
AggregateAggFunction
Aggregate Function used for the aggregate operator in
WindowedStream |
class |
DataSetAggFunction
RichGroupReduceFunction to compute aggregates that do not support pre-aggregation for batch
(DataSet) queries. |
class |
DataSetFinalAggFunction
RichGroupReduceFunction to compute the final result of a pre-aggregated aggregation
for batch (DataSet) queries. |
class |
DataSetPreAggFunction
GroupCombineFunction and MapPartitionFunction to compute pre-aggregates for batch
(DataSet) queries. |
class |
DataSetSessionWindowAggReduceGroupFunction
It wraps the aggregate logic inside of
GroupReduceOperator . |
class |
DataSetSessionWindowAggregatePreProcessor
This wraps the aggregate logic inside of
GroupCombineOperator . |
class |
DataSetSlideTimeWindowAggReduceGroupFunction
It is used for sliding windows on batch for time-windows.
|
class |
DataSetSlideWindowAggReduceCombineFunction
Wraps the aggregate logic inside of
GroupReduceOperator and
GroupCombineOperator . |
class |
DataSetSlideWindowAggReduceGroupFunction
It wraps the aggregate logic inside of
GroupReduceOperator . |
class |
DataSetTumbleCountWindowAggReduceGroupFunction
It wraps the aggregate logic inside of
GroupReduceOperator . |
class |
DataSetTumbleTimeWindowAggReduceCombineFunction
It wraps the aggregate logic inside of
GroupReduceOperator and
GroupCombineOperator . |
class |
DataSetTumbleTimeWindowAggReduceGroupFunction
It wraps the aggregate logic inside of
GroupReduceOperator . |
class |
DataSetWindowAggMapFunction
This map function only works for windows on batch tables.
|
class |
GroupAggProcessFunction
Aggregate Function used for the groupby (without window) aggregate
|
class |
ProcTimeBoundedRangeOver
Process Function used for the aggregate in bounded proc-time OVER window
DataStream |
class |
ProcTimeBoundedRowsOver
Process Function for ROW clause processing-time bounded OVER window
|
class |
ProcTimeUnboundedOver
Process Function for processing-time unbounded OVER window
|
class |
RowTimeBoundedRangeOver
Process Function for RANGE clause event-time bounded OVER window
|
class |
RowTimeBoundedRowsOver
Process Function for ROWS clause event-time bounded OVER window
|
class |
RowTimeUnboundedOver
A ProcessFunction to support unbounded event-time over-window
|
class |
RowTimeUnboundedRangeOver
A ProcessFunction to support unbounded RANGE window.
|
class |
RowTimeUnboundedRowsOver
A ProcessFunction to support unbounded ROWS window.
|
Modifier and Type | Class and Description |
---|---|
class |
CRowValuesInputFormat |
class |
ValuesInputFormat |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.