org.apache.crunch.kafka.offset

Class AbstractOffsetWriter

java.lang.Object

org.apache.crunch.kafka.offset.AbstractOffsetWriter

All Implemented Interfaces:

Closeable, AutoCloseable, OffsetWriter

Direct Known Subclasses:

HDFSOffsetWriter

public abstract class AbstractOffsetWriter
extends Object
implements OffsetWriter

Base implementation of OffsetWriter

Constructor Summary

Constructors

Constructor and Description
AbstractOffsetWriter()

Method Summary

Modifier and Type	Method and Description
void	write(Map<org.apache.kafka.common.TopicPartition,Long> offsets) Persists the offsets to a configured location with the current time specified as the as of time.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.crunch.kafka.offset.OffsetWriter

write

Methods inherited from interface java.io.Closeable

close

Constructor Detail

AbstractOffsetWriter

public AbstractOffsetWriter()

Method Detail

write

public void write(Map<org.apache.kafka.common.TopicPartition,Long> offsets)
           throws IOException

Description copied from interface: OffsetWriter

Persists the offsets to a configured location with the current time specified as the as of time.

Specified by:

write in interface OffsetWriter

Parameters:

offsets - the offsets to persist

Throws:

IOException - if there is an error persisting the offsets.