Package org.apache.storm.hdfs.spout
Class Configs
java.lang.Object
org.apache.storm.hdfs.spout.Configs
- All Implemented Interfaces:
Validated
-
Nested Class Summary
-
Field Summary
Modifier and TypeFieldDescriptionstatic final String
Deprecated.static final String
Deprecated.please useHdfsSpout.setBadFilesDir(String)
static final String
Deprecated.please useHdfsSpout.setClocksInSync(boolean)
static final String
Deprecated.please useHdfsSpout.setCommitFrequencyCount(int)
static final String
Deprecated.please useHdfsSpout.setCommitFrequencySec(int)
static final int
static final int
static final String
static final String
Filenames with this suffix in archive dir will be ignored by the Spout.static final int
static final int
static final String
Deprecated.please useHdfsSpout.setHdfsUri(String)
static final String
Deprecated.please useHdfsSpout.setIgnoreSuffix(String)
static final String
Deprecated.please useHdfsSpout.setLockDir(String)
static final String
Deprecated.please useHdfsSpout.setLockTimeoutSec(int)
static final String
Deprecated.please useHdfsSpout.setMaxOutstanding(int)
static final String
Deprecated.please useHdfsSpout.setReaderType(String)
static final String
static final String
Deprecated.please useHdfsSpout.setSourceDir(String)
static final String
-
Constructor Summary
-
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)