gobblin.util.test

Class TestingSource.Extract

java.lang.Object

gobblin.util.test.TestingSource.Extract

All Implemented Interfaces:

Extractor<String,String>, Closeable, AutoCloseable

Enclosing class:

TestingSource

public static class TestingSource.Extract
extends Object
implements Extractor<String,String>

Constructor Summary

Constructors

Constructor and Description
Extract()

Method Summary

Modifier and Type	Method and Description
void	close()
long	getExpectedRecordCount()
long	getHighWatermark()
String	getSchema()
String	readRecord(String reuse)

Methods inherited from class java.lang.Object

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

Methods inherited from interface gobblin.source.extractor.Extractor

readRecordEnvelope, recordStream

Constructor Detail

Extract

public Extract()

Method Detail

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

getSchema

public String getSchema()
                 throws IOException

Specified by:

getSchema in interface Extractor<String,String>

Throws:

IOException

readRecord

public String readRecord(String reuse)
                  throws DataRecordException,
                         IOException

Specified by:

readRecord in interface Extractor<String,String>

Throws:

DataRecordException

IOException

getExpectedRecordCount

public long getExpectedRecordCount()

Specified by:

getExpectedRecordCount in interface Extractor<String,String>

getHighWatermark

public long getHighWatermark()

Specified by:

getHighWatermark in interface Extractor<String,String>