Package org.apache.storm.hdfs.spout
Class Configs
java.lang.Object
org.apache.storm.hdfs.spout.Configs
- All Implemented Interfaces:
Validated
-
Nested Class Summary
Nested Classes -
Field Summary
FieldsModifier 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 Summary
Constructors -
Method Summary
-
Field Details
-
READER_TYPE
Deprecated.please useHdfsSpout.setReaderType(String)Required - chose the file type being consumed.- See Also:
-
TEXT
- See Also:
-
SEQ
- See Also:
-
HDFS_URI
Deprecated.please useHdfsSpout.setHdfsUri(String)Required - HDFS name node.- See Also:
-
SOURCE_DIR
Deprecated.please useHdfsSpout.setSourceDir(String)Required - dir from which to read files.- See Also:
-
ARCHIVE_DIR
Deprecated.please useHdfsSpout.setArchiveDir(String)Required - completed files will be moved here.- See Also:
-
BAD_DIR
Deprecated.please useHdfsSpout.setBadFilesDir(String)Required - unparsable files will be moved here.- See Also:
-
LOCK_DIR
Deprecated.please useHdfsSpout.setLockDir(String)Directory in which lock files will be created.- See Also:
-
COMMIT_FREQ_COUNT
Deprecated.please useHdfsSpout.setCommitFrequencyCount(int)Commit after N records. 0 disables this.- See Also:
-
COMMIT_FREQ_SEC
Deprecated.please useHdfsSpout.setCommitFrequencySec(int)Commit after N secs. cannot be disabled.- See Also:
-
MAX_OUTSTANDING
Deprecated.please useHdfsSpout.setMaxOutstanding(int)Max outstanding.- See Also:
-
LOCK_TIMEOUT
Deprecated.please useHdfsSpout.setLockTimeoutSec(int)Lock timeout.- See Also:
-
CLOCKS_INSYNC
Deprecated.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_SUFFIX
Deprecated.please useHdfsSpout.setIgnoreSuffix(String)Ignore suffix.- See Also:
-
DEFAULT_LOCK_DIR
Filenames with this suffix in archive dir will be ignored by the Spout.- See Also:
-
DEFAULT_COMMIT_FREQ_COUNT
public static final int DEFAULT_COMMIT_FREQ_COUNT- See Also:
-
DEFAULT_COMMIT_FREQ_SEC
public static final int DEFAULT_COMMIT_FREQ_SEC- See Also:
-
DEFAULT_MAX_OUTSTANDING
public static final int DEFAULT_MAX_OUTSTANDING- See Also:
-
DEFAULT_LOCK_TIMEOUT
public static final int DEFAULT_LOCK_TIMEOUT- See Also:
-
DEFAULT_HDFS_CONFIG_KEY
- See Also:
-
-
Constructor Details
-
Configs
public Configs()
-
HdfsSpout.setArchiveDir(String)