com.toolsverse.etl.connector

Class BaseStreamingPackage<P extends DataSetConnectorParams>

Object

com.toolsverse.etl.connector.BaseStreamingPackage<P>

Type Parameters:

P - the generic type

All Implemented Interfaces:

StreamingPackage

Direct Known Subclasses:

JsonStreamingPackage, KeyValueStreamingPackage, TextStreamingPackage, XmlStreamingPackage

public abstract class BaseStreamingPackage<P extends DataSetConnectorParams>
extends Object
implements StreamingPackage

The base class for streaming packages.

Since:

5.9

Version:

2.0

Constructor Summary

Constructors

Constructor and Description
BaseStreamingPackage()

Method Summary

Modifier and Type	Method and Description
DataSet	getDataSet() Gets the data set.
Driver	getDriver() Gets the driver.
String	getFilter() Gets the filter.
int	getMaxRows() Gets the maximum number of rows allowed for the DataSet.
P	getParams() Gets the parameters.
boolean	hasDestination() Checks if package has destination.
void	setCrudAction(String crudAction) Sets the CRUD action.
void	setDataSet(DataSet dataSet) Sets the data set.
void	setDriver(Driver driver) Sets the driver.
void	setFilter(String filter) Sets the filter.
void	setParams(P params) Sets the parameters.
void	setTarget(String target) Sets the target.

Methods inherited from class Object

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

Constructor Detail

BaseStreamingPackage

public BaseStreamingPackage()

Method Detail

getMaxRows

public int getMaxRows()

Description copied from interface: StreamingPackage

Gets the maximum number of rows allowed for the DataSet. Once number of rows reaches maximum - data set population stops.

Specified by:

getMaxRows in interface StreamingPackage

Returns:

int

getDataSet

public DataSet getDataSet()

Gets the data set.

Returns:

the data set

setDataSet

public void setDataSet(DataSet dataSet)

Sets the data set.

Parameters:

dataSet - the new data set

getDriver

public Driver getDriver()

Gets the driver.

Returns:

the driver

setDriver

public void setDriver(Driver driver)

Sets the driver.

Parameters:

driver - the new driver

getParams

public P getParams()

Gets the parameters.

Returns:

the parameters

setParams

public void setParams(P params)

Sets the parameters.

Parameters:

params - the new parameters

getFilter

public String getFilter()

Description copied from interface: StreamingPackage

Gets the filter.

Specified by:

getFilter in interface StreamingPackage

Returns:

the filter

setFilter

public void setFilter(String filter)

Sets the filter.

Parameters:

filter - the new filter

setCrudAction

public void setCrudAction(String crudAction)

Description copied from interface: StreamingPackage

Sets the CRUD action.

Specified by:

setCrudAction in interface StreamingPackage

Parameters:

crudAction - the new crud action

setTarget

public void setTarget(String target)

Sets the target.

Specified by:

setTarget in interface StreamingPackage

Parameters:

target - the new target

hasDestination

public boolean hasDestination()

Description copied from interface: StreamingPackage

Checks if package has destination.

Specified by:

hasDestination in interface StreamingPackage

Returns:

true, if package has destination