public class HdfsJdbcJob extends AbstractModuleFixture<HdfsJdbcJob>
| Modifier and Type | Field and Description |
|---|---|
static java.lang.String |
DEFAULT_DIRECTORY |
static java.lang.String |
DEFAULT_FILE_NAME |
static java.lang.String |
DEFAULT_NAMES |
static java.lang.String |
DEFAULT_TABLE_NAME |
label| Constructor and Description |
|---|
HdfsJdbcJob(java.lang.String dir,
java.lang.String fileName,
java.lang.String tableName,
java.lang.String names)
Construct a new HdfsJdbcJob using the provided directory and file names.
|
| Modifier and Type | Method and Description |
|---|---|
HdfsJdbcJob |
dir(java.lang.String dir)
Sets the directory where the file will be read from the hdfs.
|
HdfsJdbcJob |
fileName(java.lang.String fileName)
Sets the fileName of the file to be read
|
HdfsJdbcJob |
names(java.lang.String names)
Sets the column names that will be written to.
|
HdfsJdbcJob |
tableName(java.lang.String tableName)
Sets the tableName where the data will be written.
|
java.lang.String |
toDSL()
Renders the default DSL for this fixture.
|
static HdfsJdbcJob |
withDefaults() |
label, toStringpublic static final java.lang.String DEFAULT_DIRECTORY
public static final java.lang.String DEFAULT_FILE_NAME
public static final java.lang.String DEFAULT_TABLE_NAME
public static final java.lang.String DEFAULT_NAMES
public HdfsJdbcJob(java.lang.String dir,
java.lang.String fileName,
java.lang.String tableName,
java.lang.String names)
dir - the directory where the source file is located on hdfsfileName - The file from which data will be pulled.tableName - the table where the data will be written.names - a comma delimited list of column names that are contained in the source file.public static HdfsJdbcJob withDefaults()
public java.lang.String toDSL()
toDSL in class AbstractModuleFixture<HdfsJdbcJob>public HdfsJdbcJob dir(java.lang.String dir)
dir - the directory path.public HdfsJdbcJob fileName(java.lang.String fileName)
fileName - the name of the filepublic HdfsJdbcJob tableName(java.lang.String tableName)
tableName - The name of the tablepublic HdfsJdbcJob names(java.lang.String names)
names - Comma delimited list of column names.