Package org.jumpmind.symmetric.io.data
Class Batch
java.lang.Object
org.jumpmind.symmetric.io.data.Batch
-
Nested Class Summary
Nested Classes -
Field Summary
FieldsModifier and TypeFieldDescriptionprotected long
protected Batch.BatchType
protected BinaryEncoding
protected boolean
protected String
protected boolean
protected boolean
protected long
protected long
static final String
protected boolean
protected boolean
protected boolean
protected long
protected String
protected Date
protected Statistics
protected String
static final long
-
Constructor Summary
ConstructorsConstructorDescriptionBatch()
Batch
(Batch.BatchType batchType, long batchId, String channelId, BinaryEncoding binaryEncoding, String sourceNodeId, String targetNodeId, boolean common) -
Method Summary
Modifier and TypeMethodDescriptionbyte[]
decodeBinary
(String value) encodeBinary
(String value) long
long
long
long
long
static String
getStagedLocation
(boolean common, String nodeId, long batchId) void
incrementDataReadMillis
(long millis) void
incrementDataWriteMillis
(long millis) long
boolean
boolean
isCommon()
boolean
boolean
boolean
boolean
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)
-
Field Details
-
UNKNOWN_BATCH_ID
public static final long UNKNOWN_BATCH_ID- See Also:
-
DEFAULT_CHANNEL_ID
- See Also:
-
batchId
protected long batchId -
sourceNodeId
-
targetNodeId
-
initialLoad
protected boolean initialLoad -
channelId
-
binaryEncoding
-
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
-
statistics
-
invalidRetry
protected boolean invalidRetry -
bulkLoaderFlag
protected boolean bulkLoaderFlag -
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
-
endTimer
-
getDataReadMillis
public long getDataReadMillis() -
getDataWriteMillis
public long getDataWriteMillis() -
getLineCount
public long getLineCount() -
setLineCount
public void setLineCount(long lineCount) -
getStartTime
-
setStartTime
-
getSourceNodeId
-
getTargetNodeId
-
getNodeBatchId
-
getBatchId
public long getBatchId() -
getChannelId
-
isInitialLoad
public boolean isInitialLoad() -
getBinaryEncoding
-
setIgnored
public void setIgnored(boolean ignored) -
isIgnored
public boolean isIgnored() -
setCommon
public void setCommon(boolean commonFlag) -
isCommon
public boolean isCommon() -
getBatchType
-
getStagedLocation
-
getStagedLocation
-
setComplete
public void setComplete(boolean complete) -
isComplete
public boolean isComplete() -
setBinaryEncoding
-
setSourceNodeId
-
setStatistics
-
getStatistics
-
setInvalidRetry
public void setInvalidRetry(boolean invalidRetry) -
isInvalidRetry
public boolean isInvalidRetry() -
encodeBinary
-
decodeBinary
-