Package org.apache.flink.streaming.api.graph

Interface Summary

Interface	Description
StreamConfig.InputConfig	Interface representing chained inputs.
StreamGraphHasher	Interface for different implementations of generating hashes over a stream graph.
TransformationTranslator<OUT,T extends Transformation<OUT>>	A TransformationTranslator is responsible for translating a given Transformation to its runtime implementation depending on the execution mode.
TransformationTranslator.Context	A context giving the necessary information for the translation of a given transformation.

Class Summary

Class	Description
JSONGenerator	Helper class for generating a JSON representation from a StreamGraph.
NonChainedOutput	Used by operator chain and represents a non-chained output of the corresponding stream operator.
SimpleTransformationTranslator<OUT,T extends Transformation<OUT>>	A base class for all TransformationTranslators who translate Transformations that have a single operator in their runtime implementation.
StreamConfig	Internal configuration for a StreamOperator.
StreamConfig.NetworkInputConfig	A representation of a Network StreamConfig.InputConfig.
StreamConfig.SourceInputConfig	A serialized representation of an input.
StreamEdge	An edge in the streaming topology.
StreamGraph	Class representing the streaming topology.
StreamGraphGenerator	A generator that generates a StreamGraph from a graph of Transformations.
StreamGraphHasherV2	StreamGraphHasher from Flink 1.2.
StreamGraphUserHashHasher	StreamGraphHasher that works with user provided hashes.
StreamingJobGraphGenerator	The StreamingJobGraphGenerator converts a StreamGraph into a JobGraph.
StreamNode	Class representing the operators in the streaming programs, with all their properties.

Enum Summary

Enum	Description
GlobalStreamExchangeMode	This mode decides the default ResultPartitionType of job edges.
StreamConfig.InputRequirement	Requirements of the different inputs of an operator.