Constant Field Values

Contents

• cz.o2.*

cz.o2.*

cz.o2.proxima.beam.core.direct.io.DirectBatchUnboundedSource

Modifier and Type	Constant Field	Value
public static final java.lang.String	CFG_ENABLE_CHECKPOINT_PARTITION_MERGE	"checkpoint-partition-merge-enabled"

cz.o2.proxima.core.repository.AttributeFamilyDescriptor

Modifier and Type	Constant Field	Value
public static final java.lang.String	CFG_REPLICATION_CONSUMER_NAME_GENERATOR	"replication.consumer.name.factory"

cz.o2.proxima.core.repository.ConfigConstants

Modifier and Type	Constant Field	Value
public static final java.lang.String	ACCESS	"access"
public static final java.lang.String	ALL	"all"
public static final java.lang.String	ATTRIBUTE_FAMILIES	"attributeFamilies"
public static final java.lang.String	ATTRIBUTES	"attributes"
public static final java.lang.String	BATCH_SNAPSHOT	"batch-snapshot"
public static final java.lang.String	BATCH_UPDATES	"batch-updates"
public static final java.lang.String	CACHED_VIEW	"cached-view"
public static final java.lang.String	COMMIT_ATTRIBUTE	"commit"
public static final java.lang.String	COMMIT_LOG	"commit-log"
public static final java.lang.String	DISABLED	"disabled"
public static final java.lang.String	ENTITIES	"entities"
public static final java.lang.String	ENTITY	"entity"
public static final java.lang.String	FILTER	"filter"
public static final java.lang.String	FROM	"from"
public static final java.lang.String	LIST_PRIMARY_KEY	"list-primary-key"
public static final java.lang.String	LOCAL	"local"
public static final java.lang.String	MANAGER	"manager"
public static final java.lang.String	PARTITIONER	"partitioner"
public static final java.lang.String	PROXY	"proxy"
public static final java.lang.String	RANDOM_ACCESS	"random-access"
public static final java.lang.String	READ	"read"
public static final java.lang.String	READ_ONLY	"read-only"
public static final java.lang.String	REPLICATIONS	"replications"
public static final java.lang.String	REQUEST_ATTRIBUTE	"request.*"
public static final java.lang.String	RESPONSE_ATTRIBUTE	"response.*"
public static final java.lang.String	RESPONSE_ATTRIBUTE_PREFIX	"response."
public static final java.lang.String	SCHEME	"scheme"
public static final java.lang.String	SCHEME_PROVIDER	"scheme-provider"
public static final java.lang.String	SOURCE	"source"
public static final java.lang.String	STATE_ATTRIBUTE	"state"
public static final java.lang.String	STATE_COMMIT_LOG	"state-commit-log"
public static final java.lang.String	STORAGE	"storage"
public static final java.lang.String	TARGETS	"targets"
public static final java.lang.String	TRANSACTION_ENTITY	"_transaction"
public static final java.lang.String	TRANSACTIONAL	"transactional"
public static final java.lang.String	TRANSACTIONS	"transactions"
public static final java.lang.String	TYPE	"type"
public static final java.lang.String	VALIDATIONS	"validations"
public static final java.lang.String	VIA	"via"
public static final java.lang.String	WRITE	"write"
public static final java.lang.String	WRITE_ONLY	"write-only"

cz.o2.proxima.core.scheme.SchemaDescriptors.SchemaTypeDescriptor<T>

Modifier and Type	Constant Field	Value
public static final java.lang.String	TYPE_CHECK_ERROR_MESSAGE_TEMPLATE	"Conversion to type %s is not supported. Given type: %s"

cz.o2.proxima.core.storage.watermark.GlobalWatermarkThroughputLimiter

Modifier and Type	Constant Field	Value
public static final java.lang.String	DEFAULT_SLEEP_TIME_CFG	"default-sleep-time-ms"
public static final java.lang.String	GLOBAL_WATERMARK_UPDATE_MS_CFG	"global-watermark-update-ms"
public static final java.lang.String	MAX_AHEAD_TIME_MS_CFG	"max-watermark-ahead-ms"

