org.jumpmind.symmetric.service.impl

Class DataExtractorService

java.lang.Object

org.jumpmind.symmetric.service.impl.AbstractService

org.jumpmind.symmetric.service.impl.DataExtractorService

All Implemented Interfaces:

IDataExtractorService, INodeCommunicationService.INodeCommunicationExecutor, IService

Direct Known Subclasses:

FileSyncExtractorService

public class DataExtractorService
extends AbstractService
implements IDataExtractorService, INodeCommunicationService.INodeCommunicationExecutor

See Also:

IDataExtractorService

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	DataExtractorService.ExtractMode

Field Summary

Fields inherited from class org.jumpmind.symmetric.service.impl.AbstractService

log, parameterService, platform, sqlTemplate, sqlTemplateDirty, symmetricDialect, tablePrefix

Constructor Summary

Constructors

Constructor and Description
DataExtractorService(ISymmetricEngine engine)

Method Summary

Modifier and Type	Method and Description
protected org.jumpmind.symmetric.io.stage.StagingFileLock	acquireStagingFileLock(OutgoingBatch batch)
protected org.jumpmind.symmetric.io.data.reader.ExtractDataReader	buildExtractDataReader(Node sourceNode, Node targetNode, OutgoingBatch currentBatch, ProcessInfo processInfo)
protected org.jumpmind.symmetric.io.data.reader.ExtractDataReader	buildExtractDataReader(Node sourceNode, Node targetNode, OutgoingBatch currentBatch, ProcessInfo processInfo, boolean containsBigLob)
protected MultiBatchStagingWriter	buildMultiBatchStagingWriter(ExtractRequest request, java.util.List<ExtractRequest> childRequests, Node sourceNode, Node targetNode, java.util.List<OutgoingBatch> batches, ProcessInfo processInfo, Channel channel, boolean isRestarted)
int	cancelExtractRequests(long loadId)
protected boolean	canProcessExtractRequest(ExtractRequest request, NodeCommunication.CommunicationType communicationType)
protected boolean	changeBatchStatus(AbstractBatch.Status status, OutgoingBatch currentBatch, DataExtractorService.ExtractMode mode)
protected void	checkSendDeferredConstraints(ExtractRequest request, java.util.List<ExtractRequest> childRequests, Node targetNode)
protected void	cleanupIgnoredBatch(Node sourceNode, Node targetNode, OutgoingBatch currentBatch, org.jumpmind.symmetric.io.data.IDataWriter writer)
protected org.jumpmind.symmetric.io.data.writer.TransformWriter	createTransformDataWriter(Node identity, Node targetNode, org.jumpmind.symmetric.io.data.IDataWriter extractWriter)
void	execute(NodeCommunication nodeCommunication, RemoteNodeStatus status) This is a callback method used by the NodeCommunicationService that extracts an initial load in the background.
java.util.List<OutgoingBatch>	extract(ProcessInfo extractInfo, Node targetNode, IOutgoingTransport transport)
protected java.util.List<OutgoingBatch>	extract(ProcessInfo extractInfo, Node targetNode, java.util.List<OutgoingBatch> activeBatches, org.jumpmind.symmetric.io.data.IDataWriter dataWriter, java.io.BufferedWriter writer, DataExtractorService.ExtractMode mode)
java.util.List<OutgoingBatch>	extract(ProcessInfo extractInfo, Node targetNode, java.lang.String queue, IOutgoingTransport transport)
protected org.jumpmind.symmetric.service.impl.DataExtractorService.FutureOutgoingBatch	extractBatch(OutgoingBatch extractBatch, org.jumpmind.symmetric.service.impl.DataExtractorService.FutureExtractStatus status, ProcessInfo extractInfo, Node targetNode, org.jumpmind.symmetric.io.data.IDataWriter dataWriter, DataExtractorService.ExtractMode mode, java.util.List<OutgoingBatch> activeBatches)
boolean	extractBatchRange(java.io.Writer writer, java.lang.String nodeId, java.util.Date startBatchTime, java.util.Date endBatchTime, java.lang.String... channelIds)
boolean	extractBatchRange(java.io.Writer writer, java.lang.String nodeId, long startBatchId, long endBatchId)
void	extractConfigurationOnly(Node node, java.io.OutputStream out)
void	extractConfigurationStandalone(Node node, java.io.OutputStream out)
void	extractConfigurationStandalone(Node targetNode, java.io.Writer writer, java.lang.String... tablesToExclude) Extract the SymmetricDS configuration for the passed in Node.
boolean	extractOnlyOutgoingBatch(java.lang.String nodeId, long batchId, java.io.Writer writer) This method will extract an outgoing batch, but will not update the outgoing batch status
protected OutgoingBatch	extractOutgoingBatch(ProcessInfo extractInfo, Node targetNode, org.jumpmind.symmetric.io.data.IDataWriter dataWriter, OutgoingBatch currentBatch, boolean useStagingDataWriter, boolean updateBatchStatistics, DataExtractorService.ExtractMode mode, org.jumpmind.symmetric.io.data.IDataProcessorListener listener)
java.util.List<OutgoingBatchWithPayload>	extractToPayload(ProcessInfo processInfo, Node targetNode, org.jumpmind.symmetric.io.data.writer.StructureDataWriter.PayloadType payloadType, boolean useJdbcTimestampFormat, boolean useUpsertStatements, boolean useDelimiterIdentifiers)
protected boolean	filter(Node targetNode, java.lang.String tableName)
protected int	findStatsIndex(java.lang.String bufferString, java.lang.String prevBuffer)
protected java.lang.String	getBatchStats(OutgoingBatch batch)
protected java.lang.String	getBatchStatsColumns()
java.util.List<ExtractRequest>	getCompletedTablesForExtractByLoadId(long loadId)
protected java.util.List<ExtractRequest>	getExtractChildRequestsForNode(ExtractRequest parentRequest)
protected java.util.Map<java.lang.Long,java.util.List<ExtractRequest>>	getExtractChildRequestsForNode(NodeCommunication nodeCommunication, java.util.List<ExtractRequest> parentRequests)
protected ExtractRequest	getExtractRequestForBatch(OutgoingBatch batch)
java.util.List<org.jumpmind.symmetric.service.impl.DataExtractorService.NodeQueuePair>	getExtractRequestNodes()
protected java.util.List<ExtractRequest>	getExtractRequestsForNode(NodeCommunication nodeCommunication)
protected org.jumpmind.util.Statistics	getExtractStats(org.jumpmind.symmetric.io.data.IDataWriter writer, OutgoingBatch currentBatch)
java.util.List<ExtractRequest>	getPendingTablesForExtractByLoadId(long loadId)
protected ProcessType	getProcessType()
protected java.lang.String	getSemaphoreKey(OutgoingBatch batch, boolean useStagingDataWriter)
protected org.jumpmind.symmetric.io.stage.IStagedResource	getStagedResource(OutgoingBatch currentBatch)
protected boolean	hasLobsThatNeedExtract(org.jumpmind.db.model.Table table, org.jumpmind.symmetric.io.data.CsvData data)
protected boolean	isApplicable(NodeCommunication nodeCommunication)
protected boolean	isPreviouslyExtracted(OutgoingBatch currentBatch, boolean acquireReference)
protected boolean	isRetry(OutgoingBatch currentBatch, Node remoteNode)
protected boolean	isStagingFileLockRequired(OutgoingBatch batch)
protected OutgoingBatches	loadPendingBatches(ProcessInfo extractInfo, Node targetNode, java.lang.String queue, IOutgoingTransport transport)
protected org.jumpmind.db.model.Table	lookupAndOrderColumnsAccordingToTriggerHistory(java.lang.String routerId, TriggerHistory triggerHistory, Node sourceNode, Node targetNode, boolean setTargetTableName, boolean useDatabaseDefinition)
protected void	queue(java.lang.String nodeId, java.lang.String queue, RemoteNodeStatuses statuses)
RemoteNodeStatuses	queueWork(boolean force)
protected void	releaseLock(org.jumpmind.symmetric.service.impl.DataExtractorService.BatchLock lock, OutgoingBatch batch, boolean useStagingDataWriter)
void	releaseMissedExtractRequests()
void	removeBatchFromStaging(OutgoingBatch batch)
protected java.lang.String	replaceVariables(Node sourceNode, Node targetNode, java.lang.String str)
protected OutgoingBatch	requeryIfEnoughTimeHasPassed(long ts, OutgoingBatch currentBatch) If time has passed, then re-query the batch to double check that the status has not changed
ExtractRequest	requestExtractRequest(org.jumpmind.db.sql.ISqlTransaction transaction, java.lang.String nodeId, java.lang.String queue, TriggerRouter triggerRouter, long startBatchId, long endBatchId, long loadId, java.lang.String table, long rows, long parentRequestId)
void	resetExtractRequest(OutgoingBatch batch)
protected void	restartExtractRequest(java.util.List<OutgoingBatch> batches, ExtractRequest request, java.util.List<ExtractRequest> childRequests)
protected OutgoingBatch	sendOutgoingBatch(ProcessInfo processInfo, Node targetNode, OutgoingBatch currentBatch, boolean isRetry, org.jumpmind.symmetric.io.data.IDataWriter dataWriter, java.io.BufferedWriter writer, DataExtractorService.ExtractMode mode)
protected void	transferFromStaging(DataExtractorService.ExtractMode mode, org.jumpmind.symmetric.io.data.Batch.BatchType batchType, OutgoingBatch batch, boolean isRetry, org.jumpmind.symmetric.io.stage.IStagedResource stagedResource, java.io.BufferedWriter writer, org.jumpmind.symmetric.io.data.DataContext context, java.math.BigDecimal maxKBytesPerSec)
protected void	triggerReExtraction(OutgoingBatch currentBatch)
void	updateExtractRequestLoadTime(java.util.Date loadTime, OutgoingBatch outgoingBatch)
protected void	updateExtractRequestStatus(org.jumpmind.db.sql.ISqlTransaction transaction, long extractId, ExtractRequest.ExtractStatus status, long extractedRows, long extractedMillis)
void	updateExtractRequestTransferred(OutgoingBatch batch, long transferMillis)
protected org.jumpmind.symmetric.io.data.IDataWriter	wrapWithTransformWriter(Node sourceNode, Node targetNode, ProcessInfo processInfo, org.jumpmind.symmetric.io.data.IDataWriter dataWriter, boolean useStagingDataWriter)
protected boolean	writeBatchStats(java.io.BufferedWriter writer, char[] buffer, int bufferSize, java.lang.String prevBuffer, OutgoingBatch batch)
protected void	writeKeepAliveAck(java.io.BufferedWriter writer, Node sourceNode, boolean streamToFileEnabled)

