Module big_query 

Structs

BigQueryCommon

BigQueryConfig

BigQueryFutureManager 🔒

BigQueryLogSinker

BigQuerySink

BigQuerySinkWriter

ChangeSequenceClock 🔒

Hands out _CHANGE_SEQUENCE_NUMBERs as {physical:X}/{logical:X}, with the wall clock in microseconds as physical. Each number is greater than any reserved before from the same clock, even if the wall clock moves back.

StorageWriterClient 🔒

Constants

BIGQUERY_SEND_FUTURE_BUFFER_MAX_SIZE 🔒

BIGQUERY_SINK

CHANGE_SEQUENCE_NUMBER

CHANGE_TYPE

CONNECTION_TIMEOUT 🔒

CONNECT_TIMEOUT 🔒

DEFAULT_GRPC_CHANNEL_NUMS 🔒

MAX_ROW_SIZE 🔒

Statics

CHANGE_SEQUENCE_CLOCK 🔒

Shared by all writers in the process, so that the numbers keep increasing when a writer is rebuilt or a key moves to another actor in the process.

Functions

build_protobuf_descriptor_pool 🔒

build_protobuf_field 🔒

build_protobuf_schema 🔒

resp_to_stream