cz.o2.proxima.core.time.Watermarks

Modifier and Type	Constant Field	Value
public static final long	MAX_WATERMARK	9223372036854775807L
public static final long	MIN_WATERMARK	-9223372036854775808L

cz.o2.proxima.core.utils.zookeeper.ZKGlobalWatermarkTracker

Modifier and Type	Constant Field	Value
public static final java.lang.String	CFG_MAX_ACCEPTABLE_UPDATE_AGE_MS	"max-acceptable-update-age-ms"
public static final java.lang.String	CFG_NAME	"name"
public static final java.lang.String	CFG_TIME_PROVIDER	"time-provider-class"
public static final java.lang.String	ZK_SESSION_TIMEOUT	"zk.timeout"
public static final java.lang.String	ZK_URI	"zk.url"

cz.o2.proxima.direct.core.time.BoundedOutOfOrdernessWatermarkEstimator

Modifier and Type	Constant Field	Value
public static final long	DEFAULT_MAX_OUT_OF_ORDERNESS_MS	0L
public static final java.lang.String	MAX_OUT_OF_ORDERNESS_MS	"max-out-of-orderness"

cz.o2.proxima.direct.core.time.SkewedProcessingTimeIdlePolicy

Modifier and Type	Constant Field	Value
public static final long	DEFAULT_TIMESTAMP_SKEW	100L
public static final java.lang.String	TIMESTAMP_SKEW	"timestamp-skew"

cz.o2.proxima.direct.core.time.UnboundedOutOfOrdernessWatermarkEstimator

Modifier and Type	Constant Field	Value
public static final java.lang.String	ALLOWED_TIMESTAMP_SKEW	"allowed-timestamp-skew"
public static final long	DEFAULT_ALLOWED_TIMESTAMP_SKEW	200L
public static final long	DEFAULT_ESTIMATE_DURATION_MS	10000L
public static final long	DEFAULT_STEP_MS	200L
public static final java.lang.String	ESTIMATE_DURATION_MS	"estimate-duration"
public static final java.lang.String	MIN_WATERMARK	"min-watermark"
public static final java.lang.String	STEP_MS	"step"

cz.o2.proxima.direct.core.time.WatermarkConfiguration

Modifier and Type	Constant Field	Value
public static final java.lang.String	CFG_ESTIMATOR_FACTORY	"estimator-factory"
public static final java.lang.String	CFG_IDLE_POLICY_FACTORY	"idle-policy-factory"
public static final java.lang.String	CFG_PREFIX	"watermark."

cz.o2.proxima.direct.io.blob.BlobStorageAccessor

Modifier and Type	Constant Field	Value
public static final java.lang.String	ALLOWED_LATENESS_MS	"allowed-lateness-ms"
public static final java.lang.String	LOG_ROLL_INTERVAL	"log-roll-interval"
public static final java.lang.String	PARTITION_MAX_BLOBS	"partition.max-blobs"
public static final java.lang.String	PARTITION_MAX_TIME_SPAN_MS	"partition.max-time-span-ms"
public static final java.lang.String	PARTITION_SIZE	"partition.size"

cz.o2.proxima.direct.io.bulkfs.parquet.ParquetFileFormat

Modifier and Type	Constant Field	Value
public static final java.lang.String	PARQUET_CONFIG_COMPRESSION_KEY_NAME	"parquet.compression"
public static final java.lang.String	PARQUET_CONFIG_PAGE_SIZE_KEY_NAME	"parquet.page.size"
public static final java.lang.String	PARQUET_CONFIG_VALUES_PREFIX_KEY_NAME	"parquet.values.name.prefix"
public static final int	PARQUET_DEFAULT_PAGE_SIZE	8388608
public static final java.lang.String	PARQUET_DEFAULT_VALUES_NAME_PREFIX	""
public static final java.lang.String	PARQUET_MESSAGE_NAME	"stream_element"

