Package io.github.flink.gcp.connector.bigtable

package io.github.flink.gcp.connector.bigtable
Google Cloud Bigtable connector for Apache Flink.
  • Classes
    Class
    Description
    BigtableClientReaper
    Closes Bigtable data clients away from the task thread while keeping their physical lifetime bounded.
    BigtableCredentials
    Loads credentials for the Bigtable data and admin client families.
    BigtableDataClients
    How this connector points a BigtableDataClient at an instance: production over application-default credentials, production over a runtime-loaded service-account provider, or an emulator over a plaintext channel with no credentials.
    BigtableLineage
    Configured table identities shared by the Bigtable sources and sink families.
    BigtableMetricNames
    Every metric name this connector registers itself, in one place so that this file is the connector's inventory: what it reports can be read here without opening the writer.
    LazyBigtableDataClient
    A BigtableDataClient built on first use and closed once, held by a seam implementation that travels in the job graph.
    LengthPrefixedFields
    The length-prefixed fields the connector-owned TypeSerializers share: a byte string or a UTF-8 string as an int length followed by the bytes, and a non-negative int count.
    RowRanges
    The module's row-key range algebra: emptiness, containment, cutting, coalescing, intersection, truncation and the unsigned key comparison they all rest on, each defined once here.
    TableDestination
    A fully-qualified Bigtable table reference: project, instance and table.