Package | Description |
---|---|
org.corfudb.runtime.object |
This package contains the object layer for Corfu.
|
org.corfudb.runtime.view | |
org.corfudb.runtime.view.stream |
Constructor and Description |
---|
StreamViewSMRAdapter(CorfuRuntime runtime,
IStreamView streamView)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
IStreamView |
StreamsView.get(UUID stream)
Get a view on a stream.
|
IStreamView |
StreamsView.get(UUID stream,
StreamOptions options)
Get a view on a stream.
|
abstract IStreamView |
Layout.ReplicationMode.getStreamView(CorfuRuntime r,
UUID streamId,
StreamOptions options) |
IStreamView |
StreamsView.getUnsafe(UUID stream)
Since streams can also be used by higher level abstractions, some consumers implement
synchronization at a higher level, so the stream implementation doesn't have to
be thread-safe.
|
IStreamView |
StreamsView.getUnsafe(UUID stream,
StreamOptions options) |
abstract IStreamView |
Layout.ReplicationMode.getUnsafeStreamView(CorfuRuntime r,
UUID streamId,
StreamOptions options) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractContextStreamView<T extends AbstractStreamContext>
An abstract context stream view maintains contexts, which are used to
implement copy-on-write entries.
|
class |
AbstractQueuedStreamView
The abstract queued stream view implements a stream backed by a read queue.
|
class |
AddressMapStreamView
A view of a stream implemented with address maps.
|
class |
BackpointerStreamView
A view of a stream implemented with backpointers.
|
class |
ThreadSafeStreamView
A thread-safe implementation of IStreamView.
|
Constructor and Description |
---|
StreamSpliterator(IStreamView view)
Construct a stream spliterator with the given view and no limit.
|
StreamSpliterator(IStreamView view,
long maxGlobal)
Construct a stream spliterator with the given view and limit
|
Copyright © 2019 CorfuDB. All rights reserved.