cz.o2.proxima.direct.io.hadoop.HadoopDataAccessor

Modifier and Type	Constant Field	Value
public static final java.lang.String	HADOOP_ALLOWED_LATENESS	"hadoop.allowed-lateness"
public static final java.lang.String	HADOOP_BATCH_PROCESS_SIZE_MIN	"hadoop.process-size.min"
public static final java.lang.String	HADOOP_ROLL_INTERVAL	"hadoop.log-roll-interval"
public static final java.lang.String	TMP_FS	"hadoop.tmp.fs"

cz.o2.proxima.direct.io.kafka.KafkaAccessor

Modifier and Type	Constant Field	Value
public static final java.lang.String	ASSIGNMENT_TIMEOUT_MS	"assignment-timeout-ms"
public static final java.lang.String	AUTO_COMMIT_INTERVAL_MS	"commit.auto-interval-ms"
public static final java.lang.String	EMPTY_POLL_TIME	"poll.allowed-empty-before-watermark-move"
public static final java.lang.String	KAFKA_CONFIG_PREFIX	"kafka."
public static final java.lang.String	LOG_STALE_COMMIT_INTERVAL_MS	"commit.log-stale-interval-ms"
public static final java.lang.String	MAX_BYTES_PER_SEC	"bytes-per-sec-max"
public static final java.lang.String	PARTITIONER_CLASS	"partitioner"
public static final java.lang.String	POLL_INTERVAL_CFG	"poll.interval"
public static final java.lang.String	SEQUENCE_ID_HEADER	"seqId"
public static final java.lang.String	SERIALIZER_CLASS	"serializer-class"
public static final java.lang.String	UUID_HEADER	"uuid"

cz.o2.proxima.direct.io.pubsub.PubSubAccessor

Modifier and Type	Constant Field	Value
public static final java.lang.String	CFG_MAX_ACK_DEADLINE	"pubsub.deadline-max-ms"
public static final java.lang.String	CFG_SUBSCRIPTION_ACK_DEADLINE	"pubsub.subscription.ack-deadline"
public static final java.lang.String	CFG_SUBSCRIPTION_AUTOCREATE	"pubsub.subscription.auto-create"

cz.o2.proxima.direct.io.pubsub.PubSubStorage

Modifier and Type	Constant Field	Value
public static final java.lang.String	CFG_DEFAULT_ALLOWED_TIMESTAMP_SKEW	"pubsub.default.watermark.allowed-timestamp-skew"
public static final java.lang.String	CFG_DEFAULT_MAX_ACK_DEADLINE	"pubsub.default.deadline-max-ms"
public static final java.lang.String	CFG_DEFAULT_SUBSCRIPTION_ACK_DEADLINE	"pubsub.default.subscription.ack-deadline"
public static final java.lang.String	CFG_DEFAULT_SUBSCRIPTION_AUTO_CREATE	"pubsub.default.subscription.auto-create"
public static final java.lang.String	CFG_DEFAULT_WATERMARK_ESTIMATE_DURATION	"pubsub.default.watermark.estimate-duration"

cz.o2.proxima.direct.server.Constants

Modifier and Type	Constant Field	Value
public static final java.lang.String	CFG_IGNORE_ERRORS	"ingest.ignore-errors"
public static final java.lang.String	CFG_NUM_THREADS	"ingest.server.num-threads"
public static final java.lang.String	CFG_PORT	"ingest.server.port"
public static final int	DEFAULT_PORT	4001

cz.o2.proxima.direct.server.metrics.Metrics

Modifier and Type	Constant Field	Value
public static final java.lang.String	GROUP	"cz.o2.proxima.direct.server"

cz.o2.proxima.tools.groovy.Console

Modifier and Type	Constant Field	Value
public static final java.lang.String	INITIAL_STATEMENT	"env = new Environment()"