Package org.apache.beam.sdk.io.gcp.spanner.changestreams.model

Class ChildPartition

java.lang.Object
org.apache.beam.sdk.io.gcp.spanner.changestreams.model.ChildPartition
All Implemented Interfaces:
Serializable
@DefaultCoder(AvroCoder.class) public class ChildPartition extends Object implements Serializable
A child partition represents a new partition that should be queried. Child partitions are emitted in ChildPartitionsRecord.
See Also:

  • Constructor Details

    • ChildPartition

      public ChildPartition(String token, HashSet<String> parentTokens)
      Constructs a child partition, which will have its own token and the parents that it originated from. A child partition will have a single parent if it is originated from a partition move or split. A child partition will have multiple parents if it is originated from a partition merge.
      Parameters:
      token - the child partition token
      parentTokens - the partition tokens of the parent(s) that originated the child partition

    • ChildPartition

      public ChildPartition(String token, String parentToken)
      Constructs a child partition, which will have its own token and the parent that it originated from. Use this constructor for child partitions with a single parent (generated from a move or split). If a child partition has multiple parents use the constructor ChildPartition(java.lang.String,java.util.HashSet<java.lang.String>).
      Parameters:
      token - the child partition token
      parentToken - the partition tokens of the parent that originated the child partition

  • Method Details

    • getToken

      public String getToken()
      Unique partition identifier, which can be used to perform a change stream query.
      Returns:
      the unique partition identifier

    • getParentTokens

      public HashSet<String> getParentTokens()
      The unique partition identifiers of the parent partitions where this child partition originated from.
      Returns:
      a set of parent partition tokens

    • equals

      public boolean equals(@Nullable 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