Package | Description |
---|---|
org.apache.flink.api.java | |
org.apache.flink.cep.operator | |
org.apache.flink.streaming.api.collector.selector | |
org.apache.flink.streaming.api.environment | |
org.apache.flink.streaming.api.graph | |
org.apache.flink.streaming.api.operators | |
org.apache.flink.streaming.api.operators.async | |
org.apache.flink.streaming.runtime.tasks |
This package contains classes that realize streaming tasks.
|
Class and Description |
---|
StreamGraph
Class representing the streaming topology.
|
Class and Description |
---|
StreamConfig
Internal configuration for a
StreamOperator . |
Class and Description |
---|
StreamEdge
An edge in the streaming topology.
|
Class and Description |
---|
StreamGraph
Class representing the streaming topology.
|
Class and Description |
---|
StreamConfig
Internal configuration for a
StreamOperator . |
StreamEdge
An edge in the streaming topology.
|
StreamGraph
Class representing the streaming topology.
|
StreamGraphHasher
Interface for different implementations of generating hashes over a stream graph.
|
StreamNode
Class representing the operators in the streaming programs, with all their properties.
|
Class and Description |
---|
StreamConfig
Internal configuration for a
StreamOperator . |
Class and Description |
---|
StreamConfig
Internal configuration for a
StreamOperator . |
Class and Description |
---|
StreamConfig
Internal configuration for a
StreamOperator . |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.