public class FileSyncExtractorService extends DataExtractorService
DataExtractorService.ExtractModelog, parameterService, platform, sqlTemplate, sqlTemplateDirty, symmetricDialect, tablePrefix| Constructor and Description |
|---|
FileSyncExtractorService(ISymmetricEngine engine) |
| Modifier and Type | Method and Description |
|---|---|
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) |
protected boolean |
canProcessExtractRequest(ExtractRequest request,
NodeCommunication.CommunicationType communicationType) |
protected OutgoingBatch |
extractOutgoingBatch(ProcessInfo processInfo,
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) |
protected ProcessType |
getProcessType() |
protected org.jumpmind.symmetric.io.stage.IStagedResource |
getStagedResource(OutgoingBatch currentBatch) |
protected boolean |
isApplicable(NodeCommunication nodeCommunication) |
protected void |
queue(java.lang.String nodeId,
java.lang.String queue,
RemoteNodeStatuses statuses) |
protected org.jumpmind.symmetric.io.data.IDataWriter |
wrapWithTransformWriter(Node sourceNode,
Node targetNode,
ProcessInfo processInfo,
org.jumpmind.symmetric.io.data.IDataWriter dataWriter,
boolean useStagingDataWriter) |
acquireStagingFileLock, buildExtractDataReader, buildExtractDataReader, cancelExtractRequests, changeBatchStatus, checkSendDeferredConstraints, cleanupIgnoredBatch, createTransformDataWriter, execute, extract, extract, extract, extractBatch, extractBatchRange, extractBatchRange, extractConfigurationOnly, extractConfigurationStandalone, extractConfigurationStandalone, extractOnlyOutgoingBatch, extractToPayload, filter, findStatsIndex, getBatchStats, getBatchStatsColumns, getCompletedTablesForExtractByLoadId, getExtractChildRequestsForNode, getExtractChildRequestsForNode, getExtractRequestForBatch, getExtractRequestNodes, getExtractRequestsForNode, getExtractStats, getPendingTablesForExtractByLoadId, getSemaphoreKey, hasLobsThatNeedExtract, isPreviouslyExtracted, isRetry, isStagingFileLockRequired, loadPendingBatches, lookupAndOrderColumnsAccordingToTriggerHistory, queueWork, releaseLock, releaseMissedExtractRequests, removeBatchFromStaging, replaceVariables, requeryIfEnoughTimeHasPassed, requestExtractRequest, resetExtractRequest, restartExtractRequest, sendOutgoingBatch, transferFromStaging, triggerReExtraction, updateExtractRequestLoadTime, updateExtractRequestStatus, updateExtractRequestTransferred, writeBatchStats, writeKeepAliveAckassertNotNull, buildBatchWhere, close, createSqlReplacementTokens, createSqlReplacementTokens, getJdbcTemplate, getParameterService, getSql, getSymmetricDialect, getTablePrefix, getTargetDialect, getTargetPlatform, getTargetPlatform, isCalledFromSymmetricAdminTool, isSet, isStreamClosedByClient, isSymmetricTable, logOnce, maxDate, readAcks, sendAck, setSqlMap, synchronize, toNodeIds, toNodeIdspublic FileSyncExtractorService(ISymmetricEngine engine)
protected boolean isApplicable(NodeCommunication nodeCommunication)
isApplicable in class DataExtractorServiceprotected boolean canProcessExtractRequest(ExtractRequest request, NodeCommunication.CommunicationType communicationType)
canProcessExtractRequest in class DataExtractorServiceprotected org.jumpmind.symmetric.io.data.IDataWriter wrapWithTransformWriter(Node sourceNode, Node targetNode, ProcessInfo processInfo, org.jumpmind.symmetric.io.data.IDataWriter dataWriter, boolean useStagingDataWriter)
wrapWithTransformWriter in class DataExtractorServiceprotected org.jumpmind.symmetric.io.stage.IStagedResource getStagedResource(OutgoingBatch currentBatch)
getStagedResource in class DataExtractorServiceprotected OutgoingBatch extractOutgoingBatch(ProcessInfo processInfo, 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)
extractOutgoingBatch in class DataExtractorServiceprotected MultiBatchStagingWriter buildMultiBatchStagingWriter(ExtractRequest request, java.util.List<ExtractRequest> childRequests, Node sourceNode, Node targetNode, java.util.List<OutgoingBatch> batches, ProcessInfo processInfo, Channel channel, boolean isRestarted)
buildMultiBatchStagingWriter in class DataExtractorServiceprotected void queue(java.lang.String nodeId,
java.lang.String queue,
RemoteNodeStatuses statuses)
queue in class DataExtractorServiceprotected ProcessType getProcessType()
getProcessType in class DataExtractorService