Skip to content

OffsetSeqMetadata — Metadata of Streaming Batch

OffsetSeqMetadata holds the metadata for the current streaming batch:

OffsetSeqMetadata is used mainly when IncrementalExecution is created.

[[relevantSQLConfs]] OffsetSeqMetadata considers some configuration properties as relevantSQLConfs:

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

Creating OffsetSeqMetadata

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

apply...FIXME

apply is used when...FIXME

=== [[setSessionConf]] setSessionConf Method

[source, scala]

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

setSessionConf...FIXME

NOTE: setSessionConf is used when...FIXME