public class DataSetSlideTimeWindowAggFlatMapFunction extends RichFlatMapFunction<Row,Row> implements ResultTypeQueryable<Row>
param: windowSize window size of the sliding window param: windowSlide window slide of the sliding window param: returnType return type of this function
Constructor and Description |
---|
DataSetSlideTimeWindowAggFlatMapFunction(int timeFieldPos,
long windowSize,
long windowSlide,
TypeInformation<Row> returnType) |
Modifier and Type | Method and Description |
---|---|
void |
flatMap(Row record,
Collector<Row> out)
The core method of the FlatMapFunction.
|
TypeInformation<Row> |
getProducedType()
Gets the data type (as a
TypeInformation ) produced by this function or input format. |
close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext
public DataSetSlideTimeWindowAggFlatMapFunction(int timeFieldPos, long windowSize, long windowSlide, TypeInformation<Row> returnType)
public void flatMap(Row record, Collector<Row> out)
FlatMapFunction
flatMap
in interface FlatMapFunction<Row,Row>
flatMap
in class RichFlatMapFunction<Row,Row>
record
- The input value.out
- The collector for returning result values.public TypeInformation<Row> getProducedType()
ResultTypeQueryable
TypeInformation
) produced by this function or input format.getProducedType
in interface ResultTypeQueryable<Row>
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.