public class SourceQueryCollector
extends java.lang.Object
| Constructor and Description |
|---|
SourceQueryCollector(com.marklogic.hub.HubClient hubClient,
java.lang.String sourceDatabase) |
| Modifier and Type | Method and Description |
|---|---|
DiskQueue<java.lang.String> |
run(java.lang.String flow,
java.lang.String step,
java.util.Map<java.lang.String,java.lang.Object> options) |
public SourceQueryCollector(com.marklogic.hub.HubClient hubClient,
java.lang.String sourceDatabase)
hubClient - sourceDatabase - Determines what database will be queried; the HTTP request will still go to the staging
serverpublic DiskQueue<java.lang.String> run(java.lang.String flow, java.lang.String step, java.util.Map<java.lang.String,java.lang.Object> options)