WindowOperator
. This was an
optimized implementation used for aligned windows.@Internal @Deprecated public class AggregatingProcessingTimeWindowOperator<KEY,IN> extends AbstractAlignedProcessingTimeWindowOperator<KEY,IN,IN,IN,ReduceFunction<IN>>
AbstractStreamOperator.CountingOutput, AbstractStreamOperator.LatencyGauge
userFunction
chainingStrategy, config, latencyGauge, LOG, metrics, output
Constructor and Description |
---|
AggregatingProcessingTimeWindowOperator(ReduceFunction<IN> function,
KeySelector<IN,KEY> keySelector,
TypeSerializer<KEY> keySerializer,
TypeSerializer<IN> aggregateSerializer,
long windowLength,
long windowSlide)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected AggregatingKeyedTimePanes<IN,KEY> |
createPanes(KeySelector<IN,KEY> keySelector,
Function function)
Deprecated.
|
close, dispose, getNextEvaluationTime, getNextSlideTime, getNumPanesPerWindow, getPaneSize, getWindowSize, getWindowSlide, onProcessingTime, open, processElement, restoreState, snapshotState, toString
getUserFunction, getUserFunctionParameters, initializeState, notifyOfCompletedCheckpoint, setOutputType, setup, snapshotState
getChainingStrategy, getContainingTask, getCurrentKey, getExecutionConfig, getInternalTimerService, getKeyedStateBackend, getKeyedStateStore, getMetricGroup, getOperatorConfig, getOperatorName, getOperatorStateBackend, getOrCreateKeyedState, getPartitionedState, getPartitionedState, getProcessingTimeService, getRuntimeContext, getUserCodeClassloader, initializeState, numEventTimeTimers, numProcessingTimeTimers, processLatencyMarker, processLatencyMarker1, processLatencyMarker2, processWatermark, processWatermark1, processWatermark2, reportOrForwardLatencyMarker, setChainingStrategy, setCurrentKey, setKeyContextElement1, setKeyContextElement2, snapshotLegacyOperatorState, snapshotState
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
processLatencyMarker, processWatermark
getChainingStrategy, getMetricGroup, initializeState, notifyOfCompletedCheckpoint, setChainingStrategy, setKeyContextElement1, setKeyContextElement2, setup, snapshotLegacyOperatorState, snapshotState
public AggregatingProcessingTimeWindowOperator(ReduceFunction<IN> function, KeySelector<IN,KEY> keySelector, TypeSerializer<KEY> keySerializer, TypeSerializer<IN> aggregateSerializer, long windowLength, long windowSlide)
protected AggregatingKeyedTimePanes<IN,KEY> createPanes(KeySelector<IN,KEY> keySelector, Function function)
createPanes
in class AbstractAlignedProcessingTimeWindowOperator<KEY,IN,IN,IN,ReduceFunction<IN>>
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.