Index (common 0.3.1 API)

A B C D E F G H I J K L M N O P R S T U V W Z

A

abs(int) - Static method in class io.pravega.common.MathHelpers
abs(long) - Static method in class io.pravega.common.MathHelpers
AbstractThreadPoolService - Class in io.pravega.common.concurrent: Base Service that runs asynchronously using a thread pool.
AbstractThreadPoolService(String, ScheduledExecutorService) - Constructor for class io.pravega.common.concurrent.AbstractThreadPoolService: Creates a new instance of the AbstractThreadPoolService class.
AbstractTimer - Class in io.pravega.common: Provides a customizable way of measuring elapsed time.
AbstractTimer() - Constructor for class io.pravega.common.AbstractTimer
accept(RevisionDataOutput, T) - Method in interface io.pravega.common.io.serialization.RevisionDataOutput.ElementSerializer
accept(RevisionDataInput, ReaderType) - Method in interface io.pravega.common.io.serialization.VersionedSerializer.StreamReader
accept(TargetType, RevisionDataOutput) - Method in interface io.pravega.common.io.serialization.VersionedSerializer.StreamWriter
add(int) - Method in class io.pravega.common.lang.Int96
add(int) - Method in class io.pravega.common.SimpleMovingAverage: Adds the given value to the moving average.
add(T) - Method in class io.pravega.common.util.BlockingDrainingQueue: Adds a new item to the queue.
add(T) - Method in class io.pravega.common.util.SequencedItemList: Adds a new item at the end of the list, but only if the given item has a Sequence Number higher than the last element in the list.
addNewSample(double) - Method in class io.pravega.common.ExponentialMovingAverage: Adds a new sample to the moving average and returns the updated value.
allOf(Collection<CompletableFuture<T>>) - Static method in class io.pravega.common.concurrent.Futures: Similar implementation to CompletableFuture.allOf(vararg) but that works on a Collection.
allOfWithResults(List<CompletableFuture<T>>) - Static method in class io.pravega.common.concurrent.Futures: Similar implementation to CompletableFuture.allOf(vararg) but that works on a Collection and that returns another Collection which has the results of the given CompletableFutures.
allOfWithResults(Map<K, CompletableFuture<V>>) - Static method in class io.pravega.common.concurrent.Futures: Similar to CompletableFuture.allOf(varargs), but that works on a Map and that returns another Map which has the results of the given CompletableFutures, with the same input keys.
apply(RevisionDataInput) - Method in interface io.pravega.common.io.serialization.RevisionDataInput.ElementDeserializer
apply(TypedProperties) - Method in interface io.pravega.common.util.ConfigBuilder.ConfigConstructor
args(Object...) - Method in class io.pravega.common.lang.ProcessStarter: Starts the Process using the given command-line arguments.
array() - Method in interface io.pravega.common.util.ArrayView: Gets a reference to the backing array for this ArrayView.
array() - Method in class io.pravega.common.util.ByteArraySegment
arrayOffset() - Method in interface io.pravega.common.util.ArrayView: Gets a value indicating the offset in the backing array where this ArrayView starts at.
arrayOffset() - Method in class io.pravega.common.util.ByteArraySegment
ArrayView - Interface in io.pravega.common.util: Defines a generic read-only view of an index-based, array-like structure.
asDate() - Method in class io.pravega.common.util.ImmutableDate
asReadOnly() - Method in class io.pravega.common.util.ByteArraySegment: Returns a new ByteArraySegment that wraps the same underlying array that this ByteSegmentDoes, except that the new instance is marked as Read-Only.
AsyncMap<K,V> - Interface in io.pravega.common.util: Defines a basic asynchronous Key-Value map which allows adding, getting and removing items.
AtomicInt96 - Class in io.pravega.common.lang: This class provides the ability to atomically update a Int96 value.
AtomicInt96() - Constructor for class io.pravega.common.lang.AtomicInt96
attempt() - Method in interface io.pravega.common.util.Retry.Retryable
AuthenticationException - Exception in io.pravega.common.auth: Exception thrown when there is any error during authentication.
AuthenticationException(String) - Constructor for exception io.pravega.common.auth.AuthenticationException
AuthenticationException(String, int) - Constructor for exception io.pravega.common.auth.AuthenticationException
AuthenticationException(Exception) - Constructor for exception io.pravega.common.auth.AuthenticationException
AuthenticationException(Exception, int) - Constructor for exception io.pravega.common.auth.AuthenticationException
AuthException - Exception in io.pravega.common.auth
AuthException(String, int) - Constructor for exception io.pravega.common.auth.AuthException
AuthException(Exception, int) - Constructor for exception io.pravega.common.auth.AuthException
AuthorizationException - Exception in io.pravega.common.auth: Exception thrown when there is any error during authorization.
AuthorizationException(String) - Constructor for exception io.pravega.common.auth.AuthorizationException
AuthorizationException(String, int) - Constructor for exception io.pravega.common.auth.AuthorizationException
AuthorizationException(Exception) - Constructor for exception io.pravega.common.auth.AuthorizationException
AuthorizationException(Exception, int) - Constructor for exception io.pravega.common.auth.AuthorizationException
available() - Method in class io.pravega.common.io.BoundedInputStream
AvlTreeIndex<V extends SortedIndex.IndexEntry> - Class in io.pravega.common.util: SortedIndex backed by an AVL Tree.
AvlTreeIndex() - Constructor for class io.pravega.common.util.AvlTreeIndex: Creates a new instance of the AvlTreeIndex class.
await(CompletableFuture<T>) - Static method in class io.pravega.common.concurrent.Futures: Waits for the provided future to be complete, and returns true if it was successful, false otherwise.
await(CompletableFuture<T>, long) - Static method in class io.pravega.common.concurrent.Futures: Waits for the provided future to be complete, and returns true if it was successful, false if it failed or did not complete.
await() - Method in class io.pravega.common.util.ReusableLatch: Block until another thread calls release, or the thread is interrupted.
await(long) - Method in class io.pravega.common.util.ReusableLatch: Block until another thread calls release, or the thread is interrupted.
awaitUninterruptibly() - Method in class io.pravega.common.util.ReusableLatch: Block until release is called by another thread.

B

binarySearch(List<? extends T>, Function<? super T, Integer>) - Static method in class io.pravega.common.util.CollectionHelpers: Performs a binary search on the given sorted list using the given comparator.
binarySearch(IndexedMap<KeyType, ValueType>, Collection<KeyType>, Map<KeyType, ValueType>) - Static method in class io.pravega.common.util.CollectionHelpers: Performs a binary search on the given IndexedMap.
BitConverter - Class in io.pravega.common.util: Helper methods for various Number to Bit conversions.
BitConverter() - Constructor for class io.pravega.common.util.BitConverter
BlockingDrainingQueue<T> - Class in io.pravega.common.util: Represents a thread-safe queue that dequeues all elements at once.
BlockingDrainingQueue() - Constructor for class io.pravega.common.util.BlockingDrainingQueue: Creates a new instance of the BlockingDrainingQueue class.
BoundedInputStream - Class in io.pravega.common.io: A wrapper for an InputStream that allows reading up to a specified number of bytes.
BoundedInputStream(InputStream, int) - Constructor for class io.pravega.common.io.BoundedInputStream: Creates a new instance of the BoundedInputStream class.
build() - Method in interface io.pravega.common.ObjectBuilder: Creates a new instance of the T type (usually with the accumulated data so far).
build() - Method in class io.pravega.common.util.ConfigBuilder: Creates a new instance of the given Configuration class as defined by this builder with the information contained herein.
Builder() - Constructor for class io.pravega.common.io.serialization.VersionedSerializer.MultiType.Builder
ByteArraySegment - Class in io.pravega.common.util: Allows segmenting a byte array and operating only on that segment.
ByteArraySegment(byte[]) - Constructor for class io.pravega.common.util.ByteArraySegment: Creates a new instance of the ByteArraySegment class that wraps the entire given array.
ByteArraySegment(byte[], int, int) - Constructor for class io.pravega.common.util.ByteArraySegment: Creates a new instance of the ByteArraySegment class that wraps the given array range.
ByteArraySegment(ByteBuffer) - Constructor for class io.pravega.common.util.ByteArraySegment: Creates a new instance of the ByteArraySegment class that wraps an array backed ByteBuffer.
ByteArraySegment(byte[], int, int, boolean) - Constructor for class io.pravega.common.util.ByteArraySegment: Creates a new instance of the ByteArraySegment class that wraps the given array range.
ByteBufferUtils - Class in io.pravega.common.util
ByteBufferUtils() - Constructor for class io.pravega.common.util.ByteBufferUtils

C