Methods inherited from class org.jumpmind.symmetric.service.impl.AbstractService

assertNotNull, buildBatchWhere, close, createSqlReplacementTokens, createSqlReplacementTokens, getJdbcTemplate, getParameterService, getSql, getSymmetricDialect, getTablePrefix, getTargetDialect, getTargetPlatform, getTargetPlatform, isCalledFromSymmetricAdminTool, isSet, isStreamClosedByClient, isSymmetricTable, logOnce, maxDate, readAcks, sendAck, setSqlMap, synchronize, toNodeIds, toNodeIds

Methods inherited from class java.lang.Object

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

Constructor Detail

DataExtractorService

public DataExtractorService(ISymmetricEngine engine)

Method Detail

extractConfigurationStandalone

public void extractConfigurationStandalone(Node node,
                                           java.io.OutputStream out)

Specified by:

extractConfigurationStandalone in interface IDataExtractorService

See Also:

DataExtractorService#extractConfigurationStandalone(Node, Writer)

extractConfigurationOnly

public void extractConfigurationOnly(Node node,
                                     java.io.OutputStream out)

Specified by:

extractConfigurationOnly in interface IDataExtractorService

filter

protected boolean filter(Node targetNode,
                         java.lang.String tableName)

extractConfigurationStandalone

public void extractConfigurationStandalone(Node targetNode,
                                           java.io.Writer writer,
                                           java.lang.String... tablesToExclude)

