Constant Field Values

Contents

• io.github.*

io.github.*

io.github.flink.gcp.connector.base.metrics.DestinationMetrics

Modifier and Type	Constant Field	Value
public static final String	DESTINATION_GROUP	"destination"
public static final String	RECORDS_SEND	"recordsSend"
public static final String	SEND_ERRORS	"sendErrors"

io.github.flink.gcp.connector.base.metrics.ErrorClassCounters

Modifier and Type	Constant Field	Value
public static final String	ERROR_CLASS_GROUP	"errorClass"
public static final String	ERRORS	"errors"
public static final String	UNCLASSIFIED	"UNCLASSIFIED"

io.github.flink.gcp.connector.base.retry.RetrySchedule

Modifier and Type	Constant Field	Value
public static final double	DEFAULT_JITTER_RATIO	0.25

io.github.flink.gcp.connector.bigquery.BigQueryMetricNames

Modifier and Type	Constant Field	Value
public static final String	ACTIVE_COMMIT_DESTINATIONS	"activeCommitDestinations"
public static final String	APPEND_RETRIES	"appendRetries"
public static final String	BYTES_READ	"bytesRead"
public static final String	CAPACITY_EVICTIONS	"capacityEvictions"
public static final String	CURRENT_COMMIT_DURATION_MILLIS	"currentCommitDurationMillis"
public static final String	DESTINATION_ACTIVATIONS	"destinationActivations"
public static final String	FILES_STAGED	"filesStaged"
public static final String	IDLE_EVICTIONS	"idleEvictions"
public static final String	IN_FLIGHT_APPENDS	"inFlightAppends"
public static final String	IN_FLIGHT_BATCHES	"inFlightBatches"
public static final String	LAST_COMMIT_DURATION_MILLIS	"lastCommitDurationMillis"
public static final String	LOAD_JOBS_SUBMITTED	"loadJobsSubmitted"
public static final String	OPEN_DESTINATIONS	"openDestinations"
public static final String	PENDING_FILES	"pendingFiles"
public static final String	QUERY_JOBS_REATTACHED	"queryJobsReattached"
public static final String	QUERY_JOBS_SUBMITTED	"queryJobsSubmitted"
public static final String	QUEUED_COMMIT_DESTINATIONS	"queuedCommitDestinations"
public static final String	READ_RETRIES	"readRetries"
public static final String	READ_SESSIONS_CREATED	"readSessionsCreated"
public static final String	RECORDS_SKIPPED	"recordsSkipped"
public static final String	ROWS_READ	"rowsRead"
public static final String	SCHEMA_RECONCILIATIONS	"schemaReconciliations"
public static final String	SPLITS_ASSIGNED	"splitsAssigned"
public static final String	SPLITS_RETURNED	"splitsReturned"
public static final String	TABLES_CREATED	"tablesCreated"

io.github.flink.gcp.connector.bigquery.sink.fileloads.FileLoadsOptions

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_MAX_CONCURRENT_CHECKPOINT_FINALIZATIONS	1
public static final int	DEFAULT_MAX_CONCURRENT_DESTINATIONS	8
public static final int	DEFAULT_MAX_OPEN_DESTINATIONS	16
public static final int	DEFAULT_MAX_PENDING_FILES	10000
public static final long	DEFAULT_MAX_SERIALIZED_ROW_BYTES	15000000L
public static final long	DEFAULT_MAX_STAGING_FILE_BYTES	16777216L
public static final int	DEFAULT_SCHEMA_RECONCILE_MAX_ATTEMPTS	10

io.github.flink.gcp.connector.bigquery.sink.storage.BufferedStreamOptions

Modifier and Type	Constant Field	Value
public static final long	DEFAULT_MAX_APPEND_REQUEST_BYTES	524288L
public static final int	DEFAULT_RECOVERY_MAX_ATTEMPTS	10
public static final double	DEFAULT_RETRY_DELAY_MULTIPLIER	2.0
public static final int	DEFAULT_RETRY_MAX_ATTEMPTS	5

io.github.flink.gcp.connector.bigquery.sink.storage.DefaultStreamOptions

Modifier and Type	Constant Field	Value
public static final long	DEFAULT_MAX_APPEND_REQUEST_BYTES	524288L
public static final int	DEFAULT_MAX_CONNECTIONS_PER_REGION	20
public static final long	DEFAULT_MAX_INFLIGHT_BYTES	104857600L
public static final int	DEFAULT_MAX_INFLIGHT_REQUESTS	100
public static final int	DEFAULT_MIN_CONNECTIONS_PER_REGION	2
public static final int	DEFAULT_RECOVERY_MAX_ATTEMPTS	10
public static final double	DEFAULT_RETRY_DELAY_MULTIPLIER	2.0
public static final int	DEFAULT_RETRY_MAX_ATTEMPTS	5

