Airbyte Kotlin Bulk CDK

0.1.92

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

Package-level declarations

Types

interface Aggregate

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

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)