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(com.marklogic.hub.HubClient hubClient, java.lang.String sourceDatabase)

Method Summary

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) Obtains and grabs a list of uris that match the collector code

Methods inherited from class java.lang.Object

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

Constructor Detail

CollectorImpl

public CollectorImpl(com.marklogic.hub.HubClient hubClient,
                     java.lang.String sourceDatabase)

Parameters:

hubClient -

sourceDatabase - Determines what database will be queried; the HTTP request will still go to the staging server

Method Detail

run

public DiskQueue<java.lang.String> run(java.lang.String flow,
                                       java.lang.String step,
                                       java.util.Map<java.lang.String,java.lang.Object> options)

Description copied from interface: Collector

Obtains and grabs a list of uris that match the collector code

Specified by:

run in interface Collector

Parameters:

flow - - name of which flow

step - - step of the flow

options - - options Map for running the step

Returns:

a list of uris as strings in a diskqueue object