Package org.jumpmind.symmetric.io.data.reader

Class ProtocolDataReader

java.lang.Object

org.jumpmind.symmetric.io.data.reader.AbstractDataReader

org.jumpmind.symmetric.io.data.reader.ProtocolDataReader

All Implemented Interfaces:

IDataReader, IDataResource

public class ProtocolDataReader
extends AbstractDataReader
implements IDataReader

Field Summary

Fields

Modifier and Type	Field	Description
protected long	baseTime
protected Batch	batch
protected Batch.BatchType	batchType
protected BinaryEncoding	binaryEncoding
protected String	channelId
protected DataContext	context
protected Timestamp	createTime
protected CsvReader	csvReader
static final String	CTX_LINE_NUMBER
protected int	lineNumber
protected Object	next
protected boolean	noBinaryOldData
protected Reader	reader
protected String	sourceNodeId
protected IStagedResource	stagedResource
protected Map<Batch,Statistics>	statistics
protected boolean	streamToFile
protected String	tableName
protected String	targetNodeId
protected String[]	tokens

Fields inherited from class org.jumpmind.symmetric.io.data.reader.AbstractDataReader

log

Constructor Summary

Constructors

Constructor	Description
ProtocolDataReader(Batch.BatchType batchType, String targetNodeId, File file)
ProtocolDataReader(Batch.BatchType batchType, String targetNodeId, InputStream is)
ProtocolDataReader(Batch.BatchType batchType, String targetNodeId, Reader reader)
ProtocolDataReader(Batch.BatchType batchType, String targetNodeId, Reader reader, boolean streamToFile)
ProtocolDataReader(Batch.BatchType batchType, String targetNodeId, String input)
ProtocolDataReader(Batch.BatchType batchType, String targetNodeId, StringBuilder input)
ProtocolDataReader(Batch.BatchType batchType, String targetNodeId, IStagedResource stagedResource)

Method Summary

Modifier and Type	Method	Description
void	close()
IStagedResource	getStagedResource()
Map<Batch,Statistics>	getStatistics()
Batch	nextBatch()
CsvData	nextData()
Table	nextTable()
void	open(DataContext context)
protected void	putStats(Statistics stats, String[] statsColumns, String[] statsValues)
Object	readNext()

Methods inherited from class org.jumpmind.symmetric.io.data.reader.AbstractDataReader

logDebugAndCountBytes, toBatch, toReader, toReader

Methods inherited from class java.lang.Object

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

Field Details

CTX_LINE_NUMBER

public static final String CTX_LINE_NUMBER

stagedResource

protected IStagedResource stagedResource

reader

protected Reader reader

statistics

protected Map<Batch,Statistics> statistics

csvReader

protected CsvReader csvReader

context

protected DataContext context

next

protected Object next

batch

protected Batch batch

channelId

protected String channelId

tableName

protected String tableName

sourceNodeId

protected String sourceNodeId

targetNodeId

protected String targetNodeId

binaryEncoding

protected BinaryEncoding binaryEncoding

noBinaryOldData

protected boolean noBinaryOldData

batchType

protected Batch.BatchType batchType

lineNumber

protected int lineNumber

tokens

protected String[] tokens

streamToFile

protected boolean streamToFile

baseTime

protected long baseTime

createTime

protected Timestamp createTime

Constructor Details

ProtocolDataReader

public ProtocolDataReader(Batch.BatchType batchType,
 String targetNodeId,
 StringBuilder input)

ProtocolDataReader

public ProtocolDataReader(Batch.BatchType batchType,
 String targetNodeId,
 InputStream is)

ProtocolDataReader

public ProtocolDataReader(Batch.BatchType batchType,
 String targetNodeId,
 IStagedResource stagedResource)

ProtocolDataReader

public ProtocolDataReader(Batch.BatchType batchType,
 String targetNodeId,
 String input)

ProtocolDataReader

public ProtocolDataReader(Batch.BatchType batchType,
 String targetNodeId,
 Reader reader)

ProtocolDataReader

public ProtocolDataReader(Batch.BatchType batchType,
 String targetNodeId,
 Reader reader,
 boolean streamToFile)

ProtocolDataReader

public ProtocolDataReader(Batch.BatchType batchType,
 String targetNodeId,
 File file)

Method Details

getStagedResource

public IStagedResource getStagedResource()

open

public void open(DataContext context)

Specified by:

open in interface IDataResource

readNext

public Object readNext()

nextBatch

public Batch nextBatch()

Specified by:

nextBatch in interface IDataReader

nextTable

public Table nextTable()

Specified by:

nextTable in interface IDataReader

nextData

public CsvData nextData()

Specified by:

nextData in interface IDataReader

close

public void close()

Specified by:

close in interface IDataResource

getStatistics

public Map<Batch,Statistics> getStatistics()

Specified by:

getStatistics in interface IDataResource

putStats

protected void putStats(Statistics stats,
 String[] statsColumns,
 String[] statsValues)