public class IterativeStreamingWindowedCompute extends ProcessWindow<double[]>
allowedLateness, collectiveEvents, collectiveOutput, DEFAULT_MAX_LAG, DEFAULT_WATERMARK_INTERVAL, evictionPolicy, iTimestampExtractor, iWindow, maxLagMs, watermarkEventGenerator, watermarkInterval, windowingPolicy, windowLifeCycleListener, windowManager, windowParameter
Constructor and Description |
---|
IterativeStreamingWindowedCompute(ProcessWindowedFunction<double[]> processWindowedFunction) |
IterativeStreamingWindowedCompute(ProcessWindowedFunction<double[]> processWindowedFunction,
OperationMode operationMode) |
IterativeStreamingWindowedCompute(ProcessWindowedFunction<double[]> processWindowedFunction,
OperationMode operationMode,
SVMJobParameters svmJobParameters,
BinaryBatchModel binaryBatchModel) |
IterativeStreamingWindowedCompute(ProcessWindowedFunction<double[]> processWindowedFunction,
OperationMode operationMode,
SVMJobParameters svmJobParameters,
BinaryBatchModel binaryBatchModel,
java.lang.String modelName) |
Modifier and Type | Method and Description |
---|---|
void |
prepare(Config cfg,
TaskContext ctx)
Prepare the task to be executed
|
boolean |
process(IWindowMessage<double[]> windowMessage) |
boolean |
processLateMessages(IMessage<double[]> lateMessage) |
execute, getExpire, getLateMessages
close, execute, getEvictionPolicy, getWindowingPolicy, initialize, isTimestamped, newWindowLifeCycleListener, reset, setPolicies, start, withAllowedLateness, withCustomTimestampExtractor, withSlidingCountWindow, withSlidingDurationWindow, withTimestampExtractor, withTumblingCountWindow, withTumblingDurationWindow, withWatermarkInterval, withWindow
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
endExecute
public IterativeStreamingWindowedCompute(ProcessWindowedFunction<double[]> processWindowedFunction, OperationMode operationMode)
public IterativeStreamingWindowedCompute(ProcessWindowedFunction<double[]> processWindowedFunction, OperationMode operationMode, SVMJobParameters svmJobParameters, BinaryBatchModel binaryBatchModel)
public IterativeStreamingWindowedCompute(ProcessWindowedFunction<double[]> processWindowedFunction, OperationMode operationMode, SVMJobParameters svmJobParameters, BinaryBatchModel binaryBatchModel, java.lang.String modelName)
public IterativeStreamingWindowedCompute(ProcessWindowedFunction<double[]> processWindowedFunction)
public void prepare(Config cfg, TaskContext ctx)
INode
prepare
in interface INode
prepare
in class BaseWindowedSink<double[]>
cfg
- the configurationctx
- the task context, this has runtime information about the taskpublic boolean process(IWindowMessage<double[]> windowMessage)
process
in class ProcessWindow<double[]>
public boolean processLateMessages(IMessage<double[]> lateMessage)
processLateMessages
in class ProcessWindow<double[]>