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