Package | Description |
---|---|
org.apache.crunch.kafka.offset.hdfs |
Modifier and Type | Method and Description |
---|---|
Offsets.PartitionOffset |
Offsets.PartitionOffset.Builder.build()
Builds a PartitionOffset instance.
|
Modifier and Type | Method and Description |
---|---|
List<Offsets.PartitionOffset> |
Offsets.getOffsets()
The collection of offset information for specific topics and partitions.
|
Modifier and Type | Method and Description |
---|---|
int |
Offsets.PartitionOffset.compareTo(Offsets.PartitionOffset other) |
Modifier and Type | Method and Description |
---|---|
Offsets.Builder |
Offsets.Builder.setOffsets(List<Offsets.PartitionOffset> offsets)
Sets the collection of offsets.
|
Copyright © 2017 The Apache Software Foundation. All rights reserved.