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

MetadataQuerier

interface MetadataQuerier : AutoCloseable

An abstraction for a catalog discovery session.

Types

Link copied to clipboard
fun interface Factory<T : SourceConfiguration>

Factory for MetadataQuerier instances.

Functions

Link copied to clipboard
abstract fun close()
Link copied to clipboard
abstract fun extraChecks()

Executes extra checks which throw a io.airbyte.cdk.ConfigErrorException on failure.

Link copied to clipboard
abstract fun fields(streamID: StreamIdentifier): List<Field>

Returns all available fields in the given stream.

Link copied to clipboard
abstract fun primaryKey(streamID: StreamIdentifier): List<List<String>>

Returns the primary key for the given stream, if it exists; empty list otherwise.

Link copied to clipboard
abstract fun streamNames(streamNamespace: String?): List<StreamIdentifier>

Returns all available stream names in the given namespace.

Link copied to clipboard
abstract fun streamNamespaces(): List<String>

Returns all available namespaces.