Package | Description |
---|---|
org.apache.storm.hdfs.spout |
Modifier and Type | Method and 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
|
Copyright © 2019 The Apache Software Foundation. All rights reserved.