Package io.github.flink.gcp.connector.datastore

package io.github.flink.gcp.connector.datastore
Google Cloud Firestore in Datastore mode connector for Apache Flink (datastore.v1).

This package root shares its module with the Native-mode connector under io.github.flink.gcp.connector.firestore and nothing else beyond the base module: a database in Datastore mode is reached through its own client library and API.

  • Classes
    Class
    Description
    DatabaseDestination
    A Firestore database in Datastore mode: a project and a database id.
    DatastoreClients
    Builds the Datastore client every direction of the Datastore-mode connector opens.
    DatastoreCredentials
    Loads the credentials every direction of the Datastore-mode connector opens its client with.
    DatastoreLineage
    The lineage identity of a kind, shared by the source and the table sink so that both report the same resource for it: the Datastore API names the default database with the empty id, and lineage spells it "(default)".
    DatastoreMetricNames
    Every metric name the Datastore-mode 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.
    LazyDatastoreClient
    A Datastore client built on first use and closed once, held by a seam implementation of the source: the enumerator's planner and the readers' page reader.
    PropertyPaths
    The Datastore API's PropertyMask path grammar, shared by the lookup's mask and a merge's: a path is property names joined by dots, and a name holding a dot or a backslash must be escaped (datastore.proto).