Skip navigation links
  • Overview
  • Package
  • Class
  • Use
  • Tree
  • Deprecated
  • Index
  • Help

Deprecated API

Contents

  • Terminally Deprecated
  • Classes
  • Fields
  • Methods
  • Constructors
  • Enum Constants
  • Terminally Deprecated Elements
    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
  • Deprecated Classes
    Class
    Description
    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
  • Deprecated 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)
  • Deprecated 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)
    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, ICombiner, int)
    in favor of metrics v2 (the non-deprecated methods on this class)
    org.apache.storm.task.IMetricsContext.registerMetric(String, IReducer, int)
    in favor of metrics v2 (the non-deprecated methods on this class)
    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, ICombiner, int)
    org.apache.storm.task.TopologyContext.registerMetric(String, IReducer, int)
    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(MkClusterParam, TestJob)
    use ``` try (LocalCluster cluster = new LocalCluster.Builder()....build()) { ... } ```
    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(MkClusterParam, TestJob)
    use ``` try (LocalCluster cluster = new LocalCluster.Builder().withSimulatedTime()....build()) { ... } ```
    org.apache.storm.Testing.withSimulatedTimeLocalCluster(TestJob)
    use ``` try (LocalCluster cluster = new LocalCluster.Builder().withSimulatedTime().build()) { ... } ```
    org.apache.storm.Testing.withTrackedCluster(MkClusterParam, TestJob)
    use ``` try (LocalCluster cluster = new LocalCluster.Builder().withTracked()....build()) { ... } ```
    org.apache.storm.Testing.withTrackedCluster(TestJob)
    use ``` try (LocalCluster cluster = new LocalCluster.Builder().withTracked().build()) { ... } ```
  • Deprecated Constructors
    Constructor
    Description
    org.apache.storm.utils.NimbusClient(Map<String, Object>, String, int)
  • Deprecated 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.

Copyright © 2023 The Apache Software Foundation. All rights reserved.