Extract the SymmetricDS configuration for the passed in Node.

Specified by:

extractConfigurationStandalone in interface IDataExtractorService

extractToPayload

public java.util.List<OutgoingBatchWithPayload> extractToPayload(ProcessInfo processInfo,
                                                                 Node targetNode,
                                                                 org.jumpmind.symmetric.io.data.writer.StructureDataWriter.PayloadType payloadType,
                                                                 boolean useJdbcTimestampFormat,
                                                                 boolean useUpsertStatements,
                                                                 boolean useDelimiterIdentifiers)

Specified by:

extractToPayload in interface IDataExtractorService

extract

public java.util.List<OutgoingBatch> extract(ProcessInfo extractInfo,
                                             Node targetNode,
                                             IOutgoingTransport transport)

Specified by:

extract in interface IDataExtractorService

Returns:

a list of batches that were extracted

extract

public java.util.List<OutgoingBatch> extract(ProcessInfo extractInfo,
                                             Node targetNode,
                                             java.lang.String queue,
                                             IOutgoingTransport transport)

Specified by:

extract in interface IDataExtractorService

loadPendingBatches

protected OutgoingBatches loadPendingBatches(ProcessInfo extractInfo,
                                             Node targetNode,
                                             java.lang.String queue,
                                             IOutgoingTransport transport)