io.github.flink.gcp.connector.bigquery.sink.storage.writer.BufferedStreamWriterState

Modifier and Type	Constant Field	Value
public static final String	NO_STREAM	""

io.github.flink.gcp.connector.bigquery.source.BigQuerySourceBuilder<T>

Modifier and Type	Constant Field	Value
public static final long	DEFAULT_MAX_BYTES_PER_FETCH	8388608L
public static final int	DEFAULT_MAX_RECORDS_PER_FETCH	10000
public static final int	DEFAULT_RETRY_MAX_ATTEMPTS	25

io.github.flink.gcp.connector.bigquery.source.split.ReadStreamSplitSerializer

Modifier and Type	Constant Field	Value
public static final int	VERSION_WITH_EXPIRY	2
public static final int	VERSION_WITHOUT_EXPIRY	1

io.github.flink.gcp.connector.bigquery.table.BigQueryDynamicTableFactory

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"bigquery"

io.github.flink.gcp.connector.bigtable.BigtableMetricNames

Modifier and Type	Constant Field	Value
public static final String	ACTIVE_CHANGE_STREAM_READS	"activeChangeStreamReads"
public static final String	ACTIVE_CLIENTS	"activeClients"
public static final String	CAPACITY_EVICTIONS	"capacityEvictions"
public static final String	CHANGE_STREAM_CLOSE_STREAMS_READ	"changeStreamCloseStreamsRead"
public static final String	CHANGE_STREAM_GARBAGE_COLLECTION_MUTATIONS_READ	"changeStreamGarbageCollectionMutationsRead"
public static final String	CHANGE_STREAM_HEARTBEATS_READ	"changeStreamHeartbeatsRead"
public static final String	CHANGE_STREAM_MUTATION_ENTRIES_FILTERED	"changeStreamMutationEntriesFiltered"
public static final String	CHANGE_STREAM_MUTATIONS_READ	"changeStreamMutationsRead"
public static final String	CHANGE_STREAM_PARTITION_MERGES	"changeStreamPartitionMerges"
public static final String	CHANGE_STREAM_PARTITION_SPLITS	"changeStreamPartitionSplits"
public static final String	CHANGE_STREAM_PARTITIONS_DISCOVERED	"changeStreamPartitionsDiscovered"
public static final String	CHANGE_STREAM_PARTITIONS_RECONCILED	"changeStreamPartitionsReconciled"
public static final String	CHANGE_STREAM_READS_STARTED	"changeStreamReadsStarted"
public static final String	CHANGE_STREAM_RECORDS_SKIPPED_WITHOUT_CHANGE	"changeStreamRecordsSkippedWithoutChange"
public static final String	CHANGE_STREAM_TOKENLESS_RESTARTS	"changeStreamTokenlessRestarts"
public static final String	CHANGE_STREAM_USER_MUTATIONS_READ	"changeStreamUserMutationsRead"
public static final String	COLUMN_FAMILIES_ADDED	"columnFamiliesAdded"
public static final String	IDLE_EVICTIONS	"idleEvictions"
public static final String	IN_FLIGHT_BYTES	"inFlightBytes"
public static final String	IN_FLIGHT_ENTRIES	"inFlightEntries"
public static final String	MISSED_HEARTBEAT_INTERVALS	"missedHeartbeatIntervals"
public static final String	PARKED_ENTRIES	"parkedEntries"
public static final String	PARTITION_LOW_WATERMARK_MILLIS	"partitionLowWatermarkMillis"
public static final String	QUEUED_CHANGE_STREAM_PARTITION_LAG_MILLIS	"queuedChangeStreamPartitionLagMillis"
public static final String	QUEUED_CHANGE_STREAM_PARTITIONS	"queuedChangeStreamPartitions"
public static final String	RECORDS_SKIPPED	"recordsSkipped"
public static final String	ROW_KEY_SAMPLES_TAKEN	"rowKeySamplesTaken"
public static final String	ROWS_READ	"rowsRead"
public static final String	SPLITS_ASSIGNED	"splitsAssigned"
public static final String	SPLITS_RETURNED	"splitsReturned"
public static final String	TABLES_CREATED	"tablesCreated"
public static final String	UNASSIGNED_CHANGE_STREAM_PARTITION_LAG_MILLIS	"unassignedChangeStreamPartitionLagMillis"

io.github.flink.gcp.connector.bigtable.sink.BigtableWriterOptions

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_MAX_ACTIVE_INSTANCES	16
public static final int	DEFAULT_MAX_CONSECUTIVE_REJECTIONS	100
public static final int	UNBOUNDED	-1

io.github.flink.gcp.connector.bigtable.source.BigtableChangeStreamSourceBuilder<T>

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_MAX_CONCURRENT_STREAMS_PER_SUBTASK	2

