org.apache.crunch.kafka.offset.hdfs

Class Offsets.PartitionOffset.Builder

java.lang.Object

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

Enclosing class:

Offsets.PartitionOffset

public static class Offsets.PartitionOffset.Builder
extends Object

Builder for Offsets.PartitionOffset

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and Description
Offsets.PartitionOffset	build() Builds a PartitionOffset instance.
static Offsets.PartitionOffset.Builder	newBuilder() Creates a new builder instance.
Offsets.PartitionOffset.Builder	setOffset(long offset) Set the offset for the partition offset being built.
Offsets.PartitionOffset.Builder	setPartition(int partition) Set the partition for the partition offset being built
Offsets.PartitionOffset.Builder	setTopic(String topic) Set the topic for the partition offset being built

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.PartitionOffset.Builder newBuilder()

Creates a new builder instance.

Returns:

a new builder instance.

setTopic

public Offsets.PartitionOffset.Builder setTopic(String topic)

Set the topic for the partition offset being built

Parameters:

topic - the topic for the partition offset being built.

Returns:

builder instance

Throws:

IllegalArgumentException - if the topic is null or empty.

setPartition

public Offsets.PartitionOffset.Builder setPartition(int partition)

Set the partition for the partition offset being built

Parameters:

partition - the partition for the partition offset being built.

Returns:

builder instance

Throws:

IllegalArgumentException - if the partition is less than 0.

setOffset

public Offsets.PartitionOffset.Builder setOffset(long offset)

Set the offset for the partition offset being built. If the offset is not set then it defaults to OffsetRequest.EarliestTime().

Parameters:

offset - the topic for the partition offset being built.

Returns:

builder instance

build

public Offsets.PartitionOffset build()

Builds a PartitionOffset instance.

Returns:

the built PartitionOffset instance.

Throws:

IllegalStateException - if the topic or partition are never set or configured to invalid values.