extractOnlyOutgoingBatch

public boolean extractOnlyOutgoingBatch(java.lang.String nodeId,
                                        long batchId,
                                        java.io.Writer writer)

This method will extract an outgoing batch, but will not update the outgoing batch status

Specified by:

extractOnlyOutgoingBatch in interface IDataExtractorService

extract

protected java.util.List<OutgoingBatch> extract(ProcessInfo extractInfo,
                                                Node targetNode,
                                                java.util.List<OutgoingBatch> activeBatches,
                                                org.jumpmind.symmetric.io.data.IDataWriter dataWriter,
                                                java.io.BufferedWriter writer,
                                                DataExtractorService.ExtractMode mode)

extractBatch

protected org.jumpmind.symmetric.service.impl.DataExtractorService.FutureOutgoingBatch extractBatch(OutgoingBatch extractBatch,
                                                                                                    org.jumpmind.symmetric.service.impl.DataExtractorService.FutureExtractStatus status,
                                                                                                    ProcessInfo extractInfo,
                                                                                                    Node targetNode,
                                                                                                    org.jumpmind.symmetric.io.data.IDataWriter dataWriter,
                                                                                                    DataExtractorService.ExtractMode mode,
                                                                                                    java.util.List<OutgoingBatch> activeBatches)
                                                                                             throws java.lang.Exception

Throws:

java.lang.Exception

writeKeepAliveAck

protected void writeKeepAliveAck(java.io.BufferedWriter writer,
                                 Node sourceNode,
                                 boolean streamToFileEnabled)

changeBatchStatus

protected final boolean changeBatchStatus(AbstractBatch.Status status,
                                          OutgoingBatch currentBatch,
                                          DataExtractorService.ExtractMode mode)

requeryIfEnoughTimeHasPassed

protected final OutgoingBatch requeryIfEnoughTimeHasPassed(long ts,
                                                           OutgoingBatch currentBatch)

If time has passed, then re-query the batch to double check that the status has not changed

extractOutgoingBatch

protected OutgoingBatch extractOutgoingBatch(ProcessInfo extractInfo,
                                             Node targetNode,
                                             org.jumpmind.symmetric.io.data.IDataWriter dataWriter,
                                             OutgoingBatch currentBatch,
                                             boolean useStagingDataWriter,
                                             boolean updateBatchStatistics,
                                             DataExtractorService.ExtractMode mode,
                                             org.jumpmind.symmetric.io.data.IDataProcessorListener listener)

getSemaphoreKey

protected java.lang.String getSemaphoreKey(OutgoingBatch batch,
                                           boolean useStagingDataWriter)

acquireStagingFileLock

protected org.jumpmind.symmetric.io.stage.StagingFileLock acquireStagingFileLock(OutgoingBatch batch)

releaseLock

protected void releaseLock(org.jumpmind.symmetric.service.impl.DataExtractorService.BatchLock lock,
                           OutgoingBatch batch,
                           boolean useStagingDataWriter)

isStagingFileLockRequired

protected boolean isStagingFileLockRequired(OutgoingBatch batch)

triggerReExtraction

protected void triggerReExtraction(OutgoingBatch currentBatch)

buildExtractDataReader

protected org.jumpmind.symmetric.io.data.reader.ExtractDataReader buildExtractDataReader(Node sourceNode,
                                                                                         Node targetNode,
                                                                                         OutgoingBatch currentBatch,
                                                                                         ProcessInfo processInfo)

buildExtractDataReader

protected org.jumpmind.symmetric.io.data.reader.ExtractDataReader buildExtractDataReader(Node sourceNode,
                                                                                         Node targetNode,
                                                                                         OutgoingBatch currentBatch,
                                                                                         ProcessInfo processInfo,
                                                                                         boolean containsBigLob)

getExtractStats

protected org.jumpmind.util.Statistics getExtractStats(org.jumpmind.symmetric.io.data.IDataWriter writer,
                                                       OutgoingBatch currentBatch)

