Package | Description |
---|---|
com.persistit |
Implements Persistit™'s core functionality.
|
com.persistit.exception |
Exceptions thrown and handled by Persistit™
|
com.persistit.mxbeans |
Modifier and Type | Method and Description |
---|---|
void |
Transaction.begin()
Start a transaction.
|
void |
Persistit.checkAllVolumes()
Convenience method that performs an integrity check on all open
Volume s and reports detailed results to
System.out . |
CheckpointManager.Checkpoint |
Persistit.checkpoint()
Force a new Checkpoint and wait for it to be written.
|
boolean |
IntegrityCheck.checkTree(Tree tree)
Performs the integrity checking process on a
Tree . |
boolean |
IntegrityCheck.checkVolume(Volume volume)
Performs the integrity checking process on a
Volume . |
void |
Volume.close()
Release all resources for this
Volume and invalidate all its
buffers in the BufferPool . |
void |
Persistit.close()
Close the Persistit Journal and all
Volume s. |
void |
Persistit.close(boolean flush)
Close the Persistit Journal and all
Volume s. |
void |
Volume.close(long timeout)
Release all resources for this
Volume and invalidate all its
buffers in the BufferPool . |
void |
Transaction.commit()
Commit this transaction.
|
void |
Transaction.commit(boolean toDisk)
Deprecated.
|
void |
Transaction.commit(Transaction.CommitPolicy policy)
Commit this transaction.
|
KeyHistogram |
Exchange.computeHistogram(Key start,
Key end,
int sampleSize,
int keyDepth,
KeyFilter keyFilter,
int requestedTreeDepth) |
Volume |
Persistit.createTemporaryVolume()
Create a temporary volume.
|
Volume |
Persistit.createTemporaryVolume(int pageSize)
Create a temporary volume.
|
boolean |
Volume.delete()
Delete the file backing this
Volume . |
void |
TimelyResource.delete() |
boolean |
Persistit.deleteVolume(String volumeName)
Delete a volume currently loaded volume and remove it from the list
returned by
Persistit.getVolumes() . |
Exchange |
Exchange.fetch()
Fetches the value associated with the current
Key into the
Exchange 's Value . |
Exchange |
Exchange.fetch(int minimumBytes)
Fetches or partially fetches the value associated with the current
Key into the Exchange 's Value . |
Exchange |
Exchange.fetch(Value value)
Fetches the value associated with the current
Key into the
supplied Value object (instead of the Exchange
's assigned Value ). |
Exchange |
Exchange.fetch(Value value,
int minimumBytes)
Fetches or partially fetches the value associated with the current
Key into the supplied Value object (instead of
the Exchange 's assigned Value ). |
boolean |
Exchange.fetchAndRemove()
Remove a single key/value pair from this
Exchange 's
Tree and return the removed value in the
Exchange 's Value . |
Exchange |
Exchange.fetchAndStore()
Fetches the value associated with the
Key , then inserts or
updates the value. |
Buffer |
Exchange.fetchBufferCopy(int level)
Returns a copy of either the data page or a page on the index path to the
data page containing the current key.
|
boolean |
Persistit.flush()
Write all pending updates to the underlying OS file system.
|
void |
Persistit.force()
Request OS-level file synchronization for all open files managed by
Persistit.
|
Exchange |
Persistit.getExchange(String volumeName,
String treeName,
boolean create)
|
Exchange |
Persistit.getExchange(Volume volume,
String treeName,
boolean create)
|
Volume |
Persistit.getLockVolume() |
Accumulator.MaxAccumulator |
Tree.getMaxAccumulator(int index)
Return a
MaxAccumulator for this Tree and the
specified index value between 0 and 63, inclusive. |
Accumulator.MinAccumulator |
Tree.getMinAccumulator(int index)
Return a
MinAccumulator for this Tree and the
specified index value between 0 and 63, inclusive. |
List<Tree> |
Persistit.getSelectedTrees(TreeSelector selector)
|
Accumulator.SeqAccumulator |
Tree.getSeqAccumulator(int index)
Return a
SeqAccumulator for this Tree and the
specified index value between 0 and 63, inclusive. |
Accumulator.SumAccumulator |
Tree.getSumAccumulator(int index)
Return a
SumAccumulator for this Tree and the
specified index value between 0 and 63, inclusive. |
Tree |
Volume.getTree(String name,
boolean createIfNecessary)
Looks up by name and returns a
NewTree within this
Volume . |
String[] |
Volume.getTreeNames()
Returns an array of all currently defined
Tree names. |
V |
TimelyResource.getVersion(Version.VersionCreator<V> creator) |
protected void |
StreamLoader.ImportHandler.handleCommentRecord(String comment) |
protected void |
StreamLoader.ImportHandler.handleCompletionRecord() |
protected void |
StreamLoader.ImportHandler.handleCountRecord(long keyValueRecords,
long otherRecords) |
protected void |
StreamLoader.ImportHandler.handleDataRecord(Key key,
Value value) |
protected void |
StreamLoader.ImportHandler.handleEndRecord() |
protected void |
StreamLoader.ImportHandler.handleExceptionRecord(String exceptionString) |
protected void |
StreamLoader.ImportHandler.handleFillRecord() |
protected void |
StreamLoader.ImportHandler.handleHostNameRecord(String hostName) |
protected void |
StreamLoader.ImportHandler.handleKeyFilterRecord(String keyFilterString) |
protected void |
StreamLoader.ImportHandler.handleStartRecord() |
protected void |
StreamLoader.ImportHandler.handleTimeStampRecord(long timeStamp) |
protected void |
StreamLoader.ImportHandler.handleTreeIdRecord(String treeName) |
protected void |
StreamLoader.ImportHandler.handleUserRecord(String userName) |
protected void |
StreamLoader.ImportHandler.handleVolumeIdRecord(long volumeId,
long initialPages,
long extensionPages,
long maximumPages,
int bufferSize,
String path,
String name) |
boolean |
Exchange.hasChildren()
Return true if there is at least one key stored in this
Exchange 's Tree that is a logical child of the
current Key . |
boolean |
Exchange.hasNext()
Determines whether the current key has a logical sibling successor,
without changing the state of
Key or Value . |
boolean |
Exchange.hasNext(boolean deep)
Determines whether the current key has a logical sibling successor,
without changing the state of
Key or Value . |
boolean |
Exchange.hasNext(KeyFilter filter)
Determines whether the current key has a successor within the subset of
all keys defined by a
KeyFilter . |
boolean |
Exchange.hasPrevious()
Determines whether the current key has a logical sibling predecessor,
without changing the state of
Key or Value . |
boolean |
Exchange.hasPrevious(boolean deep)
Determines whether the current key has a logical sibling predecessor,
without changing the state of
Key or Value . |
boolean |
Exchange.hasPrevious(KeyFilter filter)
Determines whether the current key has a predecessor within the subset of
all keys defined by a
KeyFilter . |
void |
RecoveryManager.init(String path) |
void |
Persistit.initialize()
Initialize Persistit using the
Configuration supplied by the
Persistit.setConfiguration(Configuration) method or derived from
properties supplied by Persistit.setProperties(Properties) or
Persistit.setPropertiesFromFile(String) . |
void |
Persistit.initialize(Configuration configuration)
Deprecated.
|
void |
Persistit.initialize(Properties properties)
Deprecated.
|
void |
Persistit.initialize(String propertiesFileName)
Deprecated.
|
boolean |
Exchange.isValueDefined()
Determines whether the current key has an associated value - that is,
whether a
Exchange.fetch() operation would return a defined value - without
actually changing the state of either the Key or the
Value . |
void |
StreamLoader.load() |
void |
StreamLoader.load(StreamLoader.ImportHandler handler) |
void |
StreamLoader.load(TreeSelector treeSelector,
boolean createMissingVolumes,
boolean createMissingTrees) |
Volume |
Persistit.loadVolume(String vstring)
Look up, load and/or creates a volume based on a String-valued
specification.
|
Volume |
Persistit.loadVolume(VolumeSpecification volumeSpec)
Look up, load and/or creates a volume based on a
VolumeSpecification . |
void |
Exchange.lock()
Invoke
Exchange.lock(Key, long) with the current key and a default
timeout value of
60000L milliseconds. |
void |
Exchange.lock(Key key)
Invoke
Exchange.lock(Key, long) with the supplied key and a default
timeout value of
60000L milliseconds. |
void |
Exchange.lock(Key lockKey,
long timeout)
Within a transaction, enforces a constraint that no other concurrent
transaction also successfully locks the same key.
|
boolean |
Exchange.next()
Traverses to the next logical sibling key value.
|
boolean |
Exchange.next(boolean deep)
Traverses to the next key with control over depth.
|
boolean |
Exchange.next(KeyFilter filter)
Traverses to the next key value within the subset of all keys defined by
the supplied KeyFilter.
|
boolean |
StreamLoader.next(StreamLoader.ImportHandler handler) |
protected Tree[] |
Task.parseTreeList(String specification)
Parses a String that represents a list of Volume/Tree pairs.
|
boolean |
Exchange.previous()
Traverses to the previous logical sibling key value.
|
boolean |
Exchange.previous(boolean deep)
Traverses to the previous key with control over depth.
|
boolean |
Exchange.previous(KeyFilter filter)
Traverses to the previous key value within the subset of all keys defined
by the supplied KeyFilter.
|
boolean |
Exchange.remove()
Remove a single key/value pair from the this
Exchange 's
Tree . |
boolean |
Exchange.remove(Key.Direction direction)
Depending on the value of the selection parameter, remove the record
associated with the current key, its logical children, or both.
|
boolean |
Exchange.removeAll()
Remove all keys in this
Exchange 's Tree . |
boolean |
Exchange.removeKeyRange(Key key1,
Key key2)
Removes all records with keys falling between
key1 and
key2 , left-inclusive. |
void |
Exchange.removeTree()
Remove the entire
Tree that this Exchange is
based on. |
int |
Transaction.run(TransactionRunnable runnable)
Invokes the
TransactionRunnable.runTransaction() method of an
object that implements TransactionRunnable within the scope of a
transaction. |
int |
Transaction.run(TransactionRunnable runnable,
int retryCount,
long retryDelay,
boolean toDisk)
Invokes the
TransactionRunnable.runTransaction() method of an
object that implements TransactionRunnable within the scope of a
transaction. |
int |
Transaction.run(TransactionRunnable runnable,
int retryCount,
long retryDelay,
Transaction.CommitPolicy toDisk) |
protected void |
StreamSaver.runTask() |
void |
TransactionRunnable.runTransaction()
Interface for application logic that is to be run within the scope of a
Transaction . |
void |
StreamSaver.save(Exchange exchange,
KeyFilter filter)
Save all key/value pairs in the
Tree associated with the
supplied Exchange , subject to selection by the supplied
KeyFilter . |
void |
StreamSaver.saveAll()
Save all trees in all open volumes.
|
void |
StreamSaver.saveTrees(String volumeName,
String[] selectedTreeNames)
Saves one or more trees in a named volume.
|
void |
StreamSaver.saveTrees(TreeSelector treeSelector)
Saves one or more trees.
|
void |
StreamSaver.saveTrees(Volume volume,
String[] selectedTreeNames)
Saves one or more trees in the specified
Volume . |
void |
Persistit.setPropertiesFromFile(String propertiesFileName)
Sets a
Configuration derived from Properties
read from the supplied file name. |
Exchange |
Exchange.store()
Insert the current
Key and Value pair into this
Exchange 's Tree . |
boolean |
Exchange.traverse(Key.Direction direction,
boolean deep)
Performs generalized tree traversal.
|
boolean |
Exchange.traverse(Key.Direction direction,
boolean deep,
int minimumBytes)
Performs generalized tree traversal.
|
boolean |
Exchange.traverse(Key.Direction direction,
boolean deep,
int minimumBytes,
Exchange.TraverseVisitor visitor)
Performs generalized tree traversal using a
Exchange.TraverseVisitor . |
boolean |
Exchange.traverse(Key.Direction direction,
KeyFilter keyFilter,
int minBytes)
Performs generalized tree traversal constrained by a supplied
KeyFilter . |
void |
Volume.truncate()
Remove all data from this volume.
|
boolean |
Exchange.TraverseVisitor.visit(ReadOnlyExchange ex)
Receive an Exchange having
Key and Value
values set by
Exchange.traverse(Key.Direction, boolean, int, TraverseVisitor)
. |
Constructor and Description |
---|
Exchange(Persistit persistit,
String volumeName,
String treeName,
boolean create)
|
Exchange(Persistit persistit,
Volume volume,
String treeName,
boolean create)
|
Persistit(Configuration configuration)
Construct a Persistit instance with the supplied
Configuration and then initialize it. |
Persistit(Properties properties)
Construct a Persistit instance with a
Configuration derived
from the supplied Properties instance. |
Modifier and Type | Class and Description |
---|---|
class |
BufferSizeUnavailableException
Thrown if there is no
BufferPool with buffers matching
the page size of a Volume being opened. |
class |
CorruptImportStreamException
Thrown by
StreamLoader if the format of data in the
input stream is invalid. |
class |
CorruptJournalException
Thrown if the journal files are corrupt.
|
class |
CorruptValueException
Thrown if a multi-version value is malformed.
|
class |
CorruptVolumeException
Thrown if Persistit attempts to open a corrupt volume file.
|
class |
DuplicateKeyException
Thrown by
TreeBuilder on an attempt to insert duplicate
keys. |
class |
InUseException
Thrown when a Persistit database operation fails to establish a claim on a
resource within a reasonable length of time.
|
class |
InvalidKeyException
|
class |
InvalidPageAddressException
Thrown when Persistit detects an invalid page pointer.
|
class |
InvalidPageStructureException
Thrown when Persistit detects corruption within a page image.
|
class |
InvalidPageTypeException
Thrown when Persistit detects an invalid page type.
|
class |
MissingThreadException
Thrown by tests that intentionally stop background threads.
|
class |
PersistitClosedException
Thrown by
Exchange when a Thread other
than the thread that created the Exchange attempts to perform an operation. |
class |
PersistitInterruptedException
This is a wrapper for an
InterruptedException . |
class |
PersistitIOException
This is a wrapper for an
IOException . |
class |
PropertiesNotFoundException
Thrown when the Persistit is unable to find the properties file specified by
the
initialize
method. |
class |
ReadOnlyVolumeException
Thrown when an application attempts to modify data in a
Volume that is open in read-only mode. |
class |
RebalanceException
Thrown to signify an internal condition that requires special handling during
deletion rebalancing.
|
class |
RecoveryMissingVolumesException
Thrown during recovery processing when the prewrite journal contains recovery
data for one or more Volumes that no longer exist.
|
class |
RetryException
Thrown when a method must back off and retry.
|
class |
TimeoutException
Thrown when an operation has waited too long for an operation to complete.
|
class |
TransactionFailedException
Thrown by
Transaction when a transaction fails due to
excessive rollbacks. |
class |
TreeNotFoundException
|
class |
TruncateVolumeException
Thrown when an application attempts to truncate a
Volume that was opened without the create or createOnly
attribute. |
class |
UnderSpecifiedVolumeException
Thrown when the Persistit attempts to open a Volume with an incomplete
VolumeSpecification , for example, with a missing page size. |
class |
VolumeAlreadyExistsException
Thrown when the Persistit configuration specifies the
createOnly
flag for a volume that already exists, or when a the configuration specifies
a page size for a volume that does not the page size of an existing volume. |
class |
VolumeClosedException
Thrown when an application attempts to perform operations on a
Volume that has been closed. |
class |
VolumeFullException
Thrown when an attempt to modify a
Volume would exceed
the maximum volume size. |
class |
VolumeNotFoundException
Thrown when the Persistit configuration species a volume file that does not
exist, and does not specify the
create or
createOnly flag. |
class |
WrongVolumeException
Thrown by
Volume if the volume file has a different
internal ID value than expected. |
class |
WWRetryException
Thrown when a method must back off and retry.
|
Modifier and Type | Method and Description |
---|---|
void |
JournalManagerMXBean.force() |
Copyright © 2025 Open Identity Platform Community. All rights reserved.