Package org.apache.storm.hdfs.spout
Class Configs
java.lang.Object
org.apache.storm.hdfs.spout.Configs
- All Implemented Interfaces:
- Validated
- 
Nested Class SummaryNested Classes
- 
Field SummaryFieldsModifier and TypeFieldDescriptionstatic final StringDeprecated.static final StringDeprecated.please useHdfsSpout.setBadFilesDir(String)static final StringDeprecated.please useHdfsSpout.setClocksInSync(boolean)static final StringDeprecated.please useHdfsSpout.setCommitFrequencyCount(int)static final StringDeprecated.please useHdfsSpout.setCommitFrequencySec(int)static final intstatic final intstatic final Stringstatic final StringFilenames with this suffix in archive dir will be ignored by the Spout.static final intstatic final intstatic final StringDeprecated.please useHdfsSpout.setHdfsUri(String)static final StringDeprecated.please useHdfsSpout.setIgnoreSuffix(String)static final StringDeprecated.please useHdfsSpout.setLockDir(String)static final StringDeprecated.please useHdfsSpout.setLockTimeoutSec(int)static final StringDeprecated.please useHdfsSpout.setMaxOutstanding(int)static final StringDeprecated.please useHdfsSpout.setReaderType(String)static final Stringstatic final StringDeprecated.please useHdfsSpout.setSourceDir(String)static final String
- 
Constructor SummaryConstructors
- 
Method Summary
- 
Field Details- 
READER_TYPEDeprecated.please useHdfsSpout.setReaderType(String)Required - chose the file type being consumed.- See Also:
 
- 
TEXT- See Also:
 
- 
SEQ- See Also:
 
- 
HDFS_URIDeprecated.please useHdfsSpout.setHdfsUri(String)Required - HDFS name node.- See Also:
 
- 
SOURCE_DIRDeprecated.please useHdfsSpout.setSourceDir(String)Required - dir from which to read files.- See Also:
 
- 
ARCHIVE_DIRDeprecated.please useHdfsSpout.setArchiveDir(String)Required - completed files will be moved here.- See Also:
 
- 
BAD_DIRDeprecated.please useHdfsSpout.setBadFilesDir(String)Required - unparsable files will be moved here.- See Also:
 
- 
LOCK_DIRDeprecated.please useHdfsSpout.setLockDir(String)Directory in which lock files will be created.- See Also:
 
- 
COMMIT_FREQ_COUNTDeprecated.please useHdfsSpout.setCommitFrequencyCount(int)Commit after N records. 0 disables this.- See Also:
 
- 
COMMIT_FREQ_SECDeprecated.please useHdfsSpout.setCommitFrequencySec(int)Commit after N secs. cannot be disabled.- See Also:
 
- 
MAX_OUTSTANDINGDeprecated.please useHdfsSpout.setMaxOutstanding(int)Max outstanding.- See Also:
 
- 
LOCK_TIMEOUTDeprecated.please useHdfsSpout.setLockTimeoutSec(int)Lock timeout.- See Also:
 
- 
CLOCKS_INSYNCDeprecated.please useHdfsSpout.setClocksInSync(boolean)If clocks on machines in the Storm cluster are in sync inactivity duration after which locks are considered candidates for being reassigned to another spout.- See Also:
 
- 
IGNORE_SUFFIXDeprecated.please useHdfsSpout.setIgnoreSuffix(String)Ignore suffix.- See Also:
 
- 
DEFAULT_LOCK_DIRFilenames with this suffix in archive dir will be ignored by the Spout.- See Also:
 
- 
DEFAULT_COMMIT_FREQ_COUNTpublic static final int DEFAULT_COMMIT_FREQ_COUNT- See Also:
 
- 
DEFAULT_COMMIT_FREQ_SECpublic static final int DEFAULT_COMMIT_FREQ_SEC- See Also:
 
- 
DEFAULT_MAX_OUTSTANDINGpublic static final int DEFAULT_MAX_OUTSTANDING- See Also:
 
- 
DEFAULT_LOCK_TIMEOUTpublic static final int DEFAULT_LOCK_TIMEOUT- See Also:
 
- 
DEFAULT_HDFS_CONFIG_KEY- See Also:
 
 
- 
- 
Constructor Details- 
Configspublic Configs()
 
- 
HdfsSpout.setArchiveDir(String)