Package org.jumpmind.symmetric.io.data

Class Batch

java.lang.Object

org.jumpmind.symmetric.io.data.Batch

public class Batch
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	Batch.BatchType

Field Summary

Fields

Modifier and Type	Field	Description
protected long	batchId
protected Batch.BatchType	batchType
protected BinaryEncoding	binaryEncoding
protected boolean	bulkLoaderFlag
protected String	channelId
protected boolean	common
protected boolean	complete
protected long	dataReadMillis
protected long	dataWriteMillis
static final String	DEFAULT_CHANNEL_ID
protected boolean	ignored
protected boolean	initialLoad
protected boolean	invalidRetry
protected long	lineCount
protected String	sourceNodeId
protected Date	startTime
protected Statistics	statistics
protected String	targetNodeId
protected Map<String,Long>	timers
static final long	UNKNOWN_BATCH_ID

Constructor Summary

Constructors

Constructor	Description
Batch()
Batch(Batch.BatchType batchType, long batchId, String channelId, BinaryEncoding binaryEncoding, String sourceNodeId, String targetNodeId, boolean common)

Method Summary

Modifier and Type	Method	Description
byte[]	decodeBinary(String value)
String	encodeBinary(String value)
long	endTimer(String name)
long	getBatchId()
Batch.BatchType	getBatchType()
BinaryEncoding	getBinaryEncoding()
String	getChannelId()
long	getDataReadMillis()
long	getDataWriteMillis()
long	getLineCount()
String	getNodeBatchId()
String	getSourceNodeId()
String	getStagedLocation()
static String	getStagedLocation(boolean common, String nodeId, long batchId)
Date	getStartTime()
Statistics	getStatistics()
String	getTargetNodeId()
void	incrementDataReadMillis(long millis)
void	incrementDataWriteMillis(long millis)
long	incrementLineCount()
boolean	isBulkLoaderFlag()
boolean	isCommon()
boolean	isComplete()
boolean	isIgnored()
boolean	isInitialLoad()
boolean	isInvalidRetry()
void	setBatchId(long batchId)
void	setBinaryEncoding(BinaryEncoding binaryEncoding)
void	setBulkLoaderFlag(boolean bulkLoaderFlag)
void	setCommon(boolean commonFlag)
void	setComplete(boolean complete)
void	setIgnored(boolean ignored)
void	setInvalidRetry(boolean invalidRetry)
void	setLineCount(long lineCount)
void	setSourceNodeId(String sourceNodeId)
void	setStartTime(Date startTime)
void	setStatistics(Statistics statistics)
void	startTimer(String name)

Methods inherited from class java.lang.Object

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

Field Details

UNKNOWN_BATCH_ID

public static final long UNKNOWN_BATCH_ID

See Also:

• Constant Field Values

DEFAULT_CHANNEL_ID

public static final String DEFAULT_CHANNEL_ID

See Also:

• Constant Field Values

batchId

protected long batchId

sourceNodeId

protected String sourceNodeId

targetNodeId

protected String targetNodeId

initialLoad

protected boolean initialLoad

channelId

protected String channelId

binaryEncoding

protected BinaryEncoding binaryEncoding

startTime

protected Date startTime

lineCount

protected long lineCount

dataReadMillis

protected long dataReadMillis

dataWriteMillis

protected long dataWriteMillis

ignored

protected boolean ignored

common

protected boolean common

complete

protected boolean complete

batchType

protected Batch.BatchType batchType

statistics

protected Statistics statistics

invalidRetry

protected boolean invalidRetry

bulkLoaderFlag

protected boolean bulkLoaderFlag

timers

protected Map<String,Long> timers

Constructor Details

Batch

public Batch(Batch.BatchType batchType,
 long batchId,
 String channelId,
 BinaryEncoding binaryEncoding,
 String sourceNodeId,
 String targetNodeId,
 boolean common)

Batch

public Batch()

Method Details

isBulkLoaderFlag

public boolean isBulkLoaderFlag()

setBulkLoaderFlag

public void setBulkLoaderFlag(boolean bulkLoaderFlag)

setBatchId

public void setBatchId(long batchId)

incrementLineCount

public long incrementLineCount()

incrementDataReadMillis

public void incrementDataReadMillis(long millis)

incrementDataWriteMillis

public void incrementDataWriteMillis(long millis)

startTimer

public void startTimer(String name)

endTimer

public long endTimer(String name)

getDataReadMillis

public long getDataReadMillis()

getDataWriteMillis

public long getDataWriteMillis()

getLineCount

public long getLineCount()

setLineCount

public void setLineCount(long lineCount)

getStartTime

public Date getStartTime()

setStartTime

public void setStartTime(Date startTime)

getSourceNodeId

public String getSourceNodeId()

getTargetNodeId

public String getTargetNodeId()

getNodeBatchId

public String getNodeBatchId()

getBatchId

public long getBatchId()

getChannelId

public String getChannelId()

isInitialLoad

public boolean isInitialLoad()

getBinaryEncoding

public BinaryEncoding getBinaryEncoding()

setIgnored

public void setIgnored(boolean ignored)

isIgnored

public boolean isIgnored()

setCommon

public void setCommon(boolean commonFlag)

isCommon

public boolean isCommon()

getBatchType

public Batch.BatchType getBatchType()

getStagedLocation

public String getStagedLocation()

getStagedLocation

public static String getStagedLocation(boolean common,
 String nodeId,
 long batchId)

setComplete

public void setComplete(boolean complete)

isComplete

public boolean isComplete()

setBinaryEncoding

public void setBinaryEncoding(BinaryEncoding binaryEncoding)

setSourceNodeId

public void setSourceNodeId(String sourceNodeId)

setStatistics

public void setStatistics(Statistics statistics)

getStatistics

public Statistics getStatistics()

setInvalidRetry

public void setInvalidRetry(boolean invalidRetry)

isInvalidRetry

public boolean isInvalidRetry()

encodeBinary

public String encodeBinary(String value)

decodeBinary

public byte[] decodeBinary(String value)