bulk-cdk-toolkit-load-fusion/io.airbyte.cdk.fusion/FusionPaths

FusionPaths

object FusionPaths(source)

A run owns its schema, completion marker, and all batch objects.

Functions

escape

@JvmStatic

fun escape(name: String): String

run

@JvmStatic

fun run(config: FusionConfiguration, namespace: String?, streamName: String, runId: UUID, epochSeconds: Long): String

Namespace-aware run path. Null and empty namespaces have distinct sentinel components; nonempty namespaces escape literal tildes so they cannot collide with those sentinels.