| Package | Description |
|---|---|
| co.cask.cdap.data2.transaction.queue.hbase.coprocessor |
| Modifier and Type | Method and Description |
|---|---|
byte[] |
QueueConsumerConfig.getStartRow(ConsumerInstance consumerInstance) |
| Constructor and Description |
|---|
QueueConsumerConfig(Map<ConsumerInstance,byte[]> startRows,
int numGroups) |
Copyright © 2016 Cask Data, Inc. Licensed under the Apache License, Version 2.0.