public class FastObjectLoader extends Object
Modifier and Type | Class and Description |
---|---|
class |
FastObjectLoader.BoundedQueue<E>
This queue implementation is to be used by single threaded exeuctors
to restrict the amount of pending job submissions.
|
Constructor and Description |
---|
FastObjectLoader(CorfuRuntime corfuRuntime) |
Modifier and Type | Method and Description |
---|---|
void |
addCustomTypeStream(UUID streamId,
ObjectBuilder ob) |
void |
addIndexerToCorfuTableStream(String streamName,
CorfuTable.IndexRegistry indexRegistry)
Add an indexer to a stream (that backs a CorfuTable)
|
FastObjectLoader |
addStreamsToLoad(List<String> streamsToLoad)
Enable whiteList mode where we only reconstruct
the streams provided through this api.
|
void |
addStreamToIgnore(String streamName) |
void |
loadMaps()
Entry point to load the SMRMaps in memory.
|
public FastObjectLoader(@Nonnull CorfuRuntime corfuRuntime)
public FastObjectLoader addStreamsToLoad(List<String> streamsToLoad)
streamsToLoad
- public void addCustomTypeStream(UUID streamId, ObjectBuilder ob)
public void addIndexerToCorfuTableStream(String streamName, CorfuTable.IndexRegistry indexRegistry)
streamName
- Stream name.indexRegistry
- Index Registry.public void addStreamToIgnore(String streamName)
public void loadMaps()
Copyright © 2019 CorfuDB. All rights reserved.