com.bigdata.service.master

Class FileSystemScanner

java.lang.Object

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

com.bigdata.service.master.FileSystemScanner

All Implemented Interfaces:

Callable<Long>

public class FileSystemScanner
extends AbstractResourceScanner<File>

Adds all files accepted by the filter to the Queue.

Version:

$Id$

Author:

Bryan Thompson

Field Summary

Fields

Modifier and Type	Field and Description
protected File	fileOrDir
protected FilenameFilter	filter

Fields inherited from class com.bigdata.service.master.AbstractResourceScanner

log

Constructor Summary

Constructors

Constructor and Description
FileSystemScanner(BlockingBuffer<File[]> buffer, File fileOrDir, FilenameFilter filter)

Method Summary

Methods

Modifier and Type	Method and Description
static IResourceScannerFactory<File>	newFactory(File fileOrDir, FilenameFilter filter) Factory for factory.
protected void	runScanner() Run the scanner.
String	toString()

Methods inherited from class com.bigdata.service.master.AbstractResourceScanner

accept, call, getAcceptCount

Methods inherited from class java.lang.Object

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

Field Detail

fileOrDir

protected final File fileOrDir

filter

protected final FilenameFilter filter

Constructor Detail

FileSystemScanner

public FileSystemScanner(BlockingBuffer<File[]> buffer,
                 File fileOrDir,
                 FilenameFilter filter)

Parameters:

buffer - Chunks of files to be loaded are added to this buffer.

fileOrDir - The file or directory to be loaded.

filter - An optional filter on files that will be accepted when processing a directory.

Method Detail

toString

public String toString()

Overrides:

toString in class Object

runScanner

protected void runScanner()
                   throws Exception

Description copied from class: AbstractResourceScanner

Run the scanner.

Specified by:

runScanner in class AbstractResourceScanner<File>

Throws:

Exception

newFactory

public static IResourceScannerFactory<File> newFactory(File fileOrDir,
                                       FilenameFilter filter)

Factory for factory.