public class AvroWriter extends IntegrationWriter
Records
to an Apache Avro file.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 |
---|
AvroWriter(File file,
DataWriter discardWriter)
Write Avro data to the specified file.
|
AvroWriter(OutputStream outputStream,
DataWriter discardWriter)
Write Avro data to an
OutputStream . |
Modifier and Type | Method and Description |
---|---|
DataException |
addExceptionProperties(DataException exception)
Adds this endpoint's current state to a
DataException . |
void |
close()
Indicates that this endpoint has finished reading or writing.
|
long |
getDiscardedRecordCount()
Returns the number of discarded
Records |
void |
open()
Makes this endpoint ready for reading or writing.
|
protected void |
writeImpl(Record record)
Overridden by subclasses to write the specified record to this
DataWriter . |
available, getNestedEndpoint, getNestedWriter, 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 AvroWriter(File file, DataWriter discardWriter)
file
- the file to write todiscardWriter
- discard sink for records not conforming to the Avro schemapublic AvroWriter(OutputStream outputStream, DataWriter discardWriter)
OutputStream
.outputStream
- the target streamdiscardWriter
- discard sink for records not conforming to the Avro schemapublic long getDiscardedRecordCount()
Records
public void open() throws DataException
DataEndpoint
open
in class IntegrationWriter
DataException
public void close() throws DataException
DataEndpoint
close
in class DataEndpoint
DataException
protected void writeImpl(Record record) throws Throwable
DataWriter
DataWriter
.writeImpl
in class DataWriter
Throwable
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 DataWriter
Copyright (c) 2006-2023 North Concepts Inc. All Rights Reserved.