Package io.github.flink.gcp.connector.bigquery.source

package io.github.flink.gcp.connector.bigquery.source

Related Packages

Package	Description
io.github.flink.gcp.connector.bigquery	Google BigQuery connector for Apache Flink.
io.github.flink.gcp.connector.bigquery.source.enumerator
io.github.flink.gcp.connector.bigquery.source.query
io.github.flink.gcp.connector.bigquery.source.reader
io.github.flink.gcp.connector.bigquery.source.serializer
io.github.flink.gcp.connector.bigquery.source.split

Classes

Class	Description
BigQueryReadClients	Storage Read API clients, for the two places the source opens one: the enumerator creates the read session, and every reader opens its assigned streams.
BigQuerySource	A bounded source reading a BigQuery table through the Storage Read API.
BigQuerySourceBuilder<T>	Builds a BigQuerySource.
BigQuerySourceConfig<T>	Everything the source's enumerator and readers were configured with, as one immutable object shipped inside the job graph.
BigQueryStorageReadSource<T>	Reads a BigQuery table through the Storage Read API.