Uses of Class
org.apache.storm.hdfs.spout.HdfsSpout
-
Uses of HdfsSpout in org.apache.storm.hdfs.spout
Modifier 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.