call() - Method in interface io.pravega.common.Exceptions.InterruptibleCall
Callbacks - Class in io.pravega.common.function: Misc methods that can be used as callbacks.
Callbacks() - Constructor for class io.pravega.common.function.Callbacks
CancellationToken - Class in io.pravega.common.concurrent: Represents a token that can be passed around to various services or components to indicate when a task should be cancelled.
CancellationToken() - Constructor for class io.pravega.common.concurrent.CancellationToken: Creates a new instance of the CancellationToken class.
cancelPendingTake() - Method in class io.pravega.common.util.BlockingDrainingQueue: Cancels any pending Future from a take() operation.
capacityAvailable() - Method in class io.pravega.common.util.CircularBuffer
checkArgument(boolean, String, String, Object...) - Static method in class io.pravega.common.Exceptions: Throws an IllegalArgumentException if the validCondition argument is false.
checkArrayRange(long, int, long, String, String) - Static method in class io.pravega.common.Exceptions: Throws an appropriate exception if the given range is not included in the given array interval.
checkNotClosed(boolean, Object) - Static method in class io.pravega.common.Exceptions: Throws an ObjectClosedException if the closed argument is true.
checkNotNullOrEmpty(String, String) - Static method in class io.pravega.common.Exceptions: Throws a NullPointerException if the arg argument is null.
checkNotNullOrEmpty(V, String) - Static method in class io.pravega.common.Exceptions: Throws a NullPointerException if the arg argument is null.
checkNotNullOrEmpty(Map<K, V>, String) - Static method in class io.pravega.common.Exceptions: Throws a NullPointerException if the arg argument is null.
CircularBuffer - Class in io.pravega.common.util: Convenience class wrapping byteBuffer to provide a circular buffer.
CircularBuffer(int) - Constructor for class io.pravega.common.util.CircularBuffer
clear() - Method in class io.pravega.common.util.AvlTreeIndex
clear() - Method in class io.pravega.common.util.CircularBuffer
clear() - Method in class io.pravega.common.util.RedBlackTreeIndex
clear() - Method in class io.pravega.common.util.SequencedItemList: Clears the list.
clear() - Method in interface io.pravega.common.util.SortedIndex: Clears the contents of the Index.
close() - Method in class io.pravega.common.concurrent.AbstractThreadPoolService
close() - Method in class io.pravega.common.concurrent.SequentialAsyncProcessor
close() - Method in class io.pravega.common.io.BoundedInputStream
close() - Method in class io.pravega.common.io.FixedByteArrayOutputStream
close() - Method in class io.pravega.common.util.BlockingDrainingQueue: Closes the queue and prevents any other access to it.
close() - Method in interface io.pravega.common.util.CloseableIterator: Closes the Iterator.
close() - Method in class io.pravega.common.util.OrderedItemProcessor
CloseableIterator<T,TEx extends java.lang.Exception> - Interface in io.pravega.common.util: Defines an Iterator that can be closed.
CollectionHelpers - Class in io.pravega.common.util: Helper methods for collections.
CollectionHelpers() - Constructor for class io.pravega.common.util.CollectionHelpers
COMPACT_INT_MAX - Static variable in interface io.pravega.common.io.serialization.RevisionDataOutput: Maximum value that can be encoded using writeCompactInt().
COMPACT_INT_MIN - Static variable in interface io.pravega.common.io.serialization.RevisionDataOutput: Minimum value that can be encoded using writeCompactInt().
COMPACT_LONG_MAX - Static variable in interface io.pravega.common.io.serialization.RevisionDataOutput: Maximum value that can be encoded using writeCompactLong().
COMPACT_LONG_MIN - Static variable in interface io.pravega.common.io.serialization.RevisionDataOutput: Minimum value that can be encoded using writeCompactLong().
compareTo(Object) - Method in class io.pravega.common.lang.Int96
completeAfter(Supplier<CompletableFuture<? extends T>>, CompletableFuture<T>) - Static method in class io.pravega.common.concurrent.Futures: Given a Supplier returning a Future, completes another future either with the result of the first future, in case of normal completion, or exceptionally with the exception of the first future.
ConfigBuilder<T> - Class in io.pravega.common.util: A builder for a generic Property-based configuration.
ConfigBuilder(String, ConfigBuilder.ConfigConstructor<T>) - Constructor for class io.pravega.common.util.ConfigBuilder: Creates a new instance of the ConfigBuilder class.
ConfigBuilder.ConfigConstructor<R> - Interface in io.pravega.common.util
ConfigurationException - Exception in io.pravega.common.util: Exception that is thrown whenever a bad configuration is detected.
ConfigurationException(String) - Constructor for exception io.pravega.common.util.ConfigurationException: Creates a new instance of the ConfigurationException class.
ConfigurationException(String, Throwable) - Constructor for exception io.pravega.common.util.ConfigurationException: Creates a new instance of the ConfigurationException class.
copyFrom(ByteArraySegment, int, int) - Method in class io.pravega.common.util.ByteArraySegment: Copies a specified number of bytes from the given ByteArraySegment into this ByteArraySegment.
copyTo(byte[], int, int) - Method in interface io.pravega.common.util.ArrayView: Copies a specified number of bytes from this ArrayView into the given target array.
copyTo(byte[], int, int) - Method in class io.pravega.common.util.ByteArraySegment
copyTo(Map<Object, Object>) - Method in class io.pravega.common.util.ConfigBuilder: Copies the contents of this builder to the given target.
create() - Static method in class io.pravega.common.hash.RandomFactory: Returns a new random number generator.

D

dataAvailable() - Method in class io.pravega.common.util.CircularBuffer: Gets the number of bytes that can be read.
declareSerializers(VersionedSerializer.MultiType<BaseType>.Builder) - Method in class io.pravega.common.io.serialization.VersionedSerializer.MultiType: When implemented in a derived class, this method will declare all supported serializers of subtypes of BaseType by using the serializer() method.
delayedFuture(Duration, ScheduledExecutorService) - Static method in class io.pravega.common.concurrent.Futures: Creates a CompletableFuture that will do nothing and complete after a specified delay, without using a thread during the delay.
delayedFuture(Supplier<CompletableFuture<T>>, long, ScheduledExecutorService) - Static method in class io.pravega.common.concurrent.Futures: Executes the asynchronous task after the specified delay.
delayedTask(Supplier<T>, Duration, ScheduledExecutorService) - Static method in class io.pravega.common.concurrent.Futures: Executes the given task after the specified delay.
deleteFileOrDirectory(File) - Static method in class io.pravega.common.io.FileHelpers: Deletes the given file or directory.
DelimitedStringParser - Class in io.pravega.common.util: Parses Strings as a sequence of key-value pairs and allows extracting values for specific keys.
DelimitedStringParser() - Constructor for class io.pravega.common.util.DelimitedStringParser
deserialize(InputStream) - Method in class io.pravega.common.io.serialization.VersionedSerializer.MultiType: Deserializes data from the given InputStream into an object of type BaseType.
deserialize(ArrayView) - Method in class io.pravega.common.io.serialization.VersionedSerializer.MultiType: Deserializes data from the given ArrayView and creates a new object with the result.
deserialize(RevisionDataInput) - Method in class io.pravega.common.io.serialization.VersionedSerializer.WithBuilder: Deserializes data from the given RevisionDataInput and creates a new object with the result.
deserialize(InputStream) - Method in class io.pravega.common.io.serialization.VersionedSerializer.WithBuilder: Deserializes data from the given InputStream and creates a new object with the result.
deserialize(byte[]) - Method in class io.pravega.common.io.serialization.VersionedSerializer.WithBuilder: Deserializes data from the given byte array and creates a new object with the result.
deserialize(ArrayView) - Method in class io.pravega.common.io.serialization.VersionedSerializer.WithBuilder: Deserializes data from the given ArrayView and creates a new object with the result.
Direct() - Constructor for class io.pravega.common.io.serialization.VersionedSerializer.Direct
doNothing(T) - Static method in class io.pravega.common.function.Callbacks: Empty consumer.
doRun() - Method in class io.pravega.common.concurrent.AbstractThreadPoolService: Main execution of the Service.
doStart() - Method in class io.pravega.common.concurrent.AbstractThreadPoolService
doStop() - Method in class io.pravega.common.concurrent.AbstractThreadPoolService
doWhileLoop(Supplier<CompletableFuture<T>>, Predicate<T>, Executor) - Static method in class io.pravega.common.concurrent.Futures: Executes a code fragment returning a CompletableFutures while a condition on the returned value is satisfied.

E

