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

Class AbstractProtocolDataWriter

java.lang.Object

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

All Implemented Interfaces:

IDataResource, IDataWriter

Direct Known Subclasses:

ProtocolDataWriter, StagingDataWriter

public abstract class AbstractProtocolDataWriter
extends Object
implements IDataWriter

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	backwardsCompatible
protected long	baseTime
protected Batch	batch
protected DataContext	context
protected String	delimiter
protected boolean	flushBatchId
protected boolean	flushNodeId
protected long	lastTime
protected List<IProtocolDataWriterListener>	listeners
protected final org.slf4j.Logger	log
protected boolean	noBinaryOldData
protected Map<String,String>	processedTables
protected boolean	sendCaptureTime
protected boolean	sendRowCaptureTime
protected String	sourceNodeId
protected Map<Batch,Statistics>	statistics
protected Table	table

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	close()
void	end(Table table)
final void	end(Batch batch, boolean inError)
protected void	endBatch(Batch batch)
String	getDelimiter()
Map<Batch,Statistics>	getStatistics()
protected abstract void	notifyEndBatch(Batch batch, IProtocolDataWriterListener listener)
void	open(DataContext context)
protected abstract void	print(Batch batch, String data)
protected long	println(String... data)
protected int	println(String key, List<Column> columns)
protected int	println(String key, Column[] columns)
protected void	printTime(CsvData data)
void	setDelimiter(String delimiter)
boolean	start(Table table)
void	start(Batch batch)
void	write(CsvData data)

Methods inherited from class java.lang.Object

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

Field Details

log

protected final org.slf4j.Logger log

context

protected DataContext context

batch

protected Batch batch

table

protected Table table

processedTables

protected Map<String,String> processedTables

delimiter

protected String delimiter

flushNodeId

protected boolean flushNodeId

flushBatchId

protected boolean flushBatchId

statistics

protected Map<Batch,Statistics> statistics

listeners

protected List<IProtocolDataWriterListener> listeners

sourceNodeId

protected String sourceNodeId

noBinaryOldData

protected boolean noBinaryOldData

backwardsCompatible

protected boolean backwardsCompatible

sendCaptureTime

protected boolean sendCaptureTime

sendRowCaptureTime

protected boolean sendRowCaptureTime

baseTime

protected long baseTime

lastTime

protected long lastTime

Constructor Details

AbstractProtocolDataWriter

public AbstractProtocolDataWriter(String sourceNodeId,
 List<IProtocolDataWriterListener> listeners,
 boolean backwardsCompatible,
 boolean sendCaptureTime,
 boolean sendRowCaptureTime)

Method Details

open

public void open(DataContext context)

Specified by:

open in interface IDataResource

close

public void close()

Specified by:

close in interface IDataResource

start

public void start(Batch batch)

Specified by:

start in interface IDataWriter

start

public boolean start(Table table)

Specified by:

start in interface IDataWriter

write

public void write(CsvData data)

Specified by:

write in interface IDataWriter

printTime

protected void printTime(CsvData data)

end

public void end(Table table)

Specified by:

end in interface IDataWriter

end

public final void end(Batch batch,
 boolean inError)

Specified by:

end in interface IDataWriter

endBatch

protected void endBatch(Batch batch)

notifyEndBatch

protected abstract void notifyEndBatch(Batch batch,
 IProtocolDataWriterListener listener)

println

protected int println(String key,
 List<Column> columns)

println

protected int println(String key,
 Column[] columns)

print

protected abstract void print(Batch batch,
 String data)

println

protected long println(String... data)

setDelimiter

public void setDelimiter(String delimiter)

getDelimiter

public String getDelimiter()

getStatistics

public Map<Batch,Statistics> getStatistics()

Specified by:

getStatistics in interface IDataResource