FusionMetadata

Shared run identity for the schema, completion marker, and S3 batch headers.

Constructors

constructor(config: FusionConfiguration, runId: UUID, epochSeconds: Long)

fun batch(streamKey: String, generationId: Long, syncId: Long, schemaId: String, recordCount: Long, batchId: UUID): Map<String, String>

fun schema(descriptor: Map<String, Any?>, schemaId: String, generationId: Long, syncId: Long): Map<String, Any?>

fun streamComplete(jobId: Long, minGenerationId: Long? = null): Map<String, Any>

The catalog sync ID is populated from the platform job ID.