| Package | Description |
|---|---|
| co.cask.cdap.messaging.store |
| Modifier and Type | Method and Description |
|---|---|
RawMessageTableEntry |
RawMessageTableEntry.set(byte[] key,
byte[] txPtr,
byte[] payload) |
| Modifier and Type | Method and Description |
|---|---|
protected abstract co.cask.cdap.api.dataset.lib.CloseableIterator<RawMessageTableEntry> |
AbstractMessageTable.read(byte[] startRow,
byte[] stopRow)
Read the
RawMessageTableEntrys given a key range. |
| Modifier and Type | Method and Description |
|---|---|
protected abstract void |
AbstractMessageTable.persist(Iterator<RawMessageTableEntry> entries)
Store the
RawMessageTableEntrys persistently. |
Copyright © 2017 Cask Data, Inc. Licensed under the Apache License, Version 2.0.