wrapWithTransformWriter

protected org.jumpmind.symmetric.io.data.IDataWriter wrapWithTransformWriter(Node sourceNode,
                                                                             Node targetNode,
                                                                             ProcessInfo processInfo,
                                                                             org.jumpmind.symmetric.io.data.IDataWriter dataWriter,
                                                                             boolean useStagingDataWriter)

cleanupIgnoredBatch

protected void cleanupIgnoredBatch(Node sourceNode,
                                   Node targetNode,
                                   OutgoingBatch currentBatch,
                                   org.jumpmind.symmetric.io.data.IDataWriter writer)

getStagedResource

protected org.jumpmind.symmetric.io.stage.IStagedResource getStagedResource(OutgoingBatch currentBatch)

isPreviouslyExtracted

protected boolean isPreviouslyExtracted(OutgoingBatch currentBatch,
                                        boolean acquireReference)

isRetry

protected boolean isRetry(OutgoingBatch currentBatch,
                          Node remoteNode)

sendOutgoingBatch

protected OutgoingBatch sendOutgoingBatch(ProcessInfo processInfo,
                                          Node targetNode,
                                          OutgoingBatch currentBatch,
                                          boolean isRetry,
                                          org.jumpmind.symmetric.io.data.IDataWriter dataWriter,
                                          java.io.BufferedWriter writer,
                                          DataExtractorService.ExtractMode mode)

transferFromStaging

protected void transferFromStaging(DataExtractorService.ExtractMode mode,
                                   org.jumpmind.symmetric.io.data.Batch.BatchType batchType,
                                   OutgoingBatch batch,
                                   boolean isRetry,
                                   org.jumpmind.symmetric.io.stage.IStagedResource stagedResource,
                                   java.io.BufferedWriter writer,
                                   org.jumpmind.symmetric.io.data.DataContext context,
                                   java.math.BigDecimal maxKBytesPerSec)

findStatsIndex

protected int findStatsIndex(java.lang.String bufferString,
                             java.lang.String prevBuffer)

getPendingTablesForExtractByLoadId

public java.util.List<ExtractRequest> getPendingTablesForExtractByLoadId(long loadId)

Specified by:

getPendingTablesForExtractByLoadId in interface IDataExtractorService

getCompletedTablesForExtractByLoadId

public java.util.List<ExtractRequest> getCompletedTablesForExtractByLoadId(long loadId)

Specified by:

getCompletedTablesForExtractByLoadId in interface IDataExtractorService

updateExtractRequestLoadTime

public void updateExtractRequestLoadTime(java.util.Date loadTime,
                                         OutgoingBatch outgoingBatch)

Specified by:

updateExtractRequestLoadTime in interface IDataExtractorService

updateExtractRequestTransferred

public void updateExtractRequestTransferred(OutgoingBatch batch,
                                            long transferMillis)

Specified by:

updateExtractRequestTransferred in interface IDataExtractorService

cancelExtractRequests

public int cancelExtractRequests(long loadId)

Specified by:

cancelExtractRequests in interface IDataExtractorService

writeBatchStats

protected boolean writeBatchStats(java.io.BufferedWriter writer,
                                  char[] buffer,
                                  int bufferSize,
                                  java.lang.String prevBuffer,
                                  OutgoingBatch batch)
                           throws java.io.IOException

Throws:

java.io.IOException

getBatchStatsColumns

protected java.lang.String getBatchStatsColumns()

getBatchStats

protected java.lang.String getBatchStats(OutgoingBatch batch)

extractBatchRange

public boolean extractBatchRange(java.io.Writer writer,
                                 java.lang.String nodeId,
                                 long startBatchId,
                                 long endBatchId)

Specified by:

extractBatchRange in interface IDataExtractorService

extractBatchRange

public boolean extractBatchRange(java.io.Writer writer,
                                 java.lang.String nodeId,
                                 java.util.Date startBatchTime,
                                 java.util.Date endBatchTime,
                                 java.lang.String... channelIds)

Specified by:

extractBatchRange in interface IDataExtractorService

createTransformDataWriter

protected org.jumpmind.symmetric.io.data.writer.TransformWriter createTransformDataWriter(Node identity,
                                                                                          Node targetNode,
                                                                                          org.jumpmind.symmetric.io.data.IDataWriter extractWriter)

