Deprecated API

Contents

• Deprecated Classes
• Deprecated Fields
• Deprecated Methods
• Deprecated Constructors

Deprecated Classes

Class and Description
org.apache.storm.security.auth.plain.PlainClientCallbackHandler
org.apache.storm.security.auth.plain.PlainSaslTransportPlugin
org.apache.storm.solr.schema.builder.RestJsonSchemaBuilder Use RestJsonSchemaBuilder2 instead, as this doesn’t support Kerberos authentication
org.apache.storm.security.auth.plain.SaslPlainServer
org.apache.storm.utils.TimeCacheMap
org.apache.storm.transactional.TransactionAttempt

Deprecated Fields

Field and Description
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)
org.apache.storm.Config.TASK_HEARTBEAT_FREQUENCY_SECS
org.apache.storm.Config.TOPOLOGY_BACKPRESSURE_ENABLE

Deprecated Methods

Method and Description
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.scheduler.SchedulerAssignmentImpl.assign(WorkerSlot, Collection<ExecutorDetails>)
org.apache.storm.cluster.IStormClusterState.backpressureTopologies()
org.apache.storm.sql.parser.impl.SimpleCharStream.getColumn()
org.apache.storm.sql.parser.impl.SimpleCharStream.getLine()
org.apache.storm.Testing.getLocalCluster(Map<String, Object>) use try (LocalCluster cluster = new LocalCluster.Builder()....build()) { ... }
org.apache.storm.task.TopologyContext.getRegisteredMetricByName(String)
org.apache.storm.Testing.globalAmt(String, String)
org.apache.storm.Testing.mkTrackedTopology(ILocalCluster, StormTopology) use TrackedTopology directly.
org.apache.storm.security.INimbusCredentialPlugin.populateCredentials(Map<String, String>, Map<String, Object>)
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.TopologyContext.registerMetric(String, ICombiner, int)
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.TopologyContext.registerMetric(String, IReducer, int)
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.registerMetric(String, T, int)
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.ILocalDRPC.shutdown() use AutoCloseable.close() instead
org.apache.storm.ILocalCluster.shutdown() use AutoCloseable.close() instead.
org.apache.storm.cluster.IStormClusterState.topologyBackpressure(String, long, Runnable)
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 and Description
org.apache.storm.utils.NimbusClient(Map<String, Object>, String, int)