Uses of Class
org.apache.storm.hdfs.spout.HdfsSpout
Packages that use HdfsSpout
-
Uses of HdfsSpout in org.apache.storm.hdfs.spout
Methods in org.apache.storm.hdfs.spout that return HdfsSpoutModifier and TypeMethodDescriptionHdfsSpout.setArchiveDir
(String archiveDir) HdfsSpout.setBadFilesDir
(String badFilesDir) HdfsSpout.setClocksInSync
(boolean clocksInSync) HdfsSpout.setCommitFrequencyCount
(int commitFrequencyCount) HdfsSpout.setCommitFrequencySec
(int commitFrequencySec) HdfsSpout.setHdfsUri
(String hdfsUri) HdfsSpout.setIgnoreSuffix
(String ignoreSuffix) HdfsSpout.setLockDir
(String lockDir) HdfsSpout.setLockTimeoutSec
(int lockTimeoutSec) HdfsSpout.setMaxOutstanding
(int maxOutstanding) HdfsSpout.setReaderType
(String readerType) HdfsSpout.setSourceDir
(String sourceDir) HdfsSpout.withConfigKey
(String configKey) set key name under which HDFS options are placed.HdfsSpout.withOutputFields
(String... fields) Output field names.HdfsSpout.withOutputStream
(String streamName) Set output stream name.