Package | Description |
---|---|
org.apache.crunch.kafka.offset.hdfs |
Modifier and Type | Method and Description |
---|---|
static Offsets.Builder |
Offsets.Builder.newBuilder()
Creates a new Builder instance.
|
Offsets.Builder |
Offsets.Builder.setAsOfTime(long asOfTime)
Sets the as of time for the collection of offsets.
|
Offsets.Builder |
Offsets.Builder.setOffsets(List<Offsets.PartitionOffset> offsets)
Sets the collection of offsets.
|
Copyright © 2017 The Apache Software Foundation. All rights reserved.