org.apache.crunch.kafka.offset.hdfs

Class Offsets.Builder

java.lang.Object

org.apache.crunch.kafka.offset.hdfs.Offsets.Builder

Enclosing class:

Offsets

public static class Offsets.Builder
extends Object

Builder for the Offsets.

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and Description
Offsets	build() Builds an instance.
static Offsets.Builder	newBuilder() Creates a new Builder instance.
Offsets.Builder	setAsOfTime(long asOfTime) Sets the as of time for the collection of offsets.
Offsets.Builder	setOffsets(List<Offsets.PartitionOffset> offsets) Sets the collection of offsets.

Methods inherited from class java.lang.Object

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

Constructor Detail

Builder

public Builder()

Method Detail

newBuilder

public static Offsets.Builder newBuilder()

Creates a new Builder instance.

Returns:

a new Builder instance.

setAsOfTime

public Offsets.Builder setAsOfTime(long asOfTime)

Sets the as of time for the collection of offsets.

Parameters:

asOfTime - the as of time for the offsets.

Returns:

builder instance

Throws:

IllegalArgumentException - if the asOfTime is less than 0.

setOffsets

public Offsets.Builder setOffsets(List<Offsets.PartitionOffset> offsets)

Sets the collection of offsets.

Parameters:

offsets - the collection of offsets

Returns:

builder instance

Throws:

IllegalArgumentException - if the offsets is null.

build

public Offsets build()

Builds an instance.

Returns:

a built instance

Throws:

IllegalStateException - if the asOfTime is not set or the specified offsets contains duplicate entries for a topic partition.