Constant Field Values
Contents
com.linkedin.*
-
com.linkedin.alpini.base.misc.DateUtils Modifier and Type Constant Field Value public static final java.lang.String
ASCTIME_DATE_FORMAT
"EEE MMM d HH:mm:ss yyyy"
public static final java.lang.String
RFC1036_DATE_FORMAT
"EEE, dd-MMM-yy HH:mm:ss zzz"
public static final java.lang.String
RFC1123_DATE_FORMAT
"EEE, dd MMM yyyy HH:mm:ss zzz"
-
com.linkedin.alpini.base.misc.HeaderNames Modifier and Type Constant Field Value public static final java.lang.String
CONTENT_LENGTH
"Content-Length"
public static final java.lang.String
CONTENT_LOCATION
"Content-Location"
public static final java.lang.String
CONTENT_TYPE
"Content-Type"
public static final java.lang.String
PROVIDER_CLASS_NAME
"com.linkedin.alpini.base.misc.spi.HeaderNames"
public static final java.lang.String
SERVER
"Server"
-
com.linkedin.alpini.base.misc.HeaderUtils Modifier and Type Constant Field Value public static final java.lang.String
HTTP_DATE_FORMAT
"EEE, dd MMM yyyy HH:mm:ss zzz"
public static final java.lang.String
HTTP_DATE_GMT_TIMEZONE
"GMT"
-
com.linkedin.alpini.base.misc.Http2TooManyStreamsException Modifier and Type Constant Field Value public static final java.lang.String
DEFAULT_MESSAGE
"Max concurrent requests limit reached for storage node connection"
-
com.linkedin.alpini.netty4.http2.CompactHeaderHandler Modifier and Type Constant Field Value public static final java.lang.String
COMPACT_HEADER
"ech"
-
com.linkedin.alpini.router.impl.Router.Builder Modifier and Type Constant Field Value public static final long
HANDSHAKE_TIMEOUT_MILLIS
60000L
public static final long
MINIMUM_IDLE_TIMEOUT_MILLIS
1000L
public static final int
MINIMUM_MAX_CHUNK_SIZE
256
public static final long
MINIMUM_MAX_CONTENT_LENGTH
0L
public static final int
MINIMUM_MAX_HEADER_SIZE
256
public static final int
MINIMUM_MAX_INITIAL_LINE_LENGTH
256
-
com.linkedin.davinci.blobtransfer.BlobSnapshotManager Modifier and Type Constant Field Value public static final int
DEFAULT_MAX_CONCURRENT_USERS
5
-
com.linkedin.davinci.blobtransfer.BlobTransferUtils Modifier and Type Constant Field Value public static final java.lang.String
BLOB_TRANSFER_COMPLETED
"Completed"
public static final java.lang.String
BLOB_TRANSFER_STATUS
"X-Blob-Transfer-Status"
public static final java.lang.String
BLOB_TRANSFER_TYPE
"X-Blob-Transfer-Type"
-
com.linkedin.davinci.client.AvroGenericDaVinciClient<K,V> Modifier and Type Constant Field Value public static final int
DEFAULT_CHUNK_SPLIT_THRESHOLD
100
-
com.linkedin.davinci.config.StoreBackendConfig Modifier and Type Constant Field Value public static final java.lang.String
CONFIG_DIRECTORY
"config"
public static final java.lang.String
IS_MANAGED
"managed"
-
com.linkedin.davinci.config.VeniceConfigLoader Modifier and Type Constant Field Value public static final java.lang.String
CLUSTER_PROPERTIES_FILE
"cluster.properties"
public static final java.lang.String
KAFKA_CLUSTER_MAP_FILE
"kafka.cluster.map"
public static final java.lang.String
SERVER_PROPERTIES_FILE
"server.properties"
public static final java.lang.String
VENICE_CONFIG_DIR
"VENICE_CONFIG_DIR"
-
com.linkedin.davinci.config.VeniceServerConfig Modifier and Type Constant Field Value public static final int
MINIMUM_CONSUMER_NUM_IN_CONSUMER_POOL_PER_KAFKA_CLUSTER
3
-
com.linkedin.davinci.ingestion.utils.IsolatedIngestionUtils Modifier and Type Constant Field Value public static final java.lang.String
FORKED_PROCESS_METADATA_FILENAME
"ForkedProcessMetadata.conf"
public static final java.lang.String
INGESTION_ISOLATION_CONFIG_PREFIX
"isolated"
public static final java.lang.String
ISOLATED_INGESTION_CONFIG_FILENAME
"IsolatedIngestionConfig.conf"
public static final java.lang.String
ISOLATED_INGESTION_KAFKA_CLUSTER_MAP_FILENAME
"IsolatedIngestionKafkaClusterMap.conf"
public static final java.lang.String
PID
"pid"
-
com.linkedin.davinci.kafka.consumer.RemoteIngestionRepairService Modifier and Type Constant Field Value public static final int
DEFAULT_REPAIR_THREAD_SLEEP_INTERVAL_SECONDS
1800
-
com.linkedin.davinci.kafka.consumer.StoreIngestionTask Modifier and Type Constant Field Value protected static final long
KILL_WAIT_TIME_MS
5000L
-
com.linkedin.davinci.stats.BlobTransferStats Modifier and Type Constant Field Value protected static final java.lang.String
BLOB_TRANSFER_FAILED_NUM_RESPONSES
"blob_transfer_failed_num_responses"
protected static final java.lang.String
BLOB_TRANSFER_SUCCESSFUL_NUM_RESPONSES
"blob_transfer_successful_num_responses"
protected static final java.lang.String
BLOB_TRANSFER_THROUGHPUT
"blob_transfer_file_receive_throughput"
protected static final java.lang.String
BLOB_TRANSFER_TIME
"blob_transfer_time"
protected static final java.lang.String
BLOB_TRANSFER_TOTAL_NUM_RESPONSES
"blob_transfer_total_num_responses"
-
com.linkedin.davinci.stats.HostLevelIngestionStats Modifier and Type Constant Field Value public static final java.lang.String
ASSEMBLED_RECORD_SIZE_IN_BYTES
"assembled_record_size_in_bytes"
public static final java.lang.String
ASSEMBLED_RECORD_SIZE_RATIO
"assembled_record_size_ratio"
public static final java.lang.String
ASSEMBLED_RMD_SIZE_IN_BYTES
"assembled_rmd_size_in_bytes"
-
com.linkedin.davinci.stats.IngestionStats Modifier and Type Constant Field Value protected static final java.lang.String
BATCH_FOLLOWER_OFFSET_LAG
"batch_follower_offset_lag"
protected static final java.lang.String
BATCH_LEADER_OFFSET_LAG
"batch_leader_offset_lag"
public static final java.lang.String
BATCH_PROCESSING_REQUEST
"batch_processing_request"
public static final java.lang.String
BATCH_PROCESSING_REQUEST_ERROR
"batch_processing_request_error"
public static final java.lang.String
BATCH_PROCESSING_REQUEST_LATENCY
"batch_processing_request_latency"
public static final java.lang.String
BATCH_PROCESSING_REQUEST_RECORDS
"batch_processing_request_records"
public static final java.lang.String
BATCH_PROCESSING_REQUEST_SIZE
"batch_processing_request_size"
protected static final java.lang.String
BATCH_REPLICATION_LAG
"batch_replication_lag"
protected static final java.lang.String
BYTES_CONSUMED_METRIC_NAME
"bytes_consumed"
protected static final java.lang.String
CONSUMED_RECORD_END_TO_END_PROCESSING_LATENCY
"consumed_record_end_to_end_processing_latency"
protected static final java.lang.String
FOLLOWER_BYTES_CONSUMED_METRIC_NAME
"follower_bytes_consumed"
protected static final java.lang.String
FOLLOWER_OFFSET_LAG
"follower_offset_lag"
protected static final java.lang.String
FOLLOWER_RECORDS_CONSUMED_METRIC_NAME
"follower_records_consumed"
protected static final java.lang.String
HYBRID_FOLLOWER_OFFSET_LAG
"hybrid_follower_offset_lag"
protected static final java.lang.String
HYBRID_LEADER_OFFSET_LAG
"hybrid_leader_offset_lag"
public static final java.lang.String
IDLE_TIME
"idle_time"
protected static final java.lang.String
INGESTION_TASK_ERROR_GAUGE
"ingestion_task_errored_gauge"
protected static final java.lang.String
INGESTION_TASK_PUSH_TIMEOUT_GAUGE
"ingestion_task_push_timeout_gauge"
public static final java.lang.String
INTERNAL_PREPROCESSING_LATENCY
"internal_preprocessing_latency"
protected static final java.lang.String
LEADER_BYTES_CONSUMED_METRIC_NAME
"leader_bytes_consumed"
protected static final java.lang.String
LEADER_BYTES_PRODUCED_METRIC_NAME
"leader_bytes_produced"
protected static final java.lang.String
LEADER_OFFSET_LAG
"leader_offset_lag"
public static final java.lang.String
LEADER_PREPROCESSING_LATENCY
"leader_preprocessing_latency"
protected static final java.lang.String
LEADER_RECORDS_CONSUMED_METRIC_NAME
"leader_records_consumed"
protected static final java.lang.String
LEADER_RECORDS_PRODUCED_METRIC_NAME
"leader_records_produced"
protected static final java.lang.String
LEADER_STALLED_HYBRID_INGESTION_METRIC_NAME
"leader_stalled_hybrid_ingestion"
public static final java.lang.String
NEARLINE_LOCAL_BROKER_TO_READY_TO_SERVE_LATENCY
"nearline_local_broker_to_ready_to_serve_latency"
public static final java.lang.String
NEARLINE_PRODUCER_TO_LOCAL_BROKER_LATENCY
"nearline_producer_to_local_broker_latency"
protected static final java.lang.String
OFFSET_REGRESSION_DCR_ERROR
"offset_regression_dcr_error"
public static final java.lang.String
PRODUCER_CALLBACK_LATENCY
"producer_callback_latency"
protected static final java.lang.String
READY_TO_SERVE_WITH_RT_LAG_METRIC_NAME
"ready_to_serve_with_rt_lag"
protected static final java.lang.String
RECORDS_CONSUMED_METRIC_NAME
"records_consumed"
protected static final java.lang.String
SUBSCRIBE_ACTION_PREP_LATENCY
"subscribe_action_prep_latency"
protected static final java.lang.String
TIMESTAMP_REGRESSION_DCR_ERROR
"timestamp_regression_dcr_error"
protected static final java.lang.String
TOMBSTONE_CREATION_DCR
"tombstone_creation_dcr"
protected static final java.lang.String
TOTAL_DCR
"total_dcr"
protected static final java.lang.String
TRANSFORMER_ERROR_COUNT
"transformer_error_count"
public static final java.lang.String
TRANSFORMER_LATENCY
"transformer_latency"
public static final java.lang.String
TRANSFORMER_LIFECYCLE_END_LATENCY
"transformer_lifecycle_end_latency"
public static final java.lang.String
TRANSFORMER_LIFECYCLE_START_LATENCY
"transformer_lifecycle_start_latency"
protected static final java.lang.String
UPDATE_IGNORED_DCR
"update_ignored_dcr"
public static final java.lang.String
VERSION_TOPIC_END_OFFSET_REWIND_COUNT
"version_topic_end_offset_rewind_count"
protected static final java.lang.String
WRITE_COMPUTE_OPERATION_FAILURE
"write_compute_operation_failure"
-
com.linkedin.davinci.stats.ingestion.heartbeat.HeartbeatMonitoringService Modifier and Type Constant Field Value public static final int
DEFAULT_LAG_LOGGING_THREAD_SLEEP_INTERVAL_SECONDS
60
public static final int
DEFAULT_REPORTER_THREAD_SLEEP_INTERVAL_SECONDS
60
-
com.linkedin.davinci.store.AbstractStorageEngine<Partition extends AbstractStoragePartition> Modifier and Type Constant Field Value public static final int
METADATA_PARTITION_ID
1000000000
-
com.linkedin.davinci.store.record.ValueRecord Modifier and Type Constant Field Value public static final int
SCHEMA_HEADER_LENGTH
4
-
com.linkedin.davinci.store.rocksdb.RocksDBServerConfig Modifier and Type Constant Field Value public static final java.lang.String
CAPPED_PREFIX_EXTRACTOR_LENGTH
"rocksdb.capped.prefix.extractor.length"
public static final java.lang.String
RECORD_TRANSFORMER_VALUE_SCHEMA
"record.transformer.value.schema"
public static final java.lang.String
ROCKSDB_ATOMIC_FLUSH_ENABLED
"rocksdb.atomic.flush.enabled"
public static final java.lang.String
ROCKSDB_AUTO_TUNED_RATE_LIMITER_ENABLED
"rocksdb.auto.tuned.rate.limited.enabled"
public static final java.lang.String
ROCKSDB_BLOB_FILE_SIZE_IN_BYTES
"rocksdb.blob.file.size.in.bytes"
public static final java.lang.String
ROCKSDB_BLOB_FILE_STARTING_LEVEL
"rocksdb.blob.file.starting.level"
public static final java.lang.String
ROCKSDB_BLOB_FILES_ENABLED
"rocksdb.blob.files.enabled"
public static final java.lang.String
ROCKSDB_BLOB_GARBAGE_COLLECTION_AGE_CUTOFF
"rocksdb.blob.garbage.collection.age.cutoff"
public static final java.lang.String
ROCKSDB_BLOB_GARBAGE_COLLECTION_FORCE_THRESHOLD
"rocksdb.blob.garbage.collection.force.threshold"
public static final java.lang.String
ROCKSDB_BLOCK_BASE_FORMAT_VERSION
"rocksdb.block.base.format.version"
public static final java.lang.String
ROCKSDB_BLOCK_CACHE_COMPRESSED_SIZE_IN_BYTES
"rocksdb.block.cache.compressed.size.in.bytes"
public static final java.lang.String
ROCKSDB_BLOCK_CACHE_IMPLEMENTATION
"rocksdb.block.cache.implementation"
public static final java.lang.String
ROCKSDB_BLOCK_CACHE_SHARD_BITS
"rocksdb.block.cache.shard.bits"
public static final java.lang.String
ROCKSDB_BLOCK_CACHE_SIZE_IN_BYTES
"rocksdb.block.cache.size.in.bytes"
public static final java.lang.String
ROCKSDB_BLOCK_CACHE_STRICT_CAPACITY_LIMIT
"rocksdb.block.cache.strict.capacity.limit"
public static final java.lang.String
ROCKSDB_BLOOM_BITS_PER_KEY
"rocksdb.bloom.bits.per.key"
public static final java.lang.String
ROCKSDB_BYTES_PER_SYNC
"rocksdb.bytes.per.sync"
public static final java.lang.String
ROCKSDB_DB_OPEN_OPERATION_THROTTLE
"rocksdb.db.open.operation.throttle"
public static final java.lang.String
ROCKSDB_ENV_COMPACTION_POOL_SIZE
"rocksdb.env.compaction.pool.size"
public static final java.lang.String
ROCKSDB_ENV_FLUSH_POOL_SIZE
"rocksdb.env.flush.pool.size"
public static final java.lang.String
ROCKSDB_HASH_TABLE_RATIO
"rocksdb.hash.table.ratio"
public static final java.lang.String
ROCKSDB_HUGE_PAGE_TLB_SIZE
"rocksdb.huge.page.tlb.size"
public static final java.lang.String
ROCKSDB_LEVEL0_COMPACTION_TUNING_FOR_READ_WRITE_LEADER_ENABLED
"rocksdb.level0.compaction.tuning.for.read.write.leader.enabled"
public static final java.lang.String
ROCKSDB_LEVEL0_FILE_NUM_COMPACTION_TRIGGER
"rocksdb.level0.file.num.compaction.trigger"
public static final java.lang.String
ROCKSDB_LEVEL0_FILE_NUM_COMPACTION_TRIGGER_FOR_READ_WRITE_LEADER
"rocksdb.level0.file.num.compaction.trigger.for.read.write.leader"
public static final java.lang.String
ROCKSDB_LEVEL0_FILE_NUM_COMPACTION_TRIGGER_WRITE_ONLY_VERSION
"rocksdb.level0.file.num.compaction.trigger.write.only.version"
public static final java.lang.String
ROCKSDB_LEVEL0_SLOWDOWN_WRITES_TRIGGER
"rocksdb.level0.slowdown.writes.trigger"
public static final java.lang.String
ROCKSDB_LEVEL0_SLOWDOWN_WRITES_TRIGGER_FOR_READ_WRITE_LEADER
"rocksdb.level0.slowdown.writes.trigger.for.read.write.leader"
public static final java.lang.String
ROCKSDB_LEVEL0_SLOWDOWN_WRITES_TRIGGER_WRITE_ONLY_VERSION
"rocksdb.level0.slowdown.writes.trigger.write.only.version"
public static final java.lang.String
ROCKSDB_LEVEL0_STOPS_WRITES_TRIGGER
"rocksdb.level0.stops.writes.trigger"
public static final java.lang.String
ROCKSDB_LEVEL0_STOPS_WRITES_TRIGGER_FOR_READ_WRITE_LEADER
"rocksdb.level0.stops.writes.trigger.for.read.write.leader"
public static final java.lang.String
ROCKSDB_LEVEL0_STOPS_WRITES_TRIGGER_WRITE_ONLY_VERSION
"rocksdb.level0.stops.writes.trigger.write.only.version"
public static final java.lang.String
ROCKSDB_MAX_BYTES_FOR_LEVEL_BASE
"rocksdb.max.bytes.for.level.base"
public static final java.lang.String
ROCKSDB_MAX_FILE_OPENING_THREADS
"rocksdb.max.file.opening.threads"
public static final java.lang.String
ROCKSDB_MAX_LOG_FILE_NUM
"rocksdb.max.log.file.num"
public static final java.lang.String
ROCKSDB_MAX_LOG_FILE_SIZE
"rocksdb.max.log.file.size"
public static final java.lang.String
ROCKSDB_MAX_MEMTABLE_COUNT
"rocksdb.max.memtable.count"
public static final java.lang.String
ROCKSDB_MAX_OPEN_FILES
"rocksdb.max.open.files"
public static final java.lang.String
ROCKSDB_MAX_TOTAL_WAL_SIZE_IN_BYTES
"rocksdb.max.total.wal.size.in.bytes"
public static final java.lang.String
ROCKSDB_MEM_TABLE_HUGE_PAGE_SIZE_BYTES
"rocksdb.mem.table.huge.page.size.in.bytes"
public static final java.lang.String
ROCKSDB_MEMTABLE_SIZE_IN_BYTES
"rocksdb.memtable.size.in.bytes"
public static final java.lang.String
ROCKSDB_MIN_BLOB_SIZE_IN_BYTES
"rocksdb.min.blob.size.in.bytes"
public static final java.lang.String
ROCKSDB_OPTIONS_COMPACTION_STYLE
"rocksdb.options.compaction.style"
public static final java.lang.String
ROCKSDB_OPTIONS_COMPRESSION_TYPE
"rocksdb.options.compression.type"
public static final java.lang.String
ROCKSDB_OPTIONS_USE_DIRECT_READS
"rocksdb.options.use.direct.reads"
public static final java.lang.String
ROCKSDB_PLAIN_TABLE_FORMAT_ENABLED
"rocksdb.plain.table.format.enabled"
public static final java.lang.String
ROCKSDB_PUT_REUSE_BYTE_BUFFER
"rocksdb.put.reuse.byte.buffer"
public static final java.lang.String
ROCKSDB_RMD_BLOCK_CACHE_SIZE_IN_BYTES
"rocksdb.rmd.block.cache.size.in.bytes"
public static final java.lang.String
ROCKSDB_SEPARATE_RMD_CACHE_ENABLED
"rocksdb.separate.rmd.cache.enabled"
public static final java.lang.String
ROCKSDB_SET_CACHE_INDEX_AND_FILTER_BLOCKS
"rocksdb.set.cache.index.and.filter.blocks"
public static final java.lang.String
ROCKSDB_SST_FILE_BLOCK_SIZE_IN_BYTES
"rocksdb.sst.file.block.size.in.bytes"
public static final java.lang.String
ROCKSDB_STATISTICS_ENABLED
"rocksdb.statistics.enabled"
public static final java.lang.String
ROCKSDB_STORE_INDEX_IN_FILE
"rocksdb.store.index.in.file"
public static final java.lang.String
ROCKSDB_TARGET_FILE_SIZE_IN_BYTES
"rocksdb.target.file.size.in.bytes"
public static final java.lang.String
ROCKSDB_TOTAL_MEMTABLE_USAGE_CAP_IN_BYTES
"rocksdb.total.memtable.usage.cap.in.bytes"
public static final java.lang.String
ROCKSDB_WRITE_QUOTA_BYTES_PER_SECOND
"rocksdb.write.quota.bytes.per.second"
-
com.linkedin.davinci.store.rocksdb.RocksDBSstFileWriter Modifier and Type Constant Field Value protected static final int
DEFAULT_COLUMN_FAMILY_INDEX
0
protected static final int
REPLICATION_METADATA_COLUMN_FAMILY_INDEX
1
protected static final java.lang.String
ROCKSDB_LAST_FINISHED_RMD_SST_FILE_NO
"rocksdb_last_finished_rmd_sst_file_no"
protected static final java.lang.String
ROCKSDB_LAST_FINISHED_SST_FILE_NO
"rocksdb_last_finished_sst_file_no"
-
com.linkedin.davinci.store.rocksdb.RocksDBStorageEngine Modifier and Type Constant Field Value public static final java.lang.String
SERVER_CONFIG_FILE_NAME
"rocksdbConfig"
-
com.linkedin.davinci.validation.KafkaDataIntegrityValidator Modifier and Type Constant Field Value public static final long
DISABLED
-1L
-
com.linkedin.davinci.validation.PartitionTracker.TopicType Modifier and Type Constant Field Value public static final int
REALTIME_TOPIC_TYPE
1
public static final int
VERSION_TOPIC_TYPE
0
-
com.linkedin.venice.CommonConfigKeys Modifier and Type Constant Field Value public static final java.lang.String
SSL_ENABLED
"ssl.enabled"
public static final java.lang.String
SSL_FACTORY_CLASS_NAME
"ssl.factory.class.name"
public static final java.lang.String
SSL_KEY_PASSWORD
"ssl.key.password"
public static final java.lang.String
SSL_KEYMANAGER_ALGORITHM
"ssl.keymanager.algorithm"
public static final java.lang.String
SSL_KEYSTORE_LOCATION
"ssl.keystore.location"
public static final java.lang.String
SSL_KEYSTORE_PASSWORD
"ssl.keystore.password"
public static final java.lang.String
SSL_KEYSTORE_TYPE
"ssl.keystore.type"
public static final java.lang.String
SSL_NEEDS_CLIENT_CERT
"ssl.needs.client.cert"
public static final java.lang.String
SSL_SECURE_RANDOM_IMPLEMENTATION
"ssl.secure.random.implementation"
public static final java.lang.String
SSL_TRUSTMANAGER_ALGORITHM
"ssl.trustmanager.algorithm"
public static final java.lang.String
SSL_TRUSTSTORE_LOCATION
"ssl.truststore.location"
public static final java.lang.String
SSL_TRUSTSTORE_PASSWORD
"ssl.truststore.password"
public static final java.lang.String
SSL_TRUSTSTORE_TYPE
"ssl.truststore.type"
-
com.linkedin.venice.ConfigConstants Modifier and Type Constant Field Value public static final int
DEFAULT_MAX_RECORD_SIZE_BYTES_BACKFILL
104857600
public static final int
UNSPECIFIED_REPLICATION_METADATA_VERSION
-1
-
com.linkedin.venice.ConfigKeys Modifier and Type Constant Field Value public static final java.lang.String
ACTIVE_ACTIVE_REAL_TIME_SOURCE_FABRIC_LIST
"active.active.real.time.source.fabric.list"
public static final java.lang.String
ADMIN_CHECK_READ_METHOD_FOR_KAFKA
"admin.check.read.method.for.kafka"
public static final java.lang.String
ADMIN_CONSUMPTION_CYCLE_TIMEOUT_MS
"admin.consumption.cycle.timeout.ms"
public static final java.lang.String
ADMIN_CONSUMPTION_MAX_WORKER_THREAD_POOL_SIZE
"admin.consumption.max.worker.thread.pool.size"
public static final java.lang.String
ADMIN_HELIX_MESSAGING_CHANNEL_ENABLED
"admin.helix.messaging.channel.enabled"
public static final java.lang.String
ADMIN_HOSTNAME
"admin.hostname"
public static final java.lang.String
ADMIN_PORT
"admin.port"
public static final java.lang.String
ADMIN_SECURE_PORT
"admin.secure.port"
public static final java.lang.String
ADMIN_TOPIC_REPLICATION_FACTOR
"admin.topic.replication.factor"
public static final java.lang.String
ADMIN_TOPIC_SOURCE_REGION
"admin.topic.source.region"
public static final java.lang.String
AGGREGATE_REAL_TIME_SOURCE_REGION
"aggregate.real.time.source.region"
public static final java.lang.String
ALLOW_CLUSTER_WIPE
"allow.cluster.wipe"
public static final java.lang.String
ALLOW_STORE_MIGRATION
"allow.store.migration"
public static final java.lang.String
AUTOCREATE_DATA_PATH
"autocreate.data.path"
public static final java.lang.String
BLOB_TRANSFER_DISABLED_OFFSET_LAG_THRESHOLD
"blob.transfer.disabled.offset.lag.threshold"
public static final java.lang.String
BLOB_TRANSFER_MANAGER_ENABLED
"blob.transfer.manager.enabled"
public static final java.lang.String
BLOB_TRANSFER_MAX_CONCURRENT_SNAPSHOT_USER
"blob.transfer.max.concurrent.snapshot.user"
public static final java.lang.String
BLOB_TRANSFER_MAX_TIMEOUT_IN_MIN
"blob.transfer.max.timeout.in.min"
public static final java.lang.String
BLOB_TRANSFER_SNAPSHOT_RETENTION_TIME_IN_MIN
"blob.transfer.snapshot.retention.time.in.min"
public static final java.lang.String
CHILD_CLUSTER_ALLOWLIST
"child.cluster.allowlist"
public static final java.lang.String
CHILD_CLUSTER_D2_PREFIX
"child.cluster.d2.zkHost."
public static final java.lang.String
CHILD_CLUSTER_D2_SERVICE_NAME
"child.cluster.d2.service.name"
public static final java.lang.String
CHILD_CLUSTER_URL_PREFIX
"child.cluster.url."
public static final java.lang.String
CHILD_CLUSTER_WHITELIST
"child.cluster.whitelist"
public static final java.lang.String
CHILD_CONTROLLER_ADMIN_TOPIC_CONSUMPTION_ENABLED
"child.controller.admin.topic.consumption.enabled"
public static final java.lang.String
CHILD_DATA_CENTER_KAFKA_URL_PREFIX
"child.data.center.kafka.url"
public static final java.lang.String
CLIENT_PRODUCER_SCHEMA_REFRESH_INTERVAL_SECONDS
"client.producer.schema.refresh.interval.seconds"
public static final java.lang.String
CLIENT_PRODUCER_THREAD_NUM
"client.producer.thread.num"
public static final java.lang.String
CLIENT_SYSTEM_STORE_REPOSITORY_REFRESH_INTERVAL_SECONDS
"client.system.store.repository.refresh.interval.seconds"
public static final java.lang.String
CLIENT_USE_SYSTEM_STORE_REPOSITORY
"client.use.system.store.repository"
public static final java.lang.String
CLUSTER_DISCOVERY_D2_SERVICE
"cluster.discovery.d2.service"
public static final java.lang.String
CLUSTER_NAME
"cluster.name"
public static final java.lang.String
CLUSTER_TO_D2
"cluster.to.d2"
public static final java.lang.String
CLUSTER_TO_SERVER_D2
"cluster.to.server.d2"
public static final java.lang.String
CONCURRENT_INIT_ROUTINES_ENABLED
"concurrent.init.routines.enabled"
public static final java.lang.String
CONTROLLER_ADD_VERSION_VIA_ADMIN_PROTOCOL
"controller.add.version.via.admin.protocol"
public static final java.lang.String
CONTROLLER_AUTO_MATERIALIZE_DAVINCI_PUSH_STATUS_SYSTEM_STORE
"controller.auto.materialize.davinci.push.status.system.store"
public static final java.lang.String
CONTROLLER_AUTO_MATERIALIZE_META_SYSTEM_STORE
"controller.auto.materialize.meta.system.store"
public static final java.lang.String
CONTROLLER_BACKUP_VERSION_DEFAULT_RETENTION_MS
"controller.backup.version.default.retention.ms"
public static final java.lang.String
CONTROLLER_BACKUP_VERSION_DELETION_SLEEP_MS
"controller.backup.version.deletion.sleep.ms"
public static final java.lang.String
CONTROLLER_BACKUP_VERSION_METADATA_FETCH_BASED_CLEANUP_ENABLED
"controller.backup.version.metadata.fetch.cleanup.enabled"
public static final java.lang.String
CONTROLLER_BACKUP_VERSION_RETENTION_BASED_CLEANUP_ENABLED
"controller.backup.version.retention.based.cleanup.enabled"
public static final java.lang.String
CONTROLLER_CLUSTER
"controller.cluster.name"
public static final java.lang.String
CONTROLLER_CLUSTER_HELIX_CLOUD_ENABLED
"controller.cluster.helix.cloud.enabled"
public static final java.lang.String
CONTROLLER_CLUSTER_LEADER_HAAS
"controller.cluster.leader.haas.enabled"
public static final java.lang.String
CONTROLLER_CLUSTER_REPLICA
"controller.cluster.replica"
public static final java.lang.String
CONTROLLER_CLUSTER_ZK_ADDRESSS
"controller.cluster.zk.address"
public static final java.lang.String
CONTROLLER_DANGLING_TOPIC_CLEAN_UP_INTERVAL_SECOND
"controller.dangling.topic.clean.up.interval.second"
public static final java.lang.String
CONTROLLER_DANGLING_TOPIC_OCCURRENCE_THRESHOLD_FOR_CLEANUP
"controller.dangling.topic.occurrence.threshold.for.cleanup"
public static final java.lang.String
CONTROLLER_DEFAULT_READ_QUOTA_PER_ROUTER
"controller.default.read.quota.per.router"
public static final java.lang.String
CONTROLLER_DISABLE_PARENT_REQUEST_TOPIC_FOR_STREAM_PUSHES
"controller.disable.parent.request.topic.for.stream.pushes"
public static final java.lang.String
CONTROLLER_DISABLE_PARENT_TOPIC_TRUNCATION_UPON_COMPLETION
"controller.disable.parent.topic.truncation.upon.completion"
public static final java.lang.String
CONTROLLER_DISABLED_REPLICA_ENABLER_INTERVAL_MS
"controller.disabled.replica.enabler.interval.ms"
public static final java.lang.String
CONTROLLER_DISABLED_ROUTES
"controller.cluster.disabled.routes"
public static final java.lang.String
CONTROLLER_EARLY_DELETE_BACKUP_ENABLED
"controller.early.delete.backup.enabled"
public static final java.lang.String
CONTROLLER_ENABLE_DISABLED_REPLICA_ENABLED
"controller.enable.disabled.replica.enabled"
public static final java.lang.String
CONTROLLER_ENFORCE_SSL
"controller.enforce.ssl"
public static final java.lang.String
CONTROLLER_HAAS_SUPER_CLUSTER_NAME
"controller.haas.super.cluster.name"
public static final java.lang.String
CONTROLLER_HELIX_CLOUD_ID
"controller.helix.cloud.id"
public static final java.lang.String
CONTROLLER_HELIX_CLOUD_INFO_PROCESSOR_NAME
"controller.helix.cloud.info.processor.name"
public static final java.lang.String
CONTROLLER_HELIX_CLOUD_INFO_PROCESSOR_PACKAGE
"controller.helix.cloud.info.processor.package"
public static final java.lang.String
CONTROLLER_HELIX_CLOUD_INFO_SOURCES
"controller.helix.cloud.info.sources"
public static final java.lang.String
CONTROLLER_HELIX_CLOUD_PROVIDER
"controller.helix.cloud.provider"
public static final java.lang.String
CONTROLLER_HELIX_REST_CUSTOMIZED_HEALTH_URL
"controller.helix.rest.customized.health.url"
public static final java.lang.String
CONTROLLER_INSTANCE_TAG_LIST
"controller.instance.tag.list"
public static final java.lang.String
CONTROLLER_JETTY_CONFIG_OVERRIDE_PREFIX
"controller.jetty."
public static final java.lang.String
CONTROLLER_MIN_SCHEMA_COUNT_TO_KEEP
"controller.min.schema.count.keep"
public static final java.lang.String
CONTROLLER_NAME
"controller.name"
public static final java.lang.String
CONTROLLER_PARENT_EXTERNAL_SUPERSET_SCHEMA_GENERATION_ENABLED
"controller.parent.external.superset.schema.generation.enabled"
public static final java.lang.String
CONTROLLER_PARENT_MODE
"controller.parent.mode"
public static final java.lang.String
CONTROLLER_PARENT_REGION_STATE
"controller.parent.region.state"
public static final java.lang.String
CONTROLLER_PARENT_SYSTEM_STORE_HEARTBEAT_CHECK_WAIT_TIME_SECONDS
"controller.parent.system.store.heartbeat.check.wait.time.seconds"
public static final java.lang.String
CONTROLLER_PARENT_SYSTEM_STORE_REPAIR_CHECK_INTERVAL_SECONDS
"controller.parent.system.store.repair.check.interval.seconds"
public static final java.lang.String
CONTROLLER_PARENT_SYSTEM_STORE_REPAIR_RETRY_COUNT
"controller.parent.system.store.repair.retry.count"
public static final java.lang.String
CONTROLLER_PARENT_SYSTEM_STORE_REPAIR_SERVICE_ENABLED
"controller.parent.system.store.repair.service.enabled"
public static final java.lang.String
CONTROLLER_RESOURCE_INSTANCE_GROUP_TAG
"controller.resource.instance.group.tag"
public static final java.lang.String
CONTROLLER_SCHEMA_VALIDATION_ENABLED
"controller.schema.validation.enabled"
public static final java.lang.String
CONTROLLER_SSL_ENABLED
"controller.ssl.enabled"
public static final java.lang.String
CONTROLLER_STORAGE_CLUSTER_HELIX_CLOUD_ENABLED
"controller.storage.cluster.helix.cloud.enabled"
public static final java.lang.String
CONTROLLER_STORE_GRAVEYARD_CLEANUP_DELAY_MINUTES
"controller.store.graveyard.cleanup.delay.minutes"
public static final java.lang.String
CONTROLLER_STORE_GRAVEYARD_CLEANUP_ENABLED
"controller.store.graveyard.cleanup.enabled"
public static final java.lang.String
CONTROLLER_STORE_GRAVEYARD_CLEANUP_SLEEP_INTERVAL_BETWEEN_LIST_FETCH_MINUTES
"controller.store.graveyard.cleanup.sleep.interval.between.list.fetch.minutes"
public static final java.lang.String
CONTROLLER_SYSTEM_SCHEMA_CLUSTER_NAME
"controller.system.schema.cluster.name"
public static final java.lang.String
CONTROLLER_SYSTEM_STORE_ACL_SYNCHRONIZATION_DELAY_MS
"controller.system.store.acl.synchronization.delay.ms"
public static final java.lang.String
CONTROLLER_UNUSED_SCHEMA_CLEANUP_INTERVAL_SECONDS
"controller.unused.schema.cleanup.interval.seconds"
public static final java.lang.String
CONTROLLER_UNUSED_VALUE_SCHEMA_CLEANUP_ENABLED
"controller.unused.value.schema.cleanup.enabled"
public static final java.lang.String
CONTROLLER_ZK_SHARED_DAVINCI_PUSH_STATUS_SYSTEM_SCHEMA_STORE_AUTO_CREATION_ENABLED
"controller.zk.shared.davinci.push.status.system.schema.store.auto.creation.enabled"
public static final java.lang.String
CONTROLLER_ZK_SHARED_META_SYSTEM_SCHEMA_STORE_AUTO_CREATION_ENABLED
"controller.zk.shared.metadata.system.schema.store.auto.creation.enabled"
public static final java.lang.String
D2_ZK_HOSTS_ADDRESS
"r2d2Client.zkHosts"
public static final java.lang.String
DA_VINCI_CURRENT_VERSION_BOOTSTRAPPING_QUOTA_BYTES_PER_SECOND
"da.vinci.current.version.bootstrapping.quota.bytes.per.second"
public static final java.lang.String
DA_VINCI_CURRENT_VERSION_BOOTSTRAPPING_QUOTA_RECORDS_PER_SECOND
"da.vinci.current.version.bootstrapping.quota.records.per.second"
public static final java.lang.String
DA_VINCI_CURRENT_VERSION_BOOTSTRAPPING_SPEEDUP_ENABLED
"da.vinci.current.version.bootstrapping.speedup.enabled"
public static final java.lang.String
DATA_BASE_PATH
"data.base.path"
public static final java.lang.String
DAVINCI_P2P_BLOB_TRANSFER_CLIENT_PORT
"davinci.p2p.blob.transfer.client.port"
public static final java.lang.String
DAVINCI_P2P_BLOB_TRANSFER_SERVER_PORT
"davinci.p2p.blob.transfer.server.port"
public static final java.lang.String
DAVINCI_PUSH_STATUS_CHECK_INTERVAL_IN_MS
"davinci.push.status.check.interval.in.ms"
public static final java.lang.String
DAVINCI_PUSH_STATUS_SCAN_ENABLED
"davinci.push.status.scan.enabled"
public static final java.lang.String
DAVINCI_PUSH_STATUS_SCAN_INTERVAL_IN_SECONDS
"davinci.push.status.scan.interval.in.seconds"
public static final java.lang.String
DAVINCI_PUSH_STATUS_SCAN_MAX_OFFLINE_INSTANCE_COUNT
"davinci.push.status.scan.max.offline.instance.count"
public static final java.lang.String
DAVINCI_PUSH_STATUS_SCAN_MAX_OFFLINE_INSTANCE_RATIO
"davinci.push.status.scan.max.offline.instance.ratio"
public static final java.lang.String
DAVINCI_PUSH_STATUS_SCAN_NO_REPORT_RETRY_MAX_ATTEMPTS
"davinci.push.status.scan.no.report.retry.max.attempts"
public static final java.lang.String
DAVINCI_PUSH_STATUS_SCAN_THREAD_NUMBER
"davinci.push.status.scan.thread.number"
public static final java.lang.String
DEFAULT_MAX_NUMBER_OF_PARTITIONS
"default.partition.max.count"
public static final java.lang.String
DEFAULT_MAX_RECORD_SIZE_BYTES
"default.max.record.size.bytes"
public static final java.lang.String
DEFAULT_NUMBER_OF_PARTITION
"default.partition.count"
public static final java.lang.String
DEFAULT_NUMBER_OF_PARTITION_FOR_HYBRID
"default.partition.count.for.hybrid"
public static final java.lang.String
DEFAULT_OFFLINE_PUSH_STRATEGY
"default.offline.push.strategy"
public static final java.lang.String
DEFAULT_PARTITION_SIZE
"default.partition.size"
public static final java.lang.String
DEFAULT_READ_STRATEGY
"default.read.strategy"
public static final java.lang.String
DEFAULT_REPLICA_FACTOR
"default.replica.factor"
public static final java.lang.String
DEFAULT_ROUTING_STRATEGY
"default.routing.strategy"
public static final java.lang.String
DELAY_TO_REBALANCE_MS
"delay.to.rebalance.ms"
public static final java.lang.String
DEPRECATED_TOPIC_MAX_RETENTION_MS
"deprecated.topic.max.retention.ms"
public static final java.lang.String
DEPRECATED_TOPIC_RETENTION_MS
"deprecated.topic.retention.ms"
public static final java.lang.String
DIV_PRODUCER_STATE_MAX_AGE_MS
"div.producer.state.max.age.ms"
public static final java.lang.String
EMERGENCY_SOURCE_REGION
"emergency.source.region"
public static final java.lang.String
ENABLE_ACTIVE_ACTIVE_REPLICATION_AS_DEFAULT_FOR_HYBRID_STORE
"enable.active.active.replication.as.default.for.hybrid.store"
public static final java.lang.String
ENABLE_BLOB_TRANSFER
"enable.blob.transfer"
public static final java.lang.String
ENABLE_GRPC_READ_SERVER
"grpc.read.server.enabled"
public static final java.lang.String
ENABLE_HYBRID_PUSH_SSL_ALLOWLIST
"enable.hybrid.push.ssl.allowlist"
public static final java.lang.String
ENABLE_HYBRID_PUSH_SSL_WHITELIST
"enable.hybrid.push.ssl.whitelist"
public static final java.lang.String
ENABLE_INCREMENTAL_PUSH_FOR_HYBRID_ACTIVE_ACTIVE_USER_STORES
"enable.incremental.push.for.hybrid.active.active.user.stores"
public static final java.lang.String
ENABLE_OFFLINE_PUSH_SSL_ALLOWLIST
"enable.offline.push.ssl.allowlist"
public static final java.lang.String
ENABLE_OFFLINE_PUSH_SSL_WHITELIST
"enable.offline.push.ssl.whitelist"
public static final java.lang.String
ENABLE_PARTIAL_UPDATE_FOR_HYBRID_ACTIVE_ACTIVE_USER_STORES
"enable.partial.update.for.hybrid.active.active.user.stores"
public static final java.lang.String
ENABLE_PARTIAL_UPDATE_FOR_HYBRID_NON_ACTIVE_ACTIVE_USER_STORES
"enable.partial.update.for.hybrid.non.active.active.user.stores"
public static final java.lang.String
ENABLE_PARTITION_COUNT_ROUND_UP
"enable.partition.count.round.up"
public static final java.lang.String
ENABLE_SEPARATE_REAL_TIME_TOPIC_FOR_STORE_WITH_INCREMENTAL_PUSH
"enable.separate.real.time.topic.for.store.with.incremental.push"
public static final java.lang.String
ENABLE_SERVER_ALLOW_LIST
"enable.server.allowlist"
public static final java.lang.String
ENFORCE_SECURE_ROUTER
"router.enforce.ssl"
public static final java.lang.String
ERROR_PARTITION_AUTO_RESET_LIMIT
"error.partition.auto.reset.limit"
public static final java.lang.String
ERROR_PARTITION_PROCESSING_CYCLE_DELAY
"error.partition.processing.cycle.delay"
public static final java.lang.String
FAST_AVRO_FIELD_LIMIT_PER_METHOD
"fast.avro.field.limit.per.method"
public static final java.lang.String
FATAL_DATA_VALIDATION_FAILURE_TOPIC_RETENTION_MS
"fatal.data.validation.failure.topic.retention.ms"
public static final java.lang.String
FORCE_LEADER_ERROR_REPLICA_FAIL_OVER_ENABLED
"controller.force.leader.error.replica.fail.over.enabled"
public static final java.lang.String
FREEZE_INGESTION_IF_READY_TO_SERVE_OR_LOCAL_DATA_EXISTS
"freeze.ingestion.if.ready.to.serve.or.local.data.exists"
public static final java.lang.String
GRPC_READ_SERVER_PORT
"grpc.read.server.port"
public static final java.lang.String
GRPC_SERVER_WORKER_THREAD_COUNT
"grpc.server.worker.thread.count"
public static final java.lang.String
HEARTBEAT_CYCLE
"heartbeat.cycle"
public static final java.lang.String
HEARTBEAT_TIMEOUT
"heartbeat.timeout"
public static final java.lang.String
HELIX_HYBRID_STORE_QUOTA_ENABLED
"helix.hybrid.store.quota.enabled"
public static final java.lang.String
HELIX_REBALANCE_ALG
"helix.rebalance.alg"
public static final java.lang.String
HELIX_SEND_MESSAGE_TIMEOUT_MS
"helix.send.message.timeout.ms"
public static final java.lang.String
HYBRID_QUOTA_ENFORCEMENT_ENABLED
"server.hybrid.quota.enforcement.enabled"
public static final java.lang.String
IDENTITY_PARSER_CLASS
"identity.parser.class"
public static final java.lang.String
INGESTION_MEMORY_LIMIT
"ingestion.memory.limit"
public static final java.lang.String
INGESTION_MEMORY_LIMIT_STORE_LIST
"ingestion.memory.limit.store.list"
public static final java.lang.String
INGESTION_MLOCK_ENABLED
"ingestion.mlock.enabled"
public static final java.lang.String
INGESTION_USE_DA_VINCI_CLIENT
"ingestion.use.da.vinci.client"
public static final java.lang.String
INSTANCE_ID
"instance.id"
public static final java.lang.String
KAFKA_ADMIN_CLASS
"kafka.admin.class"
public static final java.lang.String
KAFKA_ADMIN_GET_TOPIC_CONFIG_MAX_RETRY_TIME_SEC
"kafka.admin.get.topic.config.max.retry.sec"
public static final java.lang.String
KAFKA_AUTO_OFFSET_RESET_CONFIG
"kafka.auto.offset.reset"
public static final java.lang.String
KAFKA_BOOTSTRAP_SERVERS
"kafka.bootstrap.servers"
public static final java.lang.String
KAFKA_CLIENT_ID_CONFIG
"kafka.client.id"
public static final java.lang.String
KAFKA_CLUSTER_MAP_KEY_NAME
"name"
public static final java.lang.String
KAFKA_CLUSTER_MAP_KEY_OTHER_URLS
"otherUrls"
public static final java.lang.String
KAFKA_CLUSTER_MAP_KEY_URL
"url"
public static final java.lang.String
KAFKA_CLUSTER_MAP_SECURITY_PROTOCOL
"securityProtocol"
public static final java.lang.String
KAFKA_CONFIG_PREFIX
"kafka."
public static final java.lang.String
KAFKA_EMPTY_POLL_SLEEP_MS
"kafka.empty.poll.sleep.ms"
public static final java.lang.String
KAFKA_ENABLE_AUTO_COMMIT_CONFIG
"kafka.enable.auto.commit"
public static final java.lang.String
KAFKA_FETCH_MAX_BYTES_CONFIG
"kafka.fetch.max.bytes"
public static final java.lang.String
KAFKA_FETCH_MAX_SIZE_PER_SEC
"kafka.fetch.max.size.per.sec"
public static final java.lang.String
KAFKA_FETCH_MAX_WAIT_MS_CONFIG
"kafka.fetch.max.wait.ms"
public static final java.lang.String
KAFKA_FETCH_MAX_WAIT_TIME_MS
"kafka.fetch.max.wait.time.ms"
public static final java.lang.String
KAFKA_FETCH_MIN_BYTES_CONFIG
"kafka.fetch.min.bytes"
public static final java.lang.String
KAFKA_FETCH_MIN_SIZE_PER_SEC
"kafka.fetch.min.size.per.sec"
public static final java.lang.String
KAFKA_FETCH_PARTITION_MAX_SIZE_PER_SEC
"kafka.fetch.partition.max.size.per.sec"
public static final java.lang.String
KAFKA_FETCH_QUOTA_BYTES_PER_SECOND
"kafka.fetch.quota.bytes.per.second"
public static final java.lang.String
KAFKA_FETCH_QUOTA_RECORDS_PER_SECOND
"kafka.fetch.quota.records.per.second"
public static final java.lang.String
KAFKA_FETCH_QUOTA_TIME_WINDOW_MS
"kafka.fetch.quota.time.window.ms"
public static final java.lang.String
KAFKA_FETCH_QUOTA_UNORDERED_BYTES_PER_SECOND
"kafka.fetch.quota.unordered.bytes.per.second"
public static final java.lang.String
KAFKA_FETCH_QUOTA_UNORDERED_RECORDS_PER_SECOND
"kafka.fetch.quota.unordered.records.per.second"
public static final java.lang.String
KAFKA_GROUP_ID_CONFIG
"kafka.group.id"
public static final java.lang.String
KAFKA_LINGER_MS
"kafka.linger.ms"
public static final java.lang.String
KAFKA_LOG_COMPACTION_FOR_HYBRID_STORES
"kafka.log.compaction.for.hybrid.stores"
public static final java.lang.String
KAFKA_MAX_PARTITION_FETCH_BYTES_CONFIG
"kafka.max.partition.fetch.bytes"
public static final java.lang.String
KAFKA_MAX_POLL_RECORDS_CONFIG
"kafka.max.poll.records"
public static final java.lang.String
KAFKA_MIN_IN_SYNC_REPLICAS
"kafka.min.in.sync.replicas"
public static final java.lang.String
KAFKA_MIN_IN_SYNC_REPLICAS_ADMIN_TOPICS
"kafka.min.in.sync.replicas.admin.topics"
public static final java.lang.String
KAFKA_MIN_IN_SYNC_REPLICAS_RT_TOPICS
"kafka.min.in.sync.replicas.rt.topics"
public static final java.lang.String
KAFKA_OVER_SSL
"kafka.over.ssl"
public static final java.lang.String
KAFKA_PRODUCER_DELIVERY_TIMEOUT_MS
"kafka.delivery.timeout.ms"
public static final java.lang.String
KAFKA_PRODUCER_METRICS
"list.of.producer.metrics.from.kafka"
public static final java.lang.String
KAFKA_PRODUCER_REQUEST_TIMEOUT_MS
"kafka.request.timeout.ms"
public static final java.lang.String
KAFKA_PRODUCER_RETRIES_CONFIG
"kafka.retries"
public static final java.lang.String
KAFKA_READ_CYCLE_DELAY_MS
"kafka.read.cycle.delay.ms"
public static final java.lang.String
KAFKA_READ_ONLY_ADMIN_CLASS
"kafka.read.only.admin.class"
public static final java.lang.String
KAFKA_REPLICATION_FACTOR
"kafka.replication.factor"
public static final java.lang.String
KAFKA_REPLICATION_FACTOR_RT_TOPICS
"kafka.replication.factor.rt.topics"
public static final java.lang.String
KAFKA_SECURITY_PROTOCOL
"security.protocol"
public static final java.lang.String
KAFKA_WRITE_ONLY_ADMIN_CLASS
"kafka.write.only.admin.class"
public static final java.lang.String
KEY_VALUE_PROFILING_ENABLED
"key.value.profiling.enabled"
public static final java.lang.String
KME_REGISTRATION_FROM_MESSAGE_HEADER_ENABLED
"kme.registration.from.message.header.enabled"
public static final java.lang.String
LEADER_FOLLOWER_STATE_TRANSITION_THREAD_POOL_STRATEGY
"leader.follower.state.transition.thread.pool.strategy"
public static final java.lang.String
LEAKED_PUSH_STATUS_CLEAN_UP_SERVICE_SLEEP_INTERVAL_MS
"leaked.push.status.clean.up.service.interval.ms"
public static final java.lang.String
LEAKED_RESOURCE_ALLOWED_LINGER_TIME_MS
"leaked.resource.allowed.linger.time.ms"
public static final java.lang.String
LISTENER_HOSTNAME
"listener.hostname"
public static final java.lang.String
LISTENER_PORT
"listener.port"
public static final java.lang.String
LISTENER_SSL_PORT
"listener.ssl.port"
public static final java.lang.String
LOCAL_CONTROLLER_D2_SERVICE_NAME
"local.controller.d2.service.name"
public static final java.lang.String
LOCAL_CONTROLLER_URL
"local.controller.url"
public static final java.lang.String
LOCAL_D2_ZK_HOST
"local.d2.zk.host"
public static final java.lang.String
LOCAL_REGION_NAME
"local.region.name"
public static final java.lang.String
MAX_FUTURE_VERSION_LEADER_FOLLOWER_STATE_TRANSITION_THREAD_NUMBER
"max.future.version.leader.follower.state.transition.thread.number"
public static final java.lang.String
MAX_LEADER_FOLLOWER_STATE_TRANSITION_THREAD_NUMBER
"max.leader.follower.state.transition.thread.number"
public static final java.lang.String
MAX_ONLINE_OFFLINE_STATE_TRANSITION_THREAD_NUMBER
"max.state.transition.thread.number"
public static final java.lang.String
MAX_READ_CAPACITY
"max.read.capacity"
public static final java.lang.String
META_STORE_WRITER_CLOSE_CONCURRENCY
"meta.store.writer.close.concurrency"
public static final java.lang.String
META_STORE_WRITER_CLOSE_TIMEOUT_MS
"meta.store.writer.close.timeout.ms"
public static final java.lang.String
MIN_CONSUMER_IN_CONSUMER_POOL_PER_KAFKA_CLUSTER
"min.consumer.in.consumer.pool.per.kafka.cluster"
public static final java.lang.String
MIN_NUMBER_OF_STORE_VERSIONS_TO_PRESERVE
"min.number.of.store.versions.to.preserve"
public static final java.lang.String
MIN_NUMBER_OF_UNUSED_KAFKA_TOPICS_TO_PRESERVE
"min.number.of.unused.kafka.topics.to.preserve"
public static final java.lang.String
MULTI_REGION
"multi.region"
public static final java.lang.String
NATIVE_REPLICATION_FABRIC_ALLOWLIST
"native.replication.fabric.allowlist"
public static final java.lang.String
NATIVE_REPLICATION_FABRIC_WHITELIST
"native.replication.fabric.whitelist"
public static final java.lang.String
NATIVE_REPLICATION_SOURCE_FABRIC
"native.replication.source.fabric"
public static final java.lang.String
NATIVE_REPLICATION_SOURCE_FABRIC_AS_DEFAULT_FOR_BATCH_ONLY_STORES
"native.replication.source.fabric.as.default.for.batch.only.stores"
public static final java.lang.String
NATIVE_REPLICATION_SOURCE_FABRIC_AS_DEFAULT_FOR_HYBRID_STORES
"native.replication.source.fabric.as.default.for.hybrid.stores"
public static final java.lang.String
OFFLINE_JOB_START_TIMEOUT_MS
"offline.job.start.timeout.ms"
public static final java.lang.String
OFFSET_LAG_DELTA_RELAX_FACTOR_FOR_FAST_ONLINE_TRANSITION_IN_RESTART
"offset.lag.delta.relax.factor.for.fast.online.transition.in.restart"
public static final java.lang.String
PARENT_CONTROLLER_MAX_ERRORED_TOPIC_NUM_TO_KEEP
"parent.controller.max.errored.topic.num.to.keep"
public static final java.lang.String
PARENT_CONTROLLER_WAITING_TIME_FOR_CONSUMPTION_MS
"parent.controller.waiting.time.for.consumption.ms"
public static final java.lang.String
PARENT_KAFKA_CLUSTER_FABRIC_LIST
"parent.kafka.cluster.fabric.list"
public static final java.lang.String
PARTICIPANT_MESSAGE_CONSUMPTION_DELAY_MS
"participant.message.consumption.delay.ms"
public static final java.lang.String
PARTICIPANT_MESSAGE_STORE_ENABLED
"participant.message.store.enabled"
public static final java.lang.String
PARTITION_COUNT_ROUND_UP_SIZE
"partition.count.round.up.size"
public static final java.lang.String
PARTITIONER_CLASS
"partitioner.class"
public static final java.lang.String
PERSISTENCE_TYPE
"persistence.type"
public static final java.lang.String
PUB_SUB_ADMIN_ADAPTER_FACTORY_CLASS
"pub.sub.admin.adapter.factory.class"
public static final java.lang.String
PUB_SUB_CONSUMER_ADAPTER_FACTORY_CLASS
"pub.sub.consumer.adapter.factory.class"
public static final java.lang.String
PUB_SUB_PRODUCER_ADAPTER_FACTORY_CLASS
"pub.sub.producer.adapter.factory.class"
public static final java.lang.String
PUB_SUB_SOURCE_OF_TRUTH_ADMIN_ADAPTER_FACTORY_CLASS
"pub.sub.of.source.of.truth.admin.adapter.factory.class"
public static final java.lang.String
PUBSUB_TOPIC_MANAGER_METADATA_FETCHER_CONSUMER_POOL_SIZE
"pubsub.topic.manager.metadata.fetcher.consumer.pool.size"
public static final java.lang.String
PUBSUB_TOPIC_MANAGER_METADATA_FETCHER_THREAD_POOL_SIZE
"pubsub.topic.manager.metadata.fetcher.thread.pool.size"
public static final java.lang.String
PUSH_JOB_FAILURE_CHECKPOINTS_TO_DEFINE_USER_ERROR
"push.job.failure.checkpoints.to.define.user.error"
public static final java.lang.String
PUSH_JOB_GUID_LEAST_SIGNIFICANT_BITS
"push.job.guid.least.significant.bits"
public static final java.lang.String
PUSH_JOB_GUID_MOST_SIGNIFICANT_BITS
"push.job.guid.most.significant.bits"
public static final java.lang.String
PUSH_JOB_STATUS_STORE_CLUSTER_NAME
"controller.push.job.status.store.cluster.name"
public static final java.lang.String
PUSH_MONITOR_TYPE
"push.monitor.type"
public static final java.lang.String
PUSH_SSL_ALLOWLIST
"push.ssl.allowlist"
public static final java.lang.String
PUSH_SSL_WHITELIST
"push.ssl.whitelist"
public static final java.lang.String
PUSH_STATUS_INSTANCE_NAME_SUFFIX
"push.status.instance.name.suffix"
public static final java.lang.String
PUSH_STATUS_STORE_ENABLED
"push.status.store.enabled"
public static final java.lang.String
PUSH_STATUS_STORE_HEARTBEAT_EXPIRATION_TIME_IN_SECONDS
"push.status.store.heartbeat.expiration.seconds"
public static final java.lang.String
PUSH_STATUS_STORE_HEARTBEAT_INTERVAL_IN_SECONDS
"push.status.store.heartbeat.interval.seconds"
public static final java.lang.String
REFRESH_ATTEMPTS_FOR_ZK_RECONNECT
"refresh.attempts.for.zk.reconnect"
public static final java.lang.String
REFRESH_INTERVAL_FOR_ZK_RECONNECT_MS
"refresh.interval.for.zk.reconnect.ms"
public static final java.lang.String
REPLICATION_METADATA_VERSION
"replication.metadata.version"
public static final java.lang.String
ROUTE_DNS_CACHE_HOST_PATTERN
"router.dns.cache.host.pattern"
public static final java.lang.String
ROUTER_ASYNC_START_ENABLED
"router.async.start.enabled"
public static final java.lang.String
ROUTER_CLIENT_DECOMPRESSION_ENABLED
"router.client.decompression.enabled"
public static final java.lang.String
ROUTER_CLIENT_RESOLUTION_RETRY_ATTEMPTS
"router.client.resolution.retry.attempts"
public static final java.lang.String
ROUTER_CLIENT_RESOLUTION_RETRY_BACKOFF_MS
"router.client.resolution.retry.backoff.ms"
public static final java.lang.String
ROUTER_CLIENT_SSL_HANDSHAKE_QUEUE_CAPACITY
"router.client.ssl.handshake.queue.capacity"
public static final java.lang.String
ROUTER_CLIENT_SSL_HANDSHAKE_THREADS
"router.client.ssl.handshake.threads"
public static final java.lang.String
ROUTER_COMPUTE_TARDY_LATENCY_MS
"router.compute.tardy.latency.ms"
public static final java.lang.String
ROUTER_CONNECTION_LIMIT
"router.connection.limit"
public static final java.lang.String
ROUTER_CONNECTION_TIMEOUT
"router.connection.timeout"
public static final java.lang.String
ROUTER_DICTIONARY_PROCESSING_THREADS
"router.dictionary.processing.threads"
public static final java.lang.String
ROUTER_DICTIONARY_RETRIEVAL_TIME_MS
"router.dictionary.retrieval.time.ms"
public static final java.lang.String
ROUTER_DNS_CACHE_ENABLED
"router.dns.cache.enabled"
public static final java.lang.String
ROUTER_DNS_CACHE_REFRESH_INTERVAL_MS
"router.dns.cache.refresh.interval.ms"
public static final java.lang.String
ROUTER_EARLY_THROTTLE_ENABLED
"router.early.throttle.enabled"
public static final java.lang.String
ROUTER_ENABLE_READ_THROTTLING
"router.enable.read.throttling"
public static final java.lang.String
ROUTER_ENABLE_SSL
"router.enable.ssl"
public static final java.lang.String
ROUTER_FULL_PENDING_QUEUE_SERVER_OOR_MS
"router.full.pending.queue.server.oor.ms"
public static final java.lang.String
ROUTER_HEART_BEAT_ENABLED
"router.heart.beat.enabled"
public static final java.lang.String
ROUTER_HELIX_ASSISTED_ROUTING_GROUP_SELECTION_STRATEGY
"router.helix.assisted.routing.group.selection.strategy"
public static final java.lang.String
ROUTER_HELIX_VIRTUAL_GROUP_FIELD_IN_DOMAIN
"router.helix.virtual.group.field.in.domain"
public static final java.lang.String
ROUTER_HTTP_CLIENT_OPENSSL_ENABLED
"router.http.client.openssl.enabled"
public static final java.lang.String
ROUTER_HTTP_CLIENT_POOL_SIZE
"router.http.client.pool.size"
public static final java.lang.String
ROUTER_HTTP_CLIENT5_POOL_SIZE
"router.http.client5.pool.size"
public static final java.lang.String
ROUTER_HTTP_CLIENT5_SKIP_CIPHER_CHECK_ENABLED
"router.http.client5.skip.cipher.check.enabled"
public static final java.lang.String
ROUTER_HTTP_CLIENT5_TOTAL_IO_THREAD_COUNT
"router.http.client5.total.io.thread.count"
public static final java.lang.String
ROUTER_HTTP2_HEADER_TABLE_SIZE
"router.http2.header.table.size"
public static final java.lang.String
ROUTER_HTTP2_INBOUND_ENABLED
"router.http2.inbound.enabled"
public static final java.lang.String
ROUTER_HTTP2_INITIAL_WINDOW_SIZE
"router.http2.initial.window.size"
public static final java.lang.String
ROUTER_HTTP2_MAX_CONCURRENT_STREAMS
"router.http2.max.concurrent.streams"
public static final java.lang.String
ROUTER_HTTP2_MAX_FRAME_SIZE
"router.http2.max.frame.size"
public static final java.lang.String
ROUTER_HTTP2_MAX_HEADER_LIST_SIZE
"router.http2.max.header.list.size"
public static final java.lang.String
ROUTER_HTTPASYNCCLIENT_CLIENT_POOL_THREAD_COUNT
"router.httpasyncclient.client.pool.io.thread.count"
public static final java.lang.String
ROUTER_HTTPASYNCCLIENT_CONNECTION_WARMING_ENABLED
"router.httpasyncclient.connection.warming.enabled"
public static final java.lang.String
ROUTER_HTTPASYNCCLIENT_CONNECTION_WARMING_EXECUTOR_THREAD_NUM
"router.httpasyncclient.connection.warming.executor.thread.num"
public static final java.lang.String
ROUTER_HTTPASYNCCLIENT_CONNECTION_WARMING_LOW_WATER_MARK
"router.httpasyncclient.connection.warming.low.water.mark"
public static final java.lang.String
ROUTER_HTTPASYNCCLIENT_CONNECTION_WARMING_NEW_INSTANCE_DELAY_JOIN_MS
"router.httpasyncclient.connection.warming.new.instance.delay.join.ms"
public static final java.lang.String
ROUTER_HTTPASYNCCLIENT_CONNECTION_WARMING_SLEEP_INTERVAL_MS
"router.httpasyncclient.connection.warming.sleep.interval.ms"
public static final java.lang.String
ROUTER_HTTPAYSNCCLIENT_CONNECTION_WARMING_SOCKET_TIMEOUT_MS
"router.httpasyncclient.connection.warming.socket.timeout.ms"
public static final java.lang.String
ROUTER_IDLE_CONNECTION_TO_SERVER_CLEANUP_ENABLED
"router.idle.connection.to.server.cleanup.enabled"
public static final java.lang.String
ROUTER_IDLE_CONNECTION_TO_SERVER_CLEANUP_THRESHOLD_MINS
"router.idle.connection.to.server.cleanup.threshold.mins"
public static final java.lang.String
ROUTER_IO_WORKER_COUNT
"router.io.worker.count"
public static final java.lang.String
ROUTER_LEAKED_FUTURE_CLEANUP_POLL_INTERVAL_MS
"router.leaked.future.cleanup.poll.interval.ms"
public static final java.lang.String
ROUTER_LEAKED_FUTURE_CLEANUP_THRESHOLD_MS
"router.leaked.future.cleanup.threshold.ms"
public static final java.lang.String
ROUTER_LONG_TAIL_RETRY_BUDGET_ENFORCEMENT_WINDOW_MS
"router.long.tail.retry.budget.enforcement.window.ms"
public static final java.lang.String
ROUTER_LONG_TAIL_RETRY_FOR_BATCH_GET_THRESHOLD_MS
"router.long.tail.retry.for.batch.get.threshold.ms"
public static final java.lang.String
ROUTER_LONG_TAIL_RETRY_FOR_SINGLE_GET_THRESHOLD_MS
"router.long.tail.retry.for.single.get.threshold.ms"
public static final java.lang.String
ROUTER_LONG_TAIL_RETRY_MAX_ROUTE_FOR_MULTI_KEYS_REQ
"router.long.tail.retry.max.route.for.multi.keys.req"
public static final java.lang.String
ROUTER_MAX_CONCURRENT_RESOLUTIONS
"router.max.concurrent.resolutions"
public static final java.lang.String
ROUTER_MAX_KEY_COUNT_IN_MULTIGET_REQ
"router.max.key_count.in.multiget.req"
public static final java.lang.String
ROUTER_MAX_OUTGOING_CONNECTION
"router.max.outgoing.connection"
public static final java.lang.String
ROUTER_MAX_OUTGOING_CONNECTION_PER_ROUTE
"router.max.outgoing.connection.per.route"
public static final java.lang.String
ROUTER_MAX_PENDING_REQUEST
"router.max.pending.request"
public static final java.lang.String
ROUTER_MAX_READ_CAPACITY
"router.max.read.capacity"
public static final java.lang.String
ROUTER_META_STORE_SHADOW_READ_ENABLED
"router.meta.store.shadow.read.enabled"
public static final java.lang.String
ROUTER_MULTI_KEY_LONG_TAIL_RETRY_BUDGET_PERCENT_DECIMAL
"router.multi.key.long.tail.retry.budget.percent.decimal"
public static final java.lang.String
ROUTER_MULTI_KEY_ROUTING_STRATEGY
"router.multi.key.routing.strategy"
public static final java.lang.String
ROUTER_MULTIGET_TARDY_LATENCY_MS
"router.multiget.tardy.latency.ms"
public static final java.lang.String
ROUTER_NETTY_GRACEFUL_SHUTDOWN_PERIOD_SECONDS
"router.netty.graceful.shutdown.period.seconds"
public static final java.lang.String
ROUTER_PENDING_CONNECTION_RESUME_THRESHOLD_PER_ROUTE
"router.pending.connection.resume.threshold.per.host"
public static final java.lang.String
ROUTER_PER_NODE_CLIENT_ENABLED
"router.per.node.client.enabled"
public static final java.lang.String
ROUTER_PER_NODE_CLIENT_THREAD_COUNT
"router.per.node.client.thread.count"
public static final java.lang.String
ROUTER_PER_STORE_ROUTER_QUOTA_BUFFER
"router.per.store.router.quota.buffer"
public static final java.lang.String
ROUTER_PRINCIPAL_NAME
"router.principal.name"
public static final java.lang.String
ROUTER_QUOTA_CHECK_WINDOW
"router.quota.check.window"
public static final java.lang.String
ROUTER_READ_QUOTA_THROTTLING_LEASE_TIMEOUT_MS
"router.read.quota.throttling.lease.timeout.ms"
public static final java.lang.String
ROUTER_RESOLVE_BEFORE_SSL
"router.resolve.before.ssl"
public static final java.lang.String
ROUTER_RETRY_MANAGER_CORE_POOL_SIZE
"router.retry.manager.core.pool.size"
public static final java.lang.String
ROUTER_SINGLE_KEY_LONG_TAIL_RETRY_BUDGET_PERCENT_DECIMAL
"router.single.key.long.tail.retry.budget.percent.decimal"
public static final java.lang.String
ROUTER_SINGLEGET_TARDY_LATENCY_MS
"router.singleget.tardy.latency.ms"
public static final java.lang.String
ROUTER_SMART_LONG_TAIL_RETRY_ABORT_THRESHOLD_MS
"router.smart.long.tail.retry.abort.threshold.ms"
public static final java.lang.String
ROUTER_SMART_LONG_TAIL_RETRY_ENABLED
"router.smart.long.tail.retry.enabled"
public static final java.lang.String
ROUTER_SOCKET_TIMEOUT
"router.socket.timeout"
public static final java.lang.String
ROUTER_STATEFUL_HEALTHCHECK_ENABLED
"router.stateful.healthcheck.enabled"
public static final java.lang.String
ROUTER_STORAGE_NODE_CLIENT_TYPE
"router.storage.node.client.type"
public static final java.lang.String
ROUTER_UNHEALTHY_PENDING_CONNECTION_THRESHOLD_PER_ROUTE
"router.unhealthy.pending.connection.threshold.per.host"
public static final java.lang.String
ROUTER_USE_LOCAL_SSL_SETTINGS
"router.local.ssl"
public static final java.lang.String
SERVER_AA_WC_LEADER_QUOTA_RECORDS_PER_SECOND
"server.aa.wc.leader.quota.records.per.second"
public static final java.lang.String
SERVER_AA_WC_WORKLOAD_PARALLEL_PROCESSING_ENABLED
"server.aa.wc.workload.parallel.processing.enabled"
public static final java.lang.String
SERVER_AA_WC_WORKLOAD_PARALLEL_PROCESSING_THREAD_POOL_SIZE
"server.aa.wc.workload.parallel.processing.thread.pool.size"
public static final java.lang.String
SERVER_BATCH_REPORT_END_OF_INCREMENTAL_PUSH_STATUS_ENABLED
"server.batch.report.end.of.incremental.push.status.enabled"
public static final java.lang.String
SERVER_BLOCKING_QUEUE_TYPE
"server.blocking.queue.type"
public static final java.lang.String
SERVER_CHANNEL_OPTION_WRITE_BUFFER_WATERMARK_HIGH_BYTES
"server.channel.option.write.buffer.watermark.high.bytes"
public static final java.lang.String
SERVER_COMPUTE_FAST_AVRO_ENABLED
"server.compute.fast.avro.enabled"
public static final java.lang.String
SERVER_COMPUTE_QUEUE_CAPACITY
"server.compute.queue.capacity"
public static final java.lang.String
SERVER_COMPUTE_THREAD_NUM
"server.compute.thread.num"
public static final java.lang.String
SERVER_CONSUMER_POOL_ALLOCATION_STRATEGY
"server.consumer.pool.allocation.strategy"
public static final java.lang.String
SERVER_CONSUMER_POOL_SIZE_FOR_CURRENT_VERSION_AA_WC_LEADER
"server.consumer.pool.size.for.current.version.aa.wc.leader"
public static final java.lang.String
SERVER_CONSUMER_POOL_SIZE_FOR_CURRENT_VERSION_NON_AA_WC_LEADER
"server.consumer.pool.size.for.current.version.non.aa.wc.leader"
public static final java.lang.String
SERVER_CONSUMER_POOL_SIZE_FOR_CURRENT_VERSION_SEPARATE_RT_LEADER
"server.consumer.pool.size.for.current.version.separate.rt.leader"
public static final java.lang.String
SERVER_CONSUMER_POOL_SIZE_FOR_NON_CURRENT_VERSION_AA_WC_LEADER
"server.consumer.pool.size.for.non.current.version.aa.wc.leader"
public static final java.lang.String
SERVER_CONSUMER_POOL_SIZE_FOR_NON_CURRENT_VERSION_NON_AA_WC_LEADER
"server.consumer.pool.size.for.non.current.version.non.aa.wc.leader"
public static final java.lang.String
SERVER_CONSUMER_POOL_SIZE_PER_KAFKA_CLUSTER
"server.consumer.pool.size.per.kafka.cluster"
public static final java.lang.String
SERVER_CURRENT_VERSION_AA_WC_LEADER_QUOTA_RECORDS_PER_SECOND
"server.current.version.aa.wc.leader.quota.records.per.second"
public static final java.lang.String
SERVER_CURRENT_VERSION_NON_AA_WC_LEADER_QUOTA_RECORDS_PER_SECOND
"server.current.version.non.aa.wc.leader.quota.records.per.second"
public static final java.lang.String
SERVER_CURRENT_VERSION_SEPARATE_RT_LEADER_QUOTA_RECORDS_PER_SECOND
"server.current.version.separate.rt.leader.quota.records.per.second"
public static final java.lang.String
SERVER_DATABASE_CHECKSUM_VERIFICATION_ENABLED
"server.database.checksum.verification.enabled"
public static final java.lang.String
SERVER_DATABASE_LOOKUP_QUEUE_CAPACITY
"server.database.lookup.queue.capacity"
public static final java.lang.String
SERVER_DATABASE_MEMORY_STATS_ENABLED
"server.database.memory.stats.enabled"
public static final java.lang.String
SERVER_DATABASE_SYNC_BYTES_INTERNAL_FOR_DEFERRED_WRITE_MODE
"server.database.sync.bytes.interval.for.deferred.write.mode"
public static final java.lang.String
SERVER_DATABASE_SYNC_BYTES_INTERNAL_FOR_TRANSACTIONAL_MODE
"server.database.sync.bytes.interval.for.transactional.mode"
public static final java.lang.String
SERVER_DB_READ_ONLY_FOR_BATCH_ONLY_STORE_ENABLED
"server.db.read.only.for.batch.only.store.enabled"
public static final java.lang.String
SERVER_DEBUG_LOGGING_ENABLED
"server.debug.logging.enabled"
public static final java.lang.String
SERVER_DEDICATED_CONSUMER_POOL_FOR_AA_WC_LEADER_ENABLED
"server.dedicated.consumer.pool.for.aa.wc.leader.enabled"
public static final java.lang.String
SERVER_DEDICATED_CONSUMER_POOL_SIZE_FOR_AA_WC_LEADER
"server.dedicated.consumer.pool.size.for.aa.wc.leader"
public static final java.lang.String
SERVER_DEDICATED_DRAINER_FOR_SORTED_INPUT_ENABLED
"server.dedicated.drainer.queue.for.sorted.input.enabled"
public static final java.lang.String
SERVER_DELETE_UNASSIGNED_PARTITIONS_ON_STARTUP
"server.delete.unassigned.partitions.on.startup"
public static final java.lang.String
SERVER_DISK_FULL_THRESHOLD
"disk.full.threshold"
public static final java.lang.String
SERVER_DISK_HEALTH_CHECK_INTERVAL_IN_SECONDS
"server.disk.health.check.interval.in.seconds"
public static final java.lang.String
SERVER_DISK_HEALTH_CHECK_SERVICE_ENABLED
"server.disk.health.check.service.enabled"
public static final java.lang.String
SERVER_DISK_HEALTH_CHECK_TIMEOUT_IN_SECONDS
"server.disk.health.check.timeout.in.seconds"
public static final java.lang.String
SERVER_ENABLE_LIVE_CONFIG_BASED_KAFKA_THROTTLING
"server.enable.live.config.based.kafka.throttling"
public static final java.lang.String
SERVER_ENABLE_PARALLEL_BATCH_GET
"server.enable.parallel.batch.get"
public static final java.lang.String
SERVER_FORKED_PROCESS_JVM_ARGUMENT_LIST
"server.forked.process.jvm.arg.list"
public static final java.lang.String
SERVER_GLOBAL_RT_DIV_ENABLED
"server.global.rt.div.enabled"
public static final java.lang.String
SERVER_HELIX_JOIN_AS_UNKNOWN
"server.helix.join.as.unknown"
public static final java.lang.String
SERVER_HTTP2_HEADER_TABLE_SIZE
"server.http2.header.table.size"
public static final java.lang.String
SERVER_HTTP2_INBOUND_ENABLED
"server.http2.inbound.enabled"
public static final java.lang.String
SERVER_HTTP2_INITIAL_WINDOW_SIZE
"server.http2.initial.window.size"
public static final java.lang.String
SERVER_HTTP2_MAX_CONCURRENT_STREAMS
"server.http2.max.concurrent.streams"
public static final java.lang.String
SERVER_HTTP2_MAX_FRAME_SIZE
"server.http2.max.frame.size"
public static final java.lang.String
SERVER_HTTP2_MAX_HEADER_LIST_SIZE
"server.http2.max.header.list.size"
public static final java.lang.String
SERVER_INCREMENTAL_PUSH_STATUS_WRITE_MODE
"server.incremental.push.status.write.mode"
public static final java.lang.String
SERVER_INGESTION_CHECKPOINT_DURING_GRACEFUL_SHUTDOWN_ENABLED
"server.ingestion.checkpoint.during.graceful.shutdown.enabled"
public static final java.lang.String
SERVER_INGESTION_HEARTBEAT_INTERVAL_MS
"server.ingestion.heartbeat.interval.ms"
public static final java.lang.String
SERVER_INGESTION_ISOLATION_ACL_ENABLED
"server.ingestion.isolation.acl.enabled"
public static final java.lang.String
SERVER_INGESTION_ISOLATION_APPLICATION_PORT
"server.ingestion.isolation.application.port"
public static final java.lang.String
SERVER_INGESTION_ISOLATION_CONNECTION_TIMEOUT_SECONDS
"server.ingestion.isolation.connection.timeout.seconds"
public static final java.lang.String
SERVER_INGESTION_ISOLATION_HEARTBEAT_REQUEST_TIMEOUT_SECONDS
"server.ingestion.isolation.heartbeat.request.timeout.seconds"
public static final java.lang.String
SERVER_INGESTION_ISOLATION_PRINCIPAL_NAME
"server.ingestion.isolation.principal.name"
public static final java.lang.String
SERVER_INGESTION_ISOLATION_REQUEST_TIMEOUT_SECONDS
"server.ingestion.isolation.request.timeout.seconds"
public static final java.lang.String
SERVER_INGESTION_ISOLATION_SERVICE_PORT
"server.ingestion.isolation.service.port"
public static final java.lang.String
SERVER_INGESTION_ISOLATION_SSL_ENABLED
"server.ingestion.isolation.ssl.enabled"
public static final java.lang.String
SERVER_INGESTION_ISOLATION_STATS_CLASS_LIST
"server.ingestion.isolation.stats.class.list"
public static final java.lang.String
SERVER_INGESTION_MODE
"server.ingestion.mode"
public static final java.lang.String
SERVER_INGESTION_TASK_MAX_IDLE_COUNT
"server.ingestion.task.max.idle.count"
public static final java.lang.String
SERVER_KAFKA_CONSUMER_OFFSET_COLLECTION_ENABLED
"server.kafka.consumer.offset.collection.enabled"
public static final java.lang.String
SERVER_KAFKA_FETCH_QUOTA_RECORDS_PER_SECOND
"server.kafka.fetch.quota.records.per.second"
public static final java.lang.String
SERVER_KAFKA_MAX_POLL_RECORDS
"server.kafka.max.poll.records"
public static final java.lang.String
SERVER_LEADER_COMPLETE_STATE_CHECK_IN_FOLLOWER_ENABLED
"server.leader.complete.state.check.in.follower.enabled"
public static final java.lang.String
SERVER_LEADER_COMPLETE_STATE_CHECK_IN_FOLLOWER_VALID_INTERVAL_MS
"server.leader.complete.state.check.in.follower.valid.interval.ms"
public static final java.lang.String
SERVER_LEAKED_RESOURCE_CLEAN_UP_INTERVAL_IN_MINUTES
"server.leaked.resource.clean.up.interval.in.minutes"
public static final java.lang.String
SERVER_LEAKED_RESOURCE_CLEANUP_ENABLED
"server.leaked.resource.cleanup.enabled"
public static final java.lang.String
SERVER_LOCAL_CONSUMER_CONFIG_PREFIX
"server.local.consumer.config.prefix."
public static final java.lang.String
SERVER_MAX_REQUEST_SIZE
"server.max.request.size"
public static final java.lang.String
SERVER_MAX_WAIT_AFTER_UNSUBSCRIBE_MS
"server.max.wait.after.unsubscribe.ms"
public static final java.lang.String
SERVER_MAX_WAIT_FOR_VERSION_INFO_MS_CONFIG
"server.max.wait.for.version.info.ms"
public static final java.lang.String
SERVER_NEARLINE_WORKLOAD_PRODUCER_THROUGHPUT_OPTIMIZATION_ENABLED
"server.nearline.workload.producer.throughput.optimization.enabled"
public static final java.lang.String
SERVER_NETTY_GRACEFUL_SHUTDOWN_PERIOD_SECONDS
"server.netty.graceful.shutdown.period.seconds"
public static final java.lang.String
SERVER_NETTY_IDLE_TIME_SECONDS
"server.netty.idle.time.seconds"
public static final java.lang.String
SERVER_NETTY_WORKER_THREADS
"server.netty.worker.threads"
public static final java.lang.String
SERVER_NODE_CAPACITY_RCU
"server.node.capacity.rcu.per.second"
public static final java.lang.String
SERVER_NON_CURRENT_VERSION_AA_WC_LEADER_QUOTA_RECORDS_PER_SECOND
"server.non.current.version.aa.wc.leader.quota.records.per.second"
public static final java.lang.String
SERVER_NON_CURRENT_VERSION_NON_AA_WC_LEADER_QUOTA_RECORDS_PER_SECOND
"server.non.current.version.non.aa.wc.leader.quota.records.per.second"
public static final java.lang.String
SERVER_NON_EXISTING_TOPIC_CHECK_RETRY_INTERNAL_SECOND
"server.non.existing.topic.check.retry.interval.second"
public static final java.lang.String
SERVER_NON_EXISTING_TOPIC_INGESTION_TASK_KILL_THRESHOLD_SECOND
"server.non.existing.topic.ingestion.task.kill.threshold.second"
public static final java.lang.String
SERVER_NUM_SCHEMA_FAST_CLASS_WARMUP
"server.num.schema.fast.class.warmup"
public static final java.lang.String
SERVER_OPTIMIZE_DATABASE_FOR_BACKUP_VERSION_ENABLED
"server.optimize.database.for.backup.version.enabled"
public static final java.lang.String
SERVER_OPTIMIZE_DATABASE_FOR_BACKUP_VERSION_NO_READ_THRESHOLD_SECONDS
"server.optimize.database.for.backup.version.no.read.threshold.seconds"
public static final java.lang.String
SERVER_OPTIMIZE_DATABASE_SERVICE_SCHEDULE_INTERNAL_SECONDS
"server.optimize.database.service.schedule.internal.seconds"
public static final java.lang.String
SERVER_PARALLEL_BATCH_GET_CHUNK_SIZE
"server.parallel.batch.get.chunk.size"
public static final java.lang.String
SERVER_PARTITION_GRACEFUL_DROP_DELAY_IN_SECONDS
"server.partition.graceful.drop.time.in.seconds"
public static final java.lang.String
SERVER_PROMOTION_TO_LEADER_REPLICA_DELAY_SECONDS
"server.promotion.to.leader.replica.delay.seconds"
public static final java.lang.String
SERVER_PUBSUB_CONSUMER_POLL_RETRY_BACKOFF_MS
"server.pubsub.consumer.poll.retry.backoff.ms"
public static final java.lang.String
SERVER_PUBSUB_CONSUMER_POLL_RETRY_TIMES
"server.pubsub.consumer.poll.retry.times"
public static final java.lang.String
SERVER_QUOTA_ENFORCEMENT_CAPACITY_MULTIPLE
"server.quota.enforcement.capacity.multiple"
public static final java.lang.String
SERVER_QUOTA_ENFORCEMENT_ENABLED
"server.quota.enforcement.enabled"
public static final java.lang.String
SERVER_QUOTA_ENFORCEMENT_INTERVAL_IN_MILLIS
"server.quota.enforcement.interval.in.millis"
public static final java.lang.String
SERVER_RECORD_LEVEL_METRICS_WHEN_BOOTSTRAPPING_CURRENT_VERSION_ENABLED
"server.record.level.metrics.when.bootstrapping.current.version.enabled"
public static final java.lang.String
SERVER_REMOTE_CONSUMER_CONFIG_PREFIX
"server.remote.consumer.config.prefix."
public static final java.lang.String
SERVER_REMOTE_INGESTION_REPAIR_SLEEP_INTERVAL_SECONDS
"server.remote.ingestion.repair.sleep.interval.seconds"
public static final java.lang.String
SERVER_RESET_ERROR_REPLICA_ENABLED
"server.reset.error.replica.enabled"
public static final java.lang.String
SERVER_REST_SERVICE_EPOLL_ENABLED
"server.rest.service.epoll.enabled"
public static final java.lang.String
SERVER_REST_SERVICE_STORAGE_THREAD_NUM
"server.rest.service.storage.thread.num"
public static final java.lang.String
SERVER_RESUBSCRIPTION_TRIGGERED_BY_VERSION_INGESTION_CONTEXT_CHANGE_ENABLED
"server.resubscription.triggered.by.version.ingestion.context.change.enabled"
public static final java.lang.String
SERVER_ROCKSDB_STORAGE_CONFIG_CHECK_ENABLED
"server.rocksdb.storage.config.check.enabled"
public static final java.lang.String
SERVER_ROUTER_CONNECTION_WARMING_DELAY_MS
"server.router.connection.warming.delay.ms"
public static final java.lang.String
SERVER_SCHEMA_FAST_CLASS_WARMUP_TIMEOUT
"server.schema.fast.class.warmup.timeout"
public static final java.lang.String
SERVER_SCHEMA_PRESENCE_CHECK_ENABLED
"server.schema.presence.check.enabled"
public static final java.lang.String
SERVER_SHARED_CONSUMER_ASSIGNMENT_STRATEGY
"server.shared.consumer.assignment.strategy"
public static final java.lang.String
SERVER_SHARED_CONSUMER_NON_EXISTING_TOPIC_CLEANUP_DELAY_MS
"server.shared.cosnumer.non.existing.topic.cleanup.delay.ms"
public static final java.lang.String
SERVER_SHUTDOWN_DISK_UNHEALTHY_TIME_MS
"server.shutdown.ssd.unhealthy.time.ms"
public static final java.lang.String
SERVER_SOURCE_TOPIC_OFFSET_CHECK_INTERVAL_MS
"server.source.topic.offset.check.interval.ms"
public static final java.lang.String
SERVER_SSL_HANDSHAKE_QUEUE_CAPACITY
"server.ssl.handshake.queue.capacity"
public static final java.lang.String
SERVER_SSL_HANDSHAKE_THREAD_POOL_SIZE
"server.ssl.handshake.thread.pool.size"
public static final java.lang.String
SERVER_STOP_CONSUMPTION_TIMEOUT_IN_SECONDS
"server.stop.consumption.timeout.in.seconds"
public static final java.lang.String
SERVER_STORAGE_NODE_RATE_LIMITER
"server.storage.node.rate.limiter"
public static final java.lang.String
SERVER_STORE_TO_EARLY_TERMINATION_THRESHOLD_MS_MAP
"server.store.to.early.termination.threshold.ms.map"
public static final java.lang.String
SERVER_STORE_VERSION_QPS_RATE_LIMITER
"server.store.version.qps.rate.limiter"
public static final java.lang.String
SERVER_STUCK_CONSUMER_REPAIR_ENABLED
"server.stuck.consumer.repair.enabled"
public static final java.lang.String
SERVER_STUCK_CONSUMER_REPAIR_INTERVAL_SECOND
"server.stuck.consumer.repair.second"
public static final java.lang.String
SERVER_STUCK_CONSUMER_REPAIR_THRESHOLD_SECOND
"server.stuck.consumer.repair.threshold.second"
public static final java.lang.String
SERVER_SYSTEM_STORE_PROMOTION_TO_LEADER_REPLICA_DELAY_SECONDS
"server.system.store.promotion.to.leader.replica.delay.seconds"
public static final java.lang.String
SERVER_UNSUB_AFTER_BATCHPUSH
"server.unsub.after.batch.push"
public static final java.lang.String
SERVER_ZSTD_DICT_COMPRESSION_LEVEL
"server.zstd.dict.compression.level"
public static final java.lang.String
SERVICE_DISCOVERY_REGISTRATION_RETRY_MS
"service.discovery.registration.retry.ms"
public static final java.lang.String
SEVER_CALCULATE_QUOTA_USAGE_BASED_ON_PARTITIONS_ASSIGNMENT_ENABLED
"server.calculate.quota.usage.based.on.partitions.assignment.enabled"
public static final java.lang.String
SORTED_INPUT_DRAINER_SIZE
"sorted.input.drainer.size"
public static final java.lang.String
SSL_KAFKA_BOOTSTRAP_SERVERS
"ssl.kafka.bootstrap.servers"
public static final java.lang.String
SSL_TO_KAFKA_LEGACY
"ssl.to.kakfa"
public static final java.lang.String
SSL_TO_STORAGE_NODES
"sslToStorageNodes"
public static final java.lang.String
STORAGE_ENGINE_OVERHEAD_RATIO
"storage.engine.overhead.ratio"
public static final java.lang.String
STORE_WRITER_BUFFER_AFTER_LEADER_LOGIC_ENABLED
"store.writer.buffer.after.leader.logic.enabled"
public static final java.lang.String
STORE_WRITER_BUFFER_MEMORY_CAPACITY
"store.writer.buffer.memory.capacity"
public static final java.lang.String
STORE_WRITER_BUFFER_NOTIFY_DELTA
"store.writer.buffer.notify.delta"
public static final java.lang.String
STORE_WRITER_NUMBER
"store.writer.number"
public static final java.lang.String
SYSTEM_SCHEMA_CLUSTER_NAME
"system.schema.cluster.name"
public static final java.lang.String
SYSTEM_SCHEMA_INITIALIZATION_AT_START_TIME_ENABLED
"system.schema.initialization.at.start.time.enabled"
public static final java.lang.String
TERMINAL_STATE_TOPIC_CHECK_DELAY_MS
"controller.terminal.state.topic.check.delay.ms"
public static final java.lang.String
TOPIC_CLEANUP_DELAY_FACTOR
"topic.cleanup.delay.factor"
public static final java.lang.String
TOPIC_CLEANUP_SLEEP_INTERVAL_BETWEEN_TOPIC_LIST_FETCH_MS
"topic.cleanup.sleep.interval.between.topic.list.fetch.ms"
public static final java.lang.String
UNREGISTER_METRIC_FOR_DELETED_STORE_ENABLED
"unregister.metric.for.deleted.store.enabled"
public static final java.lang.String
UNSORTED_INPUT_DRAINER_SIZE
"unsorted.input.drainer.size"
public static final java.lang.String
USE_DA_VINCI_SPECIFIC_EXECUTION_STATUS_FOR_ERROR
"use.da.vinci.specific.execution.status.for.error"
public static final java.lang.String
USE_PUSH_STATUS_STORE_FOR_INCREMENTAL_PUSH
"controller.server.incremental.push.use.push.status.store"
public static final java.lang.String
VALIDATE_VENICE_INTERNAL_SCHEMA_VERSION
"validate.venice.internal.schema.version"
public static final java.lang.String
VENICE_PARTITIONERS
"venice.partitioners"
public static final java.lang.String
VENICE_STORAGE_CLUSTER_LEADER_HAAS
"venice.cluster.leader.haas.enabled"
public static final java.lang.String
ZOOKEEPER_ADDRESS
"zookeeper.address"
-
com.linkedin.venice.HttpConstants Modifier and Type Constant Field Value public static final java.lang.String
AVRO_BINARY
"avro/binary"
public static final java.lang.String
BINARY
"application/octet-stream"
public static final java.lang.String
HTTP
"http"
public static final java.lang.String
HTTP_GET
"GET"
public static final java.lang.String
HTTP_PREFIX
"http://"
public static final java.lang.String
HTTPS
"https"
public static final java.lang.String
HTTPS_POST
"POST"
public static final java.lang.String
HTTPS_PREFIX
"https://"
public static final java.lang.String
JSON
"application/json"
public static final java.lang.String
LOCALHOST
"localhost"
public static final int
SC_MISDIRECTED_REQUEST
421
public static final java.lang.String
TEXT_HTML
"text/html"
public static final java.lang.String
TEXT_PLAIN
"text/plain"
public static final java.lang.String
VENICE_ALLOW_REDIRECT
"X-VENICE-ALLOW-REDIRECT"
public static final java.lang.String
VENICE_API_VERSION
"X-VENICE-API-VERSION"
public static final java.lang.String
VENICE_CLIENT_COMPUTE
"X-VENICE-CLIENT-COMPUTE"
public static final java.lang.String
VENICE_COMPRESSION_STRATEGY
"X-VENICE-COMPRESSION-STRATEGY"
public static final java.lang.String
VENICE_COMPUTE_VALUE_SCHEMA_ID
"X-VENICE-COMPUTE-VALUE-SCHEMA-ID"
public static final java.lang.String
VENICE_KEY_COUNT
"X-VENICE-KEY-COUNT"
public static final java.lang.String
VENICE_REQUEST_RCU
"X-VENICE-RCU"
public static final java.lang.String
VENICE_RETRY
"X-VENICE-RETRY"
public static final java.lang.String
VENICE_SCHEMA_ID
"X-VENICE-SCHEMA-ID"
public static final java.lang.String
VENICE_STORE_VERSION
"X-VENICE-STORE-VERSION"
public static final java.lang.String
VENICE_STREAMING
"X-VENICE-STREAMING"
public static final java.lang.String
VENICE_STREAMING_RESPONSE
"X-VENICE-STREAMING-RESPONSE"
public static final java.lang.String
VENICE_SUPPORTED_COMPRESSION_STRATEGY
"X-VENICE-SUPPORTED-COMPRESSION-STRATEGY"
-
com.linkedin.venice.LogMessages Modifier and Type Constant Field Value public static final java.lang.String
KILLED_JOB_MESSAGE
"Received the signal to kill this consumer. Topic "
-
com.linkedin.venice.RequestConstants Modifier and Type Constant Field Value public static final java.lang.String
B64_FORMAT
"b64"
public static final java.lang.String
DEFAULT_FORMAT
"string"
public static final java.lang.String
DELAY_EXECUTION
"delay_execution"
public static final java.lang.String
FORMAT_KEY
"f"
public static final java.lang.String
STRING_FORMAT
"string"
-
com.linkedin.venice.SSLConfig Modifier and Type Constant Field Value public static final boolean
DEFAULT_CONTROLLER_SSL_ENABLED
true
-
com.linkedin.venice.VeniceConstants Modifier and Type Constant Field Value public static final int
COMPUTE_REQUEST_VERSION_V2
2
public static final int
COMPUTE_REQUEST_VERSION_V3
3
public static final int
COMPUTE_REQUEST_VERSION_V4
4
public static final java.lang.String
CONTROLLER_SSL_CERTIFICATE_ATTRIBUTE_NAME
"javax.servlet.request.X509Certificate"
public static final int
DEFAULT_PER_ROUTER_READ_QUOTA
20000000
public static final java.lang.String
DEFAULT_SSL_FACTORY_CLASS_NAME
"com.linkedin.venice.security.DefaultSSLFactory"
public static final java.lang.String
ENVIRONMENT_CONFIG_KEY_FOR_REGION_NAME
"FABRIC"
public static final java.lang.String
NATIVE_REPLICATION_DEFAULT_SOURCE_FABRIC
"prod-lva1"
public static final java.lang.String
SYSTEM_PROPERTY_FOR_APP_RUNNING_REGION
"com.linkedin.app.env"
public static final java.lang.String
SYSTEM_STORE_OWNER
"venice-internal"
public static final java.lang.String
TYPE_PUSH_STATUS
"push_status"
public static final java.lang.String
TYPE_STORE_STATE
"store_state"
public static final java.lang.String
TYPE_STREAM_HYBRID_STORE_QUOTA
"stream_hybrid_store_quota"
public static final java.lang.String
TYPE_STREAM_REPROCESSING_HYBRID_STORE_QUOTA
"stream_reprocessing_hybrid_store_quota"
public static final java.lang.String
VENICE_COMPUTATION_ERROR_MAP_FIELD_NAME
"__veniceComputationError__"
-
com.linkedin.venice.acl.VeniceComponent Modifier and Type Constant Field Value public static final java.lang.String
CONTROLLER
"VeniceController"
public static final java.lang.String
ROUTER
"VeniceRouter"
public static final java.lang.String
SERVER
"VeniceServer"
-
com.linkedin.venice.client.exceptions.VeniceClientRateExceededException Modifier and Type Constant Field Value public static final int
HTTP_TOO_MANY_REQUESTS
429
-
com.linkedin.venice.client.schema.RouterBackedSchemaReader Modifier and Type Constant Field Value public static final java.lang.String
TYPE_ALL_VALUE_SCHEMA_IDS
"all_value_schema_ids"
public static final java.lang.String
TYPE_KEY_SCHEMA
"key_schema"
public static final java.lang.String
TYPE_UPDATE_SCHEMA
"update_schema"
public static final java.lang.String
TYPE_VALUE_SCHEMA
"value_schema"
-
com.linkedin.venice.client.schema.RouterBasedStoreSchemaFetcher Modifier and Type Constant Field Value public static final java.lang.String
TYPE_GET_UPDATE_SCHEMA
"update_schema"
public static final java.lang.String
TYPE_KEY_SCHEMA
"key_schema"
public static final java.lang.String
TYPE_LATEST_VALUE_SCHEMA
"latest_value_schema"
public static final java.lang.String
TYPE_VALUE_SCHEMA
"value_schema"
-
com.linkedin.venice.client.store.AbstractAvroComputeRequestBuilder<K> Modifier and Type Constant Field Value protected static final java.lang.String
COSINE_SIMILARITY_SPEC
"cosineSimilarity_spec"
protected static final java.lang.String
DOT_PRODUCT_SPEC
"dotProduct_spec"
protected static final java.lang.String
HADAMARD_PRODUCT_SPEC
"hadamardProduct_spec"
protected static final java.lang.String
PROJECTION_SPEC
"projection_spec"
-
com.linkedin.venice.client.store.AbstractAvroStoreClient<K,V> Modifier and Type Constant Field Value public static final java.lang.String
B64_FORMAT
"?f=b64"
public static final java.lang.String
TYPE_COMPUTE
"compute"
public static final java.lang.String
TYPE_STORAGE
"storage"
-
com.linkedin.venice.client.store.ClientConfig<T extends org.apache.avro.specific.SpecificRecord> Modifier and Type Constant Field Value public static final java.lang.String
DEFAULT_CLUSTER_DISCOVERY_D2_SERVICE_NAME
"venice-discovery"
public static final java.lang.String
DEFAULT_D2_ZK_BASE_PATH
"/d2"
public static final int
DEFAULT_ZK_TIMEOUT_MS
5000
-
com.linkedin.venice.client.store.D2ServiceDiscovery Modifier and Type Constant Field Value public static final java.lang.String
TYPE_D2_SERVICE_DISCOVERY
"discover_cluster"
-
com.linkedin.venice.client.store.transport.TransportClient Modifier and Type Constant Field Value protected static final java.lang.String
HTTPS
"https"
-
com.linkedin.venice.common.PushStatusStoreUtils Modifier and Type Constant Field Value public static final java.lang.String
CONTROLLER_HEARTBEAT_INSTANCE_NAME
"CONTROLLER_HEARTBEAT"
public static final java.lang.String
ONGOING_INCREMENTAL_PUSH_STATUSES_KEY
"ONGOING_INCREMENTAL_PUSHES"
public static final java.lang.String
SERVER_INCREMENTAL_PUSH_PREFIX
"SERVER_SIDE_INCREMENTAL_PUSH_STATUS"
-
com.linkedin.venice.common.VeniceSystemStoreUtils Modifier and Type Constant Field Value public static final java.lang.String
PARTICIPANT_STORE
"participant_store"
public static final java.lang.String
PUSH_JOB_DETAILS_STORE
"push_job_details_store"
public static final java.lang.String
SEPARATOR
"_"
-
com.linkedin.venice.compression.VeniceCompressor Modifier and Type Constant Field Value protected static final int
SCHEMA_HEADER_LENGTH
4
-
com.linkedin.venice.compute.ComputeRequestWrapper Modifier and Type Constant Field Value public static final int
LATEST_SCHEMA_VERSION_FOR_COMPUTE_REQUEST
3
-
com.linkedin.venice.compute.ComputeUtils Modifier and Type Constant Field Value public static final java.lang.String
CACHED_SQUARED_L2_NORM_KEY
"CACHED_SQUARED_L2_NORM_KEY"
public static final java.lang.String
ILLEGAL_AVRO_CHARACTER
"[^A-Za-z0-9_]"
public static final java.lang.String
ILLEGAL_AVRO_CHARACTER_REPLACEMENT
"_"
-
com.linkedin.venice.controller.StoreBackupVersionCleanupService Modifier and Type Constant Field Value public static final java.lang.String
TYPE_CURRENT_VERSION
"current_version"
-
com.linkedin.venice.controller.VeniceHelixAdmin Modifier and Type Constant Field Value protected static final int
INTERNAL_STORE_GET_RRT_TOPIC_ATTEMPTS
3
-
com.linkedin.venice.controller.kafka.AdminTopicUtils Modifier and Type Constant Field Value public static final int
ADMIN_TOPIC_PARTITION_ID
0
public static final int
PARTITION_NUM_FOR_ADMIN_TOPIC
1
-
com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask Modifier and Type Constant Field Value public static final int
IGNORED_CURRENT_VERSION
-1
-
com.linkedin.venice.controller.migration.MigrationPushStrategyZKAccessor Modifier and Type Constant Field Value public static final java.lang.String
MIGRATION_PUSH_STRATEGY_PATH
"/migration-push-strategy"
-
com.linkedin.venice.controller.server.NotImplemented Modifier and Type Constant Field Value public static final java.lang.String
NOT_IMPLEMENTED_MSG
"This method is not implemented yet"
-
com.linkedin.venice.controller.server.VeniceParentControllerRegionStateHandler Modifier and Type Constant Field Value public static final java.lang.String
ACTIVE_CHECK_FAILURE_WARN_MESSAGE_PREFIX
"Only active parent controllers are allowed to run "
-
com.linkedin.venice.controller.server.VeniceRouteHandler<T extends ControllerResponse> Modifier and Type Constant Field Value public static final java.lang.String
ACL_CHECK_FAILURE_WARN_MESSAGE_PREFIX
"Only admin users are allowed to run "
-
com.linkedin.venice.controller.stats.PartitionHealthStats Modifier and Type Constant Field Value public static final java.lang.String
UNDER_REPLICATED_PARTITION_SENSOR
"underReplicatedPartition"
-
com.linkedin.venice.controller.systemstore.SystemStoreRepairTask Modifier and Type Constant Field Value public static final java.lang.String
SYSTEM_STORE_REPAIR_JOB_PREFIX
"CONTROLLER_SYSTEM_STORE_REPAIR_JOB_"
-
com.linkedin.venice.controllerapi.ControllerApiConstants Modifier and Type Constant Field Value public static final java.lang.String
ACCESS_CONTROLLED
"access_controlled"
public static final java.lang.String
ACCESS_PERMISSION
"access_permission"
public static final java.lang.String
ACTIVE_ACTIVE_REPLICATION_ENABLED
"active_active_replication_enabled"
public static final java.lang.String
ALLOW_STORE_MIGRATION
"allow.store.migration"
public static final java.lang.String
AMPLIFICATION_FACTOR
"amplification_factor"
public static final java.lang.String
AUTO_SCHEMA_REGISTER_FOR_PUSHJOB_ENABLED
"auto_auto_register_for_pushjob_enabled"
public static final java.lang.String
BACKUP_STRATEGY
"backup_strategy"
public static final java.lang.String
BACKUP_VERSION_RETENTION_MS
"backup_version_retention_ms"
public static final java.lang.String
BATCH_GET_LIMIT
"batch_get_limit"
public static final java.lang.String
BATCH_GET_ROUTER_CACHE_ENABLED
"batch_get_router_cache_enabled"
public static final java.lang.String
BATCH_JOB_HEARTBEAT_ENABLED
"batch_job_heartbeat_enabled"
public static final java.lang.String
BLOB_TRANSFER_ENABLED
"blob_transfer_enabled"
public static final java.lang.String
BOOTSTRAP_TO_ONLINE_TIMEOUT_IN_HOURS
"bootstrap_to_online_timeout_in_hours"
public static final java.lang.String
BUFFER_REPLAY_POLICY
"buffer_replay_policy"
public static final java.lang.String
CHILD_CONTROLLER_ADMIN_TOPIC_CONSUMPTION_ENABLED
"child.controller.admin.topic.consumption.enabled"
public static final java.lang.String
CHUNKING_ENABLED
"chunking_enabled"
public static final java.lang.String
CLIENT_DECOMPRESSION_ENABLED
"client_decompression_enabled"
public static final java.lang.String
CLUSTER
"cluster_name"
public static final java.lang.String
CLUSTER_DEST
"cluster_name_dest"
public static final java.lang.String
CLUSTER_ID
"cluster_id"
public static final java.lang.String
COMPRESSION_DICTIONARY
"compression_dictionary"
public static final java.lang.String
COMPRESSION_STRATEGY
"compression_strategy"
public static final java.lang.String
DATA_RECOVERY_COPY_ALL_VERSION_CONFIGS
"data.recovery.copy.all.version.configs"
public static final java.lang.String
DATA_REPLICATION_POLICY
"data_replication_policy"
public static final java.lang.String
DEFER_VERSION_SWAP
"defer_version_swap"
public static final java.lang.String
DERIVED_SCHEMA
"derived_schema"
public static final java.lang.String
DERIVED_SCHEMA_ID
"derived_schema_id"
public static final java.lang.String
DEST_FABRIC
"dest_fabric"
public static final java.lang.String
DISABLE_DAVINCI_PUSH_STATUS_STORE
"disable_davinci_push_status_store"
public static final java.lang.String
DISABLE_META_STORE
"disable_meta_store"
public static final java.lang.String
DISABLE_STORE_VIEW
"disable_store_view"
public static final java.lang.String
ENABLE_DISABLED_REPLICAS
"enable_disabled_replicas"
public static final java.lang.String
ENABLE_READS
"enable_reads"
public static final java.lang.String
ENABLE_STORE_MIGRATION
"enable_store_migration"
public static final java.lang.String
ENABLE_WRITES
"enable_writes"
public static final java.lang.String
ERROR
"error"
public static final java.lang.String
ETLED_PROXY_USER_ACCOUNT
"etled_proxy_user_account"
public static final java.lang.String
EXECUTION_ID
"execution_id"
public static final java.lang.String
EXPECTED_ROUTER_COUNT
"expected_router_count"
public static final java.lang.String
FABRIC
"fabric"
public static final java.lang.String
FABRIC_A
"fabric_a"
public static final java.lang.String
FABRIC_B
"fabric_b"
public static final java.lang.String
FROZEN
"frozen"
public static final java.lang.String
FUTURE_VERSION_ETL_ENABLED
"future_version_etl_enabled"
public static final java.lang.String
HEARTBEAT_TIMESTAMP
"heartbeat_timestamp"
public static final java.lang.String
HOSTNAME
"hostname"
public static final java.lang.String
HYBRID_STORE_DISK_QUOTA_ENABLED
"hybrid-store-disk-quota-enabled"
public static final java.lang.String
HYBRID_STORE_OVERHEAD_BYPASS
"hybrid_store_overhead_bypass"
public static final java.lang.String
INCLUDE_SYSTEM_STORES
"include_system_stores"
public static final java.lang.String
INCREMENTAL_PUSH_ENABLED
"incremental_push_enabled"
public static final java.lang.String
INCREMENTAL_PUSH_VERSION
"incremental_push_version"
public static final java.lang.String
INSTANCES
"instances"
public static final java.lang.String
IS_DAVINCI_HEARTBEAT_REPORTED
"is_davinci_heartbeat_reported"
public static final java.lang.String
IS_SYSTEM_STORE
"is_system_store"
public static final java.lang.String
IS_WRITE_COMPUTE_ENABLED
"is_write_compute_enabled"
public static final java.lang.String
KAFKA_TOPIC_LOG_COMPACTION_ENABLED
"kafka.topic.log.compaction.enabled"
public static final java.lang.String
KAFKA_TOPIC_MIN_IN_SYNC_REPLICA
"kafka.topic.min.in.sync.replica"
public static final java.lang.String
KAFKA_TOPIC_RETENTION_IN_MS
"kafka.topic.retention.in.ms"
public static final java.lang.String
KEY_SCHEMA
"key_schema"
public static final java.lang.String
LARGEST_USED_VERSION_NUMBER
"largest_used_version_number"
public static final java.lang.String
LATEST_SUPERSET_SCHEMA_ID
"latest_superset_schema_id"
public static final java.lang.String
MAX_COMPACTION_LAG_SECONDS
"max_compaction_lag_seconds"
public static final java.lang.String
MAX_NEARLINE_RECORD_SIZE_BYTES
"max_nearline_record_size_bytes"
public static final java.lang.String
MAX_RECORD_SIZE_BYTES
"max_record_size_bytes"
public static final java.lang.String
MIGRATION_DUPLICATE_STORE
"migration_duplicate_store"
public static final java.lang.String
MIN_COMPACTION_LAG_SECONDS
"min_compaction_lag_seconds"
public static final java.lang.String
NAME
"store_name"
public static final java.lang.String
NATIVE_REPLICATION_ENABLED
"native_replication_enabled"
public static final java.lang.String
NATIVE_REPLICATION_SOURCE_FABRIC
"native_replication_source_fabric"
public static final java.lang.String
NEARLINE_PRODUCER_COMPRESSION_ENABLED
"nearline_producer_compression_enabled"
public static final java.lang.String
NEARLINE_PRODUCER_COUNT_PER_WRITER
"nearline_producer_count_per_writer"
public static final java.lang.String
NUM_VERSIONS_TO_PRESERVE
"num_versions_to_preserve"
public static final java.lang.String
OFFSET
"offset"
public static final java.lang.String
OFFSET_LAG_TO_GO_ONLINE
"offset_lag_to_go_online"
public static final java.lang.String
OPERATION
"operation"
public static final java.lang.String
OWNER
"owner"
public static final java.lang.String
PARTITION_COUNT
"partition_count"
public static final java.lang.String
PARTITION_DETAIL_ENABLED
"partition_detail_enabled"
public static final java.lang.String
PARTITIONER_CLASS
"partitioner_class"
public static final java.lang.String
PARTITIONER_PARAMS
"partitioner_params"
public static final java.lang.String
PARTITIONERS
"partitioners"
public static final java.lang.String
PERSONA_NAME
"persona_name"
public static final java.lang.String
PERSONA_OWNERS
"persona_owners"
public static final java.lang.String
PERSONA_QUOTA
"persona_quota"
public static final java.lang.String
PERSONA_STORES
"persona_stores"
public static final java.lang.String
PUSH_IN_SORTED_ORDER
"push_in_sorted_order"
public static final java.lang.String
PUSH_JOB_DETAILS
"push_job_details"
public static final java.lang.String
PUSH_JOB_DURATION
"push_job_duration"
public static final java.lang.String
PUSH_JOB_ID
"push_job_id"
public static final java.lang.String
PUSH_JOB_STATUS
"push_job_status"
public static final java.lang.String
PUSH_STRATEGY
"push_strategy"
public static final java.lang.String
PUSH_STREAM_SOURCE_ADDRESS
"push_stream_source_address"
public static final java.lang.String
PUSH_TYPE
"push_type"
public static final java.lang.String
READ_COMPUTATION_ENABLED
"read_computation_enabled"
public static final java.lang.String
READ_OPERATION
"read"
public static final java.lang.String
READ_QUOTA_IN_CU
"read_quota_in_cu"
public static final java.lang.String
READ_WRITE_OPERATION
"readwrite"
public static final java.lang.String
REAL_TIME_TOPIC_NAME
"real_time_topic_name"
public static final java.lang.String
REGIONS_FILTER
"regions_filter"
public static final java.lang.String
REGULAR_VERSION_ETL_ENABLED
"regular_version_etl_enabled"
public static final java.lang.String
REMOTE_KAFKA_BOOTSTRAP_SERVERS
"remote_kafka_bootstrap_servers"
public static final java.lang.String
REPLICATE_ALL_CONFIGS
"replicate_all_configs"
public static final java.lang.String
REPLICATION_FACTOR
"replication_factor"
public static final java.lang.String
REPLICATION_METADATA_PROTOCOL_VERSION_ID
"replication_metadata_protocol_version_id"
public static final java.lang.String
REPLICATION_METADATA_VERSION_ID
"replication_metadata_version_id"
public static final java.lang.String
REPUSH_SOURCE_VERSION
"repush_source_version"
public static final java.lang.String
REWIND_TIME_IN_SECONDS
"rewind_time_seconds"
public static final java.lang.String
REWIND_TIME_IN_SECONDS_OVERRIDE
"rewind_time_in_seconds_override"
public static final java.lang.String
RMD_CHUNKING_ENABLED
"rmd_chunking_enabled"
public static final java.lang.String
SCHEMA_COMPAT_TYPE
"schema_compat_type"
public static final java.lang.String
SCHEMA_ID
"schema_id"
public static final java.lang.String
SEND_START_OF_PUSH
"start_of_push"
public static final java.lang.String
SEPARATE_REAL_TIME_TOPIC_ENABLED
"separate_realtime_topic_enabled"
public static final java.lang.String
SERVER_KAFKA_FETCH_QUOTA_RECORDS_PER_SECOND
"server.kafka.fetch.quota.records.per.second"
public static final java.lang.String
SINGLE_GET_ROUTER_CACHE_ENABLED
"single_get_router_cache_enabled"
public static final java.lang.String
SKIP_DIV
"skip_div"
public static final java.lang.String
SOURCE_FABRIC
"source_fabric"
public static final java.lang.String
SOURCE_FABRIC_VERSION_INCLUDED
"source.fabric.version.included"
public static final java.lang.String
SOURCE_GRID_FABRIC
"source_grid_fabric"
public static final java.lang.String
STATUS
"status"
public static final java.lang.String
STORAGE_NODE_ID
"storage_node_id"
public static final java.lang.String
STORAGE_NODE_READ_QUOTA_ENABLED
"storage_node_read_quota_enabled"
public static final java.lang.String
STORAGE_QUOTA_IN_BYTE
"storage_quota_in_byte"
public static final java.lang.String
STORE_CONFIG_NAME_FILTER
"store_config_name_filter"
public static final java.lang.String
STORE_CONFIG_VALUE_FILTER
"store_config_value_filter"
public static final java.lang.String
STORE_MIGRATION
"store_migration"
public static final java.lang.String
STORE_PARTITION
"store_partition"
public static final java.lang.String
STORE_SIZE
"store_size"
public static final java.lang.String
STORE_TYPE
"store_type"
public static final java.lang.String
STORE_VERSION
"store_version"
public static final java.lang.String
STORE_VIEW
"store_view"
public static final java.lang.String
STORE_VIEW_CLASS
"store_view_class"
public static final java.lang.String
STORE_VIEW_NAME
"store_view_name"
public static final java.lang.String
STORE_VIEW_PARAMS
"store_view_params"
public static final java.lang.String
TARGET_SWAP_REGION
"target_swap_region"
public static final java.lang.String
TARGET_SWAP_REGION_WAIT_TIME
"target_swap_region_wait_time"
public static final java.lang.String
TARGETED_REGIONS
"targeted_regions"
public static final java.lang.String
TIME_LAG_TO_GO_ONLINE
"time_lag_to_go_online"
public static final java.lang.String
TO_BE_STOPPED_INSTANCES
"to_be_stopped_instances"
public static final java.lang.String
TOPIC
"topic"
public static final java.lang.String
TOPIC_COMPACTION_POLICY
"topic_compaction_policy"
public static final java.lang.String
UNUSED_SCHEMA_DELETION_ENABLED
"unused_schema_deletion_enabled"
public static final java.lang.String
UPDATED_CONFIGS_LIST
"updated_configs_list"
public static final java.lang.String
UPSTREAM_OFFSET
"upstream_offset"
public static final java.lang.String
VALUE_SCHEMA
"value_schema"
public static final java.lang.String
VALUE_SCHEMA_IDS
"value_schema_ids"
public static final java.lang.String
VERSION
"version"
public static final java.lang.String
VOLDEMORT_STORE_NAME
"voldemort_store_name"
public static final java.lang.String
WRITE_COMPUTATION_ENABLED
"write_computation_enabled"
public static final java.lang.String
WRITE_OPERATION
"write"
-
com.linkedin.venice.controllerapi.D2ServiceDiscoveryResponseV2 Modifier and Type Constant Field Value public static final java.lang.String
D2_SERVICE_DISCOVERY_RESPONSE_V2_ENABLED
"d2.service.discovery.response.v2.enabled"
-
com.linkedin.venice.datarecovery.DataRecoveryWorker Modifier and Type Constant Field Value public static final int
INTERVAL_UNSET
-1
-
com.linkedin.venice.fastclient.meta.RequestBasedMetadata Modifier and Type Constant Field Value public static final long
DEFAULT_CONN_WARMUP_TIMEOUT_IN_SECONDS_DEFAULT
20L
public static final long
DEFAULT_REFRESH_INTERVAL_IN_SECONDS
60L
-
com.linkedin.venice.fastclient.transport.HttpClient5BasedR2Client Modifier and Type Constant Field Value public static final java.lang.String
HTTP_METHOD_GET_LOWER_CASE
"get"
public static final java.lang.String
HTTP_METHOD_POST_LOWER_CASE
"post"
-
com.linkedin.venice.guid.GuidUtils Modifier and Type Constant Field Value public static final java.lang.String
GUID_GENERATOR_IMPLEMENTATION
"guid.generator.implementation"
-
com.linkedin.venice.hadoop.input.kafka.KafkaInputFormat Modifier and Type Constant Field Value public static final long
DEFAULT_KAFKA_INPUT_MAX_RECORDS_PER_MAPPER
5000000L
-
com.linkedin.venice.hadoop.input.kafka.KafkaInputRecordReader Modifier and Type Constant Field Value public static final java.lang.String
KIF_RECORD_READER_KAFKA_CONFIG_PREFIX
"kif.record.reader.kafka."
-
com.linkedin.venice.hadoop.mapreduce.datawriter.jobs.DataWriterMRJob Modifier and Type Constant Field Value public static final java.lang.String
HADOOP_PREFIX
"hadoop-conf."
-
com.linkedin.venice.hadoop.mapreduce.datawriter.partition.VeniceMRPartitioner Modifier and Type Constant Field Value public static final int
EMPTY_KEY_LENGTH
0
-
com.linkedin.venice.hadoop.mapreduce.datawriter.reduce.VeniceReducer Modifier and Type Constant Field Value public static final java.lang.String
MAP_REDUCE_JOB_ID_PROP
"mapreduce.job.id"
-
com.linkedin.venice.hadoop.mapreduce.engine.MapReduceEngineTaskConfigProvider Modifier and Type Constant Field Value public static final java.lang.String
MAPRED_TASK_ID_PROP_NAME
"mapred.task.id"
public static final java.lang.String
MAPREDUCE_JOB_NAME_PROP_NAME
"mapreduce.job.name"
-
com.linkedin.venice.hadoop.ssl.UserCredentialsFactory Modifier and Type Constant Field Value public static final int
REQUIRED_SECRET_KEY_COUNT
4
-
com.linkedin.venice.hadoop.task.TaskTracker Modifier and Type Constant Field Value public static final float
PROGRESS_COMPLETED
1.0f
public static final float
PROGRESS_NOT_SUPPORTED
-1.0f
-
com.linkedin.venice.hadoop.task.datawriter.AbstractDataWriterTask Modifier and Type Constant Field Value protected static final int
TASK_ID_NOT_SET
-1
-
com.linkedin.venice.helix.CachedReadOnlyStoreRepository Modifier and Type Constant Field Value public static final java.lang.String
STORE_REPOSITORY_PATH
"/Stores"
-
com.linkedin.venice.helix.CachedResourceZkStateListener Modifier and Type Constant Field Value public static final int
DEFAULT_RETRY_LOAD_ATTEMPTS
1
-
com.linkedin.venice.helix.HelixInstanceConfigRepository Modifier and Type Constant Field Value public static final int
DEFAULT_INSTANCE_GROUP_ID
0
public static final java.lang.String
GROUP_FIELD_NAME_IN_DOMAIN
"group"
public static final java.lang.String
ZONE_FIELD_NAME_IN_DOMAIN
"zone"
-
com.linkedin.venice.helix.HelixReadOnlySchemaRepository Modifier and Type Constant Field Value public static final int
VALUE_SCHEMA_STARTING_ID
1
-
com.linkedin.venice.helix.HelixSchemaAccessor Modifier and Type Constant Field Value public static final int
VALUE_SCHEMA_STARTING_ID
1
-
com.linkedin.venice.helix.HelixState Modifier and Type Constant Field Value public static final java.lang.String
DROPPED_STATE
"DROPPED"
public static final java.lang.String
ERROR_STATE
"ERROR"
public static final java.lang.String
LEADER_STATE
"LEADER"
public static final java.lang.String
OFFLINE_STATE
"OFFLINE"
public static final java.lang.String
STANDBY_STATE
"STANDBY"
-
com.linkedin.venice.helix.HelixStatusMessageChannel Modifier and Type Constant Field Value public static final int
DEFAULT_SEND_MESSAGE_TIME_OUT
1000
public static final java.lang.String
HELIX_MESSAGE_TYPE
"control_message"
public static final java.lang.String
VENICE_MESSAGE_CLASS
"veniceMessageClass"
public static final java.lang.String
VENICE_MESSAGE_FIELD
"veniceMessageFields"
-
com.linkedin.venice.helix.HelixStoreGraveyard Modifier and Type Constant Field Value public static final java.lang.String
STORE_GRAVEYARD_PATH
"/StoreGraveyard"
-
com.linkedin.venice.helix.ParentHelixOfflinePushAccessor Modifier and Type Constant Field Value public static final java.lang.String
OFFLINE_PUSH_SUB_PATH
"ParentOfflinePushes"
-
com.linkedin.venice.helix.VeniceOfflinePushMonitorAccessor Modifier and Type Constant Field Value public static final java.lang.String
OFFLINE_PUSH_SUB_PATH
"OfflinePushes"
-
com.linkedin.venice.kafka.protocol.enums.MessageType.Constants Modifier and Type Constant Field Value public static final byte
CONTROL_MESSAGE_KEY_HEADER_BYTE
2
public static final byte
PUT_KEY_HEADER_BYTE
0
public static final byte
UPDATE_KEY_HEADER_BYTE
4
-
com.linkedin.venice.listener.ReadQuotaEnforcementHandler Modifier and Type Constant Field Value public static final java.lang.String
INVALID_REQUEST_RESOURCE_MSG
"Invalid request resource: "
public static final java.lang.String
SERVER_OVER_CAPACITY_MSG
"Server over capacity"
-
com.linkedin.venice.listener.ServerAclHandler Modifier and Type Constant Field Value public static final java.lang.String
SERVER_ACL_APPROVED
"SERVER_ACL_APPROVED_ATTRIBUTE_KEY"
-
com.linkedin.venice.listener.request.RouterRequest Modifier and Type Constant Field Value public static final long
NO_REQUEST_TIMEOUT
-1L
-
com.linkedin.venice.meta.AbstractStore Modifier and Type Constant Field Value public static final long
DEFAULT_READ_QUOTA
1800L
public static final int
DEFAULT_REPLICATION_FACTOR
3
public static final long
DEFAULT_STORAGE_QUOTA
21474836480L
-
com.linkedin.venice.meta.HybridStoreConfigImpl Modifier and Type Constant Field Value public static final long
DEFAULT_HYBRID_OFFSET_LAG_THRESHOLD
1000L
public static final long
DEFAULT_HYBRID_TIME_LAG_THRESHOLD
-1L
public static final java.lang.String
DEFAULT_REAL_TIME_TOPIC_NAME
""
public static final long
DEFAULT_REWIND_TIME_IN_SECONDS
86400L
-
com.linkedin.venice.meta.LiveClusterConfig Modifier and Type Constant Field Value public static final int
DEFAULT_SERVER_KAFKA_FETCH_QUOTA_RECORDS_PER_SECOND
-1
-
com.linkedin.venice.meta.Store Modifier and Type Constant Field Value public static final int
BOOTSTRAP_TO_ONLINE_TIMEOUT_IN_HOURS
24
public static final int
DEFAULT_BATCH_GET_LIMIT
150
public static final int
IGNORE_VERSION
-1
public static final int
NON_EXISTING_VERSION
0
public static final int
NUM_VERSION_PRESERVE_NOT_SET
0
public static final java.lang.String
SYSTEM_STORE_FORMAT
"venice_system_store_%s"
public static final java.lang.String
SYSTEM_STORE_NAME_PREFIX
"venice_system_store_"
public static final long
UNLIMITED_STORAGE_QUOTA
-1L
-
com.linkedin.venice.meta.Version Modifier and Type Constant Field Value public static final java.lang.String
REAL_TIME_TOPIC_SUFFIX
"_rt"
public static final int
REPLICATION_METADATA_VERSION_ID_UNSET
-1
public static final java.lang.String
SEPARATE_REAL_TIME_TOPIC_SUFFIX
"_rt_sep"
public static final java.lang.String
STREAM_REPROCESSING_TOPIC_SUFFIX
"_sr"
public static final java.lang.String
VENICE_RE_PUSH_PUSH_ID_PREFIX
"venice_re_push_"
public static final java.lang.String
VENICE_TTL_RE_PUSH_PUSH_ID_PREFIX
"venice_ttl_re_push_"
public static final java.lang.String
VERSION_SEPARATOR
"_v"
-
com.linkedin.venice.offsets.OffsetRecord Modifier and Type Constant Field Value public static final long
DEFAULT_OFFSET_LAG
-1L
public static final long
LOWEST_OFFSET
-1L
public static final long
LOWEST_OFFSET_LAG
0L
public static final java.lang.String
NON_AA_REPLICATION_UPSTREAM_OFFSET_MAP_KEY
""
-
com.linkedin.venice.partitioner.ConstantVenicePartitioner Modifier and Type Constant Field Value public static final java.lang.String
CONSTANT_PARTITION
"constant.partition"
-
com.linkedin.venice.partitioner.DefaultVenicePartitioner Modifier and Type Constant Field Value public static final java.lang.String
MD5_HASH_ALGORITHM
"MD5"
-
com.linkedin.venice.persona.StoragePersonaAccessor Modifier and Type Constant Field Value public static final java.lang.String
STORAGE_PERSONA_SUB_PATH
"StoragePersona"
-
com.linkedin.venice.protocols.VeniceClientRequest Modifier and Type Constant Field Value public static final int
ISBATCHREQUEST_FIELD_NUMBER
9
public static final int
ISRETRYREQUEST_FIELD_NUMBER
8
public static final int
ISSTREAMINGREQUEST_FIELD_NUMBER
7
public static final int
KEYBYTES_FIELD_NUMBER
3
public static final int
KEYSTRING_FIELD_NUMBER
2
public static final int
METHOD_FIELD_NUMBER
10
public static final int
PARTITION_FIELD_NUMBER
1
public static final int
RESOURCENAME_FIELD_NUMBER
5
-
com.linkedin.venice.protocols.VeniceReadServiceGrpc Modifier and Type Constant Field Value public static final java.lang.String
SERVICE_NAME
"com.linkedin.venice.protocols.VeniceReadService"
-
com.linkedin.venice.protocols.VeniceServerResponse Modifier and Type Constant Field Value public static final int
COMPRESSIONSTRATEGY_FIELD_NUMBER
3
public static final int
DATA_FIELD_NUMBER
2
public static final int
ERRORCODE_FIELD_NUMBER
6
public static final int
ERRORMESSAGE_FIELD_NUMBER
7
public static final int
ISSTREAMINGRESPONSE_FIELD_NUMBER
5
public static final int
RESPONSERCU_FIELD_NUMBER
4
public static final int
SCHEMAID_FIELD_NUMBER
1
-
com.linkedin.venice.pubsub.PubSubConstants Modifier and Type Constant Field Value public static final long
BUFFER_REPLAY_MINIMAL_SAFETY_MARGIN
172800000L
public static final long
DEFAULT_KAFKA_MIN_LOG_COMPACTION_LAG_MS
86400000L
public static final int
DEFAULT_KAFKA_REPLICATION_FACTOR
3
public static final long
DEFAULT_TOPIC_RETENTION_POLICY_MS
432000000L
public static final long
ETERNAL_TOPIC_RETENTION_POLICY_MS
9223372036854775807L
public static final java.lang.String
PUBSUB_ADMIN_API_DEFAULT_TIMEOUT_MS
"pubsub.admin.api.default.timeout.ms"
public static final int
PUBSUB_ADMIN_API_DEFAULT_TIMEOUT_MS_DEFAULT_VALUE
120000
public static final long
PUBSUB_ADMIN_GET_TOPIC_CONFIG_RETRY_IN_SECONDS_DEFAULT_VALUE
300L
public static final java.lang.String
PUBSUB_CONSUMER_API_DEFAULT_TIMEOUT_MS
"pubsub.consumer.api.default.timeout.ms"
public static final int
PUBSUB_CONSUMER_API_DEFAULT_TIMEOUT_MS_DEFAULT_VALUE
60000
public static final java.lang.String
PUBSUB_CONSUMER_CHECK_TOPIC_EXISTENCE
"pubsub.consumer.check.topic.existence"
public static final boolean
PUBSUB_CONSUMER_CHECK_TOPIC_EXISTENCE_DEFAULT_VALUE
false
public static final java.lang.String
PUBSUB_CONSUMER_POLL_RETRY_BACKOFF_MS
"pubsub.consumer.poll.retry.backoff.ms"
public static final int
PUBSUB_CONSUMER_POLL_RETRY_BACKOFF_MS_DEFAULT_VALUE
0
public static final java.lang.String
PUBSUB_CONSUMER_POLL_RETRY_TIMES
"pubsub.consumer.poll.retry.times"
public static final int
PUBSUB_CONSUMER_POLL_RETRY_TIMES_DEFAULT_VALUE
3
public static final int
PUBSUB_CONSUMER_POLLING_FOR_METADATA_RETRY_MAX_ATTEMPT
3
public static final java.lang.String
PUBSUB_CONSUMER_POSITION_RESET_STRATEGY
"pubsub.consumer.position.reset.strategy"
public static final java.lang.String
PUBSUB_CONSUMER_POSITION_RESET_STRATEGY_DEFAULT_VALUE
"earliest"
public static final java.lang.String
PUBSUB_CONSUMER_TOPIC_QUERY_RETRY_INTERVAL_MS
"pubsub.consumer.topic.query.retry.interval.ms"
public static final int
PUBSUB_CONSUMER_TOPIC_QUERY_RETRY_INTERVAL_MS_DEFAULT_VALUE
1000
public static final java.lang.String
PUBSUB_CONSUMER_TOPIC_QUERY_RETRY_TIMES
"pubsub.consumer.topic.query.retry.times"
public static final int
PUBSUB_CONSUMER_TOPIC_QUERY_RETRY_TIMES_DEFAULT_VALUE
5
public static final int
PUBSUB_FAST_OPERATION_TIMEOUT_MS
1000
public static final long
PUBSUB_NO_PRODUCER_TIME_IN_EMPTY_TOPIC_PARTITION
-1L
public static final int
PUBSUB_OPERATION_TIMEOUT_MS_DEFAULT_VALUE
30000
public static final java.lang.String
PUBSUB_PRODUCER_USE_HIGH_THROUGHPUT_DEFAULTS
"pubsub.producer.use.high.throughput.defaults"
public static final int
PUBSUB_TOPIC_DELETE_RETRY_TIMES
3
public static final int
PUBSUB_TOPIC_DELETION_STATUS_POLL_INTERVAL_MS_DEFAULT_VALUE
2000
public static final int
PUBSUB_TOPIC_MANAGER_METADATA_FETCHER_CONSUMER_POOL_SIZE_DEFAULT_VALUE
2
public static final long
PUBSUB_TOPIC_UNKNOWN_RETENTION
-9223372036854775808L
-
com.linkedin.venice.pubsub.PubSubPositionType Modifier and Type Constant Field Value public static final int
APACHE_KAFKA_OFFSET
0
-
com.linkedin.venice.pubsub.adapter.kafka.consumer.ApacheKafkaConsumerConfig Modifier and Type Constant Field Value public static final int
DEFAULT_RECEIVE_BUFFER_SIZE
1048576
public static final java.lang.String
KAFKA_AUTO_OFFSET_RESET_CONFIG
"kafka.auto.offset.reset"
public static final java.lang.String
KAFKA_CLIENT_ID_CONFIG
"kafka.client.id"
public static final java.lang.String
KAFKA_ENABLE_AUTO_COMMIT_CONFIG
"kafka.enable.auto.commit"
public static final java.lang.String
KAFKA_FETCH_MAX_BYTES_CONFIG
"kafka.fetch.max.bytes"
public static final java.lang.String
KAFKA_FETCH_MAX_WAIT_MS_CONFIG
"kafka.fetch.max.wait.ms"
public static final java.lang.String
KAFKA_FETCH_MIN_BYTES_CONFIG
"kafka.fetch.min.bytes"
public static final java.lang.String
KAFKA_GROUP_ID_CONFIG
"kafka.group.id"
public static final java.lang.String
KAFKA_MAX_PARTITION_FETCH_BYTES_CONFIG
"kafka.max.partition.fetch.bytes"
public static final java.lang.String
KAFKA_MAX_POLL_RECORDS_CONFIG
"kafka.max.poll.records"
-
com.linkedin.venice.pubsub.adapter.kafka.producer.ApacheKafkaProducerConfig Modifier and Type Constant Field Value public static final java.lang.String
DEFAULT_KAFKA_BATCH_SIZE
"524288"
public static final java.lang.String
DEFAULT_KAFKA_LINGER_MS
"1000"
public static final java.lang.String
KAFKA_BOOTSTRAP_SERVERS
"kafka.bootstrap.servers"
public static final java.lang.String
KAFKA_BUFFER_MEMORY
"kafka.buffer.memory"
public static final java.lang.String
KAFKA_CLIENT_ID
"kafka.client.id"
public static final java.lang.String
KAFKA_COMPRESSION_TYPE
"kafka.compression.type"
public static final java.lang.String
KAFKA_CONFIG_PREFIX
"kafka."
public static final java.lang.String
KAFKA_KEY_SERIALIZER
"kafka.key.serializer"
public static final java.lang.String
KAFKA_LINGER_MS
"kafka.linger.ms"
public static final java.lang.String
KAFKA_OVER_SSL
"kafka.over.ssl"
public static final java.lang.String
KAFKA_PRODUCER_DELIVERY_TIMEOUT_MS
"kafka.delivery.timeout.ms"
public static final java.lang.String
KAFKA_PRODUCER_REQUEST_TIMEOUT_MS
"kafka.request.timeout.ms"
public static final java.lang.String
KAFKA_PRODUCER_RETRIES_CONFIG
"kafka.retries"
public static final java.lang.String
KAFKA_VALUE_SERIALIZER
"kafka.value.serializer"
public static final java.lang.String
SSL_KAFKA_BOOTSTRAP_SERVERS
"ssl.kafka.bootstrap.servers"
public static final java.lang.String
SSL_TO_KAFKA_LEGACY
"ssl.to.kakfa"
-
com.linkedin.venice.pubsub.adapter.kafka.producer.SharedKafkaProducerConfig Modifier and Type Constant Field Value public static final java.lang.String
SHARED_KAFKA_PRODUCER_BATCH_SIZE
"shared.producer.batch.size"
public static final java.lang.String
SHARED_KAFKA_PRODUCER_CONFIG_PREFIX
"shared.producer."
-
com.linkedin.venice.pubsub.api.PubSubMessageHeaders Modifier and Type Constant Field Value public static final java.lang.String
VENICE_LEADER_COMPLETION_STATE_HEADER
"lcs"
public static final java.lang.String
VENICE_TRANSPORT_PROTOCOL_HEADER
"vtp"
-
com.linkedin.venice.pubsub.api.PubSubTopicType Modifier and Type Constant Field Value public static final java.lang.String
ADMIN_TOPIC_PREFIX
"venice_admin_"
-
com.linkedin.venice.pushmonitor.AbstractPushMonitor Modifier and Type Constant Field Value public static final int
MAX_PUSH_TO_KEEP
5
-
com.linkedin.venice.pushmonitor.OfflinePushStatus Modifier and Type Constant Field Value public static final java.lang.String
HELIX_ASSIGNMENT_COMPLETED
"Helix assignment complete"
public static final java.lang.String
HELIX_RESOURCE_NOT_CREATED
"Helix Resource not created."
-
com.linkedin.venice.pushmonitor.ReplicaStatus Modifier and Type Constant Field Value public static final int
MAX_HISTORY_LENGTH
50
public static final long
NO_PROGRESS
-1L
-
com.linkedin.venice.response.VeniceReadResponseStatus Modifier and Type Constant Field Value public static final int
BAD_REQUEST
400
public static final int
INTERNAL_ERROR
500
public static final int
KEY_NOT_FOUND
-420
public static final int
OK
200
public static final int
SERVICE_UNAVAILABLE
503
public static final int
TOO_MANY_REQUESTS
429
-
com.linkedin.venice.router.AdminOperationsHandler Modifier and Type Constant Field Value public static final java.lang.String
EARLY_THROTTLE_ENABLED
"earlyThrottleEnabled"
public static final java.lang.String
READ_THROTTLING_ENABLED
"readThrottlingEnabled"
-
com.linkedin.venice.router.RouterServer Modifier and Type Constant Field Value public static final java.lang.String
DEFAULT_CLUSTER_DISCOVERY_D2_SERVICE_NAME
"venice-discovery"
public static final java.lang.String
ROUTER_SERVICE_METRIC_PREFIX
"router"
public static final java.lang.String
ROUTER_SERVICE_NAME
"venice-router"
-
com.linkedin.venice.router.api.VenicePathParser<HTTP_REQUEST extends BasicHttpRequest> Modifier and Type Constant Field Value public static final java.lang.String
ACTION_DISABLE
"disable"
public static final java.lang.String
ACTION_ENABLE
"enable"
public static final java.lang.String
SEP
"/"
public static final int
STORE_MAX_LENGTH
128
public static final java.lang.String
TASK_READ_QUOTA_THROTTLE
"readQuotaThrottle"
public static final java.lang.String
TYPE_COMPUTE
"compute"
public static final java.lang.String
TYPE_STORAGE
"storage"
-
com.linkedin.venice.router.api.routing.helix.HelixGroupLeastLoadedStrategy Modifier and Type Constant Field Value public static final int
MAX_ALLOWED_GROUP
100
-
com.linkedin.venice.samza.VeniceSystemFactory Modifier and Type Constant Field Value public static final java.lang.String
DEPLOYMENT_ID
"deployment.id"
public static final java.lang.String
DOT
"."
public static final java.lang.String
LEGACY_CHILD_D2_ZK_HOSTS_PROPERTY
"__r2d2DefaultClient__.r2d2Client.zkHosts"
public static final java.lang.String
LEGACY_VENICE_CHILD_CONTROLLER_D2_SERVICE
"VeniceController"
public static final java.lang.String
LEGACY_VENICE_PARENT_CONTROLLER_D2_SERVICE
"VeniceParentController"
public static final java.lang.String
SYSTEMS_PREFIX
"systems."
public static final java.lang.String
VENICE_AGGREGATE
"aggregate"
public static final java.lang.String
VENICE_CHILD_CONTROLLER_D2_SERVICE
"venice.child.controller.d2.service"
public static final java.lang.String
VENICE_CHILD_D2_ZK_HOSTS
"venice.child.d2.zk.hosts"
public static final java.lang.String
VENICE_CONTROLLER_DISCOVERY_URL
"venice.controller.discovery.url"
public static final java.lang.String
VENICE_PARENT_CONTROLLER_D2_SERVICE
"venice.parent.controller.d2.service"
public static final java.lang.String
VENICE_PARENT_D2_ZK_HOSTS
"venice.parent.d2.zk.hosts"
public static final java.lang.String
VENICE_PUSH_TYPE
"push.type"
public static final java.lang.String
VENICE_ROUTER_URL
"venice.router.url"
public static final java.lang.String
VENICE_STORE
"store"
-
com.linkedin.venice.schema.SchemaData Modifier and Type Constant Field Value public static final int
DUPLICATE_VALUE_SCHEMA_CODE
-2
public static final int
INVALID_VALUE_SCHEMA_ID
-1
public static final int
UNKNOWN_SCHEMA_ID
0
-
com.linkedin.venice.schema.avro.SchemaCompatibility Modifier and Type Constant Field Value public static final java.lang.String
READER_WRITER_COMPATIBLE_MESSAGE
"Reader schema can always successfully decode data written using the writer schema."
-
com.linkedin.venice.schema.rmd.RmdConstants Modifier and Type Constant Field Value public static final java.lang.String
REPLICATION_CHECKPOINT_VECTOR_FIELD_NAME
"replication_checkpoint_vector"
public static final int
REPLICATION_CHECKPOINT_VECTOR_FIELD_POS
1
public static final java.lang.String
TIMESTAMP_FIELD_NAME
"timestamp"
public static final int
TIMESTAMP_FIELD_POS
0
-
com.linkedin.venice.schema.rmd.v1.CollectionRmdTimestamp<DELETED_ELEMENT_TYPE> Modifier and Type Constant Field Value public static final java.lang.String
ACTIVE_ELEM_TS_FIELD_NAME
"activeElementsTimestamps"
public static final int
ACTIVE_ELEM_TS_FIELD_POS
3
public static final java.lang.String
DELETED_ELEM_FIELD_NAME
"deletedElementsIdentities"
public static final int
DELETED_ELEM_FIELD_POS
4
public static final java.lang.String
DELETED_ELEM_TS_FIELD_NAME
"deletedElementsTimestamps"
public static final int
DELETED_ELEM_TS_FIELD_POS
5
public static final java.lang.String
PUT_ONLY_PART_LENGTH_FIELD_NAME
"putOnlyPartLength"
public static final int
PUT_ONLY_PART_LENGTH_FIELD_POS
2
public static final java.lang.String
TOP_LEVEL_COLO_ID_FIELD_NAME
"topLevelColoID"
public static final int
TOP_LEVEL_COLO_ID_FIELD_POS
1
public static final java.lang.String
TOP_LEVEL_TS_FIELD_NAME
"topLevelFieldTimestamp"
public static final int
TOP_LEVEL_TS_FIELD_POS
0
-
com.linkedin.venice.schema.rmd.v1.RmdSchemaGeneratorV1 Modifier and Type Constant Field Value protected static final java.lang.String
METADATA_RECORD_SUFFIX
"MetadataRecord"
protected static final java.lang.String
NAME_SPACE
"com.linkedin.venice"
-
com.linkedin.venice.schema.vson.VsonAvroSchemaAdapter Modifier and Type Constant Field Value public static final java.lang.String
BYTE_WRAPPER
"byteWrapper"
public static final java.lang.String
SHORT_WRAPPER
"shortWrapper"
-
com.linkedin.venice.schema.writecompute.WriteComputeConstants Modifier and Type Constant Field Value public static final java.lang.String
LIST_OPS_NAME
"ListOps"
public static final java.lang.String
MAP_DIFF
"mapDiff"
public static final java.lang.String
MAP_OPS_NAME
"MapOps"
public static final java.lang.String
MAP_UNION
"mapUnion"
public static final java.lang.String
SET_DIFF
"setDiff"
public static final java.lang.String
SET_UNION
"setUnion"
public static final java.lang.String
WRITE_COMPUTE_RECORD_SCHEMA_SUFFIX
"WriteOpRecord"
-
com.linkedin.venice.serialization.KeyWithChunkingSuffixSerializer Modifier and Type Constant Field Value public static final java.lang.String
IGNORED_TOPIC_NAME
"ignored"
-
com.linkedin.venice.serialization.avro.InternalAvroSpecificSerializer<SPECIFIC_RECORD extends org.apache.avro.specific.SpecificRecord> Modifier and Type Constant Field Value public static final int
MAX_ATTEMPTS_FOR_SCHEMA_READER
60
public static final int
SENTINEL_PROTOCOL_VERSION_USED_FOR_UNDETECTABLE_COMPILED_SCHEMA
-1
public static final int
SENTINEL_PROTOCOL_VERSION_USED_FOR_UNVERSIONED_PROTOCOL
0
public static final java.lang.String
VENICE_SCHEMA_READER_CONFIG
"venice.schema-reader"
public static final int
WAIT_TIME_BETWEEN_SCHEMA_READER_ATTEMPTS_IN_MS
1000
-
com.linkedin.venice.spark.SparkConstants Modifier and Type Constant Field Value public static final java.lang.String
DEFAULT_SPARK_CLUSTER
"local[*]"
public static final java.lang.String
KEY_COLUMN_NAME
"key"
public static final java.lang.String
PARTITION_COLUMN_NAME
"__partition__"
public static final java.lang.String
SPARK_APP_NAME_CONFIG
"spark.app.name"
public static final java.lang.String
SPARK_CASE_SENSITIVE_CONFIG
"spark.sql.caseSensitive"
public static final java.lang.String
SPARK_CLUSTER_CONFIG
"venice.spark.cluster"
public static final java.lang.String
SPARK_DATA_WRITER_CONF_PREFIX
"spark.data.writer.conf."
public static final java.lang.String
SPARK_LEADER_CONFIG
"spark.master"
public static final java.lang.String
SPARK_SESSION_CONF_PREFIX
"venice.spark.session.conf."
public static final java.lang.String
VALUE_COLUMN_NAME
"value"
-
com.linkedin.venice.stats.AbstractVeniceAggStats<T extends AbstractVeniceStats> Modifier and Type Constant Field Value public static final java.lang.String
STORE_NAME_FOR_TOTAL_STAT
"total"
-
com.linkedin.venice.stats.AbstractVeniceStats Modifier and Type Constant Field Value public static final java.lang.String
DELIMITER
"--"
-
com.linkedin.venice.stats.LongAdderRateGauge Modifier and Type Constant Field Value public static final int
RATE_GAUGE_CACHE_DURATION_IN_SECONDS
30
-
com.linkedin.venice.stats.ServerConnectionStats Modifier and Type Constant Field Value public static final java.lang.String
CLIENT_CONNECTION_COUNT_GAUGE
"client_connection_count"
public static final java.lang.String
CLIENT_CONNECTION_REQUEST
"client_connection_request"
public static final java.lang.String
ROUTER_CONNECTION_COUNT_GAUGE
"router_connection_count"
public static final java.lang.String
ROUTER_CONNECTION_REQUEST
"router_connection_request"
-
com.linkedin.venice.stats.VeniceMetricsConfig Modifier and Type Constant Field Value public static final java.lang.String
OTEL_EXPORTER_OTLP_METRICS_DEFAULT_HISTOGRAM_AGGREGATION
"otel.exporter.otlp.metrics.default.histogram.aggregation"
public static final java.lang.String
OTEL_EXPORTER_OTLP_METRICS_DEFAULT_HISTOGRAM_AGGREGATION_MAX_BUCKETS
"otel.exporter.otlp.metrics.default.histogram.aggregation.max.buckets"
public static final java.lang.String
OTEL_EXPORTER_OTLP_METRICS_DEFAULT_HISTOGRAM_AGGREGATION_MAX_SCALE
"otel.exporter.otlp.metrics.default.histogram.aggregation.max.scale"
public static final java.lang.String
OTEL_EXPORTER_OTLP_METRICS_ENDPOINT
"otel.exporter.otlp.metrics.endpoint"
public static final java.lang.String
OTEL_EXPORTER_OTLP_METRICS_HEADERS
"otel.exporter.otlp.metrics.headers"
public static final java.lang.String
OTEL_EXPORTER_OTLP_METRICS_PROTOCOL
"otel.exporter.otlp.metrics.protocol"
public static final java.lang.String
OTEL_EXPORTER_OTLP_METRICS_TEMPORALITY_PREFERENCE
"otel.exporter.otlp.metrics.temporality.preference"
public static final java.lang.String
OTEL_VENICE_METRICS_CUSTOM_DIMENSIONS_MAP
"otel.venice.metrics.custom.dimensions.map"
public static final java.lang.String
OTEL_VENICE_METRICS_ENABLED
"otel.venice.metrics.enabled"
public static final java.lang.String
OTEL_VENICE_METRICS_EXPORT_TO_ENDPOINT
"otel.venice.metrics.export.to.endpoint"
public static final java.lang.String
OTEL_VENICE_METRICS_EXPORT_TO_LOG
"otel.venice.metrics.export.to.log"
public static final java.lang.String
OTEL_VENICE_METRICS_NAMING_FORMAT
"otel.venice.metrics.naming.format"
public static final java.lang.String
OTEL_VENICE_METRICS_PREFIX
"otel.venice.metrics.prefix"
-
com.linkedin.venice.store.rocksdb.RocksDBUtils Modifier and Type Constant Field Value public static final double
ROCKSDB_OVERHEAD_RATIO_FOR_HYBRID_STORE
2.11
-
com.linkedin.venice.streaming.StreamingConstants Modifier and Type Constant Field Value public static final int
KEY_ID_FOR_STREAMING_FOOTER
-1000000
public static final int
NON_EXISTING_KEY_SCHEMA_ID
-1000
public static final int
STREAMING_FOOTER_SCHEMA_ID
-1001
-
com.linkedin.venice.system.store.MetaStoreWriter Modifier and Type Constant Field Value public static final java.lang.String
KEY_STRING_CLUSTER_NAME
"KEY_CLUSTER_NAME"
public static final java.lang.String
KEY_STRING_PARTITION_ID
"KEY_PARTITION_ID"
public static final java.lang.String
KEY_STRING_SCHEMA_ID
"KEY_SCHEMA_ID"
public static final java.lang.String
KEY_STRING_STORE_NAME
"KEY_STORE_NAME"
public static final java.lang.String
KEY_STRING_VERSION_NUMBER
"KEY_VERSION_NUMBER"
-
com.linkedin.venice.utils.ByteUtils Modifier and Type Constant Field Value public static final long
BYTES_PER_GB
1073741824L
public static final int
BYTES_PER_KB
1024
public static final int
BYTES_PER_MB
1048576
public static final int
SIZE_OF_BOOLEAN
1
public static final int
SIZE_OF_INT
4
public static final int
SIZE_OF_LONG
8
public static final int
SIZE_OF_SHORT
2
-
com.linkedin.venice.utils.ChunkingTestUtils Modifier and Type Constant Field Value public static final int
CHUNK_LENGTH
10
-
com.linkedin.venice.utils.HelixUtils Modifier and Type Constant Field Value public static final int
DEFAULT_HELIX_OP_RETRY_COUNT
3
public static final java.lang.String
TOPOLOGY_CONSTRAINT
"instance"
-
com.linkedin.venice.utils.PathResourceRegistry<T> Modifier and Type Constant Field Value public static final java.lang.String
WILDCARD_MATCH_ANY
"*"
-
com.linkedin.venice.utils.RedundantExceptionFilter Modifier and Type Constant Field Value public static final int
DEFAULT_BITSET_SIZE
134217728
-
com.linkedin.venice.utils.SslUtils Modifier and Type Constant Field Value public static final java.lang.String
LOCAL_KEYSTORE_JKS
"localhost.jks"
public static final java.lang.String
LOCAL_PASSWORD
"dev_pass"
-
com.linkedin.venice.utils.TestStoragePersonaUtils Modifier and Type Constant Field Value public static final java.lang.String
OWNERS_DOES_NOT_EXIST_REGEX
"Invalid owner\\(s\\) provided"
public static final java.lang.String
PERSONA_DOES_NOT_EXIST_REGEX
"Update failed: persona with name .* does not exist in this cluster"
public static final java.lang.String
QUOTA_FAILED_REGEX
"Invalid persona quota:.*"
public static final java.lang.String
STORES_FAILED_REGEX
"Invalid store\\(s\\) provided: .*"
-
com.linkedin.venice.utils.TestWriteUtils Modifier and Type Constant Field Value public static final int
DEFAULT_USER_DATA_RECORD_COUNT
100
public static final java.lang.String
DEFAULT_USER_DATA_VALUE_PREFIX
"test_name_"
-
com.linkedin.venice.utils.Time Modifier and Type Constant Field Value public static final int
HOURS_PER_DAY
24
public static final int
MINUTES_PER_HOUR
60
public static final int
MS_PER_DAY
86400000
public static final int
MS_PER_HOUR
3600000
public static final int
MS_PER_MINUTE
60000
public static final int
MS_PER_SECOND
1000
public static final int
NS_PER_MS
1000000
public static final int
NS_PER_SECOND
1000000000
public static final int
NS_PER_US
1000
public static final int
SECONDS_PER_DAY
86400
public static final int
SECONDS_PER_HOUR
3600
public static final int
SECONDS_PER_MINUTE
60
public static final int
US_PER_MS
1000
public static final int
US_PER_SECOND
1000000
-
com.linkedin.venice.utils.Utils Modifier and Type Constant Field Value public static final java.lang.String
FATAL_DATA_VALIDATION_ERROR
"fatal data validation problem"
public static final java.lang.String
SEPARATE_TOPIC_SUFFIX
"_sep"
public static final java.lang.String
WILDCARD_MATCH_ANY
"*"
-
com.linkedin.venice.views.ChangeCaptureView Modifier and Type Constant Field Value public static final java.lang.String
CHANGE_CAPTURE_TOPIC_SUFFIX
"_cc"
public static final java.lang.String
CHANGE_CAPTURE_VIEW_WRITER_CLASS_NAME
"com.linkedin.davinci.store.view.ChangeCaptureViewWriter"
-
com.linkedin.venice.views.MaterializedView Modifier and Type Constant Field Value public static final java.lang.String
MATERIALIZED_VIEW_TOPIC_SUFFIX
"_mv"
-
com.linkedin.venice.views.VeniceView Modifier and Type Constant Field Value public static final java.lang.String
VIEW_TOPIC_SEPARATOR
"_"
-
com.linkedin.venice.views.ViewUtils Modifier and Type Constant Field Value public static final java.lang.String
ETERNAL_TOPIC_RETENTION_ENABLED
"eternal.topic.retention.enabled"
public static final java.lang.String
LOG_COMPACTION_ENABLED
"log.compaction.enabled"
public static final java.lang.String
PARTITION_COUNT
"sub.partition.count"
public static final java.lang.String
USE_FAST_KAFKA_OPERATION_TIMEOUT
"use.fast.kafka.operation.timeout"
-
com.linkedin.venice.vpj.VenicePushJobConstants Modifier and Type Constant Field Value public static final java.lang.String
ALLOW_DUPLICATE_KEY
"allow.duplicate.key"
public static final java.lang.String
BATCH_NUM_BYTES_PROP
"batch.num.bytes"
public static final java.lang.String
COMPRESSION_DICTIONARY_SAMPLE_SIZE
"compression.dictionary.sample.size"
public static final java.lang.String
COMPRESSION_DICTIONARY_SIZE_LIMIT
"compression.dictionary.size.limit"
public static final java.lang.String
COMPRESSION_METRIC_COLLECTION_ENABLED
"compression.metric.collection.enabled"
public static final java.lang.String
COMPRESSION_STRATEGY
"compression.strategy"
public static final java.lang.String
CONTROLLER_REQUEST_RETRY_ATTEMPTS
"controller.request.retry.attempts"
public static final java.lang.String
D2_ZK_HOSTS_PREFIX
"d2.zk.hosts."
public static final java.lang.String
DATA_WRITER_COMPUTE_JOB_CLASS
"data.writer.compute.job.class"
public static final int
DEFAULT_BATCH_BYTES_SIZE
1000000
public static final int
DEFAULT_COMPRESSION_DICTIONARY_SAMPLE_SIZE
209715200
public static final boolean
DEFAULT_COMPRESSION_METRIC_COLLECTION_ENABLED
false
public static final boolean
DEFAULT_EXTENDED_SCHEMA_VALIDITY_CHECK_ENABLED
true
public static final boolean
DEFAULT_IS_DUPLICATED_KEY_ALLOWED
false
public static final long
DEFAULT_JOB_STATUS_IN_UNKNOWN_STATE_TIMEOUT_MS
1800000L
public static final java.lang.String
DEFAULT_KEY_FIELD_PROP
"key"
public static final long
DEFAULT_POLL_STATUS_INTERVAL_MS
300000L
public static final long
DEFAULT_RE_PUSH_REWIND_IN_SECONDS_OVERRIDE
86400L
public static final boolean
DEFAULT_SSL_ENABLED
false
public static final boolean
DEFAULT_USE_MAPPER_TO_BUILD_DICTIONARY
false
public static final java.lang.String
DEFAULT_VALUE_FIELD_PROP
"value"
public static final java.lang.String
DEFER_VERSION_SWAP
"defer.version.swap"
public static final java.lang.String
DERIVED_SCHEMA_ID_PROP
"derived.schema.id"
public static final java.lang.String
ENABLE_SSL
"venice.ssl.enable"
public static final java.lang.String
ENABLE_WRITE_COMPUTE
"venice.write.compute.enable"
public static final java.lang.String
ETL_VALUE_SCHEMA_TRANSFORMATION
"etl.value.schema.transformation"
public static final java.lang.String
EXTENDED_SCHEMA_VALIDITY_CHECK_ENABLED
"extended.schema.validity.check.enabled"
public static final java.lang.String
FILE_KEY_SCHEMA
"key.schema"
public static final java.lang.String
FILE_VALUE_SCHEMA
"value.schema"
public static final java.lang.String
GENERATE_PARTIAL_UPDATE_RECORD_FROM_INPUT
"generate.partial.update.record.from.input"
public static final java.lang.String
GLOB_FILTER_PATTERN
"[^_.]*"
public static final java.lang.String
HADOOP_TMP_DIR
"hadoop.tmp.dir"
public static final java.lang.String
HADOOP_VALIDATE_SCHEMA_AND_BUILD_DICT_PREFIX
"hadoop-dict-build-conf."
public static final java.lang.String
INCREMENTAL_PUSH
"incremental.push"
public static final java.lang.String
INPUT_PATH_LAST_MODIFIED_TIME
"input.path.last.modified.time"
public static final java.lang.String
INPUT_PATH_PROP
"input.path"
public static final java.lang.String
JOB_EXEC_ID
"job.execution.id"
public static final java.lang.String
JOB_EXEC_URL
"job.execution.url"
public static final java.lang.String
JOB_SERVER_NAME
"job.server.name"
public static final java.lang.String
JOB_STATUS_IN_UNKNOWN_STATE_TIMEOUT_MS
"job.status.in.unknown.state.timeout.ms"
public static final java.lang.String
KAFKA_INPUT_BROKER_URL
"kafka.input.broker.url"
public static final java.lang.String
KAFKA_INPUT_COMBINER_ENABLED
"kafka.input.combiner.enabled"
public static final java.lang.String
KAFKA_INPUT_COMPRESSION_BUILD_NEW_DICT_ENABLED
"kafka.input.compression.build.new.dict.enabled"
public static final java.lang.String
KAFKA_INPUT_FABRIC
"kafka.input.fabric"
public static final java.lang.String
KAFKA_INPUT_MAX_RECORDS_PER_MAPPER
"kafka.input.max.records.per.mapper"
public static final java.lang.String
KAFKA_INPUT_SOURCE_COMPRESSION_STRATEGY
"kafka.input.source.compression.strategy"
public static final java.lang.String
KAFKA_INPUT_SOURCE_TOPIC_CHUNKING_ENABLED
"kafka.input.source.topic.chunking.enabled"
public static final java.lang.String
KAFKA_INPUT_TOPIC
"kafka.input.topic"
public static final java.lang.String
KAFKA_SECURITY_PROTOCOL
"SSL"
public static final java.lang.String
KAFKA_SOURCE_KEY_SCHEMA_STRING_PROP
"kafka.source.key.schema"
public static final java.lang.String
KEY_FIELD_PROP
"key.field"
public static final java.lang.String
KEY_INPUT_FILE_DATA_SIZE
"inputFileDataSize"
public static final java.lang.String
KEY_ZSTD_COMPRESSION_DICTIONARY
"zstdDictionary"
public static final java.lang.String
LEGACY_AVRO_KEY_FIELD_PROP
"avro.key.field"
public static final java.lang.String
LEGACY_AVRO_VALUE_FIELD_PROP
"avro.value.field"
public static final java.lang.String
MAP_REDUCE_PARTITIONER_CLASS_CONFIG
"map.reduce.partitioner.class"
public static final int
MINIMUM_NUMBER_OF_SAMPLES_REQUIRED_TO_BUILD_ZSTD_DICTIONARY
20
public static final java.lang.String
NON_CRITICAL_EXCEPTION
"This exception does not fail the push job. "
public static final int
NOT_SET
-1
public static final java.lang.String
PARENT_CONTROLLER_REGION_NAME
"parent.controller.region.name"
public static final java.lang.String
PARTITION_COUNT
"partition.count"
public static final java.lang.String
POLL_JOB_STATUS_INTERVAL_MS
"poll.job.status.interval.ms"
public static final java.lang.String
POLL_STATUS_RETRY_ATTEMPTS
"poll.status.retry.attempts"
public static final java.lang.String
PUSH_JOB_STATUS_UPLOAD_ENABLE
"push.job.status.upload.enable"
public static final java.lang.String
PUSH_TO_SEPARATE_REALTIME_TOPIC
"push.to.separate.realtime.topic"
public static final java.lang.String
REDUCER_SPECULATIVE_EXECUTION_ENABLE
"reducer.speculative.execution.enable"
public static final java.lang.String
REPUSH_TTL_ENABLE
"repush.ttl.enable"
public static final java.lang.String
REPUSH_TTL_POLICY
"repush.ttl.policy"
public static final java.lang.String
REPUSH_TTL_SECONDS
"repush.ttl.seconds"
public static final java.lang.String
REPUSH_TTL_START_TIMESTAMP
"repush.ttl.start.timestamp"
public static final java.lang.String
REWIND_EPOCH_TIME_BUFFER_IN_SECONDS_OVERRIDE
"rewind.epoch.time.buffer.in.seconds.override"
public static final java.lang.String
REWIND_EPOCH_TIME_IN_SECONDS_OVERRIDE
"rewind.epoch.time.in.seconds.override"
public static final java.lang.String
REWIND_TIME_IN_SECONDS_OVERRIDE
"rewind.time.in.seconds.override"
public static final java.lang.String
RMD_SCHEMA_DIR
"rmd.schema.dir"
public static final java.lang.String
SCHEMA_STRING_PROP
"schema"
public static final java.lang.String
SEND_CONTROL_MESSAGES_DIRECTLY
"send.control.messages.directly"
public static final boolean
SORTED
true
public static final java.lang.String
SOURCE_ETL
"source.etl"
public static final java.lang.String
SOURCE_GRID_FABRIC
"source.grid.fabric"
public static final java.lang.String
SOURCE_KAFKA
"source.kafka"
public static final java.lang.String
SPARK_NATIVE_INPUT_FORMAT_ENABLED
"spark.native.input.format.enabled"
public static final java.lang.String
SSL_CONFIGURATOR_CLASS_CONFIG
"ssl.configurator.class"
public static final java.lang.String
SSL_KEY_PASSWORD_PROPERTY_NAME
"ssl.key.password.property.name"
public static final java.lang.String
SSL_KEY_STORE_PASSWORD_PROPERTY_NAME
"ssl.key.store.password.property.name"
public static final java.lang.String
SSL_KEY_STORE_PROPERTY_NAME
"ssl.key.store.property.name"
public static final java.lang.String
SSL_PREFIX
"ssl"
public static final java.lang.String
SSL_TRUST_STORE_PROPERTY_NAME
"ssl.trust.store.property.name"
public static final java.lang.String
STORAGE_ENGINE_OVERHEAD_RATIO
"storage_engine_overhead_ratio"
public static final java.lang.String
STORAGE_QUOTA_PROP
"storage.quota"
public static final java.lang.String
SUPPRESS_END_OF_PUSH_MESSAGE
"suppress.end.of.push.message"
public static final java.lang.String
SYSTEM_SCHEMA_CLUSTER_D2_SERVICE_NAME
"system.schema.cluster.d2.service.name"
public static final java.lang.String
SYSTEM_SCHEMA_CLUSTER_D2_ZK_HOST
"system.schema.cluster.d2.zk.host"
public static final java.lang.String
SYSTEM_SCHEMA_READER_ENABLED
"system.schema.reader.enabled"
public static final java.lang.String
TARGETED_REGION_PUSH_ENABLED
"targeted.region.push.enabled"
public static final java.lang.String
TARGETED_REGION_PUSH_LIST
"targeted.region.push.list"
public static final java.lang.String
TARGETED_REGION_PUSH_WITH_DEFERRED_SWAP
"targeted.region.push.with.deferred.swap"
public static final java.lang.String
TELEMETRY_MESSAGE_INTERVAL
"telemetry.message.interval"
public static final java.lang.String
TEMP_DIR_PREFIX
"tmp.dir.prefix"
public static final java.lang.String
TOPIC_PROP
"venice.kafka.topic"
public static final int
UNCREATED_VERSION_NUMBER
-1
public static final java.lang.String
UPDATE_SCHEMA_STRING_PROP
"update.schema"
public static final java.lang.String
USE_MAPPER_TO_BUILD_DICTIONARY
"use.mapper.to.build.dictionary"
public static final java.lang.String
VALIDATE_SCHEMA_AND_BUILD_DICT_MAPPER_OUTPUT_DIRECTORY
"validate.schema.and.build.dict.mapper.output.directory"
public static final java.lang.String
VALIDATE_SCHEMA_AND_BUILD_DICTIONARY_MAPPER_OUTPUT_FILE_EXTENSION
".avro"
public static final java.lang.String
VALIDATE_SCHEMA_AND_BUILD_DICTIONARY_MAPPER_OUTPUT_FILE_PREFIX
"mapper-output-"
public static final java.lang.String
VALUE_FIELD_PROP
"value.field"
public static final java.lang.String
VALUE_SCHEMA_DIR
"value.schema.dir"
public static final java.lang.String
VALUE_SCHEMA_ID_PROP
"value.schema.id"
public static final java.lang.String
VENICE_DISCOVER_URL_PROP
"venice.discover.urls"
public static final java.lang.String
VENICE_STORE_NAME_PROP
"venice.store.name"
public static final java.lang.String
VSON_PUSH
"vson.push"
public static final java.lang.String
ZSTD_COMPRESSION_LEVEL
"zstd.compression.level"
public static final java.lang.String
ZSTD_DICTIONARY_CREATION_REQUIRED
"zstd.dictionary.creation.required"
public static final java.lang.String
ZSTD_DICTIONARY_CREATION_SUCCESS
"zstd.dictionary.creation.success"
-
com.linkedin.venice.writer.VeniceWriter<K,V,U> Modifier and Type Constant Field Value public static final long
APP_DEFAULT_LOGICAL_TS
-2L
public static final java.lang.String
CHECK_SUM_TYPE
"venice.writer.checksum.type"
public static final java.lang.String
CLOSE_TIMEOUT_MS
"venice.writer.close.timeout.ms"
public static final int
DEFAULT_CLOSE_TIMEOUT_MS
30000
public static final int
DEFAULT_MAX_ATTEMPTS_WHEN_TOPIC_MISSING
30
public static final int
DEFAULT_MAX_SIZE_FOR_USER_PAYLOAD_PER_MESSAGE_IN_BYTES
972800
public static final java.lang.String
ENABLE_CHUNKING
"venice.writer.chunking.enabled"
public static final java.lang.String
ENABLE_RMD_CHUNKING
"venice.writer.replication.metadata.chunking.enabled"
public static final java.lang.String
MAX_ATTEMPTS_WHEN_TOPIC_MISSING
"venice.writer.max.attemps.when.topic.missing"
public static final java.lang.String
MAX_ELAPSED_TIME_FOR_SEGMENT_IN_MS
"venice.writer.max.elapsed.time.for.segment.in.ms"
public static final java.lang.String
MAX_RECORD_SIZE_BYTES
"venice.writer.max.record.size.bytes"
public static final java.lang.String
MAX_SIZE_FOR_USER_PAYLOAD_PER_MESSAGE_IN_BYTES
"venice.writer.max.size.for.user.payload.per.message.in.bytes"
public static final java.lang.String
PRODUCER_QUEUE_SIZE
"venice.writer.producer.queue.size"
public static final java.lang.String
PRODUCER_THREAD_COUNT
"venice.writer.producer.thread.count"
public static final int
UNLIMITED_MAX_RECORD_SIZE
-1
public static final long
VENICE_DEFAULT_LOGICAL_TS
-1L
public static final int
VENICE_DEFAULT_TIMESTAMP_METADATA_VERSION_ID
-1
public static final int
VENICE_DEFAULT_VALUE_SCHEMA_ID
-1
public static final java.lang.String
VENICE_WRITER_CONFIG_PREFIX
"venice.writer."
-
com.linkedin.venice.zk.VeniceZkPaths Modifier and Type Constant Field Value public static final java.lang.String
ADMIN_TOPIC_METADATA
"adminTopicMetadata"
public static final java.lang.String
CLUSTER_CONFIG
"ClusterConfig"
public static final java.lang.String
EXECUTION_IDS
"executionids"
public static final java.lang.String
OFFLINE_PUSHES
"OfflinePushes"
public static final java.lang.String
PARENT_OFFLINE_PUSHES
"ParentOfflinePushes"
public static final java.lang.String
ROUTERS
"routers"
public static final java.lang.String
STORE_CONFIGS
"storeConfigs"
public static final java.lang.String
STORE_GRAVEYARD
"StoreGraveyard"
public static final java.lang.String
STORES
"Stores"