Package | Description |
---|---|
org.apache.flink.streaming.runtime.io | |
org.apache.flink.streaming.runtime.streamstatus | |
org.apache.flink.streaming.runtime.tasks |
This package contains classes that realize streaming tasks.
|
Constructor and Description |
---|
RecordWriterOutput(RecordWriter<SerializationDelegate<StreamRecord<OUT>>> recordWriter,
TypeSerializer<OUT> outSerializer,
OutputTag outputTag,
StreamStatusProvider streamStatusProvider) |
Modifier and Type | Interface and Description |
---|---|
interface |
StreamStatusMaintainer
Interface that allows toggling the current
StreamStatus as well as retrieving it. |
Modifier and Type | Class and Description |
---|---|
class |
OperatorChain<OUT,OP extends StreamOperator<OUT>>
The
OperatorChain contains all operators that are executed as one chain within a single
StreamTask . |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.