public class IncrementalJdbcHdfsJob extends AbstractModuleFixture<IncrementalJdbcHdfsJob>
| Modifier and Type | Field and Description |
|---|---|
static java.lang.String |
DEFAULT_COLUMN |
static java.lang.String |
DEFAULT_DIRECTORY |
static java.lang.String |
DEFAULT_FILE_NAME |
static int |
DEFAULT_OVERRIDE |
static java.lang.String |
DEFAULT_TABLE |
label| Constructor and Description |
|---|
IncrementalJdbcHdfsJob(java.lang.String dir,
java.lang.String fileName,
java.lang.String table,
java.lang.String columns,
java.lang.String partitionColumn,
int partitions,
java.lang.String checkColumn,
int override)
Construct a new jdbchdfs fixture using the provided dir, file and sql.
|
| Modifier and Type | Method and Description |
|---|---|
java.lang.String |
toDSL()
Renders the default DSL for this fixture.
|
static IncrementalJdbcHdfsJob |
withDefaults()
Creates an instance of the JdbcHdfsJob fixture using defaults.
|
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
public static final java.lang.String DEFAULT_COLUMN
public static final int DEFAULT_OVERRIDE
public IncrementalJdbcHdfsJob(java.lang.String dir,
java.lang.String fileName,
java.lang.String table,
java.lang.String columns,
java.lang.String partitionColumn,
int partitions,
java.lang.String checkColumn,
int override)
dir - the directory where the result file will be writtenfileName - The name of the file to be written.table - The table that contains the data to be extracted from the databasecolumns - The columns that contains the data to be extracted from the databasepublic static IncrementalJdbcHdfsJob withDefaults()
public java.lang.String toDSL()
toDSL in class AbstractModuleFixture<IncrementalJdbcHdfsJob>