@Internal @Deprecated public class AccumulatingProcessingTimeWindowOperator<KEY,IN,OUT> extends AbstractAlignedProcessingTimeWindowOperator<KEY,IN,OUT,ArrayList<IN>,WindowFunction<IN,OUT,KEY,TimeWindow>>
AbstractStreamOperator.CountingOutput, AbstractStreamOperator.LatencyGauge
userFunction
chainingStrategy, config, latencyGauge, LOG, metrics, output
Constructor and Description |
---|
AccumulatingProcessingTimeWindowOperator(WindowFunction<IN,OUT,KEY,TimeWindow> function,
KeySelector<IN,KEY> keySelector,
TypeSerializer<KEY> keySerializer,
TypeSerializer<IN> valueSerializer,
long windowLength,
long windowSlide)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected AccumulatingKeyedTimePanes<IN,KEY,OUT> |
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, 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 AccumulatingProcessingTimeWindowOperator(WindowFunction<IN,OUT,KEY,TimeWindow> function, KeySelector<IN,KEY> keySelector, TypeSerializer<KEY> keySerializer, TypeSerializer<IN> valueSerializer, long windowLength, long windowSlide)
protected AccumulatingKeyedTimePanes<IN,KEY,OUT> createPanes(KeySelector<IN,KEY> keySelector, Function function)
createPanes
in class AbstractAlignedProcessingTimeWindowOperator<KEY,IN,OUT,ArrayList<IN>,WindowFunction<IN,OUT,KEY,TimeWindow>>
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.