Type Members

1.  final case class CDCSequence(state: Seq[CDCState] = _root_.scala.Seq.empty, commitId: ByteString = _root_.com.google.protobuf.ByteString.EMPTY, commitTimestamp: Long = 0L, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[CDCSequence] with Product with Serializable

   A set of states that reflect changes in the current state

   A set of states that reflect changes in the current state

   state

   A set of states for merge and split cases; in the case of a new node or append, there will be one element here.

   commitId

   Meta information for debugging and metrics, shows which run the changes were pulled from

   commitTimestamp

   Run batch processing completion time

   Annotations

   @SerialVersionUID()

2.  final case class CDCState(vectorId: ByteString = _root_.com.google.protobuf.ByteString.EMPTY, prevVectorId: Option[ByteString] = _root_.scala.None, userId: Seq[ByteString] = _root_.scala.Seq.empty, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[CDCState] with Product with Serializable

   The state of a graph vertex, which is represented by the vector id

   The state of a graph vertex, which is represented by the vector id

   vectorId

   Vector UUID that will be used for ifas/ifvs identifier

   prevVectorId

   In cases of split or merge, this will contain the old vector uuid that needs to be removed from storage

   userId

   List of IFA/IFV that the vector id belongs to, and within which (in a bidirectional map) this id will need to be changed

   Annotations

   @SerialVersionUID()

3.  final case class VectorIdStateSnapshot(vectorId: ByteString = _root_.com.google.protobuf.ByteString.EMPTY, prevVectorId: Seq[ByteString] = _root_.scala.Seq.empty, userId: Seq[ByteString] = _root_.scala.Seq.empty, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[VectorIdStateSnapshot] with Product with Serializable

   The state we broadcast for streaming API Examples: Split: prev run: vector_id = 1; prev_vector_id = [ ]; user_id = [a, b, c, d, e] - original entity curr run: vector_id = 11; prev_vector_id = [1]; user_id = [a, b, c] - a message of split curr run: vector_id = 12; prev_vector_id = [1]; user_id = [d, e] - another message of split

   The state we broadcast for streaming API Examples: Split: prev run: vector_id = 1; prev_vector_id = [ ]; user_id = [a, b, c, d, e] - original entity curr run: vector_id = 11; prev_vector_id = [1]; user_id = [a, b, c] - a message of split curr run: vector_id = 12; prev_vector_id = [1]; user_id = [d, e] - another message of split

   Merge: prev run: vector_id = 11; prev_vector_id = [1]; user_id = [a, b] - original entity prev run: vector_id = 39; prev_vector_id = [3]; user_id = [e, f] - original entity curr run: vector_id = 45; prev_vector_id = [11, 39]; user_id = [a, b, e, f] - a message of merge

   Append: prev run: vector_id = 15; prev_vector_id = [1]; user_id = [a, b] - original entity curr run: vector_id = 15; prev_vector_id = [15]; user_id = [a, b, h] - a message of append

   Create: curr run: vector_id = 99; prev_vector_id = [ ]; user_id = [e, i, o] - a message of create

   vectorId

   An actual vector id

   prevVectorId

   List of previous vector ids, can be empty

   userId

   List of source ids (ifa/ifv/...), can't be empty

   Annotations

   @SerialVersionUID()