public class SequenceWriter extends ProxyWriter
Modifier and Type | Class and Description |
---|---|
static interface |
SequenceWriter.DataWriterFactory |
static class |
SequenceWriter.ElapsedTimeSequenceStrategy |
static interface |
SequenceWriter.ISequenceStrategy |
static class |
SequenceWriter.OrSequenceStrategy |
static class |
SequenceWriter.RecordCountSequenceStrategy |
static class |
SequenceWriter.SchedulerSequenceStrategy |
static class |
SequenceWriter.Sequence |
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 |
---|
SequenceWriter(SequenceWriter.ISequenceStrategy strategy,
SequenceWriter.DataWriterFactory factory) |
Modifier and Type | Method and Description |
---|---|
protected void |
writeImpl(Record record)
Overridden by subclasses to write the specified record to this
DataWriter . |
addExceptionProperties, available, close, getNestedWriter, interceptRecord, map, map, open, setNestedDataWriter, setNestedDataWriter
getNestedEndpoint, getRootEndpoint, getRootWriter, write
decrementRecordCount, enableJmx, getLastRecord, getRecordCount, getRecordCountAsBigInteger, getRecordCountAsString, 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 SequenceWriter(SequenceWriter.ISequenceStrategy strategy, SequenceWriter.DataWriterFactory factory)
protected void writeImpl(Record record) throws Throwable
DataWriter
DataWriter
.writeImpl
in class ProxyWriter
Throwable
Copyright (c) 2006-2023 North Concepts Inc. All Rights Reserved.