com.northconcepts.datapipeline.memory.MemoryWriter

public class MemoryWriter extends DataWriter

Writes records to an in-memory RecordList.

Nested Class Summary

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

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

Description

MemoryWriter()

MemoryWriter(RecordList recordSet)
Method Summary

Modifier and Type

Method

Description

RecordList

getRecordList()

String

toString()

protected void

writeImpl(Record record)

Overridden by subclasses to write the specified record to this DataWriter.

Methods inherited from class com.northconcepts.datapipeline.core.DataWriter
addExceptionProperties, available, getNestedEndpoint, getNestedWriter, getRootEndpoint, getRootWriter, getWriter, write

Methods inherited from class com.northconcepts.datapipeline.core.DataEndpoint
close, decrementRecordCount, enableJmx, getLastRecord, getRecordCount, getRecordCountAsBigInteger, getRecordCountAsString, incrementRecordCount, isRecordCountBigInteger, open, 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 Details
- MemoryWriter
  
  public MemoryWriter()
- MemoryWriter
  
  public MemoryWriter(RecordList recordSet)
Method Details
- getRecordList
  
  public RecordList getRecordList()
- writeImpl
  
  protected void writeImpl(Record record) throws Throwable
  
  Description copied from class: DataWriter
  Overridden by subclasses to write the specified record to this DataWriter.
  Contract for subclasses (see also docs/authoring/DataWriter.md):
  
  Do not call this method directly — DataWriter.write(Record) is the template method that wraps exceptions, increments the record count, and attaches the offending record to thrown DataExceptions.
  
  Do not call DataEndpoint.incrementRecordCount() here; DataWriter.write(Record) already does.
  
  Throw raw exceptions; DataWriter.write(Record) wraps them via exception(throwable).setRecord(record).
  Specified by:
  
  writeImpl in class DataWriter
  
  Throws:
  
  Throwable
- toString
  
  public String toString()
  
  Overrides:
  
  toString in class DataEndpoint

Class MemoryWriter

Nested Class Summary

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

Field Summary

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

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

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

Constructor Summary

Method Summary

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

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

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

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

Methods inherited from class java.lang.Object

Constructor Details

MemoryWriter

MemoryWriter

Method Details

getRecordList

writeImpl

toString