shared-proto
API
Generated with
shared-proto/io/io.bidmachine/io.bidmachine.protobuf/io.bidmachine.protobuf.vectorid/io.bidmachine.protobuf.vectorid.cdc.v1/CDCSequence

CDCSequence

io.bidmachine.protobuf.vectorid.cdc.v1.CDCSequence
See theCDCSequence companion object
final case class CDCSequence(state: Seq[CDCState], commitId: ByteString, commitTimestamp: Long, unknownFields: UnknownFieldSet) extends GeneratedMessage, Updatable[CDCSequence]

A grouped set of all operations that affect a cluster of related vector_ids in a single processing run.

Operations within state are ordered by type: DELETE → SPLIT → UNION → APPEND → ALIVE. All entries share connected vector_ids — if operation A references vector_id X and operation B references vector_id X (as either vector_id or prev_vector_id), they belong to the same CDCSequence.

Example — Ultimate scenario (one Kafka message): state = [ { operation: DELETE, prev_vector_id: a, user_id: [ifv_dead] }, { operation: SPLIT, vector_id: d, prev_vector_id: a, user_id: [ifv1] }, { operation: SPLIT, vector_id: e, prev_vector_id: b, user_id: [ifv3] }, { operation: UNION, vector_id: c, prev_vector_id: a, user_id: [ifv2] }, { operation: UNION, vector_id: c, prev_vector_id: b, user_id: [ifv4] }, { operation: APPEND, vector_id: c, user_id: [ifv_new] }, ]

Example — ALIVE heartbeat (separate message, no structural changes): state = [ { operation: ALIVE, vector_id: a }, ]

Value parameters

commitId

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

commitTimestamp

Run batch processing completion time

state

Chronologically ordered state changes (DELETE → SPLIT → UNION → APPEND → ALIVE)

Attributes

Companion
object
Graph
Supertypes
trait Updatable[CDCSequence]
trait GeneratedMessage
trait Serializable
trait Product
trait Equals
class Object
trait Matchable
class Any
Show all

Members list

Value members

Concrete methods

def addAllState(`__vs`: Iterable[CDCState]): CDCSequence
def addState(`__vs`: CDCState*): CDCSequence
def getField(`__field`: FieldDescriptor): PValue
def getFieldByNumber(`__fieldNumber`: Int): Any
override def serializedSize: Int

Attributes

Definition Classes
GeneratedMessage
def toProtoString: String

Returns a human-readable ASCII format representation of this message.

Returns a human-readable ASCII format representation of this message.

The original message can be decoded from this format by using fromAscii on the companion object.

Attributes

Returns

human-readable representation of this message.

def withCommitId(`__v`: ByteString): CDCSequence
def withCommitTimestamp(`__v`: Long): CDCSequence
def withState(`__v`: Seq[CDCState]): CDCSequence
def withUnknownFields(`__v`: UnknownFieldSet): CDCSequence
def writeTo(`_output__`: CodedOutputStream): Unit

Serializes the message into the given coded output stream

Serializes the message into the given coded output stream

Attributes

Inherited methods

def productElementNames: Iterator[String]

Attributes

Inherited from:
Product
def productIterator: Iterator[Any]

Attributes

Inherited from:
Product
final def toByteArray: Array[Byte]

Serializes the message and returns a byte array containing its raw bytes

Serializes the message and returns a byte array containing its raw bytes

Attributes

Inherited from:
GeneratedMessage
final def toByteString: ByteString

Serializes the message and returns a ByteString containing its raw bytes

Serializes the message and returns a ByteString containing its raw bytes

Attributes

Inherited from:
GeneratedMessage
final def toPMessage: PMessage

Attributes

Inherited from:
GeneratedMessage
def update(ms: Lens[CDCSequence, CDCSequence] => () => CDCSequence*): CDCSequence

Attributes

Inherited from:
Updatable
final def writeDelimitedTo(output: OutputStream): Unit

Attributes

Inherited from:
GeneratedMessage
final def writeTo(output: OutputStream): Unit

Serializes the message into the given output stream

Serializes the message into the given output stream

Attributes

Inherited from:
GeneratedMessage
Generated with