EnhancedByteArrayOutputStream - Class in io.pravega.common.io: A ByteArrayOutputStream that exposes the contents as a ByteArraySegment, without requiring a memory copy.
EnhancedByteArrayOutputStream() - Constructor for class io.pravega.common.io.EnhancedByteArrayOutputStream
EnumHelpers - Class in io.pravega.common.util: General helpers on Enum types.
EnumHelpers() - Constructor for class io.pravega.common.util.EnumHelpers
env(String, Object) - Method in class io.pravega.common.lang.ProcessStarter: Includes the given Environment Variable as part of the start.
errorHandler(Throwable) - Method in class io.pravega.common.concurrent.AbstractThreadPoolService: When overridden in a derived class, handles an exception that is caught by the execution of run().
exceptionallyCompose(CompletableFuture<T>, Function<Throwable, CompletableFuture<T>>) - Static method in class io.pravega.common.concurrent.Futures: Same as CompletableFuture.exceptionally(), except that it allows returning a CompletableFuture instead of a single value.
exceptionallyComposeExpecting(CompletableFuture<T>, Predicate<Throwable>, Supplier<CompletableFuture<T>>) - Static method in class io.pravega.common.concurrent.Futures: Same as exceptionallyExpecting(), except that it allows executing/returning a Future as a result in case of an expected exception.
exceptionallyExpecting(CompletableFuture<T>, Predicate<Throwable>, T) - Static method in class io.pravega.common.concurrent.Futures: Same as CompletableFuture.exceptionally(), except that it allows certain exceptions, as defined by the isExpected parameter.
exceptionListener(CompletableFuture<T>, Consumer<Throwable>) - Static method in class io.pravega.common.concurrent.Futures: Registers an exception listener to the given CompletableFuture.
exceptionListener(CompletableFuture<T>, Class<E>, Consumer<E>) - Static method in class io.pravega.common.concurrent.Futures: Registers an exception listener to the given CompletableFuture for a particular type of exception.
Exceptions - Class in io.pravega.common: Helper methods that perform various checks and throw exceptions if certain conditions are met.
Exceptions() - Constructor for class io.pravega.common.Exceptions
Exceptions.InterruptibleCall<ExceptionT extends java.lang.Exception,ResultT> - Interface in io.pravega.common
Exceptions.InterruptibleRun<ExceptionT extends java.lang.Exception> - Interface in io.pravega.common
execute(RunnableWithException, Consumer<Throwable>, Runnable, Executor) - Static method in class io.pravega.common.concurrent.ExecutorServiceHelpers: Executes the given task on the given Executor.
executionComplete(Throwable) - Method in class io.pravega.common.util.OrderedItemProcessor: Callback that is invoked when an item has completed execution.
executor - Variable in class io.pravega.common.concurrent.AbstractThreadPoolService
ExecutorServiceHelpers - Class in io.pravega.common.concurrent: Helper methods for ExecutorService.
ExecutorServiceHelpers() - Constructor for class io.pravega.common.concurrent.ExecutorServiceHelpers
ExecutorServiceHelpers.Snapshot - Class in io.pravega.common.concurrent
ExponentialMovingAverage - Class in io.pravega.common: Provides an Exponential moving average of some value.
ExponentialMovingAverage(double, double, boolean) - Constructor for class io.pravega.common.ExponentialMovingAverage: Creates a new value to track.
extractBoolean(String, Consumer<Boolean>) - Method in class io.pravega.common.util.DelimitedStringParser: Associates the given consumer with the given key.
extractInteger(String, Consumer<Integer>) - Method in class io.pravega.common.util.DelimitedStringParser: Associates the given consumer with the given key.
extractLong(String, Consumer<Long>) - Method in class io.pravega.common.util.DelimitedStringParser: Associates the given consumer with the given key.
extractString(String, Consumer<String>) - Method in class io.pravega.common.util.DelimitedStringParser: Associates the given consumer with the given key.

F

failedFuture(Throwable) - Static method in class io.pravega.common.concurrent.Futures: Creates a new CompletableFuture that is failed with the given exception.
FileHelpers - Class in io.pravega.common.io: Extension methods to the java.io.File class.
FileHelpers() - Constructor for class io.pravega.common.io.FileHelpers
fill(ByteBuffer) - Method in class io.pravega.common.util.CircularBuffer: Copies from the given ByteBuffer.
filter(List<T>, Function<T, CompletableFuture<Boolean>>) - Static method in class io.pravega.common.concurrent.Futures: Filter that takes a predicate that evaluates in future and returns the filtered list that evaluates in future.
filterOut(Collection<T>, Collection<T>) - Static method in class io.pravega.common.util.CollectionHelpers: Returns a new collection which contains all the items in the given collection that are not to be excluded.
FixedByteArrayOutputStream - Class in io.pravega.common.io: OutputStream that writes to a fixed-size buffer (this is needed because ByteArrayOutputStream auto-grows the buffer).
FixedByteArrayOutputStream(byte[], int, int) - Constructor for class io.pravega.common.io.FixedByteArrayOutputStream: Creates a new instance of the FixedByteArrayOutputStream class.
forClass(Class<?>) - Static method in class io.pravega.common.lang.ProcessStarter: Creates a new instance of the ProcessStarter class.
forEach(Consumer<V>) - Method in class io.pravega.common.util.AvlTreeIndex
forEach(Consumer<V>) - Method in class io.pravega.common.util.RedBlackTreeIndex
forEach(Consumer<V>) - Method in interface io.pravega.common.util.SortedIndex: Iterates through each item in the Index, in natural order, and calls the given consumer on all of them.
fromBytes(byte[]) - Static method in class io.pravega.common.lang.Int96
Futures - Class in io.pravega.common.concurrent: Extensions to Future and CompletableFuture.
Futures() - Constructor for class io.pravega.common.concurrent.Futures
futureWithTimeout(Duration, ScheduledExecutorService) - Static method in class io.pravega.common.concurrent.Futures: Creates a new CompletableFuture that will timeout after the given amount of time.
futureWithTimeout(Duration, String, ScheduledExecutorService) - Static method in class io.pravega.common.concurrent.Futures: Creates a new CompletableFuture that will timeout after the given amount of time.

G

