public class FilePollHdfsJob extends AbstractModuleFixture<FilePollHdfsJob>
| Modifier and Type | Field and Description |
|---|---|
static java.lang.String |
DEFAULT_DIRECTORY |
static java.lang.String |
DEFAULT_FILE_NAME |
label| Constructor and Description |
|---|
FilePollHdfsJob(java.lang.String directory,
java.lang.String fileName,
java.lang.String names)
Initializes an instance of FilePollHdfsJob
|
| Modifier and Type | Method and Description |
|---|---|
FilePollHdfsJob |
directory(java.lang.String directory)
Sets the directory that the hdfs will write to.
|
FilePollHdfsJob |
fileName(java.lang.String fileName)
Sets the fileName that the hdfs will write to.
|
FilePollHdfsJob |
names(java.lang.String names)
Sets the column names the job will pull from the csv file
|
java.lang.String |
toDSL()
Renders the default DSL for this fixture.
|
static FilePollHdfsJob |
withDefaults(java.lang.String names)
Creates a FilePollHdfsJob instance using defaults.
|
label, toStringpublic static final java.lang.String DEFAULT_FILE_NAME
public static final java.lang.String DEFAULT_DIRECTORY
public FilePollHdfsJob(java.lang.String directory,
java.lang.String fileName,
java.lang.String names)
directory - The hdfs directory where the result file will be writtenfileName - The result file namenames - the column names the job will pull from the csv filepublic static FilePollHdfsJob withDefaults(java.lang.String names)
names - the column names the job will pull from the csv filepublic java.lang.String toDSL()
toDSL in class AbstractModuleFixture<FilePollHdfsJob>public FilePollHdfsJob fileName(java.lang.String fileName)
fileName - the name of the table.public FilePollHdfsJob directory(java.lang.String directory)
directory - the name of the table.public FilePollHdfsJob names(java.lang.String names)
names - comma delimited list of column names