com.marklogic.hub.collector.impl

Class CollectorImpl

java.lang.Object

com.marklogic.hub.collector.impl.CollectorImpl

All Implemented Interfaces:

Collector

public class CollectorImpl
extends java.lang.Object
implements Collector

Constructor Summary

Constructors

Constructor and Description
CollectorImpl()
CollectorImpl(java.lang.String module, CodeFormat codeFormat)

Method Summary

Modifier and Type	Method and Description
com.marklogic.client.DatabaseClient	getClient()
CodeFormat	getCodeFormat()
HubConfig	getHubConfig()
java.lang.String	getModule()
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)
void	setClient(com.marklogic.client.DatabaseClient client)
void	setHubConfig(HubConfig config)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CollectorImpl

public CollectorImpl()

CollectorImpl

public CollectorImpl(java.lang.String module,
                     CodeFormat codeFormat)

Method Detail

setHubConfig

public void setHubConfig(HubConfig config)

Specified by:

setHubConfig in interface Collector

getHubConfig

public HubConfig getHubConfig()

Specified by:

getHubConfig in interface Collector

setClient

public void setClient(com.marklogic.client.DatabaseClient client)

Specified by:

setClient in interface Collector

getClient

public com.marklogic.client.DatabaseClient getClient()

Specified by:

getClient in interface Collector

getCodeFormat

public CodeFormat getCodeFormat()

Specified by:

getCodeFormat in interface Collector

getModule

public java.lang.String getModule()

Specified by:

getModule in interface Collector

run

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)

Specified by:

run in interface Collector