gobblin.util.test

Class StdoutWriter<D>

java.lang.Object

gobblin.util.test.StdoutWriter<D>

All Implemented Interfaces:

DataWriter<D>, Closeable, AutoCloseable

public class StdoutWriter<D>
extends Object
implements DataWriter<D>

A simple writer implementation that writes the output to Stdout

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	StdoutWriter.Builder<D>

Constructor Summary

Constructors

Constructor and Description
StdoutWriter()

Method Summary

Modifier and Type	Method and Description
long	bytesWritten()
void	cleanup()
void	close()
void	commit()
long	recordsWritten()
void	write(D record)

Methods inherited from class java.lang.Object

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

Methods inherited from interface gobblin.writer.DataWriter

getMessageHandler, writeEnvelope

Constructor Detail

StdoutWriter

public StdoutWriter()

Method Detail

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

write

public void write(D record)
           throws IOException

Specified by:

write in interface DataWriter<D>

Throws:

IOException

commit

public void commit()

Specified by:

commit in interface DataWriter<D>

cleanup

public void cleanup()

Specified by:

cleanup in interface DataWriter<D>

recordsWritten

public long recordsWritten()

Specified by:

recordsWritten in interface DataWriter<D>

bytesWritten

public long bytesWritten()
                  throws IOException

Specified by:

bytesWritten in interface DataWriter<D>

Throws:

IOException