Interface | Description |
---|---|
StreamGraphHasher |
Interface for different implementations of generating hashes over a stream graph.
|
Class | Description |
---|---|
JSONGenerator |
Helper class for generating a JSON representation from a
StreamGraph . |
StreamConfig |
Internal configuration for a
StreamOperator . |
StreamEdge |
An edge in the streaming topology.
|
StreamGraph |
Class representing the streaming topology.
|
StreamGraphGenerator |
A generator that generates a
StreamGraph from a graph of
StreamTransformations . |
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.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.