Package org.jumpmind.symmetric.service.impl

Class FileSyncExtractorService

java.lang.Object

org.jumpmind.symmetric.service.impl.AbstractService

org.jumpmind.symmetric.service.impl.DataExtractorService

org.jumpmind.symmetric.service.impl.FileSyncExtractorService

All Implemented Interfaces:

IDataExtractorService, INodeCommunicationService.INodeCommunicationExecutor, IService

public class FileSyncExtractorService
extends DataExtractorService

Nested Class Summary

Nested classes/interfaces inherited from class org.jumpmind.symmetric.service.impl.DataExtractorService

DataExtractorService.ExtractMode

Field Summary

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

engine

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

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

Constructor Summary

Constructors

Constructor	Description
FileSyncExtractorService(ISymmetricEngine engine)

Method Summary

Modifier and Type	Method	Description
protected MultiBatchStagingWriter	buildMultiBatchStagingWriter(ExtractRequest request, List<ExtractRequest> childRequests, Node sourceNode, Node targetNode, List<OutgoingBatch> batches, ProcessInfo processInfo, Channel channel, boolean isRestarted)
protected boolean	canProcessExtractRequest(ExtractRequest request, NodeCommunication.CommunicationType communicationType)
protected OutgoingBatch	extractOutgoingBatch(ProcessInfo processInfo, Node targetNode, IDataWriter dataWriter, OutgoingBatch currentBatch, boolean useStagingDataWriter, boolean updateBatchStatistics, DataExtractorService.ExtractMode mode, IDataProcessorListener listener)
protected ProcessType	getProcessType()
protected IStagedResource	getStagedResource(OutgoingBatch currentBatch)
protected boolean	isApplicable(NodeCommunication nodeCommunication)
protected void	queue(String nodeId, String queue, RemoteNodeStatuses statuses)
protected void	updateExtractRequestsForThreading()
protected IDataWriter	wrapWithTransformWriter(Node sourceNode, Node targetNode, ProcessInfo processInfo, IDataWriter dataWriter, boolean useStagingDataWriter)

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

acquireStagingFileLock, buildExtractDataReader, buildExtractDataReader, cancelExtractRequests, changeBatchStatus, checkSendDeferredConstraints, cleanupIgnoredBatch, createTransformDataWriter, execute, extract, extract, extract, extractBatch, extractBatchRange, extractBatchRange, extractConfigurationStandalone, extractOnlyOutgoingBatch, extractToPayload, findStatsIndex, getBatchStats, getBatchStatsColumns, getCompletedTablesForExtractByLoadId, getCompletedTablesForExtractByLoadIdAndNodeId, getExtractChildRequestsForNode, getExtractChildRequestsForNode, getExtractRequestForBatch, getExtractRequestNodes, getExtractRequestsForNode, getExtractRequestsForThreading, getExtractStats, getPendingTablesForExtractByLoadId, getPendingTablesForExtractByLoadIdAndNodeId, getSemaphoreKey, isPreviouslyExtracted, isRetry, isStagingFileLockRequired, loadPendingBatches, queueWork, releaseLock, releaseMissedExtractRequests, removeBatchFromStaging, requeryIfEnoughTimeHasPassed, requestExtractRequest, resetExtractRequest, restartExtractRequest, sendOutgoingBatch, transferFromStaging, triggerReExtraction, updateExtractRequestLoadTime, updateExtractRequestsForThreading, updateExtractRequestStatus, updateExtractRequestStatuses, updateExtractRequestTransferred, writeBatchStats, writeKeepAliveAck

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

assertNotNull, buildBatchOrderBy, buildBatchParams, buildBatchWhere, buildBatchWhereFromFilter, close, 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 Details

FileSyncExtractorService

public FileSyncExtractorService(ISymmetricEngine engine)

Method Details

isApplicable

protected boolean isApplicable(NodeCommunication nodeCommunication)

Overrides:

isApplicable in class DataExtractorService

updateExtractRequestsForThreading

protected void updateExtractRequestsForThreading()

Overrides:

updateExtractRequestsForThreading in class DataExtractorService

canProcessExtractRequest

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

Overrides:

canProcessExtractRequest in class DataExtractorService

wrapWithTransformWriter

protected IDataWriter wrapWithTransformWriter(Node sourceNode,
 Node targetNode,
 ProcessInfo processInfo,
 IDataWriter dataWriter,
 boolean useStagingDataWriter)

Overrides:

wrapWithTransformWriter in class DataExtractorService

getStagedResource

protected IStagedResource getStagedResource(OutgoingBatch currentBatch)

Overrides:

getStagedResource in class DataExtractorService

extractOutgoingBatch

protected OutgoingBatch extractOutgoingBatch(ProcessInfo processInfo,
 Node targetNode,
 IDataWriter dataWriter,
 OutgoingBatch currentBatch,
 boolean useStagingDataWriter,
 boolean updateBatchStatistics,
 DataExtractorService.ExtractMode mode,
 IDataProcessorListener listener)

Overrides:

extractOutgoingBatch in class DataExtractorService

buildMultiBatchStagingWriter

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

Overrides:

buildMultiBatchStagingWriter in class DataExtractorService

queue

protected void queue(String nodeId,
 String queue,
 RemoteNodeStatuses statuses)

Overrides:

queue in class DataExtractorService

getProcessType

protected ProcessType getProcessType()

Overrides:

getProcessType in class DataExtractorService