Uses of Class
org.apache.storm.validation.ConfigValidationAnnotations.isString

Packages that use ConfigValidationAnnotations.isString

Package	Description
org.apache.storm
org.apache.storm.hdfs.spout

Uses of ConfigValidationAnnotations.isString in org.apache.storm

Fields in org.apache.storm with annotations of type ConfigValidationAnnotations.isString

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.CLIENT_BLOBSTORE What blobstore implementation the storm client should use.
static String	DaemonConfig.DEV_ZOOKEEPER_PATH The path to use as the zookeeper dir when running a zookeeper server via “storm dev-zookeeper”.
static String	DaemonConfig.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	DaemonConfig.DRPC_HTTP_FILTER A class implementing javax.servlet.Filter for DRPC HTTP requests.
static String	DaemonConfig.DRPC_HTTPS_KEY_PASSWORD Password to the private key in the keystore for setting up HTTPS (SSL).
static String	DaemonConfig.DRPC_HTTPS_KEYSTORE_PASSWORD Password to the keystore used by Storm DRPC for setting up HTTPS (SSL).
static String	DaemonConfig.DRPC_HTTPS_KEYSTORE_PATH Path to the keystore used by Storm DRPC for setting up HTTPS (SSL).
static String	DaemonConfig.DRPC_HTTPS_KEYSTORE_TYPE Type of keystore used by Storm DRPC for setting up HTTPS (SSL).
static String	DaemonConfig.DRPC_HTTPS_TRUSTSTORE_PASSWORD Password to the truststore used by Storm DRPC setting up HTTPS (SSL).
static String	DaemonConfig.DRPC_HTTPS_TRUSTSTORE_PATH Path to the truststore used by Storm DRPC setting up HTTPS (SSL).
static String	DaemonConfig.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	DaemonConfig.JAVA_LIBRARY_PATH This value is passed to spawned JVMs (e.g., Nimbus, Supervisor, and Workers) for the java.library.path value.
static String	DaemonConfig.LOGVIEWER_APPENDER_NAME Appender name used by log viewer to determine log directory.
static String	DaemonConfig.LOGVIEWER_FILTER A class implementing javax.servlet.Filter for authenticating/filtering Logviewer requests.
static String	DaemonConfig.LOGVIEWER_HTTPS_KEY_PASSWORD Password to the private key in the keystore for setting up HTTPS (SSL).
static String	DaemonConfig.LOGVIEWER_HTTPS_KEYSTORE_PASSWORD Password for the keystore for HTTPS for Storm Logviewer.
static String	DaemonConfig.LOGVIEWER_HTTPS_KEYSTORE_PATH Path to the keystore containing the certs used by Storm Logviewer for HTTPS communications.
static String	DaemonConfig.LOGVIEWER_HTTPS_KEYSTORE_TYPE Type of the keystore for HTTPS for Storm Logviewer.
static String	DaemonConfig.LOGVIEWER_HTTPS_TRUSTSTORE_PASSWORD Password for the truststore for HTTPS for Storm Logviewer.
static String	DaemonConfig.LOGVIEWER_HTTPS_TRUSTSTORE_PATH Path to the truststore containing the certs used by Storm Logviewer for HTTPS communications.
static String	DaemonConfig.LOGVIEWER_HTTPS_TRUSTSTORE_TYPE Type of the truststore for HTTPS for Storm Logviewer.
static String	DaemonConfig.NIMBUS_AUTHORIZER Class name for authorization plugin for Nimbus.
static String	DaemonConfig.NIMBUS_BLOBSTORE What blobstore implementation nimbus should use.
static String	DaemonConfig.NIMBUS_DAEMON_USER This is the user that the Nimbus daemon process is running as.
static String	DaemonConfig.NIMBUS_IMPERSONATION_AUTHORIZER Impersonation user ACL config entries.
static String	Config.NIMBUS_LOCAL_ASSIGNMENTS_BACKEND_CLASS Nimbus assignments backend for storing local assignments.
static String	Config.NIMBUS_THRIFT_TRANSPORT_PLUGIN The Nimbus transport plug-in for Thrift client/server communication
static String	DaemonConfig.NIMBUS_TOPOLOGY_VALIDATOR A custom class that implements ITopologyValidator that is run whenever a topology is submitted.
static String	DaemonConfig.NIMBUS_WORKER_HEARTBEATS_RECOVERY_STRATEGY_CLASS class controls heartbeats recovery strategy.
static String	DaemonConfig.SCHEDULER_CONFIG_LOADER_ARTIFACTORY_BASE_DIRECTORY It is the part of the uri, configurable in Artifactory, which represents the top of the directory tree.
static String	DaemonConfig.SCHEDULER_CONFIG_LOADER_URI For ArtifactoryConfigLoader, this can either be a reference to an individual file in Artifactory or to a directory.
static String	DaemonConfig.STORM_CGROUP_CGEXEC_CMD full path to cgexec command.
static String	Config.STORM_CGROUP_HIERARCHY_DIR root directory of the storm cgroup hierarchy
static String	DaemonConfig.STORM_CGROUP_HIERARCHY_NAME name for the cgroup hierarchy.
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	DaemonConfig.STORM_DAEMON_METRICS_REPORTER_CSV_LOG_DIR A specify csv reporter directory for CvsPreparableReporter daemon metrics reporter.
static String	DaemonConfig.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	DaemonConfig.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	DaemonConfig.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	DaemonConfig.STORM_METRIC_PROCESSOR_CLASS Class implementing WorkerMetricsProcessor.
static String	DaemonConfig.STORM_METRIC_STORE_CLASS Class implementing MetricStore.
static String	Config.STORM_PRINCIPAL_TO_LOCAL_PLUGIN The plugin that will convert a principal to a local user.
static String	DaemonConfig.STORM_ROCKSDB_LOCATION RocksDB file location.
static String	DaemonConfig.STORM_SCHEDULER A global task scheduler used to assign topologies’s tasks to supervisors’ workers.
static String	DaemonConfig.STORM_SUPERVISOR_CGROUP_ROOTDIR root directory for cgoups.
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_DRPC_ACL The ACL of the drpc user in zookeeper so the drpc servers can verify worker tokens.
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	DaemonConfig.SUPERVISOR_AUTHORIZER Class name for authorization plugin for supervisor.
static String	DaemonConfig.SUPERVISOR_BLOBSTORE What blobstore implementation the supervisor should use.
static String	Config.SUPERVISOR_THRIFT_TRANSPORT_PLUGIN
static String	Config.SUPERVISOR_WORKER_DEFAULT_VERSION The version of storm to assume a topology should run as if not version is given by the client when submitting the topology.
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_BACKPRESSURE_WAIT_STRATEGY A class that implements a wait strategy for an upstream component (spout/bolt) trying to write to a downstream component whose recv queue is full
static String	Config.TOPOLOGY_BOLT_WAIT_STRATEGY Selects the Bolt’s Wait Strategy to use when there are no incoming msgs.
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_KRYO_FACTORY Class that specifies how to create a Kryo instance for serialization.
static String	Config.TOPOLOGY_LOGGING_CONFIG_FILE Log file the user can use to configure Log4j2.
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_SCHEDULER_STRATEGY The strategy to use when scheduling a topology with Resource Aware Scheduler.
static String	Config.TOPOLOGY_SPOUT_WAIT_STRATEGY A class that implements a wait strategy for spout.
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.TOPOLOGY_VERSION User defined version of this topology.
static String	Config.TRANSACTIONAL_ZOOKEEPER_ROOT The root directory in ZooKeeper for metadata about TransactionalSpouts.
static String	DaemonConfig.UI_CENTRAL_LOGGING_URL Storm UI Central Logging URL.
static String	DaemonConfig.UI_FILTER A class implementing javax.servlet.Filter for authenticating/filtering UI requests.
static String	DaemonConfig.UI_HOST Storm UI binds to this host/interface.
static String	DaemonConfig.UI_HTTPS_KEY_PASSWORD Password to the private key in the keystore for setting up HTTPS (SSL).
static String	DaemonConfig.UI_HTTPS_KEYSTORE_PASSWORD Password to the keystore used by Storm UI for setting up HTTPS (SSL).
static String	DaemonConfig.UI_HTTPS_KEYSTORE_PATH Path to the keystore used by Storm UI for setting up HTTPS (SSL).
static String	DaemonConfig.UI_HTTPS_KEYSTORE_TYPE Type of keystore used by Storm UI for setting up HTTPS (SSL).
static String	DaemonConfig.UI_HTTPS_TRUSTSTORE_PASSWORD Password to the truststore used by Storm UI setting up HTTPS (SSL).
static String	DaemonConfig.UI_HTTPS_TRUSTSTORE_PATH Path to the truststore used by Storm UI setting up HTTPS (SSL).
static String	DaemonConfig.UI_HTTPS_TRUSTSTORE_TYPE Type of truststore used by Storm UI for setting up HTTPS (SSL).
static String	DaemonConfig.UI_PROJECT_BUGTRACKER_URL Storm UI Project BUGTRACKER Link for reporting issue.
static String	DaemonConfig.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.

Uses of ConfigValidationAnnotations.isString in org.apache.storm.hdfs.spout

Fields in org.apache.storm.hdfs.spout with annotations of type ConfigValidationAnnotations.isString

Modifier and Type	Field and Description
static String	Configs.ARCHIVE_DIR Deprecated. please use HdfsSpout.setArchiveDir(String)
static String	Configs.BAD_DIR Deprecated. please use HdfsSpout.setBadFilesDir(String)
static String	Configs.HDFS_URI Deprecated. please use HdfsSpout.setHdfsUri(String)
static String	Configs.IGNORE_SUFFIX Deprecated. please use HdfsSpout.setIgnoreSuffix(String)
static String	Configs.LOCK_DIR Deprecated. please use HdfsSpout.setLockDir(String)
static String	Configs.READER_TYPE Deprecated. please use HdfsSpout.setReaderType(String)
static String	Configs.SOURCE_DIR Deprecated. please use HdfsSpout.setSourceDir(String)