gobblin.util.test

Class FastSequentialSource.FastSequentialExtractor

java.lang.Object

gobblin.util.test.FastSequentialSource.FastSequentialExtractor

All Implemented Interfaces:

Extractor<String,Long>, Closeable, AutoCloseable

Enclosing class:

FastSequentialSource

public static class FastSequentialSource.FastSequentialExtractor
extends Object
implements Extractor<String,Long>

Constructor Summary

Constructors

Constructor and Description
FastSequentialExtractor()

Method Summary

Modifier and Type	Method and Description
void	close()
long	getExpectedRecordCount()
long	getHighWatermark()
String	getSchema()
Long	readRecord(Long 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

FastSequentialExtractor

public FastSequentialExtractor()

Method Detail

getSchema

public String getSchema()
                 throws IOException

Specified by:

getSchema in interface Extractor<String,Long>

Throws:

IOException

readRecord

public Long readRecord(@Deprecated
                       Long reuse)
                throws DataRecordException,
                       IOException

Specified by:

readRecord in interface Extractor<String,Long>

Throws:

DataRecordException

IOException

getExpectedRecordCount

public long getExpectedRecordCount()

Specified by:

getExpectedRecordCount in interface Extractor<String,Long>

getHighWatermark

public long getHighWatermark()

Specified by:

getHighWatermark in interface Extractor<String,Long>

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException