Package | Description |
---|---|
org.apache.crunch.kafka.offset.hdfs |
Modifier and Type | Method and Description |
---|---|
static Offsets.PartitionOffset.Builder |
Offsets.PartitionOffset.Builder.newBuilder()
Creates a new builder instance.
|
Offsets.PartitionOffset.Builder |
Offsets.PartitionOffset.Builder.setOffset(long offset)
Set the
offset for the partition offset being built. |
Offsets.PartitionOffset.Builder |
Offsets.PartitionOffset.Builder.setPartition(int partition)
Set the
partition for the partition offset being built |
Offsets.PartitionOffset.Builder |
Offsets.PartitionOffset.Builder.setTopic(String topic)
Set the
topic for the partition offset being built |
Copyright © 2017 The Apache Software Foundation. All rights reserved.