public class StreamTaskNetworkInputFactory extends Object
StreamTaskNetworkInput
and RescalingStreamTaskNetworkInput
.Constructor and Description |
---|
StreamTaskNetworkInputFactory() |
Modifier and Type | Method and Description |
---|---|
static <T> StreamTaskInput<T> |
create(CheckpointedInputGate checkpointedInputGate,
TypeSerializer<T> inputSerializer,
IOManager ioManager,
StatusWatermarkValve statusWatermarkValve,
int inputIndex,
InflightDataRescalingDescriptor rescalingDescriptorinflightDataRescalingDescriptor,
Function<Integer,StreamPartitioner<?>> gatePartitioners,
TaskInfo taskInfo,
StreamTask.CanEmitBatchOfRecordsChecker canEmitBatchOfRecords)
Factory method for
StreamTaskNetworkInput or RescalingStreamTaskNetworkInput
depending on InflightDataRescalingDescriptor . |
public static <T> StreamTaskInput<T> create(CheckpointedInputGate checkpointedInputGate, TypeSerializer<T> inputSerializer, IOManager ioManager, StatusWatermarkValve statusWatermarkValve, int inputIndex, InflightDataRescalingDescriptor rescalingDescriptorinflightDataRescalingDescriptor, Function<Integer,StreamPartitioner<?>> gatePartitioners, TaskInfo taskInfo, StreamTask.CanEmitBatchOfRecordsChecker canEmitBatchOfRecords)
StreamTaskNetworkInput
or RescalingStreamTaskNetworkInput
depending on InflightDataRescalingDescriptor
.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.