public interface IDataExtractorService
| 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) |
void extractConfigurationStandalone(Node node, java.io.OutputStream out)
void extractConfigurationStandalone(Node node, java.io.Writer out, java.lang.String... tablesToIgnore)
void extractConfigurationOnly(Node node, java.io.OutputStream out)
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<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,
long startBatchId,
long endBatchId)
boolean extractBatchRange(java.io.Writer writer,
java.lang.String nodeId,
java.util.Date startBatchTime,
java.util.Date endBatchTime,
java.lang.String... channelIds)
boolean extractOnlyOutgoingBatch(java.lang.String nodeId,
long batchId,
java.io.Writer writer)
RemoteNodeStatuses queueWork(boolean force)
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 removeBatchFromStaging(OutgoingBatch batch)
java.util.List<ExtractRequest> getPendingTablesForExtractByLoadId(long loadId)
java.util.List<ExtractRequest> getCompletedTablesForExtractByLoadId(long loadId)
void updateExtractRequestLoadTime(java.util.Date loadTime,
OutgoingBatch batch)
void updateExtractRequestTransferred(OutgoingBatch batch, long transferMillis)
int cancelExtractRequests(long loadId)
void releaseMissedExtractRequests()