decorateRecordData

abstract fun decorateRecordData(timestamp: OffsetDateTime, globalStateValue: OpaqueStateValue?, stream: Stream, recordData: ObjectNode)

Modifies recordData by setting all MetaField values in global Stream feeds.

This is required by the fact that records of a given stream may be emitted by both a Stream and a Global feed and the schemas must be the same. This implies that the records emitted by Stream must have MetaFields set to suitable values, even though that Feed has no awareness of the Global state.

This method is called at most once per Stream.


abstract fun decorateRecordData(timestamp: OffsetDateTime, globalStateValue: OpaqueStateValue?, stream: Stream, recordData: NativeRecordPayload)