Package | Description |
---|---|
org.apache.flink.runtime.io.network.api.writer | |
org.apache.flink.runtime.operators | |
org.apache.flink.runtime.operators.shipping | |
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 |
---|---|
class |
BroadcastRecordWriter<T extends IOReadableWritable>
A special record-oriented runtime result writer only for broadcast mode.
|
Modifier and Type | Method and Description |
---|---|
RecordWriter |
RecordWriterBuilder.build(ResultPartitionWriter writer) |
Modifier and Type | Field and Description |
---|---|
protected List<RecordWriter<?>> |
BatchTask.eventualOutputs
The output writers for the data that this task forwards to the next task.
|
Modifier and Type | Method and Description |
---|---|
static void |
BatchTask.clearWriters(List<RecordWriter<?>> writers) |
static <T> Collector<T> |
BatchTask.getOutputCollector(AbstractInvokable task,
TaskConfig config,
ClassLoader cl,
List<RecordWriter<?>> eventualOutputs,
int outputOffset,
int numOutputs)
Creates the
Collector for the given task, as described by the given configuration. |
static <T> Collector<T> |
BatchTask.initOutputs(AbstractInvokable containingTask,
ClassLoader cl,
TaskConfig config,
List<ChainedDriver<?,?>> chainedTasksTarget,
List<RecordWriter<?>> eventualOutputs,
ExecutionConfig executionConfig,
Map<String,Accumulator<?,?>> accumulatorMap)
Creates a writer for each output.
|
Modifier and Type | Method and Description |
---|---|
List<RecordWriter<SerializationDelegate<T>>> |
OutputCollector.getWriters()
List of writers that are associated with this output collector
|
Constructor and Description |
---|
OutputCollector(List<RecordWriter<SerializationDelegate<T>>> writers,
TypeSerializer<T> serializer)
Initializes the output collector with a set of writers.
|
Constructor and Description |
---|
RecordWriterOutput(RecordWriter<SerializationDelegate<StreamRecord<OUT>>> recordWriter,
TypeSerializer<OUT> outSerializer,
OutputTag outputTag,
StreamStatusProvider streamStatusProvider) |
Modifier and Type | Method and Description |
---|---|
static <OUT> List<RecordWriter<SerializationDelegate<StreamRecord<OUT>>>> |
StreamTask.createRecordWriters(StreamConfig configuration,
Environment environment) |
Constructor and Description |
---|
OperatorChain(StreamTask<OUT,OP> containingTask,
List<RecordWriter<SerializationDelegate<StreamRecord<OUT>>>> recordWriters) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.