Constant Field Values
Contents
com.linkedin.*
-
Modifier and TypeConstant FieldValue
public static final String
"Max concurrent requests limit reached for storage node connection"
-
Modifier and TypeConstant FieldValue
public static final long
60000L
public static final long
1000L
public static final int
256
public static final long
0L
public static final int
256
public static final int
256
-
Modifier and TypeConstant FieldValue
public static final int
3
-
Modifier and TypeConstant FieldValue
public static final String
".total--success_request_latency.99thPercentile"
-
Modifier and TypeConstant FieldValue
public static final int
1800
-
Modifier and TypeConstant FieldValue
protected static final String
"blob_transfer_failed_num_responses"
protected static final String
"blob_transfer_successful_num_responses"
protected static final String
"blob_transfer_file_receive_throughput"
protected static final String
"blob_transfer_time"
protected static final String
"blob_transfer_total_num_responses"
-
Modifier and TypeConstant FieldValue
protected static final String
"batch_follower_offset_lag"
protected static final String
"batch_leader_offset_lag"
public static final String
"batch_processing_request"
public static final String
"batch_processing_request_error"
public static final String
"batch_processing_request_latency"
public static final String
"batch_processing_request_records"
public static final String
"batch_processing_request_size"
protected static final String
"batch_replication_lag"
protected static final String
"bytes_consumed"
protected static final String
"consumed_record_end_to_end_processing_latency"
protected static final String
"follower_bytes_consumed"
protected static final String
"follower_offset_lag"
protected static final String
"follower_records_consumed"
protected static final String
"hybrid_follower_offset_lag"
protected static final String
"hybrid_leader_offset_lag"
public static final String
"idle_time"
protected static final String
"ingestion_task_errored_gauge"
protected static final String
"ingestion_task_push_timeout_gauge"
public static final String
"internal_preprocessing_latency"
protected static final String
"leader_bytes_consumed"
protected static final String
"leader_bytes_produced"
protected static final String
"leader_offset_lag"
public static final String
"leader_preprocessing_latency"
protected static final String
"leader_records_consumed"
protected static final String
"leader_records_produced"
protected static final String
"leader_stalled_hybrid_ingestion"
public static final String
"nearline_local_broker_to_ready_to_serve_latency"
public static final String
"nearline_producer_to_local_broker_latency"
protected static final String
"offset_regression_dcr_error"
public static final String
"producer_callback_latency"
protected static final String
"ready_to_serve_with_rt_lag"
protected static final String
"records_consumed"
protected static final String
"subscribe_action_prep_latency"
protected static final String
"timestamp_regression_dcr_error"
protected static final String
"tombstone_creation_dcr"
protected static final String
"total_dcr"
protected static final String
"transformer_error_count"
public static final String
"transformer_latency"
public static final String
"transformer_lifecycle_end_latency"
public static final String
"transformer_lifecycle_start_latency"
protected static final String
"update_ignored_dcr"
public static final String
"version_topic_end_offset_rewind_count"
protected static final String
"write_compute_operation_failure"
-
Modifier and TypeConstant FieldValue
public static final int
60
public static final int
60
-
Modifier and TypeConstant FieldValue
public static final String
"rocksdb.capped.prefix.extractor.length"
public static final String
"record.transformer.value.schema"
public static final String
"rocksdb.atomic.flush.enabled"
public static final String
"rocksdb.auto.tuned.rate.limited.enabled"
public static final String
"rocksdb.blob.file.size.in.bytes"
public static final String
"rocksdb.blob.file.starting.level"
public static final String
"rocksdb.blob.files.enabled"
public static final String
"rocksdb.blob.garbage.collection.age.cutoff"
public static final String
"rocksdb.blob.garbage.collection.force.threshold"
public static final String
"rocksdb.block.base.format.version"
public static final String
"rocksdb.block.cache.compressed.size.in.bytes"
public static final String
"rocksdb.block.cache.implementation"
public static final String
"rocksdb.block.cache.shard.bits"
public static final String
"rocksdb.block.cache.size.in.bytes"
public static final String
"rocksdb.block.cache.strict.capacity.limit"
public static final String
"rocksdb.bloom.bits.per.key"
public static final String
"rocksdb.bytes.per.sync"
public static final String
"rocksdb.db.open.operation.throttle"
public static final String
"rocksdb.env.compaction.pool.size"
public static final String
"rocksdb.env.flush.pool.size"
public static final String
"rocksdb.hash.table.ratio"
public static final String
"rocksdb.huge.page.tlb.size"
public static final String
"rocksdb.level0.compaction.tuning.for.read.write.leader.enabled"
public static final String
"rocksdb.level0.file.num.compaction.trigger"
public static final String
"rocksdb.level0.file.num.compaction.trigger.for.read.write.leader"
public static final String
"rocksdb.level0.file.num.compaction.trigger.write.only.version"
public static final String
"rocksdb.level0.slowdown.writes.trigger"
public static final String
"rocksdb.level0.slowdown.writes.trigger.for.read.write.leader"
public static final String
"rocksdb.level0.slowdown.writes.trigger.write.only.version"
public static final String
"rocksdb.level0.stops.writes.trigger"
public static final String
"rocksdb.level0.stops.writes.trigger.for.read.write.leader"
public static final String
"rocksdb.level0.stops.writes.trigger.write.only.version"
public static final String
"rocksdb.max.bytes.for.level.base"
public static final String
"rocksdb.max.file.opening.threads"
public static final String
"rocksdb.max.log.file.num"
public static final String
"rocksdb.max.log.file.size"
public static final String
"rocksdb.max.memtable.count"
public static final String
"rocksdb.max.open.files"
public static final String
"rocksdb.max.total.wal.size.in.bytes"
public static final String
"rocksdb.mem.table.huge.page.size.in.bytes"
public static final String
"rocksdb.memtable.size.in.bytes"
public static final String
"rocksdb.min.blob.size.in.bytes"
public static final String
"rocksdb.min.write.buffer.number.to.merge"
public static final String
"rocksdb.options.compaction.style"
public static final String
"rocksdb.options.compression.type"
public static final String
"rocksdb.options.use.direct.reads"
public static final String
"rocksdb.plain.table.format.enabled"
public static final String
"rocksdb.put.reuse.byte.buffer"
public static final String
"rocksdb.rmd.block.cache.size.in.bytes"
public static final String
"rocksdb.separate.rmd.cache.enabled"
public static final String
"rocksdb.set.cache.index.and.filter.blocks"
public static final String
"rocksdb.sst.file.block.size.in.bytes"
public static final String
"rocksdb.statistics.enabled"
public static final String
"rocksdb.store.index.in.file"
public static final String
"rocksdb.target.file.size.in.bytes"
public static final String
"rocksdb.total.memtable.usage.cap.in.bytes"
public static final String
"rocksdb.write.quota.bytes.per.second"
-
Modifier and TypeConstant FieldValue
public static final int
1
public static final int
0
-
Modifier and TypeConstant FieldValue
public static final String
"ssl.enabled"
public static final String
"ssl.factory.class.name"
public static final String
"ssl.key.password"
public static final String
"ssl.keymanager.algorithm"
public static final String
"ssl.keystore.location"
public static final String
"ssl.keystore.password"
public static final String
"ssl.keystore.type"
public static final String
"ssl.needs.client.cert"
public static final String
"ssl.secure.random.implementation"
public static final String
"ssl.trustmanager.algorithm"
public static final String
"ssl.truststore.location"
public static final String
"ssl.truststore.password"
public static final String
"ssl.truststore.type"
-
Modifier and TypeConstant FieldValue
public static final int
104857600
public static final int
-1
-
Modifier and TypeConstant FieldValue
public static final String
"active.active.real.time.source.fabric.list"
public static final String
"admin.check.read.method.for.kafka"
public static final String
"admin.consumption.cycle.timeout.ms"
public static final String
"admin.consumption.max.worker.thread.pool.size"
public static final String
"admin.helix.messaging.channel.enabled"
public static final String
"admin.hostname"
public static final String
"admin.port"
public static final String
"admin.secure.port"
public static final String
"admin.topic.replication.factor"
public static final String
"admin.topic.source.region"
public static final String
"aggregate.real.time.source.region"
public static final String
"allow.cluster.wipe"
public static final String
"allow.store.migration"
public static final String
"autocreate.data.path"
public static final String
"blob.transfer.disabled.offset.lag.threshold"
public static final String
"blob.transfer.manager.enabled"
public static final String
"blob.transfer.max.concurrent.snapshot.user"
public static final String
"blob.transfer.max.timeout.in.min"
public static final String
"blob.transfer.snapshot.retention.time.in.min"
public static final String
"child.cluster.allowlist"
public static final String
"child.cluster.d2.zkHost."
public static final String
"child.cluster.d2.service.name"
public static final String
"child.cluster.url."
public static final String
"child.cluster.whitelist"
public static final String
"child.controller.admin.topic.consumption.enabled"
public static final String
"child.data.center.kafka.url"
public static final String
"client.producer.schema.refresh.interval.seconds"
public static final String
"client.producer.thread.num"
public static final String
"client.system.store.repository.refresh.interval.seconds"
public static final String
"client.use.system.store.repository"
public static final String
"cluster.discovery.d2.service"
public static final String
"cluster.name"
public static final String
"cluster.to.d2"
public static final String
"cluster.to.server.d2"
public static final String
"concurrent.init.routines.enabled"
public static final String
"controller.add.version.via.admin.protocol"
public static final String
"controller.admin.grpc.port"
public static final String
"controller.admin.secure.grpc.port"
public static final String
"controller.auto.materialize.davinci.push.status.system.store"
public static final String
"controller.auto.materialize.meta.system.store"
public static final String
"controller.backup.version.default.retention.ms"
public static final String
"controller.backup.version.deletion.sleep.ms"
public static final String
"controller.backup.version.metadata.fetch.cleanup.enabled"
public static final String
"controller.backup.version.retention.based.cleanup.enabled"
public static final String
"controller.cluster.name"
public static final String
"controller.cluster.helix.cloud.enabled"
public static final String
"controller.cluster.leader.haas.enabled"
public static final String
"controller.cluster.replica"
public static final String
"controller.cluster.zk.address"
public static final String
"controller.dangling.topic.clean.up.interval.second"
public static final String
"controller.dangling.topic.occurrence.threshold.for.cleanup"
public static final String
"controller.default.read.quota.per.router"
public static final String
"controller.disable.parent.request.topic.for.stream.pushes"
public static final String
"controller.disable.parent.topic.truncation.upon.completion"
public static final String
"controller.disabled.replica.enabler.interval.ms"
public static final String
"controller.cluster.disabled.routes"
public static final String
"controller.early.delete.backup.enabled"
public static final String
"controller.enable.disabled.replica.enabled"
public static final String
"controller.enable.hybrid.store.partition.count.update"
public static final String
"controller.enforce.ssl"
public static final String
"controller.grpc.server.enabled"
public static final String
"controller.grpc.server.thread.count"
public static final String
"controller.haas.super.cluster.name"
public static final String
"controller.helix.cloud.id"
public static final String
"controller.helix.cloud.info.processor.name"
public static final String
"controller.helix.cloud.info.processor.package"
public static final String
"controller.helix.cloud.info.sources"
public static final String
"controller.helix.cloud.provider"
public static final String
"controller.helix.rest.customized.health.url"
public static final String
"controller.instance.tag.list"
public static final String
"controller.jetty."
public static final String
"controller.min.schema.count.keep"
public static final String
"controller.name"
public static final String
"controller.parent.external.superset.schema.generation.enabled"
public static final String
"controller.parent.mode"
public static final String
"controller.parent.region.state"
public static final String
"controller.parent.system.store.heartbeat.check.wait.time.seconds"
public static final String
"controller.parent.system.store.repair.check.interval.seconds"
public static final String
"controller.parent.system.store.repair.retry.count"
public static final String
"controller.parent.system.store.repair.service.enabled"
public static final String
"controller.resource.instance.group.tag"
public static final String
"controller.schema.validation.enabled"
public static final String
"controller.ssl.enabled"
public static final String
"controller.storage.cluster.helix.cloud.enabled"
public static final String
"controller.store.graveyard.cleanup.delay.minutes"
public static final String
"controller.store.graveyard.cleanup.enabled"
public static final String
"controller.store.graveyard.cleanup.sleep.interval.between.list.fetch.minutes"
public static final String
"controller.system.schema.cluster.name"
public static final String
"controller.system.store.acl.synchronization.delay.ms"
public static final String
"controller.unused.schema.cleanup.interval.seconds"
public static final String
"controller.unused.value.schema.cleanup.enabled"
public static final String
"controller.zk.shared.davinci.push.status.system.schema.store.auto.creation.enabled"
public static final String
"controller.zk.shared.metadata.system.schema.store.auto.creation.enabled"
public static final String
"r2d2Client.zkHosts"
public static final String
"da.vinci.current.version.bootstrapping.quota.bytes.per.second"
public static final String
"da.vinci.current.version.bootstrapping.quota.records.per.second"
public static final String
"da.vinci.current.version.bootstrapping.speedup.enabled"
public static final String
"data.base.path"
public static final String
"davinci.p2p.blob.transfer.client.port"
public static final String
"davinci.p2p.blob.transfer.server.port"
public static final String
"davinci.push.status.check.interval.in.ms"
public static final String
"davinci.push.status.scan.enabled"
public static final String
"davinci.push.status.scan.interval.in.seconds"
public static final String
"davinci.push.status.scan.max.offline.instance.count"
public static final String
"davinci.push.status.scan.max.offline.instance.ratio"
public static final String
"davinci.push.status.scan.no.report.retry.max.attempts"
public static final String
"davinci.push.status.scan.thread.number"
public static final String
"default.partition.max.count"
public static final String
"default.max.record.size.bytes"
public static final String
"default.partition.count"
public static final String
"default.partition.count.for.hybrid"
public static final String
"default.offline.push.strategy"
public static final String
"default.partition.size"
public static final String
"default.read.strategy"
public static final String
"default.replica.factor"
public static final String
"default.routing.strategy"
public static final String
"delay.to.rebalance.ms"
public static final String
"deprecated.topic.max.retention.ms"
public static final String
"deprecated.topic.retention.ms"
public static final String
"div.producer.state.max.age.ms"
public static final String
"emergency.source.region"
public static final String
"enable.active.active.replication.as.default.for.hybrid.store"
public static final String
"enable.blob.transfer"
public static final String
"grpc.read.server.enabled"
public static final String
"enable.hybrid.push.ssl.allowlist"
public static final String
"enable.hybrid.push.ssl.whitelist"
public static final String
"enable.incremental.push.for.hybrid.active.active.user.stores"
public static final String
"enable.offline.push.ssl.allowlist"
public static final String
"enable.offline.push.ssl.whitelist"
public static final String
"enable.partial.update.for.hybrid.active.active.user.stores"
public static final String
"enable.partial.update.for.hybrid.non.active.active.user.stores"
public static final String
"enable.partition.count.round.up"
public static final String
"enable.separate.real.time.topic.for.store.with.incremental.push"
public static final String
"enable.server.allowlist"
public static final String
"router.enforce.ssl"
public static final String
"error.partition.auto.reset.limit"
public static final String
"error.partition.processing.cycle.delay"
public static final String
"fast.avro.field.limit.per.method"
public static final String
"fatal.data.validation.failure.topic.retention.ms"
public static final String
"controller.force.leader.error.replica.fail.over.enabled"
public static final String
"freeze.ingestion.if.ready.to.serve.or.local.data.exists"
public static final String
"grpc.read.server.port"
public static final String
"grpc.server.worker.thread.count"
public static final String
"heartbeat.cycle"
public static final String
"heartbeat.timeout"
public static final String
"helix.hybrid.store.quota.enabled"
public static final String
"helix.rebalance.alg"
public static final String
"helix.send.message.timeout.ms"
public static final String
"server.hybrid.quota.enforcement.enabled"
public static final String
"identity.parser.class"
public static final String
"ingestion.memory.limit"
public static final String
"ingestion.memory.limit.store.list"
public static final String
"ingestion.mlock.enabled"
public static final String
"ingestion.use.da.vinci.client"
public static final String
"instance.id"
public static final String
"kafka.admin.class"
public static final String
"kafka.admin.get.topic.config.max.retry.sec"
public static final String
"kafka.auto.offset.reset"
public static final String
"kafka.bootstrap.servers"
public static final String
"kafka.client.id"
public static final String
"name"
public static final String
"otherUrls"
public static final String
"url"
public static final String
"securityProtocol"
public static final String
"kafka."
public static final String
"kafka.empty.poll.sleep.ms"
public static final String
"kafka.enable.auto.commit"
public static final String
"kafka.fetch.max.bytes"
public static final String
"kafka.fetch.max.size.per.sec"
public static final String
"kafka.fetch.max.wait.ms"
public static final String
"kafka.fetch.max.wait.time.ms"
public static final String
"kafka.fetch.min.bytes"
public static final String
"kafka.fetch.min.size.per.sec"
public static final String
"kafka.fetch.partition.max.size.per.sec"
public static final String
"kafka.fetch.quota.bytes.per.second"
public static final String
"kafka.fetch.quota.records.per.second"
public static final String
"kafka.fetch.quota.time.window.ms"
public static final String
"kafka.fetch.quota.unordered.bytes.per.second"
public static final String
"kafka.fetch.quota.unordered.records.per.second"
public static final String
"kafka.group.id"
public static final String
"kafka.linger.ms"
public static final String
"kafka.log.compaction.for.hybrid.stores"
public static final String
"kafka.max.partition.fetch.bytes"
public static final String
"kafka.max.poll.records"
public static final String
"kafka.min.in.sync.replicas"
public static final String
"kafka.min.in.sync.replicas.admin.topics"
public static final String
"kafka.min.in.sync.replicas.rt.topics"
public static final String
"kafka.over.ssl"
public static final String
"kafka.delivery.timeout.ms"
public static final String
"list.of.producer.metrics.from.kafka"
public static final String
"kafka.request.timeout.ms"
public static final String
"kafka.retries"
public static final String
"kafka.read.cycle.delay.ms"
public static final String
"kafka.read.only.admin.class"
public static final String
"kafka.replication.factor"
public static final String
"kafka.replication.factor.rt.topics"
public static final String
"security.protocol"
public static final String
"kafka.write.only.admin.class"
public static final String
"key.value.profiling.enabled"
public static final String
"kme.registration.from.message.header.enabled"
public static final String
"leader.follower.state.transition.thread.pool.strategy"
public static final String
"leaked.push.status.clean.up.service.interval.ms"
public static final String
"leaked.resource.allowed.linger.time.ms"
public static final String
"listener.hostname"
public static final String
"listener.port"
public static final String
"listener.ssl.port"
public static final String
"local.controller.d2.service.name"
public static final String
"local.controller.url"
public static final String
"local.d2.zk.host"
public static final String
"local.region.name"
public static final String
"max.future.version.leader.follower.state.transition.thread.number"
public static final String
"max.leader.follower.state.transition.thread.number"
public static final String
"max.state.transition.thread.number"
public static final String
"max.read.capacity"
public static final String
"meta.store.writer.close.concurrency"
public static final String
"meta.store.writer.close.timeout.ms"
public static final String
"min.consumer.in.consumer.pool.per.kafka.cluster"
public static final String
"min.number.of.store.versions.to.preserve"
public static final String
"min.number.of.unused.kafka.topics.to.preserve"
public static final String
"multi.region"
public static final String
"name.repository.max.entry.count"
public static final String
"native.replication.fabric.allowlist"
public static final String
"native.replication.fabric.whitelist"
public static final String
"native.replication.source.fabric"
public static final String
"native.replication.source.fabric.as.default.for.batch.only.stores"
public static final String
"native.replication.source.fabric.as.default.for.hybrid.stores"
public static final String
"offline.job.start.timeout.ms"
public static final String
"offset.lag.delta.relax.factor.for.fast.online.transition.in.restart"
public static final String
"parent.controller.max.errored.topic.num.to.keep"
public static final String
"parent.controller.waiting.time.for.consumption.ms"
public static final String
"parent.kafka.cluster.fabric.list"
public static final String
"participant.message.consumption.delay.ms"
public static final String
"participant.message.store.enabled"
public static final String
"partition.count.round.up.size"
public static final String
"partitioner.class"
public static final String
"persistence.type"
public static final String
"pub.sub.admin.adapter.factory.class"
public static final String
"pub.sub.consumer.adapter.factory.class"
public static final String
"pub.sub.producer.adapter.factory.class"
public static final String
"pub.sub.of.source.of.truth.admin.adapter.factory.class"
public static final String
"pubsub.topic.manager.metadata.fetcher.consumer.pool.size"
public static final String
"pubsub.topic.manager.metadata.fetcher.thread.pool.size"
public static final String
"push.job.failure.checkpoints.to.define.user.error"
public static final String
"push.job.guid.least.significant.bits"
public static final String
"push.job.guid.most.significant.bits"
public static final String
"controller.push.job.status.store.cluster.name"
public static final String
"push.job.view.configs"
public static final String
"push.monitor.type"
public static final String
"push.ssl.allowlist"
public static final String
"push.ssl.whitelist"
public static final String
"push.status.instance.name.suffix"
public static final String
"push.status.store.enabled"
public static final String
"push.status.store.heartbeat.expiration.seconds"
public static final String
"push.status.store.heartbeat.interval.seconds"
public static final String
"refresh.attempts.for.zk.reconnect"
public static final String
"refresh.interval.for.zk.reconnect.ms"
public static final String
"replication.metadata.version"
public static final String
"router.dns.cache.host.pattern"
public static final String
"router.async.start.enabled"
public static final String
"router.client.decompression.enabled"
public static final String
"router.client.resolution.retry.attempts"
public static final String
"router.client.resolution.retry.backoff.ms"
public static final String
"router.client.ssl.handshake.queue.capacity"
public static final String
"router.client.ssl.handshake.threads"
public static final String
"router.compute.tardy.latency.ms"
public static final String
"router.connection.limit"
public static final String
"router.connection.timeout"
public static final String
"router.dictionary.processing.threads"
public static final String
"router.dictionary.retrieval.time.ms"
public static final String
"router.dns.cache.enabled"
public static final String
"router.dns.cache.refresh.interval.ms"
public static final String
"router.early.throttle.enabled"
public static final String
"router.enable.read.throttling"
public static final String
"router.enable.ssl"
public static final String
"router.full.pending.queue.server.oor.ms"
public static final String
"router.heart.beat.enabled"
public static final String
"router.helix.assisted.routing.group.selection.strategy"
public static final String
"router.helix.virtual.group.field.in.domain"
public static final String
"router.http.client.openssl.enabled"
public static final String
"router.http.client.pool.size"
public static final String
"router.http.client5.pool.size"
public static final String
"router.http.client5.skip.cipher.check.enabled"
public static final String
"router.http.client5.total.io.thread.count"
public static final String
"router.http2.header.table.size"
public static final String
"router.http2.inbound.enabled"
public static final String
"router.http2.initial.window.size"
public static final String
"router.http2.max.concurrent.streams"
public static final String
"router.http2.max.frame.size"
public static final String
"router.http2.max.header.list.size"
public static final String
"router.httpasyncclient.client.pool.io.thread.count"
public static final String
"router.httpasyncclient.connection.warming.enabled"
public static final String
"router.httpasyncclient.connection.warming.executor.thread.num"
public static final String
"router.httpasyncclient.connection.warming.low.water.mark"
public static final String
"router.httpasyncclient.connection.warming.new.instance.delay.join.ms"
public static final String
"router.httpasyncclient.connection.warming.sleep.interval.ms"
public static final String
"router.httpasyncclient.connection.warming.socket.timeout.ms"
public static final String
"router.idle.connection.to.server.cleanup.enabled"
public static final String
"router.idle.connection.to.server.cleanup.threshold.mins"
public static final String
"router.io.worker.count"
public static final String
"router.leaked.future.cleanup.poll.interval.ms"
public static final String
"router.leaked.future.cleanup.threshold.ms"
public static final String
"router.long.tail.retry.budget.enforcement.window.ms"
public static final String
"router.long.tail.retry.for.batch.get.threshold.ms"
public static final String
"router.long.tail.retry.for.single.get.threshold.ms"
public static final String
"router.long.tail.retry.max.route.for.multi.keys.req"
public static final String
"router.max.concurrent.resolutions"
public static final String
"router.max.key_count.in.multiget.req"
public static final String
"router.max.outgoing.connection"
public static final String
"router.max.outgoing.connection.per.route"
public static final String
"router.max.pending.request"
public static final String
"router.max.read.capacity"
public static final String
"router.meta.store.shadow.read.enabled"
public static final String
"router.multi.key.long.tail.retry.budget.percent.decimal"
public static final String
"router.multi.key.routing.strategy"
public static final String
"router.multiget.tardy.latency.ms"
public static final String
"router.netty.graceful.shutdown.period.seconds"
public static final String
"router.pending.connection.resume.threshold.per.host"
public static final String
"router.per.node.client.enabled"
public static final String
"router.per.node.client.thread.count"
public static final String
"router.per.store.router.quota.buffer"
public static final String
"router.principal.name"
public static final String
"router.quota.check.window"
public static final String
"router.read.quota.throttling.lease.timeout.ms"
public static final String
"router.resolve.before.ssl"
public static final String
"router.retry.manager.core.pool.size"
public static final String
"router.single.key.long.tail.retry.budget.percent.decimal"
public static final String
"router.singleget.tardy.latency.ms"
public static final String
"router.smart.long.tail.retry.abort.threshold.ms"
public static final String
"router.smart.long.tail.retry.enabled"
public static final String
"router.socket.timeout"
public static final String
"router.stateful.healthcheck.enabled"
public static final String
"router.storage.node.client.type"
public static final String
"router.unhealthy.pending.connection.threshold.per.host"
public static final String
"router.local.ssl"
public static final String
"server.aa.wc.leader.quota.records.per.second"
public static final String
"server.aa.wc.workload.parallel.processing.enabled"
public static final String
"server.aa.wc.workload.parallel.processing.thread.pool.size"
public static final String
"server.adaptive.throttler.enabled"
public static final String
"server.adaptive.throttler.signal.idle.threshold"
public static final String
"server.adaptive.throttler.single.get.latency.threshold"
public static final String
"server.batch.report.end.of.incremental.push.status.enabled"
public static final String
"server.blocking.queue.type"
public static final String
"server.channel.option.write.buffer.watermark.high.bytes"
public static final String
"server.compute.fast.avro.enabled"
public static final String
"server.compute.queue.capacity"
public static final String
"server.compute.thread.num"
public static final String
"server.consumer.pool.allocation.strategy"
public static final String
"server.consumer.pool.size.for.current.version.aa.wc.leader"
public static final String
"server.consumer.pool.size.for.current.version.non.aa.wc.leader"
public static final String
"server.consumer.pool.size.for.current.version.separate.rt.leader"
public static final String
"server.consumer.pool.size.for.non.current.version.aa.wc.leader"
public static final String
"server.consumer.pool.size.for.non.current.version.non.aa.wc.leader"
public static final String
"server.consumer.pool.size.per.kafka.cluster"
public static final String
"server.current.version.aa.wc.leader.quota.records.per.second"
public static final String
"server.current.version.non.aa.wc.leader.quota.records.per.second"
public static final String
"server.current.version.separate.rt.leader.quota.records.per.second"
public static final String
"server.database.checksum.verification.enabled"
public static final String
"server.database.lookup.queue.capacity"
public static final String
"server.database.memory.stats.enabled"
public static final String
"server.database.sync.bytes.interval.for.deferred.write.mode"
public static final String
"server.database.sync.bytes.interval.for.transactional.mode"
public static final String
"server.db.read.only.for.batch.only.store.enabled"
public static final String
"server.debug.logging.enabled"
public static final String
"server.dedicated.consumer.pool.for.aa.wc.leader.enabled"
public static final String
"server.dedicated.consumer.pool.size.for.aa.wc.leader"
public static final String
"server.dedicated.consumer.pool.size.for.sep.rt.leader"
public static final String
"server.dedicated.drainer.queue.for.sorted.input.enabled"
public static final String
"server.delete.unassigned.partitions.on.startup"
public static final String
"disk.full.threshold"
public static final String
"server.disk.health.check.interval.in.seconds"
public static final String
"server.disk.health.check.service.enabled"
public static final String
"server.disk.health.check.timeout.in.seconds"
public static final String
"server.enable.live.config.based.kafka.throttling"
public static final String
"server.enable.parallel.batch.get"
public static final String
"server.forked.process.jvm.arg.list"
public static final String
"server.global.rt.div.enabled"
public static final String
"server.helix.join.as.unknown"
public static final String
"server.http2.header.table.size"
public static final String
"server.http2.inbound.enabled"
public static final String
"server.http2.initial.window.size"
public static final String
"server.http2.max.concurrent.streams"
public static final String
"server.http2.max.frame.size"
public static final String
"server.http2.max.header.list.size"
public static final String
"server.incremental.push.status.write.mode"
public static final String
"server.ingestion.checkpoint.during.graceful.shutdown.enabled"
public static final String
"server.ingestion.heartbeat.interval.ms"
public static final String
"server.ingestion.isolation.acl.enabled"
public static final String
"server.ingestion.isolation.application.port"
public static final String
"server.ingestion.isolation.connection.timeout.seconds"
public static final String
"server.ingestion.isolation.heartbeat.request.timeout.seconds"
public static final String
"server.ingestion.isolation.principal.name"
public static final String
"server.ingestion.isolation.request.timeout.seconds"
public static final String
"server.ingestion.isolation.service.port"
public static final String
"server.ingestion.isolation.ssl.enabled"
public static final String
"server.ingestion.isolation.stats.class.list"
public static final String
"server.ingestion.mode"
public static final String
"server.ingestion.task.max.idle.count"
public static final String
"server.kafka.consumer.offset.collection.enabled"
public static final String
"server.kafka.fetch.quota.records.per.second"
public static final String
"server.kafka.max.poll.records"
public static final String
"server.leader.complete.state.check.in.follower.enabled"
public static final String
"server.leader.complete.state.check.in.follower.valid.interval.ms"
public static final String
"server.leaked.resource.clean.up.interval.in.minutes"
public static final String
"server.leaked.resource.cleanup.enabled"
public static final String
"server.local.consumer.config.prefix."
public static final String
"server.max.request.size"
public static final String
"server.max.wait.after.unsubscribe.ms"
public static final String
"server.max.wait.for.version.info.ms"
public static final String
"server.nearline.workload.producer.throughput.optimization.enabled"
public static final String
"server.netty.graceful.shutdown.period.seconds"
public static final String
"server.netty.idle.time.seconds"
public static final String
"server.netty.worker.threads"
public static final String
"server.node.capacity.rcu.per.second"
public static final String
"server.non.current.version.aa.wc.leader.quota.records.per.second"
public static final String
"server.non.current.version.non.aa.wc.leader.quota.records.per.second"
public static final String
"server.non.existing.topic.check.retry.interval.second"
public static final String
"server.non.existing.topic.ingestion.task.kill.threshold.second"
public static final String
"server.num.schema.fast.class.warmup"
public static final String
"server.optimize.database.for.backup.version.enabled"
public static final String
"server.optimize.database.for.backup.version.no.read.threshold.seconds"
public static final String
"server.optimize.database.service.schedule.internal.seconds"
public static final String
"server.parallel.batch.get.chunk.size"
public static final String
"server.partition.graceful.drop.time.in.seconds"
public static final String
"server.promotion.to.leader.replica.delay.seconds"
public static final String
"server.pubsub.consumer.poll.retry.backoff.ms"
public static final String
"server.pubsub.consumer.poll.retry.times"
public static final String
"server.quota.enforcement.capacity.multiple"
public static final String
"server.quota.enforcement.enabled"
public static final String
"server.quota.enforcement.interval.in.millis"
public static final String
"server.record.level.metrics.when.bootstrapping.current.version.enabled"
public static final String
"server.remote.consumer.config.prefix."
public static final String
"server.remote.ingestion.repair.sleep.interval.seconds"
public static final String
"server.reset.error.replica.enabled"
public static final String
"server.rest.service.epoll.enabled"
public static final String
"server.rest.service.storage.thread.num"
public static final String
"server.resubscription.triggered.by.version.ingestion.context.change.enabled"
public static final String
"server.rocksdb.storage.config.check.enabled"
public static final String
"server.router.connection.warming.delay.ms"
public static final String
"server.schema.fast.class.warmup.timeout"
public static final String
"server.schema.presence.check.enabled"
public static final String
"server.sep.rt.leader.quota.records.per.second"
public static final String
"server.shared.consumer.assignment.strategy"
public static final String
"server.shared.cosnumer.non.existing.topic.cleanup.delay.ms"
public static final String
"server.shutdown.ssd.unhealthy.time.ms"
public static final String
"server.source.topic.offset.check.interval.ms"
public static final String
"server.ssl.handshake.queue.capacity"
public static final String
"server.ssl.handshake.thread.pool.size"
public static final String
"server.stop.consumption.timeout.in.seconds"
public static final String
"server.storage.node.rate.limiter"
public static final String
"server.store.to.early.termination.threshold.ms.map"
public static final String
"server.store.version.qps.rate.limiter"
public static final String
"server.stuck.consumer.repair.enabled"
public static final String
"server.stuck.consumer.repair.second"
public static final String
"server.stuck.consumer.repair.threshold.second"
public static final String
"server.system.store.promotion.to.leader.replica.delay.seconds"
public static final String
"server.unsub.after.batch.push"
public static final String
"server.zstd.dict.compression.level"
public static final String
"service.discovery.registration.retry.ms"
public static final String
"server.calculate.quota.usage.based.on.partitions.assignment.enabled"
public static final String
"sorted.input.drainer.size"
public static final String
"ssl.kafka.bootstrap.servers"
public static final String
"ssl.to.kakfa"
public static final String
"sslToStorageNodes"
public static final String
"storage.engine.overhead.ratio"
public static final String
"store.writer.buffer.after.leader.logic.enabled"
public static final String
"store.writer.buffer.memory.capacity"
public static final String
"store.writer.buffer.notify.delta"
public static final String
"store.writer.number"
public static final String
"system.schema.cluster.name"
public static final String
"system.schema.initialization.at.start.time.enabled"
public static final String
"controller.terminal.state.topic.check.delay.ms"
public static final String
"topic.cleanup.delay.factor"
public static final String
"topic.cleanup.sleep.interval.between.topic.list.fetch.ms"
public static final String
"unregister.metric.for.deleted.store.enabled"
public static final String
"unsorted.input.drainer.size"
public static final String
"use.da.vinci.specific.execution.status.for.error"
public static final String
"controller.server.incremental.push.use.push.status.store"
public static final String
"validate.venice.internal.schema.version"
public static final String
"venice.partitioners"
public static final String
"venice.cluster.leader.haas.enabled"
public static final String
"zookeeper.address"
-
Modifier and TypeConstant FieldValue
public static final String
"avro/binary"
public static final String
"application/octet-stream"
public static final String
"http"
public static final String
"GET"
public static final String
"http://"
public static final String
"https"
public static final String
"POST"
public static final String
"https://"
public static final String
"application/json"
public static final String
"localhost"
public static final int
421
public static final String
"text/html"
public static final String
"text/plain"
public static final String
"X-VENICE-ALLOW-REDIRECT"
public static final String
"X-VENICE-API-VERSION"
public static final String
"X-VENICE-CLIENT-COMPUTE"
public static final String
"0"
public static final String
"1"
public static final String
"X-VENICE-COMPRESSION-STRATEGY"
public static final String
"X-VENICE-COMPUTE-VALUE-SCHEMA-ID"
public static final String
"X-VENICE-KEY-COUNT"
public static final String
"X-VENICE-RCU"
public static final String
"X-VENICE-RETRY"
public static final String
"X-VENICE-SCHEMA-ID"
public static final String
"X-VENICE-STORE-VERSION"
public static final String
"X-VENICE-STREAMING"
public static final String
"X-VENICE-STREAMING-RESPONSE"
public static final String
"X-VENICE-SUPPORTED-COMPRESSION-STRATEGY"
-
Modifier and TypeConstant FieldValue
public static final String
"Received the signal to kill this consumer. Topic "
-
Modifier and TypeConstant FieldValue
public static final boolean
true
-
Modifier and TypeConstant FieldValue
public static final int
2
public static final int
3
public static final int
4
public static final String
"javax.servlet.request.X509Certificate"
public static final int
20000000
public static final String
"com.linkedin.venice.security.DefaultSSLFactory"
public static final String
"FABRIC"
public static final String
"prod-lva1"
public static final String
"com.linkedin.app.env"
public static final String
"venice-internal"
public static final String
"push_status"
public static final String
"store_state"
public static final String
"stream_hybrid_store_quota"
public static final String
"stream_reprocessing_hybrid_store_quota"
public static final String
"__veniceComputationError__"
-
Modifier and TypeConstant FieldValue
public static final int
3
-
Modifier and TypeConstant FieldValue
protected static final int
3
-
Modifier and TypeConstant FieldValue
public static final int
0
public static final int
1
-
Modifier and TypeConstant FieldValue
public static final String
"This method is not implemented yet"
-
Modifier and TypeConstant FieldValue
public static final String
"Only active parent controllers are allowed to run "
-
Modifier and TypeConstant FieldValue
public static final String
"Only admin users are allowed to run "
-
Modifier and TypeConstant FieldValue
public static final String
"CONTROLLER_SYSTEM_STORE_REPAIR_JOB_"
-
Modifier and TypeConstant FieldValue
public static final String
"access_controlled"
public static final String
"access_permission"
public static final String
"active_active_replication_enabled"
public static final String
"allow.store.migration"
public static final String
"amplification_factor"
public static final String
"auto_auto_register_for_pushjob_enabled"
public static final String
"backup_strategy"
public static final String
"backup_version_retention_ms"
public static final String
"batch_get_limit"
public static final String
"batch_get_router_cache_enabled"
public static final String
"batch_job_heartbeat_enabled"
public static final String
"blob_transfer_enabled"
public static final String
"bootstrap_to_online_timeout_in_hours"
public static final String
"buffer_replay_policy"
public static final String
"child.controller.admin.topic.consumption.enabled"
public static final String
"chunking_enabled"
public static final String
"client_decompression_enabled"
public static final String
"cluster_name"
public static final String
"cluster_name_dest"
public static final String
"cluster_id"
public static final String
"compression_dictionary"
public static final String
"compression_strategy"
public static final String
"data.recovery.copy.all.version.configs"
public static final String
"data_replication_policy"
public static final String
"defer_version_swap"
public static final String
"derived_schema"
public static final String
"derived_schema_id"
public static final String
"dest_fabric"
public static final String
"disable_davinci_push_status_store"
public static final String
"disable_meta_store"
public static final String
"disable_store_view"
public static final String
"enable_disabled_replicas"
public static final String
"enable_reads"
public static final String
"enable_store_migration"
public static final String
"enable_writes"
public static final String
"error"
public static final String
"etled_proxy_user_account"
public static final String
"execution_id"
public static final String
"expected_router_count"
public static final String
"fabric"
public static final String
"fabric_a"
public static final String
"fabric_b"
public static final String
"frozen"
public static final String
"future_version_etl_enabled"
public static final String
"heartbeat_timestamp"
public static final String
"hostname"
public static final String
"hybrid-store-disk-quota-enabled"
public static final String
"hybrid_store_overhead_bypass"
public static final String
"include_system_stores"
public static final String
"incremental_push_enabled"
public static final String
"incremental_push_version"
public static final String
"instances"
public static final String
"is_abort_migration_cleanup"
public static final String
"is_davinci_heartbeat_reported"
public static final String
"is_system_store"
public static final String
"is_write_compute_enabled"
public static final String
"kafka.topic.log.compaction.enabled"
public static final String
"kafka.topic.min.in.sync.replica"
public static final String
"kafka.topic.retention.in.ms"
public static final String
"key_schema"
public static final String
"largest_used_version_number"
public static final String
"latest_superset_schema_id"
public static final String
"max_compaction_lag_seconds"
public static final String
"max_nearline_record_size_bytes"
public static final String
"max_record_size_bytes"
public static final String
"migration_duplicate_store"
public static final String
"min_compaction_lag_seconds"
public static final String
"store_name"
public static final String
"native_replication_enabled"
public static final String
"native_replication_source_fabric"
public static final String
"nearline_producer_compression_enabled"
public static final String
"nearline_producer_count_per_writer"
public static final String
"num_versions_to_preserve"
public static final String
"offset"
public static final String
"offset_lag_to_go_online"
public static final String
"operation"
public static final String
"owner"
public static final String
"partition_count"
public static final String
"partition_detail_enabled"
public static final String
"partitioner_class"
public static final String
"partitioner_params"
public static final String
"partitioners"
public static final String
"persona_name"
public static final String
"persona_owners"
public static final String
"persona_quota"
public static final String
"persona_stores"
public static final String
"push_in_sorted_order"
public static final String
"push_job_details"
public static final String
"push_job_duration"
public static final String
"push_job_id"
public static final String
"push_job_status"
public static final String
"push_strategy"
public static final String
"push_stream_source_address"
public static final String
"push_type"
public static final String
"read_computation_enabled"
public static final String
"read"
public static final String
"read_quota_in_cu"
public static final String
"readwrite"
public static final String
"real_time_topic_name"
public static final String
"regions_filter"
public static final String
"regular_version_etl_enabled"
public static final String
"remote_kafka_bootstrap_servers"
public static final String
"replicate_all_configs"
public static final String
"replication_factor"
public static final String
"replication_metadata_protocol_version_id"
public static final String
"replication_metadata_version_id"
public static final String
"repush_source_version"
public static final String
"rewind_time_seconds"
public static final String
"rewind_time_in_seconds_override"
public static final String
"rmd_chunking_enabled"
public static final String
"schema_compat_type"
public static final String
"schema_id"
public static final String
"start_of_push"
public static final String
"separate_realtime_topic_enabled"
public static final String
"server.kafka.fetch.quota.records.per.second"
public static final String
"single_get_router_cache_enabled"
public static final String
"skip_div"
public static final String
"source_fabric"
public static final String
"source.fabric.version.included"
public static final String
"source_grid_fabric"
public static final String
"status"
public static final String
"storage_node_id"
public static final String
"storage_node_read_quota_enabled"
public static final String
"storage_quota_in_byte"
public static final String
"store_config_name_filter"
public static final String
"store_config_value_filter"
public static final String
"store_migration"
public static final String
"store_name"
public static final String
"store_partition"
public static final String
"store_size"
public static final String
"store_type"
public static final String
"store_version"
public static final String
"store_view"
public static final String
"store_view_class"
public static final String
"store_view_name"
public static final String
"store_view_params"
public static final String
"target_swap_region"
public static final String
"target_swap_region_wait_time"
public static final String
"targeted_regions"
public static final String
"time_lag_to_go_online"
public static final String
"to_be_stopped_instances"
public static final String
"topic"
public static final String
"topic_compaction_policy"
public static final String
"unused_schema_deletion_enabled"
public static final String
"updated_configs_list"
public static final String
"upstream_offset"
public static final String
"value_schema"
public static final String
"value_schema_ids"
public static final String
"version"
public static final String
"voldemort_store_name"
public static final String
"write_computation_enabled"
public static final String
"write"
-
Modifier and TypeConstant FieldValue
public static final String
"d2.service.discovery.response.v2.enabled"
-
Modifier and TypeConstant FieldValue
public static final long
20L
public static final long
60L
-
Modifier and TypeConstant FieldValue
public static final long
5000000L
-
Modifier and TypeConstant FieldValue
public static final float
1.0f
public static final float
-1.0f
-
Modifier and TypeConstant FieldValue
public static final byte
0x2
public static final byte
0x0
public static final byte
0x4
-
Modifier and TypeConstant FieldValue
public static final String
"SERVER_ACL_APPROVED_ATTRIBUTE_KEY"
-
Modifier and TypeConstant FieldValue
public static final long
1800L
public static final int
3
public static final long
21474836480L
-
Modifier and TypeConstant FieldValue
public static final long
1000L
public static final long
-1L
public static final String
""
public static final long
86400L
-
Modifier and TypeConstant FieldValue
public static final int
-1
-
Modifier and TypeConstant FieldValue
public static final int
24
public static final int
150
public static final int
-1
public static final int
0
public static final int
0
public static final String
"venice_system_store_%s"
public static final String
"venice_system_store_"
public static final long
-1L
-
Modifier and TypeConstant FieldValue
public static final long
-1L
public static final long
-1L
public static final long
0L
public static final String
""
-
Modifier and TypeConstant FieldValue
public static final int
9
public static final int
8
public static final int
7
public static final int
3
public static final int
2
public static final int
10
public static final int
1
public static final int
5
-
Modifier and TypeConstant FieldValue
public static final String
"com.linkedin.venice.protocols.VeniceReadService"
-
Modifier and TypeConstant FieldValue
public static final int
3
public static final int
2
public static final int
6
public static final int
7
public static final int
5
public static final int
4
public static final int
1
-
Modifier and TypeConstant FieldValue
public static final int
2
public static final int
1
-
Modifier and TypeConstant FieldValue
public static final int
2
public static final int
1
public static final int
5
public static final int
3
public static final int
4
-
Modifier and TypeConstant FieldValue
public static final int
1
public static final int
2
public static final int
4
public static final int
3
public static final int
5
-
Modifier and TypeConstant FieldValue
public static final int
1
public static final int
2
-
Modifier and TypeConstant FieldValue
public static final String
"com.linkedin.venice.protocols.controller.ClusterAdminOpsGrpcService"
-
Modifier and TypeConstant FieldValue
public static final int
1
public static final int
2
-
Modifier and TypeConstant FieldValue
public static final int
8
public static final int
9
public static final int
6
public static final int
7
public static final int
1
public static final int
3
public static final int
2
public static final int
10
public static final int
5
public static final int
4
public static final int
11
public static final int
0
-
Modifier and TypeConstant FieldValue
public static final int
6
public static final int
5
public static final int
2
public static final int
4
public static final int
1
public static final int
3
-
Modifier and TypeConstant FieldValue
public static final int
2
public static final int
1
-
Modifier and TypeConstant FieldValue
public static final int
1
public static final int
3
public static final int
6
public static final int
4
public static final int
2
public static final int
5
-
Modifier and TypeConstant FieldValue
public static final int
2
public static final int
1
-
Modifier and TypeConstant FieldValue
public static final int
1
public static final int
2
-
Modifier and TypeConstant FieldValue
public static final int
1
public static final int
4
public static final int
3
public static final int
2
public static final int
5
-
Modifier and TypeConstant FieldValue
public static final int
3
public static final int
2
public static final int
1
-
Modifier and TypeConstant FieldValue
public static final String
"com.linkedin.venice.protocols.controller.StoreGrpcService"
-
Modifier and TypeConstant FieldValue
public static final int
3
public static final int
1
-
Modifier and TypeConstant FieldValue
public static final int
1
public static final int
2
-
Modifier and TypeConstant FieldValue
public static final int
4
public static final int
2
public static final int
3
public static final int
1
public static final int
5
-
Modifier and TypeConstant FieldValue
public static final String
"com.linkedin.venice.protocols.controller.VeniceControllerGrpcService"
-
Modifier and TypeConstant FieldValue
public static final long
172800000L
public static final long
86400000L
public static final int
3
public static final long
432000000L
public static final long
9223372036854775807L
public static final String
"pubsub.admin.api.default.timeout.ms"
public static final int
120000
public static final long
300L
public static final String
"pubsub.consumer.api.default.timeout.ms"
public static final int
60000
public static final String
"pubsub.consumer.check.topic.existence"
public static final boolean
false
public static final String
"pubsub.consumer.poll.retry.backoff.ms"
public static final int
0
public static final String
"pubsub.consumer.poll.retry.times"
public static final int
3
public static final int
3
public static final String
"pubsub.consumer.position.reset.strategy"
public static final String
"earliest"
public static final String
"pubsub.consumer.topic.query.retry.interval.ms"
public static final int
1000
public static final String
"pubsub.consumer.topic.query.retry.times"
public static final int
5
public static final int
1000
public static final long
-1L
public static final int
30000
public static final String
"pubsub.producer.use.high.throughput.defaults"
public static final int
3
public static final int
2000
public static final int
2
public static final long
-9223372036854775808L
public static final long
-1L
-
Modifier and TypeConstant FieldValue
public static final int
1048576
public static final String
"kafka.auto.offset.reset"
public static final String
"kafka.client.id"
public static final String
"kafka.enable.auto.commit"
public static final String
"kafka.fetch.max.bytes"
public static final String
"kafka.fetch.max.wait.ms"
public static final String
"kafka.fetch.min.bytes"
public static final String
"kafka.group.id"
public static final String
"kafka.max.partition.fetch.bytes"
public static final String
"kafka.max.poll.records"
-
Modifier and TypeConstant FieldValue
public static final String
"524288"
public static final String
"1000"
public static final String
"kafka.bootstrap.servers"
public static final String
"kafka.buffer.memory"
public static final String
"kafka.client.id"
public static final String
"kafka.compression.type"
public static final String
"kafka."
public static final String
"kafka.key.serializer"
public static final String
"kafka.linger.ms"
public static final String
"kafka.over.ssl"
public static final String
"kafka.delivery.timeout.ms"
public static final String
"kafka.request.timeout.ms"
public static final String
"kafka.retries"
public static final String
"kafka.value.serializer"
public static final String
"ssl.kafka.bootstrap.servers"
public static final String
"ssl.to.kakfa"
-
Modifier and TypeConstant FieldValue
public static final int
50
public static final long
-1L
-
Modifier and TypeConstant FieldValue
public static final int
400
public static final int
500
public static final int
-420
public static final int
200
public static final int
503
public static final int
429
-
Modifier and TypeConstant FieldValue
public static final String
"deployment.id"
public static final String
"."
public static final String
"__r2d2DefaultClient__.r2d2Client.zkHosts"
public static final String
"VeniceController"
public static final String
"VeniceParentController"
public static final String
"systems."
public static final String
"aggregate"
public static final String
"venice.child.controller.d2.service"
public static final String
"venice.child.d2.zk.hosts"
public static final String
"venice.controller.discovery.url"
public static final String
"venice.parent.controller.d2.service"
public static final String
"venice.parent.d2.zk.hosts"
public static final String
"push.type"
public static final String
"venice.router.url"
public static final String
"store"
-
Modifier and TypeConstant FieldValue
public static final int
-2
public static final int
-1
public static final int
0
-
Modifier and TypeConstant FieldValue
public static final String
"Reader schema can always successfully decode data written using the writer schema."
-
Modifier and TypeConstant FieldValue
public static final String
"activeElementsTimestamps"
public static final int
3
public static final String
"deletedElementsIdentities"
public static final int
4
public static final String
"deletedElementsTimestamps"
public static final int
5
public static final String
"putOnlyPartLength"
public static final int
2
public static final String
"topLevelColoID"
public static final int
1
public static final String
"topLevelFieldTimestamp"
public static final int
0
-
Modifier and TypeConstant FieldValue
public static final String
"ListOps"
public static final String
"mapDiff"
public static final String
"MapOps"
public static final String
"mapUnion"
public static final String
"setDiff"
public static final String
"setUnion"
public static final String
"WriteOpRecord"
-
Modifier and TypeConstant FieldValue
public static final int
60
public static final int
-1
public static final int
0
public static final String
"venice.schema-reader"
public static final int
1000
-
Modifier and TypeConstant FieldValue
public static final String
"local[*]"
public static final String
"key"
public static final String
"__partition__"
public static final String
"spark.app.name"
public static final String
"spark.sql.caseSensitive"
public static final String
"venice.spark.cluster"
public static final String
"spark.data.writer.conf."
public static final String
"spark.master"
public static final String
"venice.spark.session.conf."
public static final String
"value"
-
Modifier and TypeConstant FieldValue
public static final int
30
-
Modifier and TypeConstant FieldValue
public static final String
"otel.exporter.otlp.metrics.default.histogram.aggregation"
public static final String
"otel.exporter.otlp.metrics.default.histogram.aggregation.max.buckets"
public static final String
"otel.exporter.otlp.metrics.default.histogram.aggregation.max.scale"
public static final String
"otel.exporter.otlp.metrics.endpoint"
public static final String
"otel.exporter.otlp.metrics.headers"
public static final String
"otel.exporter.otlp.metrics.protocol"
public static final String
"otel.exporter.otlp.metrics.temporality.preference"
public static final String
"otel.venice.metrics.custom.dimensions.map"
public static final String
"otel.venice.metrics.enabled"
public static final String
"otel.venice.metrics.export.to.endpoint"
public static final String
"otel.venice.metrics.export.to.log"
public static final String
"otel.venice.metrics.naming.format"
public static final String
"otel.venice.metrics.prefix"
-
Modifier and TypeConstant FieldValue
public static final double
2.11
-
Modifier and TypeConstant FieldValue
public static final int
-1000000
public static final int
-1000
public static final int
-1001
-
Modifier and TypeConstant FieldValue
public static final long
1073741824L
public static final int
1024
public static final int
1048576
public static final int
1
public static final int
4
public static final int
8
public static final int
2
-
Modifier and TypeConstant FieldValue
public static final int
3
public static final String
"instance"
-
Modifier and TypeConstant FieldValue
public static final String
"Invalid owner\\(s\\) provided"
public static final String
"Update failed: persona with name .* does not exist in this cluster"
public static final String
"Invalid persona quota:.*"
public static final String
"Invalid store\\(s\\) provided: .*"
-
Modifier and TypeConstant FieldValue
public static final int
100
public static final String
"test_name_"
-
Modifier and TypeConstant FieldValue
public static final int
24
public static final int
60
public static final int
86400000
public static final int
3600000
public static final int
60000
public static final int
1000
public static final int
1000000
public static final int
1000000000
public static final int
1000
public static final int
86400
public static final int
3600
public static final int
60
public static final int
1000
public static final int
1000000
-
Modifier and TypeConstant FieldValue
public static final String
"eternal.topic.retention.enabled"
public static final String
"log.compaction.enabled"
public static final String
"nearline.producer.compression.enabled"
public static final String
"nearline.producer.count.per.writer"
public static final String
"sub.partition.count"
public static final String
"use.fast.kafka.operation.timeout"
-
Modifier and TypeConstant FieldValue
public static final String
"allow.duplicate.key"
public static final String
"batch.num.bytes"
public static final String
"compression.dictionary.sample.size"
public static final String
"compression.dictionary.size.limit"
public static final String
"compression.metric.collection.enabled"
public static final String
"compression.strategy"
public static final String
"controller.request.retry.attempts"
public static final String
"d2.zk.hosts."
public static final String
"data.writer.compute.job.class"
public static final int
1000000
public static final int
209715200
public static final boolean
false
public static final boolean
true
public static final boolean
false
public static final long
1800000L
public static final String
"key"
public static final long
300000L
public static final long
86400L
public static final boolean
false
public static final boolean
false
public static final String
"value"
public static final String
"defer.version.swap"
public static final String
"derived.schema.id"
public static final String
"venice.ssl.enable"
public static final String
"venice.write.compute.enable"
public static final String
"etl.value.schema.transformation"
public static final String
"extended.schema.validity.check.enabled"
public static final String
"key.schema"
public static final String
"value.schema"
public static final String
"generate.partial.update.record.from.input"
public static final String
"[^_.]*"
public static final String
"hadoop.tmp.dir"
public static final String
"hadoop-dict-build-conf."
public static final String
"incremental.push"
public static final String
"input.path.last.modified.time"
public static final String
"input.path"
public static final String
"job.execution.id"
public static final String
"job.execution.url"
public static final String
"job.server.name"
public static final String
"job.status.in.unknown.state.timeout.ms"
public static final String
"kafka.input.broker.url"
public static final String
"kafka.input.combiner.enabled"
public static final String
"kafka.input.compression.build.new.dict.enabled"
public static final String
"kafka.input.fabric"
public static final String
"kafka.input.max.records.per.mapper"
public static final String
"kafka.input.source.compression.strategy"
public static final String
"kafka.input.source.topic.chunking.enabled"
public static final String
"kafka.input.topic"
public static final String
"SSL"
public static final String
"kafka.source.key.schema"
public static final String
"key.field"
public static final String
"inputFileDataSize"
public static final String
"zstdDictionary"
public static final String
"avro.key.field"
public static final String
"avro.value.field"
public static final String
"map.reduce.partitioner.class"
public static final int
20
public static final String
"This exception does not fail the push job. "
public static final int
-1
public static final String
"parent.controller.region.name"
public static final String
"partition.count"
public static final String
"poll.job.status.interval.ms"
public static final String
"poll.status.retry.attempts"
public static final String
"push.job.status.upload.enable"
public static final String
"push.to.separate.realtime.topic"
public static final String
"reducer.speculative.execution.enable"
public static final String
"repush.ttl.enable"
public static final String
"repush.ttl.policy"
public static final String
"repush.ttl.seconds"
public static final String
"repush.ttl.start.timestamp"
public static final String
"rewind.epoch.time.buffer.in.seconds.override"
public static final String
"rewind.epoch.time.in.seconds.override"
public static final String
"rewind.time.in.seconds.override"
public static final String
"rmd.schema.dir"
public static final String
"schema"
public static final String
"send.control.messages.directly"
public static final boolean
true
public static final String
"source.etl"
public static final String
"source.grid.fabric"
public static final String
"source.kafka"
public static final String
"spark.native.input.format.enabled"
public static final String
"ssl.configurator.class"
public static final String
"ssl.key.password.property.name"
public static final String
"ssl.key.store.password.property.name"
public static final String
"ssl.key.store.property.name"
public static final String
"ssl"
public static final String
"ssl.trust.store.property.name"
public static final String
"storage_engine_overhead_ratio"
public static final String
"storage.quota"
public static final String
"suppress.end.of.push.message"
public static final String
"system.schema.cluster.d2.service.name"
public static final String
"system.schema.cluster.d2.zk.host"
public static final String
"system.schema.reader.enabled"
public static final String
"targeted.region.push.enabled"
public static final String
"targeted.region.push.list"
public static final String
"targeted.region.push.with.deferred.swap"
public static final String
"telemetry.message.interval"
public static final String
"tmp.dir.prefix"
public static final String
"venice.kafka.topic"
public static final int
-1
public static final String
"update.schema"
public static final String
"use.mapper.to.build.dictionary"
public static final String
"validate.schema.and.build.dict.mapper.output.directory"
public static final String
".avro"
public static final String
"mapper-output-"
public static final String
"value.field"
public static final String
"value.schema.dir"
public static final String
"value.schema.id"
public static final String
"venice.discover.urls"
public static final String
"venice.store.name"
public static final String
"vson.push"
public static final String
"zstd.compression.level"
public static final String
"zstd.dictionary.creation.required"
public static final String
"zstd.dictionary.creation.success"
-
Modifier and TypeConstant FieldValue
public static final long
-2L
public static final String
"venice.writer.checksum.type"
public static final String
"venice.writer.close.timeout.ms"
public static final int
30000
public static final int
30
public static final int
972800
public static final String
"venice.writer.chunking.enabled"
public static final String
"venice.writer.replication.metadata.chunking.enabled"
public static final String
"venice.writer.max.attemps.when.topic.missing"
public static final String
"venice.writer.max.elapsed.time.for.segment.in.ms"
public static final String
"venice.writer.max.record.size.bytes"
public static final String
"venice.writer.max.size.for.user.payload.per.message.in.bytes"
public static final String
"venice.writer.producer.queue.size"
public static final String
"venice.writer.producer.thread.count"
public static final int
-1
public static final long
-1L
public static final int
-1
public static final int
-1
public static final String
"venice.writer."
-
Modifier and TypeConstant FieldValue
public static final String
"adminTopicMetadata"
public static final String
"ClusterConfig"
public static final String
"executionids"
public static final String
"OfflinePushes"
public static final String
"ParentOfflinePushes"
public static final String
"routers"
public static final String
"storeConfigs"
public static final String
"StoreGraveyard"
public static final String
"Stores"