Package | Description |
---|---|
org.apache.flink.streaming.api.graph | |
org.apache.flink.streaming.runtime.io | |
org.apache.flink.streaming.runtime.tasks |
This package contains classes that realize streaming tasks.
|
Modifier and Type | Class and Description |
---|---|
static class |
StreamConfig.NetworkInputConfig
A representation of a Network
StreamConfig.InputConfig . |
static class |
StreamConfig.SourceInputConfig
A serialized representation of an input.
|
Modifier and Type | Method and Description |
---|---|
StreamConfig.InputConfig[] |
StreamConfig.getInputs(ClassLoader cl) |
Modifier and Type | Method and Description |
---|---|
static boolean |
StreamConfig.requiresSorting(StreamConfig.InputConfig inputConfig) |
void |
StreamConfig.setInputs(StreamConfig.InputConfig... inputs) |
Modifier and Type | Method and Description |
---|---|
static StreamMultipleInputProcessor |
StreamMultipleInputProcessorFactory.create(TaskInvokable ownerTask,
CheckpointedInputGate[] checkpointedInputGates,
StreamConfig.InputConfig[] configuredInputs,
IOManager ioManager,
MemoryManager memoryManager,
TaskIOMetricGroup ioMetricGroup,
Counter mainOperatorRecordsIn,
MultipleInputStreamOperator<?> mainOperator,
WatermarkGauge[] inputWatermarkGauges,
StreamConfig streamConfig,
Configuration taskManagerConfig,
Configuration jobConfig,
ExecutionConfig executionConfig,
ClassLoader userClassloader,
OperatorChain<?,?> operatorChain,
InflightDataRescalingDescriptor inflightDataRescalingDescriptor,
java.util.function.Function<Integer,StreamPartitioner<?>> gatePartitioners,
TaskInfo taskInfo) |
Modifier and Type | Method and Description |
---|---|
protected void |
MultipleInputStreamTask.createInputProcessor(List<IndexedInputGate>[] inputGates,
StreamConfig.InputConfig[] inputs,
WatermarkGauge[] inputWatermarkGauges,
java.util.function.Function<Integer,StreamPartitioner<?>> gatePartitioners) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.