Deprecated API

Contents

• For Removal
• Interfaces
• Classes
• Fields
• Methods
• Constructors
• Enum Constants

For Removal

Element	Description
org.apache.storm.cluster.IStormClusterState.backpressureTopologies()
org.apache.storm.cluster.IStormClusterState.removeBackpressure(String)
org.apache.storm.cluster.IStormClusterState.removeWorkerBackpressure(String, String, Long)
org.apache.storm.cluster.IStormClusterState.setupBackpressure(String, Map<String, Object>)
org.apache.storm.cluster.IStormClusterState.topologyBackpressure(String, long, Runnable)
org.apache.storm.Config.BLOBSTORE_HDFS_PRINCIPAL
org.apache.storm.Config.STORM_METRICS_REPORTERS
org.apache.storm.Config.TOPOLOGY_BACKPRESSURE_ENABLE
org.apache.storm.hive.bolt.HiveBolt
org.apache.storm.hive.bolt.mapper.DelimitedRecordHiveMapper
org.apache.storm.hive.bolt.mapper.HiveMapper
org.apache.storm.hive.bolt.mapper.JsonRecordHiveMapper
org.apache.storm.hive.common.HiveOptions
org.apache.storm.hive.common.HiveUtils
org.apache.storm.hive.common.HiveWriter
org.apache.storm.hive.security.AutoHive
org.apache.storm.hive.security.AutoHiveCommand
org.apache.storm.hive.security.AutoHiveNimbus
org.apache.storm.hive.security.HiveSecurityUtil
org.apache.storm.hive.trident.HiveState
org.apache.storm.hive.trident.HiveStateFactory
org.apache.storm.hive.trident.HiveUpdater

Interfaces

Interface	Description
org.apache.storm.hive.bolt.mapper.HiveMapper

Classes

Class	Description
org.apache.storm.hive.bolt.HiveBolt
org.apache.storm.hive.bolt.mapper.DelimitedRecordHiveMapper
org.apache.storm.hive.bolt.mapper.JsonRecordHiveMapper
org.apache.storm.hive.common.HiveOptions
org.apache.storm.hive.common.HiveUtils
org.apache.storm.hive.common.HiveWriter
org.apache.storm.hive.security.AutoHive
org.apache.storm.hive.security.AutoHiveCommand
org.apache.storm.hive.security.AutoHiveNimbus
org.apache.storm.hive.security.HiveSecurityUtil
org.apache.storm.hive.trident.HiveState
org.apache.storm.hive.trident.HiveStateFactory
org.apache.storm.hive.trident.HiveUpdater
org.apache.storm.metric.cgroup.CGroupCpu
org.apache.storm.metric.cgroup.CGroupCpuGuarantee
org.apache.storm.metric.cgroup.CGroupCpuGuaranteeByCfsQuota
org.apache.storm.metric.cgroup.CGroupMemoryLimit
org.apache.storm.metric.cgroup.CGroupMemoryUsage
org.apache.storm.metric.cgroup.CGroupMetricsBase
org.apache.storm.security.auth.plain.PlainClientCallbackHandler
org.apache.storm.security.auth.plain.PlainSaslTransportPlugin
org.apache.storm.security.auth.plain.SaslPlainServer
org.apache.storm.transactional.TransactionAttempt
org.apache.storm.utils.TimeCacheMap

Fields

Field	Description
org.apache.storm.Config.BLOBSTORE_HDFS_KEYTAB
org.apache.storm.Config.BLOBSTORE_HDFS_PRINCIPAL
org.apache.storm.Config.STORM_METRICS_REPORTERS
org.apache.storm.Config.TOPOLOGY_BACKPRESSURE_ENABLE
org.apache.storm.Config.TOPOLOGY_SPREAD_COMPONENTS
org.apache.storm.hdfs.spout.Configs.ARCHIVE_DIR	please use HdfsSpout.setArchiveDir(String)
org.apache.storm.hdfs.spout.Configs.BAD_DIR	please use HdfsSpout.setBadFilesDir(String)
org.apache.storm.hdfs.spout.Configs.CLOCKS_INSYNC	please use HdfsSpout.setClocksInSync(boolean)
org.apache.storm.hdfs.spout.Configs.COMMIT_FREQ_COUNT	please use HdfsSpout.setCommitFrequencyCount(int)
org.apache.storm.hdfs.spout.Configs.COMMIT_FREQ_SEC	please use HdfsSpout.setCommitFrequencySec(int)
org.apache.storm.hdfs.spout.Configs.HDFS_URI	please use HdfsSpout.setHdfsUri(String)
org.apache.storm.hdfs.spout.Configs.IGNORE_SUFFIX	please use HdfsSpout.setIgnoreSuffix(String)
org.apache.storm.hdfs.spout.Configs.LOCK_DIR	please use HdfsSpout.setLockDir(String)
org.apache.storm.hdfs.spout.Configs.LOCK_TIMEOUT	please use HdfsSpout.setLockTimeoutSec(int)
org.apache.storm.hdfs.spout.Configs.MAX_OUTSTANDING	please use HdfsSpout.setMaxOutstanding(int)
org.apache.storm.hdfs.spout.Configs.READER_TYPE	please use HdfsSpout.setReaderType(String)
org.apache.storm.hdfs.spout.Configs.SOURCE_DIR	please use HdfsSpout.setSourceDir(String)

