OffsetSeqMetadata — Metadata of Streaming Batch

OffsetSeqMetadata holds the metadata for the current streaming batch:

Note
OffsetSeqMetadata is used mainly when IncrementalExecution is created.

OffsetSeqMetadata considers some configuration properties as relevantSQLConfs:

relevantSQLConfs are used when OffsetSeqMetadata is created and is requested to setSessionConf.

Creating OffsetSeqMetadata — apply Factory Method

apply(
  batchWatermarkMs: Long,
  batchTimestampMs: Long,
  sessionConf: RuntimeConfig): OffsetSeqMetadata

apply…​FIXME

Note
apply is used when…​FIXME

setSessionConf Method

setSessionConf(metadata: OffsetSeqMetadata, sessionConf: RuntimeConfig): Unit

setSessionConf…​FIXME

Note
setSessionConf is used when…​FIXME

results matching ""

    No results matching ""