Interface StreamGraphHasher

    • Method Detail

      • traverseStreamGraphAndGenerateHashes

        Map<Integer,​byte[]> traverseStreamGraphAndGenerateHashes​(StreamGraph streamGraph)
        Returns a map with a hash for each StreamNode of the StreamGraph. The hash is used as the JobVertexID in order to identify nodes across job submissions if they didn't change.