org.springframework.xd.integration.fixtures

Class Jobs

java.lang.Object

org.springframework.xd.integration.fixtures.Jobs

public class Jobs
extends java.lang.Object

A factory that provides fully instantiated job fixtures using default values.

Author:

Glenn Renfro, David Turanski

Constructor Summary

Constructors

Constructor and Description
Jobs(XdEnvironment environment) Initializes the instance with xdEnvironment

Method Summary

Methods

Modifier and Type	Method and Description
FileJdbcJob	fileJdbcJob() Create an instance of the FileJdbc job with the default target dir, fileName, tableName and column names.
FilePollHdfsJob	filePollHdfsJob(java.lang.String names) Creates an instance of the FilePollHdfsJob using defaults.
FtpHdfsJob	ftpHdfsJob() Create a FtpHdfsJob Fixture using defaults.
HdfsJdbcJob	hdfsJdbcJob() Create an instance of the HdfsJdbc job with the default target dir, fileName, tableName and column names.
HdfsMongoDbJob	hdfsMongoDb() Create a new HdfsMongoDbJob that constructs a job that will read data from hdfs and output to mongo using default values.
IncrementalJdbcHdfsJob	incrementalJdbcHdfsJob() Create an instance of the JdbcHdfs job with the default hdfs target dir, fileName and source sql statement.
JdbcHdfsJob	jdbcHdfsJob() Create an instance of the JdbcHdfs job with the default hdfs target dir, fileName and source sql statement.
PartitionedJdbcHdfsJob	partitionedJdbcHdfsJob() Create an instance of the PartitionedJdbcHdfsJob job with the default hdfs target dir, fileName, table, columnNames, partitionColumn and partitions.
SparkAppJob	sparkAppJob() Create a new SparkAppJob fixture instance that is configured via property files or environment variables.

Methods inherited from class java.lang.Object

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

Constructor Detail

Jobs

public Jobs(XdEnvironment environment)

Initializes the instance with xdEnvironment

Parameters:

environment -

Method Detail

fileJdbcJob

public FileJdbcJob fileJdbcJob()

Create an instance of the FileJdbc job with the default target dir, fileName, tableName and column names.

Returns:

instance of a FileJDBCJob Fixture.

See Also:

for default values

hdfsJdbcJob

public HdfsJdbcJob hdfsJdbcJob()

Create an instance of the HdfsJdbc job with the default target dir, fileName, tableName and column names.

Returns:

instance of a HdfsJDBCJob Fixture.

See Also:

for default values

jdbcHdfsJob

public JdbcHdfsJob jdbcHdfsJob()

Create an instance of the JdbcHdfs job with the default hdfs target dir, fileName and source sql statement.

Returns:

instance of a JdbcHdfsJob Fixture.

See Also:

for default values

incrementalJdbcHdfsJob

public IncrementalJdbcHdfsJob incrementalJdbcHdfsJob()

Create an instance of the JdbcHdfs job with the default hdfs target dir, fileName and source sql statement.

Returns:

instance of a JdbcHdfsJob Fixture.

See Also:

for default values

partitionedJdbcHdfsJob

public PartitionedJdbcHdfsJob partitionedJdbcHdfsJob()

Create an instance of the PartitionedJdbcHdfsJob job with the default hdfs target dir, fileName, table, columnNames, partitionColumn and partitions.

Returns:

instance of a PartitionedJdbcHdfsJob Fixture.

See Also:

for default values

filePollHdfsJob

public FilePollHdfsJob filePollHdfsJob(java.lang.String names)

Creates an instance of the FilePollHdfsJob using defaults.

Parameters:

names - A comma delimited list of column names

Returns:

an instance of the FilePollHdfsJob fixture.

hdfsMongoDb

public HdfsMongoDbJob hdfsMongoDb()

Create a new HdfsMongoDbJob that constructs a job that will read data from hdfs and output to mongo using default values. Ensures that one can connect to MongoDB Server

Returns:

a HdfsMongoDbJob instance.

ftpHdfsJob

public FtpHdfsJob ftpHdfsJob()

Create a FtpHdfsJob Fixture using defaults.

Returns:

a FtpHdfsJob instance

sparkAppJob

public SparkAppJob sparkAppJob()

Create a new SparkAppJob fixture instance that is configured via property files or environment variables.

Returns:

SparkAppJob instance