Constructor and Description |
---|
CollectorImpl() |
CollectorImpl(java.lang.String module,
CodeFormat codeFormat) |
Modifier and Type | Method and Description |
---|---|
com.marklogic.client.DatabaseClient |
getClient()
Gets the client in use currently by the collector object
|
CodeFormat |
getCodeFormat()
Obtains the code format for the collector in use
|
HubConfig |
getHubConfig()
Returns the current hubConfig ont he collector object
|
java.lang.String |
getModule()
Returns the module for the collect
|
DiskQueue<java.lang.String> |
run(java.lang.String jobId,
java.lang.String entity,
java.lang.String flow,
int threadCount,
java.util.Map<java.lang.String,java.lang.Object> options)
Obtains and grabs a list of uris that match the collector code
|
void |
setClient(com.marklogic.client.DatabaseClient client)
Sets the client to be used to communicate with the database
|
void |
setHubConfig(HubConfig config)
Set's the hub config for the collector
|
public CollectorImpl()
public CollectorImpl(java.lang.String module, CodeFormat codeFormat)
public void setHubConfig(HubConfig config)
Collector
setHubConfig
in interface Collector
config
- takes in a HubConfig objectpublic HubConfig getHubConfig()
Collector
getHubConfig
in interface Collector
public void setClient(com.marklogic.client.DatabaseClient client)
Collector
public com.marklogic.client.DatabaseClient getClient()
Collector
public CodeFormat getCodeFormat()
Collector
getCodeFormat
in interface Collector
public java.lang.String getModule()
Collector
public DiskQueue<java.lang.String> run(java.lang.String jobId, java.lang.String entity, java.lang.String flow, int threadCount, java.util.Map<java.lang.String,java.lang.Object> options)
Collector
run
in interface Collector
jobId
- - id of the job this is to haveentity
- - name of which entity is this being run againstflow
- - name of which flowthreadCount
- - how many threads to use for the operationoptions
- - string/object map of options you want to pass to the collector