Interface StreamGraphHasher
-
- All Known Implementing Classes:
StreamGraphHasherV2
,StreamGraphUserHashHasher
public interface StreamGraphHasher
Interface for different implementations of generating hashes over a stream graph.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description Map<Integer,byte[]>
traverseStreamGraphAndGenerateHashes(StreamGraph streamGraph)
Returns a map with a hash for eachStreamNode
of theStreamGraph
.
-
-
-
Method Detail
-
traverseStreamGraphAndGenerateHashes
Map<Integer,byte[]> traverseStreamGraphAndGenerateHashes(StreamGraph streamGraph)
Returns a map with a hash for eachStreamNode
of theStreamGraph
. The hash is used as theJobVertexID
in order to identify nodes across job submissions if they didn't change.
-
-