com.bigdata.service.master

Class AbstractResourceScanner<V>

java.lang.Object

com.bigdata.service.master.AbstractResourceScanner<V>

All Implemented Interfaces:

Callable<Long>

Direct Known Subclasses:

FileSystemScanner

public abstract class AbstractResourceScanner<V>
extends Object
implements Callable<Long>

Abstract base class for the scanner for a mapped master job. The Callable should return the #of resources which were accepted for processing.

Version:

$Id$

Author:

Bryan Thompson

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.apache.log4j.Logger	log

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractResourceScanner(BlockingBuffer<V[]> buffer)

Method Summary

Methods

Modifier and Type	Method and Description
void	accept(V resource) Accept a resource for processing.
Long	call() Invokes runScanner(), queuing and transferring chunks of resources to the BlockingBuffer specified to the ctor.
long	getAcceptCount() Return the #of accepted resources.
protected abstract void	runScanner() Run the scanner.

Methods inherited from class java.lang.Object

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

Field Detail

log

protected static final org.apache.log4j.Logger log

Constructor Detail

AbstractResourceScanner

protected AbstractResourceScanner(BlockingBuffer<V[]> buffer)

Parameters:

buffer - The buffer to which the resources should be added.

Method Detail

getAcceptCount

public final long getAcceptCount()

Return the #of accepted resources.

call

public final Long call()
                throws Exception

Invokes runScanner(), queuing and transferring chunks of resources to the BlockingBuffer specified to the ctor. When runScanner() completes normally, the remaining resources are transferred from the internal queue to the BlockingBuffer.

Specified by:

call in interface Callable<Long>

Returns:

The #of resources accepted by the scanner.

Throws:

Exception

runScanner

protected abstract void runScanner()
                            throws Exception

Run the scanner.

Throws:

Exception

accept

public void accept(V resource)
            throws InterruptedException

Accept a resource for processing.

Parameters:

resource - The resource.

Throws:

InterruptedException