org.jumpmind.symmetric.service

Interface IDataExtractorService

All Known Implementing Classes:

DataExtractorService, FileSyncExtractorService

public interface IDataExtractorService

This service provides an API to extract and stream data from a source database.

Method Summary

Modifier and Type	Method and Description
int	cancelExtractRequests(long loadId)
java.util.List<OutgoingBatch>	extract(ProcessInfo processInfo, Node node, IOutgoingTransport transport)
java.util.List<OutgoingBatch>	extract(ProcessInfo processInfo, Node node, java.lang.String channelId, IOutgoingTransport transport)
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 node, java.io.Writer out, java.lang.String... tablesToIgnore)
boolean	extractOnlyOutgoingBatch(java.lang.String nodeId, long batchId, java.io.Writer writer)
java.util.List<OutgoingBatchWithPayload>	extractToPayload(ProcessInfo processInfo, Node targetNode, org.jumpmind.symmetric.io.data.writer.StructureDataWriter.PayloadType payloadType, boolean useJdbcTimestampFormat, boolean useUpsertStatements, boolean useDelimiterIdentifiers)
java.util.List<ExtractRequest>	getCompletedTablesForExtractByLoadId(long loadId)
java.util.List<ExtractRequest>	getPendingTablesForExtractByLoadId(long loadId)
RemoteNodeStatuses	queueWork(boolean force)
void	releaseMissedExtractRequests()
void	removeBatchFromStaging(OutgoingBatch batch)
ExtractRequest	requestExtractRequest(org.jumpmind.db.sql.ISqlTransaction transaction, java.lang.String nodeId, java.lang.String channelId, TriggerRouter triggerRouter, long startBatchId, long endBatchId, long loadId, java.lang.String tableName, long rows, long parentId)
void	resetExtractRequest(OutgoingBatch batch)
void	updateExtractRequestLoadTime(java.util.Date loadTime, OutgoingBatch batch)
void	updateExtractRequestTransferred(OutgoingBatch batch, long transferMillis)

Method Detail

extractConfigurationStandalone

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

extractConfigurationStandalone

void extractConfigurationStandalone(Node node,
                                    java.io.Writer out,
                                    java.lang.String... tablesToIgnore)

extractConfigurationOnly

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

extractToPayload

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

extract

java.util.List<OutgoingBatch> extract(ProcessInfo processInfo,
                                      Node node,
                                      IOutgoingTransport transport)

Returns:

a list of batches that were extracted

extract

java.util.List<OutgoingBatch> extract(ProcessInfo processInfo,
                                      Node node,
                                      java.lang.String channelId,
                                      IOutgoingTransport transport)

extractBatchRange

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

extractBatchRange

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

extractOnlyOutgoingBatch

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

queueWork

RemoteNodeStatuses queueWork(boolean force)

requestExtractRequest

ExtractRequest requestExtractRequest(org.jumpmind.db.sql.ISqlTransaction transaction,
                                     java.lang.String nodeId,
                                     java.lang.String channelId,
                                     TriggerRouter triggerRouter,
                                     long startBatchId,
                                     long endBatchId,
                                     long loadId,
                                     java.lang.String tableName,
                                     long rows,
                                     long parentId)

resetExtractRequest

void resetExtractRequest(OutgoingBatch batch)

removeBatchFromStaging

void removeBatchFromStaging(OutgoingBatch batch)

getPendingTablesForExtractByLoadId

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

getCompletedTablesForExtractByLoadId

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

updateExtractRequestLoadTime

void updateExtractRequestLoadTime(java.util.Date loadTime,
                                  OutgoingBatch batch)

updateExtractRequestTransferred

void updateExtractRequestTransferred(OutgoingBatch batch,
                                     long transferMillis)

cancelExtractRequests

int cancelExtractRequests(long loadId)

releaseMissedExtractRequests

void releaseMissedExtractRequests()