public class RecordBuffer extends DataEndpoint
DataEndpoint.State
lastRecord, PRODUCT, PRODUCT_VERSION, VENDOR, XML_INPUT_FACTORY_KEY
BUFFER_SIZE, captureElapsedTime, DEFAULT_READ_BUFFER_SIZE
id, log, name, TIMESTAMP_FORMAT
Constructor and Description |
---|
RecordBuffer(CompositeValue key) |
Modifier and Type | Method and Description |
---|---|
void |
add(Record record) |
DataException |
addExceptionProperties(DataException exception)
Adds this endpoint's current state to a
DataException . |
void |
close()
Indicates that this endpoint has finished reading or writing.
|
CompositeValue |
getKey() |
RecordList |
getRecords() |
long |
getUpdatedOn() |
Record |
nextRecord() |
void |
open()
Makes this endpoint ready for reading or writing.
|
decrementRecordCount, enableJmx, getLastRecord, getNestedEndpoint, getRecordCount, getRecordCountAsBigInteger, getRecordCountAsString, getRootEndpoint, incrementRecordCount, isRecordCountBigInteger, resetRecordCount, toString
addElapsedtime, assertClosed, assertNotOpened, assertOpened, finalize, getClosedOn, getDescription, getElapsedTime, getElapsedTimeAsString, getOpenedOn, getOpenElapsedTime, getOpenElapsedTimeAsString, getSelfTime, getSelfTimeAsString, getState, isCaptureElapsedTime, isClosed, isOpen, setCaptureElapsedTime, setDescription
public RecordBuffer(CompositeValue key)
public CompositeValue getKey()
public long getUpdatedOn()
public RecordList getRecords()
public DataException addExceptionProperties(DataException exception)
Endpoint
DataException
. Since this method is called whenever an
exception is thrown, subclasses should override it to add their specific information.addExceptionProperties
in class DataEndpoint
public void add(Record record)
public void open() throws DataException
DataEndpoint
open
in class DataEndpoint
DataException
public void close() throws DataException
DataEndpoint
close
in class DataEndpoint
DataException
public Record nextRecord()
Copyright (c) 2006-2023 North Concepts Inc. All Rights Reserved.