-
ElementDescription
-
ClassDescription
-
FieldDescriptionplease use
HdfsSpout.setBadFilesDir(String)
please useHdfsSpout.setClocksInSync(boolean)
please useHdfsSpout.setCommitFrequencyCount(int)
please useHdfsSpout.setCommitFrequencySec(int)
please useHdfsSpout.setHdfsUri(String)
please useHdfsSpout.setIgnoreSuffix(String)
please useHdfsSpout.setLockDir(String)
please useHdfsSpout.setLockTimeoutSec(int)
please useHdfsSpout.setMaxOutstanding(int)
please useHdfsSpout.setReaderType(String)
please useHdfsSpout.setSourceDir(String)
-
MethodDescriptionuse
AutoCloseable.close()
instead.useAutoCloseable.close()
insteadin favor of metrics v2 (the non-deprecated methods on this class)in favor of metrics v2 (the non-deprecated methods on this class)in favor of metrics v2 (the non-deprecated methods on this class)use ``` try (LocalCluster cluster = new LocalCluster.Builder()....build()) { ... } ```useTrackedTopology
directly.use ``` try (LocalCluster cluster = new LocalCluster.Builder()....build()) { ... } ```use ``` try (LocalCluster cluster = new LocalCluster()) { ... } ```use ``` try (Time.SimulatedTime time = new Time.SimulatedTime()) { ... } ```use ``` try (LocalCluster cluster = new LocalCluster.Builder().withSimulatedTime()....build()) { ... } ```use ``` try (LocalCluster cluster = new LocalCluster.Builder().withSimulatedTime().build()) { ... } ```use ``` try (LocalCluster cluster = new LocalCluster.Builder().withTracked()....build()) { ... } ```use ``` try (LocalCluster cluster = new LocalCluster.Builder().withTracked().build()) { ... } ```
-
Enum ConstantDescriptionused by DefaultResourceAwareStrategyOld only. Use {link #COMMON} instead.used by GenericResourceAwareStrategyOld only. Use {link #COMMON} instead.
HdfsSpout.setArchiveDir(String)