get() - Method in class io.pravega.common.concurrent.NewestReference
get() - Method in class io.pravega.common.lang.AtomicInt96
get(int) - Method in interface io.pravega.common.util.ArrayView: Gets the value at the specified index.
get(K, Duration) - Method in interface io.pravega.common.util.AsyncMap: Retrieves a value from the Map.
get(long) - Method in class io.pravega.common.util.AvlTreeIndex
get(int) - Method in class io.pravega.common.util.ByteArraySegment
get(long) - Method in class io.pravega.common.util.RedBlackTreeIndex
get(long) - Method in interface io.pravega.common.util.SortedIndex: Gets an item with the given key.
get(Property<String>) - Method in class io.pravega.common.util.TypedProperties: Gets the value of a String property.
getAndHandleExceptions(Future<ResultT>, Function<Throwable, ExceptionT>) - Static method in class io.pravega.common.concurrent.Futures: Calls get on the provided future, handling interrupted, and transforming the executionException into an exception of the type whose constructor is provided.
getAndHandleExceptions(Future<ResultT>, Consumer<Throwable>, long) - Static method in class io.pravega.common.concurrent.Futures: Similar to Futures.getAndHandleExceptions(Future, Function) but with an exception handler rather than a transforming function and a timeout on get().
getAverage(double) - Method in class io.pravega.common.SimpleMovingAverage: Gets a value indicating the current moving average.
getBaseStream() - Method in interface io.pravega.common.io.serialization.RevisionDataInput: Gets a pointer to the InputStream that this RevisionDataInput reads from.
getBaseStream() - Method in interface io.pravega.common.io.serialization.RevisionDataOutput: Gets a pointer to the OutputStream that this RevisionDataOutput writes to.
getBoolean(Property<Boolean>) - Method in class io.pravega.common.util.TypedProperties: Gets the value of a boolean property.
getCeiling(long) - Method in class io.pravega.common.util.AvlTreeIndex
getCeiling(long) - Method in class io.pravega.common.util.RedBlackTreeIndex
getCeiling(long) - Method in interface io.pravega.common.util.SortedIndex: Gets the smallest item whose key is greater than or equal to the given key.
getCollectionLength(int, int) - Method in interface io.pravega.common.io.serialization.RevisionDataOutput: Calculates the number of bytes required to serialize a Collection or array.
getCollectionLength(Collection<T>, ToIntFunction<T>) - Method in interface io.pravega.common.io.serialization.RevisionDataOutput: Calculates the number of bytes required to serialize a Collection.
getCollectionLength(T[], ToIntFunction<T>) - Method in interface io.pravega.common.io.serialization.RevisionDataOutput: Calculates the number of bytes required to serialize an array.
getCompactIntLength(int) - Method in interface io.pravega.common.io.serialization.RevisionDataOutput: Calculates the length, in bytes, of the given Integer as serialized by using writeCompactInt().
getCompactLongLength(long) - Method in interface io.pravega.common.io.serialization.RevisionDataOutput: Calculates the length, in bytes, of the given Long as serialized by using writeCompactLong().
getCopy() - Method in interface io.pravega.common.util.ArrayView: Returns a copy of the contents of this ArrayView.
getCopy() - Method in class io.pravega.common.util.ByteArraySegment
getCount() - Method in interface io.pravega.common.util.IndexedMap: Gets a value representing the number of Entries in this Map.
getCurrentValue() - Method in class io.pravega.common.ExponentialMovingAverage: Returns the current moving average.
getData() - Method in class io.pravega.common.io.EnhancedByteArrayOutputStream: Returns a readonly ByteArraySegment wrapping the current buffer of the ByteArrayOutputStream.
getData() - Method in class io.pravega.common.io.FixedByteArrayOutputStream: Returns a readonly ByteArraySegment wrapping this Stream's buffer.
getElapsed() - Method in class io.pravega.common.AbstractTimer: Gets the elapsed time.
getElapsedMillis() - Method in class io.pravega.common.AbstractTimer: Gets the elapsed time, in milliseconds.
getElapsedNanos() - Method in class io.pravega.common.AbstractTimer: Gets the elapsed time, in nanoseconds.
getElapsedNanos() - Method in class io.pravega.common.Timer
getEnum(Property<T>, Class<T>) - Method in class io.pravega.common.util.TypedProperties: Gets the value of an Enumeration property.
getException(CompletableFuture<T>) - Static method in class io.pravega.common.concurrent.Futures: If the future has failed returns the exception that caused it.
getFirst() - Method in class io.pravega.common.util.AvlTreeIndex
getFirst() - Method in class io.pravega.common.util.RedBlackTreeIndex
getFirst() - Method in interface io.pravega.common.util.SortedIndex: Gets the smallest item in the index.
getFloor(long) - Method in class io.pravega.common.util.AvlTreeIndex
getFloor(long) - Method in class io.pravega.common.util.RedBlackTreeIndex
getFloor(long) - Method in interface io.pravega.common.util.SortedIndex: Gets the largest item whose key is smaller than or equal to the given key.
getInt(Property<Integer>) - Method in class io.pravega.common.util.TypedProperties: Gets the value of an Integer property.
getKey(int) - Method in interface io.pravega.common.util.IndexedMap: Gets the Key located at the given position.
getLast() - Method in class io.pravega.common.util.AvlTreeIndex
getLast() - Method in class io.pravega.common.util.RedBlackTreeIndex
getLast() - Method in class io.pravega.common.util.SequencedItemList: Gets the last element in the list, if any.
getLast() - Method in interface io.pravega.common.util.SortedIndex: Gets the largest item in the index.
getLength() - Method in interface io.pravega.common.util.ArrayView: Gets a value representing the length of this ArrayView.
getLength() - Method in class io.pravega.common.util.ByteArraySegment
getLong(Property<Long>) - Method in class io.pravega.common.util.TypedProperties: Gets the value of a Long property.
getMapLength(int, int, int) - Method in interface io.pravega.common.io.serialization.RevisionDataOutput: Calculates the number of bytes required to serialize a Map.
getMapLength(Map<K, V>, ToIntFunction<K>, ToIntFunction<V>) - Method in interface io.pravega.common.io.serialization.RevisionDataOutput: Calculates the number of bytes required to serialize a Map.
getNext() - Method in interface io.pravega.common.util.CloseableIterator: Gets the next item in the iteration.
getReader() - Method in interface io.pravega.common.util.ArrayView: Creates an InputStream that can be used to read the contents of this ArrayView.
getReader(int, int) - Method in interface io.pravega.common.util.ArrayView: Creates an InputStream that can be used to read the contents of this ArrayView.
getReader() - Method in class io.pravega.common.util.ByteArraySegment
getReader(int, int) - Method in class io.pravega.common.util.ByteArraySegment
getRemaining() - Method in class io.pravega.common.TimeoutTimer: Calculates how much time is left of the original timeout.
getResponseCode() - Method in exception io.pravega.common.auth.AuthException
getSeed() - Static method in class io.pravega.common.hash.RandomFactory: Returns a good seed for a random number generator.
getSequenceNumber() - Method in interface io.pravega.common.util.SequencedItemList.Element: Gets a value indicating the Sequence Number for this item.
getShrinkingExecutor(int, int, String) - Static method in class io.pravega.common.concurrent.ExecutorServiceHelpers: Operates like Executors.cachedThreadPool but with a custom thread timeout and pool name.
getShutdownTimeout() - Method in class io.pravega.common.concurrent.AbstractThreadPoolService: Gets a value indicating how much to wait for the service to shut down, before failing it.
getSnapshot(ExecutorService) - Static method in class io.pravega.common.concurrent.ExecutorServiceHelpers: Gets a snapshot of the given ExecutorService.
getStopException() - Method in class io.pravega.common.concurrent.AbstractThreadPoolService: Gets a pointer to the current Stop Exception, if any is set.
getThreadFactory(String) - Static method in class io.pravega.common.concurrent.ExecutorServiceHelpers: Creates and returns a thread factory that will create threads with the given name prefix.
getThrowingException(Future<ResultT>) - Static method in class io.pravega.common.concurrent.Futures: Gets a future returning its result, or the exception that caused it to fail.
getUTFLength(String) - Method in interface io.pravega.common.io.serialization.RevisionDataOutput: Calculates the length, in bytes, of the given String as serialized by using writeUTF().
getValue(int) - Method in interface io.pravega.common.util.IndexedMap: Gets the Value located at the given position.
getWriter() - Method in class io.pravega.common.util.ByteArraySegment: Creates an OutputStream that can be used to write contents to this ByteArraySegment.

H

handleInterrupted(Exceptions.InterruptibleRun<ExceptionT>) - Static method in class io.pravega.common.Exceptions: Eliminates boilerplate code of catching and re-interrupting the thread.
handleInterrupted(Exceptions.InterruptibleCall<ExceptionT, ResultT>) - Static method in class io.pravega.common.Exceptions: Eliminates boilerplate code of catching and re-interrupting the thread.
hash(long) - Method in class io.pravega.common.hash.HashHelper
hash(String) - Method in class io.pravega.common.hash.HashHelper
HashHelper - Class in io.pravega.common.hash
hashToBucket(String, int) - Method in class io.pravega.common.hash.HashHelper
hashToBucket(UUID, int) - Method in class io.pravega.common.hash.HashHelper
hashToRange(String) - Method in class io.pravega.common.hash.HashHelper: Returns a double uniformly randomly distributed between 0 and 1 using the hash function.
hasRemaining() - Method in class io.pravega.common.TimeoutTimer: Returns true if there is time remaining.

I

identity(T) - Static method in class io.pravega.common.function.Callbacks: Identity Function.
ImmutableDate - Class in io.pravega.common.util
ImmutableDate() - Constructor for class io.pravega.common.util.ImmutableDate
ImmutableDate(long) - Constructor for class io.pravega.common.util.ImmutableDate
incrementAndGet() - Method in class io.pravega.common.lang.AtomicInt96
indefinitelyWithExpBackoff(long, int, long, Consumer<Throwable>) - Static method in class io.pravega.common.util.Retry
indefinitelyWithExpBackoff(String) - Static method in class io.pravega.common.util.Retry
indexById(Class<T>, ToIntFunction<T>) - Static method in class io.pravega.common.util.EnumHelpers: Indexes the values of the given Enum by a specified Id function.
IndexedMap<KeyType,ValueType> - Interface in io.pravega.common.util: Defines a Map that contains Key-Value pairs accessible by an index.
Int96 - Class in io.pravega.common.lang
Int96(int, long) - Constructor for class io.pravega.common.lang.Int96
InvalidPropertyValueException - Exception in io.pravega.common.util: Exception that is thrown whenever a Property Value is invalid based on what is expected.
InvalidPropertyValueException(String) - Constructor for exception io.pravega.common.util.InvalidPropertyValueException: Creates a new instance of the InvalidPropertyValueException class.
InvalidPropertyValueException(String, String) - Constructor for exception io.pravega.common.util.InvalidPropertyValueException: Creates a new instance of the InvalidPropertyValueException class.
InvalidPropertyValueException(String, String, Throwable) - Constructor for exception io.pravega.common.util.InvalidPropertyValueException: Creates a new instance of the InvalidPropertyValueException class.
invokeSafely(Consumer<T>, T, Consumer<Throwable>) - Static method in class io.pravega.common.function.Callbacks: Invokes the given Consumer with the given argument, and catches any exceptions that it may throw.
invokeSafely(BiConsumer<T1, T2>, T1, T2, Consumer<Throwable>) - Static method in class io.pravega.common.function.Callbacks: Invokes the given Consumer with the given argument, and catches any exceptions that it may throw.
io.pravega.common - package io.pravega.common
io.pravega.common.auth - package io.pravega.common.auth
io.pravega.common.concurrent - package io.pravega.common.concurrent
io.pravega.common.function - package io.pravega.common.function
io.pravega.common.hash - package io.pravega.common.hash
io.pravega.common.io - package io.pravega.common.io
io.pravega.common.io.serialization - package io.pravega.common.io.serialization
io.pravega.common.lang - package io.pravega.common.lang
io.pravega.common.util - package io.pravega.common.util
isReadOnly() - Method in class io.pravega.common.util.ByteArraySegment: Gets a value indicating whether the ByteArraySegment is read-only.
isReleased() - Method in class io.pravega.common.util.ReusableLatch: Returns whether or not release has been called and threads can call await without blocking.
isSuccessful(CompletableFuture<T>) - Static method in class io.pravega.common.concurrent.Futures: Returns true if the future is done and successful.
isTerminating(Service.State) - Static method in class io.pravega.common.concurrent.Services: Determines whether the given Service.State indicates the Service is either in the process of Stopping or already Terminated or Failed.

