com.toolsverse.etl.connector.xml

Class XmlMerger

Object

com.toolsverse.etl.connector.xml.XmlMerger

All Implemented Interfaces:

SplitProcessor

public class XmlMerger
extends Object
implements SplitProcessor

The XML merge service

Since:

1.0.0

Version:

1.0.0

Constructor Summary

Constructors

Constructor and Description
XmlMerger() Create XML merge.
XmlMerger(String path, OutputStream out, boolean includeHeader) Create XML merge object with the given repeating path and output stream
XmlMerger(String path, String outputFile, boolean includeHeader) Create XML merge object with the given repeating path and output file path

Method Summary

Modifier and Type	Method and Description
void	close() Finishes XML merge by closing all open elements and streams.
void	configureSplit(Properties properties, String toFilename) Configure split.
String	getAction() Gets the action.
void	merge(InputStream stream) Merge given input stream repeating elements into global output
void	merge(String filePath) Merge given file repeating elements into global output
IoStatus	split(IoProcessor source, IoProcessor destination, String fromFolder, String toFolder, String filename) Split the input stream into multiple files.
boolean	supportsParallel() Supports parallel.

Methods inherited from class Object

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

Constructor Detail

XmlMerger

public XmlMerger()

Create XML merge.

XmlMerger

public XmlMerger(String path,
                 String outputFile,
                 boolean includeHeader)
          throws Exception

Create XML merge object with the given repeating path and output file path

Parameters:

path - the XPath like path to repeating element

outputFile - the full path to the output file, including file name and extension

includeHeader - if true, will include all elements preceding repeating element

Throws:

Exception - in case of any error

XmlMerger

public XmlMerger(String path,
                 OutputStream out,
                 boolean includeHeader)
          throws IllegalArgumentException

Create XML merge object with the given repeating path and output stream

Parameters:

path - the XPath like path to repeating element

out - the output stream

includeHeader - if true, will include all elements preceding repeating element

Throws:

IllegalArgumentException - in case of malformed path

Method Detail

merge

public void merge(String filePath)
           throws Exception

Merge given file repeating elements into global output

Parameters:

filePath - the full path to the input file, including file name and extension

Throws:

Exception - in case of any error

merge

public void merge(InputStream stream)
           throws Exception

Merge given input stream repeating elements into global output

Parameters:

stream - the input stream

Throws:

Exception - in case of any error

close

public void close()
           throws Exception

Finishes XML merge by closing all open elements and streams.

Specified by:

close in interface SplitProcessor

Throws:

Exception - in case of any error

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

split

public IoStatus split(IoProcessor source,
                      IoProcessor destination,
                      String fromFolder,
                      String toFolder,
                      String filename)
               throws Exception

Description copied from interface: SplitProcessor

Split the input stream into multiple files.

Specified by:

split in interface SplitProcessor

Parameters:

source - IoProcessor, the source IoProcessor

destination - IoProcessor, the destination IoProcessor

fromFolder - the from folder

toFolder - the to folder

filename - the filename

Returns:

IoStatus, the status

Throws:

Exception - in case of any error

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