| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
BACKPRESSURE_DISRUPTOR_HIGH_WATERMARK |
"backpressure.disruptor.high.watermark" |
public static final String |
BACKPRESSURE_DISRUPTOR_LOW_WATERMARK |
"backpressure.disruptor.low.watermark" |
public static final String |
BLOBSTORE_CLEANUP_ENABLE |
"blobstore.cleanup.enable" |
public static final String |
BLOBSTORE_DIR |
"blobstore.dir" |
public static final String |
BLOBSTORE_HDFS_KEYTAB |
"blobstore.hdfs.keytab" |
public static final String |
BLOBSTORE_HDFS_PRINCIPAL |
"blobstore.hdfs.principal" |
public static final String |
BLOBSTORE_SUPERUSER |
"blobstore.superuser" |
public static final String |
CLIENT_BLOBSTORE |
"client.blobstore.class" |
public static final String |
DEV_ZOOKEEPER_PATH |
"dev.zookeeper.path" |
public static final String |
DRPC_AUTHORIZER |
"drpc.authorizer" |
public static final String |
DRPC_AUTHORIZER_ACL |
"drpc.authorizer.acl" |
public static final String |
DRPC_AUTHORIZER_ACL_FILENAME |
"drpc.authorizer.acl.filename" |
public static final String |
DRPC_AUTHORIZER_ACL_STRICT |
"drpc.authorizer.acl.strict" |
public static final String |
DRPC_CHILDOPTS |
"drpc.childopts" |
public static final String |
DRPC_HTTP_CREDS_PLUGIN |
"drpc.http.creds.plugin" |
public static final String |
DRPC_HTTP_FILTER |
"drpc.http.filter" |
public static final String |
DRPC_HTTP_FILTER_PARAMS |
"drpc.http.filter.params" |
public static final String |
DRPC_HTTP_PORT |
"drpc.http.port" |
public static final String |
DRPC_HTTPS_KEY_PASSWORD |
"drpc.https.key.password" |
public static final String |
DRPC_HTTPS_KEYSTORE_PASSWORD |
"drpc.https.keystore.password" |
public static final String |
DRPC_HTTPS_KEYSTORE_PATH |
"drpc.https.keystore.path" |
public static final String |
DRPC_HTTPS_KEYSTORE_TYPE |
"drpc.https.keystore.type" |
public static final String |
DRPC_HTTPS_NEED_CLIENT_AUTH |
"drpc.https.need.client.auth" |
public static final String |
DRPC_HTTPS_PORT |
"drpc.https.port" |
public static final String |
DRPC_HTTPS_TRUSTSTORE_PASSWORD |
"drpc.https.truststore.password" |
public static final String |
DRPC_HTTPS_TRUSTSTORE_PATH |
"drpc.https.truststore.path" |
public static final String |
DRPC_HTTPS_TRUSTSTORE_TYPE |
"drpc.https.truststore.type" |
public static final String |
DRPC_HTTPS_WANT_CLIENT_AUTH |
"drpc.https.want.client.auth" |
public static final String |
DRPC_INVOCATIONS_PORT |
"drpc.invocations.port" |
public static final String |
DRPC_INVOCATIONS_THREADS |
"drpc.invocations.threads" |
public static final String |
DRPC_INVOCATIONS_THRIFT_TRANSPORT_PLUGIN |
"drpc.invocations.thrift.transport" |
public static final String |
DRPC_MAX_BUFFER_SIZE |
"drpc.max_buffer_size" |
public static final String |
DRPC_PORT |
"drpc.port" |
public static final String |
DRPC_QUEUE_SIZE |
"drpc.queue.size" |
public static final String |
DRPC_REQUEST_TIMEOUT_SECS |
"drpc.request.timeout.secs" |
public static final String |
DRPC_SERVERS |
"drpc.servers" |
public static final String |
DRPC_THRIFT_TRANSPORT_PLUGIN |
"drpc.thrift.transport" |
public static final String |
DRPC_WORKER_THREADS |
"drpc.worker.threads" |
public static final String |
ISOLATION_SCHEDULER_MACHINES |
"isolation.scheduler.machines" |
public static final String |
JAVA_LIBRARY_PATH |
"java.library.path" |
public static final String |
LOGS_GROUPS |
"logs.groups" |
public static final String |
LOGS_USERS |
"logs.users" |
public static final String |
LOGVIEWER_APPENDER_NAME |
"logviewer.appender.name" |
public static final String |
LOGVIEWER_CHILDOPTS |
"logviewer.childopts" |
public static final String |
LOGVIEWER_CLEANUP_AGE_MINS |
"logviewer.cleanup.age.mins" |
public static final String |
LOGVIEWER_CLEANUP_INTERVAL_SECS |
"logviewer.cleanup.interval.secs" |
public static final String |
LOGVIEWER_HTTPS_KEY_PASSWORD |
"logviewer.https.key.password" |
public static final String |
LOGVIEWER_HTTPS_KEYSTORE_PASSWORD |
"logviewer.https.keystore.password" |
public static final String |
LOGVIEWER_HTTPS_KEYSTORE_PATH |
"logviewer.https.keystore.path" |
public static final String |
LOGVIEWER_HTTPS_KEYSTORE_TYPE |
"logviewer.https.keystore.type" |
public static final String |
LOGVIEWER_HTTPS_NEED_CLIENT_AUTH |
"logviewer.https.need.client.auth" |
public static final String |
LOGVIEWER_HTTPS_PORT |
"logviewer.https.port" |
public static final String |
LOGVIEWER_HTTPS_TRUSTSTORE_PASSWORD |
"logviewer.https.truststore.password" |
public static final String |
LOGVIEWER_HTTPS_TRUSTSTORE_PATH |
"logviewer.https.truststore.path" |
public static final String |
LOGVIEWER_HTTPS_TRUSTSTORE_TYPE |
"logviewer.https.truststore.type" |
public static final String |
LOGVIEWER_HTTPS_WANT_CLIENT_AUTH |
"logviewer.https.want.client.auth" |
public static final String |
LOGVIEWER_MAX_PER_WORKER_LOGS_SIZE_MB |
"logviewer.max.per.worker.logs.size.mb" |
public static final String |
LOGVIEWER_MAX_SUM_WORKER_LOGS_SIZE_MB |
"logviewer.max.sum.worker.logs.size.mb" |
public static final String |
LOGVIEWER_PORT |
"logviewer.port" |
public static final String |
MULTITENANT_SCHEDULER_USER_POOLS |
"multitenant.scheduler.user.pools" |
public static final String |
NIMBUS_ADMINS |
"nimbus.admins" |
public static final String |
NIMBUS_AUTHORIZER |
"nimbus.authorizer" |
public static final String |
NIMBUS_AUTO_CRED_PLUGINS |
"nimbus.autocredential.plugins.classes" |
public static final String |
NIMBUS_BLOBSTORE |
"nimbus.blobstore.class" |
public static final String |
NIMBUS_BLOBSTORE_EXPIRATION_SECS |
"nimbus.blobstore.expiration.secs" |
public static final String |
NIMBUS_CHILDOPTS |
"nimbus.childopts" |
public static final String |
NIMBUS_CLEANUP_INBOX_FREQ_SECS |
"nimbus.cleanup.inbox.freq.secs" |
public static final String |
NIMBUS_CODE_SYNC_FREQ_SECS |
"nimbus.code.sync.freq.secs" |
public static final String |
NIMBUS_CREDENTIAL_RENEW_FREQ_SECS |
"nimbus.credential.renewers.freq.secs" |
public static final String |
NIMBUS_CREDENTIAL_RENEWERS |
"nimbus.credential.renewers.classes" |
public static final String |
NIMBUS_DAEMON_USER |
"nimbus.daemon.user" |
public static final String |
NIMBUS_EXECUTORS_PER_TOPOLOGY |
"nimbus.executors.perTopology" |
public static final String |
NIMBUS_FILE_COPY_EXPIRATION_SECS |
"nimbus.file.copy.expiration.secs" |
public static final String |
NIMBUS_GROUPS |
"nimbus.groups" |
public static final String |
NIMBUS_HOST |
"nimbus.host" |
public static final String |
NIMBUS_IMPERSONATION_ACL |
"nimbus.impersonation.acl" |
public static final String |
NIMBUS_IMPERSONATION_AUTHORIZER |
"nimbus.impersonation.authorizer" |
public static final String |
NIMBUS_INBOX_JAR_EXPIRATION_SECS |
"nimbus.inbox.jar.expiration.secs" |
public static final String |
NIMBUS_MONITOR_FREQ_SECS |
"nimbus.monitor.freq.secs" |
public static final String |
NIMBUS_QUEUE_SIZE |
"nimbus.queue.size" |
public static final String |
NIMBUS_SEEDS |
"nimbus.seeds" |
public static final String |
NIMBUS_SLOTS_PER_TOPOLOGY |
"nimbus.slots.perTopology" |
public static final String |
NIMBUS_SUPERVISOR_TIMEOUT_SECS |
"nimbus.supervisor.timeout.secs" |
public static final String |
NIMBUS_SUPERVISOR_USERS |
"nimbus.supervisor.users" |
public static final String |
NIMBUS_TASK_LAUNCH_SECS |
"nimbus.task.launch.secs" |
public static final String |
NIMBUS_TASK_TIMEOUT_SECS |
"nimbus.task.timeout.secs" |
public static final String |
NIMBUS_THRIFT_MAX_BUFFER_SIZE |
"nimbus.thrift.max_buffer_size" |
public static final String |
NIMBUS_THRIFT_PORT |
"nimbus.thrift.port" |
public static final String |
NIMBUS_THRIFT_THREADS |
"nimbus.thrift.threads" |
public static final String |
NIMBUS_THRIFT_TRANSPORT_PLUGIN |
"nimbus.thrift.transport" |
public static final String |
NIMBUS_TOPOLOGY_ACTION_NOTIFIER_PLUGIN |
"nimbus.topology.action.notifier.plugin.class" |
public static final String |
NIMBUS_TOPOLOGY_VALIDATOR |
"nimbus.topology.validator" |
public static final String |
NIMBUS_USERS |
"nimbus.users" |
public static final String |
PACEMAKER_AUTH_METHOD |
"pacemaker.auth.method" |
public static final String |
PACEMAKER_CHILDOPTS |
"pacemaker.childopts" |
public static final String |
PACEMAKER_HOST |
"pacemaker.host" |
public static final String |
PACEMAKER_MAX_THREADS |
"pacemaker.max.threads" |
public static final String |
PACEMAKER_PORT |
"pacemaker.port" |
public static final String |
RESOURCE_AWARE_SCHEDULER_EVICTION_STRATEGY |
"resource.aware.scheduler.eviction.strategy" |
public static final String |
RESOURCE_AWARE_SCHEDULER_PRIORITY_STRATEGY |
"resource.aware.scheduler.priority.strategy" |
public static final String |
RESOURCE_AWARE_SCHEDULER_USER_POOLS |
"resource.aware.scheduler.user.pools" |
public static final String |
SCHEDULER_DISPLAY_RESOURCE |
"scheduler.display.resource" |
public static final String |
STORM_BLOBSTORE_INPUTSTREAM_BUFFER_SIZE_BYTES |
"storm.blobstore.inputstream.buffer.size.bytes" |
public static final String |
STORM_BLOBSTORE_REPLICATION_FACTOR |
"storm.blobstore.replication.factor" |
public static final String |
STORM_CLUSTER_MODE |
"storm.cluster.mode" |
public static final String |
STORM_CLUSTER_STATE_STORE |
"storm.cluster.state.store" |
public static final String |
STORM_DAEMON_METRICS_REPORTER_CSV_LOG_DIR |
"storm.daemon.metrics.reporter.csv.log.dir" |
public static final String |
STORM_DAEMON_METRICS_REPORTER_PLUGIN_DOMAIN |
"storm.daemon.metrics.reporter.plugin.domain" |
public static final String |
STORM_DAEMON_METRICS_REPORTER_PLUGIN_DURATION_UNIT |
"storm.daemon.metrics.reporter.plugin.duration.unit" |
public static final String |
STORM_DAEMON_METRICS_REPORTER_PLUGIN_LOCALE |
"storm.daemon.metrics.reporter.plugin.locale" |
public static final String |
STORM_DAEMON_METRICS_REPORTER_PLUGIN_RATE_UNIT |
"storm.daemon.metrics.reporter.plugin.rate.unit" |
public static final String |
STORM_DAEMON_METRICS_REPORTER_PLUGINS |
"storm.daemon.metrics.reporter.plugins" |
public static final String |
STORM_DO_AS_USER |
"storm.doAsUser" |
public static final String |
STORM_EXHIBITOR_POLL |
"storm.exhibitor.poll.millis" |
public static final String |
STORM_EXHIBITOR_PORT |
"storm.exhibitor.port" |
public static final String |
STORM_EXHIBITOR_RETRY_INTERVAL |
"storm.exhibitor.retry.interval" |
public static final String |
STORM_EXHIBITOR_RETRY_INTERVAL_CEILING |
"storm.exhibitor.retry.intervalceiling.millis" |
public static final String |
STORM_EXHIBITOR_RETRY_TIMES |
"storm.exhibitor.retry.times" |
public static final String |
STORM_EXHIBITOR_SERVERS |
"storm.exhibitor.servers" |
public static final String |
STORM_EXHIBITOR_URIPATH |
"storm.exhibitor.poll.uripath" |
public static final String |
STORM_GROUP_MAPPING_SERVICE_CACHE_DURATION_SECS |
"storm.group.mapping.service.cache.duration.secs" |
public static final String |
STORM_GROUP_MAPPING_SERVICE_PARAMS |
"storm.group.mapping.service.params" |
public static final String |
STORM_GROUP_MAPPING_SERVICE_PROVIDER_PLUGIN |
"storm.group.mapping.service" |
public static final String |
STORM_HEALTH_CHECK_DIR |
"storm.health.check.dir" |
public static final String |
STORM_HEALTH_CHECK_TIMEOUT_MS |
"storm.health.check.timeout.ms" |
public static final String |
STORM_ID |
"storm.id" |
public static final String |
STORM_LOCAL_DIR |
"storm.local.dir" |
public static final String |
STORM_LOCAL_HOSTNAME |
"storm.local.hostname" |
public static final String |
STORM_LOCAL_MODE_ZMQ |
"storm.local.mode.zmq" |
public static final String |
STORM_LOG4J2_CONF_DIR |
"storm.log4j2.conf.dir" |
public static final String |
STORM_MESSAGING_NETTY_AUTHENTICATION |
"storm.messaging.netty.authentication" |
public static final String |
STORM_MESSAGING_NETTY_BUFFER_SIZE |
"storm.messaging.netty.buffer_size" |
public static final String |
STORM_MESSAGING_NETTY_CLIENT_WORKER_THREADS |
"storm.messaging.netty.client_worker_threads" |
public static final String |
STORM_MESSAGING_NETTY_MAX_RETRIES |
"storm.messaging.netty.max_retries" |
public static final String |
STORM_MESSAGING_NETTY_MAX_SLEEP_MS |
"storm.messaging.netty.max_wait_ms" |
public static final String |
STORM_MESSAGING_NETTY_MIN_SLEEP_MS |
"storm.messaging.netty.min_wait_ms" |
public static final String |
STORM_MESSAGING_NETTY_SERVER_WORKER_THREADS |
"storm.messaging.netty.server_worker_threads" |
public static final String |
STORM_MESSAGING_NETTY_SOCKET_BACKLOG |
"storm.messaging.netty.socket.backlog" |
public static final String |
STORM_MESSAGING_TRANSPORT |
"storm.messaging.transport" |
public static final String |
STORM_META_SERIALIZATION_DELEGATE |
"storm.meta.serialization.delegate" |
public static final String |
STORM_NETTY_FLUSH_CHECK_INTERVAL_MS |
"storm.messaging.netty.flush.check.interval.ms" |
public static final String |
STORM_NETTY_MESSAGE_BATCH_SIZE |
"storm.messaging.netty.transfer.batch.size" |
public static final String |
STORM_NETWORK_TOPOGRAPHY_PLUGIN |
"storm.network.topography.plugin" |
public static final String |
STORM_NIMBUS_RETRY_INTERVAL |
"storm.nimbus.retry.interval.millis" |
public static final String |
STORM_NIMBUS_RETRY_INTERVAL_CEILING |
"storm.nimbus.retry.intervalceiling.millis" |
public static final String |
STORM_NIMBUS_RETRY_TIMES |
"storm.nimbus.retry.times" |
public static final String |
STORM_PRINCIPAL_TO_LOCAL_PLUGIN |
"storm.principal.tolocal" |
public static final String |
STORM_RESOURCE_ISOLATION_PLUGIN_ENABLE |
"storm.resource.isolation.plugin.enable" |
public static final String |
STORM_SCHEDULER |
"storm.scheduler" |
public static final String |
STORM_THRIFT_TRANSPORT_PLUGIN |
"storm.thrift.transport" |
public static final String |
STORM_TOPOLOGY_SUBMISSION_NOTIFIER_PLUGIN |
"storm.topology.submission.notifier.plugin.class" |
public static final String |
STORM_WORKERS_ARTIFACTS_DIR |
"storm.workers.artifacts.dir" |
public static final String |
STORM_ZOOKEEPER_AUTH_PAYLOAD |
"storm.zookeeper.auth.payload" |
public static final String |
STORM_ZOOKEEPER_AUTH_SCHEME |
"storm.zookeeper.auth.scheme" |
public static final String |
STORM_ZOOKEEPER_CONNECTION_TIMEOUT |
"storm.zookeeper.connection.timeout" |
public static final String |
STORM_ZOOKEEPER_PORT |
"storm.zookeeper.port" |
public static final String |
STORM_ZOOKEEPER_RETRY_INTERVAL |
"storm.zookeeper.retry.interval" |
public static final String |
STORM_ZOOKEEPER_RETRY_INTERVAL_CEILING |
"storm.zookeeper.retry.intervalceiling.millis" |
public static final String |
STORM_ZOOKEEPER_RETRY_TIMES |
"storm.zookeeper.retry.times" |
public static final String |
STORM_ZOOKEEPER_ROOT |
"storm.zookeeper.root" |
public static final String |
STORM_ZOOKEEPER_SERVERS |
"storm.zookeeper.servers" |
public static final String |
STORM_ZOOKEEPER_SESSION_TIMEOUT |
"storm.zookeeper.session.timeout" |
public static final String |
STORM_ZOOKEEPER_SUPERACL |
"storm.zookeeper.superACL" |
public static final String |
STORM_ZOOKEEPER_TOPOLOGY_AUTH_PAYLOAD |
"storm.zookeeper.topology.auth.payload" |
public static final String |
STORM_ZOOKEEPER_TOPOLOGY_AUTH_SCHEME |
"storm.zookeeper.topology.auth.scheme" |
public static final String |
SUPERVISOR_BLOBSTORE |
"supervisor.blobstore.class" |
public static final String |
SUPERVISOR_BLOBSTORE_DOWNLOAD_MAX_RETRIES |
"supervisor.blobstore.download.max_retries" |
public static final String |
SUPERVISOR_BLOBSTORE_DOWNLOAD_THREAD_COUNT |
"supervisor.blobstore.download.thread.count" |
public static final String |
SUPERVISOR_CHILDOPTS |
"supervisor.childopts" |
public static final String |
SUPERVISOR_CPU_CAPACITY |
"supervisor.cpu.capacity" |
public static final String |
SUPERVISOR_ENABLE |
"supervisor.enable" |
public static final String |
SUPERVISOR_HEARTBEAT_FREQUENCY_SECS |
"supervisor.heartbeat.frequency.secs" |
public static final String |
SUPERVISOR_LOCALIZER_CACHE_CLEANUP_INTERVAL_MS |
"supervisor.localizer.cleanup.interval.ms" |
public static final String |
SUPERVISOR_LOCALIZER_CACHE_TARGET_SIZE_MB |
"supervisor.localizer.cache.target.size.mb" |
public static final String |
SUPERVISOR_MEMORY_CAPACITY_MB |
"supervisor.memory.capacity.mb" |
public static final String |
SUPERVISOR_MONITOR_FREQUENCY_SECS |
"supervisor.monitor.frequency.secs" |
public static final String |
SUPERVISOR_RUN_WORKER_AS_USER |
"supervisor.run.worker.as.user" |
public static final String |
SUPERVISOR_SCHEDULER_META |
"supervisor.scheduler.meta" |
public static final String |
SUPERVISOR_SLOTS_PORTS |
"supervisor.slots.ports" |
public static final String |
SUPERVISOR_WORKER_LAUNCHER |
"supervisor.worker.launcher" |
public static final String |
SUPERVISOR_WORKER_SHUTDOWN_SLEEP_SECS |
"supervisor.worker.shutdown.sleep.secs" |
public static final String |
SUPERVISOR_WORKER_START_TIMEOUT_SECS |
"supervisor.worker.start.timeout.secs" |
public static final String |
SUPERVISOR_WORKER_TIMEOUT_SECS |
"supervisor.worker.timeout.secs" |
public static final String |
TASK_CREDENTIALS_POLL_SECS |
"task.credentials.poll.secs" |
public static final String |
TASK_HEARTBEAT_FREQUENCY_SECS |
"task.heartbeat.frequency.secs" |
public static final String |
TASK_REFRESH_POLL_SECS |
"task.refresh.poll.secs" |
public static final String |
TOPOLOGY_ACKER_EXECUTORS |
"topology.acker.executors" |
public static final String |
TOPOLOGY_AUTO_CREDENTIALS |
"topology.auto-credentials" |
public static final String |
TOPOLOGY_AUTO_TASK_HOOKS |
"topology.auto.task.hooks" |
public static final String |
TOPOLOGY_BACKPRESSURE_ENABLE |
"topology.backpressure.enable" |
public static final String |
TOPOLOGY_BLOBSTORE_MAP |
"topology.blobstore.map" |
public static final String |
TOPOLOGY_BOLTS_MESSAGE_ID_FIELD_NAME |
"topology.bolts.message.id.field.name" |
public static final String |
TOPOLOGY_BOLTS_OUTGOING_OVERFLOW_BUFFER_ENABLE |
"topology.bolts.outgoing.overflow.buffer.enable" |
public static final String |
TOPOLOGY_BOLTS_SLIDING_INTERVAL_COUNT |
"topology.bolts.window.sliding.interval.count" |
public static final String |
TOPOLOGY_BOLTS_SLIDING_INTERVAL_DURATION_MS |
"topology.bolts.window.sliding.interval.duration.ms" |
public static final String |
TOPOLOGY_BOLTS_TUPLE_TIMESTAMP_FIELD_NAME |
"topology.bolts.tuple.timestamp.field.name" |
public static final String |
TOPOLOGY_BOLTS_TUPLE_TIMESTAMP_MAX_LAG_MS |
"topology.bolts.tuple.timestamp.max.lag.ms" |
public static final String |
TOPOLOGY_BOLTS_WATERMARK_EVENT_INTERVAL_MS |
"topology.bolts.watermark.event.interval.ms" |
public static final String |
TOPOLOGY_BOLTS_WINDOW_LENGTH_COUNT |
"topology.bolts.window.length.count" |
public static final String |
TOPOLOGY_BOLTS_WINDOW_LENGTH_DURATION_MS |
"topology.bolts.window.length.duration.ms" |
public static final String |
TOPOLOGY_BUILTIN_METRICS_BUCKET_SIZE_SECS |
"topology.builtin.metrics.bucket.size.secs" |
public static final String |
TOPOLOGY_CLASSPATH |
"topology.classpath" |
public static final String |
TOPOLOGY_COMPONENT_CPU_PCORE_PERCENT |
"topology.component.cpu.pcore.percent" |
public static final String |
TOPOLOGY_COMPONENT_RESOURCES_OFFHEAP_MEMORY_MB |
"topology.component.resources.offheap.memory.mb" |
public static final String |
TOPOLOGY_COMPONENT_RESOURCES_ONHEAP_MEMORY_MB |
"topology.component.resources.onheap.memory.mb" |
public static final String |
TOPOLOGY_DEBUG |
"topology.debug" |
public static final String |
TOPOLOGY_DISABLE_LOADAWARE_MESSAGING |
"topology.disable.loadaware.messaging" |
public static final String |
TOPOLOGY_DISRUPTOR_BATCH_SIZE |
"topology.disruptor.batch.size" |
public static final String |
TOPOLOGY_DISRUPTOR_BATCH_TIMEOUT_MILLIS |
"topology.disruptor.batch.timeout.millis" |
public static final String |
TOPOLOGY_DISRUPTOR_WAIT_STRATEGY |
"topology.disruptor.wait.strategy" |
public static final String |
TOPOLOGY_DISRUPTOR_WAIT_TIMEOUT_MILLIS |
"topology.disruptor.wait.timeout.millis" |
public static final String |
TOPOLOGY_ENABLE_MESSAGE_TIMEOUTS |
"topology.enable.message.timeouts" |
public static final String |
TOPOLOGY_ENVIRONMENT |
"topology.environment" |
public static final String |
TOPOLOGY_ERROR_THROTTLE_INTERVAL_SECS |
"topology.error.throttle.interval.secs" |
public static final String |
TOPOLOGY_EVENTLOGGER_EXECUTORS |
"topology.eventlogger.executors" |
public static final String |
TOPOLOGY_EXECUTOR_RECEIVE_BUFFER_SIZE |
"topology.executor.receive.buffer.size" |
public static final String |
TOPOLOGY_EXECUTOR_SEND_BUFFER_SIZE |
"topology.executor.send.buffer.size" |
public static final String |
TOPOLOGY_FALL_BACK_ON_JAVA_SERIALIZATION |
"topology.fall.back.on.java.serialization" |
public static final String |
TOPOLOGY_GROUPS |
"topology.groups" |
public static final String |
TOPOLOGY_ISOLATED_MACHINES |
"topology.isolate.machines" |
public static final String |
TOPOLOGY_KRYO_DECORATORS |
"topology.kryo.decorators" |
public static final String |
TOPOLOGY_KRYO_FACTORY |
"topology.kryo.factory" |
public static final String |
TOPOLOGY_KRYO_REGISTER |
"topology.kryo.register" |
public static final String |
TOPOLOGY_LOGGING_SENSITIVITY |
"topology.logging.sensitivity" |
public static final String |
TOPOLOGY_MAX_ERROR_REPORT_PER_INTERVAL |
"topology.max.error.report.per.interval" |
public static final String |
TOPOLOGY_MAX_REPLICATION_WAIT_TIME_SEC |
"topology.max.replication.wait.time.sec" |
public static final String |
TOPOLOGY_MAX_SPOUT_PENDING |
"topology.max.spout.pending" |
public static final String |
TOPOLOGY_MAX_TASK_PARALLELISM |
"topology.max.task.parallelism" |
public static final String |
TOPOLOGY_MESSAGE_TIMEOUT_SECS |
"topology.message.timeout.secs" |
public static final String |
TOPOLOGY_METRICS_CONSUMER_REGISTER |
"topology.metrics.consumer.register" |
public static final String |
TOPOLOGY_MIN_REPLICATION_COUNT |
"topology.min.replication.count" |
public static final String |
TOPOLOGY_MULTILANG_SERIALIZER |
"topology.multilang.serializer" |
public static final String |
TOPOLOGY_NAME |
"topology.name" |
public static final String |
TOPOLOGY_PRIORITY |
"topology.priority" |
public static final String |
TOPOLOGY_SCHEDULER_STRATEGY |
"topology.scheduler.strategy" |
public static final String |
TOPOLOGY_SHELLBOLT_MAX_PENDING |
"topology.shellbolt.max.pending" |
public static final String |
TOPOLOGY_SKIP_MISSING_KRYO_REGISTRATIONS |
"topology.skip.missing.kryo.registrations" |
public static final String |
TOPOLOGY_SLEEP_SPOUT_WAIT_STRATEGY_TIME_MS |
"topology.sleep.spout.wait.strategy.time.ms" |
public static final String |
TOPOLOGY_SPOUT_WAIT_STRATEGY |
"topology.spout.wait.strategy" |
public static final String |
TOPOLOGY_SPREAD_COMPONENTS |
"topology.spread.components" |
public static final String |
TOPOLOGY_STATE_CHECKPOINT_INTERVAL |
"topology.state.checkpoint.interval.ms" |
public static final String |
TOPOLOGY_STATE_PROVIDER |
"topology.state.provider" |
public static final String |
TOPOLOGY_STATE_PROVIDER_CONFIG |
"topology.state.provider.config" |
public static final String |
TOPOLOGY_STATE_SYNCHRONIZATION_TIMEOUT_SECS |
"topology.state.synchronization.timeout.secs" |
public static final String |
TOPOLOGY_STATS_SAMPLE_RATE |
"topology.stats.sample.rate" |
public static final String |
TOPOLOGY_SUBMITTER_PRINCIPAL |
"topology.submitter.principal" |
public static final String |
TOPOLOGY_SUBMITTER_USER |
"topology.submitter.user" |
public static final String |
TOPOLOGY_SUBPROCESS_TIMEOUT_SECS |
"topology.subprocess.timeout.secs" |
public static final String |
TOPOLOGY_TASKS |
"topology.tasks" |
public static final String |
TOPOLOGY_TESTING_ALWAYS_TRY_SERIALIZE |
"topology.testing.always.try.serialize" |
public static final String |
TOPOLOGY_TICK_TUPLE_FREQ_SECS |
"topology.tick.tuple.freq.secs" |
public static final String |
TOPOLOGY_TRANSACTIONAL_ID |
"topology.transactional.id" |
public static final String |
TOPOLOGY_TRANSFER_BUFFER_SIZE |
"topology.transfer.buffer.size" |
public static final String |
TOPOLOGY_TRIDENT_BATCH_EMIT_INTERVAL_MILLIS |
"topology.trident.batch.emit.interval.millis" |
public static final String |
TOPOLOGY_TUPLE_SERIALIZER |
"topology.tuple.serializer" |
public static final String |
TOPOLOGY_USERS |
"topology.users" |
public static final String |
TOPOLOGY_WORKER_CHILDOPTS |
"topology.worker.childopts" |
public static final String |
TOPOLOGY_WORKER_GC_CHILDOPTS |
"topology.worker.gc.childopts" |
public static final String |
TOPOLOGY_WORKER_LOGWRITER_CHILDOPTS |
"topology.worker.logwriter.childopts" |
public static final String |
TOPOLOGY_WORKER_MAX_HEAP_SIZE_MB |
"topology.worker.max.heap.size.mb" |
public static final String |
TOPOLOGY_WORKER_METRICS |
"topology.worker.metrics" |
public static final String |
TOPOLOGY_WORKER_SHARED_THREAD_POOL_SIZE |
"topology.worker.shared.thread.pool.size" |
public static final String |
TOPOLOGY_WORKERS |
"topology.workers" |
public static final String |
TRANSACTIONAL_ZOOKEEPER_PORT |
"transactional.zookeeper.port" |
public static final String |
TRANSACTIONAL_ZOOKEEPER_ROOT |
"transactional.zookeeper.root" |
public static final String |
TRANSACTIONAL_ZOOKEEPER_SERVERS |
"transactional.zookeeper.servers" |
public static final String |
UI_CENTRAL_LOGGING_URL |
"ui.central.logging.url" |
public static final String |
UI_CHILDOPTS |
"ui.childopts" |
public static final String |
UI_FILTER |
"ui.filter" |
public static final String |
UI_FILTER_PARAMS |
"ui.filter.params" |
public static final String |
UI_HEADER_BUFFER_BYTES |
"ui.header.buffer.bytes" |
public static final String |
UI_HOST |
"ui.host" |
public static final String |
UI_HTTP_CREDS_PLUGIN |
"ui.http.creds.plugin" |
public static final String |
UI_HTTPS_KEY_PASSWORD |
"ui.https.key.password" |
public static final String |
UI_HTTPS_KEYSTORE_PASSWORD |
"ui.https.keystore.password" |
public static final String |
UI_HTTPS_KEYSTORE_PATH |
"ui.https.keystore.path" |
public static final String |
UI_HTTPS_KEYSTORE_TYPE |
"ui.https.keystore.type" |
public static final String |
UI_HTTPS_NEED_CLIENT_AUTH |
"ui.https.need.client.auth" |
public static final String |
UI_HTTPS_PORT |
"ui.https.port" |
public static final String |
UI_HTTPS_TRUSTSTORE_PASSWORD |
"ui.https.truststore.password" |
public static final String |
UI_HTTPS_TRUSTSTORE_PATH |
"ui.https.truststore.path" |
public static final String |
UI_HTTPS_TRUSTSTORE_TYPE |
"ui.https.truststore.type" |
public static final String |
UI_HTTPS_WANT_CLIENT_AUTH |
"ui.https.want.client.auth" |
public static final String |
UI_PORT |
"ui.port" |
public static final String |
UI_PROJECT_BUGTRACKER_URL |
"ui.project.bugtracker.url" |
public static final String |
WORKER_CHILDOPTS |
"worker.childopts" |
public static final String |
WORKER_GC_CHILDOPTS |
"worker.gc.childopts" |
public static final String |
WORKER_HEAP_MEMORY_MB |
"worker.heap.memory.mb" |
public static final String |
WORKER_HEARTBEAT_FREQUENCY_SECS |
"worker.heartbeat.frequency.secs" |
public static final String |
WORKER_LOG_LEVEL_RESET_POLL_SECS |
"worker.log.level.reset.poll.secs" |
public static final String |
WORKER_METRICS |
"worker.metrics" |
public static final String |
WORKER_PROFILER_CHILDOPTS |
"worker.profiler.childopts" |
public static final String |
WORKER_PROFILER_COMMAND |
"worker.profiler.command" |
public static final String |
WORKER_PROFILER_ENABLED |
"worker.profiler.enabled" |
public static final String |
ZMQ_HWM |
"zmq.hwm" |
public static final String |
ZMQ_LINGER_MILLIS |
"zmq.linger.millis" |
public static final String |
ZMQ_THREADS |
"zmq.threads" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
CREDENTIALS_CHANGED_STREAM_ID |
"__credentials" |
public static final String |
METRICS_COMPONENT_ID_PREFIX |
"__metrics" |
public static final String |
METRICS_STREAM_ID |
"__metrics" |
public static final String |
METRICS_TICK_STREAM_ID |
"__metrics_tick" |
public static final String |
SYSTEM_COMPONENT_ID |
"__system" |
public static final long |
SYSTEM_TASK_ID |
-1L |
public static final String |
SYSTEM_TICK_STREAM_ID |
"__tick" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
protected static final String |
BASE_BLOBS_DIR_NAME |
"blobs" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final int |
ADMIN |
4 |
public static final int |
READ |
1 |
public static final int |
WRITE |
2 |
| Modifier and Type | Constant Field | Value |
|---|---|---|
protected static final String |
BLOBSTORE_DATA_FILE |
"data" |
protected static final String |
TMP_EXT |
".tmp" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final int |
DEFAULT_EMIT_FREQUENCY |
2 |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
CASSANDRA_BATCH_SIZE_ROWS |
"cassandra.batch.size.rows" |
public static final String |
CASSANDRA_CONSISTENCY_LEVEL |
"cassandra.output.consistencyLevel" |
public static final String |
CASSANDRA_KEYSPACE |
"cassandra.keyspace" |
public static final String |
CASSANDRA_NODES |
"cassandra.nodes" |
public static final String |
CASSANDRA_PASSWORD |
"cassandra.password" |
public static final String |
CASSANDRA_PORT |
"cassandra.port" |
public static final String |
CASSANDRA_RECONNECT_POLICY_BASE_MS |
"cassandra.reconnectionPolicy.baseDelayMs" |
public static final String |
CASSANDRA_RECONNECT_POLICY_MAX_MS |
"cassandra.reconnectionPolicy.maxDelayMs" |
public static final String |
CASSANDRA_RETRY_POLICY |
"cassandra.retryPolicy" |
public static final String |
CASSANDRA_USERNAME |
"cassandra.username" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
ASSIGNMENTS_ROOT |
"assignments" |
public static final String |
ASSIGNMENTS_SUBTREE |
"/assignments" |
public static final String |
BACKPRESSURE_ROOT |
"backpressure" |
public static final String |
BACKPRESSURE_SUBTREE |
"/backpressure" |
public static final String |
BLOBSTORE_MAX_KEY_SEQUENCE_NUMBER_ROOT |
"blobstoremaxkeysequencenumber" |
public static final String |
BLOBSTORE_MAX_KEY_SEQUENCE_NUMBER_SUBTREE |
"/blobstoremaxkeysequencenumber" |
public static final String |
BLOBSTORE_ROOT |
"blobstore" |
public static final String |
BLOBSTORE_SUBTREE |
"/blobstore" |
public static final String |
CODE_ROOT |
"code" |
public static final String |
CREDENTIALS_ROOT |
"credentials" |
public static final String |
CREDENTIALS_SUBTREE |
"/credentials" |
public static final String |
ERRORS_ROOT |
"errors" |
public static final String |
ERRORS_SUBTREE |
"/errors" |
public static final String |
LOGCONFIG_ROOT |
"logconfigs" |
public static final String |
LOGCONFIG_SUBTREE |
"/logconfigs" |
public static final String |
NIMBUSES_ROOT |
"nimbuses" |
public static final String |
NIMBUSES_SUBTREE |
"/nimbuses" |
public static final String |
PROFILERCONFIG_ROOT |
"profilerconfigs" |
public static final String |
PROFILERCONFIG_SUBTREE |
"/profilerconfigs" |
public static final String |
STORMS_ROOT |
"storms" |
public static final String |
STORMS_SUBTREE |
"/storms" |
public static final String |
SUPERVISORS_ROOT |
"supervisors" |
public static final String |
SUPERVISORS_SUBTREE |
"/supervisors" |
public static final String |
WORKERBEATS_ROOT |
"workerbeats" |
public static final String |
WORKERBEATS_SUBTREE |
"/workerbeats" |
public static final String |
ZK_SEPERATOR |
"/" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
DATA |
"data" |
public static final String |
VERSION |
"version" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
CGROUP_CLONE_CHILDREN |
"/cgroup.clone_children" |
public static final String |
CGROUP_EVENT_CONTROL |
"/cgroup.event_control" |
public static final String |
CGROUP_PROCS |
"/cgroup.procs" |
public static final String |
NOTIFY_ON_RELEASE |
"/notify_on_release" |
public static final String |
RELEASE_AGENT |
"/release_agent" |
public static final String |
TASKS |
"/tasks" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
CGROUP_STATUS_FILE |
"/proc/cgroups" |
public static final String |
MOUNT_STATUS_FILE |
"/proc/mounts" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
BLKIO_IO_MERGED |
"/blkio.io_merged" |
public static final String |
BLKIO_IO_QUEUED |
"/blkio.io_queued" |
public static final String |
BLKIO_IO_SERVICE_BYTES |
"/blkio.io_service_bytes" |
public static final String |
BLKIO_IO_SERVICE_TIME |
"/blkio.io_service_time" |
public static final String |
BLKIO_IO_SERVICED |
"/blkio.io_serviced" |
public static final String |
BLKIO_IO_WAIT_TIME |
"/blkio.io_wait_time" |
public static final String |
BLKIO_RESET_STATS |
"/blkio.reset_stats" |
public static final String |
BLKIO_SECTORS |
"/blkio.sectors" |
public static final String |
BLKIO_THROTTLE_IO_SERVICE_BYTES |
"/blkio.throttle.io_service_bytes" |
public static final String |
BLKIO_THROTTLE_IO_SERVICED |
"/blkio.throttle.io_serviced" |
public static final String |
BLKIO_THROTTLE_READ_BPS_DEVICE |
"/blkio.throttle.read_bps_device" |
public static final String |
BLKIO_THROTTLE_READ_IOPS_DEVICE |
"/blkio.throttle.read_iops_device" |
public static final String |
BLKIO_THROTTLE_WRITE_BPS_DEVICE |
"/blkio.throttle.write_bps_device" |
public static final String |
BLKIO_THROTTLE_WRITE_IOPS_DEVICE |
"/blkio.throttle.write_iops_device" |
public static final String |
BLKIO_TIME |
"/blkio.time" |
public static final String |
BLKIO_WEIGHT |
"/blkio.weight" |
public static final String |
BLKIO_WEIGHT_DEVICE |
"/blkio.weight_device" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
CPUACCT_STAT |
"/cpuacct.stat" |
public static final String |
CPUACCT_USAGE |
"/cpuacct.usage" |
public static final String |
CPUACCT_USAGE_PERCPU |
"/cpuacct.usage_percpu" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
CPU_CFS_PERIOD_US |
"/cpu.cfs_period_us" |
public static final String |
CPU_CFS_QUOTA_US |
"/cpu.cfs_quota_us" |
public static final String |
CPU_RT_PERIOD_US |
"/cpu.rt_period_us" |
public static final String |
CPU_RT_RUNTIME_US |
"/cpu.rt_runtime_us" |
public static final String |
CPU_SHARES |
"/cpu.shares" |
public static final String |
CPU_STAT |
"/cpu.stat" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
CPUSET_CPU_EXCLUSIVE |
"/cpuset.cpu_exclusive" |
public static final String |
CPUSET_CPUS |
"/cpuset.cpus" |
public static final String |
CPUSET_MEM_EXCLUSIVE |
"/cpuset.mem_exclusive" |
public static final String |
CPUSET_MEM_HARDWALL |
"/cpuset.mem_hardwall" |
public static final String |
CPUSET_MEMORY_MIGRATE |
"/cpuset.memory_migrate" |
public static final String |
CPUSET_MEMORY_PRESSURE |
"/cpuset.memory_pressure" |
public static final String |
CPUSET_MEMORY_PRESSURE_ENABLED |
"/cpuset.memory_pressure_enabled" |
public static final String |
CPUSET_MEMORY_SPREAD_PAGE |
"/cpuset.memory_spread_page" |
public static final String |
CPUSET_MEMORY_SPREAD_SLAB |
"/cpuset.memory_spread_slab" |
public static final String |
CPUSET_MEMS |
"/cpuset.mems" |
public static final String |
CPUSET_SCHED_LOAD_BALANCE |
"/cpuset.sched_load_balance" |
public static final String |
CPUSET_SCHED_RELAX_DOMAIN_LEVEL |
"/cpuset.sched_relax_domain_level" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
FREEZER_STATE |
"/freezer.state" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
MEMORY_FAILCNT |
"/memory.failcnt" |
public static final String |
MEMORY_FORCE_EMPTY |
"/memory.force_empty" |
public static final String |
MEMORY_LIMIT_IN_BYTES |
"/memory.limit_in_bytes" |
public static final String |
MEMORY_MAX_USAGE_IN_BYTES |
"/memory.max_usage_in_bytes" |
public static final String |
MEMORY_MEMSW_FAILCNT |
"/memory.memsw.failcnt" |
public static final String |
MEMORY_MEMSW_LIMIT_IN_BYTES |
"/memory.memsw.limit_in_bytes" |
public static final String |
MEMORY_MEMSW_MAX_USAGE_IN_BYTES |
"/memory.memsw.max_usage_in_bytes" |
public static final String |
MEMORY_MEMSW_USAGE_IN_BYTES |
"/memory.memsw.usage_in_bytes" |
public static final String |
MEMORY_OOM_CONTROL |
"/memory.oom_control" |
public static final String |
MEMORY_STAT |
"/memory.stat" |
public static final String |
MEMORY_SWAPPINESS |
"/memory.swappiness" |
public static final String |
MEMORY_USAGE_IN_BYTES |
"/memory.usage_in_bytes" |
public static final String |
MEMORY_USE_HIERARCHY |
"/memory.use_hierarchy" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
NET_CLS_CLASSID |
"/net_cls.classid" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
NET_PRIO_IFPRIOMAP |
"/net_prio.ifpriomap" |
public static final String |
NET_PRIO_PRIOIDX |
"/net_prio.prioidx" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
ACKER_ACK_STREAM_ID |
"__ack_ack" |
public static final String |
ACKER_COMPONENT_ID |
"__acker" |
public static final String |
ACKER_FAIL_STREAM_ID |
"__ack_fail" |
public static final String |
ACKER_INIT_STREAM_ID |
"__ack_init" |
public static final String |
ACKER_RESET_TIMEOUT_STREAM_ID |
"__ack_reset_timeout" |
public static final int |
TIMEOUT_BUCKET_NUM |
3 |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
EVENTLOGGER_COMPONENT_ID |
"__eventlogger" |
public static final String |
EVENTLOGGER_STREAM_ID |
"__eventlog" |
public static final String |
SYSTEM_STREAM_ID |
"__system" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
ARGS_STREAM |
"default" |
public static final String |
ID_STREAM |
"id" |
public static final String |
RETURN_STREAM |
"ret" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
EH_SERVICE_FQDN_SUFFIX |
"servicebus.windows.net" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
Message |
"message" |
public static final String |
Offset |
"offset" |
public static final String |
PartitionKey |
"partitionKey" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
DEFAULT_METHOD_NAME |
"getTopology" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
HBASE_CREDENTIALS |
"HBASE_CREDENTIALS" |
public static final String |
HBASE_KEYTAB_FILE_KEY |
"hbase.keytab.file" |
public static final String |
HBASE_PRINCIPAL_KEY |
"hbase.kerberos.principal" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
STORM_KEYTAB_FILE_KEY |
"storm.keytab.file" |
public static final String |
STORM_USER_NAME_KEY |
"storm.kerberos.principal" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
DEFAULT_FIELD_DELIMITER |
"," |
public static final String |
DEFAULT_RECORD_DELIMITER |
"\n" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
HDFS_CREDENTIALS |
"HDFS_CREDENTIALS" |
public static final String |
TOPOLOGY_HDFS_URI |
"topology.hdfs.uri" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
STORM_KEYTAB_FILE_KEY |
"hdfs.keytab.file" |
public static final String |
STORM_USER_NAME_KEY |
"hdfs.kerberos.principal" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
ARCHIVE_DIR |
"hdfsspout.archive.dir" |
public static final String |
BAD_DIR |
"hdfsspout.badfiles.dir" |
public static final String |
CLOCKS_INSYNC |
"hdfsspout.clocks.insync" |
public static final String |
COMMIT_FREQ_COUNT |
"hdfsspout.commit.count" |
public static final String |
COMMIT_FREQ_SEC |
"hdfsspout.commit.sec" |
public static final int |
DEFAULT_COMMIT_FREQ_COUNT |
20000 |
public static final int |
DEFAULT_COMMIT_FREQ_SEC |
10 |
public static final String |
DEFAULT_HDFS_CONFIG_KEY |
"hdfs.config" |
public static final String |
DEFAULT_LOCK_DIR |
".lock" |
public static final int |
DEFAULT_LOCK_TIMEOUT |
300 |
public static final int |
DEFAULT_MAX_OUTSTANDING |
10000 |
public static final String |
HDFS_URI |
"hdfsspout.hdfs" |
public static final String |
IGNORE_SUFFIX |
"hdfsspout.ignore.suffix" |
public static final String |
LOCK_DIR |
"hdfsspout.lock.dir" |
public static final String |
LOCK_TIMEOUT |
"hdfsspout.lock.timeout.sec" |
public static final String |
MAX_OUTSTANDING |
"hdfsspout.max.outstanding" |
public static final String |
READER_TYPE |
"hdfsspout.reader.type" |
public static final String |
SEQ |
"seq" |
public static final String |
SOURCE_DIR |
"hdfsspout.source.dir" |
public static final String |
TEXT |
"text" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
DIR_LOCK_FILE |
"DIRLOCK" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
BUFFER_SIZE |
"hdfsspout.reader.buffer.bytes" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
DEFAULT_FIELD_DELIMITER |
"," |
public static final String |
DEFAULT_RECORD_DELIMITER |
"\n" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
STRING_SCHEME_OFFSET |
"offset" |
public static final String |
STRING_SCHEME_PARTITION_KEY |
"partition" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
STRING_SCHEME_KEY |
"str" |
public static final String |
TOPIC_KEY |
"topic" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
STRING_SCHEME_KEY |
"str" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
TOPIC |
"topic" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
BOLT_KEY |
"key" |
public static final String |
BOLT_MESSAGE |
"message" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
ARCHIVESDIR |
"archives" |
public static final String |
FILECACHE |
"filecache" |
public static final String |
FILESDIR |
"files" |
public static final String |
USERCACHE |
"usercache" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final short |
IDENTIFIER |
-500 |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
FIELD_COMPONENT_ID |
"component-id" |
public static final String |
FIELD_MESSAGE_ID |
"message-id" |
public static final String |
FIELD_TS |
"ts" |
public static final String |
FIELD_VALUES |
"values" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
DEFAULT_CHARSET |
"UTF-8" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
DEFAULT_RACK |
"/default-rack" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
KERBEROS_HANDLER |
"kerberos-handler" |
public static final String |
SASL_HANDLER |
"sasl-handler" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
KERBEROS_HANDLER |
"kerberos-handler" |
public static final String |
SASL_HANDLER |
"sasl-handler" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
DEFAULT_HOST |
"127.0.0.1" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
protected static final String |
PASSWORD |
"password" |
protected static final String |
USERNAME |
"username" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
LOGIN_CONTEXT_CLIENT |
"StormClient" |
public static final String |
LOGIN_CONTEXT_PACEMAKER_CLIENT |
"PacemakerClient" |
public static final String |
LOGIN_CONTEXT_PACEMAKER_DIGEST |
"PacemakerDigest" |
public static final String |
LOGIN_CONTEXT_PACEMAKER_SERVER |
"PacemakerServer" |
public static final String |
LOGIN_CONTEXT_SERVER |
"StormServer" |
public static final String |
SERVICE |
"storm_thrift_server" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
FUNCTION_NAME |
"function.name" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
CLIENT_USERS_KEY |
"client.users" |
public static final String |
FUNCTION_KEY |
"function.name" |
public static final String |
INVOCATION_USER_KEY |
"invocation.user" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
protected static final String |
WILD_CARD |
"*" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
WHITELIST_USERS_CONF |
"storm.auth.simple-white-list.users" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
DIGEST |
"DIGEST-MD5" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
SYSPROP_SUPER_PASSWORD |
"storm.SASLAuthenticationProvider.superPassword" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
KERBEROS |
"GSSAPI" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
protected static final int |
DEFAULT_MAX_LENGTH |
2147483647 |
protected static final int |
MECHANISM_NAME_BYTES |
1 |
protected static final int |
PAYLOAD_LENGTH_BYTES |
4 |
protected static final int |
STATUS_BYTES |
1 |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
PLAIN |
"PLAIN" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
PASSWORD |
"password" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
SASL_PLAIN_SERVER |
"SaslPlainServer" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
SECRET_KEY |
"topology.tuple.serializer.blowfish.key" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
CHECKPOINT_COMPONENT_ID |
"$checkpointspout" |
public static final String |
CHECKPOINT_FIELD_ACTION |
"action" |
public static final String |
CHECKPOINT_FIELD_TXID |
"txid" |
public static final String |
CHECKPOINT_STREAM_ID |
"$checkpoint" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final int |
DEFAULT_IDENTIFIER_MAX_LENGTH |
128 |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final boolean |
staticFlag |
false |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final int |
A |
1 |
public static final int |
ABS |
2 |
public static final int |
ABSOLUTE |
3 |
public static final int |
ACTION |
4 |
public static final int |
ADA |
5 |
public static final int |
ADD |
6 |
public static final int |
ADMIN |
7 |
public static final int |
AFTER |
8 |
public static final int |
ALL |
9 |
public static final int |
ALLOCATE |
10 |
public static final int |
ALLOW |
11 |
public static final int |
ALTER |
13 |
public static final int |
ALWAYS |
12 |
public static final int |
AND |
14 |
public static final int |
ANY |
15 |
public static final int |
APPROX_NUMERIC_LITERAL |
531 |
public static final int |
ARE |
16 |
public static final int |
ARRAY |
17 |
public static final int |
AS |
18 |
public static final int |
ASC |
19 |
public static final int |
ASENSITIVE |
20 |
public static final int |
ASSERTION |
21 |
public static final int |
ASSIGNMENT |
22 |
public static final int |
ASYMMETRIC |
23 |
public static final int |
AT |
24 |
public static final int |
ATOMIC |
25 |
public static final int |
ATTRIBUTE |
26 |
public static final int |
ATTRIBUTES |
27 |
public static final int |
AUTHORIZATION |
28 |
public static final int |
AVG |
29 |
public static final int |
BACK_QUOTED_IDENTIFIER |
586 |
public static final int |
BEFORE |
30 |
public static final int |
BEGIN |
31 |
public static final int |
BEL |
592 |
public static final int |
BERNOULLI |
32 |
public static final int |
BETWEEN |
33 |
public static final int |
BIGINT |
34 |
public static final int |
BINARY |
35 |
public static final int |
BINARY_STRING_LITERAL |
536 |
public static final int |
BIT |
36 |
public static final int |
BLOB |
37 |
public static final int |
BOOLEAN |
38 |
public static final int |
BOTH |
39 |
public static final int |
BRACKET_QUOTED_IDENTIFIER |
584 |
public static final int |
BREADTH |
40 |
public static final int |
BTID |
2 |
public static final int |
BY |
41 |
public static final int |
C |
42 |
public static final int |
CALL |
43 |
public static final int |
CALLED |
44 |
public static final int |
CARDINALITY |
45 |
public static final int |
CASCADE |
46 |
public static final int |
CASCADED |
47 |
public static final int |
CASE |
48 |
public static final int |
CAST |
49 |
public static final int |
CATALOG |
50 |
public static final int |
CATALOG_NAME |
51 |
public static final int |
CEIL |
52 |
public static final int |
CEILING |
53 |
public static final int |
CHAIN |
54 |
public static final int |
CHAR |
55 |
public static final int |
CHAR_LENGTH |
56 |
public static final int |
CHARACTER |
57 |
public static final int |
CHARACTER_LENGTH |
58 |
public static final int |
CHARACTER_SET_CATALOG |
59 |
public static final int |
CHARACTER_SET_NAME |
60 |
public static final int |
CHARACTER_SET_SCHEMA |
61 |
public static final int |
CHARACTERISTICS |
62 |
public static final int |
CHARACTERS |
63 |
public static final int |
CHARSETNAME |
540 |
public static final int |
CHECK |
64 |
public static final int |
CLASS_ORIGIN |
65 |
public static final int |
CLOB |
66 |
public static final int |
CLOSE |
67 |
public static final int |
COALESCE |
68 |
public static final int |
COBOL |
69 |
public static final int |
COLLATE |
70 |
public static final int |
COLLATION |
71 |
public static final int |
COLLATION_CATALOG |
72 |
public static final int |
COLLATION_ID |
587 |
public static final int |
COLLATION_NAME |
73 |
public static final int |
COLLATION_SCHEMA |
74 |
public static final int |
COLLECT |
75 |
public static final int |
COLON |
559 |
public static final int |
COLUMN |
76 |
public static final int |
COLUMN_NAME |
77 |
public static final int |
COMMA |
554 |
public static final int |
COMMAND_FUNCTION |
78 |
public static final int |
COMMAND_FUNCTION_CODE |
79 |
public static final int |
COMMIT |
80 |
public static final int |
COMMITTED |
81 |
public static final int |
CONCAT |
567 |
public static final int |
CONDITION |
82 |
public static final int |
CONDITION_NUMBER |
83 |
public static final int |
CONNECT |
84 |
public static final int |
CONNECTION |
85 |
public static final int |
CONNECTION_NAME |
86 |
public static final int |
CONSTRAINT |
87 |
public static final int |
CONSTRAINT_CATALOG |
88 |
public static final int |
CONSTRAINT_NAME |
89 |
public static final int |
CONSTRAINT_SCHEMA |
90 |
public static final int |
CONSTRAINTS |
91 |
public static final int |
CONSTRUCTOR |
92 |
public static final int |
CONTAINS |
93 |
public static final int |
CONTINUE |
95 |
public static final int |
CONVERT |
94 |
public static final int |
CORR |
96 |
public static final int |
CORRESPONDING |
97 |
public static final int |
COUNT |
98 |
public static final int |
COVAR_POP |
99 |
public static final int |
COVAR_SAMP |
100 |
public static final int |
CREATE |
101 |
public static final int |
CROSS |
102 |
public static final int |
CUBE |
103 |
public static final int |
CUME_DIST |
104 |
public static final int |
CURRENT |
105 |
public static final int |
CURRENT_CATALOG |
106 |
public static final int |
CURRENT_DATE |
107 |
public static final int |
CURRENT_DEFAULT_TRANSFORM_GROUP |
108 |
public static final int |
CURRENT_PATH |
109 |
public static final int |
CURRENT_ROLE |
110 |
public static final int |
CURRENT_SCHEMA |
111 |
public static final int |
CURRENT_TIME |
112 |
public static final int |
CURRENT_TIMESTAMP |
113 |
public static final int |
CURRENT_TRANSFORM_GROUP_FOR_TYPE |
114 |
public static final int |
CURRENT_USER |
115 |
public static final int |
CURSOR |
116 |
public static final int |
CURSOR_NAME |
117 |
public static final int |
CYCLE |
118 |
public static final int |
DATA |
119 |
public static final int |
DATE |
120 |
public static final int |
DATETIME_INTERVAL_CODE |
121 |
public static final int |
DATETIME_INTERVAL_PRECISION |
122 |
public static final int |
DAY |
123 |
public static final int |
DEALLOCATE |
124 |
public static final int |
DEC |
125 |
public static final int |
DECIMAL |
126 |
public static final int |
DECIMAL_NUMERIC_LITERAL |
532 |
public static final int |
DECLARE |
127 |
public static final int |
DEFAULT |
0 |
public static final int |
DEFAULT_KW |
128 |
public static final int |
DEFAULTS |
129 |
public static final int |
DEFERRABLE |
130 |
public static final int |
DEFERRED |
131 |
public static final int |
DEFINED |
132 |
public static final int |
DEFINER |
133 |
public static final int |
DEGREE |
134 |
public static final int |
DELETE |
135 |
public static final int |
DENSE_RANK |
136 |
public static final int |
DEPTH |
137 |
public static final int |
DEREF |
138 |
public static final int |
DERIVED |
139 |
public static final int |
DESC |
141 |
public static final int |
DESCRIBE |
140 |
public static final int |
DESCRIPTION |
142 |
public static final int |
DESCRIPTOR |
143 |
public static final int |
DETERMINISTIC |
144 |
public static final int |
DIAGNOSTICS |
145 |
public static final int |
DIGIT |
591 |
public static final int |
DISALLOW |
146 |
public static final int |
DISCONNECT |
147 |
public static final int |
DISPATCH |
148 |
public static final int |
DISTINCT |
149 |
public static final int |
DOMAIN |
150 |
public static final int |
DOT |
553 |
public static final int |
DOUBLE |
151 |
public static final int |
DOUBLE_PERIOD |
568 |
public static final int |
DOUBLE_QUOTE |
570 |
public static final int |
DQID |
1 |
public static final int |
DROP |
152 |
public static final int |
DYNAMIC |
153 |
public static final int |
DYNAMIC_FUNCTION |
154 |
public static final int |
DYNAMIC_FUNCTION_CODE |
155 |
public static final int |
EACH |
156 |
public static final int |
ELEMENT |
157 |
public static final int |
ELSE |
158 |
public static final int |
END |
159 |
public static final int |
END_EXEC |
160 |
public static final int |
EOF |
0 |
public static final int |
EQ |
555 |
public static final int |
EQUALS |
161 |
public static final int |
ESCAPE |
162 |
public static final int |
EVERY |
163 |
public static final int |
EXCEPT |
164 |
public static final int |
EXCEPTION |
165 |
public static final int |
EXCLUDE |
166 |
public static final int |
EXCLUDING |
167 |
public static final int |
EXEC |
168 |
public static final int |
EXECUTE |
169 |
public static final int |
EXISTS |
170 |
public static final int |
EXP |
171 |
public static final int |
EXPLAIN |
172 |
public static final int |
EXPONENT |
533 |
public static final int |
EXTEND |
174 |
public static final int |
EXTERNAL |
173 |
public static final int |
EXTRACT |
175 |
public static final int |
FALSE |
176 |
public static final int |
FETCH |
177 |
public static final int |
FILTER |
178 |
public static final int |
FINAL |
179 |
public static final int |
FIRST |
180 |
public static final int |
FIRST_VALUE |
181 |
public static final int |
FLOAT |
182 |
public static final int |
FLOOR |
183 |
public static final int |
FOLLOWING |
184 |
public static final int |
FOR |
185 |
public static final int |
FOREIGN |
186 |
public static final int |
FORMAL_COMMENT |
581 |
public static final int |
FORTRAN |
187 |
public static final int |
FOUND |
188 |
public static final int |
FREE |
189 |
public static final int |
FROM |
190 |
public static final int |
FULL |
191 |
public static final int |
FUNCTION |
192 |
public static final int |
FUSION |
193 |
public static final int |
G |
194 |
public static final int |
GE |
561 |
public static final int |
GENERAL |
195 |
public static final int |
GENERATED |
196 |
public static final int |
GET |
197 |
public static final int |
GLOBAL |
198 |
public static final int |
GO |
199 |
public static final int |
GOTO |
200 |
public static final int |
GRANT |
201 |
public static final int |
GRANTED |
202 |
public static final int |
GROUP |
203 |
public static final int |
GROUPING |
204 |
public static final int |
GT |
556 |
public static final int |
HAVING |
205 |
public static final int |
HEXDIGIT |
534 |
public static final int |
HIERARCHY |
206 |
public static final int |
HOLD |
207 |
public static final int |
HOOK |
558 |
public static final int |
HOUR |
208 |
public static final int |
IDENTIFIER |
588 |
public static final int |
IDENTITY |
209 |
public static final int |
IMMEDIATE |
210 |
public static final int |
IMPLEMENTATION |
211 |
public static final int |
IMPORT |
212 |
public static final int |
IN |
213 |
public static final int |
IN_FORMAL_COMMENT |
4 |
public static final int |
IN_MULTI_LINE_COMMENT |
5 |
public static final int |
IN_SINGLE_LINE_COMMENT |
3 |
public static final int |
INCLUDING |
215 |
public static final int |
INCREMENT |
216 |
public static final int |
INDICATOR |
214 |
public static final int |
INITIALLY |
217 |
public static final int |
INNER |
218 |
public static final int |
INOUT |
219 |
public static final int |
INPUT |
220 |
public static final int |
INPUTFORMAT |
526 |
public static final int |
INSENSITIVE |
221 |
public static final int |
INSERT |
222 |
public static final int |
INSTANCE |
223 |
public static final int |
INSTANTIABLE |
224 |
public static final int |
INT |
225 |
public static final int |
INTEGER |
226 |
public static final int |
INTERSECT |
227 |
public static final int |
INTERSECTION |
228 |
public static final int |
INTERVAL |
229 |
public static final int |
INTO |
230 |
public static final int |
INVOKER |
231 |
public static final int |
IS |
232 |
public static final int |
ISOLATION |
233 |
public static final int |
JAVA |
234 |
public static final int |
JOIN |
235 |
public static final int |
K |
236 |
public static final int |
KEY |
237 |
public static final int |
KEY_MEMBER |
238 |
public static final int |
KEY_TYPE |
239 |
public static final int |
LABEL |
240 |
public static final int |
LANGUAGE |
241 |
public static final int |
LARGE |
242 |
public static final int |
LAST |
243 |
public static final int |
LAST_VALUE |
244 |
public static final int |
LATERAL |
245 |
public static final int |
LBRACE |
548 |
public static final int |
LBRACE_D |
544 |
public static final int |
LBRACE_FN |
547 |
public static final int |
LBRACE_T |
545 |
public static final int |
LBRACE_TS |
546 |
public static final int |
LBRACKET |
550 |
public static final int |
LE |
560 |
public static final int |
LEADING |
246 |
public static final int |
LEFT |
247 |
public static final int |
LENGTH |
248 |
public static final int |
LETTER |
590 |
public static final int |
LEVEL |
249 |
public static final int |
LIBRARY |
250 |
public static final int |
LIKE |
251 |
public static final int |
LIMIT |
252 |
public static final int |
LN |
253 |
public static final int |
LOCAL |
254 |
public static final int |
LOCALTIME |
255 |
public static final int |
LOCALTIMESTAMP |
256 |
public static final int |
LOCATION |
525 |
public static final int |
LOCATOR |
257 |
public static final int |
LOWER |
258 |
public static final int |
LPAREN |
542 |
public static final int |
LT |
557 |
public static final int |
M |
259 |
public static final int |
MAP |
260 |
public static final int |
MATCH |
261 |
public static final int |
MATCHED |
262 |
public static final int |
MAX |
263 |
public static final int |
MAXVALUE |
264 |
public static final int |
MEMBER |
265 |
public static final int |
MERGE |
266 |
public static final int |
MESSAGE_LENGTH |
267 |
public static final int |
MESSAGE_OCTET_LENGTH |
268 |
public static final int |
MESSAGE_TEXT |
269 |
public static final int |
METHOD |
270 |
public static final int |
MIN |
271 |
public static final int |
MINUS |
564 |
public static final int |
MINUTE |
272 |
public static final int |
MINVALUE |
273 |
public static final int |
MOD |
274 |
public static final int |
MODIFIES |
275 |
public static final int |
MODULE |
276 |
public static final int |
MONTH |
277 |
public static final int |
MORE_KW |
278 |
public static final int |
MULTI_LINE_COMMENT |
582 |
public static final int |
MULTISET |
279 |
public static final int |
MUMPS |
280 |
public static final int |
NAME |
281 |
public static final int |
NAMES |
282 |
public static final int |
NATIONAL |
283 |
public static final int |
NATURAL |
284 |
public static final int |
NCHAR |
285 |
public static final int |
NCLOB |
286 |
public static final int |
NE |
562 |
public static final int |
NESTING |
287 |
public static final int |
NEW |
288 |
public static final int |
NEXT |
289 |
public static final int |
NO |
290 |
public static final int |
NONE |
291 |
public static final int |
NORMALIZE |
292 |
public static final int |
NORMALIZED |
293 |
public static final int |
NOT |
294 |
public static final int |
NULL |
295 |
public static final int |
NULLABLE |
296 |
public static final int |
NULLIF |
297 |
public static final int |
NULLS |
298 |
public static final int |
NUMBER |
299 |
public static final int |
NUMERIC |
300 |
public static final int |
OBJECT |
301 |
public static final int |
OCTET_LENGTH |
302 |
public static final int |
OCTETS |
303 |
public static final int |
OF |
304 |
public static final int |
OFFSET |
305 |
public static final int |
OLD |
306 |
public static final int |
ON |
307 |
public static final int |
ONLY |
308 |
public static final int |
OPEN |
309 |
public static final int |
OPTION |
310 |
public static final int |
OPTIONS |
311 |
public static final int |
OR |
312 |
public static final int |
ORDER |
313 |
public static final int |
ORDERING |
314 |
public static final int |
ORDINALITY |
315 |
public static final int |
OTHERS |
316 |
public static final int |
OUT |
317 |
public static final int |
OUTER |
318 |
public static final int |
OUTPUT |
319 |
public static final int |
OUTPUTFORMAT |
527 |
public static final int |
OVER |
320 |
public static final int |
OVERLAPS |
321 |
public static final int |
OVERLAY |
322 |
public static final int |
OVERRIDING |
323 |
public static final int |
PAD |
324 |
public static final int |
PARAMETER |
325 |
public static final int |
PARAMETER_MODE |
326 |
public static final int |
PARAMETER_NAME |
327 |
public static final int |
PARAMETER_ORDINAL_POSITION |
328 |
public static final int |
PARAMETER_SPECIFIC_CATALOG |
329 |
public static final int |
PARAMETER_SPECIFIC_NAME |
330 |
public static final int |
PARAMETER_SPECIFIC_SCHEMA |
331 |
public static final int |
PARTIAL |
332 |
public static final int |
PARTITION |
333 |
public static final int |
PASCAL |
334 |
public static final int |
PASSTHROUGH |
335 |
public static final int |
PATH |
336 |
public static final int |
PERCENT_RANK |
337 |
public static final int |
PERCENTILE_CONT |
338 |
public static final int |
PERCENTILE_DISC |
339 |
public static final int |
PLACING |
340 |
public static final int |
PLAN |
341 |
public static final int |
PLI |
342 |
public static final int |
PLUS |
563 |
public static final int |
POSITION |
343 |
public static final int |
POWER |
344 |
public static final int |
PRECEDING |
345 |
public static final int |
PRECISION |
346 |
public static final int |
PREFIXED_STRING_LITERAL |
538 |
public static final int |
PREPARE |
347 |
public static final int |
PRESERVE |
348 |
public static final int |
PRIMARY |
349 |
public static final int |
PRIOR |
350 |
public static final int |
PRIVILEGES |
351 |
public static final int |
PROCEDURE |
352 |
public static final int |
PUBLIC |
353 |
public static final int |
QUOTE |
569 |
public static final int |
QUOTED_IDENTIFIER |
585 |
public static final int |
QUOTED_STRING |
537 |
public static final int |
RANGE |
354 |
public static final int |
RANK |
355 |
public static final int |
RBRACE |
549 |
public static final int |
RBRACKET |
551 |
public static final int |
READ |
356 |
public static final int |
READS |
357 |
public static final int |
REAL |
358 |
public static final int |
RECURSIVE |
359 |
public static final int |
REF |
360 |
public static final int |
REFERENCES |
361 |
public static final int |
REFERENCING |
362 |
public static final int |
REGR_AVGX |
363 |
public static final int |
REGR_AVGY |
364 |
public static final int |
REGR_COUNT |
365 |
public static final int |
REGR_INTERCEPT |
366 |
public static final int |
REGR_R2 |
367 |
public static final int |
REGR_SLOPE |
368 |
public static final int |
REGR_SXX |
369 |
public static final int |
REGR_SXY |
370 |
public static final int |
REGR_SYY |
371 |
public static final int |
RELATIVE |
372 |
public static final int |
RELEASE |
373 |
public static final int |
REPEATABLE |
374 |
public static final int |
RESTART |
375 |
public static final int |
RESTRICT |
376 |
public static final int |
RESULT |
377 |
public static final int |
RETURN |
378 |
public static final int |
RETURNED_CARDINALITY |
379 |
public static final int |
RETURNED_LENGTH |
380 |
public static final int |
RETURNED_OCTET_LENGTH |
381 |
public static final int |
RETURNED_SQLSTATE |
382 |
public static final int |
RETURNS |
383 |
public static final int |
REVOKE |
384 |
public static final int |
RIGHT |
385 |
public static final int |
ROLE |
386 |
public static final int |
ROLLBACK |
387 |
public static final int |
ROLLUP |
388 |
public static final int |
ROUTINE |
389 |
public static final int |
ROUTINE_CATALOG |
390 |
public static final int |
ROUTINE_NAME |
391 |
public static final int |
ROUTINE_SCHEMA |
392 |
public static final int |
ROW |
393 |
public static final int |
ROW_COUNT |
394 |
public static final int |
ROW_NUMBER |
395 |
public static final int |
ROWS |
396 |
public static final int |
RPAREN |
543 |
public static final int |
SAVEPOINT |
397 |
public static final int |
SCALE |
398 |
public static final int |
SCHEMA |
399 |
public static final int |
SCHEMA_NAME |
400 |
public static final int |
SCOPE |
401 |
public static final int |
SCOPE_CATALOGS |
402 |
public static final int |
SCOPE_NAME |
403 |
public static final int |
SCOPE_SCHEMA |
404 |
public static final int |
SCROLL |
405 |
public static final int |
SEARCH |
406 |
public static final int |
SECOND |
407 |
public static final int |
SECTION |
408 |
public static final int |
SECURITY |
409 |
public static final int |
SELECT |
410 |
public static final int |
SELF |
411 |
public static final int |
SEMICOLON |
552 |
public static final int |
SENSITIVE |
412 |
public static final int |
SEQUENCE |
413 |
public static final int |
SERIALIZABLE |
414 |
public static final int |
SERVER |
415 |
public static final int |
SERVER_NAME |
416 |
public static final int |
SESSION |
417 |
public static final int |
SESSION_USER |
418 |
public static final int |
SET |
419 |
public static final int |
SETS |
420 |
public static final int |
SIMILAR |
421 |
public static final int |
SIMPLE |
422 |
public static final int |
SINGLE_LINE_COMMENT |
580 |
public static final int |
SIZE |
423 |
public static final int |
SLASH |
566 |
public static final int |
SMALLINT |
424 |
public static final int |
SOME |
425 |
public static final int |
SOURCE |
426 |
public static final int |
SPACE |
427 |
public static final int |
SPECIFIC |
428 |
public static final int |
SPECIFIC_NAME |
429 |
public static final int |
SPECIFICTYPE |
430 |
public static final int |
SQL |
431 |
public static final int |
SQLEXCEPTION |
432 |
public static final int |
SQLSTATE |
433 |
public static final int |
SQLWARNING |
434 |
public static final int |
SQRT |
435 |
public static final int |
STAR |
565 |
public static final int |
START |
436 |
public static final int |
STATE |
437 |
public static final int |
STATEMENT |
438 |
public static final int |
STATIC |
439 |
public static final int |
STDDEV_POP |
440 |
public static final int |
STDDEV_SAMP |
441 |
public static final int |
STORED |
528 |
public static final int |
STREAM |
442 |
public static final int |
STRUCTURE |
443 |
public static final int |
STYLE |
444 |
public static final int |
SUBCLASS_ORIGIN |
445 |
public static final int |
SUBMULTISET |
446 |
public static final int |
SUBSTITUTE |
448 |
public static final int |
SUBSTRING |
447 |
public static final int |
SUM |
449 |
public static final int |
SYMMETRIC |
450 |
public static final int |
SYSTEM |
451 |
public static final int |
SYSTEM_USER |
452 |
public static final int |
TABLE |
453 |
public static final int |
TABLE_NAME |
454 |
public static final int |
TABLESAMPLE |
455 |
public static final int |
TBLPROPERTIES |
529 |
public static final int |
TEMPORARY |
456 |
public static final int |
THEN |
457 |
public static final int |
TIES |
458 |
public static final int |
TIME |
459 |
public static final int |
TIMESTAMP |
460 |
public static final int |
TIMEZONE_HOUR |
461 |
public static final int |
TIMEZONE_MINUTE |
462 |
public static final int |
TINYINT |
463 |
public static final int |
TO |
464 |
public static final int |
TOP_LEVEL_COUNT |
465 |
public static final int |
TRAILING |
466 |
public static final int |
TRANSACTION |
467 |
public static final int |
TRANSACTIONS_ACTIVE |
468 |
public static final int |
TRANSACTIONS_COMMITTED |
469 |
public static final int |
TRANSACTIONS_ROLLED_BACK |
470 |
public static final int |
TRANSFORM |
471 |
public static final int |
TRANSFORMS |
472 |
public static final int |
TRANSLATE |
473 |
public static final int |
TRANSLATION |
474 |
public static final int |
TREAT |
475 |
public static final int |
TRIGGER |
476 |
public static final int |
TRIGGER_CATALOG |
477 |
public static final int |
TRIGGER_NAME |
478 |
public static final int |
TRIGGER_SCHEMA |
479 |
public static final int |
TRIM |
480 |
public static final int |
TRUE |
481 |
public static final int |
TYPE |
482 |
public static final int |
UESCAPE |
483 |
public static final int |
UNBOUNDED |
484 |
public static final int |
UNCOMMITTED |
485 |
public static final int |
UNDER |
486 |
public static final int |
UNICODE_QUOTED_ESCAPE_CHAR |
541 |
public static final int |
UNICODE_QUOTED_IDENTIFIER |
589 |
public static final int |
UNICODE_STRING_LITERAL |
539 |
public static final int |
UNION |
487 |
public static final int |
UNIQUE |
488 |
public static final int |
UNKNOWN |
489 |
public static final int |
UNNAMED |
490 |
public static final int |
UNNEST |
491 |
public static final int |
UNSIGNED_INTEGER_LITERAL |
530 |
public static final int |
UPDATE |
492 |
public static final int |
UPPER |
493 |
public static final int |
UPSERT |
494 |
public static final int |
USAGE |
495 |
public static final int |
USER |
496 |
public static final int |
USER_DEFINED_TYPE_CATALOG |
497 |
public static final int |
USER_DEFINED_TYPE_CODE |
498 |
public static final int |
USER_DEFINED_TYPE_NAME |
499 |
public static final int |
USER_DEFINED_TYPE_SCHEMA |
500 |
public static final int |
USING |
501 |
public static final int |
VALUE |
502 |
public static final int |
VALUES |
503 |
public static final int |
VAR_POP |
504 |
public static final int |
VAR_SAMP |
505 |
public static final int |
VARBINARY |
507 |
public static final int |
VARCHAR |
506 |
public static final int |
VARYING |
508 |
public static final int |
VERSION |
509 |
public static final int |
VIEW |
510 |
public static final int |
WHEN |
511 |
public static final int |
WHENEVER |
512 |
public static final int |
WHERE |
513 |
public static final int |
WHITESPACE |
535 |
public static final int |
WIDTH_BUCKET |
514 |
public static final int |
WINDOW |
515 |
public static final int |
WITH |
516 |
public static final int |
WITHIN |
517 |
public static final int |
WITHOUT |
518 |
public static final int |
WORK |
519 |
public static final int |
WRAPPER |
520 |
public static final int |
WRITE |
521 |
public static final int |
XML |
522 |
public static final int |
YEAR |
523 |
public static final int |
ZONE |
524 |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
GLOBAL_COUNT_KEY |
"GLOBAL-COUNT" |
public static final int |
PARTITION_TAKE_PER_BATCH |
3 |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final int |
BUCKET_SIZE |
10 |
public static final int |
PARTITION_TAKE_PER_BATCH |
3 |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
ACKED |
"acked" |
public static final String |
EXECUTE_LATENCIES |
"execute-latencies" |
public static final String |
EXECUTED |
"executed" |
public static final String |
FAILED |
"failed" |
public static final String |
PROCESS_LATENCIES |
"process-latencies" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
EMITTED |
"emitted" |
public static final int |
NUM_STAT_BUCKETS |
20 |
public static final String |
RATE |
"rate" |
public static final String |
TRANSFERRED |
"transferred" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
ACKED |
"acked" |
public static final String |
COMPLETE_LATENCIES |
"complete-latencies" |
public static final String |
FAILED |
"failed" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final int |
TEN_MIN_IN_SECONDS |
600 |
public static final String |
TEN_MIN_IN_SECONDS_STR |
"600" |
public static final String |
TYPE |
"type" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
HEARTBEAT_STREAM_ID |
"__heartbeat" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
SHARED_EXECUTOR |
"executor" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
MAX_BATCH_SIZE_CONF |
"topology.spout.max.batch.size" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
ID_FIELD |
"$tx" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
BATCH_STREAM_ID |
"$batch" |
public static final String |
COMMIT_STREAM_ID |
"$commit" |
public static final long |
INIT_TXID |
1L |
public static final String |
SUCCESS_STREAM_ID |
"$success" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
COORD_STREAM_PREFIX |
"$coord-" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final int |
BROADCAST_DEST |
-2 |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
NIMBUS_DO_NOT_REASSIGN |
"NIMBUS-DO-NOT-REASSIGN" |
public static final String |
RESOURCES_SUBDIR |
"resources" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
LS_APPROVED_WORKERS |
"approved-workers" |
public static final String |
LS_ID |
"supervisor-id" |
public static final String |
LS_LOCAL_ASSIGNMENTS |
"local-assignments" |
public static final String |
LS_TOPO_HISTORY |
"topo-hist" |
public static final String |
LS_WORKER_HEARTBEAT |
"worker-heartbeat" |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
CURRENT_BLOB_SUFFIX_ID |
"current" |
public static final String |
DEFAULT_BLOB_VERSION_SUFFIX |
".version" |
public static final String |
DEFAULT_CURRENT_BLOB_SUFFIX |
".current" |
public static final String |
DEFAULT_STREAM_ID |
"default" |
public static final int |
SIGKILL |
9 |
public static final int |
SIGTERM |
15 |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final int |
EXPIRE_EVENTS_THRESHOLD |
100 |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
BOLT_ID |
"constbolt" |
public static final String |
SPOUT_ID |
"hdfsspout" |
public static final int |
WORKER_NUM |
1 |
| Modifier and Type | Constant Field | Value |
|---|---|---|
public static final String |
FIELDS |
"message" |
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.