com.northconcepts.datapipeline.foundations.datamapping

Class DataMappingEditor

java.lang.Object

com.northconcepts.datapipeline.foundations.datamapping.DataMappingEditor

public class DataMappingEditor
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static int	COLUMN_STATS_READER_THREADS
static int	MAX_WAIT_TIME
static int	MIN_DATA_SIZE
static int	PAGE_SIZE

Constructor Summary

Constructors

Constructor and Description
DataMappingEditor(DataReaderFactory source)

Method Summary

Modifier and Type	Method and Description
DataMappingEditor	applyDataMapping() Re-applies an existing DataMapping on the source dataset along with the existing sorting and page number.
DataMappingEditor	applyDataMapping(DataMapping dataMapping) Applies a new DataMapping on the source dataset along with the existing sorting and page number.
DataMappingEditor	applyPagination() Re-applies the existing sorting and page number to the existing mapped data from the source dataset.
DataMappingEditor	applyPagination(int pageNumber) Applies a new sorting and page number to the existing mapped data from the source dataset.
DataMappingEditor	close()
DataMapping	getDataMapping()
Dataset	getDatasetAfterDataMapping() Returns the dataset containing the mapped data that hasn't been sorted.
RecordList	getFailedRecords() Returns the records which failed mapping along with the failure details in a sess\ion property (limited to #getMaxSavedFailedRecords() records).
int	getMaxPagedRecordCount()
int	getPageNumber()
DataReaderFactory	getSource()
RecordList	getTarget() Returns all of the mapped and sorted data.
RecordList	getTargetPage()
long	getTotalFailedRecordCount() Returns total failed record count during mapping.

Methods inherited from class java.lang.Object

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

Field Detail

COLUMN_STATS_READER_THREADS

public static final int COLUMN_STATS_READER_THREADS

See Also:

Constant Field Values

PAGE_SIZE

public static final int PAGE_SIZE

See Also:

Constant Field Values

MIN_DATA_SIZE

public static final int MIN_DATA_SIZE

See Also:

Constant Field Values

MAX_WAIT_TIME

public static final int MAX_WAIT_TIME

See Also:

Constant Field Values

Constructor Detail

DataMappingEditor

public DataMappingEditor(DataReaderFactory source)

Method Detail

close

public DataMappingEditor close()

applyDataMapping

public DataMappingEditor applyDataMapping(DataMapping dataMapping)

Applies a new DataMapping on the source dataset along with the existing sorting and page number.

applyDataMapping

public DataMappingEditor applyDataMapping()

Re-applies an existing DataMapping on the source dataset along with the existing sorting and page number.

applyPagination

public DataMappingEditor applyPagination(int pageNumber)

Applies a new sorting and page number to the existing mapped data from the source dataset. This method does not cause a reload or re mapping of the source, it uses the data currently loaded and mapped.

applyPagination

public DataMappingEditor applyPagination()

Re-applies the existing sorting and page number to the existing mapped data from the source dataset. This method does not cause a reload or re mapping of the source, it uses the data currently loaded and mapped.

getSource

public DataReaderFactory getSource()

getDatasetAfterDataMapping

public Dataset getDatasetAfterDataMapping()

Returns the dataset containing the mapped data that hasn't been sorted. Sorting occurs on the target RecordList -- see getTarget().

getDataMapping

public DataMapping getDataMapping()

getPageNumber

public int getPageNumber()

getMaxPagedRecordCount

public int getMaxPagedRecordCount()

getTarget

public RecordList getTarget()

Returns all of the mapped and sorted data.

getFailedRecords

public RecordList getFailedRecords()

Returns the records which failed mapping along with the failure details in a sess\ion property (limited to #getMaxSavedFailedRecords() records). The session property key is #DATA_MAPPING_RESULT_SESSION_KEY and the type is DataMappingResult.

getTotalFailedRecordCount

public long getTotalFailedRecordCount()

Returns total failed record count during mapping.

getTargetPage

public RecordList getTargetPage()