Package | Description |
---|---|
org.apache.storm |
Modifier and Type | Field and Description |
---|---|
static String |
Config.BLOBSTORE_DIR
What directory to use for the blobstore.
|
static String |
Config.BLOBSTORE_HDFS_KEYTAB
keytab for nimbus/supervisor to use to access secure hdfs for the blobstore.
|
static String |
Config.BLOBSTORE_HDFS_PRINCIPAL
principal for nimbus/supervisor to use to access secure hdfs for the blobstore.
|
static String |
Config.BLOBSTORE_SUPERUSER
The blobstore super user has all read/write/admin permissions to all blobs - user running the blobstore.
|
static String |
Config.CLIENT_BLOBSTORE
What blobstore implementation the storm client should use.
|
static Object |
Config.CLIENT_JAR_TRANSFORMER
An implementation of @{link org.apache.storm.daemon.JarTransformer} that will can be used to transform a jar file before storm jar runs with it.
|
static String |
Config.DEV_ZOOKEEPER_PATH
The path to use as the zookeeper dir when running a zookeeper server via “storm dev-zookeeper”.
|
static String |
Config.DRPC_AUTHORIZER
Class name for authorization plugin for DRPC client
|
static String |
Config.DRPC_AUTHORIZER_ACL_FILENAME
File name of the DRPC Authorizer ACL.
|
static String |
Config.DRPC_HTTP_CREDS_PLUGIN
Class name of the HTTP credentials plugin for DRPC.
|
static String |
Config.DRPC_HTTP_FILTER
A class implementing javax.servlet.Filter for DRPC HTTP requests
|
static String |
Config.DRPC_HTTPS_KEY_PASSWORD
Password to the private key in the keystore for setting up HTTPS (SSL).
|
static String |
Config.DRPC_HTTPS_KEYSTORE_PASSWORD
Password to the keystore used by Storm DRPC for setting up HTTPS (SSL).
|
static String |
Config.DRPC_HTTPS_KEYSTORE_PATH
Path to the keystore used by Storm DRPC for setting up HTTPS (SSL).
|
static String |
Config.DRPC_HTTPS_KEYSTORE_TYPE
Type of keystore used by Storm DRPC for setting up HTTPS (SSL).
|
static String |
Config.DRPC_HTTPS_TRUSTSTORE_PASSWORD
Password to the truststore used by Storm DRPC setting up HTTPS (SSL).
|
static String |
Config.DRPC_HTTPS_TRUSTSTORE_PATH
Path to the truststore used by Storm DRPC setting up HTTPS (SSL).
|
static String |
Config.DRPC_HTTPS_TRUSTSTORE_TYPE
Type of truststore used by Storm DRPC for setting up HTTPS (SSL).
|
static String |
Config.DRPC_INVOCATIONS_THRIFT_TRANSPORT_PLUGIN
The DRPC invocations transport plug-in for Thrift client/server communication
|
static String |
Config.DRPC_THRIFT_TRANSPORT_PLUGIN
The DRPC transport plug-in for Thrift client/server communication
|
static String |
Config.JAVA_LIBRARY_PATH
This value is passed to spawned JVMs (e.g., Nimbus, Supervisor, and Workers) for the java.library.path value.
|
static String |
Config.LOGVIEWER_APPENDER_NAME
Appender name used by log viewer to determine log directory.
|
static String |
Config.LOGVIEWER_HTTPS_KEY_PASSWORD
Password to the private key in the keystore for setting up HTTPS (SSL).
|
static String |
Config.LOGVIEWER_HTTPS_KEYSTORE_PASSWORD
Password for the keystore for HTTPS for Storm Logviewer
|
static String |
Config.LOGVIEWER_HTTPS_KEYSTORE_PATH
Path to the keystore containing the certs used by Storm Logviewer for HTTPS communications
|
static String |
Config.LOGVIEWER_HTTPS_KEYSTORE_TYPE
Type of the keystore for HTTPS for Storm Logviewer.
|
static String |
Config.LOGVIEWER_HTTPS_TRUSTSTORE_PASSWORD
Password for the truststore for HTTPS for Storm Logviewer
|
static String |
Config.LOGVIEWER_HTTPS_TRUSTSTORE_PATH
Path to the truststore containing the certs used by Storm Logviewer for HTTPS communications
|
static String |
Config.LOGVIEWER_HTTPS_TRUSTSTORE_TYPE
Type of the truststore for HTTPS for Storm Logviewer.
|
static String |
Config.NIMBUS_AUTHORIZER
Class name for authorization plugin for Nimbus
|
static String |
Config.NIMBUS_BLOBSTORE
What blobstore implementation nimbus should use.
|
static String |
Config.NIMBUS_DAEMON_USER
This is the user that the Nimbus daemon process is running as.
|
static String |
Config.NIMBUS_HOST
Deprecated.
|
static String |
Config.NIMBUS_IMPERSONATION_AUTHORIZER
Impersonation user ACL config entries.
|
static String |
Config.NIMBUS_THRIFT_TRANSPORT_PLUGIN
The Nimbus transport plug-in for Thrift client/server communication
|
static String |
Config.NIMBUS_TOPOLOGY_VALIDATOR
A custom class that implements ITopologyValidator that is run whenever a topology is submitted.
|
static String |
Config.PACEMAKER_HOST
Deprecated.
in favor of PACEMAKER_SERVERS for Pacemaker-HA.
|
static String |
Config.STORM_CLUSTER_MODE
The mode this Storm cluster is running in.
|
static String |
Config.STORM_CLUSTER_STATE_STORE
The ClusterState factory that worker will use to create a ClusterState to store state in.
|
static String |
Config.STORM_DAEMON_METRICS_REPORTER_CSV_LOG_DIR
A specify csv reporter directory for CvsPreparableReporter daemon metrics reporter.
|
static String |
Config.STORM_DAEMON_METRICS_REPORTER_PLUGIN_DOMAIN
A specify domain for daemon metrics reporter plugin to limit reporting to specific domain.
|
static String |
Config.STORM_DAEMON_METRICS_REPORTER_PLUGIN_DURATION_UNIT
A specify duration-unit in TimeUnit to specify reporting window for daemon metrics reporter plugin.
|
static String |
Config.STORM_DAEMON_METRICS_REPORTER_PLUGIN_LOCALE
A specify Locale for daemon metrics reporter plugin.
|
static String |
Config.STORM_DAEMON_METRICS_REPORTER_PLUGIN_RATE_UNIT
A specify rate-unit in TimeUnit to specify reporting frequency for daemon metrics reporter plugin.
|
static String |
Config.STORM_DO_AS_USER
The user as which the nimbus client should be acquired to perform the operation.
|
static String |
Config.STORM_EXHIBITOR_URIPATH |
static String |
Config.STORM_GROUP_MAPPING_SERVICE_PROVIDER_PLUGIN
The plugin that will provide user groups service
|
static String |
Config.STORM_HEALTH_CHECK_DIR
The directory where storm’s health scripts go.
|
static String |
Config.STORM_ID
The id assigned to a running topology.
|
static String |
Config.STORM_LOCAL_DIR
A directory on the local filesystem used by Storm for any local filesystem usage it needs.
|
static String |
Config.STORM_LOCAL_HOSTNAME
The hostname the supervisors/workers should report to nimbus.
|
static String |
Config.STORM_LOG4J2_CONF_DIR
A directory that holds configuration files for log4j2.
|
static String |
Config.STORM_MESSAGING_TRANSPORT
The transporter for communication among Storm tasks
|
static String |
Config.STORM_META_SERIALIZATION_DELEGATE
The delegate for serializing metadata, should be used for serialized objects stored in zookeeper and on disk.
|
static String |
Config.STORM_PRINCIPAL_TO_LOCAL_PLUGIN
The plugin that will convert a principal to a local user.
|
static String |
Config.STORM_SCHEDULER
A global task scheduler used to assign topologies’s tasks to supervisors’ workers.
|
static String |
Config.STORM_THRIFT_TRANSPORT_PLUGIN
The default transport plug-in for Thrift client/server communication
|
static String |
Config.STORM_TOPOLOGY_SUBMISSION_NOTIFIER_PLUGIN
FQCN of a class that implements
ISubmitterHook @see ISubmitterHook for details. |
static String |
Config.STORM_WORKERS_ARTIFACTS_DIR
The workers-artifacts directory (where we place all workers’ logs), can be either absolute or relative.
|
static String |
Config.STORM_ZOOKEEPER_AUTH_PAYLOAD
A string representing the payload for cluster Zookeeper authentication.
|
static String |
Config.STORM_ZOOKEEPER_AUTH_SCHEME
The cluster Zookeeper authentication scheme to use, e.g.
|
static String |
Config.STORM_ZOOKEEPER_ROOT
The root location at which Storm stores data in ZooKeeper.
|
static String |
Config.STORM_ZOOKEEPER_SUPERACL
This is part of a temporary workaround to a ZK bug, it is the ‘scheme:acl’ for the user Nimbus and Supervisors use to authenticate with ZK.
|
static String |
Config.STORM_ZOOKEEPER_TOPOLOGY_AUTH_PAYLOAD
A string representing the payload for topology Zookeeper authentication.
|
static String |
Config.STORM_ZOOKEEPER_TOPOLOGY_AUTH_SCHEME
The topology Zookeeper authentication scheme to use, e.g.
|
static String |
Config.SUPERVISOR_BLOBSTORE
What blobstore implementation the supervisor should use.
|
static String |
Config.SUPERVISOR_WORKER_LAUNCHER
Full path to the worker-laucher executable that will be used to lauch workers when SUPERVISOR_RUN_WORKER_AS_USER is set to true.
|
static String |
Config.TOPOLOGY_BOLTS_LATE_TUPLE_STREAM
Bolt-specific configuration for windowed bolts to specify the name of the stream on which late tuples are going to be emitted.
|
static String |
Config.TOPOLOGY_BOLTS_MESSAGE_ID_FIELD_NAME |
static String |
Config.TOPOLOGY_DISRUPTOR_WAIT_STRATEGY
Deprecated.
this is no longer supported Configure the wait strategy used for internal queuing. Can be used to tradeoff latency vs. throughput
|
static String |
Config.TOPOLOGY_KRYO_FACTORY
Class that specifies how to create a Kryo instance for serialization.
|
static String |
Config.TOPOLOGY_LOGGING_SENSITIVITY
Topology central logging sensitivity to determine who has access to logs in central logging system.
|
static String |
Config.TOPOLOGY_MULTILANG_LOG_HANDLER
The fully qualified name of a
ShellLogHandler to handle output from non-JVM processes e.g. |
static String |
Config.TOPOLOGY_MULTILANG_SERIALIZER
The serializer for communication between shell components and non-JVM processes
|
static String |
Config.TOPOLOGY_NAME
Name of the topology.
|
static String |
Config.TOPOLOGY_SPOUT_WAIT_STRATEGY
A class that implements a strategy for what to do when a spout needs to wait.
|
static String |
Config.TOPOLOGY_STATE_PROVIDER
The class name of the
StateProvider implementation. |
static String |
Config.TOPOLOGY_STATE_PROVIDER_CONFIG
The configuration specific to the
StateProvider implementation. |
static String |
Config.TOPOLOGY_SUBMITTER_PRINCIPAL
The principal who submitted a topology
|
static String |
Config.TOPOLOGY_SUBMITTER_USER
The local user name of the user who submitted a topology.
|
static String |
Config.TOPOLOGY_TRANSACTIONAL_ID
This config is available for TransactionalSpouts, and contains the id ( a String) for the transactional topology.
|
static String |
Config.TOPOLOGY_TUPLE_SERIALIZER
The serializer class for ListDelegate (tuple payload).
|
static String |
Config.TRANSACTIONAL_ZOOKEEPER_ROOT
The root directory in ZooKeeper for metadata about TransactionalSpouts.
|
static String |
Config.UI_CENTRAL_LOGGING_URL
Storm UI Central Logging URL.
|
static String |
Config.UI_FILTER
A class implementing javax.servlet.Filter for authenticating/filtering UI requests
|
static String |
Config.UI_HOST
Storm UI binds to this host/interface.
|
static String |
Config.UI_HTTP_CREDS_PLUGIN
Class name of the HTTP credentials plugin for the UI.
|
static String |
Config.UI_HTTP_X_FRAME_OPTIONS
Value of X-FRAME-OPTIONS HTTP Header option used by Storm UI.
|
static String |
Config.UI_HTTPS_KEY_PASSWORD
Password to the private key in the keystore for setting up HTTPS (SSL).
|
static String |
Config.UI_HTTPS_KEYSTORE_PASSWORD
Password to the keystore used by Storm UI for setting up HTTPS (SSL).
|
static String |
Config.UI_HTTPS_KEYSTORE_PATH
Path to the keystore used by Storm UI for setting up HTTPS (SSL).
|
static String |
Config.UI_HTTPS_KEYSTORE_TYPE
Type of keystore used by Storm UI for setting up HTTPS (SSL).
|
static String |
Config.UI_HTTPS_TRUSTSTORE_PASSWORD
Password to the truststore used by Storm UI setting up HTTPS (SSL).
|
static String |
Config.UI_HTTPS_TRUSTSTORE_PATH
Path to the truststore used by Storm UI setting up HTTPS (SSL).
|
static String |
Config.UI_HTTPS_TRUSTSTORE_TYPE
Type of truststore used by Storm UI for setting up HTTPS (SSL).
|
static String |
Config.UI_PROJECT_BUGTRACKER_URL
Storm UI Project BUGTRACKER Link for reporting issue.
|
static String |
Config.WORKER_PROFILER_COMMAND
The command launched supervisor with worker arguments pid, action and [target_directory] Where action is - start profile, stop profile, jstack, heapdump and kill against pid
|
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.