Airbyte Kotlin Bulk CDK

0.1.92

bulk-cdk-core-extract/io.airbyte.cdk.discover

Package-level declarations

Types

AirbyteStreamFactory

interface AirbyteStreamFactory

Stateless object for building an AirbyteStream during DISCOVER.

CdcIntegerMetaFieldType

data object CdcIntegerMetaFieldType : LosslessFieldType

CdcNumberMetaFieldType

data object CdcNumberMetaFieldType : LosslessFieldType

CdcOffsetDateTimeMetaFieldType

data object CdcOffsetDateTimeMetaFieldType : LosslessFieldType

CdcOffsetDateTimeStringMetaFieldType

data object CdcOffsetDateTimeStringMetaFieldType : LosslessFieldType

CdcStringMetaFieldType

data object CdcStringMetaFieldType : LosslessFieldType

CommonMetaField

enum CommonMetaField : Enum<CommonMetaField> , MetaField

Convenience enum listing the MetaFields which are generated by all connectors.

DiscoveredStream

data class DiscoveredStream(val id: StreamIdentifier, val columns: List<Field>, val primaryKeyColumnIDs: List<List<String>>)

DiscoverOperation

@Singleton

@Requires(property = "airbyte.connector.operation", value = "discover")

@Requires(env = ["source"])

class DiscoverOperation(val config: SourceConfiguration, val metadataQuerierFactory: MetadataQuerier.Factory<SourceConfiguration>, val airbyteStreamFactory: AirbyteStreamFactory, val outputConsumer: OutputConsumer) : Operation

data class Field(val id: String, val type: FieldType) : FieldOrMetaField

Internal equivalent of io.airbyte.protocol.models.Field for values which come from the source itself, instead of being generated by the connector during its operation.

FieldOrMetaField

sealed interface FieldOrMetaField

Internal equivalent of a io.airbyte.protocol.models.Field.

interface FieldType

Root of our own type hierarchy for Airbyte record fields.

LosslessFieldType

interface LosslessFieldType : FieldType

Subtype of FieldType for all FieldTypes whose Airbyte record values can be turned back into their original source values. This allows these values to be persisted in an Airbyte state message.

MetadataQuerier

interface MetadataQuerier : AutoCloseable

An abstraction for a catalog discovery session.

interface MetaField : FieldOrMetaField

Internal equivalent of io.airbyte.protocol.models.Field for values which are generated by the connector itself during its operation, instead of coming from the source.

MetaFieldDecorator

interface MetaFieldDecorator

MetaField schema definition and utilities, to be implemented by each source connector.