Package org.jumpmind.symmetric.io.data.writer

Class ProtocolDataWriter

java.lang.Object

org.jumpmind.symmetric.io.data.writer.AbstractProtocolDataWriter

org.jumpmind.symmetric.io.data.writer.ProtocolDataWriter

All Implemented Interfaces:

IDataResource, IDataWriter

public class ProtocolDataWriter
extends AbstractProtocolDataWriter

Field Summary

Fields inherited from class org.jumpmind.symmetric.io.data.writer.AbstractProtocolDataWriter

backwardsCompatible, baseTime, batch, context, delimiter, flushBatchId, flushNodeId, lastTime, listeners, log, noBinaryOldData, processedTables, sendCaptureTime, sendRowCaptureTime, sourceNodeId, statistics, table

Constructor Summary

Constructors

Constructor	Description
ProtocolDataWriter(String sourceNodeId, Writer writer, boolean backwardsCompatible, boolean sendCaptureTime, boolean sendRowCaptureTime)
ProtocolDataWriter(String sourceNodeId, List<IProtocolDataWriterListener> listeners, Writer writer, boolean backwardsCompatible, boolean sendCaptureTime, boolean sendRowCaptureTime)

Method Summary

Modifier and Type	Method	Description
protected void	endBatch(Batch batch)
protected void	notifyEndBatch(Batch batch, IProtocolDataWriterListener listener)
protected void	print(Batch batch, String data)

Methods inherited from class org.jumpmind.symmetric.io.data.writer.AbstractProtocolDataWriter

close, end, end, getDelimiter, getStatistics, open, println, println, println, printTime, setDelimiter, start, start, write

Methods inherited from class java.lang.Object

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

Constructor Details

ProtocolDataWriter

public ProtocolDataWriter(String sourceNodeId,
 Writer writer,
 boolean backwardsCompatible,
 boolean sendCaptureTime,
 boolean sendRowCaptureTime)

ProtocolDataWriter

public ProtocolDataWriter(String sourceNodeId,
 List<IProtocolDataWriterListener> listeners,
 Writer writer,
 boolean backwardsCompatible,
 boolean sendCaptureTime,
 boolean sendRowCaptureTime)

Method Details

endBatch

protected void endBatch(Batch batch)

Overrides:

endBatch in class AbstractProtocolDataWriter

notifyEndBatch

protected void notifyEndBatch(Batch batch,
 IProtocolDataWriterListener listener)

Specified by:

notifyEndBatch in class AbstractProtocolDataWriter

print

protected void print(Batch batch,
 String data)

Specified by:

print in class AbstractProtocolDataWriter