public class Config extends HashMap<String,Object>
This class also provides constants for all the configurations possible on a Storm cluster and Storm topology. Each constant is paired with a schema that defines the validity criterion of the corresponding field. Default values for these configs can be found in defaults.yaml.
Note that you may put other configurations in any of the configs. Storm will ignore anything it doesn't recognize, but your topologies are free to make use of them by reading them in the prepare method of Bolts or the open method of Spouts.
AbstractMap.SimpleEntry<K,V>, AbstractMap.SimpleImmutableEntry<K,V>| Modifier and Type | Field and Description |
|---|---|
static String |
DEV_ZOOKEEPER_PATH
The path to use as the zookeeper dir when running a zookeeper server via
"storm dev-zookeeper".
|
static Object |
DEV_ZOOKEEPER_PATH_SCHEMA |
static String |
DRPC_AUTHORIZER
Class name for authorization plugin for DRPC client
|
static String |
DRPC_AUTHORIZER_ACL
The Access Control List for the DRPC Authorizer.
|
static String |
DRPC_AUTHORIZER_ACL_FILENAME
File name of the DRPC Authorizer ACL.
|
static Object |
DRPC_AUTHORIZER_ACL_FILENAME_SCHEMA |
static Object |
DRPC_AUTHORIZER_ACL_SCHEMA |
static String |
DRPC_AUTHORIZER_ACL_STRICT
Whether the DRPCSimpleAclAuthorizer should deny requests for operations
involving functions that have no explicit ACL entry.
|
static Object |
DRPC_AUTHORIZER_ACL_STRICT_SCHEMA |
static Object |
DRPC_AUTHORIZER_SCHEMA |
static String |
DRPC_CHILDOPTS
Childopts for Storm DRPC Java process.
|
static Object |
DRPC_CHILDOPTS_SCHEMA |
static String |
DRPC_HTTP_CREDS_PLUGIN
Class name of the HTTP credentials plugin for DRPC.
|
static Object |
DRPC_HTTP_CREDS_PLUGIN_SCHEMA |
static String |
DRPC_HTTP_FILTER
A class implementing javax.servlet.Filter for DRPC HTTP requests
|
static String |
DRPC_HTTP_FILTER_PARAMS
Initialization parameters for the javax.servlet.Filter of the DRPC HTTP
service
|
static Object |
DRPC_HTTP_FILTER_PARAMS_SCHEMA |
static Object |
DRPC_HTTP_FILTER_SCHEMA |
static String |
DRPC_HTTP_PORT
This port is used by Storm DRPC for receiving HTTP DPRC requests from clients.
|
static Object |
DRPC_HTTP_PORT_SCHEMA |
static String |
DRPC_HTTPS_KEY_PASSWORD
Password to the private key in the keystore for settting up HTTPS (SSL).
|
static Object |
DRPC_HTTPS_KEY_PASSWORD_SCHEMA |
static String |
DRPC_HTTPS_KEYSTORE_PASSWORD
Password to the keystore used by Storm DRPC for setting up HTTPS (SSL).
|
static Object |
DRPC_HTTPS_KEYSTORE_PASSWORD_SCHEMA |
static String |
DRPC_HTTPS_KEYSTORE_PATH
Path to the keystore used by Storm DRPC for setting up HTTPS (SSL).
|
static Object |
DRPC_HTTPS_KEYSTORE_PATH_SCHEMA |
static String |
DRPC_HTTPS_KEYSTORE_TYPE
Type of keystore used by Storm DRPC for setting up HTTPS (SSL).
|
static Object |
DRPC_HTTPS_KEYSTORE_TYPE_SCHEMA |
static String |
DRPC_HTTPS_NEED_CLIENT_AUTH |
static Object |
DRPC_HTTPS_NEED_CLIENT_AUTH_SCHEMA |
static String |
DRPC_HTTPS_PORT
This port is used by Storm DRPC for receiving HTTPS (SSL) DPRC requests from clients.
|
static Object |
DRPC_HTTPS_PORT_SCHEMA |
static String |
DRPC_HTTPS_TRUSTSTORE_PASSWORD
Password to the truststore used by Storm DRPC settting up HTTPS (SSL).
|
static Object |
DRPC_HTTPS_TRUSTSTORE_PASSWORD_SCHEMA |
static String |
DRPC_HTTPS_TRUSTSTORE_PATH
Path to the truststore used by Storm DRPC settting up HTTPS (SSL).
|
static Object |
DRPC_HTTPS_TRUSTSTORE_PATH_SCHEMA |
static String |
DRPC_HTTPS_TRUSTSTORE_TYPE
Type of truststore used by Storm DRPC for setting up HTTPS (SSL).
|
static Object |
DRPC_HTTPS_TRUSTSTORE_TYPE_SCHEMA |
static String |
DRPC_HTTPS_WANT_CLIENT_AUTH
Password to the truststore used by Storm DRPC settting up HTTPS (SSL).
|
static Object |
DRPC_HTTPS_WANT_CLIENT_AUTH_SCHEMA |
static String |
DRPC_INVOCATIONS_PORT
This port on Storm DRPC is used by DRPC topologies to receive function invocations and send results back.
|
static Object |
DRPC_INVOCATIONS_PORT_SCHEMA |
static String |
DRPC_INVOCATIONS_THREADS
DRPC invocations thrift server worker threads
|
static Object |
DRPC_INVOCATIONS_THREADS_SCHEMA |
static String |
DRPC_INVOCATIONS_THRIFT_TRANSPORT_PLUGIN
The DRPC invocations transport plug-in for Thrift client/server communication
|
static Object |
DRPC_INVOCATIONS_THRIFT_TRANSPORT_PLUGIN_SCHEMA |
static String |
DRPC_MAX_BUFFER_SIZE
The maximum buffer size thrift should use when reading messages for DRPC.
|
static Object |
DRPC_MAX_BUFFER_SIZE_SCHEMA |
static String |
DRPC_PORT
This port is used by Storm DRPC for receiving DPRC requests from clients.
|
static Object |
DRPC_PORT_SCHEMA |
static String |
DRPC_QUEUE_SIZE
DRPC thrift server queue size
|
static Object |
DRPC_QUEUE_SIZE_SCHEMA |
static String |
DRPC_REQUEST_TIMEOUT_SECS
The timeout on DRPC requests within the DRPC server.
|
static Object |
DRPC_REQUEST_TIMEOUT_SECS_SCHEMA |
static String |
DRPC_SERVERS
List of DRPC servers so that the DRPCSpout knows who to talk to.
|
static Object |
DRPC_SERVERS_SCHEMA |
static String |
DRPC_THRIFT_TRANSPORT_PLUGIN
The DRPC transport plug-in for Thrift client/server communication
|
static Object |
DRPC_THRIFT_TRANSPORT_PLUGIN_SCHEMA |
static String |
DRPC_WORKER_THREADS
DRPC thrift server worker threads
|
static Object |
DRPC_WORKER_THREADS_SCHEMA |
static String |
ISOLATION_SCHEDULER_MACHINES
A map from topology name to the number of machines that should be dedicated for that topology.
|
static Object |
ISOLATION_SCHEDULER_MACHINES_SCHEMA |
static String |
JAVA_LIBRARY_PATH
This value is passed to spawned JVMs (e.g., Nimbus, Supervisor, and Workers)
for the java.library.path value.
|
static Object |
JAVA_LIBRARY_PATH_SCHEMA |
static String |
LOGS_GROUPS
A list of groups allowed to view logs via the Log Viewer
|
static Object |
LOGS_GROUPS_SCHEMA |
static String |
LOGS_USERS
A list of users allowed to view logs via the Log Viewer
|
static Object |
LOGS_USERS_SCHEMA |
static String |
LOGVIEWER_APPENDER_NAME
Appender name used by log viewer to determine log directory.
|
static Object |
LOGVIEWER_APPENDER_NAME_SCHEMA |
static String |
LOGVIEWER_CHILDOPTS
Childopts for log viewer java process.
|
static Object |
LOGVIEWER_CHILDOPTS_SCHEMA |
static String |
LOGVIEWER_CLEANUP_AGE_MINS
How many minutes since a log was last modified for the log to be considered for clean-up
|
static Object |
LOGVIEWER_CLEANUP_AGE_MINS_SCHEMA |
static String |
LOGVIEWER_CLEANUP_INTERVAL_SECS
How often to clean up old log files
|
static Object |
LOGVIEWER_CLEANUP_INTERVAL_SECS_SCHEMA |
static String |
LOGVIEWER_PORT
HTTP UI port for log viewer
|
static Object |
LOGVIEWER_PORT_SCHEMA |
static String |
MULTITENANT_SCHEDULER_USER_POOLS
A map from the user name to the number of machines that should that user is allowed to use.
|
static Object |
MULTITENANT_SCHEDULER_USER_POOLS_SCHEMA |
static String |
NIMBUS_ADMINS
A list of users that are cluster admins and can run any command.
|
static Object |
NIMBUS_ADMINS_SCHEMA |
static String |
NIMBUS_AUTHORIZER
Class name for authorization plugin for Nimbus
|
static Object |
NIMBUS_AUTHORIZER_SCHEMA |
static String |
NIMBUS_AUTO_CRED_PLUGINS
A list of plugins that nimbus should load during submit topology to populate
credentials on user's behalf.
|
static Object |
NIMBUS_AUTO_CRED_PLUGINS_SCHEMA |
static String |
NIMBUS_CHILDOPTS
This parameter is used by the storm-deploy project to configure the
jvm options for the nimbus daemon.
|
static Object |
NIMBUS_CHILDOPTS_SCHEMA |
static String |
NIMBUS_CLEANUP_INBOX_FREQ_SECS
How often nimbus should wake the cleanup thread to clean the inbox.
|
static Object |
NIMBUS_CLEANUP_INBOX_FREQ_SECS_SCHEMA |
static String |
NIMBUS_CREDENTIAL_RENEW_FREQ_SECS
How often nimbus should wake up to renew credentials if needed.
|
static Object |
NIMBUS_CREDENTIAL_RENEW_FREQ_SECS_SCHEMA |
static String |
NIMBUS_CREDENTIAL_RENEWERS
A list of credential renewers that nimbus should load.
|
static Object |
NIMBUS_CREDENTIAL_RENEWERS_SCHEMA |
static String |
NIMBUS_EXECUTORS_PER_TOPOLOGY
A number representing the maximum number of executors any single topology can acquire.
|
static Object |
NIMBUS_EXECUTORS_PER_TOPOLOGY_SCHEMA |
static String |
NIMBUS_FILE_COPY_EXPIRATION_SECS
During upload/download with the master, how long an upload or download connection is idle
before nimbus considers it dead and drops the connection.
|
static Object |
NIMBUS_FILE_COPY_EXPIRATION_SECS_SCHEMA |
static String |
NIMBUS_GROUPS
A list of groups , users belong to these groups are the only ones allowed to run user operation on storm cluster.
|
static Object |
NIMBUS_GROUPS_SCHEMA |
static String |
NIMBUS_HOST
The host that the master server is running on.
|
static Object |
NIMBUS_HOST_SCHEMA |
static String |
NIMBUS_IMPERSONATION_ACL
Impersonation user ACL config entries.
|
static Object |
NIMBUS_IMPERSONATION_ACL_SCHEMA |
static String |
NIMBUS_IMPERSONATION_AUTHORIZER
Impersonation user ACL config entries.
|
static Object |
NIMBUS_IMPERSONATION_AUTHORIZER_SCHEMA |
static String |
NIMBUS_INBOX_JAR_EXPIRATION_SECS
The length of time a jar file lives in the inbox before being deleted by the cleanup thread.
|
static Object |
NIMBUS_INBOX_JAR_EXPIRATION_SECS_SCHEMA |
static String |
NIMBUS_MONITOR_FREQ_SECS
How often nimbus should wake up to check heartbeats and do reassignments.
|
static Object |
NIMBUS_MONITOR_FREQ_SECS_SCHEMA |
static String |
NIMBUS_REASSIGN
Whether or not nimbus should reassign tasks if it detects that a task goes down.
|
static Object |
NIMBUS_REASSIGN_SCHEMA |
static String |
NIMBUS_SLOTS_PER_TOPOLOGY
A number representing the maximum number of workers any single topology can acquire.
|
static Object |
NIMBUS_SLOTS_PER_TOPOLOGY_SCHEMA |
static String |
NIMBUS_SUPERVISOR_TIMEOUT_SECS
How long before a supervisor can go without heartbeating before nimbus considers it dead
and stops assigning new work to it.
|
static Object |
NIMBUS_SUPERVISOR_TIMEOUT_SECS_SCHEMA |
static String |
NIMBUS_SUPERVISOR_USERS
A list of users that run the supervisors and should be authorized to interact with
nimbus as a supervisor would.
|
static Object |
NIMBUS_SUPERVISOR_USERS_SCHEMA |
static String |
NIMBUS_TASK_LAUNCH_SECS
A special timeout used when a task is initially launched.
|
static Object |
NIMBUS_TASK_LAUNCH_SECS_SCHEMA |
static String |
NIMBUS_TASK_TIMEOUT_SECS
How long without heartbeating a task can go before nimbus will consider the
task dead and reassign it to another location.
|
static Object |
NIMBUS_TASK_TIMEOUT_SECS_SCHEMA |
static String |
NIMBUS_THRIFT_MAX_BUFFER_SIZE
The maximum buffer size thrift should use when reading messages.
|
static Object |
NIMBUS_THRIFT_MAX_BUFFER_SIZE_SCHEMA |
static String |
NIMBUS_THRIFT_PORT
Which port the Thrift interface of Nimbus should run on.
|
static Object |
NIMBUS_THRIFT_PORT_SCHEMA |
static String |
NIMBUS_THRIFT_THREADS
The number of threads that should be used by the nimbus thrift server.
|
static Object |
NIMBUS_THRIFT_THREADS_SCHEMA |
static String |
NIMBUS_THRIFT_TRANSPORT_PLUGIN
The Nimbus transport plug-in for Thrift client/server communication
|
static Object |
NIMBUS_THRIFT_TRANSPORT_PLUGIN_SCHEMA |
static String |
NIMBUS_TOPOLOGY_VALIDATOR
A custom class that implements ITopologyValidator that is run whenever a
topology is submitted.
|
static Object |
NIMBUS_TOPOLOGY_VALIDATOR_SCHEMA |
static String |
NIMBUS_USERS
A list of users that are the only ones allowed to run user operation on storm cluster.
|
static Object |
NIMBUS_USERS_SCHEMA |
static String |
STORM_CLUSTER_MODE
The mode this Storm cluster is running in.
|
static Object |
STORM_CLUSTER_MODE_SCHEMA |
static String |
STORM_DO_AS_USER
The user as which the nimbus client should be acquired to perform the operation.
|
static Object |
STORM_DO_AS_USER_SCHEMA |
static String |
STORM_GROUP_MAPPING_SERVICE_CACHE_DURATION_SECS
Max no.of seconds group mapping service will cache user groups
|
static Object |
STORM_GROUP_MAPPING_SERVICE_CACHE_DURATION_SECS_SCHEMA |
static String |
STORM_GROUP_MAPPING_SERVICE_PROVIDER_PLUGIN
The plugin that will provide user groups service
|
static Object |
STORM_GROUP_MAPPING_SERVICE_PROVIDER_PLUGIN_SCHEMA |
static String |
STORM_ID
The id assigned to a running topology.
|
static Object |
STORM_ID_SCHEMA |
static String |
STORM_LOCAL_DIR
A directory on the local filesystem used by Storm for any local
filesystem usage it needs.
|
static Object |
STORM_LOCAL_DIR_SCHEMA |
static String |
STORM_LOCAL_HOSTNAME
The hostname the supervisors/workers should report to nimbus.
|
static Object |
STORM_LOCAL_HOSTNAME_SCHEMA |
static String |
STORM_LOCAL_MODE_ZMQ
Whether or not to use ZeroMQ for messaging in local mode.
|
static Object |
STORM_LOCAL_MODE_ZMQ_SCHEMA |
static String |
STORM_MESSAGING_NETTY_AUTHENTICATION
Netty based messaging: Is authentication required for Netty messaging from client worker process to server worker process.
|
static Object |
STORM_MESSAGING_NETTY_AUTHENTICATION_SCHEMA |
static String |
STORM_MESSAGING_NETTY_BUFFER_SIZE
Netty based messaging: The buffer size for send/recv buffer
|
static Object |
STORM_MESSAGING_NETTY_BUFFER_SIZE_SCHEMA |
static String |
STORM_MESSAGING_NETTY_CLIENT_WORKER_THREADS
Netty based messaging: The # of worker threads for the client.
|
static Object |
STORM_MESSAGING_NETTY_CLIENT_WORKER_THREADS_SCHEMA |
static String |
STORM_MESSAGING_NETTY_MAX_RETRIES
Netty based messaging: The max # of retries that a peer will perform when a remote is not accessible
|
static Object |
STORM_MESSAGING_NETTY_MAX_RETRIES_SCHEMA |
static String |
STORM_MESSAGING_NETTY_MAX_SLEEP_MS
Netty based messaging: The max # of milliseconds that a peer will wait.
|
static Object |
STORM_MESSAGING_NETTY_MAX_SLEEP_MS_SCHEMA |
static String |
STORM_MESSAGING_NETTY_MIN_SLEEP_MS
Netty based messaging: The min # of milliseconds that a peer will wait.
|
static Object |
STORM_MESSAGING_NETTY_MIN_SLEEP_MS_SCHEMA |
static String |
STORM_MESSAGING_NETTY_SERVER_WORKER_THREADS
Netty based messaging: The # of worker threads for the server.
|
static Object |
STORM_MESSAGING_NETTY_SERVER_WORKER_THREADS_SCHEMA |
static String |
STORM_MESSAGING_NETTY_SOCKET_BACKLOG
Netty based messaging: Sets the backlog value to specify when the channel binds to a local address
|
static Object |
STORM_MESSAGING_NETTY_SOCKET_BACKLOG_SCHEMA |
static String |
STORM_MESSAGING_TRANSPORT
The transporter for communication among Storm tasks
|
static Object |
STORM_MESSAGING_TRANSPORT_SCHEMA |
static String |
STORM_META_SERIALIZATION_DELEGATE
The delegate for serializing metadata, should be used for serialized objects stored in zookeeper and on disk.
|
static Object |
STORM_META_SERIALIZATION_DELEGATE_SCHEMA |
static String |
STORM_NETTY_FLUSH_CHECK_INTERVAL_MS
We check with this interval that whether the Netty channel is writable and try to write pending messages
|
static Object |
STORM_NETTY_FLUSH_CHECK_INTERVAL_MS_SCHEMA |
static String |
STORM_NETTY_MESSAGE_BATCH_SIZE
If the Netty messaging layer is busy, the Netty client will try to batch message as more as possible up to the size of STORM_NETTY_MESSAGE_BATCH_SIZE bytes
|
static Object |
STORM_NETTY_MESSAGE_BATCH_SIZE_SCHEMA |
static String |
STORM_NIMBUS_RETRY_INTERVAL
The starting interval between exponential backoff retries of a Nimbus operation.
|
static String |
STORM_NIMBUS_RETRY_INTERVAL_CEILING
The ceiling of the interval between retries of a client connect to Nimbus operation.
|
static Object |
STORM_NIMBUS_RETRY_INTERVAL_CEILING_SCHEMA |
static Object |
STORM_NIMBUS_RETRY_INTERVAL_SCHEMA |
static String |
STORM_NIMBUS_RETRY_TIMES
The number of times to retry a Nimbus operation.
|
static Object |
STORM_NIMBUS_RETRY_TIMES_SCHEMA |
static String |
STORM_PRINCIPAL_TO_LOCAL_PLUGIN
The plugin that will convert a principal to a local user.
|
static Object |
STORM_PRINCIPAL_TO_LOCAL_PLUGIN_SCHEMA |
static String |
STORM_SCHEDULER
A global task scheduler used to assign topologies's tasks to supervisors' wokers.
|
static Object |
STORM_SCHEDULER_SCHEMA |
static String |
STORM_THRIFT_TRANSPORT_PLUGIN
The default transport plug-in for Thrift client/server communication
|
static Object |
STORM_THRIFT_TRANSPORT_PLUGIN_SCHEMA |
static String |
STORM_ZOOKEEPER_AUTH_PAYLOAD
A string representing the payload for cluster Zookeeper authentication.
|
static Object |
STORM_ZOOKEEPER_AUTH_PAYLOAD_SCHEMA |
static String |
STORM_ZOOKEEPER_AUTH_SCHEME
The cluster Zookeeper authentication scheme to use, e.g.
|
static Object |
STORM_ZOOKEEPER_AUTH_SCHEME_SCHEMA |
static String |
STORM_ZOOKEEPER_CONNECTION_TIMEOUT
The connection timeout for clients to ZooKeeper.
|
static Object |
STORM_ZOOKEEPER_CONNECTION_TIMEOUT_SCHEMA |
static String |
STORM_ZOOKEEPER_PORT
The port Storm will use to connect to each of the ZooKeeper servers.
|
static Object |
STORM_ZOOKEEPER_PORT_SCHEMA |
static String |
STORM_ZOOKEEPER_RETRY_INTERVAL
The interval between retries of a Zookeeper operation.
|
static String |
STORM_ZOOKEEPER_RETRY_INTERVAL_CEILING
The ceiling of the interval between retries of a Zookeeper operation.
|
static Object |
STORM_ZOOKEEPER_RETRY_INTERVAL_CEILING_SCHEMA |
static Object |
STORM_ZOOKEEPER_RETRY_INTERVAL_SCHEMA |
static String |
STORM_ZOOKEEPER_RETRY_TIMES
The number of times to retry a Zookeeper operation.
|
static Object |
STORM_ZOOKEEPER_RETRY_TIMES_SCHEMA |
static String |
STORM_ZOOKEEPER_ROOT
The root location at which Storm stores data in ZooKeeper.
|
static Object |
STORM_ZOOKEEPER_ROOT_SCHEMA |
static String |
STORM_ZOOKEEPER_SERVERS
A list of hosts of ZooKeeper servers used to manage the cluster.
|
static Object |
STORM_ZOOKEEPER_SERVERS_SCHEMA |
static String |
STORM_ZOOKEEPER_SESSION_TIMEOUT
The session timeout for clients to ZooKeeper.
|
static Object |
STORM_ZOOKEEPER_SESSION_TIMEOUT_SCHEMA |
static String |
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 Object |
STORM_ZOOKEEPER_SUPERACL_SCHEMA |
static String |
STORM_ZOOKEEPER_TOPOLOGY_AUTH_PAYLOAD
A string representing the payload for topology Zookeeper authentication.
|
static Object |
STORM_ZOOKEEPER_TOPOLOGY_AUTH_PAYLOAD_SCHEMA |
static String |
STORM_ZOOKEEPER_TOPOLOGY_AUTH_SCHEME
The topology Zookeeper authentication scheme to use, e.g.
|
static Object |
STORM_ZOOKEEPER_TOPOLOGY_AUTH_SCHEME_SCHEMA |
static String |
SUPERVISOR_CHILDOPTS
This parameter is used by the storm-deploy project to configure the
jvm options for the supervisor daemon.
|
static Object |
SUPERVISOR_CHILDOPTS_SCHEMA |
static String |
SUPERVISOR_ENABLE
Whether or not the supervisor should launch workers assigned to it.
|
static Object |
SUPERVISOR_ENABLE_SCHEMA |
static String |
SUPERVISOR_HEARTBEAT_FREQUENCY_SECS
how often the supervisor sends a heartbeat to the master.
|
static Object |
SUPERVISOR_HEARTBEAT_FREQUENCY_SECS_SCHEMA |
static String |
SUPERVISOR_MONITOR_FREQUENCY_SECS
How often the supervisor checks the worker heartbeats to see if any of them
need to be restarted.
|
static Object |
SUPERVISOR_MONITOR_FREQUENCY_SECS_SCHEMA |
static String |
SUPERVISOR_RUN_WORKER_AS_USER
Should the supervior try to run the worker as the lauching user or not.
|
static Object |
SUPERVISOR_RUN_WORKER_AS_USER_SCHEMA |
static String |
SUPERVISOR_SCHEDULER_META
the metadata configured on the supervisor
|
static Object |
SUPERVISOR_SCHEDULER_META_SCHEMA |
static String |
SUPERVISOR_SLOTS_PORTS
A list of ports that can run workers on this supervisor.
|
static Object |
SUPERVISOR_SLOTS_PORTS_SCHEMA |
static String |
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 Object |
SUPERVISOR_WORKER_LAUNCHER_SCHEMA |
static String |
SUPERVISOR_WORKER_SHUTDOWN_SLEEP_SECS
How many seconds to sleep for before shutting down threads on worker
|
static Object |
SUPERVISOR_WORKER_SHUTDOWN_SLEEP_SECS_SCHEMA |
static String |
SUPERVISOR_WORKER_START_TIMEOUT_SECS
How long a worker can go without heartbeating during the initial launch before
the supervisor tries to restart the worker process.
|
static Object |
SUPERVISOR_WORKER_START_TIMEOUT_SECS_SCHEMA |
static String |
SUPERVISOR_WORKER_TIMEOUT_SECS
How long a worker can go without heartbeating before the supervisor tries to
restart the worker process.
|
static Object |
SUPERVISOR_WORKER_TIMEOUT_SECS_SCHEMA |
static String |
TASK_CREDENTIALS_POLL_SECS
How often a task should sync credentials, worst case.
|
static Object |
TASK_CREDENTIALS_POLL_SECS_SCHEMA |
static String |
TASK_HEARTBEAT_FREQUENCY_SECS
How often a task should heartbeat its status to the master.
|
static Object |
TASK_HEARTBEAT_FREQUENCY_SECS_SCHEMA |
static String |
TASK_REFRESH_POLL_SECS
How often a task should sync its connections with other tasks (if a task is
reassigned, the other tasks sending messages to it need to refresh their connections).
|
static Object |
TASK_REFRESH_POLL_SECS_SCHEMA |
static String |
TOPOLOGY_ACKER_EXECUTORS
How many executors to spawn for ackers.
|
static Object |
TOPOLOGY_ACKER_EXECUTORS_SCHEMA |
static String |
TOPOLOGY_AUTO_CREDENTIALS
A list of IAutoCredentials that the topology should load and use.
|
static Object |
TOPOLOGY_AUTO_CREDENTIALS_SCHEMA |
static String |
TOPOLOGY_AUTO_TASK_HOOKS
A list of task hooks that are automatically added to every spout and bolt in the topology.
|
static Object |
TOPOLOGY_AUTO_TASK_HOOKS_SCHEMA |
static String |
TOPOLOGY_BOLTS_OUTGOING_OVERFLOW_BUFFER_ENABLE |
static Object |
TOPOLOGY_BOLTS_OUTGOING_OVERFLOW_BUFFER_ENABLE_SCHEMA |
static String |
TOPOLOGY_BUILTIN_METRICS_BUCKET_SIZE_SECS
The time period that builtin metrics data in bucketed into.
|
static Object |
TOPOLOGY_BUILTIN_METRICS_BUCKET_SIZE_SECS_SCHEMA |
static String |
TOPOLOGY_CLASSPATH
Topology-specific classpath for the worker child process.
|
static Object |
TOPOLOGY_CLASSPATH_SCHEMA |
static String |
TOPOLOGY_DEBUG
When set to true, Storm will log every message that's emitted.
|
static Object |
TOPOLOGY_DEBUG_SCHEMA |
static String |
TOPOLOGY_DISRUPTOR_WAIT_STRATEGY
Configure the wait strategy used for internal queuing.
|
static Object |
TOPOLOGY_DISRUPTOR_WAIT_STRATEGY_SCHEMA |
static String |
TOPOLOGY_ENABLE_MESSAGE_TIMEOUTS
True if Storm should timeout messages or not.
|
static Object |
TOPOLOGY_ENABLE_MESSAGE_TIMEOUTS_SCHEMA |
static String |
TOPOLOGY_ENVIRONMENT
Topology-specific environment variables for the worker child process.
|
static Object |
TOPOLOGY_ENVIRONMENT_SCHEMA |
static String |
TOPOLOGY_ERROR_THROTTLE_INTERVAL_SECS
The interval in seconds to use for determining whether to throttle error reported to Zookeeper.
|
static Object |
TOPOLOGY_ERROR_THROTTLE_INTERVAL_SECS_SCHEMA |
static String |
TOPOLOGY_EXECUTOR_RECEIVE_BUFFER_SIZE
The size of the Disruptor receive queue for each executor.
|
static Object |
TOPOLOGY_EXECUTOR_RECEIVE_BUFFER_SIZE_SCHEMA |
static String |
TOPOLOGY_EXECUTOR_SEND_BUFFER_SIZE
The size of the Disruptor send queue for each executor.
|
static Object |
TOPOLOGY_EXECUTOR_SEND_BUFFER_SIZE_SCHEMA |
static String |
TOPOLOGY_FALL_BACK_ON_JAVA_SERIALIZATION
Whether or not to use Java serialization in a topology.
|
static Object |
TOPOLOGY_FALL_BACK_ON_JAVA_SERIALIZATION_SCHEMA |
static String |
TOPOLOGY_GROUPS
A list of groups that are allowed to interact with the topology.
|
static Object |
TOPOLOGY_GROUPS_SCHEMA |
static String |
TOPOLOGY_ISOLATED_MACHINES
The number of machines that should be used by this topology to isolate it from all others.
|
static Object |
TOPOLOGY_ISOLATED_MACHINES_SCHEMA |
static String |
TOPOLOGY_KRYO_DECORATORS
A list of classes that customize storm's kryo instance during start-up.
|
static Object |
TOPOLOGY_KRYO_DECORATORS_SCHEMA |
static String |
TOPOLOGY_KRYO_FACTORY
Class that specifies how to create a Kryo instance for serialization.
|
static Object |
TOPOLOGY_KRYO_FACTORY_SCHEMA |
static String |
TOPOLOGY_KRYO_REGISTER
A list of serialization registrations for Kryo ( http://code.google.com/p/kryo/ ),
the underlying serialization framework for Storm.
|
static Object |
TOPOLOGY_KRYO_REGISTER_SCHEMA |
static String |
TOPOLOGY_LOGGING_SENSITIVITY
Topology central logging sensitivity to determine who has access to logs in central logging system.
|
static Object |
TOPOLOGY_LOGGING_SENSITIVITY_SCHEMA |
static String |
TOPOLOGY_MAX_ERROR_REPORT_PER_INTERVAL
See doc for TOPOLOGY_ERROR_THROTTLE_INTERVAL_SECS
|
static Object |
TOPOLOGY_MAX_ERROR_REPORT_PER_INTERVAL_SCHEMA |
static String |
TOPOLOGY_MAX_SPOUT_PENDING
The maximum number of tuples that can be pending on a spout task at any given time.
|
static Object |
TOPOLOGY_MAX_SPOUT_PENDING_SCHEMA |
static String |
TOPOLOGY_MAX_TASK_PARALLELISM
The maximum parallelism allowed for a component in this topology.
|
static Object |
TOPOLOGY_MAX_TASK_PARALLELISM_SCHEMA |
static String |
TOPOLOGY_MESSAGE_TIMEOUT_SECS
The maximum amount of time given to the topology to fully process a message
emitted by a spout.
|
static Object |
TOPOLOGY_MESSAGE_TIMEOUT_SECS_SCHEMA |
static String |
TOPOLOGY_METRICS_CONSUMER_REGISTER |
static Object |
TOPOLOGY_METRICS_CONSUMER_REGISTER_SCHEMA |
static String |
TOPOLOGY_MULTILANG_SERIALIZER
The serializer for communication between shell components and non-JVM
processes
|
static Object |
TOPOLOGY_MULTILANG_SERIALIZER_SCHEMA |
static String |
TOPOLOGY_NAME
Name of the topology.
|
static Object |
TOPOLOGY_NAME_SCHEMA |
static String |
TOPOLOGY_SHELLBOLT_MAX_PENDING
Max pending tuples in one ShellBolt
|
static Object |
TOPOLOGY_SHELLBOLT_MAX_PENDING_SCHEMA |
static String |
TOPOLOGY_SKIP_MISSING_KRYO_REGISTRATIONS
Whether or not Storm should skip the loading of kryo registrations for which it
does not know the class or have the serializer implementation.
|
static Object |
TOPOLOGY_SKIP_MISSING_KRYO_REGISTRATIONS_SCHEMA |
static String |
TOPOLOGY_SLEEP_SPOUT_WAIT_STRATEGY_TIME_MS
The amount of milliseconds the SleepEmptyEmitStrategy should sleep for.
|
static Object |
TOPOLOGY_SLEEP_SPOUT_WAIT_STRATEGY_TIME_MS_SCHEMA |
static String |
TOPOLOGY_SPOUT_WAIT_STRATEGY
A class that implements a strategy for what to do when a spout needs to wait.
|
static Object |
TOPOLOGY_SPOUT_WAIT_STRATEGY_SCHEMA |
static String |
TOPOLOGY_SPREAD_COMPONENTS
Array of components that scheduler should try to place on separate hosts.
|
static Object |
TOPOLOGY_SPREAD_COMPONENTS_SCHEMA |
static String |
TOPOLOGY_STATE_SYNCHRONIZATION_TIMEOUT_SECS
The maximum amount of time a component gives a source of state to synchronize before it requests
synchronization again.
|
static Object |
TOPOLOGY_STATE_SYNCHRONIZATION_TIMEOUT_SECS_SCHEMA |
static String |
TOPOLOGY_STATS_SAMPLE_RATE
The percentage of tuples to sample to produce stats for a task.
|
static Object |
TOPOLOGY_STATS_SAMPLE_RATE_SCHEMA |
static String |
TOPOLOGY_SUBMITTER_PRINCIPAL
The principal who submitted a topology
|
static Object |
TOPOLOGY_SUBMITTER_PRINCIPAL_SCHEMA |
static String |
TOPOLOGY_SUBMITTER_USER
The local user name of the user who submitted a topology.
|
static Object |
TOPOLOGY_SUBMITTER_USER_SCHEMA |
static String |
TOPOLOGY_TASKS
How many instances to create for a spout/bolt.
|
static Object |
TOPOLOGY_TASKS_SCHEMA |
static String |
TOPOLOGY_TESTING_ALWAYS_TRY_SERIALIZE
Try to serialize all tuples, even for local transfers.
|
static Object |
TOPOLOGY_TESTING_ALWAYS_TRY_SERIALIZE_SCHEMA |
static String |
TOPOLOGY_TICK_TUPLE_FREQ_SECS
How often a tick tuple from the "__system" component and "__tick" stream should be sent
to tasks.
|
static Object |
TOPOLOGY_TICK_TUPLE_FREQ_SECS_SCHEMA |
static String |
TOPOLOGY_TRANSACTIONAL_ID
This config is available for TransactionalSpouts, and contains the id ( a String) for
the transactional topology.
|
static Object |
TOPOLOGY_TRANSACTIONAL_ID_SCHEMA |
static String |
TOPOLOGY_TRANSFER_BUFFER_SIZE
The size of the Disruptor transfer queue for each worker.
|
static Object |
TOPOLOGY_TRANSFER_BUFFER_SIZE_SCHEMA |
static String |
TOPOLOGY_TRIDENT_BATCH_EMIT_INTERVAL_MILLIS
How often a batch can be emitted in a Trident topology.
|
static Object |
TOPOLOGY_TRIDENT_BATCH_EMIT_INTERVAL_MILLIS_SCHEMA |
static String |
TOPOLOGY_TUPLE_SERIALIZER
The serializer class for ListDelegate (tuple payload).
|
static Object |
TOPOLOGY_TUPLE_SERIALIZER_SCHEMA |
static String |
TOPOLOGY_USERS
A list of users that are allowed to interact with the topology.
|
static Object |
TOPOLOGY_USERS_SCHEMA |
static String |
TOPOLOGY_WORKER_CHILDOPTS
Topology-specific options for the worker child process.
|
static Object |
TOPOLOGY_WORKER_CHILDOPTS_SCHEMA |
static String |
TOPOLOGY_WORKER_GC_CHILDOPTS
Topology-specific options GC for the worker child process.
|
static Object |
TOPOLOGY_WORKER_GC_CHILDOPTS_SCHEMA |
static String |
TOPOLOGY_WORKER_SHARED_THREAD_POOL_SIZE
The size of the shared thread pool for worker tasks to make use of.
|
static Object |
TOPOLOGY_WORKER_SHARED_THREAD_POOL_SIZE_SCHEMA |
static String |
TOPOLOGY_WORKERS
How many processes should be spawned around the cluster to execute this
topology.
|
static Object |
TOPOLOGY_WORKERS_SCHEMA |
static String |
TRANSACTIONAL_ZOOKEEPER_PORT
The port to use to connect to the transactional zookeeper servers.
|
static Object |
TRANSACTIONAL_ZOOKEEPER_PORT_SCHEMA |
static String |
TRANSACTIONAL_ZOOKEEPER_ROOT
The root directory in ZooKeeper for metadata about TransactionalSpouts.
|
static Object |
TRANSACTIONAL_ZOOKEEPER_ROOT_SCHEMA |
static String |
TRANSACTIONAL_ZOOKEEPER_SERVERS
The list of zookeeper servers in which to keep the transactional state.
|
static Object |
TRANSACTIONAL_ZOOKEEPER_SERVERS_SCHEMA |
static String |
UI_CHILDOPTS
Childopts for Storm UI Java process.
|
static Object |
UI_CHILDOPTS_SCHEMA |
static String |
UI_FILTER
A class implementing javax.servlet.Filter for authenticating/filtering UI requests
|
static String |
UI_FILTER_PARAMS
Initialization parameters for the javax.servlet.Filter
|
static Object |
UI_FILTER_PARAMS_SCHEMA |
static Object |
UI_FILTER_SCHEMA |
static String |
UI_HEADER_BUFFER_BYTES
The size of the header buffer for the UI in bytes
|
static Object |
UI_HEADER_BUFFER_BYTES_SCHEMA |
static String |
UI_HOST
Storm UI binds to this host/interface.
|
static Object |
UI_HOST_SCHEMA |
static String |
UI_HTTP_CREDS_PLUGIN
Class name of the HTTP credentials plugin for the UI.
|
static Object |
UI_HTTP_CREDS_PLUGIN_SCHEMA |
static String |
UI_HTTPS_KEY_PASSWORD
Password to the private key in the keystore for settting up HTTPS (SSL).
|
static Object |
UI_HTTPS_KEY_PASSWORD_SCHEMA |
static String |
UI_HTTPS_KEYSTORE_PASSWORD
Password to the keystore used by Storm UI for setting up HTTPS (SSL).
|
static Object |
UI_HTTPS_KEYSTORE_PASSWORD_SCHEMA |
static String |
UI_HTTPS_KEYSTORE_PATH
Path to the keystore used by Storm UI for setting up HTTPS (SSL).
|
static Object |
UI_HTTPS_KEYSTORE_PATH_SCHEMA |
static String |
UI_HTTPS_KEYSTORE_TYPE
Type of keystore used by Storm UI for setting up HTTPS (SSL).
|
static Object |
UI_HTTPS_KEYSTORE_TYPE_SCHEMA |
static String |
UI_HTTPS_NEED_CLIENT_AUTH |
static Object |
UI_HTTPS_NEED_CLIENT_AUTH_SCHEMA |
static String |
UI_HTTPS_PORT
This port is used by Storm DRPC for receiving HTTPS (SSL) DPRC requests from clients.
|
static Object |
UI_HTTPS_PORT_SCHEMA |
static String |
UI_HTTPS_TRUSTSTORE_PASSWORD
Password to the truststore used by Storm UI settting up HTTPS (SSL).
|
static Object |
UI_HTTPS_TRUSTSTORE_PASSWORD_SCHEMA |
static String |
UI_HTTPS_TRUSTSTORE_PATH
Path to the truststore used by Storm UI settting up HTTPS (SSL).
|
static Object |
UI_HTTPS_TRUSTSTORE_PATH_SCHEMA |
static String |
UI_HTTPS_TRUSTSTORE_TYPE
Type of truststore used by Storm UI for setting up HTTPS (SSL).
|
static Object |
UI_HTTPS_TRUSTSTORE_TYPE_SCHEMA |
static String |
UI_HTTPS_WANT_CLIENT_AUTH
Password to the truststore used by Storm DRPC settting up HTTPS (SSL).
|
static Object |
UI_HTTPS_WANT_CLIENT_AUTH_SCHEMA |
static String |
UI_PORT
Storm UI binds to this port.
|
static Object |
UI_PORT_SCHEMA |
static String |
WORKER_CHILDOPTS
The jvm opts provided to workers launched by this supervisor.
|
static Object |
WORKER_CHILDOPTS_SCHEMA |
static String |
WORKER_GC_CHILDOPTS
The jvm opts provided to workers launched by this supervisor for GC.
|
static Object |
WORKER_GC_CHILDOPTS_SCHEMA |
static String |
WORKER_HEARTBEAT_FREQUENCY_SECS
How often this worker should heartbeat to the supervisor.
|
static Object |
WORKER_HEARTBEAT_FREQUENCY_SECS_SCHEMA |
static String |
WORKER_RECEIVER_THREAD_COUNT
control how many worker receiver threads we need per worker
|
static Object |
WORKER_RECEIVER_THREAD_COUNT_SCHEMA |
static String |
ZMQ_HWM
The high water for the ZeroMQ push sockets used for networking.
|
static Object |
ZMQ_HWM_SCHEMA |
static String |
ZMQ_LINGER_MILLIS
How long a connection should retry sending messages to a target host when
the connection is closed.
|
static Object |
ZMQ_LINGER_MILLIS_SCHEMA |
static String |
ZMQ_THREADS
The number of threads that should be used by the zeromq context in each worker process.
|
static Object |
ZMQ_THREADS_SCHEMA |
| Constructor and Description |
|---|
Config() |
| Modifier and Type | Method and Description |
|---|---|
void |
registerDecorator(Class<? extends IKryoDecorator> klass) |
static void |
registerDecorator(Map conf,
Class<? extends IKryoDecorator> klass) |
void |
registerMetricsConsumer(Class klass) |
void |
registerMetricsConsumer(Class klass,
long parallelismHint) |
void |
registerMetricsConsumer(Class klass,
Object argument,
long parallelismHint) |
static void |
registerMetricsConsumer(Map conf,
Class klass) |
static void |
registerMetricsConsumer(Map conf,
Class klass,
long parallelismHint) |
static void |
registerMetricsConsumer(Map conf,
Class klass,
Object argument,
long parallelismHint) |
void |
registerSerialization(Class klass) |
void |
registerSerialization(Class klass,
Class<? extends com.esotericsoftware.kryo.Serializer> serializerClass) |
static void |
registerSerialization(Map conf,
Class klass) |
static void |
registerSerialization(Map conf,
Class klass,
Class<? extends com.esotericsoftware.kryo.Serializer> serializerClass) |
static void |
setClasspath(Map conf,
String cp) |
void |
setClasspath(String cp) |
void |
setDebug(boolean isOn) |
static void |
setDebug(Map conf,
boolean isOn) |
void |
setEnvironment(Map env) |
static void |
setEnvironment(Map conf,
Map env) |
void |
setFallBackOnJavaSerialization(boolean fallback) |
static void |
setFallBackOnJavaSerialization(Map conf,
boolean fallback) |
void |
setKryoFactory(Class<? extends IKryoFactory> klass) |
static void |
setKryoFactory(Map conf,
Class<? extends IKryoFactory> klass) |
void |
setMaxSpoutPending(int max) |
static void |
setMaxSpoutPending(Map conf,
int max) |
void |
setMaxTaskParallelism(int max) |
static void |
setMaxTaskParallelism(Map conf,
int max) |
void |
setMessageTimeoutSecs(int secs) |
static void |
setMessageTimeoutSecs(Map conf,
int secs) |
void |
setNumAckers(int numExecutors) |
static void |
setNumAckers(Map conf,
int numExecutors) |
void |
setNumWorkers(int workers) |
static void |
setNumWorkers(Map conf,
int workers) |
void |
setSkipMissingKryoRegistrations(boolean skip) |
static void |
setSkipMissingKryoRegistrations(Map conf,
boolean skip) |
void |
setStatsSampleRate(double rate) |
static void |
setStatsSampleRate(Map conf,
double rate) |
clear, clone, containsKey, containsValue, entrySet, get, isEmpty, keySet, put, putAll, remove, size, valuesequals, hashCode, toStringpublic static final String STORM_ZOOKEEPER_SUPERACL
public static final Object STORM_ZOOKEEPER_SUPERACL_SCHEMA
public static final String STORM_MESSAGING_TRANSPORT
public static final Object STORM_MESSAGING_TRANSPORT_SCHEMA
public static final String STORM_MESSAGING_NETTY_BUFFER_SIZE
public static final Object STORM_MESSAGING_NETTY_BUFFER_SIZE_SCHEMA
public static final String STORM_MESSAGING_NETTY_SOCKET_BACKLOG
public static final Object STORM_MESSAGING_NETTY_SOCKET_BACKLOG_SCHEMA
public static final String STORM_MESSAGING_NETTY_MAX_RETRIES
public static final Object STORM_MESSAGING_NETTY_MAX_RETRIES_SCHEMA
public static final String STORM_MESSAGING_NETTY_MIN_SLEEP_MS
public static final Object STORM_MESSAGING_NETTY_MIN_SLEEP_MS_SCHEMA
public static final String STORM_MESSAGING_NETTY_MAX_SLEEP_MS
public static final Object STORM_MESSAGING_NETTY_MAX_SLEEP_MS_SCHEMA
public static final String STORM_MESSAGING_NETTY_SERVER_WORKER_THREADS
public static final Object STORM_MESSAGING_NETTY_SERVER_WORKER_THREADS_SCHEMA
public static final String STORM_MESSAGING_NETTY_CLIENT_WORKER_THREADS
public static final Object STORM_MESSAGING_NETTY_CLIENT_WORKER_THREADS_SCHEMA
public static final String STORM_NETTY_MESSAGE_BATCH_SIZE
public static final Object STORM_NETTY_MESSAGE_BATCH_SIZE_SCHEMA
public static final String STORM_NETTY_FLUSH_CHECK_INTERVAL_MS
public static final Object STORM_NETTY_FLUSH_CHECK_INTERVAL_MS_SCHEMA
public static final String STORM_MESSAGING_NETTY_AUTHENTICATION
public static final Object STORM_MESSAGING_NETTY_AUTHENTICATION_SCHEMA
public static final String STORM_META_SERIALIZATION_DELEGATE
public static final Object STORM_META_SERIALIZATION_DELEGATE_SCHEMA
public static final String STORM_ZOOKEEPER_SERVERS
public static final Object STORM_ZOOKEEPER_SERVERS_SCHEMA
public static final String STORM_ZOOKEEPER_PORT
public static final Object STORM_ZOOKEEPER_PORT_SCHEMA
public static final String STORM_LOCAL_DIR
public static final Object STORM_LOCAL_DIR_SCHEMA
public static final String STORM_SCHEDULER
public static final Object STORM_SCHEDULER_SCHEMA
public static final String STORM_CLUSTER_MODE
public static final Object STORM_CLUSTER_MODE_SCHEMA
public static final String STORM_LOCAL_HOSTNAME
InetAddress.getLocalHost().getCanonicalHostName().
You should set this config when you dont have a DNS which supervisors/workers
can utilize to find each other based on hostname got from calls to
InetAddress.getLocalHost().getCanonicalHostName().public static final Object STORM_LOCAL_HOSTNAME_SCHEMA
public static final String STORM_PRINCIPAL_TO_LOCAL_PLUGIN
public static final Object STORM_PRINCIPAL_TO_LOCAL_PLUGIN_SCHEMA
public static final String STORM_GROUP_MAPPING_SERVICE_PROVIDER_PLUGIN
public static final Object STORM_GROUP_MAPPING_SERVICE_PROVIDER_PLUGIN_SCHEMA
public static final String STORM_GROUP_MAPPING_SERVICE_CACHE_DURATION_SECS
public static final Object STORM_GROUP_MAPPING_SERVICE_CACHE_DURATION_SECS_SCHEMA
public static final String STORM_THRIFT_TRANSPORT_PLUGIN
public static final Object STORM_THRIFT_TRANSPORT_PLUGIN_SCHEMA
public static final String TOPOLOGY_TUPLE_SERIALIZER
public static final Object TOPOLOGY_TUPLE_SERIALIZER_SCHEMA
public static final String TOPOLOGY_TESTING_ALWAYS_TRY_SERIALIZE
public static final Object TOPOLOGY_TESTING_ALWAYS_TRY_SERIALIZE_SCHEMA
public static final String STORM_LOCAL_MODE_ZMQ
public static final Object STORM_LOCAL_MODE_ZMQ_SCHEMA
public static final String STORM_ZOOKEEPER_ROOT
public static final Object STORM_ZOOKEEPER_ROOT_SCHEMA
public static final String STORM_ZOOKEEPER_SESSION_TIMEOUT
public static final Object STORM_ZOOKEEPER_SESSION_TIMEOUT_SCHEMA
public static final String STORM_ZOOKEEPER_CONNECTION_TIMEOUT
public static final Object STORM_ZOOKEEPER_CONNECTION_TIMEOUT_SCHEMA
public static final String STORM_ZOOKEEPER_RETRY_TIMES
public static final Object STORM_ZOOKEEPER_RETRY_TIMES_SCHEMA
public static final String STORM_ZOOKEEPER_RETRY_INTERVAL
public static final Object STORM_ZOOKEEPER_RETRY_INTERVAL_SCHEMA
public static final String STORM_ZOOKEEPER_RETRY_INTERVAL_CEILING
public static final Object STORM_ZOOKEEPER_RETRY_INTERVAL_CEILING_SCHEMA
public static final String STORM_ZOOKEEPER_AUTH_SCHEME
public static final Object STORM_ZOOKEEPER_AUTH_SCHEME_SCHEMA
public static final String STORM_ZOOKEEPER_AUTH_PAYLOAD
public static final Object STORM_ZOOKEEPER_AUTH_PAYLOAD_SCHEMA
public static final String STORM_ZOOKEEPER_TOPOLOGY_AUTH_SCHEME
public static final Object STORM_ZOOKEEPER_TOPOLOGY_AUTH_SCHEME_SCHEMA
public static final String STORM_ZOOKEEPER_TOPOLOGY_AUTH_PAYLOAD
public static final Object STORM_ZOOKEEPER_TOPOLOGY_AUTH_PAYLOAD_SCHEMA
public static final String STORM_ID
public static final Object STORM_ID_SCHEMA
public static final String STORM_NIMBUS_RETRY_TIMES
public static final Object STORM_NIMBUS_RETRY_TIMES_SCHEMA
public static final String STORM_NIMBUS_RETRY_INTERVAL
public static final Object STORM_NIMBUS_RETRY_INTERVAL_SCHEMA
public static final String STORM_NIMBUS_RETRY_INTERVAL_CEILING
public static final Object STORM_NIMBUS_RETRY_INTERVAL_CEILING_SCHEMA
public static final String NIMBUS_HOST
public static final Object NIMBUS_HOST_SCHEMA
public static final String NIMBUS_THRIFT_TRANSPORT_PLUGIN
public static final Object NIMBUS_THRIFT_TRANSPORT_PLUGIN_SCHEMA
public static final String NIMBUS_THRIFT_PORT
public static final Object NIMBUS_THRIFT_PORT_SCHEMA
public static final String NIMBUS_THRIFT_THREADS
public static final Object NIMBUS_THRIFT_THREADS_SCHEMA
public static final String NIMBUS_ADMINS
public static final Object NIMBUS_ADMINS_SCHEMA
public static final String NIMBUS_USERS
public static final Object NIMBUS_USERS_SCHEMA
public static final String NIMBUS_GROUPS
public static final Object NIMBUS_GROUPS_SCHEMA
public static final String NIMBUS_SUPERVISOR_USERS
public static final Object NIMBUS_SUPERVISOR_USERS_SCHEMA
public static final String NIMBUS_THRIFT_MAX_BUFFER_SIZE
public static final Object NIMBUS_THRIFT_MAX_BUFFER_SIZE_SCHEMA
public static final String NIMBUS_CHILDOPTS
public static final Object NIMBUS_CHILDOPTS_SCHEMA
public static final String NIMBUS_TASK_TIMEOUT_SECS
public static final Object NIMBUS_TASK_TIMEOUT_SECS_SCHEMA
public static final String NIMBUS_MONITOR_FREQ_SECS
public static final Object NIMBUS_MONITOR_FREQ_SECS_SCHEMA
public static final String NIMBUS_CLEANUP_INBOX_FREQ_SECS
NIMBUS_INBOX_JAR_EXPIRATION_SECS,
Constant Field Valuespublic static final Object NIMBUS_CLEANUP_INBOX_FREQ_SECS_SCHEMA
public static final String NIMBUS_INBOX_JAR_EXPIRATION_SECS
NIMBUS_CLEANUP_FREQ_SECS,
Constant Field Valuespublic static final Object NIMBUS_INBOX_JAR_EXPIRATION_SECS_SCHEMA
public static final String NIMBUS_SUPERVISOR_TIMEOUT_SECS
public static final Object NIMBUS_SUPERVISOR_TIMEOUT_SECS_SCHEMA
public static final String NIMBUS_TASK_LAUNCH_SECS
A separate timeout exists for launch because there can be quite a bit of overhead to launching new JVM's and configuring them.
public static final Object NIMBUS_TASK_LAUNCH_SECS_SCHEMA
public static final String NIMBUS_REASSIGN
public static final Object NIMBUS_REASSIGN_SCHEMA
public static final String NIMBUS_FILE_COPY_EXPIRATION_SECS
public static final Object NIMBUS_FILE_COPY_EXPIRATION_SECS_SCHEMA
public static final String NIMBUS_TOPOLOGY_VALIDATOR
public static final Object NIMBUS_TOPOLOGY_VALIDATOR_SCHEMA
public static final String NIMBUS_AUTHORIZER
public static final Object NIMBUS_AUTHORIZER_SCHEMA
public static final String NIMBUS_IMPERSONATION_AUTHORIZER
public static final Object NIMBUS_IMPERSONATION_AUTHORIZER_SCHEMA
public static final String NIMBUS_IMPERSONATION_ACL
public static final Object NIMBUS_IMPERSONATION_ACL_SCHEMA
public static final String NIMBUS_CREDENTIAL_RENEW_FREQ_SECS
public static final Object NIMBUS_CREDENTIAL_RENEW_FREQ_SECS_SCHEMA
public static final String NIMBUS_CREDENTIAL_RENEWERS
public static final Object NIMBUS_CREDENTIAL_RENEWERS_SCHEMA
public static final String NIMBUS_AUTO_CRED_PLUGINS
public static final Object NIMBUS_AUTO_CRED_PLUGINS_SCHEMA
public static final String UI_HOST
public static final Object UI_HOST_SCHEMA
public static final String UI_PORT
public static final Object UI_PORT_SCHEMA
public static final String LOGVIEWER_PORT
public static final Object LOGVIEWER_PORT_SCHEMA
public static final String LOGVIEWER_CHILDOPTS
public static final Object LOGVIEWER_CHILDOPTS_SCHEMA
public static final String LOGVIEWER_CLEANUP_INTERVAL_SECS
public static final Object LOGVIEWER_CLEANUP_INTERVAL_SECS_SCHEMA
public static final String LOGVIEWER_CLEANUP_AGE_MINS
public static final Object LOGVIEWER_CLEANUP_AGE_MINS_SCHEMA
public static final String LOGS_USERS
public static final Object LOGS_USERS_SCHEMA
public static final String LOGS_GROUPS
public static final Object LOGS_GROUPS_SCHEMA
public static final String LOGVIEWER_APPENDER_NAME
public static final Object LOGVIEWER_APPENDER_NAME_SCHEMA
public static final String UI_CHILDOPTS
public static final Object UI_CHILDOPTS_SCHEMA
public static final String UI_FILTER
public static final Object UI_FILTER_SCHEMA
public static final String UI_FILTER_PARAMS
public static final Object UI_FILTER_PARAMS_SCHEMA
public static final String UI_HEADER_BUFFER_BYTES
public static final Object UI_HEADER_BUFFER_BYTES_SCHEMA
public static final String UI_HTTPS_PORT
public static final Object UI_HTTPS_PORT_SCHEMA
public static final String UI_HTTPS_KEYSTORE_PATH
public static final Object UI_HTTPS_KEYSTORE_PATH_SCHEMA
public static final String UI_HTTPS_KEYSTORE_PASSWORD
public static final Object UI_HTTPS_KEYSTORE_PASSWORD_SCHEMA
public static final String UI_HTTPS_KEYSTORE_TYPE
public static final Object UI_HTTPS_KEYSTORE_TYPE_SCHEMA
public static final String UI_HTTPS_KEY_PASSWORD
public static final Object UI_HTTPS_KEY_PASSWORD_SCHEMA
public static final String UI_HTTPS_TRUSTSTORE_PATH
public static final Object UI_HTTPS_TRUSTSTORE_PATH_SCHEMA
public static final String UI_HTTPS_TRUSTSTORE_PASSWORD
public static final Object UI_HTTPS_TRUSTSTORE_PASSWORD_SCHEMA
public static final String UI_HTTPS_TRUSTSTORE_TYPE
public static final Object UI_HTTPS_TRUSTSTORE_TYPE_SCHEMA
public static final String UI_HTTPS_WANT_CLIENT_AUTH
public static final Object UI_HTTPS_WANT_CLIENT_AUTH_SCHEMA
public static final String UI_HTTPS_NEED_CLIENT_AUTH
public static final Object UI_HTTPS_NEED_CLIENT_AUTH_SCHEMA
public static final String DRPC_SERVERS
public static final Object DRPC_SERVERS_SCHEMA
public static final String DRPC_HTTP_PORT
public static final Object DRPC_HTTP_PORT_SCHEMA
public static final String DRPC_HTTPS_PORT
public static final Object DRPC_HTTPS_PORT_SCHEMA
public static final String DRPC_HTTPS_KEYSTORE_PATH
public static final Object DRPC_HTTPS_KEYSTORE_PATH_SCHEMA
public static final String DRPC_HTTPS_KEYSTORE_PASSWORD
public static final Object DRPC_HTTPS_KEYSTORE_PASSWORD_SCHEMA
public static final String DRPC_HTTPS_KEYSTORE_TYPE
public static final Object DRPC_HTTPS_KEYSTORE_TYPE_SCHEMA
public static final String DRPC_HTTPS_KEY_PASSWORD
public static final Object DRPC_HTTPS_KEY_PASSWORD_SCHEMA
public static final String DRPC_HTTPS_TRUSTSTORE_PATH
public static final Object DRPC_HTTPS_TRUSTSTORE_PATH_SCHEMA
public static final String DRPC_HTTPS_TRUSTSTORE_PASSWORD
public static final Object DRPC_HTTPS_TRUSTSTORE_PASSWORD_SCHEMA
public static final String DRPC_HTTPS_TRUSTSTORE_TYPE
public static final Object DRPC_HTTPS_TRUSTSTORE_TYPE_SCHEMA
public static final String DRPC_HTTPS_WANT_CLIENT_AUTH
public static final Object DRPC_HTTPS_WANT_CLIENT_AUTH_SCHEMA
public static final String DRPC_HTTPS_NEED_CLIENT_AUTH
public static final Object DRPC_HTTPS_NEED_CLIENT_AUTH_SCHEMA
public static final String DRPC_THRIFT_TRANSPORT_PLUGIN
public static final Object DRPC_THRIFT_TRANSPORT_PLUGIN_SCHEMA
public static final String DRPC_PORT
public static final Object DRPC_PORT_SCHEMA
public static final String DRPC_AUTHORIZER
public static final Object DRPC_AUTHORIZER_SCHEMA
public static final String DRPC_AUTHORIZER_ACL
DRPCSimpleAclAuthorizer,
Constant Field Valuespublic static final Object DRPC_AUTHORIZER_ACL_SCHEMA
public static final String DRPC_AUTHORIZER_ACL_FILENAME
DRPCSimpleAclAuthorizer,
Constant Field Valuespublic static final Object DRPC_AUTHORIZER_ACL_FILENAME_SCHEMA
public static final String DRPC_AUTHORIZER_ACL_STRICT
DRPCSimpleAclAuthorizer,
Constant Field Valuespublic static final Object DRPC_AUTHORIZER_ACL_STRICT_SCHEMA
public static final String DRPC_WORKER_THREADS
public static final Object DRPC_WORKER_THREADS_SCHEMA
public static final String DRPC_MAX_BUFFER_SIZE
public static final Object DRPC_MAX_BUFFER_SIZE_SCHEMA
public static final String DRPC_QUEUE_SIZE
public static final Object DRPC_QUEUE_SIZE_SCHEMA
public static final String DRPC_INVOCATIONS_THRIFT_TRANSPORT_PLUGIN
public static final Object DRPC_INVOCATIONS_THRIFT_TRANSPORT_PLUGIN_SCHEMA
public static final String DRPC_INVOCATIONS_PORT
public static final Object DRPC_INVOCATIONS_PORT_SCHEMA
public static final String DRPC_INVOCATIONS_THREADS
public static final Object DRPC_INVOCATIONS_THREADS_SCHEMA
public static final String DRPC_REQUEST_TIMEOUT_SECS
public static final Object DRPC_REQUEST_TIMEOUT_SECS_SCHEMA
public static final String DRPC_CHILDOPTS
public static final Object DRPC_CHILDOPTS_SCHEMA
public static final String UI_HTTP_CREDS_PLUGIN
public static final Object UI_HTTP_CREDS_PLUGIN_SCHEMA
public static final String DRPC_HTTP_CREDS_PLUGIN
public static final Object DRPC_HTTP_CREDS_PLUGIN_SCHEMA
public static final String SUPERVISOR_SCHEDULER_META
public static final Object SUPERVISOR_SCHEDULER_META_SCHEMA
public static final String SUPERVISOR_SLOTS_PORTS
public static final Object SUPERVISOR_SLOTS_PORTS_SCHEMA
public static final String NIMBUS_SLOTS_PER_TOPOLOGY
public static final Object NIMBUS_SLOTS_PER_TOPOLOGY_SCHEMA
public static final String DRPC_HTTP_FILTER
public static final Object DRPC_HTTP_FILTER_SCHEMA
public static final String DRPC_HTTP_FILTER_PARAMS
public static final Object DRPC_HTTP_FILTER_PARAMS_SCHEMA
public static final String NIMBUS_EXECUTORS_PER_TOPOLOGY
public static final Object NIMBUS_EXECUTORS_PER_TOPOLOGY_SCHEMA
public static final String SUPERVISOR_CHILDOPTS
public static final Object SUPERVISOR_CHILDOPTS_SCHEMA
public static final String SUPERVISOR_WORKER_TIMEOUT_SECS
public static final Object SUPERVISOR_WORKER_TIMEOUT_SECS_SCHEMA
public static final String SUPERVISOR_WORKER_SHUTDOWN_SLEEP_SECS
public static final Object SUPERVISOR_WORKER_SHUTDOWN_SLEEP_SECS_SCHEMA
public static final String SUPERVISOR_WORKER_START_TIMEOUT_SECS
public static final Object SUPERVISOR_WORKER_START_TIMEOUT_SECS_SCHEMA
public static final String SUPERVISOR_ENABLE
public static final Object SUPERVISOR_ENABLE_SCHEMA
public static final String SUPERVISOR_HEARTBEAT_FREQUENCY_SECS
public static final Object SUPERVISOR_HEARTBEAT_FREQUENCY_SECS_SCHEMA
public static final String SUPERVISOR_MONITOR_FREQUENCY_SECS
public static final Object SUPERVISOR_MONITOR_FREQUENCY_SECS_SCHEMA
public static final String SUPERVISOR_RUN_WORKER_AS_USER
public static final Object SUPERVISOR_RUN_WORKER_AS_USER_SCHEMA
public static final String SUPERVISOR_WORKER_LAUNCHER
public static final Object SUPERVISOR_WORKER_LAUNCHER_SCHEMA
public static final String WORKER_CHILDOPTS
public static final Object WORKER_CHILDOPTS_SCHEMA
public static final String WORKER_GC_CHILDOPTS
public static final Object WORKER_GC_CHILDOPTS_SCHEMA
public static final String WORKER_RECEIVER_THREAD_COUNT
public static final Object WORKER_RECEIVER_THREAD_COUNT_SCHEMA
public static final String WORKER_HEARTBEAT_FREQUENCY_SECS
public static final Object WORKER_HEARTBEAT_FREQUENCY_SECS_SCHEMA
public static final String TASK_HEARTBEAT_FREQUENCY_SECS
public static final Object TASK_HEARTBEAT_FREQUENCY_SECS_SCHEMA
public static final String TASK_REFRESH_POLL_SECS
public static final Object TASK_REFRESH_POLL_SECS_SCHEMA
public static final String TASK_CREDENTIALS_POLL_SECS
public static final Object TASK_CREDENTIALS_POLL_SECS_SCHEMA
public static final String TOPOLOGY_USERS
public static final Object TOPOLOGY_USERS_SCHEMA
public static final String TOPOLOGY_GROUPS
public static final Object TOPOLOGY_GROUPS_SCHEMA
public static final String TOPOLOGY_ENABLE_MESSAGE_TIMEOUTS
public static final Object TOPOLOGY_ENABLE_MESSAGE_TIMEOUTS_SCHEMA
public static final String TOPOLOGY_DEBUG
public static final Object TOPOLOGY_DEBUG_SCHEMA
public static final String TOPOLOGY_MULTILANG_SERIALIZER
public static final Object TOPOLOGY_MULTILANG_SERIALIZER_SCHEMA
public static final String TOPOLOGY_WORKERS
public static final Object TOPOLOGY_WORKERS_SCHEMA
public static final String TOPOLOGY_TASKS
public static final Object TOPOLOGY_TASKS_SCHEMA
public static final String TOPOLOGY_ACKER_EXECUTORS
If this is set to 0, then Storm will immediately ack tuples as soon as they come off the spout, effectively disabling reliability.
public static final Object TOPOLOGY_ACKER_EXECUTORS_SCHEMA
public static final String TOPOLOGY_MESSAGE_TIMEOUT_SECS
public static final Object TOPOLOGY_MESSAGE_TIMEOUT_SECS_SCHEMA
public static final String TOPOLOGY_KRYO_REGISTER
public static final Object TOPOLOGY_KRYO_REGISTER_SCHEMA
public static final String TOPOLOGY_KRYO_DECORATORS
public static final Object TOPOLOGY_KRYO_DECORATORS_SCHEMA
public static final String TOPOLOGY_KRYO_FACTORY
public static final Object TOPOLOGY_KRYO_FACTORY_SCHEMA
public static final String TOPOLOGY_SKIP_MISSING_KRYO_REGISTRATIONS
public static final Object TOPOLOGY_SKIP_MISSING_KRYO_REGISTRATIONS_SCHEMA
public static final String TOPOLOGY_METRICS_CONSUMER_REGISTER
public static final Object TOPOLOGY_METRICS_CONSUMER_REGISTER_SCHEMA
public static final String TOPOLOGY_MAX_TASK_PARALLELISM
public static final Object TOPOLOGY_MAX_TASK_PARALLELISM_SCHEMA
public static final String TOPOLOGY_MAX_SPOUT_PENDING
public static final Object TOPOLOGY_MAX_SPOUT_PENDING_SCHEMA
public static final String TOPOLOGY_SPOUT_WAIT_STRATEGY
public static final Object TOPOLOGY_SPOUT_WAIT_STRATEGY_SCHEMA
public static final String TOPOLOGY_SLEEP_SPOUT_WAIT_STRATEGY_TIME_MS
public static final Object TOPOLOGY_SLEEP_SPOUT_WAIT_STRATEGY_TIME_MS_SCHEMA
public static final String TOPOLOGY_STATE_SYNCHRONIZATION_TIMEOUT_SECS
public static final Object TOPOLOGY_STATE_SYNCHRONIZATION_TIMEOUT_SECS_SCHEMA
public static final String TOPOLOGY_STATS_SAMPLE_RATE
public static final Object TOPOLOGY_STATS_SAMPLE_RATE_SCHEMA
public static final String TOPOLOGY_BUILTIN_METRICS_BUCKET_SIZE_SECS
public static final Object TOPOLOGY_BUILTIN_METRICS_BUCKET_SIZE_SECS_SCHEMA
public static final String TOPOLOGY_FALL_BACK_ON_JAVA_SERIALIZATION
public static final Object TOPOLOGY_FALL_BACK_ON_JAVA_SERIALIZATION_SCHEMA
public static final String TOPOLOGY_WORKER_CHILDOPTS
public static final Object TOPOLOGY_WORKER_CHILDOPTS_SCHEMA
public static final String TOPOLOGY_WORKER_GC_CHILDOPTS
public static final Object TOPOLOGY_WORKER_GC_CHILDOPTS_SCHEMA
public static final String TOPOLOGY_CLASSPATH
public static final Object TOPOLOGY_CLASSPATH_SCHEMA
public static final String TOPOLOGY_ENVIRONMENT
public static final Object TOPOLOGY_ENVIRONMENT_SCHEMA
public static final String TOPOLOGY_BOLTS_OUTGOING_OVERFLOW_BUFFER_ENABLE
public static final Object TOPOLOGY_BOLTS_OUTGOING_OVERFLOW_BUFFER_ENABLE_SCHEMA
public static final String TOPOLOGY_TRANSACTIONAL_ID
public static final Object TOPOLOGY_TRANSACTIONAL_ID_SCHEMA
public static final String TOPOLOGY_AUTO_TASK_HOOKS
public static final Object TOPOLOGY_AUTO_TASK_HOOKS_SCHEMA
public static final String TOPOLOGY_EXECUTOR_RECEIVE_BUFFER_SIZE
public static final Object TOPOLOGY_EXECUTOR_RECEIVE_BUFFER_SIZE_SCHEMA
public static final String TOPOLOGY_EXECUTOR_SEND_BUFFER_SIZE
public static final Object TOPOLOGY_EXECUTOR_SEND_BUFFER_SIZE_SCHEMA
public static final String TOPOLOGY_TRANSFER_BUFFER_SIZE
public static final Object TOPOLOGY_TRANSFER_BUFFER_SIZE_SCHEMA
public static final String TOPOLOGY_TICK_TUPLE_FREQ_SECS
public static final Object TOPOLOGY_TICK_TUPLE_FREQ_SECS_SCHEMA
public static final String TOPOLOGY_DISRUPTOR_WAIT_STRATEGY
public static final Object TOPOLOGY_DISRUPTOR_WAIT_STRATEGY_SCHEMA
public static final String TOPOLOGY_WORKER_SHARED_THREAD_POOL_SIZE
public static final Object TOPOLOGY_WORKER_SHARED_THREAD_POOL_SIZE_SCHEMA
public static final String TOPOLOGY_ERROR_THROTTLE_INTERVAL_SECS
public static final Object TOPOLOGY_ERROR_THROTTLE_INTERVAL_SECS_SCHEMA
public static final String TOPOLOGY_MAX_ERROR_REPORT_PER_INTERVAL
public static final Object TOPOLOGY_MAX_ERROR_REPORT_PER_INTERVAL_SCHEMA
public static final String TOPOLOGY_TRIDENT_BATCH_EMIT_INTERVAL_MILLIS
public static final Object TOPOLOGY_TRIDENT_BATCH_EMIT_INTERVAL_MILLIS_SCHEMA
public static final String TOPOLOGY_NAME
public static final Object TOPOLOGY_NAME_SCHEMA
public static final String TOPOLOGY_SUBMITTER_PRINCIPAL
public static final Object TOPOLOGY_SUBMITTER_PRINCIPAL_SCHEMA
public static final String TOPOLOGY_SUBMITTER_USER
public static final Object TOPOLOGY_SUBMITTER_USER_SCHEMA
public static final String TOPOLOGY_SPREAD_COMPONENTS
public static final Object TOPOLOGY_SPREAD_COMPONENTS_SCHEMA
public static final String TOPOLOGY_AUTO_CREDENTIALS
public static final Object TOPOLOGY_AUTO_CREDENTIALS_SCHEMA
public static final String TOPOLOGY_SHELLBOLT_MAX_PENDING
public static final Object TOPOLOGY_SHELLBOLT_MAX_PENDING_SCHEMA
public static final String TOPOLOGY_LOGGING_SENSITIVITY
public static final Object TOPOLOGY_LOGGING_SENSITIVITY_SCHEMA
public static final String TRANSACTIONAL_ZOOKEEPER_ROOT
public static final Object TRANSACTIONAL_ZOOKEEPER_ROOT_SCHEMA
public static final String TRANSACTIONAL_ZOOKEEPER_SERVERS
public static final Object TRANSACTIONAL_ZOOKEEPER_SERVERS_SCHEMA
public static final String TRANSACTIONAL_ZOOKEEPER_PORT
public static final Object TRANSACTIONAL_ZOOKEEPER_PORT_SCHEMA
public static final String STORM_DO_AS_USER
public static final Object STORM_DO_AS_USER_SCHEMA
public static final String ZMQ_THREADS
public static final Object ZMQ_THREADS_SCHEMA
public static final String ZMQ_LINGER_MILLIS
public static final Object ZMQ_LINGER_MILLIS_SCHEMA
public static final String ZMQ_HWM
public static final Object ZMQ_HWM_SCHEMA
public static final String JAVA_LIBRARY_PATH
public static final Object JAVA_LIBRARY_PATH_SCHEMA
public static final String DEV_ZOOKEEPER_PATH
public static final Object DEV_ZOOKEEPER_PATH_SCHEMA
public static final String ISOLATION_SCHEDULER_MACHINES
public static final Object ISOLATION_SCHEDULER_MACHINES_SCHEMA
public static final String MULTITENANT_SCHEDULER_USER_POOLS
public static final Object MULTITENANT_SCHEDULER_USER_POOLS_SCHEMA
public static final String TOPOLOGY_ISOLATED_MACHINES
public static final Object TOPOLOGY_ISOLATED_MACHINES_SCHEMA
public void setClasspath(String cp)
public void setEnvironment(Map env)
public static void setDebug(Map conf, boolean isOn)
public void setDebug(boolean isOn)
public static void setNumWorkers(Map conf, int workers)
public void setNumWorkers(int workers)
public static void setNumAckers(Map conf, int numExecutors)
public void setNumAckers(int numExecutors)
public static void setMessageTimeoutSecs(Map conf, int secs)
public void setMessageTimeoutSecs(int secs)
public void registerSerialization(Class klass)
public static void registerSerialization(Map conf, Class klass, Class<? extends com.esotericsoftware.kryo.Serializer> serializerClass)
public void registerSerialization(Class klass, Class<? extends com.esotericsoftware.kryo.Serializer> serializerClass)
public static void registerMetricsConsumer(Map conf, Class klass, Object argument, long parallelismHint)
public void registerMetricsConsumer(Class klass, Object argument, long parallelismHint)
public static void registerMetricsConsumer(Map conf, Class klass, long parallelismHint)
public void registerMetricsConsumer(Class klass, long parallelismHint)
public void registerMetricsConsumer(Class klass)
public static void registerDecorator(Map conf, Class<? extends IKryoDecorator> klass)
public void registerDecorator(Class<? extends IKryoDecorator> klass)
public static void setKryoFactory(Map conf, Class<? extends IKryoFactory> klass)
public void setKryoFactory(Class<? extends IKryoFactory> klass)
public static void setSkipMissingKryoRegistrations(Map conf, boolean skip)
public void setSkipMissingKryoRegistrations(boolean skip)
public static void setMaxTaskParallelism(Map conf, int max)
public void setMaxTaskParallelism(int max)
public static void setMaxSpoutPending(Map conf, int max)
public void setMaxSpoutPending(int max)
public static void setStatsSampleRate(Map conf, double rate)
public void setStatsSampleRate(double rate)
public static void setFallBackOnJavaSerialization(Map conf, boolean fallback)
public void setFallBackOnJavaSerialization(boolean fallback)
Copyright © 2015. All rights reserved.