gobblin.util.test

Class HelloWorldSource.ExtractorImpl

java.lang.Object

gobblin.util.test.HelloWorldSource.ExtractorImpl

All Implemented Interfaces:

Extractor<String,String>, Closeable, AutoCloseable

Enclosing class:

HelloWorldSource

public static class HelloWorldSource.ExtractorImpl
extends Object
implements Extractor<String,String>

Constructor Summary

Constructors

Constructor and Description
ExtractorImpl(int helloId)

Method Summary

Modifier and Type	Method and Description
void	close()
long	getExpectedRecordCount()
long	getHighWatermark()
String	getSchema()
static String	helloMessage(int helloId)
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

ExtractorImpl

public ExtractorImpl(int helloId)

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)

Specified by:

readRecord in interface Extractor<String,String>

helloMessage

public static String helloMessage(int helloId)

getExpectedRecordCount

public long getExpectedRecordCount()

Specified by:

getExpectedRecordCount in interface Extractor<String,String>

getHighWatermark

public long getHighWatermark()

Specified by:

getHighWatermark in interface Extractor<String,String>