org.springframework.xd.test.fixtures

Class PartitionedJdbcHdfsJob

java.lang.Object

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

org.springframework.xd.test.fixtures.PartitionedJdbcHdfsJob

public class PartitionedJdbcHdfsJob
extends AbstractModuleFixture<PartitionedJdbcHdfsJob>

A test fixture that represents a partitioned JdbcHdfs Job

Author:

Glenn Renfro, Thomas Risberg

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	DEFAULT_COLUMN_NAMES
static java.lang.String	DEFAULT_PARTITION_COLUMN
static int	DEFAULT_PARTITIONS
static java.lang.String	DEFAULT_TABLE

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

label

Constructor Summary

Constructors

Constructor and Description
PartitionedJdbcHdfsJob(java.lang.String dir, java.lang.String fileName, java.lang.String tableName, java.lang.String columns, java.lang.String partitionColumn, int partitions) Construct a new jdbchdfs partitioned fixture using the provided parameters.

Method Summary

Methods

Modifier and Type	Method and Description
java.lang.String	toDSL() Renders the default DSL for this fixture.
static PartitionedJdbcHdfsJob	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_TABLE

public static final java.lang.String DEFAULT_TABLE

See Also:

Constant Field Values

DEFAULT_COLUMN_NAMES

public static final java.lang.String DEFAULT_COLUMN_NAMES

See Also:

Constant Field Values

DEFAULT_PARTITION_COLUMN

public static final java.lang.String DEFAULT_PARTITION_COLUMN

See Also:

Constant Field Values

DEFAULT_PARTITIONS

public static final int DEFAULT_PARTITIONS

See Also:

Constant Field Values

Constructor Detail

PartitionedJdbcHdfsJob

public PartitionedJdbcHdfsJob(java.lang.String dir,
                      java.lang.String fileName,
                      java.lang.String tableName,
                      java.lang.String columns,
                      java.lang.String partitionColumn,
                      int partitions)

Construct a new jdbchdfs partitioned fixture using the provided parameters.

Parameters:

dir - the directory where the result file will be written

fileName - The name of the file to be written.

tableName - The tableName name to select from

columns - The column names to select

partitionColumn - The column used for partitioning

partitions - The number of partitions

Method Detail

withDefaults

public static PartitionedJdbcHdfsJob 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<PartitionedJdbcHdfsJob>