Package | Description |
---|---|
org.apache.flink.streaming.api.operators | |
org.apache.flink.streaming.runtime.io | |
org.apache.flink.streaming.runtime.io.recovery | |
org.apache.flink.streaming.runtime.operators |
This package contains the operators that perform the stream transformations.
|
org.apache.flink.streaming.runtime.streamrecord | |
org.apache.flink.streaming.runtime.streamstatus | |
org.apache.flink.streaming.runtime.tasks |
This package contains classes that realize streaming tasks.
|
Class and Description |
---|
StreamStatusMaintainer
Interface that allows toggling the current
StreamStatus as well as retrieving it. |
Class and Description |
---|
StatusWatermarkValve
A
StatusWatermarkValve embodies the logic of how Watermark and StreamStatus are propagated to downstream outputs, given a set of one or multiple input channels
that continuously receive them. |
StreamStatus
A Stream Status element informs stream tasks whether or not they should continue to expect
records and watermarks from the input stream that sent them.
|
StreamStatusMaintainer
Interface that allows toggling the current
StreamStatus as well as retrieving it. |
StreamStatusProvider
Interface for retrieving the current
StreamStatus . |
Class and Description |
---|
StatusWatermarkValve
A
StatusWatermarkValve embodies the logic of how Watermark and StreamStatus are propagated to downstream outputs, given a set of one or multiple input channels
that continuously receive them. |
Class and Description |
---|
StreamStatusMaintainer
Interface that allows toggling the current
StreamStatus as well as retrieving it. |
Class and Description |
---|
StreamStatus
A Stream Status element informs stream tasks whether or not they should continue to expect
records and watermarks from the input stream that sent them.
|
Class and Description |
---|
StatusWatermarkValve.InputChannelStatus
An
InputChannelStatus keeps track of an input channel's last watermark, stream
status, and whether or not the channel's current watermark is aligned with the overall
watermark output from the valve. |
StreamStatus
A Stream Status element informs stream tasks whether or not they should continue to expect
records and watermarks from the input stream that sent them.
|
StreamStatusProvider
Interface for retrieving the current
StreamStatus . |
Class and Description |
---|
StreamStatus
A Stream Status element informs stream tasks whether or not they should continue to expect
records and watermarks from the input stream that sent them.
|
StreamStatusMaintainer
Interface that allows toggling the current
StreamStatus as well as retrieving it. |
StreamStatusProvider
Interface for retrieving the current
StreamStatus . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.