org.springframework.xd.test.fixtures

Class IncrementalJdbcHdfsJob

java.lang.Object

org.springframework.xd.test.fixtures.AbstractModuleFixture<IncrementalJdbcHdfsJob>

org.springframework.xd.test.fixtures.IncrementalJdbcHdfsJob

public class IncrementalJdbcHdfsJob
extends AbstractModuleFixture<IncrementalJdbcHdfsJob>

A test fixture that represents the JdbcHdfs Job

Author:

Glenn Renfro, Michael Minella

Field Summary

Fields

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

Fields inherited from class org.springframework.xd.test.fixtures.AbstractModuleFixture

label

Constructor Summary

Constructors

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.

Method Summary

Methods

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.

Methods inherited from class org.springframework.xd.test.fixtures.AbstractModuleFixture

label, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

DEFAULT_DIRECTORY

public static final java.lang.String DEFAULT_DIRECTORY

See Also:

Constant Field Values

DEFAULT_FILE_NAME

public static final java.lang.String DEFAULT_FILE_NAME

See Also:

Constant Field Values

DEFAULT_TABLE

public static final java.lang.String DEFAULT_TABLE

See Also:

Constant Field Values

DEFAULT_COLUMN

public static final java.lang.String DEFAULT_COLUMN

See Also:

Constant Field Values

DEFAULT_OVERRIDE

public static final int DEFAULT_OVERRIDE

See Also:

Constant Field Values

Constructor Detail

IncrementalJdbcHdfsJob

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)

Construct a new jdbchdfs fixture using the provided dir, file and sql.

Parameters:

dir - the directory where the result file will be written

fileName - The name of the file to be written.

table - The table that contains the data to be extracted from the database

columns - The columns that contains the data to be extracted from the database

Method Detail

withDefaults

public static IncrementalJdbcHdfsJob withDefaults()

Creates an instance of the JdbcHdfsJob fixture using defaults.

Returns:

an instance of the JdbcHdfsJob fixture.

toDSL

public java.lang.String toDSL()

Renders the default DSL for this fixture.

Specified by:

toDSL in class AbstractModuleFixture<IncrementalJdbcHdfsJob>