J

joinCollections(Collection<Type1>, Function<Type1, OutputType>, Collection<Type2>, Function<Type2, OutputType>) - Static method in class io.pravega.common.util.CollectionHelpers: Returns an unmodifiable Collection View made up of the given Collections while translating the items into a common type.
joinSets(Set<T>, Set<T>) - Static method in class io.pravega.common.util.CollectionHelpers: Returns an unmodifiable Set View made up of the given Sets.
joinSets(Set<Type1>, Function<Type1, OutputType>, Set<Type2>, Function<Type2, OutputType>) - Static method in class io.pravega.common.util.CollectionHelpers: Returns an unmodifiable Set View made up of the given Sets while translating the items into a common type.

K

key() - Method in interface io.pravega.common.util.SortedIndex.IndexEntry: Gets a value representing the key of the entry.
keysAllOfWithResults(Map<CompletableFuture<K>, V>) - Static method in class io.pravega.common.concurrent.Futures: Similar to CompletableFuture.allOf(varargs), but that works on a Map and that returns another Map which has the results of the given CompletableFutures, with the same input keys.

L

length(int) - Method in interface io.pravega.common.io.serialization.RevisionDataOutput: If requiresExplicitLength() == true, this method will write 4 bytes at the current position representing the expected serialization length (via the argument).
LoggerHelpers - Class in io.pravega.common: Extension methods for Logger class.
LoggerHelpers() - Constructor for class io.pravega.common.LoggerHelpers
loop(Supplier<Boolean>, Supplier<CompletableFuture<Void>>, Executor) - Static method in class io.pravega.common.concurrent.Futures: Executes a loop using CompletableFutures, without invoking join()/get() on any of them or exclusively hogging a thread.
loop(Supplier<Boolean>, Supplier<CompletableFuture<T>>, Consumer<T>, Executor) - Static method in class io.pravega.common.concurrent.Futures: Executes a loop using CompletableFutures, without invoking join()/get() on any of them or exclusively hogging a thread.

M

mapToString(Map<K, V>) - Static method in class io.pravega.common.util.ToStringUtils: Transforms a map into a string of the from: "K1=V1, K2=V2, K3=V3" Where the string versions of the key and value are derived from their toString() function.
MathHelpers - Class in io.pravega.common
MathHelpers() - Constructor for class io.pravega.common.MathHelpers
minMax(int, int, int) - Static method in class io.pravega.common.MathHelpers
minMax(long, long, long) - Static method in class io.pravega.common.MathHelpers
minMax(double, double, double) - Static method in class io.pravega.common.MathHelpers
MissingPropertyException - Exception in io.pravega.common.util: Exception that is thrown whenever a required Configuration Property is Missing.
MissingPropertyException(String) - Constructor for exception io.pravega.common.util.MissingPropertyException: Creates a new instance of the MissingPropertyException class.
MultiType() - Constructor for class io.pravega.common.io.serialization.VersionedSerializer.MultiType: Creates a new instance of the MultiType class.
mustRethrow(Throwable) - Static method in class io.pravega.common.Exceptions: Determines if the given Throwable represents a fatal exception and cannot be handled.

N

named(String) - Static method in class io.pravega.common.util.Property: Creates a new instance of the Property class with no default value.
named(String, T) - Static method in class io.pravega.common.util.Property: Creates a new instance of the Property class with the given default value.
NANOS_TO_MILLIS - Static variable in class io.pravega.common.AbstractTimer
newBuilder() - Method in class io.pravega.common.io.serialization.VersionedSerializer.WithBuilder: When implemented in a derived class, this method will return a new instance of the Builder each time it is invoked.
NewestReference<T extends java.lang.Comparable<T>> - Class in io.pravega.common.concurrent: Keeps the largest value in a thread safe way.
NewestReference() - Constructor for class io.pravega.common.concurrent.NewestReference
newScheduledThreadPool(int, String) - Static method in class io.pravega.common.concurrent.ExecutorServiceHelpers: Creates a new ScheduledExecutorService that will use daemon threads with appropriate names the threads.
NONE - Static variable in class io.pravega.common.concurrent.CancellationToken: A CancellationToken that can be used as a placeholder for "no token to pass".

O

ObjectBuilder<T> - Interface in io.pravega.common: Defines an object that can build other objects.
ObjectClosedException - Exception in io.pravega.common: Thrown when an object has been closed via AutoCloseable.close().
ObjectClosedException(Object) - Constructor for exception io.pravega.common.ObjectClosedException
ObjectClosedException(Object, Throwable) - Constructor for exception io.pravega.common.ObjectClosedException
onStop(Service, Runnable, Consumer<Throwable>, Executor) - Static method in class io.pravega.common.concurrent.Services: Attaches the given callbacks which will be invoked when the given Service enters a TERMINATED or FAILED state.
onTimeout(CompletableFuture<T>, Consumer<TimeoutException>) - Static method in class io.pravega.common.concurrent.Futures: Attaches the given callback as an exception listener to the given CompletableFuture, which will be invoked when the future times out (fails with a TimeoutException).
OrderedItemProcessor<ItemType,ResultType> - Class in io.pravega.common.util: Processes items in order, subject to capacity constraints.
OrderedItemProcessor(int, Function<ItemType, CompletableFuture<ResultType>>, Executor) - Constructor for class io.pravega.common.util.OrderedItemProcessor: Creates a new instance of the OrderedItemProcessor class.
OrderedItemProcessor.ProcessingException - Exception in io.pravega.common.util

P

parse(String) - Method in class io.pravega.common.util.DelimitedStringParser: Parses the given string using the configuration set on this parser.
parser(String, String) - Static method in class io.pravega.common.util.DelimitedStringParser: Creates a new DelimitedStringParser with the given Pair and KeyValue delimiters.
poll(int) - Method in class io.pravega.common.util.BlockingDrainingQueue: Returns the next items from the queue, if any.
process(ItemType) - Method in class io.pravega.common.util.OrderedItemProcessor: Processes the given item.
ProcessStarter - Class in io.pravega.common.lang: Helps start a Class out of Process.
Property<T> - Class in io.pravega.common.util: Represents a Property that can be used for configuration.
Property() - Constructor for class io.pravega.common.util.Property
put(K, V, Duration) - Method in interface io.pravega.common.util.AsyncMap: Inserts a new Key-Value pair into the map.
put(V) - Method in class io.pravega.common.util.AvlTreeIndex
put(V) - Method in class io.pravega.common.util.RedBlackTreeIndex
put(V) - Method in interface io.pravega.common.util.SortedIndex: Inserts the given item into the Index.

R

