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.beam.tools.proto.service.Collect.Item

Modifier and Type	Constant Field	Value
public static final int	SERIALIZED_FIELD_NUMBER	1

cz.o2.proxima.beam.tools.proto.service.Collect.Response

Modifier and Type	Constant Field	Value
public static final int	STATUS_FIELD_NUMBER	1
public static final int	STATUSCODE_FIELD_NUMBER	2

cz.o2.proxima.beam.tools.proto.service.CollectServiceGrpc

Modifier and Type	Constant Field	Value
public static final java.lang.String	SERVICE_NAME	"CollectService"

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.direct.server.rpc.proto.service.IngestServiceGrpc

Modifier and Type	Constant Field	Value
public static final java.lang.String	SERVICE_NAME	"IngestService"

cz.o2.proxima.direct.server.rpc.proto.service.RetrieveServiceGrpc

Modifier and Type	Constant Field	Value
public static final java.lang.String	SERVICE_NAME	"RetrieveService"

cz.o2.proxima.direct.server.rpc.proto.service.Rpc.BeginTransactionRequest

Modifier and Type	Constant Field	Value
public static final int	ATTRIBUTESINVOLVED_FIELD_NUMBER	1
public static final int	TRANSACTIONID_FIELD_NUMBER	2

cz.o2.proxima.direct.server.rpc.proto.service.Rpc.BeginTransactionResponse

Modifier and Type	Constant Field	Value
public static final int	TRANSACTIONID_FIELD_NUMBER	1

cz.o2.proxima.direct.server.rpc.proto.service.Rpc.GetRequest

Modifier and Type	Constant Field	Value
public static final int	ATTRIBUTE_FIELD_NUMBER	3
public static final int	ENTITY_FIELD_NUMBER	1
public static final int	KEY_FIELD_NUMBER	2
public static final int	TRANSACTIONID_FIELD_NUMBER	4

cz.o2.proxima.direct.server.rpc.proto.service.Rpc.GetResponse

Modifier and Type	Constant Field	Value
public static final int	STAMP_FIELD_NUMBER	4
public static final int	STATUS_FIELD_NUMBER	1
public static final int	STATUSMESSAGE_FIELD_NUMBER	2
public static final int	VALUE_FIELD_NUMBER	3

cz.o2.proxima.direct.server.rpc.proto.service.Rpc.Ingest

Modifier and Type	Constant Field	Value
public static final int	ATTRIBUTE_FIELD_NUMBER	3
public static final int	DELETE_FIELD_NUMBER	6
public static final int	ENTITY_FIELD_NUMBER	2
public static final int	KEY_FIELD_NUMBER	4
public static final int	STAMP_FIELD_NUMBER	7
public static final int	TRANSACTIONID_FIELD_NUMBER	8
public static final int	UUID_FIELD_NUMBER	1
public static final int	VALUE_FIELD_NUMBER	5

cz.o2.proxima.direct.server.rpc.proto.service.Rpc.IngestBulk

Modifier and Type	Constant Field	Value
public static final int	INGEST_FIELD_NUMBER	1

cz.o2.proxima.direct.server.rpc.proto.service.Rpc.KeyAttribute

Modifier and Type	Constant Field	Value
public static final int	ATTRIBUTE_FIELD_NUMBER	3
public static final int	ENTITY_FIELD_NUMBER	1
public static final int	KEY_FIELD_NUMBER	2

cz.o2.proxima.direct.server.rpc.proto.service.Rpc.KeyValue

Modifier and Type	Constant Field	Value
public static final int	ATTRIBUTE_FIELD_NUMBER	2
public static final int	KEY_FIELD_NUMBER	1
public static final int	STAMP_FIELD_NUMBER	4
public static final int	VALUE_FIELD_NUMBER	3

cz.o2.proxima.direct.server.rpc.proto.service.Rpc.ListRequest

Modifier and Type	Constant Field	Value
public static final int	ENTITY_FIELD_NUMBER	1
public static final int	KEY_FIELD_NUMBER	2
public static final int	LIMIT_FIELD_NUMBER	5
public static final int	OFFSET_FIELD_NUMBER	4
public static final int	TRANSACTIONID_FIELD_NUMBER	6
public static final int	WILDCARDPREFIX_FIELD_NUMBER	3

cz.o2.proxima.direct.server.rpc.proto.service.Rpc.ListResponse

Modifier and Type	Constant Field	Value
public static final int	STATUS_FIELD_NUMBER	1
public static final int	STATUSMESSAGE_FIELD_NUMBER	2
public static final int	VALUE_FIELD_NUMBER	3

