Airbyte Kotlin Bulk CDK

1.0.2

bulk-cdk-core-load/io.airbyte.cdk.load.dataflow.aggregate

Package-level declarations

Types

interface Aggregate

Represents a batch or aggregation of records to be loaded via bulk operations.

data class AggregateEntry(val key: StoreKey, val value: Aggregate, val partitionCountsHistogram: PartitionHistogram, val partitionBytesHistogram: PartitionHistogram, val stalenessTrigger: TimeTrigger, val recordCountTrigger: SizeTrigger, val estimatedBytesTrigger: SizeTrigger)

AggregateFactory

interface AggregateFactory

Factory interface for creating Aggregate instances.

class AggregateStore(aggFactory: AggregateFactory, config: AggregatePublishingConfig)

AggregateStoreFactory

class AggregateStoreFactory(aggFactory: AggregateFactory, aggregatePublishingConfig: AggregatePublishingConfig)

class SizeTrigger(size: Long)

typealias StoreKey = DestinationStream.Descriptor

class TimeTrigger(size: Long)