public class StreamGraphHasherV2 extends Object implements StreamGraphHasher
DO NOT MODIFY THIS CLASS
|Constructor and Description|
|Modifier and Type||Method and Description|
Returns a map with a hash for each
public Map<Integer,byte> traverseStreamGraphAndGenerateHashes(StreamGraph streamGraph)
StreamGraph. The hash is used as the
JobVertexIDin order to identify nodes across job submissions if they didn't change.
StreamGraph is traversed. The hash is either computed from the
transformation's user-specified id (see
Transformation.getUid()) or generated in a
The generated hash is deterministic with respect to:
StreamNode.idto hash as 16-byte array.
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.