cz.o2.proxima.direct.server.rpc.proto.service.Rpc.ListResponse.AttrValue

Modifier and Type	Constant Field	Value
public static final int	ATTRIBUTE_FIELD_NUMBER	1
public static final int	STAMP_FIELD_NUMBER	3
public static final int	VALUE_FIELD_NUMBER	2

cz.o2.proxima.direct.server.rpc.proto.service.Rpc.MultifetchRequest

Modifier and Type	Constant Field	Value
public static final int	GETREQUEST_FIELD_NUMBER	1
public static final int	LISTREQUEST_FIELD_NUMBER	2
public static final int	TRANSACTIONID_FIELD_NUMBER	3

cz.o2.proxima.direct.server.rpc.proto.service.Rpc.MultifetchResponse

Modifier and Type	Constant Field	Value
public static final int	GETRESPONSE_FIELD_NUMBER	1
public static final int	LISTRESPONSE_FIELD_NUMBER	2

cz.o2.proxima.direct.server.rpc.proto.service.Rpc.ScanRequest

Modifier and Type	Constant Field	Value
public static final int	ATTRIBUTE_FIELD_NUMBER	2
public static final int	ENTITY_FIELD_NUMBER	1

cz.o2.proxima.direct.server.rpc.proto.service.Rpc.ScanResult

Modifier and Type	Constant Field	Value
public static final int	VALUE_FIELD_NUMBER	5

cz.o2.proxima.direct.server.rpc.proto.service.Rpc.Status

Modifier and Type	Constant Field	Value
public static final int	STATUS_FIELD_NUMBER	2
public static final int	STATUSMESSAGE_FIELD_NUMBER	3
public static final int	UUID_FIELD_NUMBER	1

cz.o2.proxima.direct.server.rpc.proto.service.Rpc.StatusBulk

Modifier and Type	Constant Field	Value
public static final int	STATUS_FIELD_NUMBER	1

cz.o2.proxima.direct.server.rpc.proto.service.Rpc.TransactionCommitRequest

Modifier and Type	Constant Field	Value
public static final int	TRANSACTIONID_FIELD_NUMBER	1

cz.o2.proxima.direct.server.rpc.proto.service.Rpc.TransactionCommitResponse

Modifier and Type	Constant Field	Value
public static final int	SEQID_FIELD_NUMBER	3
public static final int	STAMP_FIELD_NUMBER	2
public static final int	STATUS_FIELD_NUMBER	1

cz.o2.proxima.direct.server.rpc.proto.service.Rpc.TransactionCommitResponse.Status

Modifier and Type	Constant Field	Value
public static final int	COMMITTED_VALUE	1
public static final int	FAILED_VALUE	3
public static final int	REJECTED_VALUE	2
public static final int	UNKNOWN_VALUE	0

cz.o2.proxima.io.pubsub.proto.PubSub.Bulk

Modifier and Type	Constant Field	Value
public static final int	KV_FIELD_NUMBER	1
public static final int	UUID_FIELD_NUMBER	2

cz.o2.proxima.io.pubsub.proto.PubSub.BulkWrapper

Modifier and Type	Constant Field	Value
public static final int	COMPRESSION_FIELD_NUMBER	1
public static final int	VALUE_FIELD_NUMBER	2

cz.o2.proxima.io.pubsub.proto.PubSub.BulkWrapper.Compression

Modifier and Type	Constant Field	Value
public static final int	DEFLATE_VALUE	2
public static final int	NONE_VALUE	1
public static final int	UNKNOWN_VALUE	0

cz.o2.proxima.io.pubsub.proto.PubSub.KeyValue

Modifier and Type	Constant Field	Value
public static final int	ATTRIBUTE_FIELD_NUMBER	2
public static final int	DELETE_FIELD_NUMBER	4
public static final int	DELETEWILDCARD_FIELD_NUMBER	5
public static final int	KEY_FIELD_NUMBER	1
public static final int	STAMP_FIELD_NUMBER	6
public static final int	VALUE_FIELD_NUMBER	3

cz.o2.proxima.io.serialization.proto.Serialization.Cell

Modifier and Type	Constant Field	Value
public static final int	SEQID_FIELD_NUMBER	2
public static final int	VALUE_FIELD_NUMBER	1

cz.o2.proxima.io.serialization.proto.Serialization.Element

