org.springframework.xd.test.fixtures

Class HdfsSink

java.lang.Object

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

org.springframework.xd.test.fixtures.HdfsSink

public class HdfsSink
extends AbstractModuleFixture<HdfsSink>

A test fixture that allows testing of the 'hdfs' sink module.

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
HdfsSink(java.lang.String directoryName, java.lang.String fileName) Initializes a hdfs file sink fixture;

Method Summary

Methods

Modifier and Type	Method and Description
HdfsSink	directoryName(java.lang.String directoryName) Sets the directory that the file will be written on hdfs
HdfsSink	fileName(java.lang.String fileName) Sets the file Name that the hdfs sink will write the data.
java.lang.String	toDSL() Renders the DSL for this fixture.
static HdfsSink	withDefaults() Returns an instance of the HdfsSink 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

HdfsSink

public HdfsSink(java.lang.String directoryName,
        java.lang.String fileName)

Initializes a hdfs file sink fixture;

Parameters:

directoryName - The directory to write the file on the hdfs.

fileName - The name of file to write on the hdfs.

Method Detail

withDefaults

public static HdfsSink withDefaults()

Returns an instance of the HdfsSink using defaults.

Returns:

instance of the HdfsSink

toDSL

public java.lang.String toDSL()

Renders the DSL for this fixture.

Specified by:

toDSL in class AbstractModuleFixture<HdfsSink>

fileName

public HdfsSink fileName(java.lang.String fileName)

Sets the file Name that the hdfs sink will write the data.

Parameters:

fileName - the name of the file

Returns:

the current HdfsSink instance.

directoryName

public HdfsSink directoryName(java.lang.String directoryName)

Sets the directory that the file will be written on hdfs

Parameters:

directoryName - the name of the directory

Returns:

the current HdfsSink instance.