Package | Description |
---|---|
org.apache.flink.streaming.api.operators | |
org.apache.flink.streaming.runtime.io | |
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 |
---|
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–2020 The Apache Software Foundation. All rights reserved.