RandomAccessOutputStream - Interface in io.pravega.common.io.serialization: Defines an extension to OutputStream that allows writing to an arbitrary position.
RandomFactory - Class in io.pravega.common.hash: Acts as a constructor for java.util.Random objects.
RandomFactory() - Constructor for class io.pravega.common.hash.RandomFactory
read() - Method in class io.pravega.common.io.BoundedInputStream
read(byte[], int, int) - Method in class io.pravega.common.io.BoundedInputStream
read(ByteBuffer) - Method in class io.pravega.common.util.CircularBuffer: Copies into the given ByteBuffer.
read(long, int) - Method in class io.pravega.common.util.SequencedItemList: Reads a number of items starting with the first one that has a Sequence Number higher than the given one.
readAll(InputStream, byte[], int, int) - Static method in class io.pravega.common.io.StreamHelpers: Reads at most 'maxLength' bytes from the given input stream, as long as the stream still has data to serve.
readAll(InputStream, int) - Static method in class io.pravega.common.io.StreamHelpers: Reads a number of bytes from the given InputStream and returns it as the given byte array.
readArray(RevisionDataInput.ElementDeserializer<T>, IntFunction<T[]>) - Method in interface io.pravega.common.io.serialization.RevisionDataInput: Decodes a specific array that has been serialized using RevisionDataOutput.writeArray(T[], ElementSerializer).
readArray() - Method in interface io.pravega.common.io.serialization.RevisionDataInput: Decodes a byte array that has been serialized using RevisionDataOutput.writeArray(byte[]).
readCollection(RevisionDataInput.ElementDeserializer<T>) - Method in interface io.pravega.common.io.serialization.RevisionDataInput: Decodes a generic Collection that has been serialized using RevisionDataOutput.writeCollection().
readCollection(RevisionDataInput.ElementDeserializer<T>, Supplier<C>) - Method in interface io.pravega.common.io.serialization.RevisionDataInput: Decodes a specific Collection that has been serialized using RevisionDataOutput.writeCollection().
readCompactInt() - Method in interface io.pravega.common.io.serialization.RevisionDataInput: Decodes an Integer that has been serialized using RevisionDataOutput.writeCompactInt().
readCompactLong() - Method in interface io.pravega.common.io.serialization.RevisionDataInput: Decodes a Long that has been serialized using RevisionDataOutput.writeCompactLong().
readFrom(InputStream) - Method in class io.pravega.common.util.ByteArraySegment: Attempts to read the contents of the InputStream and load it into this ByteArraySegment.
readInt(byte[], int) - Static method in class io.pravega.common.util.BitConverter: Reads a 32-bit integer from the given byte array starting at the given position.
readInt(ArrayView, int) - Static method in class io.pravega.common.util.BitConverter: Reads a 32-bit integer from the given ArrayView starting at the given position.
readInt(InputStream) - Static method in class io.pravega.common.util.BitConverter: Reads a 32-bit integer from the given InputStream that was encoded using BitConverter.writeInt.
readLong(ArrayView, int) - Static method in class io.pravega.common.util.BitConverter: Reads a 64-bit long from the given ArrayView starting at the given position.
readLong(byte[], int) - Static method in class io.pravega.common.util.BitConverter: Reads a 64-bit long from the given byte array starting at the given position.
readMap(RevisionDataInput.ElementDeserializer<K>, RevisionDataInput.ElementDeserializer<V>) - Method in interface io.pravega.common.io.serialization.RevisionDataInput: Decodes a generic Map that has been serialized using RevisionDataOutput.writeMap().
readMap(RevisionDataInput.ElementDeserializer<K>, RevisionDataInput.ElementDeserializer<V>, Supplier<M>) - Method in interface io.pravega.common.io.serialization.RevisionDataInput: Decodes a specific Map that has been serialized using RevisionDataOutput.writeMap().
readUUID() - Method in interface io.pravega.common.io.serialization.RevisionDataInput: Decodes a UUID that has been serialized using RevisionDataOutput.writeUUID().
rebase(Properties) - Method in class io.pravega.common.util.ConfigBuilder: Creates a new instance of the ConfigBuilder class that uses the given java.util.Properties object as a base.
RedBlackTreeIndex<V extends SortedIndex.IndexEntry> - Class in io.pravega.common.util: SortedIndex backed by a Red-Black Tree (java.util.TreeMap).
RedBlackTreeIndex() - Constructor for class io.pravega.common.util.RedBlackTreeIndex: Creates a new instance of the RedBlackTreeIndex class.
register(CompletableFuture<T>) - Method in class io.pravega.common.concurrent.CancellationToken: Registers the given Future to the token.
register(CompletableFuture<T>) - Method in class io.pravega.common.util.ReusableFutureLatch: Supply a future to be notified when ReusableFutureLatch.release(Object) is called.
registerAndRunReleaser(Runnable, CompletableFuture<T>) - Method in class io.pravega.common.util.ReusableFutureLatch: If the latch is released, completes the provided future without invoking the provided runnable.
release(T) - Method in class io.pravega.common.util.ReusableFutureLatch: Complete all waiting futures, and all future calls to register be notified immediately.
release() - Method in class io.pravega.common.util.ReusableLatch: Allow all waiting threads to go through, and all future threads to proceed without blocking.
releaseExceptionally(Throwable) - Method in class io.pravega.common.util.ReusableFutureLatch: Complete all waiting futures, and all future calls to register be notified immediately.
releaseExceptionallyAndReset(Throwable) - Method in class io.pravega.common.util.ReusableFutureLatch: Identical to calling #releaseExceptionally(Exception); #reset() except it is atomic.
remove(K, Duration) - Method in interface io.pravega.common.util.AsyncMap: Deletes a Key-Value pair from the Map, if any.
remove(long) - Method in class io.pravega.common.util.AvlTreeIndex
remove(long) - Method in class io.pravega.common.util.RedBlackTreeIndex
remove(long) - Method in interface io.pravega.common.util.SortedIndex: Removes any item with the given key from the Index.
requestCancellation() - Method in class io.pravega.common.concurrent.CancellationToken: Cancels all registered futures.
requiresExplicitLength() - Method in interface io.pravega.common.io.serialization.RevisionDataOutput: Gets a value indicating whether this instance of a RevisionDataOutput requires length() to be called prior to writing anything to it.
reset() - Method in class io.pravega.common.SimpleMovingAverage: Clears the SimpleMovingAverage of any data.
reset(Duration) - Method in class io.pravega.common.TimeoutTimer: Reset the timeout so that the original amount of time is remaining.
reset() - Method in class io.pravega.common.util.ReusableFutureLatch: If ReusableFutureLatch.release(Object) or #releaseExceptionally(Exception) has been called it resets the object into the unreleased state.
reset() - Method in class io.pravega.common.util.ReusableLatch: Resets the latch to an un-release state.
RetriesExhaustedException - Exception in io.pravega.common.util: Exception thrown by Retry utility class when all of the configured number of attempts have failed.
RetriesExhaustedException(Throwable) - Constructor for exception io.pravega.common.util.RetriesExhaustedException
Retry - Class in io.pravega.common.util: A Utility class to support retrying something that can fail with exponential backoff.
Retry.Retryable<ReturnT,RetryableET extends java.lang.Exception,NonRetryableET extends java.lang.Exception> - Interface in io.pravega.common.util
Retry.RetryAndThrowBase<ThrowsT extends java.lang.Exception> - Class in io.pravega.common.util
Retry.RetryAndThrowConditionally - Class in io.pravega.common.util: Returned by Retry.RetryExceptionally.throwingOn(Class) to add the type of exception that should cause the method to throw right away.
Retry.RetryAndThrowExceptionally<RetryT extends java.lang.Exception,ThrowsT extends java.lang.Exception> - Class in io.pravega.common.util: Returned by Retry.RetryExceptionally.throwingOn(Class) to add the type of exception that should cause the method to throw right away.
Retry.RetryExceptionally<RetryT extends java.lang.Exception> - Class in io.pravega.common.util: Returned by Retry.RetryWithBackoff.retryingOn(Class) to add the type of exception that should result in a retry.
Retry.RetryUnconditionally - Class in io.pravega.common.util: Returned by Retry.indefinitelyWithExpBackoff(long, int, long, Consumer) (Class)} to retry indefinitely.
Retry.RetryWithBackoff - Class in io.pravega.common.util: Returned by Retry.withExpBackoff(long, int, int) to set the retry schedule.
retryingOn(Class<RetryT>) - Method in class io.pravega.common.util.Retry.RetryWithBackoff
retryWhen(Predicate<Throwable>) - Method in class io.pravega.common.util.Retry.RetryWithBackoff
ReusableFutureLatch<T> - Class in io.pravega.common.util: This class is similar to ReusableLatch but that works with CompletableFuture so that blocking can be async and exceptions and results can be passed.
ReusableFutureLatch() - Constructor for class io.pravega.common.util.ReusableFutureLatch
ReusableLatch - Class in io.pravega.common.util: This class is similar to CountDownLatch and Semaphore.
ReusableLatch() - Constructor for class io.pravega.common.util.ReusableLatch
ReusableLatch(boolean) - Constructor for class io.pravega.common.util.ReusableLatch
revision(int, VersionedSerializer.StreamWriter<TargetType>, VersionedSerializer.StreamReader<ReaderType>) - Method in class io.pravega.common.io.serialization.VersionedSerializer.FormatVersion: Creates a new Revision and registers it.
RevisionDataInput - Interface in io.pravega.common.io.serialization: Extension to DataInput that adds support for a few new constructs.
RevisionDataInput.ElementDeserializer<T> - Interface in io.pravega.common.io.serialization: Defines a Function signature that can deserialize an element from a RevisionDataInput.
RevisionDataOutput - Interface in io.pravega.common.io.serialization: Extension to DataOutput that adds support for a few new constructs and supports formatting a Serialization Revision.
RevisionDataOutput.ElementSerializer<T> - Interface in io.pravega.common.io.serialization: Defines a Function signature that can serialize an element to a RevisionDataOutput.
run() - Method in interface io.pravega.common.Exceptions.InterruptibleRun
run() - Method in interface io.pravega.common.function.RunnableWithException
run(Retry.Retryable<ReturnT, RetryT, ThrowsT>) - Method in class io.pravega.common.util.Retry.RetryAndThrowBase
runAsync() - Method in class io.pravega.common.concurrent.SequentialAsyncProcessor: Executes one instance of the task, or queues it up at most once should the task be currently running.
runAsync(Supplier<CompletableFuture<ReturnT>>, ScheduledExecutorService) - Method in class io.pravega.common.util.Retry.RetryAndThrowBase
runInExecutor(Runnable, ScheduledExecutorService) - Method in class io.pravega.common.util.Retry.RetryAndThrowBase
RunnableWithException - Interface in io.pravega.common.function: Functional interface for a runnable with no result that may throw an Exception.
runOrFail(Callable<R>, CompletableFuture<T>) - Static method in class io.pravega.common.concurrent.Futures: Runs the provided Callable in the current thread (synchronously) if it throws any Exception or Throwable the exception is propagated, but the supplied future is also failed.