Methods

Method	Description
org.apache.storm.cluster.IStormClusterState.backpressureTopologies()
org.apache.storm.cluster.IStormClusterState.removeBackpressure(String)
org.apache.storm.cluster.IStormClusterState.removeWorkerBackpressure(String, String, Long)
org.apache.storm.cluster.IStormClusterState.setupBackpressure(String, Map<String, Object>)
org.apache.storm.cluster.IStormClusterState.topologyBackpressure(String, long, Runnable)
org.apache.storm.Config.getBlobstoreHDFSPrincipal(Map)
org.apache.storm.drpc.LinearDRPCTopologyBuilder.addBolt(IRichBolt, Number)
org.apache.storm.hdfs.trident.HdfsState.HdfsFileOptions.addRotationAction(RotationAction)
org.apache.storm.hooks.IWorkerHook.start(Map<String, Object>, WorkerTopologyContext)	see IWorkerHook.start(Map, WorkerUserContext)
org.apache.storm.ILocalCluster.shutdown()	use AutoCloseable.close() instead.
org.apache.storm.ILocalDRPC.shutdown()	use AutoCloseable.close() instead
org.apache.storm.messaging.IContext.prepare(Map<String, Object>)
org.apache.storm.metrics2.reporters.StormReporter.prepare(MetricRegistry, Map<String, Object>, Map<String, Object>)
org.apache.storm.metrics2.StormMetricRegistry.gauge(String, Gauge<T>, String, String, Integer, Integer)
org.apache.storm.scheduler.SchedulerAssignmentImpl.assign(WorkerSlot, Collection<ExecutorDetails>)
org.apache.storm.security.INimbusCredentialPlugin.populateCredentials(Map<String, String>, Map<String, Object>)
org.apache.storm.sql.parser.impl.SimpleCharStream.getColumn()
org.apache.storm.sql.parser.impl.SimpleCharStream.getLine()
org.apache.storm.task.IMetricsContext.registerMetric(String, T, int)	in favor of metrics v2 (the non-deprecated methods on this class)
org.apache.storm.task.TopologyContext.getRegisteredMetricByName(String)
org.apache.storm.task.TopologyContext.registerMetric(String, T, int)
org.apache.storm.Testing.getLocalCluster(Map<String, Object>)	use ``` try (LocalCluster cluster = new LocalCluster.Builder()....build()) { ... } ```
org.apache.storm.Testing.globalAmt(String, String)
org.apache.storm.Testing.mkTrackedTopology(ILocalCluster, StormTopology)	use TrackedTopology directly.
org.apache.storm.Testing.withLocalCluster(TestJob)	use ``` try (LocalCluster cluster = new LocalCluster()) { ... } ```
org.apache.storm.Testing.withSimulatedTime(Runnable)	use ``` try (Time.SimulatedTime time = new Time.SimulatedTime()) { ... } ```
org.apache.storm.Testing.withSimulatedTimeLocalCluster(TestJob)	use ``` try (LocalCluster cluster = new LocalCluster.Builder().withSimulatedTime().build()) { ... } ```
org.apache.storm.Testing.withTrackedCluster(TestJob)	use ``` try (LocalCluster cluster = new LocalCluster.Builder().withTracked().build()) { ... } ```
org.apache.storm.utils.NimbusClient.getConfiguredClient(Map<String, Object>)	use #build() instead.
org.apache.storm.utils.NimbusClient.getConfiguredClientAs(Map<String, Object>, String)	use #build() instead.
org.apache.storm.utils.SupervisorClient.getConfiguredClient(Map, String)	use #createSupervisorClient() instead.
org.apache.storm.utils.SupervisorClient.getConfiguredClientAs(Map, String, int, String)	use #createSupervisorClient() instead.

Constructors

Constructor	Description
org.apache.storm.utils.NimbusClient(Map<String, Object>, String, int, Integer)	use #buildWithNimbusHostPort() instead.
org.apache.storm.utils.SupervisorClient(Map, String, int)	use #build() instead.

Enum Constants

Enum Constant	Description
org.apache.storm.scheduler.resource.strategies.scheduling.BaseResourceAwareStrategy.NodeSortType.DEFAULT_RAS	used by DefaultResourceAwareStrategyOld only. Use {link #COMMON} instead.
org.apache.storm.scheduler.resource.strategies.scheduling.BaseResourceAwareStrategy.NodeSortType.GENERIC_RAS	used by GenericResourceAwareStrategyOld only. Use {link #COMMON} instead.