Package com.hazelcast.jet.core

Class BroadcastKey<K>

java.lang.Object
com.hazelcast.jet.core.BroadcastKey<K>
Type Parameters:
K - type of key
public final class BroadcastKey<K> extends Object
Marks a key in the snapshot state to indicate that the corresponding entry should be broadcast to all processors when restoring the snapshot.
Since:
Jet 3.0

  • Method Details

    • key

      @Nonnull public K key()
      Returns the underlying key

    • broadcastKey

      @Nonnull public static <K> BroadcastKey<K> broadcastKey(@Nonnull K key)
      Returns a given key as a broadcast key.

      Note: Several processor instances can use the returned BroadcastKey with the same key to store unique values and the values will not overwrite each other. Upon a snapshot restore, each processor will receive multiple key-value pairs with the given BroadcastKey

    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • toString

      public String toString()
      Overrides:
      toString in class Object