Modifier and Type	Constant Field	Value
public static final int	ATTRIBUTE_FIELD_NUMBER	2
public static final int	DELETE_FIELD_NUMBER	5
public static final int	DELETEWILDCARD_FIELD_NUMBER	6
public static final int	KEY_FIELD_NUMBER	1
public static final int	STAMP_FIELD_NUMBER	3
public static final int	UUID_FIELD_NUMBER	7
public static final int	VALUE_FIELD_NUMBER	4

cz.o2.proxima.io.serialization.proto.Serialization.Header

Modifier and Type	Constant Field	Value
public static final int	GZIP_FIELD_NUMBER	3
public static final int	MAGIC_FIELD_NUMBER	1
public static final int	VERSION_FIELD_NUMBER	2

cz.o2.proxima.io.serialization.proto.Serialization.JsonElement

Modifier and Type	Constant Field	Value
public static final int	ATTRIBUTE_FIELD_NUMBER	2
public static final int	DELETE_FIELD_NUMBER	5
public static final int	DELETEWILDCARD_FIELD_NUMBER	6
public static final int	KEY_FIELD_NUMBER	1
public static final int	STAMP_FIELD_NUMBER	3
public static final int	UUID_FIELD_NUMBER	7
public static final int	VALUE_FIELD_NUMBER	4

cz.o2.proxima.scheme.proto.transactions.Transactions.Flags

Modifier and Type	Constant Field	Value
public static final int	ABORTED_VALUE	3
public static final int	COMMITTED_VALUE	2
public static final int	DUPLICATE_VALUE	4
public static final int	OPEN_VALUE	1
public static final int	ROLLBACK_VALUE	6
public static final int	UNKNOWN_VALUE	0
public static final int	UPDATE_VALUE	5

cz.o2.proxima.scheme.proto.transactions.Transactions.KeyAttribute

Modifier and Type	Constant Field	Value
public static final int	ATTRIBUTE_FIELD_NUMBER	4
public static final int	ATTRIBUTEDESC_FIELD_NUMBER	3
public static final int	DELETE_FIELD_NUMBER	5
public static final int	ENTITY_FIELD_NUMBER	1
public static final int	KEY_FIELD_NUMBER	2
public static final int	SEQID_FIELD_NUMBER	6

cz.o2.proxima.scheme.proto.transactions.Transactions.ProtoCommit

Modifier and Type	Constant Field	Value
public static final int	TRANSACTIONUPDATES_FIELD_NUMBER	4
public static final int	UPDATES_FIELD_NUMBER	3

cz.o2.proxima.scheme.proto.transactions.Transactions.ProtoRequest

Modifier and Type	Constant Field	Value
public static final int	FLAGS_FIELD_NUMBER	3
public static final int	INPUTATTRIBUTE_FIELD_NUMBER	1
public static final int	OUTPUT_FIELD_NUMBER	5
public static final int	RESPONSEPARTITIONID_FIELD_NUMBER	4

cz.o2.proxima.scheme.proto.transactions.Transactions.ProtoResponse

Modifier and Type	Constant Field	Value
public static final int	FLAGS_FIELD_NUMBER	1
public static final int	RESPONSEPARTITIONID_FIELD_NUMBER	4
public static final int	SEQID_FIELD_NUMBER	2
public static final int	STAMP_FIELD_NUMBER	3

cz.o2.proxima.scheme.proto.transactions.Transactions.ProtoState

Modifier and Type	Constant Field	Value
public static final int	COMMITTEDOUTPUTS_FIELD_NUMBER	6
public static final int	FLAGS_FIELD_NUMBER	1
public static final int	INPUTATTRIBUTES_FIELD_NUMBER	4
public static final int	SEQID_FIELD_NUMBER	2
public static final int	STAMP_FIELD_NUMBER	3

cz.o2.proxima.scheme.proto.transactions.Transactions.ProtoStreamElement

Modifier and Type	Constant Field	Value
public static final int	ATTRIBUTE_FIELD_NUMBER	3
public static final int	DELETE_FIELD_NUMBER	5
public static final int	ENTITY_FIELD_NUMBER	1
public static final int	KEY_FIELD_NUMBER	2
public static final int	SEQID_FIELD_NUMBER	8
public static final int	STAMP_FIELD_NUMBER	6
public static final int	UUID_FIELD_NUMBER	7
public static final int	VALUE_FIELD_NUMBER	4

cz.o2.proxima.scheme.proto.transactions.Transactions.TransactionUpdate

Modifier and Type	Constant Field	Value
public static final int	ELEMENT_FIELD_NUMBER	2
public static final int	TARGETFAMILY_FIELD_NUMBER	1

cz.o2.proxima.tools.groovy.Console

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