Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
DATE_FORMAT_STRING |
"yyyy-MM-dd" |
public static final int |
EPOCH_JULIAN |
2440588 |
public static final long |
MILLIS_PER_DAY |
86400000L |
public static final long |
MILLIS_PER_HOUR |
3600000L |
public static final long |
MILLIS_PER_MINUTE |
60000L |
public static final long |
MILLIS_PER_SECOND |
1000L |
public static final String |
TIME_FORMAT_STRING |
"HH:mm:ss" |
public static final String |
TIMESTAMP_FORMAT_STRING |
"yyyy-MM-dd HH:mm:ss" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
PARALLELISM_AUTO_MAX |
2147483647 |
public static final int |
PARALLELISM_DEFAULT |
-1 |
public static final int |
PARALLELISM_UNKNOWN |
-2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
BLOCK_SIZE_PARAMETER_KEY |
"input.block_size" |
public static final long |
NATIVE_BLOCK_SIZE |
-9223372036854775808L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
BLOCK_SIZE_PARAMETER_KEY |
"output.block_size" |
public static final long |
NATIVE_BLOCK_SIZE |
-9223372036854775808L |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final String |
RECORD_DELIMITER |
"delimited-format.delimiter" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
ENUMERATE_NESTED_FILES_FLAG |
"recursive.file.enumeration" |
protected static final long |
READ_WHOLE_SPLIT_FLAG |
-1L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FILE_PARAMETER_KEY |
"flink.output.file" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
HADOOP_COPYING |
"_COPYING_" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final float |
AVG_RECORD_BYTES_UNKNOWN |
-1.0f |
public static final long |
NUM_RECORDS_UNKNOWN |
-1L |
public static final long |
SIZE_UNKNOWN |
-1L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
SELECT_ALL_CHAR |
"*" |
public static final String |
SELECT_ALL_CHAR_SCALA |
"_" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
SIZE_MISMATCH_MESSAGE |
"The number of specified keys is different." |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
GPU_NAME |
"GPU" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
TERMINATION_CRITERION_AGGREGATOR_NAME |
"terminationCriterion.aggregator" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
DEFAULT_FIELD_DELIMITER |
"," |
public static final String |
DEFAULT_LINE_DELIMITER |
"\n" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
DEFAULT_LINE_DELIMITER |
"\n" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final double |
EPSILON |
1.0E-5 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MAX_ARITY |
25 |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final String |
DEFAULT_UNDEFINED |
"<undefined>" |
protected static final String |
NO_VALUE_KEY |
"__NO_VALUE_KEY" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
DEFAULT_LINE_DELIMITER |
"\n" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
serialVersionUID |
1L |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final String |
ENDING_STATE_NAME |
"$endState$" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MAX_SLOTS_UNKNOWN |
-1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
MANIFEST_ATTRIBUTE_ASSEMBLER_CLASS |
"program-class" |
public static final String |
MANIFEST_ATTRIBUTE_MAIN_CLASS |
"Main-Class" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
AKKA_ASK_TIMEOUT |
"akka.ask.timeout" |
public static final String |
AKKA_CLIENT_TIMEOUT |
"akka.client.timeout" |
public static final String |
AKKA_DISPATCHER_THROUGHPUT |
"akka.throughput" |
public static final String |
AKKA_FRAMESIZE |
"akka.framesize" |
public static final String |
AKKA_JVM_EXIT_ON_FATAL_ERROR |
"akka.jvm-exit-on-fatal-error" |
public static final String |
AKKA_LOG_LIFECYCLE_EVENTS |
"akka.log.lifecycle.events" |
public static final String |
AKKA_LOOKUP_TIMEOUT |
"akka.lookup.timeout" |
public static final String |
AKKA_SSL_ENABLED |
"akka.ssl.enabled" |
public static final String |
AKKA_STARTUP_TIMEOUT |
"akka.startup-timeout" |
public static final String |
AKKA_TCP_TIMEOUT |
"akka.tcp.timeout" |
public static final String |
AKKA_TRANSPORT_HEARTBEAT_INTERVAL |
"akka.transport.heartbeat.interval" |
public static final String |
AKKA_TRANSPORT_HEARTBEAT_PAUSE |
"akka.transport.heartbeat.pause" |
public static final String |
AKKA_TRANSPORT_THRESHOLD |
"akka.transport.threshold" |
public static final String |
AKKA_WATCH_HEARTBEAT_INTERVAL |
"akka.watch.heartbeat.interval" |
public static final String |
AKKA_WATCH_HEARTBEAT_PAUSE |
"akka.watch.heartbeat.pause" |
public static final String |
AKKA_WATCH_THRESHOLD |
"akka.watch.threshold" |
public static final String |
BLOB_FETCH_BACKLOG_KEY |
"blob.fetch.backlog" |
public static final String |
BLOB_FETCH_CONCURRENT_KEY |
"blob.fetch.num-concurrent" |
public static final String |
BLOB_FETCH_RETRIES_KEY |
"blob.fetch.retries" |
public static final String |
BLOB_SERVER_PORT |
"blob.server.port" |
public static final String |
BLOB_SERVICE_SSL_ENABLED |
"blob.service.ssl.enabled" |
public static final String |
BLOB_STORAGE_DIRECTORY_KEY |
"blob.storage.directory" |
public static final String |
CHECKPOINTS_DIRECTORY_KEY |
"state.checkpoints.dir" |
public static final String |
CONTAINERIZED_HEAP_CUTOFF_MIN |
"containerized.heap-cutoff-min" |
public static final String |
CONTAINERIZED_HEAP_CUTOFF_RATIO |
"containerized.heap-cutoff-ratio" |
public static final String |
CONTAINERIZED_MASTER_ENV_PREFIX |
"containerized.master.env." |
public static final String |
CONTAINERIZED_TASK_MANAGER_ENV_PREFIX |
"containerized.taskmanager.env." |
public static final String |
DEFAULT_AKKA_ASK_TIMEOUT |
"10 s" |
public static final String |
DEFAULT_AKKA_CLIENT_TIMEOUT |
"60 s" |
public static final int |
DEFAULT_AKKA_DISPATCHER_THROUGHPUT |
15 |
public static final String |
DEFAULT_AKKA_FRAMESIZE |
"10485760b" |
public static final boolean |
DEFAULT_AKKA_LOG_LIFECYCLE_EVENTS |
false |
public static final String |
DEFAULT_AKKA_LOOKUP_TIMEOUT |
"10 s" |
public static final boolean |
DEFAULT_AKKA_SSL_ENABLED |
true |
public static final String |
DEFAULT_AKKA_TRANSPORT_HEARTBEAT_INTERVAL |
"1000 s" |
public static final String |
DEFAULT_AKKA_TRANSPORT_HEARTBEAT_PAUSE |
"6000 s" |
public static final double |
DEFAULT_AKKA_TRANSPORT_THRESHOLD |
300.0 |
public static final double |
DEFAULT_AKKA_WATCH_THRESHOLD |
12.0 |
public static final int |
DEFAULT_BLOB_FETCH_BACKLOG |
1000 |
public static final int |
DEFAULT_BLOB_FETCH_CONCURRENT |
50 |
public static final int |
DEFAULT_BLOB_FETCH_RETRIES |
5 |
public static final String |
DEFAULT_BLOB_SERVER_PORT |
"0" |
public static final boolean |
DEFAULT_BLOB_SERVICE_SSL_ENABLED |
true |
public static final int |
DEFAULT_DELIMITED_FORMAT_MAX_LINE_SAMPLES |
10 |
public static final int |
DEFAULT_DELIMITED_FORMAT_MAX_SAMPLE_LEN |
2097152 |
public static final int |
DEFAULT_DELIMITED_FORMAT_MIN_LINE_SAMPLES |
2 |
public static final int |
DEFAULT_EXECUTION_RETRIES |
0 |
public static final boolean |
DEFAULT_FILESYSTEM_ALWAYS_CREATE_DIRECTORY |
false |
public static final boolean |
DEFAULT_FILESYSTEM_OVERWRITE |
false |
public static final String |
DEFAULT_FILESYSTEM_SCHEME |
"file:///" |
public static final int |
DEFAULT_FS_STREAM_OPENING_TIMEOUT |
0 |
public static final String |
DEFAULT_HA_JOB_MANAGER_PORT |
"0" |
public static final String |
DEFAULT_HA_MODE |
"none" |
public static final String |
DEFAULT_HA_ZOOKEEPER_CLIENT_ACL |
"open" |
public static final int |
DEFAULT_JOB_MANAGER_IPC_PORT |
6123 |
public static final int |
DEFAULT_JOB_MANAGER_WEB_ARCHIVE_COUNT |
5 |
public static final int |
DEFAULT_JOB_MANAGER_WEB_BACK_PRESSURE_CLEAN_UP_INTERVAL |
600000 |
public static final int |
DEFAULT_JOB_MANAGER_WEB_BACK_PRESSURE_DELAY |
50 |
public static final int |
DEFAULT_JOB_MANAGER_WEB_BACK_PRESSURE_NUM_SAMPLES |
100 |
public static final int |
DEFAULT_JOB_MANAGER_WEB_BACK_PRESSURE_REFRESH_INTERVAL |
60000 |
public static final boolean |
DEFAULT_JOB_MANAGER_WEB_CHECKPOINTS_DISABLE |
false |
public static final int |
DEFAULT_JOB_MANAGER_WEB_CHECKPOINTS_HISTORY_SIZE |
10 |
public static final int |
DEFAULT_JOB_MANAGER_WEB_FRONTEND_PORT |
8081 |
public static final boolean |
DEFAULT_JOB_MANAGER_WEB_SSL_ENABLED |
true |
public static final boolean |
DEFAULT_JOB_MANAGER_WEB_SUBMIT_ENABLED |
true |
public static final int |
DEFAULT_LOCAL_NUMBER_JOB_MANAGER |
1 |
public static final int |
DEFAULT_LOCAL_NUMBER_RESOURCE_MANAGER |
1 |
public static final int |
DEFAULT_LOCAL_NUMBER_TASK_MANAGER |
1 |
public static final float |
DEFAULT_MEMORY_MANAGER_MEMORY_FRACTION |
0.699999988079071f |
public static final int |
DEFAULT_MESOS_ARTIFACT_SERVER_PORT |
0 |
public static final boolean |
DEFAULT_MESOS_ARTIFACT_SERVER_SSL_ENABLED |
true |
public static final int |
DEFAULT_MESOS_FAILOVER_TIMEOUT_SECS |
600 |
public static final String |
DEFAULT_MESOS_RESOURCEMANAGER_FRAMEWORK_NAME |
"Flink" |
public static final String |
DEFAULT_MESOS_RESOURCEMANAGER_FRAMEWORK_ROLE |
"*" |
public static final String |
DEFAULT_MESOS_RESOURCEMANAGER_FRAMEWORK_USER |
"" |
public static final int |
DEFAULT_METRICS_LATENCY_HISTORY_SIZE |
128 |
public static final int |
DEFAULT_PARALLELISM |
1 |
public static final String |
DEFAULT_PARALLELISM_KEY |
"parallelism.default" |
public static final String |
DEFAULT_RECOVERY_JOB_MANAGER_PORT |
"0" |
public static final String |
DEFAULT_RECOVERY_MODE |
"standalone" |
public static final int |
DEFAULT_RESOURCE_MANAGER_IPC_PORT |
0 |
public static final boolean |
DEFAULT_RUNTIME_HASH_JOIN_BLOOM_FILTERS |
false |
public static final String |
DEFAULT_SECURITY_SSL_ALGORITHMS |
"TLS_RSA_WITH_AES_128_CBC_SHA" |
public static final boolean |
DEFAULT_SECURITY_SSL_ENABLED |
false |
public static final String |
DEFAULT_SECURITY_SSL_PROTOCOL |
"TLSv1.2" |
public static final boolean |
DEFAULT_SECURITY_SSL_VERIFY_HOSTNAME |
true |
public static final float |
DEFAULT_SORT_SPILLING_THRESHOLD |
0.800000011920929f |
public static final String |
DEFAULT_SORT_SPILLING_THRESHOLD_KEY |
"taskmanager.runtime.sort-spilling-threshold" |
public static final int |
DEFAULT_SPILLING_MAX_FAN |
128 |
public static final String |
DEFAULT_SPILLING_MAX_FAN_KEY |
"taskmanager.runtime.max-fan" |
public static final String |
DEFAULT_STATE_BACKEND |
"jobmanager" |
public static final long |
DEFAULT_TASK_CANCELLATION_INTERVAL_MILLIS |
30000L |
public static final int |
DEFAULT_TASK_MANAGER_DATA_PORT |
0 |
public static final boolean |
DEFAULT_TASK_MANAGER_DATA_SSL_ENABLED |
true |
public static final long |
DEFAULT_TASK_MANAGER_DEBUG_MEMORY_USAGE_LOG_INTERVAL_MS |
5000L |
public static final boolean |
DEFAULT_TASK_MANAGER_DEBUG_MEMORY_USAGE_START_LOG_THREAD |
false |
public static final String |
DEFAULT_TASK_MANAGER_INITIAL_REGISTRATION_PAUSE |
"500 ms" |
public static final int |
DEFAULT_TASK_MANAGER_IPC_PORT |
0 |
public static final String |
DEFAULT_TASK_MANAGER_MAX_REGISTRATION_DURATION |
"Inf" |
public static final String |
DEFAULT_TASK_MANAGER_MAX_REGISTRATION_PAUSE |
"30 s" |
public static final boolean |
DEFAULT_TASK_MANAGER_MEMORY_PRE_ALLOCATE |
false |
public static final int |
DEFAULT_TASK_MANAGER_MEMORY_SEGMENT_SIZE |
32768 |
public static final String |
DEFAULT_TASK_MANAGER_NETWORK_DEFAULT_IO_MODE |
"sync" |
public static final int |
DEFAULT_TASK_MANAGER_NETWORK_NUM_BUFFERS |
2048 |
public static final String |
DEFAULT_TASK_MANAGER_REFUSED_REGISTRATION_PAUSE |
"10 s" |
public static final boolean |
DEFAULT_USE_LARGE_RECORD_HANDLER |
false |
public static final String |
DEFAULT_YARN_APPLICATION_MASTER_PORT |
"deprecated" |
public static final String |
DEFAULT_YARN_CONTAINER_START_COMMAND_TEMPLATE |
"%java% %jvmmem% %jvmopts% %logging% %class% %args% %redirects%" |
public static final int |
DEFAULT_YARN_HEAP_CUTOFF |
600 |
public static final float |
DEFAULT_YARN_HEAP_CUTOFF_RATIO |
0.25f |
public static final String |
DEFAULT_YARN_JOB_MANAGER_PORT |
"0" |
public static final int |
DEFAULT_YARN_MIN_HEAP_CUTOFF |
-1 |
public static final String |
DEFAULT_ZOOKEEPER_CHECKPOINT_COUNTER_PATH |
"/checkpoint-counter" |
public static final String |
DEFAULT_ZOOKEEPER_CHECKPOINTS_PATH |
"/checkpoints" |
public static final int |
DEFAULT_ZOOKEEPER_CLIENT_PORT |
2181 |
public static final int |
DEFAULT_ZOOKEEPER_CONNECTION_TIMEOUT |
15000 |
public static final String |
DEFAULT_ZOOKEEPER_DIR_KEY |
"/flink" |
public static final int |
DEFAULT_ZOOKEEPER_INIT_LIMIT |
10 |
public static final String |
DEFAULT_ZOOKEEPER_JOBGRAPHS_PATH |
"/jobgraphs" |
public static final String |
DEFAULT_ZOOKEEPER_LATCH_PATH |
"/leaderlatch" |
public static final String |
DEFAULT_ZOOKEEPER_LEADER_PATH |
"/leader" |
public static final int |
DEFAULT_ZOOKEEPER_LEADER_PORT |
3888 |
public static final int |
DEFAULT_ZOOKEEPER_MAX_RETRY_ATTEMPTS |
3 |
public static final String |
DEFAULT_ZOOKEEPER_MESOS_WORKERS_PATH |
"/mesos-workers" |
public static final String |
DEFAULT_ZOOKEEPER_NAMESPACE_KEY |
"/default" |
public static final int |
DEFAULT_ZOOKEEPER_PEER_PORT |
2888 |
public static final int |
DEFAULT_ZOOKEEPER_RETRY_WAIT |
5000 |
public static final boolean |
DEFAULT_ZOOKEEPER_SASL_DISABLE |
true |
public static final int |
DEFAULT_ZOOKEEPER_SESSION_TIMEOUT |
60000 |
public static final int |
DEFAULT_ZOOKEEPER_SYNC_LIMIT |
5 |
public static final String |
DELIMITED_FORMAT_MAX_LINE_SAMPLES_KEY |
"compiler.delimited-informat.max-line-samples" |
public static final String |
DELIMITED_FORMAT_MAX_SAMPLE_LENGTH_KEY |
"compiler.delimited-informat.max-sample-len" |
public static final String |
DELIMITED_FORMAT_MIN_LINE_SAMPLES_KEY |
"compiler.delimited-informat.min-line-samples" |
public static final String |
ENV_FLINK_BIN_DIR |
"FLINK_BIN_DIR" |
public static final String |
ENV_FLINK_CONF_DIR |
"FLINK_CONF_DIR" |
public static final String |
ENV_FLINK_HOME_DIR |
"FLINK_HOME" |
public static final String |
ENV_FLINK_LIB_DIR |
"FLINK_LIB_DIR" |
public static final String |
EXECUTION_RETRIES_KEY |
"execution-retries.default" |
public static final String |
EXECUTION_RETRY_DELAY_KEY |
"execution-retries.delay" |
public static final String |
FILESYSTEM_DEFAULT_OVERWRITE_KEY |
"fs.overwrite-files" |
public static final String |
FILESYSTEM_OUTPUT_ALWAYS_CREATE_DIRECTORY_KEY |
"fs.output.always-create-directory" |
public static final String |
FILESYSTEM_SCHEME |
"fs.default-scheme" |
public static final String |
FLINK_BASE_DIR_PATH_KEY |
"flink.base.dir.path" |
public static final String |
FLINK_JVM_OPTIONS |
"env.java.opts" |
public static final String |
FS_STREAM_OPENING_TIMEOUT_KEY |
"taskmanager.runtime.fs_timeout" |
public static final String |
HA_JOB_DELAY |
"high-availability.job.delay" |
public static final String |
HA_JOB_MANAGER_PORT |
"high-availability.jobmanager.port" |
public static final String |
HA_MODE |
"high-availability" |
public static final String |
HA_ZOOKEEPER_CHECKPOINT_COUNTER_PATH |
"high-availability.zookeeper.path.checkpoint-counter" |
public static final String |
HA_ZOOKEEPER_CHECKPOINTS_PATH |
"high-availability.zookeeper.path.checkpoints" |
public static final String |
HA_ZOOKEEPER_CLIENT_ACL |
"high-availability.zookeeper.client.acl" |
public static final String |
HA_ZOOKEEPER_CONNECTION_TIMEOUT |
"high-availability.zookeeper.client.connection-timeout" |
public static final String |
HA_ZOOKEEPER_DIR_KEY |
"high-availability.zookeeper.path.root" |
public static final String |
HA_ZOOKEEPER_JOBGRAPHS_PATH |
"high-availability.zookeeper.path.jobgraphs" |
public static final String |
HA_ZOOKEEPER_LATCH_PATH |
"high-availability.zookeeper.path.latch" |
public static final String |
HA_ZOOKEEPER_LEADER_PATH |
"high-availability.zookeeper.path.leader" |
public static final String |
HA_ZOOKEEPER_MAX_RETRY_ATTEMPTS |
"high-availability.zookeeper.client.max-retry-attempts" |
public static final String |
HA_ZOOKEEPER_MESOS_WORKERS_PATH |
"high-availability.zookeeper.path.mesos-workers" |
public static final String |
HA_ZOOKEEPER_NAMESPACE_KEY |
"high-availability.zookeeper.path.namespace" |
public static final String |
HA_ZOOKEEPER_QUORUM_KEY |
"high-availability.zookeeper.quorum" |
public static final String |
HA_ZOOKEEPER_RETRY_WAIT |
"high-availability.zookeeper.client.retry-wait" |
public static final String |
HA_ZOOKEEPER_SESSION_TIMEOUT |
"high-availability.zookeeper.client.session-timeout" |
public static final String |
HA_ZOOKEEPER_STORAGE_PATH |
"high-availability.zookeeper.storageDir" |
public static final String |
HDFS_DEFAULT_CONFIG |
"fs.hdfs.hdfsdefault" |
public static final String |
HDFS_SITE_CONFIG |
"fs.hdfs.hdfssite" |
public static final String |
JOB_MANAGER_IPC_ADDRESS_KEY |
"jobmanager.rpc.address" |
public static final String |
JOB_MANAGER_IPC_PORT_KEY |
"jobmanager.rpc.port" |
public static final String |
JOB_MANAGER_WEB_ARCHIVE_COUNT |
"jobmanager.web.history" |
public static final String |
JOB_MANAGER_WEB_BACK_PRESSURE_CLEAN_UP_INTERVAL |
"jobmanager.web.backpressure.cleanup-interval" |
public static final String |
JOB_MANAGER_WEB_BACK_PRESSURE_DELAY |
"jobmanager.web.backpressure.delay-between-samples" |
public static final String |
JOB_MANAGER_WEB_BACK_PRESSURE_NUM_SAMPLES |
"jobmanager.web.backpressure.num-samples" |
public static final String |
JOB_MANAGER_WEB_BACK_PRESSURE_REFRESH_INTERVAL |
"jobmanager.web.backpressure.refresh-interval" |
public static final String |
JOB_MANAGER_WEB_CHECKPOINTS_DISABLE |
"jobmanager.web.checkpoints.disable" |
public static final String |
JOB_MANAGER_WEB_CHECKPOINTS_HISTORY_SIZE |
"jobmanager.web.checkpoints.history" |
public static final String |
JOB_MANAGER_WEB_LOG_PATH_KEY |
"jobmanager.web.log.path" |
public static final String |
JOB_MANAGER_WEB_PORT_KEY |
"jobmanager.web.port" |
public static final String |
JOB_MANAGER_WEB_SSL_ENABLED |
"jobmanager.web.ssl.enabled" |
public static final String |
JOB_MANAGER_WEB_SUBMIT_ENABLED_KEY |
"jobmanager.web.submit.enable" |
public static final String |
JOB_MANAGER_WEB_TMPDIR_KEY |
"jobmanager.web.tmpdir" |
public static final String |
JOB_MANAGER_WEB_UPLOAD_DIR_KEY |
"jobmanager.web.upload.dir" |
public static final String |
LIBRARY_CACHE_MANAGER_CLEANUP_INTERVAL |
"library-cache-manager.cleanup.interval" |
public static final String |
LOCAL_NUMBER_JOB_MANAGER |
"local.number-jobmanager" |
public static final String |
LOCAL_NUMBER_RESOURCE_MANAGER |
"local.number-resourcemanager" |
public static final String |
LOCAL_NUMBER_TASK_MANAGER |
"local.number-taskmanager" |
public static final String |
LOCAL_START_WEBSERVER |
"local.start-webserver" |
public static final String |
MESOS_ARTIFACT_SERVER_PORT_KEY |
"mesos.resourcemanager.artifactserver.port" |
public static final String |
MESOS_ARTIFACT_SERVER_SSL_ENABLED |
"mesos.resourcemanager.artifactserver.ssl.enabled" |
public static final String |
MESOS_FAILOVER_TIMEOUT_SECONDS |
"mesos.failover-timeout" |
public static final String |
MESOS_INITIAL_TASKS |
"mesos.initial-tasks" |
public static final String |
MESOS_MASTER_URL |
"mesos.master" |
public static final String |
MESOS_MAX_FAILED_TASKS |
"mesos.maximum-failed-tasks" |
public static final String |
MESOS_RESOURCEMANAGER_FRAMEWORK_NAME |
"mesos.resourcemanager.framework.name" |
public static final String |
MESOS_RESOURCEMANAGER_FRAMEWORK_PRINCIPAL |
"mesos.resourcemanager.framework.principal" |
public static final String |
MESOS_RESOURCEMANAGER_FRAMEWORK_ROLE |
"mesos.resourcemanager.framework.role" |
public static final String |
MESOS_RESOURCEMANAGER_FRAMEWORK_SECRET |
"mesos.resourcemanager.framework.secret" |
public static final String |
MESOS_RESOURCEMANAGER_FRAMEWORK_USER |
"mesos.resourcemanager.framework.user" |
public static final String |
METRICS_LATENCY_HISTORY_SIZE |
"metrics.latency.history-size" |
public static final String |
METRICS_REPORTER_CLASS_SUFFIX |
"class" |
public static final String |
METRICS_REPORTER_INTERVAL_SUFFIX |
"interval" |
public static final String |
METRICS_REPORTER_PREFIX |
"metrics.reporter." |
public static final String |
METRICS_REPORTER_SCOPE_DELIMITER |
"scope.delimiter" |
public static final String |
METRICS_REPORTERS_LIST |
"metrics.reporters" |
public static final String |
METRICS_SCOPE_DELIMITER |
"metrics.scope.delimiter" |
public static final String |
METRICS_SCOPE_NAMING_JM |
"metrics.scope.jm" |
public static final String |
METRICS_SCOPE_NAMING_JM_JOB |
"metrics.scope.jm.job" |
public static final String |
METRICS_SCOPE_NAMING_OPERATOR |
"metrics.scope.operator" |
public static final String |
METRICS_SCOPE_NAMING_TASK |
"metrics.scope.task" |
public static final String |
METRICS_SCOPE_NAMING_TM |
"metrics.scope.tm" |
public static final String |
METRICS_SCOPE_NAMING_TM_JOB |
"metrics.scope.tm.job" |
public static final String |
PATH_HADOOP_CONFIG |
"fs.hdfs.hadoopconf" |
public static final String |
RECOVERY_JOB_DELAY |
"recovery.job.delay" |
public static final String |
RECOVERY_JOB_MANAGER_PORT |
"recovery.jobmanager.port" |
public static final String |
RECOVERY_MODE |
"recovery.mode" |
public static final String |
RESOURCE_MANAGER_IPC_PORT_KEY |
"resourcemanager.rpc.port" |
public static final String |
RESTART_STRATEGY |
"restart-strategy" |
public static final String |
RESTART_STRATEGY_FAILURE_RATE_DELAY |
"restart-strategy.failure-rate.delay" |
public static final String |
RESTART_STRATEGY_FAILURE_RATE_FAILURE_RATE_INTERVAL |
"restart-strategy.failure-rate.failure-rate-interval" |
public static final String |
RESTART_STRATEGY_FAILURE_RATE_MAX_FAILURES_PER_INTERVAL |
"restart-strategy.failure-rate.max-failures-per-interval" |
public static final String |
RESTART_STRATEGY_FIXED_DELAY_ATTEMPTS |
"restart-strategy.fixed-delay.attempts" |
public static final String |
RUNTIME_HASH_JOIN_BLOOM_FILTERS_KEY |
"taskmanager.runtime.hashjoin-bloom-filters" |
public static final String |
SAVEPOINT_DIRECTORY_KEY |
"state.savepoints.dir" |
public static final String |
SAVEPOINT_FS_DIRECTORY_KEY |
"savepoints.state.backend.fs.dir" |
public static final String |
SECURITY_SSL_ALGORITHMS |
"security.ssl.algorithms" |
public static final String |
SECURITY_SSL_ENABLED |
"security.ssl.enabled" |
public static final String |
SECURITY_SSL_KEY_PASSWORD |
"security.ssl.key-password" |
public static final String |
SECURITY_SSL_KEYSTORE |
"security.ssl.keystore" |
public static final String |
SECURITY_SSL_KEYSTORE_PASSWORD |
"security.ssl.keystore-password" |
public static final String |
SECURITY_SSL_PROTOCOL |
"security.ssl.protocol" |
public static final String |
SECURITY_SSL_TRUSTSTORE |
"security.ssl.truststore" |
public static final String |
SECURITY_SSL_TRUSTSTORE_PASSWORD |
"security.ssl.truststore-password" |
public static final String |
SECURITY_SSL_VERIFY_HOSTNAME |
"security.ssl.verify-hostname" |
public static final String |
STATE_BACKEND |
"state.backend" |
public static final String |
TASK_CANCELLATION_INTERVAL_MILLIS |
"task.cancellation-interval" |
public static final String |
TASK_MANAGER_DATA_PORT_KEY |
"taskmanager.data.port" |
public static final String |
TASK_MANAGER_DATA_SSL_ENABLED |
"taskmanager.data.ssl.enabled" |
public static final String |
TASK_MANAGER_DEBUG_MEMORY_USAGE_LOG_INTERVAL_MS |
"taskmanager.debug.memory.logIntervalMs" |
public static final String |
TASK_MANAGER_DEBUG_MEMORY_USAGE_START_LOG_THREAD |
"taskmanager.debug.memory.startLogThread" |
public static final String |
TASK_MANAGER_HOSTNAME_KEY |
"taskmanager.hostname" |
public static final String |
TASK_MANAGER_INITIAL_REGISTRATION_PAUSE |
"taskmanager.initial-registration-pause" |
public static final String |
TASK_MANAGER_IPC_PORT_KEY |
"taskmanager.rpc.port" |
public static final String |
TASK_MANAGER_LOG_PATH_KEY |
"taskmanager.log.path" |
public static final String |
TASK_MANAGER_MAX_REGISTARTION_PAUSE |
"taskmanager.max-registration-pause" |
public static final String |
TASK_MANAGER_MAX_REGISTRATION_DURATION |
"taskmanager.maxRegistrationDuration" |
public static final String |
TASK_MANAGER_MEMORY_FRACTION_KEY |
"taskmanager.memory.fraction" |
public static final String |
TASK_MANAGER_MEMORY_OFF_HEAP_KEY |
"taskmanager.memory.off-heap" |
public static final String |
TASK_MANAGER_MEMORY_PRE_ALLOCATE_KEY |
"taskmanager.memory.preallocate" |
public static final String |
TASK_MANAGER_MEMORY_SEGMENT_SIZE_KEY |
"taskmanager.memory.segment-size" |
public static final String |
TASK_MANAGER_MEMORY_SIZE_KEY |
"taskmanager.memory.size" |
public static final String |
TASK_MANAGER_NETWORK_DEFAULT_IO_MODE |
"taskmanager.network.defaultIOMode" |
public static final String |
TASK_MANAGER_NETWORK_NUM_BUFFERS_KEY |
"taskmanager.network.numberOfBuffers" |
public static final String |
TASK_MANAGER_NUM_TASK_SLOTS |
"taskmanager.numberOfTaskSlots" |
public static final String |
TASK_MANAGER_REFUSED_REGISTRATION_PAUSE |
"taskmanager.refused-registration-pause" |
public static final String |
TASK_MANAGER_TMP_DIR_KEY |
"taskmanager.tmp.dirs" |
public static final String |
USE_LARGE_RECORD_HANDLER_KEY |
"taskmanager.runtime.large-record-handler" |
public static final String |
YARN_APPLICATION_ATTEMPTS |
"yarn.application-attempts" |
public static final String |
YARN_APPLICATION_MASTER_ENV_PREFIX |
"yarn.application-master.env." |
public static final String |
YARN_APPLICATION_MASTER_PORT |
"yarn.application-master.port" |
public static final String |
YARN_APPLICATION_TAGS |
"yarn.tags" |
public static final String |
YARN_CONTAINER_START_COMMAND_TEMPLATE |
"yarn.container-start-command-template" |
public static final String |
YARN_HEAP_CUTOFF_MIN |
"yarn.heap-cutoff-min" |
public static final String |
YARN_HEAP_CUTOFF_RATIO |
"yarn.heap-cutoff-ratio" |
public static final String |
YARN_HEARTBEAT_DELAY_SECONDS |
"yarn.heartbeat-delay" |
public static final String |
YARN_MAX_FAILED_CONTAINERS |
"yarn.maximum-failed-containers" |
public static final String |
YARN_PROPERTIES_FILE_LOCATION |
"yarn.properties-file.location" |
public static final String |
YARN_REALLOCATE_FAILED_CONTAINERS |
"yarn.reallocate-failed" |
public static final String |
YARN_TASK_MANAGER_ENV_PREFIX |
"yarn.taskmanager.env." |
public static final String |
YARN_VCORES |
"yarn.containers.vcores" |
public static final String |
ZOOKEEPER_CHECKPOINT_COUNTER_PATH |
"recovery.zookeeper.path.checkpoint-counter" |
public static final String |
ZOOKEEPER_CHECKPOINTS_PATH |
"recovery.zookeeper.path.checkpoints" |
public static final String |
ZOOKEEPER_CONNECTION_TIMEOUT |
"recovery.zookeeper.client.connection-timeout" |
public static final String |
ZOOKEEPER_DIR_KEY |
"recovery.zookeeper.path.root" |
public static final String |
ZOOKEEPER_JOBGRAPHS_PATH |
"recovery.zookeeper.path.jobgraphs" |
public static final String |
ZOOKEEPER_LATCH_PATH |
"recovery.zookeeper.path.latch" |
public static final String |
ZOOKEEPER_LEADER_PATH |
"recovery.zookeeper.path.leader" |
public static final String |
ZOOKEEPER_MAX_RETRY_ATTEMPTS |
"recovery.zookeeper.client.max-retry-attempts" |
public static final String |
ZOOKEEPER_MESOS_WORKERS_PATH |
"recovery.zookeeper.path.mesos-workers" |
public static final String |
ZOOKEEPER_NAMESPACE_KEY |
"recovery.zookeeper.path.namespace" |
public static final String |
ZOOKEEPER_QUORUM_KEY |
"recovery.zookeeper.quorum" |
public static final String |
ZOOKEEPER_RECOVERY_PATH |
"recovery.zookeeper.storageDir" |
public static final String |
ZOOKEEPER_RETRY_WAIT |
"recovery.zookeeper.client.retry-wait" |
public static final String |
ZOOKEEPER_SASL_DISABLE |
"zookeeper.sasl.disable" |
public static final String |
ZOOKEEPER_SASL_SERVICE_NAME |
"zookeeper.sasl.service-name" |
public static final String |
ZOOKEEPER_SESSION_TIMEOUT |
"recovery.zookeeper.client.session-timeout" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
LEGACY_MODE |
"legacy" |
public static final String |
NEW_MODE |
"new" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FLINK_CONF_FILENAME |
"flink-conf.yaml" |
public static final String |
HIDDEN_CONTENT |
"******" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
CONTAINERIZED_MASTER_ENV_PREFIX |
"containerized.master.env." |
public static final String |
CONTAINERIZED_TASK_MANAGER_ENV_PREFIX |
"containerized.taskmanager.env." |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
MERGE_OPERATOR_NAME |
"stringappendtest" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
CUR_DIR |
"." |
public static final String |
SEPARATOR |
"/" |
public static final char |
SEPARATOR_CHAR |
47 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
ARG_CONVERSION_DURATION |
"durationConversion" |
public static final String |
ARG_CONVERSION_RATE |
"rateConversion" |
public static final String |
ARG_HOST |
"host" |
public static final String |
ARG_PORT |
"port" |
public static final String |
ARG_PREFIX |
"prefix" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
BYTES_COPIED_CNT_NAME |
"BYTES_COPIED" |
public static final String |
FILES_COPIED_CNT_NAME |
"FILES_COPIED" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
V1 |
0 |
public static final int |
V2 |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
D1 |
2 |
public static final int |
D2 |
3 |
public static final int |
V1 |
0 |
public static final int |
V2 |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
V1 |
0 |
public static final int |
V2 |
1 |
public static final int |
V3 |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
MAX_VERTEX_COUNT |
4294967296L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
MAX_VERTEX_COUNT |
4294967296L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
COMMUNITIES_SINGLE_ITERATION |
"1,5\n2,6\n3,1\n4,1\n5,1\n6,8\n7,8\n8,7" |
public static final String |
COMMUNITIES_WITH_TIE |
"1,2\n2,1\n3,1\n4,1\n5,1" |
public static final double |
DELTA |
0.5 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
EDGES |
"1\t2\n2\t3\n2\t4\n3\t4" |
public static final String |
VERTICES_WITH_MIN_ID |
"1,1\n2,1\n3,1\n4,1" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
EDGES |
"1,2\n1,4\n2,3\n2,4\n2,5\n3,5\n4,5\n4,6\n5,7\n5,9\n6,7\n6,8\n7,8\n7,9\n8,9" |
public static final int |
NUM_VERTICES |
9 |
public static final String |
RESULTED_WEIGHTED_EDGES |
"1,2,1.4142135623730951\n1,4,4.242640687119285\n2,3,1.4142135623730951\n2,4,2.8284271247461903\n2,5,4.242640687119285\n3,5,2.8284271247461903\n4,5,1.4142135623730951\n4,6,2.8284271247461903\n5,7,2.8284271247461903\n5,9,5.656854249492381\n6,7,1.4142135623730951\n6,8,2.8284271247461903\n7,8,1.4142135623730951\n7,9,2.8284271247461903\n8,9,1.4142135623730951" |
public static final String |
VERTICES |
"1,1.0,1.0\n2,2.0,2.0\n3,3.0,3.0\n4,4.0,4.0\n5,5.0,5.0\n6,6.0,6.0\n7,7.0,7.0\n8,8.0,8.0\n9,9.0,9.0" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
EDGES |
"1,3,3.0\n2,4,3.0\n2,5,2.0\n3,2,1.0\n3,5,5.0\n4,5,1.0" |
public static final String |
EDGES_IN_SSSP |
"1,3,3.0\n2,5,2.0\n3,2,1.0\n4,5,1.0" |
public static final int |
NUM_VERTICES |
5 |
public static final String |
RESULTED_VERTICES |
"1,1.7976931348623157E308\n2,1.7976931348623157E308\n3,1.7976931348623157E308\n4,1.0\n5,0.0" |
public static final String |
SRC_EDGE_TO_BE_REMOVED |
"2" |
public static final String |
TRG_EDGE_TO_BE_REMOVED |
"5" |
public static final String |
VAL_EDGE_TO_BE_REMOVED |
"2.0" |
public static final String |
VERTICES |
"1,6.0\n2,2.0\n3,3.0\n4,1.0\n5,0.0" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
LABELS_AFTER_1_ITERATION |
"1,10\n2,10\n3,10\n4,40\n5,40\n6,40\n7,40\n" |
public static final String |
LABELS_WITH_TIE |
"1,10\n2,10\n3,10\n4,10\n5,20\n6,20\n7,20\n8,20\n9,20\n" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
COMMUNITIES_RESULT |
"user_1\t1\nuser_2\t1\nuser_3\t3\nuser_4\t3\nuser_5\t4" |
public static final String |
MAX_ITERATIONS |
"2" |
public static final String |
MISMATCHES |
"ERROR: <song_5 track_8> Angie" |
public static final String |
TOP_SONGS_RESULT |
"user_1\tsong_1\nuser_2\tsong_4\nuser_3\tsong_2\nuser_4\tsong_3\nuser_5\tsong_3" |
public static final String |
USER_SONG_TRIPLETS |
"user_1\tsong_1\t100\nuser_1\tsong_5\t200\nuser_2\tsong_1\t10\nuser_2\tsong_4\t20\nuser_3\tsong_2\t3\nuser_4\tsong_2\t1\nuser_4\tsong_3\t2\nuser_5\tsong_3\t30" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
EDGES |
"2\t1\n5\t2\n5\t4\n4\t3\n4\t2\n1\t4\n1\t2\n1\t3\n3\t5\n" |
public static final String |
RANKS_AFTER_3_ITERATIONS |
"1,0.237\n2,0.248\n3,0.173\n4,0.175\n5,0.165\n" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
EDGES |
"1\t2\t12.0\n1\t3\t13.0\n2\t3\t23.0\n3\t4\t34.0\n3\t5\t35.0\n4\t5\t45.0\n5\t1\t51.0" |
public static final String |
RESULTED_SINGLE_SOURCE_SHORTEST_PATHS |
"1,0.0\n2,12.0\n3,13.0\n4,47.0\n5,48.0" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
EDGES |
"1\t2\n1\t3\n2\t3\n2\t6\n3\t4\n3\t5\n3\t6\n4\t5\n6\t7\n" |
public static final String |
RESULTED_NUMBER_OF_TRIANGLES |
"3" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MINIMUM_OFFSET |
1 |
public static final int |
MINIMUM_VERTEX_COUNT |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MINIMUM_VERTEX_COUNT |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MINIMUM_VERTEX_COUNT |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MINIMUM_VERTEX_COUNT |
2 |
public static final int |
MINIMUM_VERTEX_DEGREE |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MINIMUM_VERTEX_COUNT |
0 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MINIMUM_DIMENSIONS |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MINIMUM_VERTEX_COUNT |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final float |
DEFAULT_A |
0.5699999928474426f |
public static final float |
DEFAULT_B |
0.1899999976158142f |
public static final float |
DEFAULT_C |
0.1899999976158142f |
public static final float |
DEFAULT_NOISE |
0.10000000149011612f |
public static final int |
MINIMUM_EDGE_COUNT |
1 |
public static final int |
MINIMUM_VERTEX_COUNT |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MINIMUM_VERTEX_PAIR_COUNT |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MINIMUM_VERTEX_COUNT |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MAXIMUM_BLOCK_COUNT |
32768 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
DEFAULT_SEED |
5435701917232523172L |
public static final int |
MINIMUM_CYCLES_PER_BLOCK |
1048576 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
DEFAULT_SEED |
8415200798306848441L |
public static final int |
MINIMUM_CYCLES_PER_BLOCK |
1048576 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
D1 |
2 |
public static final int |
D2 |
3 |
public static final int |
V1 |
0 |
public static final int |
V2 |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
V1 |
0 |
public static final int |
V2 |
1 |
public static final int |
V3 |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
HASH_SEED |
933365956 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
HASH_SEED |
138865185 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
HASH_SEED |
-1036437567 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
HASH_SEED |
-744500821 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
HASH_SEED |
1074835241 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
HASH_SEED |
1074835241 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
HASH_SEED |
-469371183 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DEFAULT_GROUP_SIZE |
64 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
HASH_SEED |
1931441127 |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final int |
DEFAULT_CAPACITY_IN_BYTES |
1024 |
protected static final int |
ELEMENT_LENGTH_IN_BYTES |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final int |
DEFAULT_CAPACITY_IN_BYTES |
1024 |
protected static final int |
ELEMENT_LENGTH_IN_BYTES |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final int |
DEFAULT_CAPACITY_IN_BYTES |
1024 |
protected static final int |
ELEMENT_LENGTH_IN_BYTES |
8 |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final int |
DEFAULT_CAPACITY_IN_BYTES |
1024 |
protected static final int |
ELEMENT_LENGTH_IN_BYTES |
4 |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final int |
DEFAULT_CAPACITY_IN_BYTES |
4096 |
protected static final int |
ELEMENT_LENGTH_IN_BYTES |
4 |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final int |
DEFAULT_CAPACITY_IN_BYTES |
4096 |
protected static final int |
ELEMENT_LENGTH_IN_BYTES |
8 |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final int |
DEFAULT_CAPACITY_IN_BYTES |
1024 |
protected static final int |
ELEMENT_LENGTH_IN_BYTES |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final int |
DEFAULT_CAPACITY_IN_BYTES |
4096 |
protected static final int |
HIGH_BIT |
128 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
UNRESERVED_ROLE |
"*" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
JOB_GRAPH_FILE_PATH |
"flink.jobgraph.path" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
ENV_FLINK_CONTAINER_ID |
"_FLINK_CONTAINER_ID" |
public static final String |
ENV_FLINK_TMP_DIR |
"_FLINK_TMP_DIR" |
public static final String |
ENV_FRAMEWORK_NAME |
"FRAMEWORK_NAME" |
public static final String |
ENV_JVM_ARGS |
"JVM_ARGS" |
public static final String |
ENV_TASK_NAME |
"TASK_NAME" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
MESOS_RESOURCEMANAGER_TASKS_CONTAINER_TYPE_DOCKER |
"docker" |
public static final String |
MESOS_RESOURCEMANAGER_TASKS_CONTAINER_TYPE_MESOS |
"mesos" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
UPDATE_INTERVAL_SECONDS |
5 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
API_KEY |
"apikey" |
public static final String |
TAGS |
"tags" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
ARG_PROTOCOL |
"protocol" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
ARG_PORT |
"port" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
ARG_HOST |
"host" |
public static final String |
ARG_PORT |
"port" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
HINT_LOCAL_STRATEGY |
"LOCAL_STRATEGY" |
public static final String |
HINT_LOCAL_STRATEGY_COMBINING_SORT |
"LOCAL_STRATEGY_COMBINING_SORT" |
public static final String |
HINT_LOCAL_STRATEGY_HASH_BUILD_FIRST |
"LOCAL_STRATEGY_HASH_BUILD_FIRST" |
public static final String |
HINT_LOCAL_STRATEGY_HASH_BUILD_SECOND |
"LOCAL_STRATEGY_HASH_BUILD_SECOND" |
public static final String |
HINT_LOCAL_STRATEGY_MERGE |
"LOCAL_STRATEGY_MERGE" |
public static final String |
HINT_LOCAL_STRATEGY_NESTEDLOOP_BLOCKED_OUTER_FIRST |
"LOCAL_STRATEGY_NESTEDLOOP_BLOCKED_OUTER_FIRST" |
public static final String |
HINT_LOCAL_STRATEGY_NESTEDLOOP_BLOCKED_OUTER_SECOND |
"LOCAL_STRATEGY_NESTEDLOOP_BLOCKED_OUTER_SECOND" |
public static final String |
HINT_LOCAL_STRATEGY_NESTEDLOOP_STREAMED_OUTER_FIRST |
"LOCAL_STRATEGY_NESTEDLOOP_STREAMED_OUTER_FIRST" |
public static final String |
HINT_LOCAL_STRATEGY_NESTEDLOOP_STREAMED_OUTER_SECOND |
"LOCAL_STRATEGY_NESTEDLOOP_STREAMED_OUTER_SECOND" |
public static final String |
HINT_LOCAL_STRATEGY_SORT |
"LOCAL_STRATEGY_SORT" |
public static final String |
HINT_LOCAL_STRATEGY_SORT_BOTH_MERGE |
"LOCAL_STRATEGY_SORT_BOTH_MERGE" |
public static final String |
HINT_LOCAL_STRATEGY_SORT_FIRST_MERGE |
"LOCAL_STRATEGY_SORT_FIRST_MERGE" |
public static final String |
HINT_LOCAL_STRATEGY_SORT_SECOND_MERGE |
"LOCAL_STRATEGY_SORT_SECOND_MERGE" |
public static final String |
HINT_SHIP_STRATEGY |
"INPUT_SHIP_STRATEGY" |
public static final String |
HINT_SHIP_STRATEGY_BROADCAST |
"SHIP_BROADCAST" |
public static final String |
HINT_SHIP_STRATEGY_FIRST_INPUT |
"INPUT_LEFT_SHIP_STRATEGY" |
public static final String |
HINT_SHIP_STRATEGY_FORWARD |
"SHIP_FORWARD" |
public static final String |
HINT_SHIP_STRATEGY_REPARTITION |
"SHIP_REPARTITION" |
public static final String |
HINT_SHIP_STRATEGY_REPARTITION_HASH |
"SHIP_REPARTITION_HASH" |
public static final String |
HINT_SHIP_STRATEGY_REPARTITION_RANGE |
"SHIP_REPARTITION_RANGE" |
public static final String |
HINT_SHIP_STRATEGY_SECOND_INPUT |
"INPUT_RIGHT_SHIP_STRATEGY" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final double |
UNKNOWN |
-1.0 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MAX_DYNAMIC_PATH_COST_WEIGHT |
100 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
MERGE_ITERATION_AUX_TASKS_KEY |
"compiler.merge-iteration-aux" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FLINK_PYTHON_DC_ID |
"flink" |
public static final String |
PLAN_ARGUMENTS_KEY |
"python.plan.arguments" |
public static final String |
PLANBINDER_CONFIG_BCVAR_COUNT |
"PLANBINDER_BCVAR_COUNT" |
public static final String |
PLANBINDER_CONFIG_BCVAR_NAME_PREFIX |
"PLANBINDER_BCVAR_" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final byte |
TYPE_ARRAY |
63 |
public static final byte |
TYPE_KEY_VALUE |
62 |
public static final byte |
TYPE_VALUE_VALUE |
61 |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final int |
SIGNAL_BUFFER_REQUEST |
0 |
protected static final int |
SIGNAL_BUFFER_REQUEST_G0 |
-3 |
protected static final int |
SIGNAL_BUFFER_REQUEST_G1 |
-4 |
protected static final int |
SIGNAL_ERROR |
-2 |
protected static final int |
SIGNAL_FINISHED |
-1 |
protected static final byte |
SIGNAL_LAST |
32 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final byte |
TYPE_BOOLEAN |
34 |
public static final byte |
TYPE_BYTE |
33 |
public static final byte |
TYPE_BYTES |
27 |
public static final byte |
TYPE_DOUBLE |
30 |
public static final byte |
TYPE_FLOAT |
29 |
public static final byte |
TYPE_INTEGER |
32 |
public static final byte |
TYPE_LONG |
31 |
public static final byte |
TYPE_NULL |
26 |
public static final byte |
TYPE_STRING |
28 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
SIZE |
20 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
HEADER_MAGIC_NUMBER |
1231054637 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
VERSION |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
VERSION |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final int |
EXIT_CODE_FATAL_ERROR |
-13 |
public static final String |
RESOURCE_MANAGER_NAME |
"resourcemanager" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
DISPATCHER_NAME |
"dispatcher" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final int |
RUNTIME_FAILURE_RETURN_CODE |
2 |
protected static final int |
STARTUP_FAILURE_RETURN_CODE |
1 |
protected static final int |
SUCCESS_RETURN_CODE |
0 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
PARALLELISM_AUTO_MAX_ERROR_MESSAGE |
"PARALLELISM_AUTO_MAX is no longer supported. Please specify a concrete value for the parallelism." |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
VALUE_NOT_SET |
-1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FULL_RESTART_STRATEGY_NAME |
"full" |
public static final String |
INDIVIDUAL_RESTART_STRATEGY_NAME |
"individual" |
public static final String |
PIPELINED_REGION_RESTART_STRATEGY_NAME |
"region" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
METRIC_NAME |
"downtime" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
METRIC_NAME |
"fullRestarts" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
METRIC_NAME |
"restartingTime" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
METRIC_NAME |
"uptime" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MIN_SKIP_BYTES |
1048576 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_CPU_CORES |
"cpuCores" |
public static final String |
FIELD_NAME_SIZE_JVM_HEAP |
"freeMemory" |
public static final String |
FIELD_NAME_SIZE_MANAGED_MEMORY |
"managedMemory" |
public static final String |
FIELD_NAME_SIZE_PHYSICAL_MEMORY |
"physicalMemory" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final short |
FLAG_LAST_BLOCK |
1 |
protected static final int |
HEAD_BLOCK_LENGTH_OFFSET |
4 |
protected static final int |
HEADER_FLAGS_OFFSET |
2 |
protected static final int |
HEADER_LENGTH |
8 |
protected static final short |
HEADER_MAGIC_NUMBER |
-16130 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
AGGREGATOR_NAME |
"pact.runtime.workset-empty-aggregator" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
ARCHIVE_NAME |
"archive" |
public static final String |
JOB_MANAGER_NAME |
"jobmanager" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DEFAULT_PAGE_SIZE |
32768 |
public static final int |
MIN_PAGE_SIZE |
4096 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_SLOTS_AVAILABLE |
"slots-available" |
public static final String |
FIELD_NAME_SLOTS_TOTAL |
"slots-total" |
public static final String |
FIELD_NAME_TASKMANAGERS |
"taskmanagers" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_JOBS |
"jobs" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_JOB_ID |
"id" |
public static final String |
FIELD_NAME_JOB_STATUS |
"status" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_JOBS_CANCELLED |
"jobs-cancelled" |
public static final String |
FIELD_NAME_JOBS_FAILED |
"jobs-failed" |
public static final String |
FIELD_NAME_JOBS_FINISHED |
"jobs-finished" |
public static final String |
FIELD_NAME_JOBS_RUNNING |
"jobs-running" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_JOBS |
"jobs" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
IO_CURRENT_INPUT_1_WATERMARK |
"currentInput1Watermark" |
public static final String |
IO_CURRENT_INPUT_2_WATERMARK |
"currentInput2Watermark" |
public static final String |
IO_CURRENT_INPUT_WATERMARK |
"currentInputWatermark" |
public static final String |
IO_CURRENT_OUTPUT_WATERMARK |
"currentOutputWatermark" |
public static final String |
IO_NUM_BUFFERS_IN |
"numBuffersIn" |
public static final String |
IO_NUM_BUFFERS_IN_LOCAL |
"numBuffersInLocal" |
public static final String |
IO_NUM_BUFFERS_IN_LOCAL_RATE |
"numBuffersInLocalPerSecond" |
public static final String |
IO_NUM_BUFFERS_IN_REMOTE |
"numBuffersInRemote" |
public static final String |
IO_NUM_BUFFERS_IN_REMOTE_RATE |
"numBuffersInRemotePerSecond" |
public static final String |
IO_NUM_BUFFERS_OUT |
"numBuffersOut" |
public static final String |
IO_NUM_BUFFERS_OUT_RATE |
"numBuffersOutPerSecond" |
public static final String |
IO_NUM_BYTES_IN |
"numBytesIn" |
public static final String |
IO_NUM_BYTES_IN_LOCAL |
"numBytesInLocal" |
public static final String |
IO_NUM_BYTES_IN_LOCAL_RATE |
"numBytesInLocalPerSecond" |
public static final String |
IO_NUM_BYTES_IN_REMOTE |
"numBytesInRemote" |
public static final String |
IO_NUM_BYTES_IN_REMOTE_RATE |
"numBytesInRemotePerSecond" |
public static final String |
IO_NUM_BYTES_OUT |
"numBytesOut" |
public static final String |
IO_NUM_BYTES_OUT_RATE |
"numBytesOutPerSecond" |
public static final String |
IO_NUM_RECORDS_IN |
"numRecordsIn" |
public static final String |
IO_NUM_RECORDS_IN_RATE |
"numRecordsInPerSecond" |
public static final String |
IO_NUM_RECORDS_OUT |
"numRecordsOut" |
public static final String |
IO_NUM_RECORDS_OUT_RATE |
"numRecordsOutPerSecond" |
public static final String |
NUM_REGISTERED_TASK_MANAGERS |
"numRegisteredTaskManagers" |
public static final String |
NUM_RUNNING_JOBS |
"numRunningJobs" |
public static final String |
TASK_SLOTS_AVAILABLE |
"taskSlotsAvailable" |
public static final String |
TASK_SLOTS_TOTAL |
"taskSlotsTotal" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final byte |
METRIC_CATEGORY_COUNTER |
0 |
public static final byte |
METRIC_CATEGORY_GAUGE |
1 |
public static final byte |
METRIC_CATEGORY_HISTOGRAM |
2 |
public static final byte |
METRIC_CATEGORY_METER |
3 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
METRIC_QUERY_SERVICE_NAME |
"MetricQueryService" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final byte |
INFO_CATEGORY_JM |
0 |
public static final byte |
INFO_CATEGORY_JOB |
2 |
public static final byte |
INFO_CATEGORY_OPERATOR |
4 |
public static final byte |
INFO_CATEGORY_TASK |
3 |
public static final byte |
INFO_CATEGORY_TM |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
SCOPE_INHERIT_PARENT |
"*" |
public static final String |
SCOPE_SEPARATOR |
"." |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final int |
MAX_NUM_WRITE_BUFFERS |
4 |
protected static final int |
MIN_NUM_SORT_MEM_SEGMENTS |
10 |
protected static final int |
MIN_NUM_WRITE_BUFFERS |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
RESOURCE_MANAGER_NAME |
"resourcemanager" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
HTTP_ATTRIBUTE_REQUEST |
"request" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
DASHBOARD_CONFIG_REST_PATH |
"/config" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
SUBTASK_CURRENT_ATTEMPT_DETAILS_REST_PATH |
"/jobs/:jobid/vertices/:vertexid/subtasks/:subtasknum" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
PARAMETER_SUBTASK_INDEX |
"subtasknum" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
TASK_MANAGER_ID_KEY |
"taskmanagerid" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
HTTP_DATE_FORMAT |
"EEE, dd MMM yyyy HH:mm:ss zzz" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_COMMIT |
"flink-commit" |
public static final String |
FIELD_NAME_VERSION |
"flink-version" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
PARAMETER_METRICS |
"get" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
PARAMETER_JOB_ID |
"jobid" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
PARAMETER_VERTEX_ID |
"vertexid" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_CONFIG_KEY |
"key" |
public static final String |
FIELD_NAME_CONFIG_VALUE |
"value" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
CLUSTER_CONFIG_REST_PATH |
"/jobmanager/config" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
URL |
"/overview" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_FLINK_REVISION |
"flink-revision" |
public static final String |
FIELD_NAME_FLINK_VERSION |
"flink-version" |
public static final String |
FIELD_NAME_REFRESH_INTERVAL |
"refresh-interval" |
public static final String |
FIELD_NAME_TIMEZONE_NAME |
"timezone-name" |
public static final String |
FIELD_NAME_TIMEZONE_OFFSET |
"timezone-offset" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
URL |
"/jobs/:jobid/accumulators" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_JOB_ACCUMULATORS |
"job-accumulators" |
public static final String |
FIELD_NAME_SERIALIZED_USER_TASK_ACCUMULATORS |
"serialized-user-task-accumulators" |
public static final String |
FIELD_NAME_USER_TASK_ACCUMULATORS |
"user-task-accumulators" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_ACC_NAME |
"name" |
public static final String |
FIELD_NAME_ACC_TYPE |
"type" |
public static final String |
FIELD_NAME_ACC_VALUE |
"value" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
URL |
"/jobs/:jobid/config" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_EXECUTION_CONFIG |
"execution-config" |
public static final String |
FIELD_NAME_JOB_ID |
"jid" |
public static final String |
FIELD_NAME_JOB_NAME |
"name" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_EXECUTION_MODE |
"execution-mode" |
public static final String |
FIELD_NAME_GLOBAL_JOB_PARAMETERS |
"user-config" |
public static final String |
FIELD_NAME_OBJECT_REUSE_MODE |
"object-reuse-mode" |
public static final String |
FIELD_NAME_PARALLELISM |
"job-parallelism" |
public static final String |
FIELD_NAME_RESTART_STRATEGY |
"restart-strategy" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
URL |
"/jobs/:jobid/exceptions" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_ALL_EXCEPTIONS |
"all-exceptions" |
public static final String |
FIELD_NAME_ROOT_EXCEPTION |
"root-exception" |
public static final String |
FIELD_NAME_TIMESTAMP |
"timestamp" |
public static final String |
FIELD_NAME_TRUNCATED |
"truncated" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_EXCEPTION |
"exception" |
public static final String |
FIELD_NAME_LOCATION |
"location" |
public static final String |
FIELD_NAME_TASK |
"task" |
public static final String |
FIELD_NAME_TIMESTAMP |
"timestamp" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
KEY |
"jobid" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
CURRENT_JOB_IDS_REST_PATH |
"/jobs" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
URL |
"/jobs/:jobid/plan" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
URL |
"/jobs/overview" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
URL |
"/jobs/:jobid" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
URL |
"/jobs/:jobid/vertices/:vertexid/accumulators" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_ID |
"id" |
public static final String |
FIELD_NAME_USER_ACCUMULATORS |
"user-accumulators" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_BACKPRESSURE_LEVEL |
"backpressure-level" |
public static final String |
FIELD_NAME_END_TIMESTAMP |
"end-timestamp" |
public static final String |
FIELD_NAME_STATUS |
"status" |
public static final String |
FIELD_NAME_SUBTASKS |
"subtasks" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_BACKPRESSURE_LEVEL |
"backpressure-level" |
public static final String |
FIELD_NAME_RATIO |
"ratio" |
public static final String |
FIELD_NAME_SUBTASK |
"subtask" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
URL |
"/jobs/:jobid/vertices/:vertexid" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_NOW |
"now" |
public static final String |
FIELD_NAME_PARALLELISM |
"parallelism" |
public static final String |
FIELD_NAME_SUBTASKS |
"subtasks" |
public static final String |
FIELD_NAME_VERTEX_ID |
"id" |
public static final String |
FIELD_NAME_VERTEX_NAME |
"name" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_ATTEMPT |
"attempt" |
public static final String |
FIELD_NAME_DURATION |
"duration" |
public static final String |
FIELD_NAME_END_TIME |
"end-time" |
public static final String |
FIELD_NAME_HOST |
"host" |
public static final String |
FIELD_NAME_METRICS |
"metrics" |
public static final String |
FIELD_NAME_START_TIME |
"start_time" |
public static final String |
FIELD_NAME_STATUS |
"status" |
public static final String |
FIELD_NAME_SUBTASK |
"subtask" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
KEY |
"vertexid" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
URL |
"/jobs/:jobid/vertices/:vertexid/taskmanagers" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
VERTEX_TASK_FIELD_ID |
"id" |
public static final String |
VERTEX_TASK_FIELD_NAME |
"name" |
public static final String |
VERTEX_TASK_FIELD_NOW |
"now" |
public static final String |
VERTEX_TASK_FIELD_TASK_MANAGERS |
"taskmanagers" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
TASK_MANAGERS_FIELD_DURATION |
"duration" |
public static final String |
TASK_MANAGERS_FIELD_END_TIME |
"end-time" |
public static final String |
TASK_MANAGERS_FIELD_HOST |
"host" |
public static final String |
TASK_MANAGERS_FIELD_METRICS |
"metrics" |
public static final String |
TASK_MANAGERS_FIELD_START_TIME |
"start-time" |
public static final String |
TASK_MANAGERS_FIELD_STATUS |
"status" |
public static final String |
TASK_MANAGERS_FIELD_STATUS_COUNTS |
"status-counts" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
KEY |
"parallelism" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
KEY |
"subtaskindex" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
URL |
"/jobs/:jobid/vertices/:vertexid/subtasks/accumulators" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
URL |
"/jobs/:jobid/vertices/:vertexid/subtasktimes" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_ID |
"id" |
public static final String |
FIELD_NAME_NAME |
"name" |
public static final String |
FIELD_NAME_NOW |
"now" |
public static final String |
FIELD_NAME_SUBTASKS |
"subtasks" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_DURATION |
"duration" |
public static final String |
FIELD_NAME_HOST |
"host" |
public static final String |
FIELD_NAME_SUBTASK |
"subtask" |
public static final String |
FIELD_NAME_TIMESTAMPS |
"timestamps" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
KEY |
"triggerid" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
URL |
"/jobs/:jobid/checkpoints/config" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_CHECKPOINT_INTERVAL |
"interval" |
public static final String |
FIELD_NAME_CHECKPOINT_MAX_CONCURRENT |
"max_concurrent" |
public static final String |
FIELD_NAME_CHECKPOINT_MIN_PAUSE |
"min_pause" |
public static final String |
FIELD_NAME_CHECKPOINT_TIMEOUT |
"timeout" |
public static final String |
FIELD_NAME_EXTERNALIZED_CHECKPOINT_CONFIG |
"externalization" |
public static final String |
FIELD_NAME_PROCESSING_MODE |
"mode" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_DELETE_ON_CANCELLATION |
"delete_on_cancellation" |
public static final String |
FIELD_NAME_ENABLED |
"enabled" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
KEY |
"checkpointid" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_COUNTS |
"counts" |
public static final String |
FIELD_NAME_HISTORY |
"history" |
public static final String |
FIELD_NAME_LATEST_CHECKPOINTS |
"latest" |
public static final String |
FIELD_NAME_SUMMARY |
"summary" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_COMPLETED_CHECKPOINTS |
"completed" |
public static final String |
FIELD_NAME_FAILED_CHECKPOINTS |
"failed" |
public static final String |
FIELD_NAME_IN_PROGRESS_CHECKPOINTS |
"in_progress" |
public static final String |
FIELD_NAME_RESTORED_CHECKPOINTS |
"restored" |
public static final String |
FIELD_NAME_TOTAL_CHECKPOINTS |
"total" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_COMPLETED |
"completed" |
public static final String |
FIELD_NAME_FAILED |
"failed" |
public static final String |
FIELD_NAME_RESTORED |
"restored" |
public static final String |
FIELD_NAME_SAVEPOINT |
"savepoint" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_EXTERNAL_PATH |
"external_path" |
public static final String |
FIELD_NAME_ID |
"id" |
public static final String |
FIELD_NAME_IS_SAVEPOINT |
"is_savepoint" |
public static final String |
FIELD_NAME_RESTORE_TIMESTAMP |
"restore_timestamp" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_ALIGNMENT_BUFFERED |
"alignment_buffered" |
public static final String |
FIELD_NAME_DURATION |
"end_to_end_duration" |
public static final String |
FIELD_NAME_STATE_SIZE |
"state_size" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
URL |
"/jobs/:jobid/checkpoints" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
URL |
"/jobs/:jobid/checkpoints/details/:checkpointid" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_ALIGNMENT_BUFFERED |
"alignment_buffered" |
public static final String |
FIELD_NAME_DURATION |
"end_to_end_duration" |
public static final String |
FIELD_NAME_ID |
"id" |
public static final String |
FIELD_NAME_IS_SAVEPOINT |
"is_savepoint" |
public static final String |
FIELD_NAME_LATEST_ACK_TIMESTAMP |
"latest_ack_timestamp" |
public static final String |
FIELD_NAME_NUM_ACK_SUBTASKS |
"num_acknowledged_subtasks" |
public static final String |
FIELD_NAME_NUM_SUBTASKS |
"num_subtasks" |
public static final String |
FIELD_NAME_STATE_SIZE |
"state_size" |
public static final String |
FIELD_NAME_STATUS |
"status" |
public static final String |
FIELD_NAME_TASKS |
"tasks" |
public static final String |
FIELD_NAME_TRIGGER_TIMESTAMP |
"trigger_timestamp" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_DISCARDED |
"discarded" |
public static final String |
FIELD_NAME_EXTERNAL_PATH |
"external_path" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_FAILURE_MESSAGE |
"failure_message" |
public static final String |
FIELD_NAME_FAILURE_TIMESTAMP |
"failure_timestamp" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_AVERAGE |
"avg" |
public static final String |
FIELD_NAME_MAXIMUM |
"max" |
public static final String |
FIELD_NAME_MINIMUM |
"min" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_CHECKPOINT_STATUS |
"status" |
public static final String |
FIELD_NAME_INDEX |
"index" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_ACK_TIMESTAMP |
"ack_timestamp" |
public static final String |
FIELD_NAME_ALIGNMENT |
"alignment" |
public static final String |
FIELD_NAME_CHECKPOINT_DURATION |
"checkpoint" |
public static final String |
FIELD_NAME_DURATION |
"end_to_end_duration" |
public static final String |
FIELD_NAME_STATE_SIZE |
"state_size" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_ALIGNMENT_BUFFERED |
"buffered" |
public static final String |
FIELD_NAME_ALIGNMENT_DURATION |
"duration" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_ASYNC_DURATION |
"async" |
public static final String |
FIELD_NAME_SYNC_DURATION |
"sync" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_ALIGNMENT_BUFFERED |
"alignment_buffered" |
public static final String |
FIELD_NAME_CHECKPOINT_STATUS |
"status" |
public static final String |
FIELD_NAME_DURATION |
"end_to_end_duration" |
public static final String |
FIELD_NAME_ID |
"id" |
public static final String |
FIELD_NAME_LATEST_ACK_TIMESTAMP |
"latest_ack_timestamp" |
public static final String |
FIELD_NAME_NUM_ACK_SUBTASKS |
"num_acknowledged_subtasks" |
public static final String |
FIELD_NAME_NUM_SUBTASKS |
"num_subtasks" |
public static final String |
FIELD_NAME_STATE_SIZE |
"state_size" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
URL |
"/jobs/:jobid/checkpoints/details/:checkpointid/subtasks/:vertexid" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_SUBTASKS_CHECKPOINT_STATISTICS |
"subtasks" |
public static final String |
FIELD_NAME_SUMMARY |
"summary" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_BUFFERED_DATA |
"buffered" |
public static final String |
FIELD_NAME_DURATION |
"duration" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_ASYNCHRONOUS_DURATION |
"async" |
public static final String |
FIELD_NAME_SYNCHRONOUS_DURATION |
"sync" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_ALIGNMENT |
"alignment" |
public static final String |
FIELD_NAME_CHECKPOINT_DURATION |
"checkpoint_duration" |
public static final String |
FIELD_NAME_DURATION |
"end_to_end_duration" |
public static final String |
FIELD_NAME_STATE_SIZE |
"state_size" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
URL |
"/jobs/:jobid" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_DURATION |
"duration" |
public static final String |
FIELD_NAME_END_TIME |
"end-time" |
public static final String |
FIELD_NAME_IS_STOPPABLE |
"isStoppable" |
public static final String |
FIELD_NAME_JOB_ID |
"jid" |
public static final String |
FIELD_NAME_JOB_NAME |
"name" |
public static final String |
FIELD_NAME_JOB_STATUS |
"state" |
public static final String |
FIELD_NAME_JOB_VERTEX_INFOS |
"vertices" |
public static final String |
FIELD_NAME_JOB_VERTICES_PER_STATE |
"status-counts" |
public static final String |
FIELD_NAME_JSON_PLAN |
"plan" |
public static final String |
FIELD_NAME_NOW |
"now" |
public static final String |
FIELD_NAME_START_TIME |
"start-time" |
public static final String |
FIELD_NAME_TIMESTAMPS |
"timestamps" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_JOB_VERTEX_DURATION |
"duration" |
public static final String |
FIELD_NAME_JOB_VERTEX_END_TIME |
"end-time" |
public static final String |
FIELD_NAME_JOB_VERTEX_ID |
"id" |
public static final String |
FIELD_NAME_JOB_VERTEX_METRICS |
"metrics" |
public static final String |
FIELD_NAME_JOB_VERTEX_NAME |
"name" |
public static final String |
FIELD_NAME_JOB_VERTEX_START_TIME |
"start-time" |
public static final String |
FIELD_NAME_JOB_VERTEX_STATE |
"status" |
public static final String |
FIELD_NAME_PARALLELISM |
"parallelism" |
public static final String |
FIELD_NAME_TASKS_PER_STATE |
"tasks" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_JOB_GRAPH |
"jobGraphFileName" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_JOB_URL |
"jobUrl" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
KEY |
"attempt" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_ATTEMPT_NUM |
"attempt" |
public static final String |
FIELD_NAME_ID |
"id" |
public static final String |
FIELD_NAME_SUBTASK_INDEX |
"subtask" |
public static final String |
FIELD_NAME_USER_ACCUMULATORS |
"user-accumulators" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_ATTEMPT |
"attempt" |
public static final String |
FIELD_NAME_DURATION |
"duration" |
public static final String |
FIELD_NAME_END_TIME |
"end-time" |
public static final String |
FIELD_NAME_HOST |
"host" |
public static final String |
FIELD_NAME_METRICS |
"metrics" |
public static final String |
FIELD_NAME_START_TIME |
"start-time" |
public static final String |
FIELD_NAME_STATUS |
"status" |
public static final String |
FIELD_NAME_SUBTASK_INDEX |
"subtask" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_JOB_VERTEX_ID |
"id" |
public static final String |
FIELD_NAME_PARALLELISM |
"parallelism" |
public static final String |
FIELD_NAME_SUBTASKS |
"subtasks" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_ATTEMPT_NUM |
"attempt" |
public static final String |
FIELD_NAME_HOST |
"host" |
public static final String |
FIELD_NAME_SUBTASK_INDEX |
"subtask" |
public static final String |
FIELD_NAME_USER_ACCUMULATORS |
"user-accumulators" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_ACC_NAME |
"name" |
public static final String |
FIELD_NAME_ACC_TYPE |
"type" |
public static final String |
FIELD_NAME_ACC_VALUE |
"value" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_SAVEPOINT_PATH |
"savepoint-path" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_TARGET_DIRECTORY |
"target-directory" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
URL |
"/taskmanagers/:taskmanagerid" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_METRICS |
"metrics" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
KEY |
"taskmanagerid" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_ADDRESS |
"path" |
public static final String |
FIELD_NAME_DATA_PORT |
"dataPort" |
public static final String |
FIELD_NAME_HARDWARE |
"hardware" |
public static final String |
FIELD_NAME_LAST_HEARTBEAT |
"timeSinceLastHeartbeat" |
public static final String |
FIELD_NAME_NUMBER_AVAILABLE_SLOTS |
"freeSlots" |
public static final String |
FIELD_NAME_NUMBER_SLOTS |
"slotsNumber" |
public static final String |
FIELD_NAME_RESOURCE_ID |
"id" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_DIRECT_COUNT |
"directCount" |
public static final String |
FIELD_NAME_DIRECT_MAX |
"directMax" |
public static final String |
FIELD_NAME_DIRECT_USED |
"directUsed" |
public static final String |
FIELD_NAME_GARBAGE_COLLECTORS |
"garbageCollectors" |
public static final String |
FIELD_NAME_HEAP_COMMITTED |
"heapCommitted" |
public static final String |
FIELD_NAME_HEAP_MAX |
"heapMax" |
public static final String |
FIELD_NAME_HEAP_USED |
"heapUsed" |
public static final String |
FIELD_NAME_MAPPED_COUNT |
"mappedCount" |
public static final String |
FIELD_NAME_MAPPED_MAX |
"mappedMax" |
public static final String |
FIELD_NAME_MAPPED_USED |
"mappedUsed" |
public static final String |
FIELD_NAME_NETWORK_MEMORY_SEGMENTS_AVAILABLE |
"memorySegmentsAvailable" |
public static final String |
FIELD_NAME_NETWORK_MEMROY_SEGMENTS_TOTAL |
"memorySegmentsTotal" |
public static final String |
FIELD_NAME_NON_HEAP_COMMITTED |
"nonHeapCommitted" |
public static final String |
FIELD_NAME_NON_HEAP_MAX |
"nonHeapMax" |
public static final String |
FIELD_NAME_NON_HEAP_USED |
"nonHeapUsed" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_COUNT |
"count" |
public static final String |
FIELD_NAME_NAME |
"name" |
public static final String |
FIELD_NAME_TIME |
"time" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
URL |
"/taskmanagers" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_TASK_MANAGERS |
"taskmanagers" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
CONTENT_TYPE_BINARY |
"application/octet-stream" |
public static final String |
CONTENT_TYPE_JAR |
"application/java-archive" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
DEFAULT_OPERATOR_STATE_NAME |
"_default_" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
VERSION |
4 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
NO_CURRENT_KEY_GROUP |
-1 |
public static final long |
NO_OFFSET_SET |
-1L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DEFAULT_LOWER_BOUND_MAX_PARALLELISM |
128 |
public static final int |
UPPER_BOUND_MAX_PARALLELISM |
32768 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
VERSION |
3 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FS_STATE_BACKEND_NAME |
"filesystem" |
public static final String |
MEMORY_STATE_BACKEND_NAME |
"jobmanager" |
public static final String |
ROCKSDB_STATE_BACKEND_NAME |
"rocksdb" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
CHECKPOINT_DIR_PREFIX |
"chk-" |
public static final String |
CHECKPOINT_SHARED_STATE_DIR |
"shared" |
public static final String |
CHECKPOINT_TASK_OWNED_STATE_DIR |
"taskowned" |
public static final String |
METADATA_FILE_NAME |
"_metadata" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DEFAULT_WRITE_BUFFER_SIZE |
4096 |
public static final int |
MAX_FILE_STATE_THRESHOLD |
1048576 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MAX_FILE_STATE_THRESHOLD |
1048576 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DEFAULT_MAX_STATE_SIZE |
5242880 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
EXTERNAL_POINTER |
"<checkpoint-not-externally-addressable>" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
TASK_MANAGER_NAME |
"taskmanager" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
LOCAL_STATE_SUB_DIRECTORY_ROOT |
"localState" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
UNKNOWN |
"<unknown>" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
WEB_MONITOR_ADDRESS_KEY |
"web.monitor.address" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
KEY |
"jarid" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
URL |
"/jars" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
JAR_LIST_FIELD_ADDRESS |
"address" |
public static final String |
JAR_LIST_FIELD_FILES |
"files" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
JAR_ENTRY_FIELD_DESC |
"description" |
public static final String |
JAR_ENTRY_FIELD_NAME |
"name" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
JAR_FILE_FIELD_ENTRY |
"entry" |
public static final String |
JAR_FILE_FIELD_ID |
"id" |
public static final String |
JAR_FILE_FIELD_NAME |
"name" |
public static final String |
JAR_FILE_FIELD_UPLOADED |
"uploaded" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
URL |
"/jars/upload" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
KEY |
"savepointPath" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DEFAULT_ZOOKEEPER_CLIENT_PORT |
2181 |
public static final int |
DEFAULT_ZOOKEEPER_INIT_LIMIT |
10 |
public static final int |
DEFAULT_ZOOKEEPER_LEADER_PORT |
3888 |
public static final int |
DEFAULT_ZOOKEEPER_PEER_PORT |
2888 |
public static final int |
DEFAULT_ZOOKEEPER_SYNC_LIMIT |
5 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
SUBMIT_BLOCKING |
"SUBMIT_STORM_TOPOLOGY_BLOCKING" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
TOPOLOGY_ID |
"Streaming Exclamation" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
EXCLAMATION_COUNT |
"exclamation.count" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
EVEN_STREAM |
"even" |
public static final String |
ODD_STREAM |
"odd" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
ATTRIBUTE_LINE |
"line" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
INPUT_FILE_PATH |
"input.path" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
ATTRIBUTE_COUNT |
"count" |
public static final String |
ATTRIBUTE_WORD |
"word" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
ATTRIBUTE_COUNT |
"count" |
public static final String |
ATTRIBUTE_WORD |
"word" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
ATTRIBUTE_COUNT |
"count" |
public static final int |
ATTRIBUTE_COUNT_INDEX |
1 |
public static final String |
ATTRIBUTE_WORD |
"word" |
public static final int |
ATTRIBUTE_WORD_INDEX |
0 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
ATTRIBUTE_COUNT |
"count" |
public static final int |
ATTRIBUTE_COUNT_INDEX |
1 |
public static final String |
ATTRIBUTE_WORD |
"word" |
public static final int |
ATTRIBUTE_WORD_INDEX |
0 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
DEFAULT_ID |
"default ID" |
public static final String |
DEFUALT_BOLT_NAME |
"Unnamed Bolt" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DEFAULT_MAX_CONCURRENT_CHECKPOINTS |
1 |
public static final long |
DEFAULT_MIN_PAUSE_BETWEEN_CHECKPOINTS |
0L |
public static final long |
DEFAULT_TIMEOUT |
600000L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
DEFAULT_JOB_NAME |
"Flink Streaming Job" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
MIN_MONITORING_INTERVAL |
1L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
CONTENTS |
"contents" |
public static final String |
ID |
"id" |
public static final String |
PACT |
"pact" |
public static final String |
PARALLELISM |
"parallelism" |
public static final String |
PREDECESSORS |
"predecessors" |
public static final String |
SHIP_STRATEGY |
"ship_strategy" |
public static final String |
SIDE |
"side" |
public static final String |
STEPS |
"step_function" |
public static final String |
TYPE |
"type" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DEFAULT_LOWER_BOUND_MAX_PARALLELISM |
128 |
public static final int |
UPPER_BOUND_MAX_PARALLELISM |
32768 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
VERSION |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
NO_VERSION |
-2147483648 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
CONFIG_KEY_BULK_FLUSH_BACKOFF_DELAY |
"bulk.flush.backoff.delay" |
public static final String |
CONFIG_KEY_BULK_FLUSH_BACKOFF_ENABLE |
"bulk.flush.backoff.enable" |
public static final String |
CONFIG_KEY_BULK_FLUSH_BACKOFF_RETRIES |
"bulk.flush.backoff.retries" |
public static final String |
CONFIG_KEY_BULK_FLUSH_BACKOFF_TYPE |
"bulk.flush.backoff.type" |
public static final String |
CONFIG_KEY_BULK_FLUSH_INTERVAL_MS |
"bulk.flush.interval.ms" |
public static final String |
CONFIG_KEY_BULK_FLUSH_MAX_ACTIONS |
"bulk.flush.max.actions" |
public static final String |
CONFIG_KEY_BULK_FLUSH_MAX_SIZE_MB |
"bulk.flush.max.size.mb" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
CONF_COMPRESS |
"mapreduce.output.fileoutputformat.compress" |
public static final String |
CONF_COMPRESS_CODEC |
"mapreduce.output.fileoutputformat.compress.codec" |
public static final String |
CONF_DEFLATE_LEVEL |
"avro.deflate.level" |
public static final String |
CONF_OUTPUT_KEY_SCHEMA |
"avro.schema.output.key" |
public static final String |
CONF_OUTPUT_VALUE_SCHEMA |
"avro.schema.output.value" |
public static final String |
CONF_XZ_LEVEL |
"avro.xz.level" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
KEY_FIELD |
"key" |
public static final String |
KEY_VALUE_PAIR_RECORD_NAME |
"KeyValuePair" |
public static final String |
KEY_VALUE_PAIR_RECORD_NAMESPACE |
"org.apache.avro.mapreduce" |
public static final String |
VALUE_FIELD |
"value" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DEFAULT_GET_PARTITIONS_RETRIES |
3 |
public static final String |
GET_PARTITIONS_RETRIES_KEY |
"flink.get-partitions.retry" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
DEFAULT_POLL_TIMEOUT |
100L |
public static final String |
KEY_POLL_TIMEOUT |
"flink.poll-timeout" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
KEY_DISABLE_METRICS |
"flink.disable-metrics" |
public static final String |
KEY_PARTITION_DISCOVERY_INTERVAL_MILLIS |
"flink.partition-discovery.interval-millis" |
public static final int |
MAX_NUM_PENDING_CHECKPOINTS |
100 |
public static final long |
PARTITION_DISCOVERY_DISABLED |
-9223372036854775808L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DEFAULT_KAFKA_PRODUCERS_POOL_SIZE |
5 |
public static final String |
KEY_DISABLE_METRICS |
"flink.disable-metrics" |
public static final int |
SAFE_SCALE_DOWN_FACTOR |
5 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
KEY_DISABLE_METRICS |
"flink.disable-metrics" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
EARLIEST_OFFSET |
-915623761775L |
public static final long |
GROUP_OFFSET |
-915623761773L |
public static final long |
LATEST_OFFSET |
-915623761774L |
public static final long |
OFFSET_NOT_SET |
-915623761776L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
COMMITS_FAILED_METRICS_COUNTER |
"commitsFailed" |
public static final String |
COMMITS_SUCCEEDED_METRICS_COUNTER |
"commitsSucceeded" |
public static final String |
COMMITTED_OFFSETS_METRICS_GAUGE |
"committedOffsets" |
public static final String |
CURRENT_OFFSETS_METRICS_GAUGE |
"currentOffsets" |
public static final String |
KAFKA_CONSUMER_METRICS_GROUP |
"KafkaConsumer" |
public static final String |
LEGACY_COMMITTED_OFFSETS_METRICS_GROUP |
"committed-offsets" |
public static final String |
LEGACY_CURRENT_OFFSETS_METRICS_GROUP |
"current-offsets" |
public static final String |
OFFSETS_BY_PARTITION_METRICS_GROUP |
"partition" |
public static final String |
OFFSETS_BY_TOPIC_METRICS_GROUP |
"topic" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
CLIENT_BUFFER_SIZE |
"twitter-source.bufferSize" |
public static final String |
CLIENT_HOSTS |
"twitter-source.hosts" |
public static final String |
CLIENT_NAME |
"twitter-source.name" |
public static final String |
CONSUMER_KEY |
"twitter-source.consumerKey" |
public static final String |
CONSUMER_SECRET |
"twitter-source.consumerSecret" |
public static final String |
TOKEN |
"twitter-source.token" |
public static final String |
TOKEN_SECRET |
"twitter-source.tokenSecret" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
DEFAULT_CHANNEL |
"#en.wikipedia" |
public static final String |
DEFAULT_HOST |
"irc.wikimedia.org" |
public static final int |
DEFAULT_PORT |
6667 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
INPUT_PAIRS |
"(1,40)\n(29,38)\n(11,15)\n(17,39)\n(24,41)\n(7,33)\n(20,2)\n(11,5)\n(3,16)\n(23,36)\n(15,23)\n(28,13)\n(1,1)\n(10,6)\n(21,5)\n(14,36)\n(17,15)\n(7,9)" |
public static final String |
RESULTS |
"((1,40),3)\n((24,41),2)\n((3,16),5)\n((1,1),10)\n((17,15),4)\n((29,38),2)\n((7,33),3)\n((23,36),3)\n((10,6),6)\n((7,9),5)\n((11,15),4)\n((20,2),5)\n((15,23),4)\n((21,5),5)\n((17,39),3)\n((11,5),6)\n((28,13),4)\n((14,36),3)" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
RESULTS |
"1\n1\n1\n1\n1\n1\n1\n1\n1\n1\n1\n1\n1\n1\n1\n1\n1\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
BROKER_ADDRESS |
"localhost:9092" |
public static final int |
NUM_PARTITIONS |
1 |
public static final String |
TOPIC |
"flink-demo-topic-1" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
STREAMING_COUNTS_AS_TUPLES |
"(apache,1)\n(apache,2)\n(apache,3)\n(flink,1)\n(flink,2)\n(flink,3)\n" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
EXPECTED |
"(a,1,1)\n(c,6,1)\n(c,11,1)\n(b,1,3)\n(a,10,1)" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
CAR_DATA |
"(0,55,15.277777777777777,1424951918630)\n(1,45,12.5,1424951918632)\n(0,50,29.166666666666664,1424951919632)\n(1,50,26.38888888888889,1424951919632)\n(0,55,44.44444444444444,1424951920633)\n(1,45,38.888888888888886,1424951920633)\n(0,50,58.33333333333333,1424951921634)\n(1,40,50.0,1424951921634)\n(0,55,73.6111111111111,1424951922634)\n(1,35,59.72222222222222,1424951922634)\n(0,60,90.27777777777777,1424951923634)\n(1,40,70.83333333333333,1424951923634)\n(0,65,108.33333333333333,1424951924635)\n(1,35,80.55555555555554,1424951924635)\n(0,60,125.0,1424951925635)\n(1,40,91.66666666666666,1424951925635)\n(0,55,140.27777777777777,1424951926635)\n(1,45,104.16666666666666,1424951926636)\n(0,60,156.94444444444443,1424951927636)\n(1,50,118.05555555555554,1424951927636)\n(0,55,172.2222222222222,1424951928636)\n(1,45,130.55555555555554,1424951928636)\n(0,50,186.1111111111111,1424951929636)\n(1,50,144.44444444444443,1424951929637)\n(0,55,201.38888888888886,1424951930637)\n(1,55,159.7222222222222,1424951930637)\n(0,60,218.05555555555551,1424951931637)\n(1,60,176.38888888888886,1424951931637)\n(0,55,233.3333333333333,1424951932637)\n(1,65,194.4444444444444,1424951932638)\n(0,50,247.22222222222217,1424951933638)\n(1,70,213.88888888888886,1424951933638)\n(0,45,259.7222222222222,1424951934638)\n(1,65,231.9444444444444,1424951934638)\n(0,50,273.6111111111111,1424951935638)\n(1,70,251.38888888888886,1424951935639)\n(0,55,288.88888888888886,1424951936639)\n(1,75,272.2222222222222,1424951936639)\n(0,50,302.77777777777777,1424951937639)\n(1,70,291.66666666666663,1424951937639)\n(0,45,315.27777777777777,1424951938640)\n(1,65,309.7222222222222,1424951938640)\n(0,50,329.1666666666667,1424951939640)\n(1,70,329.16666666666663,1424951939640)\n(0,55,344.44444444444446,1424951940640)\n(1,65,347.2222222222222,1424951940640)\n(0,50,358.33333333333337,1424951941641)\n(1,70,366.66666666666663,1424951941641)\n(0,55,373.61111111111114,1424951942641)\n(1,65,384.7222222222222,1424951942641)\n(0,50,387.50000000000006,1424951943641)\n(1,70,404.16666666666663,1424951943641)\n(0,45,400.00000000000006,1424951944642)\n(1,65,422.2222222222222,1424951944642)\n(0,50,413.88888888888897,1424951945642)\n(1,60,438.88888888888886,1424951945642)\n(0,45,426.38888888888897,1424951946642)\n(1,65,456.9444444444444,1424951946642)\n(0,40,437.50000000000006,1424951947643)\n(1,70,476.38888888888886,1424951947643)\n(0,45,450.00000000000006,1424951948643)\n(1,75,497.2222222222222,1424951948643)\n(0,40,461.11111111111114,1424951949643)\n(1,80,519.4444444444443,1424951949644)\n(0,45,473.61111111111114,1424951950644)\n(1,75,540.2777777777777,1424951950644)\n(0,50,487.50000000000006,1424951951644)\n(1,80,562.4999999999999,1424951951644)\n(0,45,500.00000000000006,1424951952644)\n(1,85,586.111111111111,1424951952645)\n(0,40,511.11111111111114,1424951953645)\n(1,80,608.3333333333331,1424951953645)\n(0,35,520.8333333333334,1424951954645)\n(1,75,629.1666666666665,1424951954645)\n(0,40,531.9444444444445,1424951955645)\n(1,70,648.611111111111,1424951955646)\n(0,45,544.4444444444445,1424951956646)\n(1,75,669.4444444444443,1424951956646)\n(0,50,558.3333333333334,1424951957646)\n(1,80,691.6666666666665,1424951957646)\n(0,55,573.6111111111112,1424951958646)\n(1,85,715.2777777777776,1424951958647)\n(0,60,590.2777777777778,1424951959647)\n(1,80,737.4999999999998,1424951959647)\n(0,65,608.3333333333334,1424951960647)\n(1,85,761.1111111111109,1424951960647)\n(0,70,627.7777777777778,1424951961647)\n(1,80,783.333333333333,1424951961648)\n(0,75,648.6111111111112,1424951962648)\n(1,85,806.9444444444441,1424951962648)\n(0,80,670.8333333333334,1424951963648)\n(1,90,831.9444444444441,1424951963648)\n(0,75,691.6666666666667,1424951964649)\n(1,95,858.333333333333,1424951964649)\n(0,70,711.1111111111112,1424951965649)\n(1,90,883.333333333333,1424951965649)\n(0,75,731.9444444444446,1424951966649)\n(1,95,909.722222222222,1424951966649)\n(0,70,751.388888888889,1424951967649)\n(1,100,937.4999999999998,1424951967650)\n(0,75,772.2222222222224,1424951968650)\n(1,100,965.2777777777776,1424951968650)\n(0,80,794.4444444444446,1424951969650)\n(1,100,993.0555555555554,1424951969650)\n(0,75,815.2777777777779,1424951970651)\n(1,100,1020.8333333333333,1424951970651)\n(0,80,837.5000000000001,1424951971651)\n(1,100,1048.611111111111,1424951971651)\n(0,85,861.1111111111112,1424951972651)\n(1,100,1076.388888888889,1424951972651)\n(0,80,883.3333333333334,1424951973652)\n(1,95,1102.7777777777778,1424951973652)\n(0,75,904.1666666666667,1424951974652)\n(1,100,1130.5555555555557,1424951974652)\n(0,70,923.6111111111112,1424951975652)\n(1,100,1158.3333333333335,1424951975652)\n(0,75,944.4444444444446,1424951976653)\n(1,100,1186.1111111111113,1424951976653)\n(0,80,966.6666666666667,1424951977653)\n(1,95,1212.5000000000002,1424951977653)\n(0,75,987.5000000000001,1424951978653)\n(1,100,1240.277777777778,1424951978653)\n(0,80,1009.7222222222223,1424951979654)\n(1,100,1268.0555555555559,1424951979654)\n(0,85,1033.3333333333335,1424951980654)\n(1,100,1295.8333333333337,1424951980654)\n(0,90,1058.3333333333335,1424951981654)\n(1,100,1323.6111111111115,1424951981654)\n(0,85,1081.9444444444446,1424951982655)\n(1,100,1351.3888888888894,1424951982655)\n(0,90,1106.9444444444446,1424951983655)\n(1,100,1379.1666666666672,1424951983655)\n(0,95,1133.3333333333335,1424951984655)\n(1,100,1406.944444444445,1424951984656)\n(0,90,1158.3333333333335,1424951985656)\n(1,95,1433.333333333334,1424951985656)\n(0,95,1184.7222222222224,1424951986656)\n(1,90,1458.333333333334,1424951986656)\n(0,90,1209.7222222222224,1424951987656)\n(1,95,1484.7222222222229,1424951987657)\n(0,85,1233.3333333333335,1424951988657)\n(1,90,1509.7222222222229,1424951988657)\n(0,80,1255.5555555555557,1424951989657)\n(1,95,1536.1111111111118,1424951989657)\n(0,85,1279.1666666666667,1424951990657)\n(1,100,1563.8888888888896,1424951990658)\n(0,90,1304.1666666666667,1424951991658)\n(1,95,1590.2777777777785,1424951991658)\n(0,95,1330.5555555555557,1424951992658)\n(1,90,1615.2777777777785,1424951992658)\n(0,100,1358.3333333333335,1424951993659)\n(1,95,1641.6666666666674,1424951993659)\n(0,100,1386.1111111111113,1424951994659)\n(1,100,1669.4444444444453,1424951994659)\n(0,95,1412.5000000000002,1424951995659)\n(1,95,1695.8333333333342,1424951995660)\n(0,100,1440.277777777778,1424951996660)\n(1,90,1720.8333333333342,1424951996660)\n(0,100,1468.0555555555559,1424951997660)\n(1,85,1744.4444444444453,1424951997660)\n(0,95,1494.4444444444448,1424951998660)\n(1,80,1766.6666666666674,1424951998661)\n(0,100,1522.2222222222226,1424951999661)\n(1,75,1787.5000000000007,1424951999661)\n(0,95,1548.6111111111115,1424952000661)\n(1,80,1809.7222222222229,1424952000661)\n(0,90,1573.6111111111115,1424952001662)\n(1,75,1830.555555555556,1424952001662)\n(0,95,1600.0000000000005,1424952002662)\n(1,80,1852.7777777777783,1424952002662)\n(0,100,1627.7777777777783,1424952003662)\n(1,85,1876.3888888888894,1424952003662)\n(0,100,1655.555555555556,1424952004663)\n(1,80,1898.6111111111115,1424952004663)\n(0,95,1681.944444444445,1424952005663)\n(1,85,1922.2222222222226,1424952005663)\n(0,100,1709.7222222222229,1424952006663)\n(1,90,1947.2222222222226,1424952006664)\n(0,100,1737.5000000000007,1424952007664)\n(1,95,1973.6111111111115,1424952007664)\n(0,95,1763.8888888888896,1424952008664)\n(1,90,1998.6111111111115,1424952008664)\n(0,100,1791.6666666666674,1424952009664)\n(1,85,2022.2222222222226,1424952009665)\n(0,95,1818.0555555555563,1424952010665)\n(1,80,2044.4444444444448,1424952010665)\n(0,90,1843.0555555555563,1424952011665)\n(1,75,2065.2777777777783,1424952011665)\n(0,95,1869.4444444444453,1424952012666)\n(1,80,2087.5000000000005,1424952012666)\n(0,100,1897.222222222223,1424952013666)\n(1,85,2111.1111111111118,1424952013666)\n(0,95,1923.611111111112,1424952014666)\n(1,90,2136.1111111111118,1424952014666)\n(0,100,1951.3888888888898,1424952015667)\n(1,85,2159.722222222223,1424952015667)\n(0,95,1977.7777777777787,1424952016667)\n(1,90,2184.722222222223,1424952016667)\n(0,100,2005.5555555555566,1424952017667)\n(1,95,2211.1111111111118,1424952017668)" |
public static final String |
TOP_CASE_CLASS_SPEEDS |
"CarEvent(0,55,15.277777777777777,1424951918630)\nCarEvent(1,50,26.38888888888889,1424951919632)\nCarEvent(0,65,108.33333333333333,1424951924635)\nCarEvent(1,50,26.38888888888889,1424951919632)\nCarEvent(0,65,108.33333333333333,1424951924635)\nCarEvent(1,65,194.4444444444444,1424951932638)\nCarEvent(0,65,108.33333333333333,1424951924635)\nCarEvent(1,70,213.88888888888886,1424951933638)\nCarEvent(0,60,218.05555555555551,1424951931637)\nCarEvent(1,75,272.2222222222222,1424951936639)\nCarEvent(0,55,233.3333333333333,1424951932637)\nCarEvent(1,75,272.2222222222222,1424951936639)\nCarEvent(1,75,272.2222222222222,1424951936639)\nCarEvent(0,55,288.88888888888886,1424951936639)\nCarEvent(1,70,329.16666666666663,1424951939640)\nCarEvent(0,55,373.61111111111114,1424951942641)\nCarEvent(1,80,519.4444444444443,1424951949644)\nCarEvent(1,85,586.111111111111,1424951952645)\nCarEvent(0,50,487.50000000000006,1424951951644)\nCarEvent(1,85,586.111111111111,1424951952645)\nCarEvent(0,60,590.2777777777778,1424951959647)\nCarEvent(1,85,586.111111111111,1424951952645)\nCarEvent(0,75,648.6111111111112,1424951962648)\nCarEvent(1,85,715.2777777777776,1424951958647)\nCarEvent(1,95,858.333333333333,1424951964649)\nCarEvent(0,80,670.8333333333334,1424951963648)\nCarEvent(1,95,858.333333333333,1424951964649)\nCarEvent(0,80,670.8333333333334,1424951963648)\nCarEvent(1,100,937.4999999999998,1424951967650)\nCarEvent(1,100,937.4999999999998,1424951967650)\nCarEvent(0,80,670.8333333333334,1424951963648)\nCarEvent(1,100,937.4999999999998,1424951967650)\nCarEvent(0,85,861.1111111111112,1424951972651)\nCarEvent(1,100,937.4999999999998,1424951967650)\nCarEvent(1,100,937.4999999999998,1424951967650)\nCarEvent(0,85,861.1111111111112,1424951972651)\nCarEvent(1,100,993.0555555555554,1424951969650)\nCarEvent(0,85,861.1111111111112,1424951972651)\nCarEvent(1,100,1048.611111111111,1424951971651)\nCarEvent(1,100,1130.5555555555557,1424951974652)\nCarEvent(0,90,1058.3333333333335,1424951981654)\nCarEvent(1,100,1158.3333333333335,1424951975652)\nCarEvent(0,95,1133.3333333333335,1424951984655)\nCarEvent(1,100,1240.277777777778,1424951978653)\nCarEvent(0,95,1133.3333333333335,1424951984655)\nCarEvent(1,100,1268.0555555555559,1424951979654)\nCarEvent(0,95,1133.3333333333335,1424951984655)\nCarEvent(1,100,1323.6111111111115,1424951981654)\nCarEvent(0,95,1133.3333333333335,1424951984655)\nCarEvent(1,100,1379.1666666666672,1424951983655)\nCarEvent(0,100,1358.3333333333335,1424951993659)\nCarEvent(1,100,1563.8888888888896,1424951990658)\nCarEvent(0,100,1358.3333333333335,1424951993659)\nCarEvent(1,100,1563.8888888888896,1424951990658)\nCarEvent(0,100,1358.3333333333335,1424951993659)\nCarEvent(1,100,1563.8888888888896,1424951990658)\nCarEvent(0,100,1358.3333333333335,1424951993659)\nCarEvent(0,100,1358.3333333333335,1424951993659)\nCarEvent(1,100,1669.4444444444453,1424951994659)\nCarEvent(0,100,1440.277777777778,1424951996660)\nCarEvent(1,90,1720.8333333333342,1424951996660)\nCarEvent(0,100,1468.0555555555559,1424951997660)\nCarEvent(1,95,1973.6111111111115,1424952007664)\nCarEvent(0,100,1522.2222222222226,1424951999661)\nCarEvent(0,100,1627.7777777777783,1424952003662)\nCarEvent(1,95,1973.6111111111115,1424952007664)\nCarEvent(0,100,1627.7777777777783,1424952003662)\nCarEvent(1,95,1973.6111111111115,1424952007664)\nCarEvent(0,100,1709.7222222222229,1424952006663)\nCarEvent(0,100,1737.5000000000007,1424952007664)\nCarEvent(1,95,1973.6111111111115,1424952007664)\n" |
public static final String |
TOP_SPEEDS |
"(0,55,15.277777777777777,1424951918630)\n(1,50,26.38888888888889,1424951919632)\n(0,65,108.33333333333333,1424951924635)\n(1,50,26.38888888888889,1424951919632)\n(0,65,108.33333333333333,1424951924635)\n(1,65,194.4444444444444,1424951932638)\n(0,65,108.33333333333333,1424951924635)\n(1,70,213.88888888888886,1424951933638)\n(0,60,218.05555555555551,1424951931637)\n(1,75,272.2222222222222,1424951936639)\n(0,55,233.3333333333333,1424951932637)\n(1,75,272.2222222222222,1424951936639)\n(1,75,272.2222222222222,1424951936639)\n(0,55,288.88888888888886,1424951936639)\n(1,70,329.16666666666663,1424951939640)\n(0,55,373.61111111111114,1424951942641)\n(1,80,519.4444444444443,1424951949644)\n(1,85,586.111111111111,1424951952645)\n(0,50,487.50000000000006,1424951951644)\n(1,85,586.111111111111,1424951952645)\n(0,60,590.2777777777778,1424951959647)\n(1,85,586.111111111111,1424951952645)\n(0,75,648.6111111111112,1424951962648)\n(1,85,715.2777777777776,1424951958647)\n(1,95,858.333333333333,1424951964649)\n(0,80,670.8333333333334,1424951963648)\n(1,95,858.333333333333,1424951964649)\n(0,80,670.8333333333334,1424951963648)\n(1,100,937.4999999999998,1424951967650)\n(1,100,937.4999999999998,1424951967650)\n(0,80,670.8333333333334,1424951963648)\n(1,100,937.4999999999998,1424951967650)\n(0,85,861.1111111111112,1424951972651)\n(1,100,937.4999999999998,1424951967650)\n(1,100,937.4999999999998,1424951967650)\n(0,85,861.1111111111112,1424951972651)\n(1,100,993.0555555555554,1424951969650)\n(0,85,861.1111111111112,1424951972651)\n(1,100,1048.611111111111,1424951971651)\n(1,100,1130.5555555555557,1424951974652)\n(0,90,1058.3333333333335,1424951981654)\n(1,100,1158.3333333333335,1424951975652)\n(0,95,1133.3333333333335,1424951984655)\n(1,100,1240.277777777778,1424951978653)\n(0,95,1133.3333333333335,1424951984655)\n(1,100,1268.0555555555559,1424951979654)\n(0,95,1133.3333333333335,1424951984655)\n(1,100,1323.6111111111115,1424951981654)\n(0,95,1133.3333333333335,1424951984655)\n(1,100,1379.1666666666672,1424951983655)\n(0,100,1358.3333333333335,1424951993659)\n(1,100,1563.8888888888896,1424951990658)\n(0,100,1358.3333333333335,1424951993659)\n(1,100,1563.8888888888896,1424951990658)\n(0,100,1358.3333333333335,1424951993659)\n(1,100,1563.8888888888896,1424951990658)\n(0,100,1358.3333333333335,1424951993659)\n(0,100,1358.3333333333335,1424951993659)\n(1,100,1669.4444444444453,1424951994659)\n(0,100,1440.277777777778,1424951996660)\n(1,90,1720.8333333333342,1424951996660)\n(0,100,1468.0555555555559,1424951997660)\n(1,95,1973.6111111111115,1424952007664)\n(0,100,1522.2222222222226,1424951999661)\n(0,100,1627.7777777777783,1424952003662)\n(1,95,1973.6111111111115,1424952007664)\n(0,100,1627.7777777777783,1424952003662)\n(1,95,1973.6111111111115,1424952007664)\n(0,100,1709.7222222222229,1424952006663)\n(0,100,1737.5000000000007,1424952007664)\n(1,95,1973.6111111111115,1424952007664)\n" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FLINK_PYTHON_DC_ID |
"flink" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
ACTIVE_STATUS |
0 |
public static final int |
IDLE_STATUS |
-1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
DEFAULT_SESSION_ID |
"default" |
public static final String |
MODE_EMBEDDED |
"embedded" |
public static final String |
MODE_GATEWAY |
"gateway" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final int |
MAX_COLUMN_WIDTH |
25 |
protected static final int |
NO_ROW_SELECTED |
-1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
CLI_NAME |
"Flink SQL CLI Client" |
public static final String |
DEFAULT_MARGIN |
" " |
public static final String |
INPUT_ENTER_PAGE |
"Enter page number:" |
public static final String |
INPUT_ERROR |
"The input is invalid please check it again." |
public static final String |
INPUT_TITLE |
"Input Dialog" |
public static final String |
MESSAGE_EMPTY |
"Result was empty." |
public static final String |
MESSAGE_INVALID_PATH |
"Path is invalid." |
public static final String |
MESSAGE_MAX_SIZE_EXCEEDED |
"The given file exceeds the maximum number of characters." |
public static final String |
MESSAGE_QUIT |
"Exiting Flink SQL CLI Client..." |
public static final String |
MESSAGE_RESET |
"All session properties have been set to their default values." |
public static final String |
MESSAGE_RESULT_QUIT |
"Result retrieval cancelled." |
public static final String |
MESSAGE_RESULT_SNAPSHOT_ERROR |
"Could not create a snapshot of the dynamic table." |
public static final String |
MESSAGE_SET |
"Session property has been set." |
public static final String |
MESSAGE_SQL_EXECUTION_ERROR |
"Could not execute SQL statement." |
public static final String |
MESSAGE_UNKNOWN_SQL |
"Unknown SQL statement." |
public static final String |
MESSAGE_UNKNOWN_TABLE |
"Unknown table." |
public static final String |
MESSAGE_WILL_EXECUTE |
"Executing the following statement:" |
public static final String |
NULL_COLUMN |
"(NULL)" |
public static final String |
RESULT_CHANGELOG |
"Changelog" |
public static final String |
RESULT_DEC_REFRESH |
"Dec Refresh" |
public static final String |
RESULT_FIRST |
"First Page" |
public static final String |
RESULT_GOTO |
"Goto Page" |
public static final String |
RESULT_INC_REFRESH |
"Inc Refresh" |
public static final String |
RESULT_LAST |
"Last Page" |
public static final String |
RESULT_LAST_PAGE |
"Last" |
public static final String |
RESULT_LAST_REFRESH |
"Updated:" |
public static final String |
RESULT_NEXT |
"Next Page" |
public static final String |
RESULT_OPEN |
"Open Row" |
public static final String |
RESULT_PAGE |
"Page:" |
public static final String |
RESULT_PAGE_OF |
" of " |
public static final String |
RESULT_PREV |
"Prev Page" |
public static final String |
RESULT_QUIT |
"Quit" |
public static final String |
RESULT_REFRESH |
"Refresh" |
public static final String |
RESULT_REFRESH_INTERVAL |
"Refresh:" |
public static final String |
RESULT_REFRESH_UNKNOWN |
"Unknown" |
public static final String |
RESULT_SEARCH |
"Search" |
public static final String |
RESULT_STOPPED |
"Table program finished." |
public static final String |
RESULT_TABLE |
"Table" |
public static final String |
RESULT_TITLE |
"SQL Query Result" |
public static final String |
ROW_HEADER |
"Row Summary" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
DEPLOYMENT |
"deployment" |
public static final String |
DEPLOYMENT_GATEWAY_ADDRESS |
"gateway-address" |
public static final String |
DEPLOYMENT_GATEWAY_PORT |
"gateway-port" |
public static final String |
DEPLOYMENT_RESPONSE_TIMEOUT |
"response-timeout" |
public static final String |
DEPLOYMENT_TYPE |
"type" |
public static final String |
DEPLOYMENT_TYPE_VALUE_STANDALONE |
"standalone" |
public static final String |
EXECUTION |
"execution" |
public static final String |
EXECUTION_MAX_PARALLELISM |
"max-parallelism" |
public static final String |
EXECUTION_MAX_STATE_RETENTION |
"max-idle-state-retention" |
public static final String |
EXECUTION_MIN_STATE_RETENTION |
"min-idle-state-retention" |
public static final String |
EXECUTION_PARALLELISM |
"parallelism" |
public static final String |
EXECUTION_RESULT_MODE |
"result-mode" |
public static final String |
EXECUTION_RESULT_MODE_VALUE_CHANGELOG |
"changelog" |
public static final String |
EXECUTION_RESULT_MODE_VALUE_TABLE |
"table" |
public static final String |
EXECUTION_TIME_CHARACTERISTIC |
"time-characteristic" |
public static final String |
EXECUTION_TIME_CHARACTERISTIC_VALUE_EVENT_TIME |
"event-time" |
public static final String |
EXECUTION_TIME_CHARACTERISTIC_VALUE_PROCESSING_TIME |
"processing-time" |
public static final String |
EXECUTION_TYPE |
"type" |
public static final String |
EXECUTION_TYPE_VALUE_BATCH |
"batch" |
public static final String |
EXECUTION_TYPE_VALUE_STREAMING |
"streaming" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FORMAT_FAIL_ON_MISSING_FIELD |
"format.fail-on-missing-field" |
public static final String |
FORMAT_JSON_SCHEMA |
"format.json-schema" |
public static final String |
FORMAT_SCHEMA |
"format.schema" |
public static final String |
FORMAT_TYPE_VALUE |
"json" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
CONNECTOR_PROPERTIES |
"connector.properties" |
public static final String |
CONNECTOR_PROPERTIES_KEY |
"key" |
public static final String |
CONNECTOR_PROPERTIES_VALUE |
"value" |
public static final String |
CONNECTOR_SPECIFIC_OFFSETS |
"connector.specific-offsets" |
public static final String |
CONNECTOR_SPECIFIC_OFFSETS_OFFSET |
"offset" |
public static final String |
CONNECTOR_SPECIFIC_OFFSETS_PARTITION |
"partition" |
public static final String |
CONNECTOR_STARTUP_MODE |
"connector.startup-mode" |
public static final String |
CONNECTOR_STARTUP_MODE_VALUE_EARLIEST |
"earliest-offset" |
public static final String |
CONNECTOR_STARTUP_MODE_VALUE_GROUP_OFFSETS |
"group-offsets" |
public static final String |
CONNECTOR_STARTUP_MODE_VALUE_LATEST |
"latest-offset" |
public static final String |
CONNECTOR_STARTUP_MODE_VALUE_SPECIFIC_OFFSETS |
"specific-offsets" |
public static final String |
CONNECTOR_TOPIC |
"connector.topic" |
public static final String |
CONNECTOR_TYPE_VALUE_KAFKA |
"kafka" |
public static final String |
CONNECTOR_VERSION_VALUE_010 |
"0.10" |
public static final String |
CONNECTOR_VERSION_VALUE_011 |
"0.11" |
public static final String |
CONNECTOR_VERSION_VALUE_08 |
"0.8" |
public static final String |
CONNECTOR_VERSION_VALUE_09 |
"0.9" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
EDGES |
"1 2\n1 3\n1 4\n1 5\n2 3\n2 5\n3 4\n3 7\n5 6\n3 8\n7 8\n" |
public static final String |
TRIANGLES_BY_DEGREE |
"2,1,3\n4,1,3\n2,1,5\n7,3,8\n" |
public static final String |
TRIANGLES_BY_ID |
"1,2,3\n1,3,4\n1,2,5\n3,7,8\n" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
CENTERS_2D_AFTER_20_ITERATIONS_DOUBLE_DIGIT |
"0|15.80|79.42|\n1|43.11|78.20|\n2|83.13|82.18|\n3|65.70|18.49|\n4|25.13|44.42|\n5|82.90|48.16|\n6|20.79|13.08|" |
public static final String |
CENTERS_2D_AFTER_SINGLE_ITERATION_DOUBLE_DIGIT |
"0|13.53|74.53|\n1|49.12|80.49|\n2|87.20|81.83|\n3|67.39|23.32|\n4|26.94|46.34|\n5|88.39|48.64|\n6|23.20|16.71|" |
public static final String |
CENTERS_AFTER_20_ITERATIONS_DOUBLE_DIGIT |
"0|38.25|54.52|19.34|\n1|32.14|83.04|50.35|\n2|87.48|56.57|20.27|\n3|75.40|18.65|67.49|\n4|24.93|29.25|77.56|\n5|78.67|66.07|70.82|\n6|39.51|14.04|18.74|\n" |
public static final String |
CENTERS_AFTER_20_ITERATIONS_SINGLE_DIGIT |
"0|38.3|54.5|19.3|\n1|32.1|83.0|50.4|\n2|87.5|56.6|20.3|\n3|75.4|18.6|67.5|\n4|24.9|29.2|77.6|\n5|78.7|66.1|70.8|\n6|39.5|14.0|18.7|\n" |
public static final String |
CENTERS_AFTER_ONE_STEP |
"0|28.47|54.80|21.88|\n1|52.74|80.10|73.03|\n2|83.92|60.45|25.17|\n3|70.73|20.18|67.06|\n4|22.51|47.19|86.23|\n5|82.70|53.79|68.68|\n6|29.74|19.17|59.16|" |
public static final String |
CENTERS_AFTER_ONE_STEP_SINGLE_DIGIT |
"0|28.5|54.8|21.9|\n1|52.7|80.1|73.0|\n2|83.9|60.5|25.2|\n3|70.7|20.2|67.0|\n4|22.5|47.2|86.2|\n5|82.7|53.8|68.7|\n6|29.7|19.2|59.2|" |
public static final String |
DATAPOINTS |
"0|50.90|16.20|72.08|\n1|73.65|61.76|62.89|\n2|61.73|49.95|92.74|\n3|1.60|70.11|16.32|\n4|2.43|19.81|89.56|\n5|67.99|9.00|14.48|\n6|87.80|84.49|55.83|\n7|90.26|42.99|53.29|\n8|51.36|6.16|9.35|\n9|12.43|9.52|12.54|\n10|80.01|8.78|29.74|\n11|92.76|2.93|80.07|\n12|46.32|100.00|22.98|\n13|34.11|45.61|58.60|\n14|68.82|16.36|96.60|\n15|81.47|76.45|28.40|\n16|65.55|40.21|43.43|\n17|84.22|88.56|13.31|\n18|36.99|68.36|57.12|\n19|28.87|37.69|91.04|\n20|31.56|13.22|86.00|\n21|18.49|34.45|54.52|\n22|13.33|94.02|92.07|\n23|91.19|81.62|55.06|\n24|85.78|39.02|25.58|\n25|94.41|47.07|78.23|\n26|90.62|10.43|80.20|\n27|31.52|85.81|39.79|\n28|24.65|77.98|26.35|\n29|69.34|75.79|63.96|\n30|22.56|78.61|66.66|\n31|91.74|83.82|73.92|\n32|76.64|89.53|44.66|\n33|36.02|73.01|92.32|\n34|87.86|18.94|10.74|\n35|91.94|34.61|5.20|\n36|12.52|47.01|95.29|\n37|44.01|26.19|78.50|\n38|26.20|73.36|10.08|\n39|15.21|17.37|54.33|\n40|27.96|94.81|44.41|\n41|26.44|44.81|70.88|\n42|53.29|26.69|2.40|\n43|23.94|11.50|1.71|\n44|19.00|25.48|50.80|\n45|82.26|1.88|58.08|\n46|47.56|82.54|82.73|\n47|51.54|35.10|32.95|\n48|86.71|55.51|19.08|\n49|54.16|23.68|32.41|\n50|71.81|32.83|46.66|\n51|20.70|14.19|64.96|\n52|57.17|88.56|55.23|\n53|91.39|49.38|70.55|\n54|47.90|62.07|76.03|\n55|55.70|37.77|30.15|\n56|87.87|74.62|25.95|\n57|95.70|45.04|15.27|\n58|41.61|89.37|24.45|\n59|82.19|20.84|11.13|\n60|49.88|2.62|18.62|\n61|16.42|53.30|74.13|\n62|38.37|72.62|35.16|\n63|43.26|49.59|92.56|\n64|28.96|2.36|78.49|\n65|88.41|91.43|92.55|\n66|98.61|79.58|33.03|\n67|4.94|18.65|30.78|\n68|75.89|79.30|63.90|\n69|93.18|76.26|9.50|\n70|73.43|70.50|76.49|\n71|78.64|90.87|34.49|\n72|58.47|63.07|8.82|\n73|69.74|54.36|64.43|\n74|38.47|36.60|33.39|\n75|51.07|14.75|2.54|\n76|24.18|16.85|15.00|\n77|7.56|50.72|93.45|\n78|64.28|97.01|57.31|\n79|85.30|24.13|76.57|\n80|72.78|30.78|13.11|\n81|18.42|17.45|32.20|\n82|87.44|74.98|87.90|\n83|38.30|17.77|37.33|\n84|63.62|7.90|34.23|\n85|8.84|67.87|30.65|\n86|76.12|51.83|80.12|\n87|32.30|74.79|4.39|\n88|41.73|45.34|18.66|\n89|58.13|18.43|83.38|\n90|98.10|33.46|83.07|\n91|17.76|4.10|88.51|\n92|60.58|18.15|59.96|\n93|50.11|33.25|85.64|\n94|97.74|60.93|38.97|\n95|76.31|52.50|95.43|\n96|7.71|85.85|36.26|\n97|9.32|72.21|42.17|\n98|71.29|51.88|57.62|\n99|31.39|7.27|88.74|" |
public static final String |
DATAPOINTS_2D |
"0|50.90|16.20|\n1|73.65|61.76|\n2|61.73|49.95|\n3|1.60|70.11|\n4|2.43|19.81|\n5|67.99|9.00|\n6|87.80|84.49|\n7|90.26|42.99|\n8|51.36|6.16|\n9|12.43|9.52|\n10|80.01|8.78|\n11|92.76|2.93|\n12|46.32|100.00|\n13|34.11|45.61|\n14|68.82|16.36|\n15|81.47|76.45|\n16|65.55|40.21|\n17|84.22|88.56|\n18|36.99|68.36|\n19|28.87|37.69|\n20|31.56|13.22|\n21|18.49|34.45|\n22|13.33|94.02|\n23|91.19|81.62|\n24|85.78|39.02|\n25|94.41|47.07|\n26|90.62|10.43|\n27|31.52|85.81|\n28|24.65|77.98|\n29|69.34|75.79|\n30|22.56|78.61|\n31|91.74|83.82|\n32|76.64|89.53|\n33|36.02|73.01|\n34|87.86|18.94|\n35|91.94|34.61|\n36|12.52|47.01|\n37|44.01|26.19|\n38|26.20|73.36|\n39|15.21|17.37|\n40|27.96|94.81|\n41|26.44|44.81|\n42|53.29|26.69|\n43|23.94|11.50|n44|19.00|25.48|\n45|82.26|1.88|\n46|47.56|82.54|\n47|51.54|35.10|\n48|86.71|55.51|\n49|54.16|23.68|\n50|71.81|32.83|\n51|20.70|14.19|\n52|57.17|88.56|\n53|91.39|49.38|\n54|47.90|62.07|\n55|55.70|37.77|\n56|87.87|74.62|\n57|95.70|45.04|\n58|41.61|89.37|\n59|82.19|20.84|\n60|49.88|2.62|\n61|16.42|53.30|\n62|38.37|72.62|\n63|43.26|49.59|\n64|28.96|2.36|\n65|88.41|91.43|\n66|98.61|79.58|\n67|4.94|18.65|\n68|75.89|79.30|\n69|93.18|76.26|\n70|73.43|70.50|\n71|78.64|90.87|\n72|58.47|63.07|\n73|69.74|54.36|\n74|38.47|36.60|\n75|51.07|14.75|\n76|24.18|16.85|\n77|7.56|50.72|\n78|64.28|97.01|\n79|85.30|24.13|\n80|72.78|30.78|\n81|18.42|17.45|\n82|87.44|74.98|\n83|38.30|17.77|\n84|63.62|7.90|\n85|8.84|67.87|\n86|76.12|51.83|\n87|32.30|74.79|n88|41.73|45.34|\n89|58.13|18.43|\n90|98.10|33.46|\n91|17.76|4.10|\n92|60.58|18.15|\n93|50.11|33.25|\n94|97.74|60.93|\n95|76.31|52.50|\n96|7.71|85.85|\n97|9.32|72.21|\n98|71.29|51.88|\n99|31.39|7.27|" |
public static final String |
INITIAL_CENTERS |
"0|1.96|65.04|20.82|\n1|53.99|84.23|81.59|\n2|97.28|74.50|40.32|\n3|63.57|24.53|87.07|\n4|28.10|43.27|86.53|\n5|99.51|62.70|64.48|\n6|30.31|30.36|80.46|" |
public static final String |
INITIAL_CENTERS_2D |
"0|1.96|65.04|\n1|53.99|84.23|\n2|97.28|74.50|\n3|63.57|24.53|\n4|28.10|43.27|\n5|99.51|62.70|\n6|30.31|30.36|" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
EDGES |
"2 1\n5 2\n5 4\n4 3\n4 2\n1 4\n1 2\n1 3\n3 5\n" |
public static final int |
NUM_VERTICES |
5 |
public static final String |
RANKS_AFTER_3_ITERATIONS |
"1 0.237\n2 0.248\n3 0.173\n4 0.175\n5 0.165" |
public static final String |
RANKS_AFTER_EPSILON_0_0001_CONVERGENCE |
"1 0.238\n2 0.244\n3 0.170\n4 0.171\n5 0.174" |
public static final String |
VERTICES |
"1\n2\n5\n3\n4" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
DOCS |
"url_10|volutpat magna quis consectetuer volutpat ad erat editors exerci oscillations euismod volutpat Lorem convectionullamcorper Lorem volutpat enim tation elit |\nurl_11|adipiscing enim diam ex tincidunt tincidunt nonummy volutpat minim euismod volutpat suscipit ex sed laoreet aliquip quis diam tincidunt wisi diam elit sed ut minim ad nonummy amet volutpat nostrud erat |\nurl_12|ut nostrud adipiscing adipiscing ipsum nonummy amet volutpat volutpat sit enim Ut amet |\nurl_13|euismod sit adipiscing ex suscipit ea veniam tincidunt laoreet nibh editors ullamcorper consectetuer convection commodo sed nostrud ea ex ullamcorper dolor dolore ad diam dolore amet ut tincidunt nonummy euismod enim ullamcorper tincidunt dolor sit volutpat dolor tincidunt aliquam nisl tation ullamcorper sed consectetuer sit sit laoreet ex |\nurl_14|ad magna ipsum nonummy aliquip dolore aliquam veniam lobortis nostrud aliquip nibh amet aliquam editors magna aliquam volutpat nonummy sed tation erat adipiscing nostrud magna ut sit dolore volutpat laoreet nisl wisi Ut veniam nibh laoreet ad nostrud ut aliquip |\nurl_15|enim ipsum veniam ex editor Lorem elit laoreet exerci ea wisi oscillations convection euismod euismod diam ut euismod ad Lorem ut Ut tation wisi diam suscipit nibh nostrud minim dolor |\nurl_16|tation ad sed veniam lobortis editor nonummy Ut ea ipsum aliquip dolore ut laoreet tation ad ut Lorem ipsum minim nostrud quis Lorem enim |\nurl_17|veniam editor veniam Lorem aliquam ipsum amet ut convection veniam enim commodo ad ex magna nibh Ut ex sed ut nostrud amet volutpat nibh Ut wisi ea laoreet Lorem amet minim ullamcorper tincidunt veniam laoreet laoreet |\nurl_18|veniam diam tincidunt ullamcorper adipiscing oscillations adipiscing aliquip quis nibh suscipit ex sit sit wisi diam aliquam aliquip ea diam euismod ad erat ut ipsum lobortis ea exerci |\nurl_19|adipiscing nisl oscillations ea editors tincidunt tation convection tincidunt tincidunt ut wisi tincidunt ut ut Ut nibh aliquam laoreet exerci enim ea nibh erat nonummy |\nurl_20|ut diam aliquip ipsum laoreet elit volutpat suscipit nostrud convection tation nisl suscipit nonummy tation tation ut enim dolor nisl magna aliquam enim consectetuer sed tincidunt quis amet elit |\nurl_21|tation ad exerci volutpat tincidunt sit ullamcorper oscillations ut minim sed diam Lorem adipiscing |\nurl_22|sit exerci ad ut minim convection ad ea dolore Lorem ipsum amet sit wisi sed ullamcorper ipsum enim aliquam tincidunt elit nonummy laoreet laoreet dolore tation ullamcorper commodo Ut elit sit minim suscipit nisl laoreet |\nurl_23|Lorem nibh ea ea ex ut tation euismod tincidunt lobortis enim ullamcorper euismod amet magna sit erat enim editor diam dolor volutpat diam nisl ut erat commodo amet veniam consectetuer ex commodo sed magna ea erat ullamcorper dolor sed diam enim euismod |\nurl_24|nisl dolor magna editors ad consectetuer veniam commodo Ut dolor wisi dolore amet dolore dolore volutpat convection Ut oscillations |\nurl_25|ut euismod quis ad nostrud volutpat dolor wisi oscillations nostrud sed nonummy wisi exerci convection sed erat nostrud quis editors Ut nostrud consectetuer aliquip exerci ut Ut tincidunt aliquam suscipit erat |\nurl_26|nisl elit ea minim aliquam dolor consectetuer consectetuer quis Ut convection laoreet sit enim nostrud sed dolor magna dolor elit adipiscing |\nurl_27|nisl euismod ipsum ex adipiscing erat euismod diam quis oscillations aliquip nisl ut sit dolor wisi enim tincidunt amet ullamcorper adipiscing nibh Ut volutpat sed nonummy ex ea wisi exerci aliquam elit Ut aliquip nostrud ad nibh ut sit suscipit ut commodo wisi Lorem nibh |\nurl_28|laoreet sed editor dolor diam convection sed diam exerci laoreet oscillations consectetuer ullamcorper suscipit ut editors quis commodo editor veniam nibh ea diam ex magna ea elit sit sed nibh lobortis consectetuer erat erat sit minim ea ad ea nisl magna volutpat ut |\nurl_29|consectetuer convection amet diam erat euismod erat editor oscillations ipsum tation tation editors minim wisi tation quis adipiscing euismod nonummy erat ut diam suscipit tincidunt ut consectetuer Lorem editor sit quis euismod veniam tincidunt aliquam ut veniam adipiscing magna Ut ut dolore euismod minim veniam |" |
public static final String |
EXCEPTED_RESULT |
"87|url_24|39\n59|url_28|41\n" |
public static final String |
RANKS |
"77|url_10|51|\n7|url_11|24|\n19|url_12|28|\n13|url_13|50|\n81|url_14|41|\n87|url_15|28|\n78|url_16|29|\n70|url_17|7|\n91|url_18|38|\n99|url_19|11|\n37|url_20|46|\n64|url_21|46|\n25|url_22|14|\n6|url_23|12|\n87|url_24|39|\n0|url_25|27|\n97|url_26|27|\n9|url_27|54|\n59|url_28|41|\n40|url_29|11|" |
public static final String |
VISITS |
"112.99.215.248|url_20|2011-5-1|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n189.69.147.166|url_19|2009-8-2|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n83.7.97.153|url_21|2010-3-20|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n215.57.124.59|url_10|2008-1-26|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n174.176.121.10|url_25|2007-12-17|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n66.225.121.11|url_16|2007-10-8|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n57.11.211.126|url_14|2010-12-6|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n129.127.115.129|url_28|2009-2-5|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n137.249.175.115|url_27|2011-5-7|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n101.92.9.112|url_12|2012-1-10|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n113.108.207.12|url_24|2011-3-20|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n179.141.87.220|url_18|2007-10-3|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n46.10.118.101|url_20|2009-7-4|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n91.67.84.155|url_20|2012-7-7|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n102.142.34.164|url_22|2010-7-18|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n203.67.94.61|url_14|2007-7-27|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n229.121.13.143|url_19|2010-4-17|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n209.154.189.12|url_16|2011-4-24|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n57.113.29.197|url_13|2008-9-23|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n132.90.139.12|url_16|2007-10-17|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n101.21.109.146|url_29|2009-2-24|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n171.69.34.255|url_29|2009-2-1|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n11.114.192.13|url_25|2008-9-8|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n37.188.212.141|url_15|2011-1-21|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n102.40.251.47|url_26|2010-7-17|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n136.85.230.245|url_17|2010-8-12|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n68.96.194.82|url_29|2007-10-12|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n62.126.40.210|url_29|2011-2-13|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n12.81.184.191|url_11|2008-1-12|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n12.232.205.52|url_18|2008-1-26|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n227.83.79.30|url_25|2008-6-4|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n88.222.17.152|url_21|2007-10-1|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n55.87.23.63|url_22|2008-8-16|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n54.41.77.25|url_18|2012-12-18|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n203.83.250.233|url_10|2009-4-5|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n42.13.134.196|url_15|2012-9-23|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n224.51.182.133|url_27|2008-11-13|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n180.209.212.98|url_27|2008-6-27|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n29.173.47.29|url_24|2011-9-18|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n251.153.164.73|url_18|2008-3-6|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n195.164.244.58|url_23|2010-12-21|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n96.167.244.51|url_18|2007-2-10|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n131.169.48.126|url_19|2009-6-10|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n171.151.109.83|url_12|2011-6-24|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n150.87.176.48|url_22|2008-10-3|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n56.172.201.54|TPCHQuery3ITCaseurl_25|2012-11-3|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n175.241.83.44|url_13|2008-2-22|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n105.222.1.251|url_18|2012-7-6|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n195.117.130.95|url_10|2012-4-24|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n10.139.236.176|url_14|2011-4-9|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n207.100.168.191|url_22|2007-5-1|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n196.129.126.177|url_25|2008-4-2|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n170.239.116.200|url_27|2010-3-15|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n99.79.118.85|url_13|2008-3-12|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n112.65.132.135|url_15|2010-8-3|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n109.15.235.196|url_14|2012-8-25|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n240.201.229.137|url_21|2008-9-22|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n74.53.245.171|url_18|2007-6-19|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n158.230.101.250|url_17|2011-4-17|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n198.197.213.210|url_11|2012-5-1|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n1.54.145.90|url_11|2009-6-16|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n2.236.14.86|url_13|2007-9-7|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n203.180.186.150|url_16|2010-2-17|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n135.83.247.101|url_22|2007-12-7|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n54.214.72.16|url_12|2007-5-2|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n238.115.186.34|url_10|2007-5-24|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n6.251.55.92|url_26|2007-5-18|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n196.96.11.111|url_16|2007-11-7|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n209.40.86.220|url_24|2009-5-17|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n130.208.66.140|url_19|2011-9-22|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n176.157.170.178|url_27|2008-12-12|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n103.4.119.128|url_15|2010-6-19|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n31.181.160.159|url_12|2009-8-10|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n166.238.60.79|url_23|2009-2-1|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n64.165.114.139|url_19|2007-9-17|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n11.45.238.55|url_26|2011-8-17|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n189.121.92.228|url_18|2008-1-16|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n137.114.181.208|url_14|2007-6-15|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n165.194.234.136|url_18|2012-3-7|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n210.145.85.234|url_10|2007-9-3|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n227.37.135.138|url_21|2010-5-4|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n39.87.120.86|url_25|2007-2-6|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n107.144.159.246|url_11|2010-7-6|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n160.38.166.236|url_15|2009-6-18|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n79.44.39.160|url_10|2008-12-19|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n143.52.62.175|url_19|2011-12-8|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n68.54.137.193|url_19|2007-6-6|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n199.137.128.158|url_27|2008-4-26|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n10.0.80.61|url_10|2011-3-15|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n4.30.48.164|url_29|2007-2-26|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n136.29.50.223|url_12|2008-3-5|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n83.101.200.110|url_23|2009-1-26|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n11.149.83.246|url_29|2010-9-18|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n154.119.20.134|url_14|2011-1-4|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n191.124.167.123|url_15|2009-6-24|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n27.158.167.38|url_11|2011-5-16|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n16.197.156.206|url_16|2009-2-1|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n222.150.206.233|url_20|2012-2-11|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n198.59.29.225|url_21|2007-2-25|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n182.91.244.40|url_18|2010-5-7|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n23.110.45.72|url_28|2008-6-23|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n94.241.8.36|url_11|2007-7-4|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n226.223.202.210|url_17|2007-10-15|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n73.16.194.132|url_14|2012-7-2|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n195.45.98.110|url_13|2012-2-23|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n189.123.80.178|url_29|2011-1-1|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n190.134.174.18|url_23|2011-12-17|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n133.54.252.245|url_13|2011-3-13|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n244.29.167.182|url_18|2012-10-11|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n125.32.251.232|url_26|2010-4-22|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n74.139.30.20|url_16|2012-2-8|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n100.73.180.209|url_29|2010-4-4|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n133.155.158.147|url_16|2011-11-22|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n185.53.212.102|url_15|2010-12-19|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n154.189.125.92|url_27|2007-10-5|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n12.209.166.107|url_26|2007-5-1|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n106.99.152.22|url_25|2011-12-4|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n37.120.32.53|url_22|2008-12-8|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n29.17.125.185|url_12|2011-8-18|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n233.125.12.14|url_19|2011-2-7|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n241.78.212.114|url_25|2007-12-22|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n153.183.247.90|url_18|2011-9-23|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n245.43.17.177|url_15|2012-4-21|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n55.13.54.220|url_24|2008-11-17|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n104.149.82.217|url_10|2011-9-26|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n36.15.167.145|url_24|2008-1-9|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n145.149.81.203|url_20|2008-5-27|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n68.89.4.115|url_18|2007-7-17|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n236.88.134.53|url_15|2010-5-2|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n180.140.58.209|url_29|2012-8-5|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n138.46.241.237|url_17|2010-11-13|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n254.217.79.58|url_29|2007-1-11|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n142.184.197.136|url_10|2007-11-3|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n216.118.94.220|url_12|2007-2-18|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n53.99.54.0|url_14|2008-3-9|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n95.151.221.37|url_28|2009-5-2|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n46.110.43.78|url_27|2007-11-9|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n172.96.203.180|url_11|2012-1-17|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n22.188.231.143|url_21|2007-10-23|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n216.46.80.239|url_22|2009-9-18|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n103.213.7.86|url_26|2007-12-25|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n186.204.3.180|url_27|2012-1-22|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n129.197.116.192|url_10|2012-5-1|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n8.164.181.242|url_24|2008-11-17|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n145.52.12.132|url_28|2012-8-6|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n20.22.62.146|url_11|2007-4-27|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n233.255.32.151|url_19|2008-6-25|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n31.233.226.148|url_24|2011-8-4|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n57.130.120.117|url_25|2008-12-9|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n29.98.249.152|url_21|2011-8-7|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n25.187.66.122|url_20|2008-12-17|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n236.205.44.215|url_26|2008-9-13|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n18.40.99.157|url_23|2012-1-7|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n204.221.88.206|url_24|2012-11-8|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n199.5.94.240|url_24|2011-9-24|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n57.175.34.24|url_14|2009-12-10|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n130.25.116.220|url_10|2007-6-5|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n134.174.12.250|url_22|2011-6-22|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n162.185.114.212|url_13|2011-8-24|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n8.113.137.95|url_14|2011-6-22|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n176.253.5.99|url_12|2010-4-12|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n3.110.24.0|url_12|2009-6-18|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n159.128.152.207|url_17|2012-2-2|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n104.145.150.244|url_10|2012-2-13|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n203.19.224.207|url_12|2012-9-24|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n225.163.125.108|url_20|2010-4-8|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n197.137.29.71|url_21|2007-10-25|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n29.207.144.144|url_12|2012-7-13|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n139.222.222.113|url_14|2010-4-15|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n169.225.20.141|url_29|2012-2-18|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n137.86.141.104|url_26|2012-3-10|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n193.100.2.122|url_24|2011-12-15|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n20.105.209.161|url_13|2010-2-7|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n116.81.52.207|url_11|2007-4-13|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n141.88.224.116|url_19|2009-4-12|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n72.198.58.37|url_26|2012-2-2|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n13.37.92.90|url_22|2011-5-16|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n191.163.173.142|url_24|2012-5-2|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n183.57.175.105|url_27|2007-8-13|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n230.212.34.87|url_10|2010-12-21|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n133.150.217.96|url_24|2012-7-27|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n62.254.96.239|url_24|2011-5-15|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
COUNTS |
"machen 1\nzeit 2\nheerscharen 1\nkeiner 2\nmeine 3\nfuehr 1\ntriumph 1\nkommst 1\nfrei 1\nschaffen 1\ngesinde 1\nlangbeinigen 1\nschalk 1\nbesser 1\nsolang 1\nmeer 4\nfragst 1\ngabriel 1\nselbst 2\nbin 1\nsich 7\ndu 11\nsogar 1\ngeht 1\nimmer 4\nmensch 2\nbefestigt 1\nlebt 2\nmag 3\nengeln 2\nbreiten 1\nblitzendes 1\ntags 1\nsie 2\nplagen 2\nallzu 1\nmeisten 1\no 1\npfade 1\nkennst 1\nnichts 3\ngedanken 1\nbefriedigt 1\nmich 6\ns 3\nes 8\nverneinen 1\ner 13\ngleich 1\nbaeumchen 1\ndonnergang 1\nwunderlich 1\nreise 1\nurquell 1\ndoch 3\naufs 2\ntoten 1\nniemals 1\neine 2\nhab 1\ndarfst 1\nda 5\ngen 1\neinem 2\nteil 1\ndas 7\nspeise 1\nwenig 1\nsterne 1\ngeb 1\nwelten 1\nalle 3\ntoent 1\ngras 1\nfelsen 1\nkette 1\nich 14\nfuer 2\nals 3\nmein 1\nschoene 1\nverzeih 1\nschwankender 1\nwie 9\nmenschlich 1\ngaertner 1\ntaetigkeit 1\nbange 1\nliebe 1\nsei 2\nseh 1\ntollheit 1\nam 6\nmichael 1\ngeist 1\nab 1\nnahst 1\nvollendet 1\nliebt 1\nbrausen 1\nnase 1\nerlaubt 1\nweiss 2\nschnellem 1\ndeinem 1\ngleichem 1\ngaerung 1\ndauernden 1\ndeines 1\nvorgeschriebne 1\nirdisch 1\nworte 1\nverehren 1\nhohen 2\nweise 2\nkuenft 1\nwerdende 1\nwette 2\nwuetend 1\nerscheinung 1\ngar 2\nverlieren 1\nbraucht 1\nweiter 1\ntrank 1\ntierischer 1\nwohl 1\nverteilen 1\nverhoehnt 1\nschaeumt 1\nhimmelslichts 1\nunbedingte 1\nherzlich 1\nanblick 2\nnennt 1\ngruent 1\nbluet 1\nleichnam 1\nerschlaffen 1\njammertagen 1\nzieh 1\nihm 3\nbesondre 1\nihn 5\ngrossen 1\nvollen 1\nihr 7\nboten 1\nvoller 1\nsingt 1\nmuhme 1\nschon 1\nlast 1\nkleine 1\nparadieseshelle 1\nnein 1\nechten 1\nunter 1\nbei 1\nherr 11\ngern 3\nsphaerenlauf 1\nstets 1\nganze 1\nbraechte 1\nfordert 1\nschoensten 1\nherrlich 2\ngegeben 1\nallein 2\nreichen 1\nschauervoller 1\nmusst 1\nrecht 1\nbleibt 1\npracht 1\ntreibt 1\nbefangen 1\nwas 2\nmenschen 3\njede 1\nhohe 1\ntiefsten 1\nbilden 1\ndrum 1\ngibt 2\nguter 1\nfuerwahr 1\nim 3\ngrund 1\nin 9\nhoechste 1\nschliesst 1\nfels 1\nsteh 1\neuer 1\nerster 1\nersten 3\ngoettersoehne 1\nbrechen 1\ntiefen 1\nfrucht 1\nkreis 1\nsiehst 1\nwege 1\nist 8\nzikaden 1\nfrischen 1\nruh 1\ndeine 2\nmaus 1\nbrudersphaeren 1\nnachher 1\neuch 4\ngnaden 1\nanzuklagen 1\nschlange 1\nstaerke 2\nerde 4\nverlaub 1\nsanfte 1\nholden 1\nsonst 1\ntreten 1\nsahst 1\nalten 1\num 1\nwieder 1\nalter 1\naltes 1\nnun 1\nlieb 1\ngesellen 1\nerscheinen 1\nwirkt 2\nhaettst 2\nnur 7\ntiefbewegte 1\nlachen 2\ndrange 1\nschlag 1\nschein 1\nmuss 1\nverworren 1\nweges 1\nallen 1\ngewoehnlich 1\nalles 1\nhalb 1\nstuerme 1\nspringt 1\nsollt 1\nklarheit 1\nso 6\nerfassen 1\nliedchen 1\nprolog 1\nzur 1\nfressen 1\nzum 1\nfaust 2\nerzengel 2\njahre 1\nsonn 1\nraphael 1\nland 2\nlang 1\ngelange 1\nlust 2\nwelt 1\nsehe 1\nihre 1\njedes 1\nerfreut 1\nseiner 1\ndenn 1\nwandeln 1\nwechselt 1\njeden 1\ndort 1\nschlecht 1\nwenigsten 1\nwuerd 1\nschranken 1\nbewusst 2\nseinem 2\ngehasst 1\nsein 1\nmeinem 1\nmeinen 1\npathos 1\nherrn 1\nlange 2\nherab 1\ndiesen 1\nihren 1\nberuehmte 1\ngoethe 1\ntag 3\ntier 1\nquark 1\ndank 1\nseine 1\nteufel 2\nzweck 1\nwenn 7\nsoll 1\nwirkung 1\nerlaubnis 1\nlebendig 1\nuns 1\nleicht 1\ngewiss 1\nschnell 1\nund 29\ngerne 1\nrechten 1\numher 2\nvernunft 1\ngrase 1\nnach 1\nleben 1\ngott 1\nder 29\ndes 5\ndoktor 1\nbeschaemt 1\ndreht 1\nhabe 1\nsagen 2\nbekennen 1\ndunklen 1\nwettet 1\nden 9\nmephistopheles 9\ndem 4\nauch 4\nkann 2\narmen 1\nmir 9\nstrebt 1\ngut 2\nmit 11\nbald 2\nhimmlischen 1\nhimmel 3\nnoch 3\nkannst 1\ndeinesgleichen 1\nflammt 1\nergruenden 2\nnacht 1\nscheint 1\nferne 2\ntragoedie 1\nabgewoehnt 1\nreizt 1\ngeistern 1\nnicht 10\nsacht 1\nunbegreiflich 2\nschnelle 1\neinmal 1\nwerd 1\nwerke 2\nbegraebt 1\nknecht 1\nrings 1\nwird 1\nkatze 1\nhuete 1\nfortgerissen 1\ngebt 1\nhuebsch 1\nhast 1\nirrt 1\nbefinde 1\nsind 2\nfuehren 2\nfliegt 1\newig 3\nbrust 2\nsonne 1\nsprechen 1\nein 3\nstrasse 1\nvon 8\nueberlassen 1\ndir 4\nvom 3\nzu 11\nschwebt 1\ndie 22\nvor 2\nwangen 1\nwettgesang 1\ndonnerschlags 1\nfind 1\ndich 3\numfass 1\nverboten 1\nlaeg 1\nnie 1\ndrei 2\ndauern 1\ntoren 1\ndauert 1\nverheeren 1\nfliegend 1\naus 1\nstaub 1\nfluessen 1\nhaus 1\nauf 5\ndient 2\ntiefer 1\nnaeh 1\nzieren 1\n" |
public static final String |
COUNTS_AS_TUPLES |
"(machen,1)\n(zeit,2)\n(heerscharen,1)\n(keiner,2)\n(meine,3)\n(fuehr,1)\n(triumph,1)\n(kommst,1)\n(frei,1)\n(schaffen,1)\n(gesinde,1)\n(langbeinigen,1)\n(schalk,1)\n(besser,1)\n(solang,1)\n(meer,4)\n(fragst,1)\n(gabriel,1)\n(selbst,2)\n(bin,1)\n(sich,7)\n(du,11)\n(sogar,1)\n(geht,1)\n(immer,4)\n(mensch,2)\n(befestigt,1)\n(lebt,2)\n(mag,3)\n(engeln,2)\n(breiten,1)\n(blitzendes,1)\n(tags,1)\n(sie,2)\n(plagen,2)\n(allzu,1)\n(meisten,1)\n(o,1)\n(pfade,1)\n(kennst,1)\n(nichts,3)\n(gedanken,1)\n(befriedigt,1)\n(mich,6)\n(s,3)\n(es,8)\n(verneinen,1)\n(er,13)\n(gleich,1)\n(baeumchen,1)\n(donnergang,1)\n(wunderlich,1)\n(reise,1)\n(urquell,1)\n(doch,3)\n(aufs,2)\n(toten,1)\n(niemals,1)\n(eine,2)\n(hab,1)\n(darfst,1)\n(da,5)\n(gen,1)\n(einem,2)\n(teil,1)\n(das,7)\n(speise,1)\n(wenig,1)\n(sterne,1)\n(geb,1)\n(welten,1)\n(alle,3)\n(toent,1)\n(gras,1)\n(felsen,1)\n(kette,1)\n(ich,14)\n(fuer,2)\n(als,3)\n(mein,1)\n(schoene,1)\n(verzeih,1)\n(schwankender,1)\n(wie,9)\n(menschlich,1)\n(gaertner,1)\n(taetigkeit,1)\n(bange,1)\n(liebe,1)\n(sei,2)\n(seh,1)\n(tollheit,1)\n(am,6)\n(michael,1)\n(geist,1)\n(ab,1)\n(nahst,1)\n(vollendet,1)\n(liebt,1)\n(brausen,1)\n(nase,1)\n(erlaubt,1)\n(weiss,2)\n(schnellem,1)\n(deinem,1)\n(gleichem,1)\n(gaerung,1)\n(dauernden,1)\n(deines,1)\n(vorgeschriebne,1)\n(irdisch,1)\n(worte,1)\n(verehren,1)\n(hohen,2)\n(weise,2)\n(kuenft,1)\n(werdende,1)\n(wette,2)\n(wuetend,1)\n(erscheinung,1)\n(gar,2)\n(verlieren,1)\n(braucht,1)\n(weiter,1)\n(trank,1)\n(tierischer,1)\n(wohl,1)\n(verteilen,1)\n(verhoehnt,1)\n(schaeumt,1)\n(himmelslichts,1)\n(unbedingte,1)\n(herzlich,1)\n(anblick,2)\n(nennt,1)\n(gruent,1)\n(bluet,1)\n(leichnam,1)\n(erschlaffen,1)\n(jammertagen,1)\n(zieh,1)\n(ihm,3)\n(besondre,1)\n(ihn,5)\n(grossen,1)\n(vollen,1)\n(ihr,7)\n(boten,1)\n(voller,1)\n(singt,1)\n(muhme,1)\n(schon,1)\n(last,1)\n(kleine,1)\n(paradieseshelle,1)\n(nein,1)\n(echten,1)\n(unter,1)\n(bei,1)\n(herr,11)\n(gern,3)\n(sphaerenlauf,1)\n(stets,1)\n(ganze,1)\n(braechte,1)\n(fordert,1)\n(schoensten,1)\n(herrlich,2)\n(gegeben,1)\n(allein,2)\n(reichen,1)\n(schauervoller,1)\n(musst,1)\n(recht,1)\n(bleibt,1)\n(pracht,1)\n(treibt,1)\n(befangen,1)\n(was,2)\n(menschen,3)\n(jede,1)\n(hohe,1)\n(tiefsten,1)\n(bilden,1)\n(drum,1)\n(gibt,2)\n(guter,1)\n(fuerwahr,1)\n(im,3)\n(grund,1)\n(in,9)\n(hoechste,1)\n(schliesst,1)\n(fels,1)\n(steh,1)\n(euer,1)\n(erster,1)\n(ersten,3)\n(goettersoehne,1)\n(brechen,1)\n(tiefen,1)\n(frucht,1)\n(kreis,1)\n(siehst,1)\n(wege,1)\n(ist,8)\n(zikaden,1)\n(frischen,1)\n(ruh,1)\n(deine,2)\n(maus,1)\n(brudersphaeren,1)\n(nachher,1)\n(euch,4)\n(gnaden,1)\n(anzuklagen,1)\n(schlange,1)\n(staerke,2)\n(erde,4)\n(verlaub,1)\n(sanfte,1)\n(holden,1)\n(sonst,1)\n(treten,1)\n(sahst,1)\n(alten,1)\n(um,1)\n(wieder,1)\n(alter,1)\n(altes,1)\n(nun,1)\n(lieb,1)\n(gesellen,1)\n(erscheinen,1)\n(wirkt,2)\n(haettst,2)\n(nur,7)\n(tiefbewegte,1)\n(lachen,2)\n(drange,1)\n(schlag,1)\n(schein,1)\n(muss,1)\n(verworren,1)\n(weges,1)\n(allen,1)\n(gewoehnlich,1)\n(alles,1)\n(halb,1)\n(stuerme,1)\n(springt,1)\n(sollt,1)\n(klarheit,1)\n(so,6)\n(erfassen,1)\n(liedchen,1)\n(prolog,1)\n(zur,1)\n(fressen,1)\n(zum,1)\n(faust,2)\n(erzengel,2)\n(jahre,1)\n(sonn,1)\n(raphael,1)\n(land,2)\n(lang,1)\n(gelange,1)\n(lust,2)\n(welt,1)\n(sehe,1)\n(ihre,1)\n(jedes,1)\n(erfreut,1)\n(seiner,1)\n(denn,1)\n(wandeln,1)\n(wechselt,1)\n(jeden,1)\n(dort,1)\n(schlecht,1)\n(wenigsten,1)\n(wuerd,1)\n(schranken,1)\n(bewusst,2)\n(seinem,2)\n(gehasst,1)\n(sein,1)\n(meinem,1)\n(meinen,1)\n(pathos,1)\n(herrn,1)\n(lange,2)\n(herab,1)\n(diesen,1)\n(ihren,1)\n(beruehmte,1)\n(goethe,1)\n(tag,3)\n(tier,1)\n(quark,1)\n(dank,1)\n(seine,1)\n(teufel,2)\n(zweck,1)\n(wenn,7)\n(soll,1)\n(wirkung,1)\n(erlaubnis,1)\n(lebendig,1)\n(uns,1)\n(leicht,1)\n(gewiss,1)\n(schnell,1)\n(und,29)\n(gerne,1)\n(rechten,1)\n(umher,2)\n(vernunft,1)\n(grase,1)\n(nach,1)\n(leben,1)\n(gott,1)\n(der,29)\n(des,5)\n(doktor,1)\n(beschaemt,1)\n(dreht,1)\n(habe,1)\n(sagen,2)\n(bekennen,1)\n(dunklen,1)\n(wettet,1)\n(den,9)\n(mephistopheles,9)\n(dem,4)\n(auch,4)\n(kann,2)\n(armen,1)\n(mir,9)\n(strebt,1)\n(gut,2)\n(mit,11)\n(bald,2)\n(himmlischen,1)\n(himmel,3)\n(noch,3)\n(kannst,1)\n(deinesgleichen,1)\n(flammt,1)\n(ergruenden,2)\n(nacht,1)\n(scheint,1)\n(ferne,2)\n(tragoedie,1)\n(abgewoehnt,1)\n(reizt,1)\n(geistern,1)\n(nicht,10)\n(sacht,1)\n(unbegreiflich,2)\n(schnelle,1)\n(einmal,1)\n(werd,1)\n(werke,2)\n(begraebt,1)\n(knecht,1)\n(rings,1)\n(wird,1)\n(katze,1)\n(huete,1)\n(fortgerissen,1)\n(gebt,1)\n(huebsch,1)\n(hast,1)\n(irrt,1)\n(befinde,1)\n(sind,2)\n(fuehren,2)\n(fliegt,1)\n(ewig,3)\n(brust,2)\n(sonne,1)\n(sprechen,1)\n(ein,3)\n(strasse,1)\n(von,8)\n(ueberlassen,1)\n(dir,4)\n(vom,3)\n(zu,11)\n(schwebt,1)\n(die,22)\n(vor,2)\n(wangen,1)\n(wettgesang,1)\n(donnerschlags,1)\n(find,1)\n(dich,3)\n(umfass,1)\n(verboten,1)\n(laeg,1)\n(nie,1)\n(drei,2)\n(dauern,1)\n(toren,1)\n(dauert,1)\n(verheeren,1)\n(fliegend,1)\n(aus,1)\n(staub,1)\n(fluessen,1)\n(haus,1)\n(auf,5)\n(dient,2)\n(tiefer,1)\n(naeh,1)\n(zieren,1)\n" |
public static final String |
STREAMING_COUNTS_AS_TUPLES |
"(machen,1)\n(zeit,1)\n(zeit,2)\n(heerscharen,1)\n(keiner,1)\n(keiner,2)\n(meine,1)\n(meine,2)\n(meine,3)\n(fuehr,1)\n(triumph,1)\n(kommst,1)\n(frei,1)\n(schaffen,1)\n(gesinde,1)\n(langbeinigen,1)\n(schalk,1)\n(besser,1)\n(solang,1)\n(meer,1)\n(meer,2)\n(meer,3)\n(meer,4)\n(fragst,1)\n(gabriel,1)\n(selbst,1)\n(selbst,2)\n(bin,1)\n(sich,1)\n(sich,2)\n(sich,3)\n(sich,4)\n(sich,5)\n(sich,6)\n(sich,7)\n(du,1)\n(du,2)\n(du,3)\n(du,4)\n(du,5)\n(du,6)\n(du,7)\n(du,8)\n(du,9)\n(du,10)\n(du,11)\n(sogar,1)\n(geht,1)\n(immer,1)\n(immer,2)\n(immer,3)\n(immer,4)\n(mensch,1)\n(mensch,2)\n(befestigt,1)\n(lebt,1)\n(lebt,2)\n(mag,1)\n(mag,2)\n(mag,3)\n(engeln,1)\n(engeln,2)\n(breiten,1)\n(blitzendes,1)\n(tags,1)\n(sie,1)\n(sie,2)\n(plagen,1)\n(plagen,2)\n(allzu,1)\n(meisten,1)\n(o,1)\n(pfade,1)\n(kennst,1)\n(nichts,1)\n(nichts,2)\n(nichts,3)\n(gedanken,1)\n(befriedigt,1)\n(mich,1)\n(mich,2)\n(mich,3)\n(mich,4)\n(mich,5)\n(mich,6)\n(s,1)\n(s,2)\n(s,3)\n(es,1)\n(es,2)\n(es,3)\n(es,4)\n(es,5)\n(es,6)\n(es,7)\n(es,8)\n(verneinen,1)\n(er,1)\n(er,2)\n(er,3)\n(er,4)\n(er,5)\n(er,6)\n(er,7)\n(er,8)\n(er,9)\n(er,10)\n(er,11)\n(er,12)\n(er,13)\n(gleich,1)\n(baeumchen,1)\n(donnergang,1)\n(wunderlich,1)\n(reise,1)\n(urquell,1)\n(doch,1)\n(doch,2)\n(doch,3)\n(aufs,1)\n(aufs,2)\n(toten,1)\n(niemals,1)\n(eine,1)\n(eine,2)\n(hab,1)\n(darfst,1)\n(da,1)\n(da,2)\n(da,3)\n(da,4)\n(da,5)\n(gen,1)\n(einem,1)\n(einem,2)\n(teil,1)\n(das,1)\n(das,2)\n(das,3)\n(das,4)\n(das,5)\n(das,6)\n(das,7)\n(speise,1)\n(wenig,1)\n(sterne,1)\n(geb,1)\n(welten,1)\n(alle,1)\n(alle,2)\n(alle,3)\n(toent,1)\n(gras,1)\n(felsen,1)\n(kette,1)\n(ich,1)\n(ich,2)\n(ich,3)\n(ich,4)\n(ich,5)\n(ich,6)\n(ich,7)\n(ich,8)\n(ich,9)\n(ich,10)\n(ich,11)\n(ich,12)\n(ich,13)\n(ich,14)\n(fuer,1)\n(fuer,2)\n(als,1)\n(als,2)\n(als,3)\n(mein,1)\n(schoene,1)\n(verzeih,1)\n(schwankender,1)\n(wie,1)\n(wie,2)\n(wie,3)\n(wie,4)\n(wie,5)\n(wie,6)\n(wie,7)\n(wie,8)\n(wie,9)\n(menschlich,1)\n(gaertner,1)\n(taetigkeit,1)\n(bange,1)\n(liebe,1)\n(sei,1)\n(sei,2)\n(seh,1)\n(tollheit,1)\n(am,1)\n(am,2)\n(am,3)\n(am,4)\n(am,5)\n(am,6)\n(michael,1)\n(geist,1)\n(ab,1)\n(nahst,1)\n(vollendet,1)\n(liebt,1)\n(brausen,1)\n(nase,1)\n(erlaubt,1)\n(weiss,1)\n(weiss,2)\n(schnellem,1)\n(deinem,1)\n(gleichem,1)\n(gaerung,1)\n(dauernden,1)\n(deines,1)\n(vorgeschriebne,1)\n(irdisch,1)\n(worte,1)\n(verehren,1)\n(hohen,1)\n(hohen,2)\n(weise,1)\n(weise,2)\n(kuenft,1)\n(werdende,1)\n(wette,1)\n(wette,2)\n(wuetend,1)\n(erscheinung,1)\n(gar,1)\n(gar,2)\n(verlieren,1)\n(braucht,1)\n(weiter,1)\n(trank,1)\n(tierischer,1)\n(wohl,1)\n(verteilen,1)\n(verhoehnt,1)\n(schaeumt,1)\n(himmelslichts,1)\n(unbedingte,1)\n(herzlich,1)\n(anblick,1)\n(anblick,2)\n(nennt,1)\n(gruent,1)\n(bluet,1)\n(leichnam,1)\n(erschlaffen,1)\n(jammertagen,1)\n(zieh,1)\n(ihm,1)\n(ihm,2)\n(ihm,3)\n(besondre,1)\n(ihn,1)\n(ihn,2)\n(ihn,3)\n(ihn,4)\n(ihn,5)\n(grossen,1)\n(vollen,1)\n(ihr,1)\n(ihr,2)\n(ihr,3)\n(ihr,4)\n(ihr,5)\n(ihr,6)\n(ihr,7)\n(boten,1)\n(voller,1)\n(singt,1)\n(muhme,1)\n(schon,1)\n(last,1)\n(kleine,1)\n(paradieseshelle,1)\n(nein,1)\n(echten,1)\n(unter,1)\n(bei,1)\n(herr,1)\n(herr,2)\n(herr,3)\n(herr,4)\n(herr,5)\n(herr,6)\n(herr,7)\n(herr,8)\n(herr,9)\n(herr,10)\n(herr,11)\n(gern,1)\n(gern,2)\n(gern,3)\n(sphaerenlauf,1)\n(stets,1)\n(ganze,1)\n(braechte,1)\n(fordert,1)\n(schoensten,1)\n(herrlich,1)\n(herrlich,2)\n(gegeben,1)\n(allein,1)\n(allein,2)\n(reichen,1)\n(schauervoller,1)\n(musst,1)\n(recht,1)\n(bleibt,1)\n(pracht,1)\n(treibt,1)\n(befangen,1)\n(was,1)\n(was,2)\n(menschen,1)\n(menschen,2)\n(menschen,3)\n(jede,1)\n(hohe,1)\n(tiefsten,1)\n(bilden,1)\n(drum,1)\n(gibt,1)\n(gibt,2)\n(guter,1)\n(fuerwahr,1)\n(im,1)\n(im,2)\n(im,3)\n(grund,1)\n(in,1)\n(in,2)\n(in,3)\n(in,4)\n(in,5)\n(in,6)\n(in,7)\n(in,8)\n(in,9)\n(hoechste,1)\n(schliesst,1)\n(fels,1)\n(steh,1)\n(euer,1)\n(erster,1)\n(ersten,1)\n(ersten,2)\n(ersten,3)\n(goettersoehne,1)\n(brechen,1)\n(tiefen,1)\n(frucht,1)\n(kreis,1)\n(siehst,1)\n(wege,1)\n(ist,1)\n(ist,2)\n(ist,3)\n(ist,4)\n(ist,5)\n(ist,6)\n(ist,7)\n(ist,8)\n(zikaden,1)\n(frischen,1)\n(ruh,1)\n(deine,1)\n(deine,2)\n(maus,1)\n(brudersphaeren,1)\n(nachher,1)\n(euch,1)\n(euch,2)\n(euch,3)\n(euch,4)\n(gnaden,1)\n(anzuklagen,1)\n(schlange,1)\n(staerke,1)\n(staerke,2)\n(erde,1)\n(erde,2)\n(erde,3)\n(erde,4)\n(verlaub,1)\n(sanfte,1)\n(holden,1)\n(sonst,1)\n(treten,1)\n(sahst,1)\n(alten,1)\n(um,1)\n(wieder,1)\n(alter,1)\n(altes,1)\n(nun,1)\n(lieb,1)\n(gesellen,1)\n(erscheinen,1)\n(wirkt,1)\n(wirkt,2)\n(haettst,1)\n(haettst,2)\n(nur,1)\n(nur,2)\n(nur,3)\n(nur,4)\n(nur,5)\n(nur,6)\n(nur,7)\n(tiefbewegte,1)\n(lachen,1)\n(lachen,2)\n(drange,1)\n(schlag,1)\n(schein,1)\n(muss,1)\n(verworren,1)\n(weges,1)\n(allen,1)\n(gewoehnlich,1)\n(alles,1)\n(halb,1)\n(stuerme,1)\n(springt,1)\n(sollt,1)\n(klarheit,1)\n(so,1)\n(so,2)\n(so,3)\n(so,4)\n(so,5)\n(so,6)\n(erfassen,1)\n(liedchen,1)\n(prolog,1)\n(zur,1)\n(fressen,1)\n(zum,1)\n(faust,1)\n(faust,2)\n(erzengel,1)\n(erzengel,2)\n(jahre,1)\n(sonn,1)\n(raphael,1)\n(land,1)\n(land,2)\n(lang,1)\n(gelange,1)\n(lust,1)\n(lust,2)\n(welt,1)\n(sehe,1)\n(ihre,1)\n(jedes,1)\n(erfreut,1)\n(seiner,1)\n(denn,1)\n(wandeln,1)\n(wechselt,1)\n(jeden,1)\n(dort,1)\n(schlecht,1)\n(wenigsten,1)\n(wuerd,1)\n(schranken,1)\n(bewusst,1)\n(bewusst,2)\n(seinem,1)\n(seinem,2)\n(gehasst,1)\n(sein,1)\n(meinem,1)\n(meinen,1)\n(pathos,1)\n(herrn,1)\n(lange,1)\n(lange,2)\n(herab,1)\n(diesen,1)\n(ihren,1)\n(beruehmte,1)\n(goethe,1)\n(tag,1)\n(tag,2)\n(tag,3)\n(tier,1)\n(quark,1)\n(dank,1)\n(seine,1)\n(teufel,1)\n(teufel,2)\n(zweck,1)\n(wenn,1)\n(wenn,2)\n(wenn,3)\n(wenn,4)\n(wenn,5)\n(wenn,6)\n(wenn,7)\n(soll,1)\n(wirkung,1)\n(erlaubnis,1)\n(lebendig,1)\n(uns,1)\n(leicht,1)\n(gewiss,1)\n(schnell,1)\n(und,1)\n(und,2)\n(und,3)\n(und,4)\n(und,5)\n(und,6)\n(und,7)\n(und,8)\n(und,9)\n(und,10)\n(und,11)\n(und,12)\n(und,13)\n(und,14)\n(und,15)\n(und,16)\n(und,17)\n(und,18)\n(und,19)\n(und,20)\n(und,21)\n(und,22)\n(und,23)\n(und,24)\n(und,25)\n(und,26)\n(und,27)\n(und,28)\n(und,29)\n(gerne,1)\n(rechten,1)\n(umher,1)\n(umher,2)\n(vernunft,1)\n(grase,1)\n(nach,1)\n(leben,1)\n(gott,1)\n(der,1)\n(der,2)\n(der,3)\n(der,4)\n(der,5)\n(der,6)\n(der,7)\n(der,8)\n(der,9)\n(der,10)\n(der,11)\n(der,12)\n(der,13)\n(der,14)\n(der,15)\n(der,16)\n(der,17)\n(der,18)\n(der,19)\n(der,20)\n(der,21)\n(der,22)\n(der,23)\n(der,24)\n(der,25)\n(der,26)\n(der,27)\n(der,28)\n(der,29)\n(des,1)\n(des,2)\n(des,3)\n(des,4)\n(des,5)\n(doktor,1)\n(beschaemt,1)\n(dreht,1)\n(habe,1)\n(sagen,1)\n(sagen,2)\n(bekennen,1)\n(dunklen,1)\n(wettet,1)\n(den,1)\n(den,2)\n(den,3)\n(den,4)\n(den,5)\n(den,6)\n(den,7)\n(den,8)\n(den,9)\n(mephistopheles,1)\n(mephistopheles,2)\n(mephistopheles,3)\n(mephistopheles,4)\n(mephistopheles,5)\n(mephistopheles,6)\n(mephistopheles,7)\n(mephistopheles,8)\n(mephistopheles,9)\n(dem,1)\n(dem,2)\n(dem,3)\n(dem,4)\n(auch,1)\n(auch,2)\n(auch,3)\n(auch,4)\n(kann,1)\n(kann,2)\n(armen,1)\n(mir,1)\n(mir,2)\n(mir,3)\n(mir,4)\n(mir,5)\n(mir,6)\n(mir,7)\n(mir,8)\n(mir,9)\n(strebt,1)\n(gut,1)\n(gut,2)\n(mit,1)\n(mit,2)\n(mit,3)\n(mit,4)\n(mit,5)\n(mit,6)\n(mit,7)\n(mit,8)\n(mit,9)\n(mit,10)\n(mit,11)\n(bald,1)\n(bald,2)\n(himmlischen,1)\n(himmel,1)\n(himmel,2)\n(himmel,3)\n(noch,1)\n(noch,2)\n(noch,3)\n(kannst,1)\n(deinesgleichen,1)\n(flammt,1)\n(ergruenden,1)\n(ergruenden,2)\n(nacht,1)\n(scheint,1)\n(ferne,1)\n(ferne,2)\n(tragoedie,1)\n(abgewoehnt,1)\n(reizt,1)\n(geistern,1)\n(nicht,1)\n(nicht,2)\n(nicht,3)\n(nicht,4)\n(nicht,5)\n(nicht,6)\n(nicht,7)\n(nicht,8)\n(nicht,9)\n(nicht,10)\n(sacht,1)\n(unbegreiflich,1)\n(unbegreiflich,2)\n(schnelle,1)\n(einmal,1)\n(werd,1)\n(werke,1)\n(werke,2)\n(begraebt,1)\n(knecht,1)\n(rings,1)\n(wird,1)\n(katze,1)\n(huete,1)\n(fortgerissen,1)\n(gebt,1)\n(huebsch,1)\n(hast,1)\n(irrt,1)\n(befinde,1)\n(sind,1)\n(sind,2)\n(fuehren,1)\n(fuehren,2)\n(fliegt,1)\n(ewig,1)\n(ewig,2)\n(ewig,3)\n(brust,1)\n(brust,2)\n(sonne,1)\n(sprechen,1)\n(ein,1)\n(ein,2)\n(ein,3)\n(strasse,1)\n(von,1)\n(von,2)\n(von,3)\n(von,4)\n(von,5)\n(von,6)\n(von,7)\n(von,8)\n(ueberlassen,1)\n(dir,1)\n(dir,2)\n(dir,3)\n(dir,4)\n(vom,1)\n(vom,2)\n(vom,3)\n(zu,1)\n(zu,2)\n(zu,3)\n(zu,4)\n(zu,5)\n(zu,6)\n(zu,7)\n(zu,8)\n(zu,9)\n(zu,10)\n(zu,11)\n(schwebt,1)\n(die,1)\n(die,2)\n(die,3)\n(die,4)\n(die,5)\n(die,6)\n(die,7)\n(die,8)\n(die,9)\n(die,10)\n(die,11)\n(die,12)\n(die,13)\n(die,14)\n(die,15)\n(die,16)\n(die,17)\n(die,18)\n(die,19)\n(die,20)\n(die,21)\n(die,22)\n(vor,1)\n(vor,2)\n(wangen,1)\n(wettgesang,1)\n(donnerschlags,1)\n(find,1)\n(dich,1)\n(dich,2)\n(dich,3)\n(umfass,1)\n(verboten,1)\n(laeg,1)\n(nie,1)\n(drei,1)\n(drei,2)\n(dauern,1)\n(toren,1)\n(dauert,1)\n(verheeren,1)\n(fliegend,1)\n(aus,1)\n(staub,1)\n(fluessen,1)\n(haus,1)\n(auf,1)\n(auf,2)\n(auf,3)\n(auf,4)\n(auf,5)\n(dient,1)\n(dient,2)\n(tiefer,1)\n(naeh,1)\n(zieren,1)\n" |
public static final String |
TEXT |
"Goethe - Faust: Der Tragoedie erster Teil\nProlog im Himmel.\nDer Herr. Die himmlischen Heerscharen. Nachher Mephistopheles. Die drei\nErzengel treten vor.\nRAPHAEL: Die Sonne toent, nach alter Weise, In Brudersphaeren Wettgesang,\nUnd ihre vorgeschriebne Reise Vollendet sie mit Donnergang. Ihr Anblick\ngibt den Engeln Staerke, Wenn keiner Sie ergruenden mag; die unbegreiflich\nhohen Werke Sind herrlich wie am ersten Tag.\nGABRIEL: Und schnell und unbegreiflich schnelle Dreht sich umher der Erde\nPracht; Es wechselt Paradieseshelle Mit tiefer, schauervoller Nacht. Es\nschaeumt das Meer in breiten Fluessen Am tiefen Grund der Felsen auf, Und\nFels und Meer wird fortgerissen Im ewig schnellem Sphaerenlauf.\nMICHAEL: Und Stuerme brausen um die Wette Vom Meer aufs Land, vom Land\naufs Meer, und bilden wuetend eine Kette Der tiefsten Wirkung rings umher.\nDa flammt ein blitzendes Verheeren Dem Pfade vor des Donnerschlags. Doch\ndeine Boten, Herr, verehren Das sanfte Wandeln deines Tags.\nZU DREI: Der Anblick gibt den Engeln Staerke, Da keiner dich ergruenden\nmag, Und alle deine hohen Werke Sind herrlich wie am ersten Tag.\nMEPHISTOPHELES: Da du, o Herr, dich einmal wieder nahst Und fragst, wie\nalles sich bei uns befinde, Und du mich sonst gewoehnlich gerne sahst, So\nsiehst du mich auch unter dem Gesinde. Verzeih, ich kann nicht hohe Worte\nmachen, Und wenn mich auch der ganze Kreis verhoehnt; Mein Pathos braechte\ndich gewiss zum Lachen, Haettst du dir nicht das Lachen abgewoehnt. Von\nSonn\' und Welten weiss ich nichts zu sagen, Ich sehe nur, wie sich die\nMenschen plagen. Der kleine Gott der Welt bleibt stets von gleichem\nSchlag, Und ist so wunderlich als wie am ersten Tag. Ein wenig besser\nwuerd er leben, Haettst du ihm nicht den Schein des Himmelslichts gegeben;\nEr nennt\'s Vernunft und braucht\'s allein, Nur tierischer als jedes Tier\nzu sein. Er scheint mir, mit Verlaub von euer Gnaden, Wie eine der\nlangbeinigen Zikaden, Die immer fliegt und fliegend springt Und gleich im\nGras ihr altes Liedchen singt; Und laeg er nur noch immer in dem Grase! In\njeden Quark begraebt er seine Nase.\nDER HERR: Hast du mir weiter nichts zu sagen? Kommst du nur immer\nanzuklagen? Ist auf der Erde ewig dir nichts recht?\nMEPHISTOPHELES: Nein Herr! ich find es dort, wie immer, herzlich\nschlecht. Die Menschen dauern mich in ihren Jammertagen, Ich mag sogar\ndie armen selbst nicht plagen.\nDER HERR: Kennst du den Faust?\nMEPHISTOPHELES: Den Doktor?\nDER HERR: Meinen Knecht!\nMEPHISTOPHELES: Fuerwahr! er dient Euch auf besondre Weise. Nicht irdisch\nist des Toren Trank noch Speise. Ihn treibt die Gaerung in die Ferne, Er\nist sich seiner Tollheit halb bewusst; Vom Himmel fordert er die schoensten\nSterne Und von der Erde jede hoechste Lust, Und alle Naeh und alle Ferne\nBefriedigt nicht die tiefbewegte Brust.\nDER HERR: Wenn er mir auch nur verworren dient, So werd ich ihn bald in\ndie Klarheit fuehren. Weiss doch der Gaertner, wenn das Baeumchen gruent, Das\nBluet und Frucht die kuenft\'gen Jahre zieren.\nMEPHISTOPHELES: Was wettet Ihr? den sollt Ihr noch verlieren! Wenn Ihr\nmir die Erlaubnis gebt, Ihn meine Strasse sacht zu fuehren.\nDER HERR: Solang er auf der Erde lebt, So lange sei dir\'s nicht verboten,\nEs irrt der Mensch so lang er strebt.\nMEPHISTOPHELES: Da dank ich Euch; denn mit den Toten Hab ich mich niemals\ngern befangen. Am meisten lieb ich mir die vollen, frischen Wangen. Fuer\neinem Leichnam bin ich nicht zu Haus; Mir geht es wie der Katze mit der Maus.\nDER HERR: Nun gut, es sei dir ueberlassen! Zieh diesen Geist von seinem\nUrquell ab, Und fuehr ihn, kannst du ihn erfassen, Auf deinem Wege mit\nherab, Und steh beschaemt, wenn du bekennen musst: Ein guter Mensch, in\nseinem dunklen Drange, Ist sich des rechten Weges wohl bewusst.\nMEPHISTOPHELES: Schon gut! nur dauert es nicht lange. Mir ist fuer meine\nWette gar nicht bange. Wenn ich zu meinem Zweck gelange, Erlaubt Ihr mir\nTriumph aus voller Brust. Staub soll er fressen, und mit Lust, Wie meine\nMuhme, die beruehmte Schlange.\nDER HERR: Du darfst auch da nur frei erscheinen; Ich habe deinesgleichen\nnie gehasst. Von allen Geistern, die verneinen, ist mir der Schalk am\nwenigsten zur Last. Des Menschen Taetigkeit kann allzu leicht erschlaffen,\ner liebt sich bald die unbedingte Ruh; Drum geb ich gern ihm den Gesellen\nzu, Der reizt und wirkt und muss als Teufel schaffen. Doch ihr, die echten\nGoettersoehne, Erfreut euch der lebendig reichen Schoene! Das Werdende, das\newig wirkt und lebt, Umfass euch mit der Liebe holden Schranken, Und was\nin schwankender Erscheinung schwebt, Befestigt mit dauernden Gedanken!\n(Der Himmel schliesst, die Erzengel verteilen sich.)\nMEPHISTOPHELES (allein): Von Zeit zu Zeit seh ich den Alten gern, Und\nhuete mich, mit ihm zu brechen. Es ist gar huebsch von einem grossen Herrn,\nSo menschlich mit dem Teufel selbst zu sprechen." |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
CODEBASE_KEY |
"codebase" |
public static final String |
NEW_CODEBASE |
"new" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final long |
DEFAULT_AKKA_ASK_TIMEOUT |
1000L |
protected static final String |
DEFAULT_AKKA_STARTUP_TIMEOUT |
"60 s" |
protected static final int |
MINIMUM_HEAP_SIZE_MB |
192 |
protected static final long |
TASK_MANAGER_MEMORY_SIZE |
80L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
SIZE |
16 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
STRINGIFIED_NULL_EXCEPTION |
"(null)" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
KEYTAB_FILE_NAME |
"krb5.keytab" |
public static final String |
KRB5_FILE_NAME |
"krb5.conf" |
public static final String |
YARN_SITE_FILE_NAME |
"yarn-site.xml" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
ENV_APP_ID |
"_APP_ID" |
public static final String |
ENV_CLIENT_HOME_DIR |
"_CLIENT_HOME_DIR" |
public static final String |
ENV_CLIENT_SHIP_FILES |
"_CLIENT_SHIP_FILES" |
public static final String |
ENV_DETACHED |
"_DETACHED" |
public static final String |
ENV_DYNAMIC_PROPERTIES |
"_DYNAMIC_PROPERTIES" |
public static final String |
ENV_FLINK_CLASSPATH |
"_FLINK_CLASSPATH" |
public static final String |
ENV_HADOOP_USER_NAME |
"HADOOP_USER_NAME" |
public static final String |
ENV_KRB5_PATH |
"_KRB5_PATH" |
public static final String |
ENV_SLOTS |
"_SLOTS" |
public static final String |
ENV_TM_COUNT |
"_CLIENT_TM_COUNT" |
public static final String |
ENV_TM_MEMORY |
"_CLIENT_TM_MEMORY" |
public static final String |
ENV_YARN_SITE_XML_PATH |
"_YARN_SITE_XML_PATH" |
public static final String |
ENV_ZOOKEEPER_NAMESPACE |
"_ZOOKEEPER_NAMESPACE" |
public static final String |
FLINK_JAR_PATH |
"_FLINK_JAR_PATH" |
public static final String |
FLINK_YARN_FILES |
"_FLINK_YARN_FILES" |
public static final String |
KEYTAB_PATH |
"_KEYTAB_PATH" |
public static final String |
KEYTAB_PRINCIPAL |
"_KEYTAB_PRINCIPAL" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
CONFIG_FILE_LOG4J_NAME |
"log4j.properties" |
public static final String |
CONFIG_FILE_LOGBACK_NAME |
"logback.xml" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
JOB_GRAPH_FILE_PATH |
"flink.jobgraph.path" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FLINK_RECOVERY_DATA_DIR |
"flink_recovery_data" |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.