Modifier and Type | Class and Description |
---|---|
static class |
Configs.ReaderTypeValidator |
Constructor and Description |
---|
Configs() |
@Deprecated public static final String READER_TYPE
HdfsSpout.setReaderType(String)
public static final String TEXT
public static final String SEQ
@Deprecated public static final String HDFS_URI
HdfsSpout.setHdfsUri(String)
@Deprecated public static final String SOURCE_DIR
HdfsSpout.setSourceDir(String)
@Deprecated public static final String ARCHIVE_DIR
HdfsSpout.setArchiveDir(String)
@Deprecated public static final String BAD_DIR
HdfsSpout.setBadFilesDir(String)
@Deprecated public static final String LOCK_DIR
HdfsSpout.setLockDir(String)
@Deprecated public static final String COMMIT_FREQ_COUNT
HdfsSpout.setCommitFrequencyCount(int)
@Deprecated public static final String COMMIT_FREQ_SEC
HdfsSpout.setCommitFrequencySec(int)
@Deprecated public static final String MAX_OUTSTANDING
HdfsSpout.setMaxOutstanding(int)
@Deprecated public static final String LOCK_TIMEOUT
HdfsSpout.setLockTimeoutSec(int)
@Deprecated public static final String CLOCKS_INSYNC
HdfsSpout.setClocksInSync(boolean)
@Deprecated public static final String IGNORE_SUFFIX
HdfsSpout.setIgnoreSuffix(String)
public static final String DEFAULT_LOCK_DIR
public static final int DEFAULT_COMMIT_FREQ_COUNT
public static final int DEFAULT_COMMIT_FREQ_SEC
public static final int DEFAULT_MAX_OUTSTANDING
public static final int DEFAULT_LOCK_TIMEOUT
public static final String DEFAULT_HDFS_CONFIG_KEY
Copyright © 2019 The Apache Software Foundation. All rights reserved.