Package | Description |
---|---|
org.apache.flink.streaming.api.datastream | |
org.apache.flink.streaming.api.graph | |
org.apache.flink.streaming.api.transformations | |
org.apache.flink.streaming.runtime.io | |
org.apache.flink.streaming.runtime.io.recovery | |
org.apache.flink.streaming.runtime.partitioner | |
org.apache.flink.streaming.runtime.tasks |
This package contains classes that realize streaming tasks.
|
org.apache.flink.table.runtime.partitioner |
Class and Description |
---|
StreamPartitioner
A special
ChannelSelector for use in streaming programs. |
Class and Description |
---|
StreamPartitioner
A special
ChannelSelector for use in streaming programs. |
Class and Description |
---|
StreamPartitioner
A special
ChannelSelector for use in streaming programs. |
Class and Description |
---|
StreamPartitioner
A special
ChannelSelector for use in streaming programs. |
Class and Description |
---|
StreamPartitioner
A special
ChannelSelector for use in streaming programs. |
Class and Description |
---|
ConfigurableStreamPartitioner
Interface for
StreamPartitioner which have to be configured with the maximum parallelism
of the stream transformation. |
StreamPartitioner
A special
ChannelSelector for use in streaming programs. |
Class and Description |
---|
StreamPartitioner
A special
ChannelSelector for use in streaming programs. |
Class and Description |
---|
StreamPartitioner
A special
ChannelSelector for use in streaming programs. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.