| Package | Description |
|---|---|
| org.apache.flink.streaming.runtime.io | |
| org.apache.flink.streaming.runtime.tasks |
This package contains classes that realize streaming tasks.
|
| Constructor and Description |
|---|
RecordWriterOutput(StreamRecordWriter<org.apache.flink.runtime.plugable.SerializationDelegate<StreamRecord<OUT>>> recordWriter,
org.apache.flink.api.common.typeutils.TypeSerializer<OUT> outSerializer,
org.apache.flink.util.OutputTag outputTag,
StreamStatusProvider streamStatusProvider) |
| Modifier and Type | Method and Description |
|---|---|
static <OUT> List<StreamRecordWriter<org.apache.flink.runtime.plugable.SerializationDelegate<StreamRecord<OUT>>>> |
StreamTask.createStreamRecordWriters(StreamConfig configuration,
org.apache.flink.runtime.execution.Environment environment) |
| Constructor and Description |
|---|
OperatorChain(StreamTask<OUT,OP> containingTask,
List<StreamRecordWriter<org.apache.flink.runtime.plugable.SerializationDelegate<StreamRecord<OUT>>>> streamRecordWriters) |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.