io.github.flink.gcp.connector.bigtable.source.BigtableSourceBuilder<T>

Modifier and Type	Constant Field	Value
public static final long	DEFAULT_MAX_BYTES_PER_FETCH	8388608L
public static final int	DEFAULT_MAX_ROWS_PER_FETCH	1000

io.github.flink.gcp.connector.bigtable.table.BigtableDynamicTableFactory

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"bigtable"

io.github.flink.gcp.connector.cloudtasks.CloudTasksMetricNames

Modifier and Type	Constant Field	Value
public static final String	IN_FLIGHT_TASKS	"inFlightTasks"
public static final String	PARKED_TASKS	"parkedTasks"
public static final String	RECORDS_SKIPPED	"recordsSkipped"
public static final String	TASKS_DEDUPLICATED	"tasksDeduplicated"

io.github.flink.gcp.connector.cloudtasks.table.CloudTasksDynamicTableFactory

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"cloud-tasks"

io.github.flink.gcp.connector.cloudtasks.table.form.FormUrlEncodedFormatFactory

Modifier and Type	Constant Field	Value
public static final String	CONTENT_TYPE	"application/x-www-form-urlencoded"
public static final String	IDENTIFIER	"form-urlencoded"

io.github.flink.gcp.connector.pubsub.PubSubMetricNames

Modifier and Type	Constant Field	Value
public static final String	ACTIVE_PUBLISHERS	"activePublishers"
public static final String	ASSIGNED_SPLITS	"assignedSplits"
public static final String	BUFFERED_BYTES	"bufferedBytes"
public static final String	BUFFERED_MESSAGES	"bufferedMessages"
public static final String	CAPACITY_EVICTIONS	"capacityEvictions"
public static final String	DEAD_LETTER_FLUSH_MILLIS	"deadLetterFlushMillis"
public static final String	DEAD_LETTER_PUBLISHER_SHUTDOWNS_ABANDONED	"deadLetterPublisherShutdownsAbandoned"
public static final String	DEAD_LETTERS_PUBLISHED	"deadLettersPublished"
public static final String	FETCHER_BUFFERED_BYTES	"fetcherBufferedBytes"
public static final String	FETCHER_BUFFERED_MESSAGES	"fetcherBufferedMessages"
public static final String	IDLE_EVICTIONS	"idleEvictions"
public static final String	IN_FLIGHT_BYTES	"inFlightBytes"
public static final String	IN_FLIGHT_DEAD_LETTERS	"inFlightDeadLetters"
public static final String	IN_FLIGHT_MESSAGES	"inFlightMessages"
public static final String	LONGEST_DEAD_LETTER_FLUSH_MILLIS	"longestDeadLetterFlushMillis"
public static final String	MESSAGES_ACKED	"messagesAcked"
public static final String	MESSAGES_DROPPED	"messagesDropped"
public static final String	MESSAGES_NACKED	"messagesNacked"
public static final String	MESSAGES_RECEIVED	"messagesReceived"
public static final String	PARKED_MESSAGES	"parkedMessages"
public static final String	PARKED_SPLITS	"parkedSplits"
public static final String	PENDING_ACKS	"pendingAcks"
public static final String	PENDING_CHECKPOINTS	"pendingCheckpoints"
public static final String	PUBLISHER_SHUTDOWNS_ABANDONED	"publisherShutdownsAbandoned"
public static final String	RECORDS_SKIPPED	"recordsSkipped"
public static final String	SPLITS_PARKED	"splitsParked"
public static final String	SUBSCRIBER_FAILURES_UNREPORTED	"subscriberFailuresUnreported"
public static final String	SUBSCRIBER_SHUTDOWNS_ABANDONED	"subscriberShutdownsAbandoned"
public static final String	TOPICS_CREATED	"topicsCreated"
public static final String	UNASSIGNED_READERS	"unassignedReaders"

io.github.flink.gcp.connector.pubsub.deadletter.PubSubDeadLetterQueue

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_MAX_IN_FLIGHT_MESSAGES	1000
public static final int	UNBOUNDED	-1
public static final int	WRITE_THROUGH	0

io.github.flink.gcp.connector.pubsub.sink.PubSubPublisherOptions

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_MAX_ACTIVE_PUBLISHERS	100
public static final int	DEFAULT_MAX_CONSECUTIVE_REJECTIONS	100
public static final int	UNBOUNDED	-1

io.github.flink.gcp.connector.pubsub.table.PubSubDynamicTableFactory

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"pubsub"

io.github.flink.gcp.connector.spanner.SpannerMetricNames

