com.continuent.tungsten.replicator.extractor
Interface ParallelExtractor

All Superinterfaces:

Extractor, ReplicatorPlugin

All Known Implementing Classes:

ParallelQueueExtractor, THLParallelQueueExtractor

public interface ParallelExtractor
extends Extractor

Denotes an extractor that extends normal Extractor capabilities to allow parallel operation.

Version:

1.0

Author:

Robert Hodges

Method Summary

java.lang.String	getStoreName() Returns the store name on which this extractor operates.
void	setTaskId(int id) Sets the ID of the task using this extractor.

Methods inherited from interface com.continuent.tungsten.replicator.extractor.Extractor

extract, getCurrentResourceEventId, hasMoreEvents, setLastEvent, setLastEventId

Methods inherited from interface com.continuent.tungsten.replicator.plugin.ReplicatorPlugin

configure, prepare, release

Method Detail

setTaskId

void setTaskId(int id)

Sets the ID of the task using this extractor. This method is called prior to invoking the configure() method.

Parameters:

id - Task ID

See Also:

ReplicatorPlugin.configure(com.continuent.tungsten.replicator.plugin.PluginContext)

getStoreName

java.lang.String getStoreName()

Returns the store name on which this extractor operates. This is used to implement orderly shutdown and synchronize waits.