Package | Description |
---|---|
org.apache.storm | |
org.apache.storm.hdfs.spout |
Modifier and Type | Field and Description |
---|---|
static String |
DaemonConfig.BLACKLIST_SCHEDULER_ASSUME_SUPERVISOR_BAD_BASED_ON_BAD_SLOT
Whether
BlacklistScheduler will assume the supervisor is bad based on bad slots or not. |
static String |
DaemonConfig.BLACKLIST_SCHEDULER_ENABLE_SEND_ASSIGNMENT_FAILURES
Enables blacklisting support for supervisors with failed send assignment calls.
|
static String |
Config.BLOBSTORE_CLEANUP_ENABLE
Enable the blobstore cleaner.
|
static String |
Config.DISABLE_SYMLINKS
On some systems (windows for example) symlinks require special privileges that not everyone wants to grant a headless user.
|
static String |
Config.DRPC_AUTHORIZER_ACL_STRICT
Whether the DRPCSimpleAclAuthorizer should deny requests for operations involving functions that have no explicit ACL entry.
|
static String |
DaemonConfig.DRPC_DISABLE_HTTP_BINDING
This controls wheather Storm DRPC should bind to http port even if drpc.http.port is > 0.
|
static String |
DaemonConfig.DRPC_HTTPS_ENABLE_SSL_RELOAD
If set to true, keystore and truststore for DRPC Server will be automatically reloaded when modified.
|
static String |
DaemonConfig.DRPC_HTTPS_NEED_CLIENT_AUTH |
static String |
DaemonConfig.DRPC_HTTPS_WANT_CLIENT_AUTH
Password to the truststore used by Storm DRPC setting up HTTPS (SSL).
|
static String |
DaemonConfig.LOGVIEWER_DISABLE_HTTP_BINDING
This controls wheather Storm Logviewer should bind to http port even if logviewer.port is > 0.
|
static String |
DaemonConfig.LOGVIEWER_HTTPS_ENABLE_SSL_RELOAD
If set to true, keystore and truststore for Logviewer will be automatically reloaded when modified.
|
static String |
DaemonConfig.LOGVIEWER_HTTPS_NEED_CLIENT_AUTH |
static String |
DaemonConfig.LOGVIEWER_HTTPS_WANT_CLIENT_AUTH
Password to the truststore used by Storm Logviewer setting up HTTPS (SSL).
|
static String |
DaemonConfig.SCHEDULER_DISPLAY_RESOURCE
Whether we want to display all the resource capacity and scheduled usage on the UI page.
|
static String |
Config.STORM_BLOBSTORE_ACL_VALIDATION_ENABLED
For secure mode we would want to turn on this config By default this is turned off assuming the default is insecure.
|
static String |
DaemonConfig.STORM_CGROUP_INHERIT_CPUSET_CONFIGS
To determine whether or not to cgroups should inherit cpuset.cpus and cpuset.mems config values form parent cgroup Note that cpuset.cpus and cpuset.mems configs in a cgroup must be initialized (i.e.
|
static String |
DaemonConfig.STORM_CGROUP_MEMORY_ENFORCEMENT_ENABLE
Java does not always play nicely with cgroups.
|
static String |
DaemonConfig.STORM_HEALTH_CHECK_FAIL_ON_TIMEOUTS
Boolean setting to configure if health checks should fail when timeouts occur or not.
|
static String |
Config.STORM_LOCAL_MODE_ZMQ
Whether or not to use ZeroMQ for messaging in local mode.
|
static String |
Config.STORM_MESSAGING_NETTY_AUTHENTICATION
Netty based messaging: Is authentication required for Netty messaging from client worker process to server worker process.
|
static String |
DaemonConfig.STORM_NIMBUS_ZOOKEEPER_ACLS_CHECK
In nimbus on startup check if all of the zookeeper ACLs are correct before starting.
|
static String |
DaemonConfig.STORM_NIMBUS_ZOOKEEPER_ACLS_FIXUP
In nimbus on startup check if all of the zookeeper ACLs are correct before starting.
|
static String |
DaemonConfig.STORM_RESOURCE_ISOLATION_PLUGIN_ENABLE
flag to determine whether to use a resource isolation plugin Also determines whether the unit tests for cgroup runs.
|
static String |
DaemonConfig.STORM_ROCKSDB_CREATE_IF_MISSING
RocksDB create if missing flag.
|
static String |
DaemonConfig.STORM_TOPOLOGY_CLASSPATH_BEGINNING_ENABLED
Enables user-first classpath.
|
static String |
DaemonConfig.SUPERVISOR_ENABLE
Whether or not the supervisor should launch workers assigned to it.
|
static String |
Config.SUPERVISOR_RUN_WORKER_AS_USER
Should the supervior try to run the worker as the lauching user or not.
|
static String |
Config.TOPOLOGY_BACKPRESSURE_ENABLE
Deprecated.
|
static String |
Config.TOPOLOGY_DEBUG
When set to true, Storm will log every message that’s emitted.
|
static String |
Config.TOPOLOGY_DISABLE_LOADAWARE_MESSAGING
Disable load aware grouping support.
|
static String |
Config.TOPOLOGY_ENABLE_MESSAGE_TIMEOUTS
True if Storm should timeout messages or not.
|
static String |
Config.TOPOLOGY_ENABLE_V2_METRICS_TICK
This config allows a topology to report metrics data points from the V2 metrics API through the metrics tick.
|
static String |
Config.TOPOLOGY_FALL_BACK_ON_JAVA_SERIALIZATION
Whether or not to use Java serialization in a topology.
|
static String |
Config.TOPOLOGY_RAS_ONE_COMPONENT_PER_WORKER
Whether to limit each worker to one component.
|
static String |
Config.TOPOLOGY_RAS_ONE_EXECUTOR_PER_WORKER
Whether to limit each worker to one executor.
|
static String |
Config.TOPOLOGY_SERIALIZED_MESSAGE_SIZE_METRICS
Enable tracking of network message byte counts per source-destination task.
|
static String |
Config.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 String |
Config.TOPOLOGY_TESTING_ALWAYS_TRY_SERIALIZE
Try to serialize all tuples, even for local transfers.
|
static String |
DaemonConfig.UI_DISABLE_HTTP_BINDING
This controls wheather Storm UI should bind to http port even if ui.port is > 0.
|
static String |
DaemonConfig.UI_DISABLE_SPOUT_LAG_MONITORING
This controls whether Storm UI displays spout lag for the Kafka spout.
|
static String |
DaemonConfig.UI_HTTPS_ENABLE_SSL_RELOAD
If set to true, keystore and truststore for UI will be automatically reloaded when modified.
|
static String |
DaemonConfig.UI_HTTPS_NEED_CLIENT_AUTH |
static String |
DaemonConfig.UI_HTTPS_WANT_CLIENT_AUTH
Password to the truststore used by Storm DRPC setting up HTTPS (SSL).
|
static String |
DaemonConfig.WORKER_PROFILER_ENABLED
Enable profiling of worker JVMs using Oracle’s Java Flight Recorder.
|
Modifier and Type | Field and Description |
---|---|
static String |
Configs.CLOCKS_INSYNC
Deprecated.
please use
HdfsSpout.setClocksInSync(boolean) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.