Modifier and Type	Constant Field	Value
public static final String	ACTIVE_CHANGE_STREAM_QUERIES	"activeChangeStreamQueries"
public static final String	BATCHES_SENT	"batchesSent"
public static final String	BUFFERED_BYTES	"bufferedBytes"
public static final String	BUFFERED_CELLS	"bufferedCells"
public static final String	BUFFERED_MUTATIONS	"bufferedMutations"
public static final String	CHANGE_STREAM_COLUMN_OCCURRENCES_FILTERED	"changeStreamColumnOccurrencesFiltered"
public static final String	CHANGE_STREAM_FINISHED_PARENT_PROOFS	"changeStreamFinishedParentProofs"
public static final String	CHANGE_STREAM_PARTITION_LEDGER_ENTRIES	"changeStreamPartitionLedgerEntries"
public static final String	CHANGE_STREAM_PARTITIONS_DISCOVERED	"changeStreamPartitionsDiscovered"
public static final String	CHANGE_STREAM_QUERIES_STARTED	"changeStreamQueriesStarted"
public static final String	CHANGE_STREAM_RECORDS_FILTERED_BY_TABLE	"changeStreamRecordsFilteredByTable"
public static final String	CHANGE_STREAM_RECORDS_SKIPPED_WITHOUT_CHANGE	"changeStreamRecordsSkippedWithoutChange"
public static final String	LAST_CHANGE_STREAM_RECORD_WAIT_MILLIS	"lastChangeStreamRecordWaitMillis"
public static final String	LONGEST_CHANGE_STREAM_RECORD_WAIT_MILLIS	"longestChangeStreamRecordWaitMillis"
public static final String	MISSED_HEARTBEAT_INTERVALS	"missedHeartbeatIntervals"
public static final String	MUTATIONS_RETRIED	"mutationsRetried"
public static final String	PARTITIONS_REREAD	"partitionsReread"
public static final String	QUEUED_CHANGE_STREAM_PARTITION_LAG_MILLIS	"queuedChangeStreamPartitionLagMillis"
public static final String	QUEUED_CHANGE_STREAM_PARTITIONS	"queuedChangeStreamPartitions"
public static final String	READS_PLANNED	"readsPlanned"
public static final String	RECORDS_SKIPPED	"recordsSkipped"
public static final String	ROWS_READ	"rowsRead"
public static final String	SPLITS_ASSIGNED	"splitsAssigned"
public static final String	SPLITS_RETURNED	"splitsReturned"
public static final String	UNASSIGNED_CHANGE_STREAM_PARTITION_LAG_MILLIS	"unassignedChangeStreamPartitionLagMillis"

io.github.flink.gcp.connector.spanner.sink.SpannerWriterOptions

Modifier and Type	Constant Field	Value
public static final long	DEFAULT_MAX_BATCH_BYTES	1048576L
public static final int	DEFAULT_MAX_BATCH_CELLS	5000
public static final int	DEFAULT_MAX_BATCH_MUTATIONS	500

io.github.flink.gcp.connector.spanner.source.SpannerChangeStreamSourceBuilder<T>

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_MAX_CONCURRENT_QUERIES_PER_SUBTASK	8

io.github.flink.gcp.connector.spanner.source.SpannerSourceBuilder<T>

Modifier and Type	Constant Field	Value
public static final long	DEFAULT_MAX_BYTES_PER_FETCH	12582912L
public static final int	DEFAULT_MAX_ROWS_PER_FETCH	1000

io.github.flink.gcp.connector.spanner.source.changestream.ChangeStreamPartitionSplit

Modifier and Type	Constant Field	Value
public static final String	INITIAL_PARTITION_ID	"change-stream-initial"

io.github.flink.gcp.connector.spanner.table.SpannerDynamicTableFactory

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"spanner"

io.github.flink.gcp.connector.testutils.ServiceAccountKeyFiles

Modifier and Type	Constant Field	Value
public static final String	CLIENT_EMAIL	"service-account@example.invalid"

io.github.flink.gcp.connector.testutils.TestSinkCommitterMetricGroup

Modifier and Type	Constant Field	Value
public static final String	ALREADY_COMMITTED_COMMITTABLES	"alreadyCommittedCommittables"
public static final String	FAILED_COMMITTABLES	"failedCommittables"
public static final String	RETRIED_COMMITTABLES	"retriedCommittables"
public static final String	SUCCESSFUL_COMMITTABLES	"successfulCommittables"
public static final String	TOTAL_COMMITTABLES	"totalCommittables"

io.github.flink.gcp.connector.testutils.TestSinkWriterMetricGroup

Modifier and Type	Constant Field	Value
public static final String	NUM_BYTES_SEND	"numBytesSend"
public static final String	NUM_RECORDS_SEND	"numRecordsSend"
public static final String	NUM_RECORDS_SEND_ERRORS	"numRecordsSendErrors"