public class StreamTwoInputProcessorFactory extends Object
StreamTwoInputProcessor
.Constructor and Description |
---|
StreamTwoInputProcessorFactory() |
Modifier and Type | Method and Description |
---|---|
static <IN1,IN2> StreamTwoInputProcessor<IN1,IN2> |
create(AbstractInvokable ownerTask,
CheckpointedInputGate[] checkpointedInputGates,
IOManager ioManager,
MemoryManager memoryManager,
TaskIOMetricGroup taskIOMetricGroup,
StreamStatusMaintainer streamStatusMaintainer,
TwoInputStreamOperator<IN1,IN2,?> streamOperator,
WatermarkGauge input1WatermarkGauge,
WatermarkGauge input2WatermarkGauge,
BoundedMultiInput endOfInputAware,
StreamConfig streamConfig,
Configuration taskManagerConfig,
Configuration jobConfig,
ExecutionConfig executionConfig,
ClassLoader userClassloader,
Counter numRecordsIn) |
public static <IN1,IN2> StreamTwoInputProcessor<IN1,IN2> create(AbstractInvokable ownerTask, CheckpointedInputGate[] checkpointedInputGates, IOManager ioManager, MemoryManager memoryManager, TaskIOMetricGroup taskIOMetricGroup, StreamStatusMaintainer streamStatusMaintainer, TwoInputStreamOperator<IN1,IN2,?> streamOperator, WatermarkGauge input1WatermarkGauge, WatermarkGauge input2WatermarkGauge, BoundedMultiInput endOfInputAware, StreamConfig streamConfig, Configuration taskManagerConfig, Configuration jobConfig, ExecutionConfig executionConfig, ClassLoader userClassloader, Counter numRecordsIn)
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.