com.toolsverse.etl.connector

Class BaseSplitProcessor

Object

com.toolsverse.etl.connector.BaseSplitProcessor

All Implemented Interfaces:

SplitProcessor

Direct Known Subclasses:

JsonSplitProcessor, TextSplitProcessor, XmlSplitProcessor

public abstract class BaseSplitProcessor
extends Object
implements SplitProcessor

This base abstract implementation of the SplitProcessor.

Since:

5.8

Version:

1.0

Constructor Summary

Constructors

Constructor and Description
BaseSplitProcessor()

Method Summary

Modifier and Type	Method and Description
void	close() Close.
void	configureSplit(Properties properties, String toFilename) Configure split.
String	getAction() Gets the action.
int	getMaxNumberOfRows() Gets the maximum number of rows in file.
boolean	supportsParallel() Supports parallel.

Methods inherited from class Object

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

Methods inherited from interface com.toolsverse.io.SplitProcessor

split

Constructor Detail

BaseSplitProcessor

public BaseSplitProcessor()

Method Detail

getMaxNumberOfRows

public int getMaxNumberOfRows()

Gets the maximum number of rows in file.

Returns:

int, the maximum number of rows in file

configureSplit

public void configureSplit(Properties properties,
                           String toFilename)
                    throws IllegalArgumentException

Description copied from interface: SplitProcessor

Configure split.

Specified by:

configureSplit in interface SplitProcessor

Parameters:

properties - the properties

toFilename - the to filename

Throws:

IllegalArgumentException - the illegal argument exception

close

public void close()
           throws Exception

Description copied from interface: SplitProcessor

Close.

Specified by:

close in interface SplitProcessor

Throws:

Exception

getAction

public String getAction()

Description copied from interface: SplitProcessor

Gets the action.

Specified by:

getAction in interface SplitProcessor

Returns:

the action

supportsParallel

public boolean supportsParallel()

Description copied from interface: SplitProcessor

Supports parallel.

Specified by:

supportsParallel in interface SplitProcessor

Returns:

true, if successful