org.springframework.xd.test.fixtures

Class HdfsJdbcJob

java.lang.Object

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

org.springframework.xd.test.fixtures.HdfsJdbcJob

public class HdfsJdbcJob
extends AbstractModuleFixture<HdfsJdbcJob>

A test fixture that represents the HdfsJdbc Job

Author:

Glenn Renfro

Field Summary

Fields

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

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

label

Constructor Summary

Constructors

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.

Method Summary

Methods

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()

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_NAME

public static final java.lang.String DEFAULT_TABLE_NAME

See Also:

Constant Field Values

DEFAULT_NAMES

public static final java.lang.String DEFAULT_NAMES

See Also:

Constant Field Values

Constructor Detail

HdfsJdbcJob

public 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.

Parameters:

dir - the directory where the source file is located on hdfs

fileName - 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.

Method Detail

withDefaults

public static HdfsJdbcJob withDefaults()

toDSL

public java.lang.String toDSL()

Renders the default DSL for this fixture.

Specified by:

toDSL in class AbstractModuleFixture<HdfsJdbcJob>

dir

public HdfsJdbcJob dir(java.lang.String dir)

Sets the directory where the file will be read from the hdfs.

Parameters:

dir - the directory path.

Returns:

The current instance of the HdfsJdbcJob

fileName

public HdfsJdbcJob fileName(java.lang.String fileName)

Sets the fileName of the file to be read

Parameters:

fileName - the name of the file

Returns:

The current instance of the HdfsJdbcJob

tableName

public HdfsJdbcJob tableName(java.lang.String tableName)

Sets the tableName where the data will be written.

Parameters:

tableName - The name of the table

Returns:

The current instance of the HdfsJdbcJob

names

public HdfsJdbcJob names(java.lang.String names)

Sets the column names that will be written to.

Parameters:

names - Comma delimited list of column names.

Returns:

The current instance of the HdfsJdbcJob