lookupAndOrderColumnsAccordingToTriggerHistory

protected org.jumpmind.db.model.Table lookupAndOrderColumnsAccordingToTriggerHistory(java.lang.String routerId,
                                                                                     TriggerHistory triggerHistory,
                                                                                     Node sourceNode,
                                                                                     Node targetNode,
                                                                                     boolean setTargetTableName,
                                                                                     boolean useDatabaseDefinition)

replaceVariables

protected java.lang.String replaceVariables(Node sourceNode,
                                            Node targetNode,
                                            java.lang.String str)

queueWork

public RemoteNodeStatuses queueWork(boolean force)

Specified by:

queueWork in interface IDataExtractorService

queue

protected void queue(java.lang.String nodeId,
                     java.lang.String queue,
                     RemoteNodeStatuses statuses)

getExtractRequestNodes

public java.util.List<org.jumpmind.symmetric.service.impl.DataExtractorService.NodeQueuePair> getExtractRequestNodes()

getExtractRequestsForNode

protected java.util.List<ExtractRequest> getExtractRequestsForNode(NodeCommunication nodeCommunication)

getExtractRequestForBatch

protected ExtractRequest getExtractRequestForBatch(OutgoingBatch batch)

getExtractChildRequestsForNode

protected java.util.Map<java.lang.Long,java.util.List<ExtractRequest>> getExtractChildRequestsForNode(NodeCommunication nodeCommunication,
                                                                                                      java.util.List<ExtractRequest> parentRequests)

getExtractChildRequestsForNode

protected java.util.List<ExtractRequest> getExtractChildRequestsForNode(ExtractRequest parentRequest)

resetExtractRequest

public void resetExtractRequest(OutgoingBatch batch)

Specified by:

resetExtractRequest in interface IDataExtractorService

requestExtractRequest

public ExtractRequest requestExtractRequest(org.jumpmind.db.sql.ISqlTransaction transaction,
                                            java.lang.String nodeId,
                                            java.lang.String queue,
                                            TriggerRouter triggerRouter,
                                            long startBatchId,
                                            long endBatchId,
                                            long loadId,
                                            java.lang.String table,
                                            long rows,
                                            long parentRequestId)

Specified by:

requestExtractRequest in interface IDataExtractorService

updateExtractRequestStatus

protected void updateExtractRequestStatus(org.jumpmind.db.sql.ISqlTransaction transaction,
                                          long extractId,
                                          ExtractRequest.ExtractStatus status,
                                          long extractedRows,
                                          long extractedMillis)

canProcessExtractRequest

protected boolean canProcessExtractRequest(ExtractRequest request,
                                           NodeCommunication.CommunicationType communicationType)

execute

public void execute(NodeCommunication nodeCommunication,
                    RemoteNodeStatus status)

This is a callback method used by the NodeCommunicationService that extracts an initial load in the background.

Specified by:

execute in interface INodeCommunicationService.INodeCommunicationExecutor

restartExtractRequest

protected void restartExtractRequest(java.util.List<OutgoingBatch> batches,
                                     ExtractRequest request,
                                     java.util.List<ExtractRequest> childRequests)

releaseMissedExtractRequests

public void releaseMissedExtractRequests()

Specified by:

releaseMissedExtractRequests in interface IDataExtractorService

checkSendDeferredConstraints

protected void checkSendDeferredConstraints(ExtractRequest request,
                                            java.util.List<ExtractRequest> childRequests,
                                            Node targetNode)

isApplicable

protected boolean isApplicable(NodeCommunication nodeCommunication)

buildMultiBatchStagingWriter

protected MultiBatchStagingWriter buildMultiBatchStagingWriter(ExtractRequest request,
                                                               java.util.List<ExtractRequest> childRequests,
                                                               Node sourceNode,
                                                               Node targetNode,
                                                               java.util.List<OutgoingBatch> batches,
                                                               ProcessInfo processInfo,
                                                               Channel channel,
                                                               boolean isRestarted)

getProcessType

protected ProcessType getProcessType()

hasLobsThatNeedExtract

protected boolean hasLobsThatNeedExtract(org.jumpmind.db.model.Table table,
                                         org.jumpmind.symmetric.io.data.CsvData data)

removeBatchFromStaging

public void removeBatchFromStaging(OutgoingBatch batch)

Specified by:

removeBatchFromStaging in interface IDataExtractorService