Package | Description |
---|---|
org.apache.flink.state.api.output.operators | |
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.tasks |
This package contains classes that realize streaming tasks.
|
org.apache.flink.streaming.runtime.watermarkstatus | |
org.apache.flink.table.runtime.operators.multipleinput.input | |
org.apache.flink.table.runtime.operators.multipleinput.output | |
org.apache.flink.table.runtime.operators.wmassigners |
Class and Description |
---|
WatermarkStatus
A Watermark Status element informs stream tasks whether or not they should continue to expect
watermarks from the input stream that sent them.
|
Class and Description |
---|
WatermarkStatus
A Watermark Status element informs stream tasks whether or not they should continue to expect
watermarks from the input stream that sent them.
|
Class and Description |
---|
StatusWatermarkValve
A
StatusWatermarkValve embodies the logic of how Watermark and WatermarkStatus are propagated to downstream outputs, given a set of one or multiple input
channels that continuously receive them. |
WatermarkStatus
A Watermark Status element informs stream tasks whether or not they should continue to expect
watermarks from the input stream that sent them.
|
Class and Description |
---|
StatusWatermarkValve
A
StatusWatermarkValve embodies the logic of how Watermark and WatermarkStatus are propagated to downstream outputs, given a set of one or multiple input
channels that continuously receive them. |
Class and Description |
---|
WatermarkStatus
A Watermark Status element informs stream tasks whether or not they should continue to expect
watermarks from the input stream that sent them.
|
Class and Description |
---|
WatermarkStatus
A Watermark Status element informs stream tasks whether or not they should continue to expect
watermarks from the input stream that sent them.
|
Class and Description |
---|
WatermarkStatus
A Watermark Status element informs stream tasks whether or not they should continue to expect
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. |
WatermarkStatus
A Watermark Status element informs stream tasks whether or not they should continue to expect
watermarks from the input stream that sent them.
|
Class and Description |
---|
WatermarkStatus
A Watermark Status element informs stream tasks whether or not they should continue to expect
watermarks from the input stream that sent them.
|
Class and Description |
---|
WatermarkStatus
A Watermark Status element informs stream tasks whether or not they should continue to expect
watermarks from the input stream that sent them.
|
Class and Description |
---|
WatermarkStatus
A Watermark Status element informs stream tasks whether or not they should continue to expect
watermarks from the input stream that sent them.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.