S

seededWith(String) - Static method in class io.pravega.common.hash.HashHelper
SequencedItemList<T extends SequencedItemList.Element> - Class in io.pravega.common.util: Represents a List that can append only on one end and can truncate from the other, which provides random reads.
SequencedItemList() - Constructor for class io.pravega.common.util.SequencedItemList: Creates a new instance of the TruncateableList class.
SequencedItemList.Element - Interface in io.pravega.common.util: Defines an Element that can be added to a SequencedItemList.
SequentialAsyncProcessor - Class in io.pravega.common.concurrent: An Executor extension that runs the same task asynchronously, but never concurrently.
SequentialAsyncProcessor(Runnable, Retry.RetryAndThrowBase<? extends Throwable>, Consumer<Throwable>, ScheduledExecutorService) - Constructor for class io.pravega.common.concurrent.SequentialAsyncProcessor: Region Constructor.
SerializationException - Exception in io.pravega.common.io: An exception that is thrown when serialization or deserialization fails.
SerializationException(String) - Constructor for exception io.pravega.common.io.SerializationException: Creates a new instance of the SerializationException class.
SerializationException(String, Throwable) - Constructor for exception io.pravega.common.io.SerializationException: Creates a new instance of the SerializationException class.
serialize(OutputStream, BaseType) - Method in class io.pravega.common.io.serialization.VersionedSerializer.MultiType
serialize(RevisionDataOutput, T) - Method in class io.pravega.common.io.serialization.VersionedSerializer: Serializes the given object to the given RevisionDataOutput.
serialize(T) - Method in class io.pravega.common.io.serialization.VersionedSerializer: Serializes the given object to an in-memory buffer (RandomAccessOutputStream) and returns a view of it.
serialize(OutputStream, T) - Method in class io.pravega.common.io.serialization.VersionedSerializer: Serializes the given object to the given OutputStream.
serializer(Class<TargetType>, int, VersionedSerializer.WithBuilder<TargetType, ReaderType>) - Method in class io.pravega.common.io.serialization.VersionedSerializer.MultiType.Builder: Registers a new serializer for the given class.
Services - Class in io.pravega.common.concurrent: Helper methods that allow controlling Services.
Services() - Constructor for class io.pravega.common.concurrent.Services
set(int, long) - Method in class io.pravega.common.lang.AtomicInt96
set(int, byte) - Method in class io.pravega.common.util.ByteArraySegment: Sets the value at the specified index.
shouldUnwrap(Class<? extends Exception>) - Static method in class io.pravega.common.Exceptions: Returns true if the provided class is CompletionException or ExecutionException which need to be unwrapped.
shutdown(ExecutorService...) - Static method in class io.pravega.common.concurrent.ExecutorServiceHelpers: Shuts down the given ExecutorServices in two phases, using a timeout of 5 seconds: 1.
shutdown(Duration, ExecutorService...) - Static method in class io.pravega.common.concurrent.ExecutorServiceHelpers: Shuts down the given ExecutorServices in two phases: 1.
SimpleMovingAverage - Class in io.pravega.common: Helps calculate simple moving averages for a number of values.
SimpleMovingAverage(int) - Constructor for class io.pravega.common.SimpleMovingAverage: Creates a new instance of the SimpleMovingAverage class.
size() - Method in class io.pravega.common.io.FixedByteArrayOutputStream
size() - Method in interface io.pravega.common.io.serialization.RandomAccessOutputStream: Gets a value indicating the size of this OutputStream.
size() - Method in class io.pravega.common.util.AvlTreeIndex
size() - Method in class io.pravega.common.util.BlockingDrainingQueue: Gets a value indicating the size of this queue.
size() - Method in class io.pravega.common.util.RedBlackTreeIndex
size() - Method in interface io.pravega.common.util.SortedIndex: Gets a value indicating the number of items in the Index.
skip(long) - Method in class io.pravega.common.io.BoundedInputStream
slice(ByteBuffer, int, int) - Static method in class io.pravega.common.util.ByteBufferUtils
Snapshot() - Constructor for class io.pravega.common.concurrent.ExecutorServiceHelpers.Snapshot
SortedIndex<V extends SortedIndex.IndexEntry> - Interface in io.pravega.common.util: Defines an Index that orders its IndexEntries by an Int64 (long) Key.
SortedIndex.IndexEntry - Interface in io.pravega.common.util: Defines a generic entry into an Index.
start() - Method in class io.pravega.common.lang.ProcessStarter: Executes the Class using the accumulated options.
startAsync(Service, Executor) - Static method in class io.pravega.common.concurrent.Services: Asynchronously starts a Service and returns a CompletableFuture that will indicate when it is running.
stdErr(ProcessBuilder.Redirect) - Method in class io.pravega.common.lang.ProcessStarter: Redirects the Standard Err of the Process to the given Redirect.
stdIn(ProcessBuilder.Redirect) - Method in class io.pravega.common.lang.ProcessStarter: Redirects the Standard In of the Process to the given Redirect.
stdOut(ProcessBuilder.Redirect) - Method in class io.pravega.common.lang.ProcessStarter: Redirects the Standard Out of the Process to the given Redirect.
stopAsync(Service, Executor) - Static method in class io.pravega.common.concurrent.Services: Asynchronously stops a Service and returns a CompletableFuture that will indicate when it is stopped.
StreamHelpers - Class in io.pravega.common.io: Miscellaneous operations on Streams.
StreamHelpers() - Constructor for class io.pravega.common.io.StreamHelpers
stringToMap(String, Function<String, K>, Function<String, V>) - Static method in class io.pravega.common.util.ToStringUtils: Performs the reverse of ToStringUtils.mapToString(Map).
subSegment(int, int) - Method in class io.pravega.common.util.ByteArraySegment: Returns a new ByteArraySegment that is a sub-segment of this ByteArraySegment.
subSegment(int, int, boolean) - Method in class io.pravega.common.util.ByteArraySegment: Returns a new ByteArraySegment that is a sub-segment of this ByteArraySegment.
subStream(int) - Method in class io.pravega.common.io.BoundedInputStream: Creates a new BoundedInputStream wrapping the same InputStream as this one, starting at the current position, with the given bound.
subStream(int, int) - Method in class io.pravega.common.io.EnhancedByteArrayOutputStream
subStream(int, int) - Method in class io.pravega.common.io.FixedByteArrayOutputStream
subStream(int, int) - Method in interface io.pravega.common.io.serialization.RandomAccessOutputStream: Creates a new fixed-size OutputStream starting at the given position in this OutputStream and of the given length.
sysProp(String, Object) - Method in class io.pravega.common.lang.ProcessStarter: Includes the given System Property as part of the start.

T

