gobblin.util.test

Class TestingSource

java.lang.Object

gobblin.util.test.TestingSource

All Implemented Interfaces:

Source<String,String>

public class TestingSource
extends Object
implements Source<String,String>

A trivial implementation of Source to be used to testing.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TestingSource.Extract

Field Summary

Fields

Modifier and Type	Field and Description
protected List<WorkUnit>	_workunits

Constructor Summary

Constructors

Constructor and Description
TestingSource()

Method Summary

Modifier and Type	Method and Description
Extractor<String,String>	getExtractor(WorkUnitState state)
List<WorkUnit>	getWorkunits(SourceState state)
void	shutdown(SourceState state)

Methods inherited from class java.lang.Object

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

Field Detail

_workunits

protected List<WorkUnit> _workunits

Constructor Detail

TestingSource

public TestingSource()

Method Detail

getWorkunits

public List<WorkUnit> getWorkunits(SourceState state)

Specified by:

getWorkunits in interface Source<String,String>

getExtractor

public Extractor<String,String> getExtractor(WorkUnitState state)
                                      throws IOException

Specified by:

getExtractor in interface Source<String,String>

Throws:

IOException

shutdown

public void shutdown(SourceState state)

Specified by:

shutdown in interface Source<String,String>