com.northconcepts.datapipeline.group

Class AggregateReader

java.lang.Object

com.northconcepts.datapipeline.core.DataObject

com.northconcepts.datapipeline.core.Endpoint

com.northconcepts.datapipeline.core.DataEndpoint

com.northconcepts.datapipeline.core.DataReader

com.northconcepts.datapipeline.core.ProxyReader

com.northconcepts.datapipeline.group.AggregateReader

Deprecated.

use GroupByReader instead. GroupByReader provides the same functionality and can return continuous results

@Deprecated
public class AggregateReader
extends ProxyReader

A proxy that applies set functions (sum, max, etc.) to fields of records passing through.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AggregateReader.AggregateOperation Deprecated.

Nested classes/interfaces inherited from class com.northconcepts.datapipeline.core.DataEndpoint

DataEndpoint.State

Field Summary

Fields inherited from class com.northconcepts.datapipeline.core.DataReader

fieldLineage, recordLineage

Fields inherited from class com.northconcepts.datapipeline.core.DataEndpoint

lastRecord, PRODUCT, PRODUCT_VERSION, VENDOR, XML_INPUT_FACTORY_KEY

Fields inherited from class com.northconcepts.datapipeline.core.Endpoint

BUFFER_SIZE, captureElapsedTime, DEFAULT_READ_BUFFER_SIZE

Fields inherited from class com.northconcepts.datapipeline.core.DataObject

id, log, name, TIMESTAMP_FORMAT

Constructor Summary

Constructors

Constructor and Description
AggregateReader(DataReader targetDataSource) Deprecated.

Method Summary

Modifier and Type	Method and Description
AggregateReader	add(AggregateReader.AggregateOperation... operations) Deprecated.
DataException	addExceptionProperties(DataException exception) Deprecated. Adds this endpoint's current state to a DataException.
AggregateReader	average(String fieldName) Deprecated.
AggregateReader	clear() Deprecated.
AggregateReader	count(String fieldName) Deprecated.
Object	getAverage(String fieldName) Deprecated.
Object	getCount(String fieldName) Deprecated.
Object	getMaximum(String fieldName) Deprecated.
Object	getMinimum(String fieldName) Deprecated.
Object	getSum(String fieldName) Deprecated.
protected Record	interceptRecord(Record record) Deprecated.
AggregateReader	maximum(String fieldName) Deprecated.
AggregateReader	minimum(String fieldName) Deprecated.
void	open() Deprecated. Makes this endpoint ready for reading or writing.
void	reset() Deprecated.
AggregateReader	sum(String fieldName) Deprecated.
String	toString() Deprecated.

Methods inherited from class com.northconcepts.datapipeline.core.ProxyReader

available, close, getNestedReader, map, map, readImpl, setNestedDataReader, setNestedDataReader

Methods inherited from class com.northconcepts.datapipeline.core.DataReader

addLineage, getBufferSize, getNestedEndpoint, getReader, getRootEndpoint, getRootReader, isExhausted, isLineageSupported, isSaveLineage, peek, pop, push, read, setSaveLineage, skip

Methods inherited from class com.northconcepts.datapipeline.core.DataEndpoint

decrementRecordCount, enableJmx, getLastRecord, getRecordCount, getRecordCountAsBigInteger, getRecordCountAsString, incrementRecordCount, isRecordCountBigInteger, resetRecordCount

Methods inherited from class com.northconcepts.datapipeline.core.Endpoint

addElapsedtime, assertClosed, assertNotOpened, assertOpened, finalize, getClosedOn, getDescription, getElapsedTime, getElapsedTimeAsString, getOpenedOn, getOpenElapsedTime, getOpenElapsedTimeAsString, getSelfTime, getSelfTimeAsString, getState, isCaptureElapsedTime, isClosed, isOpen, setCaptureElapsedTime, setDescription

Methods inherited from class com.northconcepts.datapipeline.core.DataObject

exception, exception, exception, getId, getName, resetID

Methods inherited from class java.lang.Object

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

Constructor Detail

AggregateReader

public AggregateReader(DataReader targetDataSource)

Deprecated.

Method Detail

addExceptionProperties

public DataException addExceptionProperties(DataException exception)

Deprecated.

Description copied from class: Endpoint

Adds this endpoint's current state to a DataException. Since this method is called whenever an exception is thrown, subclasses should override it to add their specific information.

Overrides:

addExceptionProperties in class ProxyReader

interceptRecord

protected Record interceptRecord(Record record)
                          throws Throwable

Deprecated.

Overrides:

interceptRecord in class ProxyReader

Throws:

Throwable

add

public AggregateReader add(AggregateReader.AggregateOperation... operations)

Deprecated.

clear

public AggregateReader clear()

Deprecated.

reset

public void reset()

Deprecated.

open

public void open()
          throws DataException

Deprecated.

Description copied from class: DataEndpoint

Makes this endpoint ready for reading or writing.

Overrides:

open in class ProxyReader

Throws:

DataException

minimum

public AggregateReader minimum(String fieldName)

Deprecated.

maximum

public AggregateReader maximum(String fieldName)

Deprecated.

sum

public AggregateReader sum(String fieldName)

Deprecated.

average

public AggregateReader average(String fieldName)

Deprecated.

count

public AggregateReader count(String fieldName)

Deprecated.

getMinimum

public Object getMinimum(String fieldName)

Deprecated.

getMaximum

public Object getMaximum(String fieldName)

Deprecated.

getSum

public Object getSum(String fieldName)

Deprecated.

getAverage

public Object getAverage(String fieldName)

Deprecated.

getCount

public Object getCount(String fieldName)

Deprecated.

toString

public String toString()

Deprecated.

Overrides:

toString in class DataEndpoint