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)