org.springframework.xd.test.fixtures

Class FilePollHdfsJob

java.lang.Object

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

org.springframework.xd.test.fixtures.FilePollHdfsJob

public class FilePollHdfsJob
extends AbstractModuleFixture<FilePollHdfsJob>

Test fixture that creates a File Poll Hdfs 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

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

label

Constructor Summary

Constructors

Constructor and Description
FilePollHdfsJob(java.lang.String directory, java.lang.String fileName, java.lang.String names) Initializes an instance of FilePollHdfsJob

Method Summary

Methods

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.

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_FILE_NAME

public static final java.lang.String DEFAULT_FILE_NAME

See Also:

Constant Field Values

DEFAULT_DIRECTORY

public static final java.lang.String DEFAULT_DIRECTORY

See Also:

Constant Field Values

Constructor Detail

FilePollHdfsJob

public FilePollHdfsJob(java.lang.String directory,
               java.lang.String fileName,
               java.lang.String names)

Initializes an instance of FilePollHdfsJob

Parameters:

directory - The hdfs directory where the result file will be written

fileName - The result file name

names - the column names the job will pull from the csv file

Method Detail

withDefaults

public static FilePollHdfsJob withDefaults(java.lang.String names)

Creates a FilePollHdfsJob instance using defaults.

Parameters:

names - the column names the job will pull from the csv file

Returns:

an instance of the FilePollHdfsJob

toDSL

public java.lang.String toDSL()

Renders the default DSL for this fixture.

Specified by:

toDSL in class AbstractModuleFixture<FilePollHdfsJob>

fileName

public FilePollHdfsJob fileName(java.lang.String fileName)

Sets the fileName that the hdfs will write to.

Parameters:

fileName - the name of the table.

Returns:

an instance to this FilePollHdfsJob.

directory

public FilePollHdfsJob directory(java.lang.String directory)

Sets the directory that the hdfs will write to.

Parameters:

directory - the name of the table.

Returns:

an instance to this FilePollHdfsJob.

names

public FilePollHdfsJob names(java.lang.String names)

Sets the column names the job will pull from the csv file

Parameters:

names - comma delimited list of column names

Returns:

an instance to this FilePollHdfsJob.