Package | Description |
---|---|
org.corfudb.runtime.view.stream |
Modifier and Type | Method and Description |
---|---|
protected AbstractQueuedStreamView.BackpointerOp |
AbstractQueuedStreamView.resolveCheckpoint(org.corfudb.runtime.view.stream.AbstractQueuedStreamView.QueuedStreamContext context,
ILogData data,
long maxGlobal) |
static AbstractQueuedStreamView.BackpointerOp |
AbstractQueuedStreamView.BackpointerOp.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static AbstractQueuedStreamView.BackpointerOp[] |
AbstractQueuedStreamView.BackpointerOp.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
protected boolean |
BackpointerStreamView.discoverAddressSpace(UUID streamId,
NavigableSet<Long> queue,
long startAddress,
long stopAddress,
Function<ILogData,AbstractQueuedStreamView.BackpointerOp> filter,
boolean checkpoint,
long maxGlobal) |
protected abstract boolean |
AbstractQueuedStreamView.discoverAddressSpace(UUID streamId,
NavigableSet<Long> queue,
long startAddress,
long stopAddress,
Function<ILogData,AbstractQueuedStreamView.BackpointerOp> filter,
boolean checkpoint,
long maxGlobal)
Defines the strategy to discover addresses belonging to this stream.
|
protected boolean |
AddressMapStreamView.discoverAddressSpace(UUID streamId,
NavigableSet<Long> queue,
long startAddress,
long stopAddress,
Function<ILogData,AbstractQueuedStreamView.BackpointerOp> filter,
boolean checkpoint,
long maxGlobal)
Retrieve this stream's address map, i.e., a map of all addresses corresponding to this stream between
(stop address, start address] and return a boolean indicating if addresses were found in this range.
|
Copyright © 2019 CorfuDB. All rights reserved.