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