take(int) - Method in class io.pravega.common.util.BlockingDrainingQueue: Returns the next items from the queue.
throwingOn(Class<ThrowsT>) - Method in class io.pravega.common.util.Retry.RetryExceptionally
TimeoutTimer - Class in io.pravega.common: Helps figuring out how much time is left from a particular (initial) timeout.
TimeoutTimer(Duration) - Constructor for class io.pravega.common.TimeoutTimer: Creates a new instance of the TimeoutTimer class.
TimeoutTimer(Duration, Supplier<Long>) - Constructor for class io.pravega.common.TimeoutTimer: Creates a new instance of the TimeoutTimer class.
Timer - Class in io.pravega.common: Allows easy measurement of elapsed time.
Timer() - Constructor for class io.pravega.common.Timer: Creates a new instance of the Timer class.
toBytes() - Method in class io.pravega.common.lang.Int96
toString() - Method in class io.pravega.common.AbstractTimer
toString() - Method in class io.pravega.common.concurrent.CancellationToken
toString() - Method in class io.pravega.common.ExponentialMovingAverage
toString() - Method in class io.pravega.common.util.CircularBuffer
toString() - Method in class io.pravega.common.util.Property
toString() - Method in class io.pravega.common.util.ReusableFutureLatch
toString() - Method in class io.pravega.common.util.ReusableLatch
ToStringUtils - Class in io.pravega.common.util
ToStringUtils() - Constructor for class io.pravega.common.util.ToStringUtils
toUUID(String) - Method in class io.pravega.common.hash.HashHelper
toVoid(CompletableFuture<T>) - Static method in class io.pravega.common.concurrent.Futures: Returns a CompletableFuture that will end when the given future ends, but discards its result.
toVoidExpecting(CompletableFuture<T>, T, Supplier<E>) - Static method in class io.pravega.common.concurrent.Futures: Returns a CompletableFuture that will end when the given future ends, expecting a certain result.
traceEnter(Logger, String, Object...) - Static method in class io.pravega.common.LoggerHelpers: Traces the fact that a method entry has occurred.
traceEnterWithContext(Logger, String, String, Object...) - Static method in class io.pravega.common.LoggerHelpers: Traces the fact that a method entry has occurred.
traceLeave(Logger, String, long, Object...) - Static method in class io.pravega.common.LoggerHelpers: Traces the fact that a method has exited normally.
traceLeave(Logger, String, String, long, Object...) - Static method in class io.pravega.common.LoggerHelpers: Traces the fact that a method has exited normally.
traceObjectId - Variable in class io.pravega.common.concurrent.AbstractThreadPoolService
truncate(long) - Method in class io.pravega.common.util.SequencedItemList: Truncates items from the beginning of the list up to, and including, the element with the given Sequence Number.
TypedProperties - Class in io.pravega.common.util: * Wrapper for a java.util.Properties object, that sections it based on a namespace.
TypedProperties(Properties, String) - Constructor for class io.pravega.common.util.TypedProperties: Creates a new instance of the TypedProperties class.

U

unwrap(Throwable) - Static method in class io.pravega.common.Exceptions: If the provided exception is a CompletionException or ExecutionException which need be unwrapped.
update(T) - Method in class io.pravega.common.concurrent.NewestReference
UUID_BYTES - Static variable in interface io.pravega.common.io.serialization.RevisionDataOutput: The number of bytes required to encode a UUID.

V

VersionedSerializer<T> - Class in io.pravega.common.io.serialization: Custom serializer base class that supports backward and forward compatibility.
VersionedSerializer() - Constructor for class io.pravega.common.io.serialization.VersionedSerializer
VersionedSerializer.Direct<TargetType> - Class in io.pravega.common.io.serialization: A Single-Type VersionedDeserializer that serializes and deserializes into the same object.
VersionedSerializer.FormatVersion<TargetType,ReaderType> - Class in io.pravega.common.io.serialization: Represents a Version of a Format.
VersionedSerializer.MultiType<BaseType> - Class in io.pravega.common.io.serialization: A VersionedDeserializer that serializes deserializes objects instantiating different types that inherit from a single base type.
VersionedSerializer.MultiType.Builder - Class in io.pravega.common.io.serialization
VersionedSerializer.StreamReader<ReaderType> - Interface in io.pravega.common.io.serialization: Defines a Function that deserializes data from a RevisionDataInput into a target Object.
VersionedSerializer.StreamWriter<TargetType> - Interface in io.pravega.common.io.serialization: Defines a Function that serializes an Object to a RevisionDataOutput.
VersionedSerializer.WithBuilder<TargetType,ReaderType extends ObjectBuilder<TargetType>> - Class in io.pravega.common.io.serialization: A Single-Type VersionedDeserializer that deserializes into a "Builder" object.

W

with(Property<V>, V) - Method in class io.pravega.common.util.ConfigBuilder: Includes the given property and its value in the builder.
WithBuilder() - Constructor for class io.pravega.common.io.serialization.VersionedSerializer.WithBuilder
withExpBackoff(long, int, int) - Static method in class io.pravega.common.util.Retry
withExpBackoff(long, int, int, long) - Static method in class io.pravega.common.util.Retry
withUnsafe(Property<?>, Object) - Method in class io.pravega.common.util.ConfigBuilder: Includes the given property and its value in the builder, without Property-Value type-enforcement.
write(byte[]) - Method in class io.pravega.common.io.EnhancedByteArrayOutputStream
write(int, int) - Method in class io.pravega.common.io.EnhancedByteArrayOutputStream
write(byte[], int, int, int) - Method in class io.pravega.common.io.EnhancedByteArrayOutputStream
write(int) - Method in class io.pravega.common.io.FixedByteArrayOutputStream
write(int, int) - Method in class io.pravega.common.io.FixedByteArrayOutputStream
write(byte[], int, int, int) - Method in class io.pravega.common.io.FixedByteArrayOutputStream
write(int, int) - Method in interface io.pravega.common.io.serialization.RandomAccessOutputStream: Writes the given byte value at the given position.
write(byte[], int, int, int) - Method in interface io.pravega.common.io.serialization.RandomAccessOutputStream: Writes a sequence of bytes at the given position.
writeArray(T[], RevisionDataOutput.ElementSerializer<T>) - Method in interface io.pravega.common.io.serialization.RevisionDataOutput: Serializes the given array using the given ElementSerializer.
writeArray(byte[]) - Method in interface io.pravega.common.io.serialization.RevisionDataOutput: Serializes the given byte array.
writeArray(ByteArraySegment) - Method in interface io.pravega.common.io.serialization.RevisionDataOutput: Serializes the given byte array segment.
writeArray(byte[], int, int) - Method in interface io.pravega.common.io.serialization.RevisionDataOutput: Serializes the given byte array.
writeCollection(Collection<T>, RevisionDataOutput.ElementSerializer<T>) - Method in interface io.pravega.common.io.serialization.RevisionDataOutput: Serializes the given Collection using the given ElementSerializer.
writeCompactInt(int) - Method in interface io.pravega.common.io.serialization.RevisionDataOutput: Encodes the given Integer into a compact serialization of 1, 2, 3 or 4 bytes.
writeCompactLong(long) - Method in interface io.pravega.common.io.serialization.RevisionDataOutput: Encodes the given Long into a compact serialization of 1, 2, 4 or 8 bytes.
writeInt(ArrayView, int, int) - Static method in class io.pravega.common.util.BitConverter: Writes the given 32-bit Integer to the given ArrayView at the given offset.
writeInt(byte[], int, int) - Static method in class io.pravega.common.util.BitConverter: Writes the given 32-bit Integer to the given byte array at the given offset.
writeInt(OutputStream, int) - Static method in class io.pravega.common.util.BitConverter: Writes the given 32-bit Integer to the given OutputStream.
writeLong(ArrayView, int, long) - Static method in class io.pravega.common.util.BitConverter: Writes the given 64-bit Long to the given ArrayView at the given offset.
writeLong(byte[], int, long) - Static method in class io.pravega.common.util.BitConverter: Writes the given 64-bit Long to the given byte array at the given offset.
writeMap(Map<K, V>, RevisionDataOutput.ElementSerializer<K>, RevisionDataOutput.ElementSerializer<V>) - Method in interface io.pravega.common.io.serialization.RevisionDataOutput: Serializes the given Map using the given ElementSerializers (one for Key and one for Value).
writeTo(OutputStream) - Method in class io.pravega.common.util.ByteArraySegment: Writes the entire contents of this ByteArraySegment to the given OutputStream.
writeUUID(UUID) - Method in interface io.pravega.common.io.serialization.RevisionDataOutput: Serializes the given UUID as two consecutive Long values.

Z

ZERO - Static variable in class io.pravega.common.lang.Int96
zero() - Method in class io.pravega.common.TimeoutTimer: Adjust the time so that the is no time remaining.

A B C D E F G H I J K L M N O P R S T U V W Z