- AbstractDatasetConfiguration - Class in com.terracottatech.store.configuration
-
- AbstractDatasetConfiguration(String, String, Map<CellDefinition<?>, IndexSettings>, Integer, DiskDurability, PersistentStorageType) - Constructor for class com.terracottatech.store.configuration.AbstractDatasetConfiguration
-
- AbstractRecord<K extends java.lang.Comparable<K>> - Class in com.terracottatech.store
-
A useful partial implementation of
Record
.
- AbstractRecord() - Constructor for class com.terracottatech.store.AbstractRecord
-
- acceptEither(CompletionStage<? extends T>, Consumer<? super T>) - Method in interface com.terracottatech.store.async.Operation
-
- acceptEitherAsync(CompletionStage<? extends T>, Consumer<? super T>, Executor) - Method in interface com.terracottatech.store.async.Operation
-
- acceptEitherAsync(CompletionStage<? extends T>, Consumer<? super T>) - Method in interface com.terracottatech.store.async.Operation
-
- acquireRole(String, Duration) - Method in interface com.terracottatech.store.coordination.Coordinator
-
Try to acquire the given role within the supplied time.
- add(Cell<?>) - Method in class com.terracottatech.store.AbstractRecord
-
- add(K, Cell<?>...) - Method in interface com.terracottatech.store.async.AsyncDatasetWriterReader
-
- add(K, Iterable<Cell<?>>) - Method in interface com.terracottatech.store.async.AsyncDatasetWriterReader
-
- add(Function<? super Record<K>, T>, Cell<?>...) - Method in interface com.terracottatech.store.async.AsyncReadWriteRecordAccessor
-
- add(Function<? super Record<K>, T>, Iterable<Cell<?>>) - Method in interface com.terracottatech.store.async.AsyncReadWriteRecordAccessor
-
- add(Cell<?>...) - Method in interface com.terracottatech.store.async.AsyncReadWriteRecordAccessor
-
- add(Iterable<Cell<?>>) - Method in interface com.terracottatech.store.async.AsyncReadWriteRecordAccessor
-
- add(Cell<?>) - Method in class com.terracottatech.store.CellSet
-
Adds the specified Cell
to this set if a cell having the same cell name is not already present.
- add(K, Cell<?>...) - Method in interface com.terracottatech.store.DatasetWriterReader
-
Creates a record for the specified key.
- add(K, Iterable<Cell<?>>) - Method in interface com.terracottatech.store.DatasetWriterReader
-
Creates a record for the specified key.
- add(double) - Method in interface com.terracottatech.store.function.BuildableToDoubleFunction
-
Returns a function that calculates the sum of operand
and
this
.
- add(int) - Method in interface com.terracottatech.store.function.BuildableToIntFunction
-
Returns a function that calculates the sum of operand
and
this
.
- add(long) - Method in interface com.terracottatech.store.function.BuildableToLongFunction
-
Returns a function that calculates the sum of operand
and
this
.
- add(Function<? super Record<K>, T>, Cell<?>...) - Method in interface com.terracottatech.store.ReadWriteRecordAccessor
-
Creates a record for the key that was used to create this ReadWriteRecordAccessor.
- add(Function<? super Record<K>, T>, Iterable<Cell<?>>) - Method in interface com.terracottatech.store.ReadWriteRecordAccessor
-
Creates a record for the key that was used to create this ReadWriteRecordAccessor.
- add(Cell<?>...) - Method in interface com.terracottatech.store.ReadWriteRecordAccessor
-
Creates a record for the key used to create this ReadWriteRecordAccessor.
- add(Iterable<Cell<?>>) - Method in interface com.terracottatech.store.ReadWriteRecordAccessor
-
Creates a record for the key used to create this ReadWriteRecordAccessor.
- addAll(Collection<? extends Cell<?>>) - Method in class com.terracottatech.store.AbstractRecord
-
- advanced() - Method in interface com.terracottatech.store.configuration.DatasetConfigurationBuilder
-
Access more advanced configuration options than are generally needed.
- AdvancedDatasetConfiguration - Interface in com.terracottatech.store.configuration
-
AdvancedDatasetConfiguration
- AdvancedDatasetConfigurationBuilder - Interface in com.terracottatech.store.configuration
-
Interface for advanced
dataset
configuration options.
- allMatch(DoublePredicate) - Method in interface com.terracottatech.store.async.AsyncDoubleStream
-
An asynchronous equivalent to DoubleStream.allMatch(java.util.function.DoublePredicate)
.
- allMatch(IntPredicate) - Method in interface com.terracottatech.store.async.AsyncIntStream
-
An asynchronous equivalent to IntStream.allMatch(java.util.function.IntPredicate)
.
- allMatch(LongPredicate) - Method in interface com.terracottatech.store.async.AsyncLongStream
-
An asynchronous equivalent to LongStream.allMatch(java.util.function.LongPredicate)
.
- allMatch(Predicate<? super T>) - Method in interface com.terracottatech.store.async.AsyncStream
-
An asynchronous equivalent to Stream.allMatch(java.util.function.Predicate)
.
- allOf(UpdateOperation.CellUpdateOperation<?, ?>...) - Static method in interface com.terracottatech.store.UpdateOperation
-
Creates a compound transform composed of the given individual cell mutations.
- allOf(List<? extends UpdateOperation.CellUpdateOperation<?, ?>>) - Static method in interface com.terracottatech.store.UpdateOperation
-
Creates a compound transform composed of the given individual cell mutations.
- ALWAYS - Static variable in class com.terracottatech.store.configuration.BaseDiskDurability
-
Static instance of
DiskDurability
representing disk durability
where every mutative operation is fully synced/fsynched/flushed to disk.
- and(Predicate<? super T>) - Method in interface com.terracottatech.store.function.BuildablePredicate
-
- anyMatch(DoublePredicate) - Method in interface com.terracottatech.store.async.AsyncDoubleStream
-
An asynchronous equivalent to DoubleStream.anyMatch(java.util.function.DoublePredicate)
.
- anyMatch(IntPredicate) - Method in interface com.terracottatech.store.async.AsyncIntStream
-
An asynchronous equivalent to IntStream.anyMatch(java.util.function.IntPredicate)
.
- anyMatch(LongPredicate) - Method in interface com.terracottatech.store.async.AsyncLongStream
-
An asynchronous equivalent to LongStream.anyMatch(java.util.function.LongPredicate)
.
- anyMatch(Predicate<? super T>) - Method in interface com.terracottatech.store.async.AsyncStream
-
An asynchronous equivalent to Stream.anyMatch(java.util.function.Predicate)
.
- apply(Record<K>) - Method in interface com.terracottatech.store.UpdateOperation
-
Applies this transform to the given record.
- apply(Record<K>) - Method in interface com.terracottatech.store.UpdateOperation.CellUpdateOperation
-
- applyToEither(CompletionStage<? extends T>, Function<? super T, U>) - Method in interface com.terracottatech.store.async.Operation
-
- applyToEitherAsync(CompletionStage<? extends T>, Function<? super T, U>, Executor) - Method in interface com.terracottatech.store.async.Operation
-
- applyToEitherAsync(CompletionStage<? extends T>, Function<? super T, U>) - Method in interface com.terracottatech.store.async.Operation
-
- asComparator() - Method in interface com.terracottatech.store.function.BuildableComparableFunction
-
Returns a Comparator
that orders objects using the values mapped by
this function.
- asComparator() - Method in interface com.terracottatech.store.function.BuildableToDoubleFunction
-
Returns a Comparator
that orders objects using the double values
mapped by this function.
- asComparator() - Method in interface com.terracottatech.store.function.BuildableToIntFunction
-
Returns a Comparator
that orders objects using the integer values
mapped by this function.
- asComparator() - Method in interface com.terracottatech.store.function.BuildableToLongFunction
-
Returns a Comparator
that orders objects using the double values
mapped by this function.
- asDoubleStream() - Method in interface com.terracottatech.store.async.AsyncIntStream
-
An asynchronous equivalent to IntStream.asDoubleStream()
.
- asDoubleStream() - Method in interface com.terracottatech.store.async.AsyncLongStream
-
An asynchronous equivalent to LongStream.asDoubleStream()
.
- asEnum() - Method in class com.terracottatech.store.Type
-
- asLongStream() - Method in interface com.terracottatech.store.async.AsyncIntStream
-
An asynchronous equivalent to IntStream.asLongStream()
.
- async() - Method in interface com.terracottatech.store.DatasetReader
-
Returns an asynchronous version of this reader using the ForkJoinPool.commonPool()
as an executor.
- async(Executor) - Method in interface com.terracottatech.store.DatasetReader
-
Returns an asynchronous version of this reader.
- async() - Method in interface com.terracottatech.store.DatasetWriterReader
-
Returns an asynchronous version of this writer-reader using the ForkJoinPool.commonPool()
as an executor.
- async(Executor) - Method in interface com.terracottatech.store.DatasetWriterReader
-
Returns an asynchronous version of this writer-reader.
- AsyncConditionalReadRecordAccessor<K extends java.lang.Comparable<K>> - Interface in com.terracottatech.store.async
-
- AsyncConditionalReadWriteRecordAccessor<K extends java.lang.Comparable<K>> - Interface in com.terracottatech.store.async
-
- AsyncDatasetReader<K extends java.lang.Comparable<K>> - Interface in com.terracottatech.store.async
-
- AsyncDatasetWriterReader<K extends java.lang.Comparable<K>> - Interface in com.terracottatech.store.async
-
- AsyncDoubleStream - Interface in com.terracottatech.store.async
-
An asynchronous equivalent to DoubleStream
.
- AsyncIntStream - Interface in com.terracottatech.store.async
-
An asynchronous equivalent to IntStream
.
- AsyncLongStream - Interface in com.terracottatech.store.async
-
An asynchronous equivalent to LongStream
.
- AsyncMutableRecordStream<K extends java.lang.Comparable<K>> - Interface in com.terracottatech.store.async
-
- AsyncReadRecordAccessor<K extends java.lang.Comparable<K>> - Interface in com.terracottatech.store.async
-
- AsyncReadWriteRecordAccessor<K extends java.lang.Comparable<K>> - Interface in com.terracottatech.store.async
-
- AsyncRecordStream<K extends java.lang.Comparable<K>> - Interface in com.terracottatech.store.async
-
- AsyncStream<T> - Interface in com.terracottatech.store.async
-
An asynchronous equivalent to Stream
.
- average() - Method in interface com.terracottatech.store.async.AsyncDoubleStream
-
An asynchronous equivalent to DoubleStream.average()
.
- average() - Method in interface com.terracottatech.store.async.AsyncIntStream
-
An asynchronous equivalent to IntStream.average()
.
- average() - Method in interface com.terracottatech.store.async.AsyncLongStream
-
An asynchronous equivalent to LongStream.average()
.
- averagingDouble(ToDoubleFunction<? super T>) - Static method in class com.terracottatech.store.function.Collectors
-
Functionally transparent version of Collectors.averagingDouble(ToDoubleFunction)
- averagingInt(ToIntFunction<? super T>) - Static method in class com.terracottatech.store.function.Collectors
-
Functionally transparent version of Collectors.averagingInt(ToIntFunction)
- averagingLong(ToLongFunction<? super T>) - Static method in class com.terracottatech.store.function.Collectors
-
Functionally transparent version of Collectors.averagingLong(ToLongFunction)
- BaseDiskDurability - Class in com.terracottatech.store.configuration
-
- BaseDiskDurability.Timed - Class in com.terracottatech.store.configuration
-
- batch(int) - Method in interface com.terracottatech.store.stream.MutableRecordStream
-
- batch(int) - Method in interface com.terracottatech.store.stream.RecordStream
-
Returns an equivalent stream that uses the given batch size hint.
- BOOL - Static variable in class com.terracottatech.store.Type
-
The Boolean
type.
- BoolCellDefinition - Interface in com.terracottatech.store.definition
-
- boolResultOf(Predicate<Record<?>>) - Method in interface com.terracottatech.store.UpdateOperation.BoolWriteOperationBuilder
-
Creates a transform that writes a cell with the supplied definition and value derived by applying the predicate
to the existing record.
- boxed() - Method in interface com.terracottatech.store.async.AsyncDoubleStream
-
An asynchronous equivalent to DoubleStream.boxed()
.
- boxed() - Method in interface com.terracottatech.store.async.AsyncIntStream
-
An asynchronous equivalent to IntStream.boxed()
.
- boxed() - Method in interface com.terracottatech.store.async.AsyncLongStream
-
An asynchronous equivalent to LongStream.boxed()
.
- boxed() - Method in interface com.terracottatech.store.function.BuildablePredicate
-
- boxed() - Method in interface com.terracottatech.store.function.BuildableToDoubleFunction
-
- boxed() - Method in interface com.terracottatech.store.function.BuildableToIntFunction
-
- boxed() - Method in interface com.terracottatech.store.function.BuildableToLongFunction
-
- BTREE - Static variable in interface com.terracottatech.store.indexing.IndexSettings
-
Specifies a B-Tree index.
- btree() - Static method in interface com.terracottatech.store.indexing.IndexSettings
-
Creates a settings object that defines an B-Tree based ordered index.
- build() - Method in interface com.terracottatech.store.configuration.DatasetConfigurationBuilder
-
Creates the DatasetConfiguration as defined by the builder state
- build() - Method in interface com.terracottatech.store.coordination.Coordinator.Builder
-
Builds a coordinator.
- build() - Method in interface com.terracottatech.store.manager.ClusteredDatasetManagerBuilder
-
Creates the DatasetManager that has been configured using this ClusteredDatasetManagerBuilder
- build() - Method in interface com.terracottatech.store.manager.EmbeddedDatasetManagerBuilder
-
Creates the DatasetManager that has been configured using this EmbeddedDatasetManagerBuilder
- BuildableComparableFunction<T,R extends java.lang.Comparable<R>> - Interface in com.terracottatech.store.function
-
A function of one argument that generates a Comparable
result, and
supports building derived functional types.
- BuildableComparableOptionalFunction<T,R extends java.lang.Comparable<R>> - Interface in com.terracottatech.store.function
-
A function of one argument that generates an Optional<Comparable>
result, and
supports building derived functional types.
- BuildableFunction<T,R> - Interface in com.terracottatech.store.function
-
A function of one argument that supports building derived functional types.
- BuildableOptionalFunction<T,R> - Interface in com.terracottatech.store.function
-
A function of one argument that generates an Optional
result , and
supports building derived functional types.
- BuildablePredicate<T> - Interface in com.terracottatech.store.function
-
Created by cdennis on 5/24/17.
- BuildableStringFunction<T> - Interface in com.terracottatech.store.function
-
A function of one argument that generates a String
result, and
supports building derived functional types.
- BuildableStringOptionalFunction<T> - Interface in com.terracottatech.store.function
-
A function of one argument that generates an Optional<String>
result, and
supports building derived functional types.
- BuildableToDoubleFunction<T> - Interface in com.terracottatech.store.function
-
A function of one argument that generates a double
result, and
supports building derived functional types.
- BuildableToIntFunction<T> - Interface in com.terracottatech.store.function
-
A function of one argument that generates an int
result, and
supports building derived functional types.
- BuildableToLongFunction<T> - Interface in com.terracottatech.store.function
-
A function of one argument that generates a long
result, and
supports building derived functional types.
- BYTES - Static variable in class com.terracottatech.store.Type
-
The binary type.
- BytesCellDefinition - Interface in com.terracottatech.store.definition
-
- Cell<T> - Interface in com.terracottatech.store
-
A representation of a cell.
- cell(String, T) - Static method in interface com.terracottatech.store.Cell
-
Creates a new cell.
- cell() - Method in interface com.terracottatech.store.UpdateOperation.CellUpdateOperation
-
Returns the cell to be written or an empty optional to remove.
- CellCollection - Interface in com.terracottatech.store
-
- CellDefinition<T> - Interface in com.terracottatech.store.definition
-
A {name, type}
tuple that identifies a cell.
- CellDefinition.CellImpl<T> - Class in com.terracottatech.store.definition
-
- CellDefinition.Impl<T> - Class in com.terracottatech.store.definition
-
Internal interned definition implementation.
- CellSet - Class in com.terracottatech.store
-
A collection of
Cell
s having no more than one cell having a given name.
- CellSet() - Constructor for class com.terracottatech.store.CellSet
-
Creates an new, mutable empty CellSet
instance.
- CellSet(Iterable<Cell<?>>) - Constructor for class com.terracottatech.store.CellSet
-
Creates a new, mutable
CellSet
instance containing the
Cell
s from the specified
Iterable
in the order returned by the iterator.
- ChangeListener<K extends java.lang.Comparable<K>> - Interface in com.terracottatech.store
-
- ChangeType - Enum in com.terracottatech.store
-
- CHAR - Static variable in class com.terracottatech.store.Type
-
The Character
type.
- CharCellDefinition - Interface in com.terracottatech.store.definition
-
- clear() - Method in class com.terracottatech.store.AbstractRecord
-
- close() - Method in interface com.terracottatech.store.coordination.Role
-
Voluntarily relinquish role.
- close() - Method in interface com.terracottatech.store.Dataset
-
Closes the Dataset.
- close() - Method in interface com.terracottatech.store.manager.DatasetManager
-
Closes the DatasetManager.
- clustered(URI) - Static method in interface com.terracottatech.store.manager.DatasetManager
-
- clustered(Iterable<InetSocketAddress>) - Static method in interface com.terracottatech.store.manager.DatasetManager
-
- ClusteredDatasetManagerBuilder - Interface in com.terracottatech.store.manager
-
A ClusteredDatasetManagerBuilder allows configuration of the interaction with a cluster.
- collect(Supplier<R>, ObjDoubleConsumer<R>, BiConsumer<R, R>) - Method in interface com.terracottatech.store.async.AsyncDoubleStream
-
An asynchronous equivalent to DoubleStream.collect(java.util.function.Supplier, java.util.function.ObjDoubleConsumer, java.util.function.BiConsumer)
.
- collect(Supplier<R>, ObjIntConsumer<R>, BiConsumer<R, R>) - Method in interface com.terracottatech.store.async.AsyncIntStream
-
An asynchronous equivalent to IntStream.collect(java.util.function.Supplier, java.util.function.ObjIntConsumer, java.util.function.BiConsumer)
.
- collect(Supplier<R>, ObjLongConsumer<R>, BiConsumer<R, R>) - Method in interface com.terracottatech.store.async.AsyncLongStream
-
An asynchronous equivalent to LongStream.collect(java.util.function.Supplier, java.util.function.ObjLongConsumer, java.util.function.BiConsumer)
.
- collect(Supplier<R>, BiConsumer<R, ? super T>, BiConsumer<R, R>) - Method in interface com.terracottatech.store.async.AsyncStream
-
An asynchronous equivalent to Stream.collect(java.util.function.Supplier, java.util.function.BiConsumer, java.util.function.BiConsumer)
.
- collect(Collector<? super T, A, R>) - Method in interface com.terracottatech.store.async.AsyncStream
-
An asynchronous equivalent to Stream.reduce(java.util.function.BinaryOperator)
.
- Collectors - Class in com.terracottatech.store.function
-
Provides functionally transparent equivalent collectors to Collectors
.
- Collectors() - Constructor for class com.terracottatech.store.function.Collectors
-
- Collectors.VarianceType - Enum in com.terracottatech.store.function
-
The set of variance statistic types.
- com.terracottatech.store - package com.terracottatech.store
-
Contains the core data storage components of Terracotta Store.
- com.terracottatech.store.async - package com.terracottatech.store.async
-
Contains types for performing asynchronous operations on datasets.
- com.terracottatech.store.configuration - package com.terracottatech.store.configuration
-
Contains types representing dataset configurations and their associated builders.
- com.terracottatech.store.coordination - package com.terracottatech.store.coordination
-
- com.terracottatech.store.definition - package com.terracottatech.store.definition
-
Contains types representing both generic and type-specific cell definitions.
- com.terracottatech.store.function - package com.terracottatech.store.function
-
Contains a set of types that form a DSL that allows the creation of behaviorally transparent
functions.
- com.terracottatech.store.indexing - package com.terracottatech.store.indexing
-
Contains classes related to configuration-time and runtime manipulation of indexes.
- com.terracottatech.store.manager - package com.terracottatech.store.manager
-
Contains classes for the creating, retrieving and destroying datasets.
- com.terracottatech.store.stream - package com.terracottatech.store.stream
-
- ComparableCellDefinition<T extends java.lang.Comparable<T>> - Interface in com.terracottatech.store.definition
-
Definition of a comparable cell.
- composite(Collector<T, ?, ?>...) - Static method in class com.terracottatech.store.function.Collectors
-
Runs a list of Collector
s accepting elements of type U
in parallel against the same sequence of elements.
- concurrencyHint(int) - Method in interface com.terracottatech.store.configuration.AdvancedDatasetConfigurationBuilder
-
Gives a hint to the desired level of concurrency.
- ConditionalReadRecordAccessor<K extends java.lang.Comparable<K>> - Interface in com.terracottatech.store
-
A ConditionalReadRecordAccessor provides read operations on a record.
- ConditionalReadWriteRecordAccessor<K extends java.lang.Comparable<K>> - Interface in com.terracottatech.store
-
A ConditionalReadWriteRecordAccessor provides read and write transformations on a record.
- ConfigurationMode - Enum in com.terracottatech.store.manager
-
Defines whether datasets configured in
DatasetManagerConfiguration
should be validated/created
Note that while validating a dataset, only the validity of the key type will be checked.
- contains(Object) - Method in class com.terracottatech.store.CellSet
-
Returns true
if this set contains the specified Cell
or another cell having the same name.
- Coordinator - Interface in com.terracottatech.store.coordination
-
Simple tooling for coordination across a Terracotta cluster.
- Coordinator.Builder - Interface in com.terracottatech.store.coordination
-
Builder for Coordinator
instances.
- count() - Method in interface com.terracottatech.store.async.AsyncDoubleStream
-
An asynchronous equivalent to DoubleStream.count()
.
- count() - Method in interface com.terracottatech.store.async.AsyncIntStream
-
An asynchronous equivalent to IntStream.count()
.
- count() - Method in interface com.terracottatech.store.async.AsyncLongStream
-
An asynchronous equivalent to LongStream.count()
.
- count() - Method in interface com.terracottatech.store.async.AsyncStream
-
An asynchronous equivalent to Stream.count()
.
- counting() - Static method in class com.terracottatech.store.function.Collectors
-
Functionally transparent version of Collectors.counting()
- createIndex(CellDefinition<T>, IndexSettings) - Method in interface com.terracottatech.store.indexing.Indexing
-
Trigger creation of a new index using the given settings over cells of the
given definition.
- custom(Function<Record<K>, Iterable<Cell<?>>>) - Static method in interface com.terracottatech.store.UpdateOperation
-
Creates a custom transform that applies the given user supplied function.
- Dataset<K extends java.lang.Comparable<K>> - Interface in com.terracottatech.store
-
Main access point in to a Terracotta Store dataset.
- DatasetConfiguration - Interface in com.terracottatech.store.configuration
-
- datasetConfiguration() - Method in interface com.terracottatech.store.manager.DatasetManager
-
- DatasetConfigurationBuilder - Interface in com.terracottatech.store.configuration
-
- DatasetExistsException - Exception in com.terracottatech.store
-
Thrown to terminate a request to create a dataset that already exists.
- DatasetExistsException(Throwable) - Constructor for exception com.terracottatech.store.DatasetExistsException
-
- DatasetExistsException(String) - Constructor for exception com.terracottatech.store.DatasetExistsException
-
- DatasetExistsException(String, Throwable) - Constructor for exception com.terracottatech.store.DatasetExistsException
-
- DatasetInfo(Type<K>, DatasetConfiguration) - Constructor for class com.terracottatech.store.manager.DatasetManagerConfiguration.DatasetInfo
-
- DatasetKeyTypeMismatchException - Exception in com.terracottatech.store
-
Thrown when the requested dataset does not have the expected key type.
- DatasetKeyTypeMismatchException(Throwable) - Constructor for exception com.terracottatech.store.DatasetKeyTypeMismatchException
-
- DatasetKeyTypeMismatchException(String) - Constructor for exception com.terracottatech.store.DatasetKeyTypeMismatchException
-
- DatasetKeyTypeMismatchException(String, Throwable) - Constructor for exception com.terracottatech.store.DatasetKeyTypeMismatchException
-
- DatasetManager - Interface in com.terracottatech.store.manager
-
This is the entry point into the Terracotta store API.
- DatasetManagerConfiguration - Interface in com.terracottatech.store.manager
-
- DatasetManagerConfiguration.DatasetInfo<K extends java.lang.Comparable<K>> - Class in com.terracottatech.store.manager
-
- DatasetManagerConfiguration.Type - Enum in com.terracottatech.store.manager
-
- DatasetManagerConfigurationException - Exception in com.terracottatech.store.manager
-
- DatasetManagerConfigurationException(String) - Constructor for exception com.terracottatech.store.manager.DatasetManagerConfigurationException
-
- DatasetManagerConfigurationException(String, Throwable) - Constructor for exception com.terracottatech.store.manager.DatasetManagerConfigurationException
-
- DatasetManagerConfigurationParser - Interface in com.terracottatech.store.manager
-
- DatasetMissingException - Exception in com.terracottatech.store
-
Thrown to indicate a requested dataset does not exist.
- DatasetMissingException(Throwable) - Constructor for exception com.terracottatech.store.DatasetMissingException
-
- DatasetMissingException(String) - Constructor for exception com.terracottatech.store.DatasetMissingException
-
- DatasetMissingException(String, Throwable) - Constructor for exception com.terracottatech.store.DatasetMissingException
-
- DatasetReader<K extends java.lang.Comparable<K>> - Interface in com.terracottatech.store
-
Accessor that provides read only access on to a dataset.
- DatasetWriterReader<K extends java.lang.Comparable<K>> - Interface in com.terracottatech.store
-
Accessor that provides read and write access on to a dataset.
- decrement() - Method in interface com.terracottatech.store.function.BuildableToDoubleFunction
-
Returns a function that decrements this
by one.
- decrement() - Method in interface com.terracottatech.store.function.BuildableToIntFunction
-
Returns a function that decrements this
by one.
- decrement() - Method in interface com.terracottatech.store.function.BuildableToLongFunction
-
Returns a function that decrements this
by one.
- DEFAULT_CONNECTION_TIMEOUT_MS - Static variable in interface com.terracottatech.store.manager.ClusteredDatasetManagerBuilder
-
The default connection timeout in milliseconds.
- DEFAULT_RECONNECT_TIMEOUT_MS - Static variable in interface com.terracottatech.store.manager.ClusteredDatasetManagerBuilder
-
The default reconnect timeout in milliseconds.
- defaultEngine() - Static method in interface com.terracottatech.store.configuration.PersistentStorageType
-
System wide default persistent storage engine type used, if none is specified for a dataset.
- define(String, Type<T>) - Static method in interface com.terracottatech.store.definition.CellDefinition
-
Returns a cell definition with the given type
and name
.
- defineBool(String) - Static method in interface com.terracottatech.store.definition.CellDefinition
-
Returns a
boolean
cell definition with the given
name
.
- defineBytes(String) - Static method in interface com.terracottatech.store.definition.CellDefinition
-
Returns a
byte array
cell definition with the given
name
.
- defineChar(String) - Static method in interface com.terracottatech.store.definition.CellDefinition
-
Returns a
character
cell definition with the given
name
.
- defineDouble(String) - Static method in interface com.terracottatech.store.definition.CellDefinition
-
Returns a
double
cell definition with the given
name
.
- defineInt(String) - Static method in interface com.terracottatech.store.definition.CellDefinition
-
Returns an
integer
cell definition with the given
name
.
- defineLong(String) - Static method in interface com.terracottatech.store.definition.CellDefinition
-
Returns a
long
cell definition with the given
name
.
- defineString(String) - Static method in interface com.terracottatech.store.definition.CellDefinition
-
Returns a
string
cell definition with the given
name
.
- definition() - Method in interface com.terracottatech.store.Cell
-
Returns the definition for this cell.
- definition() - Method in class com.terracottatech.store.definition.CellDefinition.CellImpl
-
- definition() - Method in interface com.terracottatech.store.indexing.Index
-
- definition() - Method in interface com.terracottatech.store.UpdateOperation.CellUpdateOperation
-
Returns the cell definition modified by this transform.
- delete(Function<? super Record<K>, T>) - Method in interface com.terracottatech.store.async.AsyncConditionalReadWriteRecordAccessor
-
- delete() - Method in interface com.terracottatech.store.async.AsyncConditionalReadWriteRecordAccessor
-
- delete(K) - Method in interface com.terracottatech.store.async.AsyncDatasetWriterReader
-
- delete() - Method in interface com.terracottatech.store.async.AsyncMutableRecordStream
-
Deletes every Record
in the stream.
- delete(Function<? super Record<K>, T>) - Method in interface com.terracottatech.store.async.AsyncReadWriteRecordAccessor
-
- delete() - Method in interface com.terracottatech.store.async.AsyncReadWriteRecordAccessor
-
- delete(Function<? super Record<K>, T>) - Method in interface com.terracottatech.store.ConditionalReadWriteRecordAccessor
-
Deletes the record held against the key used to create this ConditionalReadWriteRecordAccessor,
if that record matches the predicate used to create this ConditionalReadWriteRecordAccessor.
- delete() - Method in interface com.terracottatech.store.ConditionalReadWriteRecordAccessor
-
Deletes the record held against the key used to create this ConditionalReadWriteRecordAccessor,
if that record matches the predicate used to create this ConditionalReadWriteRecordAccessor.
- delete(K) - Method in interface com.terracottatech.store.DatasetWriterReader
-
Deletes a record for the specified key.
- delete(Function<? super Record<K>, T>) - Method in interface com.terracottatech.store.ReadWriteRecordAccessor
-
Deletes a record held against the key used to create this ReadWriteRecordAccessor.
- delete() - Method in interface com.terracottatech.store.ReadWriteRecordAccessor
-
Deletes a record held against the key used to create this ReadWriteRecordAccessor.
- delete() - Method in interface com.terracottatech.store.stream.MutableRecordStream
-
Deletes every Record
in the stream.
- deleteThen() - Method in interface com.terracottatech.store.async.AsyncMutableRecordStream
-
Deletes every
Record
in the stream.
- deleteThen() - Method in interface com.terracottatech.store.stream.MutableRecordStream
-
Deletes every
Record
in the stream.
- deregisterChangeListener(ChangeListener<K>) - Method in interface com.terracottatech.store.DatasetReader
-
Deregisters a listener so that it no longer receives events
- destroyDataset(String) - Method in interface com.terracottatech.store.manager.DatasetManager
-
Permanently removes the Dataset
and all the data it contains.
- destroyIndex(Index<?>) - Method in interface com.terracottatech.store.indexing.Indexing
-
Destroy an index.
- disk(String) - Method in interface com.terracottatech.store.configuration.DatasetConfigurationBuilder
-
Set the name of the resource to use for disk storage and use/deploy the persistent storage engine configured as
system wide default.
- disk(String, PersistentStorageType) - Method in interface com.terracottatech.store.configuration.DatasetConfigurationBuilder
-
Set the name of the resource to use for disk storage and use/deploy the specified persistent storage engine type.
- disk(String, Path, EmbeddedDatasetManagerBuilder.PersistenceMode, EmbeddedDatasetManagerBuilder.FileMode) - Method in interface com.terracottatech.store.manager.EmbeddedDatasetManagerBuilder
-
Registers a location for local disk storage.
- disk(String, Path, EmbeddedDatasetManagerBuilder.FileMode) - Method in interface com.terracottatech.store.manager.EmbeddedDatasetManagerBuilder
-
Registers a location for local disk storage.
- DiskDurability - Interface in com.terracottatech.store.configuration
-
Used to specify the disk durability of a dataset.
- DiskDurability.DiskDurabilityEnum - Enum in com.terracottatech.store.configuration
-
Order is from most conservative to least conservative.
- distinct() - Method in interface com.terracottatech.store.async.AsyncDoubleStream
-
An asynchronous equivalent to DoubleStream.distinct()
.
- distinct() - Method in interface com.terracottatech.store.async.AsyncIntStream
-
An asynchronous equivalent to IntStream.distinct()
.
- distinct() - Method in interface com.terracottatech.store.async.AsyncLongStream
-
An asynchronous equivalent to LongStream.distinct()
.
- distinct() - Method in interface com.terracottatech.store.async.AsyncMutableRecordStream
-
- distinct() - Method in interface com.terracottatech.store.async.AsyncRecordStream
-
- distinct() - Method in interface com.terracottatech.store.async.AsyncStream
-
An asynchronous equivalent to Stream.distinct()
.
- distinct() - Method in interface com.terracottatech.store.stream.MutableRecordStream
-
- distinct() - Method in interface com.terracottatech.store.stream.RecordStream
- divide(double) - Method in interface com.terracottatech.store.function.BuildableToDoubleFunction
-
Returns a function that calculates the quotient of this
and
divisor
.
- divide(int) - Method in interface com.terracottatech.store.function.BuildableToIntFunction
-
Returns a function that calculates the quotient of this
and
divisor
.
- divide(long) - Method in interface com.terracottatech.store.function.BuildableToLongFunction
-
Returns a function that calculates the quotient of this
and
divisor
.
- DOUBLE - Static variable in class com.terracottatech.store.Type
-
The Double
type.
- DoubleCellDefinition - Interface in com.terracottatech.store.definition
-
- doubleResultOf(ToDoubleFunction<Record<?>>) - Method in interface com.terracottatech.store.UpdateOperation.DoubleWriteOperationBuilder
-
Creates a transform that writes a cell with the supplied definition and value derived by applying the function
to the existing record.
- doubleValueOr(double) - Method in interface com.terracottatech.store.definition.DoubleCellDefinition
-
Returns a function that extracts this cells value from a record.
- doubleValueOrFail() - Method in interface com.terracottatech.store.definition.DoubleCellDefinition
-
Returns a function that extracts this cells value from a record.
- durabilityEventual() - Method in interface com.terracottatech.store.configuration.DatasetConfigurationBuilder
-
Configure this dataset to leave durability flushing to the operating
system.
- durabilityEveryMutation() - Method in interface com.terracottatech.store.configuration.DatasetConfigurationBuilder
-
Configure this dataset to forceable push every mutative operation to disk.
- durabilityTimed(long, TimeUnit) - Method in interface com.terracottatech.store.configuration.DatasetConfigurationBuilder
-
Configure this dataset to allow a mutative change to linger unflushed
to disk for no more than the specified duration.
- embedded() - Static method in interface com.terracottatech.store.manager.DatasetManager
-
- EmbeddedDatasetManagerBuilder - Interface in com.terracottatech.store.manager
-
An EmbeddedDatasetManagerBuilder allows configuration of the interaction with embedded storage.
- EmbeddedDatasetManagerBuilder.FileMode - Enum in com.terracottatech.store.manager
-
- EmbeddedDatasetManagerBuilder.PersistenceMode - Enum in com.terracottatech.store.manager
-
- emptiesFirst() - Method in interface com.terracottatech.store.function.BuildableComparableOptionalFunction
-
Returns a Comparator
that orders objects using the optional values mapped by
this function, with empty values considered less than non-empty.
- emptiesLast() - Method in interface com.terracottatech.store.function.BuildableComparableOptionalFunction
-
Returns a Comparator
that orders objects using the optional values mapped by
this function, with empty values considered greater than non-empty.
- emptyRecord(K) - Static method in interface com.terracottatech.store.Record
-
Returns an empty record instance for the given key.
- equals(Object) - Method in class com.terracottatech.store.AbstractRecord
-
- equals(Object) - Method in interface com.terracottatech.store.Cell
-
Compares the supplied object with this cell for equality.
- equals(Object) - Method in class com.terracottatech.store.configuration.BaseDiskDurability.Timed
-
- equals(Object) - Method in class com.terracottatech.store.definition.CellDefinition.CellImpl
-
- equals(Object) - Method in class com.terracottatech.store.definition.CellDefinition.Impl
-
- equals(Object) - Method in interface com.terracottatech.store.Record
-
Indicates whether some object is equal to this Record
.
- equals(Object, Object) - Static method in class com.terracottatech.store.Type
-
Compares to cell values for equality.
- equals(Object) - Method in class com.terracottatech.store.Type
-
- exceptionally(Function<Throwable, ? extends T>) - Method in interface com.terracottatech.store.async.Operation
-
- execute(Callable<R>, Duration) - Method in interface com.terracottatech.store.coordination.Role
-
Execute the given callable as the rightful holder of this role.
- execute(Runnable, Duration) - Method in interface com.terracottatech.store.coordination.Role
-
Execute the given runnable as the rightful holder of this role.
- executor() - Method in interface com.terracottatech.store.async.Operation
-
Returns the default asynchronous execution pool for this operation.
- exists() - Method in interface com.terracottatech.store.definition.CellDefinition
-
Returns a predicate that tests for the presence of this cell on a record.
- explain(Consumer<Object>) - Method in interface com.terracottatech.store.async.AsyncMutableRecordStream
-
- explain(Consumer<Object>) - Method in interface com.terracottatech.store.async.AsyncRecordStream
-
- explain(Consumer<Object>) - Method in interface com.terracottatech.store.stream.MutableRecordStream
-
- explain(Consumer<Object>) - Method in interface com.terracottatech.store.stream.RecordStream
-
Observes the stream pipeline and provides the pre-execution analysis information for this stream pipeline.
- filter(DoublePredicate) - Method in interface com.terracottatech.store.async.AsyncDoubleStream
-
An asynchronous equivalent to DoubleStream.filter(java.util.function.DoublePredicate)
.
- filter(IntPredicate) - Method in interface com.terracottatech.store.async.AsyncIntStream
-
An asynchronous equivalent to IntStream.filter(java.util.function.IntPredicate)
.
- filter(LongPredicate) - Method in interface com.terracottatech.store.async.AsyncLongStream
-
An asynchronous equivalent to LongStream.filter(java.util.function.LongPredicate)
.
- filter(Predicate<? super Record<K>>) - Method in interface com.terracottatech.store.async.AsyncMutableRecordStream
-
- filter(Predicate<? super Record<K>>) - Method in interface com.terracottatech.store.async.AsyncRecordStream
-
- filter(Predicate<? super T>) - Method in interface com.terracottatech.store.async.AsyncStream
-
An asynchronous equivalent to Stream.filter(java.util.function.Predicate)
.
- filter(Predicate<? super Record<K>>) - Method in interface com.terracottatech.store.stream.MutableRecordStream
-
- filter(Predicate<? super Record<K>>) - Method in interface com.terracottatech.store.stream.RecordStream
-
- filtering(Predicate<? super T>, Collector<T, A, R>) - Static method in class com.terracottatech.store.function.Collectors
-
- findAny() - Method in interface com.terracottatech.store.async.AsyncDoubleStream
-
An asynchronous equivalent to DoubleStream.findAny()
.
- findAny() - Method in interface com.terracottatech.store.async.AsyncIntStream
-
An asynchronous equivalent to IntStream.findAny()
.
- findAny() - Method in interface com.terracottatech.store.async.AsyncLongStream
-
An asynchronous equivalent to LongStream.findAny()
.
- findAny() - Method in interface com.terracottatech.store.async.AsyncStream
-
An asynchronous equivalent to Stream.findAny()
.
- findFirst() - Method in interface com.terracottatech.store.async.AsyncDoubleStream
-
An asynchronous equivalent to DoubleStream.findFirst()
.
- findFirst() - Method in interface com.terracottatech.store.async.AsyncIntStream
-
An asynchronous equivalent to IntStream.findFirst()
.
- findFirst() - Method in interface com.terracottatech.store.async.AsyncLongStream
-
An asynchronous equivalent to LongStream.findFirst()
.
- findFirst() - Method in interface com.terracottatech.store.async.AsyncStream
-
An asynchronous equivalent to Stream.findFirst()
.
- first() - Static method in class com.terracottatech.store.Tuple
-
- flatMap(DoubleFunction<? extends DoubleStream>) - Method in interface com.terracottatech.store.async.AsyncDoubleStream
-
An asynchronous equivalent to DoubleStream.flatMap(java.util.function.DoubleFunction)
.
- flatMap(IntFunction<? extends IntStream>) - Method in interface com.terracottatech.store.async.AsyncIntStream
-
An asynchronous equivalent to IntStream.flatMap(java.util.function.IntFunction)
.
- flatMap(LongFunction<? extends LongStream>) - Method in interface com.terracottatech.store.async.AsyncLongStream
-
An asynchronous equivalent to LongStream.flatMap(java.util.function.LongFunction)
.
- flatMap(Function<? super T, ? extends Stream<? extends R>>) - Method in interface com.terracottatech.store.async.AsyncStream
-
An asynchronous equivalent to Stream.flatMap(java.util.function.Function)
.
- flatMapToDouble(Function<? super T, ? extends DoubleStream>) - Method in interface com.terracottatech.store.async.AsyncStream
-
An asynchronous equivalent to Stream.flatMapToDouble(java.util.function.Function)
.
- flatMapToInt(Function<? super T, ? extends IntStream>) - Method in interface com.terracottatech.store.async.AsyncStream
-
An asynchronous equivalent to Stream.flatMapToInt(java.util.function.Function)
.
- flatMapToLong(Function<? super T, ? extends LongStream>) - Method in interface com.terracottatech.store.async.AsyncStream
-
An asynchronous equivalent to Stream.flatMapToLong(java.util.function.Function)
.
- forEach(DoubleConsumer) - Method in interface com.terracottatech.store.async.AsyncDoubleStream
-
An asynchronous equivalent to DoubleStream.forEach(java.util.function.DoubleConsumer)
.
- forEach(IntConsumer) - Method in interface com.terracottatech.store.async.AsyncIntStream
-
An asynchronous equivalent to IntStream.forEach(java.util.function.IntConsumer)
.
- forEach(LongConsumer) - Method in interface com.terracottatech.store.async.AsyncLongStream
-
An asynchronous equivalent to LongStream.forEach(java.util.function.LongConsumer)
.
- forEach(Consumer<? super T>) - Method in interface com.terracottatech.store.async.AsyncStream
-
An asynchronous equivalent to Stream.forEach(java.util.function.Consumer)
.
- forEachOrdered(DoubleConsumer) - Method in interface com.terracottatech.store.async.AsyncDoubleStream
-
An asynchronous equivalent to DoubleStream.forEachOrdered(java.util.function.DoubleConsumer)
.
- forEachOrdered(IntConsumer) - Method in interface com.terracottatech.store.async.AsyncIntStream
-
An asynchronous equivalent to IntStream.forEachOrdered(java.util.function.IntConsumer)
.
- forEachOrdered(LongConsumer) - Method in interface com.terracottatech.store.async.AsyncLongStream
-
An asynchronous equivalent to LongStream.forEachOrdered(java.util.function.LongConsumer)
.
- forEachOrdered(Consumer<? super T>) - Method in interface com.terracottatech.store.async.AsyncStream
-
An asynchronous equivalent to Stream.forEachOrdered(java.util.function.Consumer)
.
- forJdkType(Class<? extends T>) - Static method in class com.terracottatech.store.Type
-
Return the Terracotta Store type corresponding to the supplied JDK type.
- fromOrdinal(int) - Static method in class com.terracottatech.store.Type
-
- FRS_PERMANENT_ID - Static variable in interface com.terracottatech.store.configuration.PersistentStorageType
-
- get(K) - Method in interface com.terracottatech.store.async.AsyncDatasetReader
-
- get(CellDefinition<T>) - Method in interface com.terracottatech.store.CellCollection
-
- get(String) - Method in interface com.terracottatech.store.CellCollection
-
Retrieve a cell by name.
- get(CellDefinition<T>) - Method in class com.terracottatech.store.CellSet
-
- get(String) - Method in class com.terracottatech.store.CellSet
-
- get(K) - Method in interface com.terracottatech.store.DatasetReader
-
Retrieves the record for the specified key.
- getAllIndexes() - Method in interface com.terracottatech.store.indexing.Indexing
-
Return the current set of indexes.
- getConcurrencyHint() - Method in class com.terracottatech.store.configuration.AbstractDatasetConfiguration
-
- getConcurrencyHint() - Method in interface com.terracottatech.store.configuration.AdvancedDatasetConfiguration
-
- getDataset(String, Type<K>) - Method in interface com.terracottatech.store.manager.DatasetManager
-
Gets a
Dataset
with the specified name and key type.
- getDatasetConfiguration() - Method in class com.terracottatech.store.manager.DatasetManagerConfiguration.DatasetInfo
-
- getDatasetManagerConfiguration() - Method in interface com.terracottatech.store.manager.DatasetManager
-
- getDatasetManagerConfigurationParser() - Static method in interface com.terracottatech.store.manager.DatasetManagerConfigurationParser
-
- getDatasets() - Method in interface com.terracottatech.store.manager.DatasetManagerConfiguration
-
- getDiskDurability() - Method in class com.terracottatech.store.configuration.AbstractDatasetConfiguration
-
- getDiskDurability() - Method in interface com.terracottatech.store.configuration.DatasetConfiguration
-
- getDiskResource() - Method in class com.terracottatech.store.configuration.AbstractDatasetConfiguration
-
- getDiskResource() - Method in interface com.terracottatech.store.configuration.DatasetConfiguration
-
- getDurabilityEnum() - Method in class com.terracottatech.store.configuration.BaseDiskDurability
-
- getDurabilityEnum() - Method in interface com.terracottatech.store.configuration.DiskDurability
-
- getEngineStatus() - Method in enum com.terracottatech.store.configuration.PersistentStorageEngine
-
- getEngineStatus() - Method in interface com.terracottatech.store.configuration.PersistentStorageType
-
Returns the status of the current feature support for this particular persistent storage engine.
- getEqualsPredicate() - Method in interface com.terracottatech.store.Record
-
Returns a predicate that tests if another Record
instance is the same as this one.
- getFirst() - Method in class com.terracottatech.store.Tuple
-
Returns the first value held in the Tuple.
- getIndexes() - Method in class com.terracottatech.store.configuration.AbstractDatasetConfiguration
-
- getIndexes() - Method in interface com.terracottatech.store.configuration.DatasetConfiguration
-
- getIndexing() - Method in interface com.terracottatech.store.Dataset
-
Exposes the
indexing
instance used to create, alter and delete
indexes for this dataset.
- getJDKType() - Method in class com.terracottatech.store.Type
-
Returns the corresponding JDK type for this Terracotta Store type.
- getKey() - Method in interface com.terracottatech.store.ReadRecordAccessor
-
Returns the key that this accessor is against.
- getKey() - Method in interface com.terracottatech.store.Record
-
Returns the key for this record.
- getKeyType() - Method in interface com.terracottatech.store.DatasetReader
-
Return the key type of underlying Dataset
.
- getLiveIndexes() - Method in interface com.terracottatech.store.indexing.Indexing
-
Return the current set of live indexes.
- getLongName() - Method in enum com.terracottatech.store.configuration.PersistentStorageEngine
-
- getLongName() - Method in interface com.terracottatech.store.configuration.PersistentStorageType
-
Returns a display name for this persistent storage type that cen be used for logging etc.
- getMembers() - Method in interface com.terracottatech.store.coordination.Coordinator
-
Return the current set of members in this coordinator.
- getMillisDuration() - Method in class com.terracottatech.store.configuration.BaseDiskDurability.Timed
-
- getOffheapResource() - Method in class com.terracottatech.store.configuration.AbstractDatasetConfiguration
-
- getOffheapResource() - Method in interface com.terracottatech.store.configuration.DatasetConfiguration
-
- getPermanentId() - Method in enum com.terracottatech.store.configuration.PersistentStorageEngine
-
- getPermanentId() - Method in interface com.terracottatech.store.configuration.PersistentStorageType
-
Returns a permanent identifier for this persistent storage type that is guaranteed to stay unique, regardless of
all the new persistent storage type(s) that may be added in the future.
- getPersistentStorageType() - Method in class com.terracottatech.store.configuration.AbstractDatasetConfiguration
-
- getPersistentStorageType() - Method in interface com.terracottatech.store.configuration.DatasetConfiguration
-
- getResult() - Method in exception com.terracottatech.store.coordination.RoleViolationException
-
Return the result of the associated role task execution.
- getSecond() - Method in class com.terracottatech.store.Tuple
-
Returns the second value held in the Tuple.
- getShortName() - Method in enum com.terracottatech.store.configuration.PersistentStorageEngine
-
- getShortName() - Method in interface com.terracottatech.store.configuration.PersistentStorageType
-
Returns a case insensitive name for this persistent storage type that can be used for configuration etc.
- getStorageType() - Method in enum com.terracottatech.store.manager.EmbeddedDatasetManagerBuilder.PersistenceMode
-
- getType() - Method in class com.terracottatech.store.manager.DatasetManagerConfiguration.DatasetInfo
-
- getType() - Method in interface com.terracottatech.store.manager.DatasetManagerConfiguration
-
- groupingBy(Function<? super T, ? extends K>, Collector<? super T, A, D>) - Static method in class com.terracottatech.store.function.Collectors
-
Functionally transparent version of Collectors.groupingBy(Function, Collector)
- groupingByConcurrent(Function<? super T, ? extends K>, Collector<? super T, A, D>) - Static method in class com.terracottatech.store.function.Collectors
-
Functionally transparent version of Collectors.groupingByConcurrent(Function, Collector)
- identity() - Static method in interface com.terracottatech.store.function.BuildableFunction
-
Returns a function that simply returns its argument.
- iff(Predicate<? super Record<K>>) - Method in interface com.terracottatech.store.async.AsyncReadRecordAccessor
-
- iff(Predicate<? super Record<K>>) - Method in interface com.terracottatech.store.async.AsyncReadWriteRecordAccessor
-
- iff(Predicate<? super Record<K>>) - Method in interface com.terracottatech.store.ReadRecordAccessor
-
Read operations on the returned ConditionalReadRecordAccessor will have the
supplied predicate applied to the record held against the key used to create this ReadRecordAccessor.
- iff(Predicate<? super Record<K>>) - Method in interface com.terracottatech.store.ReadWriteRecordAccessor
-
Read and write operations on the returned ConditionalReadWriteRecordAccessor will have the
supplied predicate applied to the record held against the key used to create this ReadWriteRecordAccessor.
- increment() - Method in interface com.terracottatech.store.function.BuildableToDoubleFunction
-
Returns a function that increments this
by one.
- increment() - Method in interface com.terracottatech.store.function.BuildableToIntFunction
-
Returns a function that increments this
by one.
- increment() - Method in interface com.terracottatech.store.function.BuildableToLongFunction
-
Returns a function that increments this
by one.
- index(CellDefinition<?>, IndexSettings) - Method in interface com.terracottatech.store.configuration.DatasetConfigurationBuilder
-
Configure indexing for given cell.
- Index<T extends java.lang.Comparable<T>> - Interface in com.terracottatech.store.indexing
-
Representation of an index.
- Index.Status - Enum in com.terracottatech.store.indexing
-
Status of an index.
- Indexing - Interface in com.terracottatech.store.indexing
-
Allows creation, destruction, and querying of the indexes available to a
Dataset
.
- IndexSettings - Interface in com.terracottatech.store.indexing
-
Representation of the configuration settings for an index.
- inline() - Method in interface com.terracottatech.store.stream.MutableRecordStream
-
- inline() - Method in interface com.terracottatech.store.stream.RecordStream
-
Returns an equivalent stream where any client side operations are performed inline with the server side.
- input(Function<T, R>) - Static method in interface com.terracottatech.store.UpdateOperation
-
Creates a bi-function that returns the result of the first argument applied to the given function.
- install(Cell<?>...) - Static method in interface com.terracottatech.store.UpdateOperation
-
Creates a transform that outputs the specified set of cells.
- install(Iterable<Cell<?>>) - Static method in interface com.terracottatech.store.UpdateOperation
-
Creates a transform that outputs the specified set of cells.
- INT - Static variable in class com.terracottatech.store.Type
-
The Integer
type.
- IntCellDefinition - Interface in com.terracottatech.store.definition
-
- intResultOf(ToIntFunction<Record<?>>) - Method in interface com.terracottatech.store.UpdateOperation.IntWriteOperationBuilder
-
Creates a transform that writes a cell with the supplied definition and value derived by applying the function
to the existing record.
- intValueOr(int) - Method in interface com.terracottatech.store.definition.IntCellDefinition
-
Returns a function that extracts this cells value from a record.
- intValueOrFail() - Method in interface com.terracottatech.store.definition.IntCellDefinition
-
Returns a function that extracts this cells value from a record.
- is(R) - Method in interface com.terracottatech.store.function.BuildableFunction
-
Returns a predicate that tests the value generated by this
for
equality with the supplied constant.
- is(R) - Method in interface com.terracottatech.store.function.BuildableOptionalFunction
-
Returns a predicate that tests the value generated by this
for
equality with the supplied constant.
- is(double) - Method in interface com.terracottatech.store.function.BuildableToDoubleFunction
-
Returns a predicate that tests the value generated by this
for
equality with the supplied constant.
- is(int) - Method in interface com.terracottatech.store.function.BuildableToIntFunction
-
Returns a predicate that tests the value generated by this
for
equality with the supplied constant.
- is(long) - Method in interface com.terracottatech.store.function.BuildableToLongFunction
-
Returns a predicate that tests the value generated by this
for
equality with the supplied constant.
- isFalse() - Method in interface com.terracottatech.store.definition.BoolCellDefinition
-
Returns a record predicate derived from the logical inverse of this cell value.
- isGreaterThan(R) - Method in interface com.terracottatech.store.function.BuildableComparableFunction
-
Returns a predicate that tests the value generated by this
to see
if it is greater than the supplied constant.
- isGreaterThan(R) - Method in interface com.terracottatech.store.function.BuildableComparableOptionalFunction
-
Returns a predicate that tests the value generated by this
to see
if it is greater than the supplied constant.
- isGreaterThan(double) - Method in interface com.terracottatech.store.function.BuildableToDoubleFunction
-
Returns a predicate that tests the value generated by this
to see
if it is greater than the supplied constant.
- isGreaterThan(int) - Method in interface com.terracottatech.store.function.BuildableToIntFunction
-
Returns a predicate that tests the value generated by this
to see
if it is greater than the supplied constant.
- isGreaterThan(long) - Method in interface com.terracottatech.store.function.BuildableToLongFunction
-
Returns a predicate that tests the value generated by this
to see
if it is greater than the supplied constant.
- isGreaterThanOrEqualTo(R) - Method in interface com.terracottatech.store.function.BuildableComparableFunction
-
Returns a predicate that tests the value generated by this
to see
if it is greater than or equal to the supplied constant.
- isGreaterThanOrEqualTo(R) - Method in interface com.terracottatech.store.function.BuildableComparableOptionalFunction
-
Returns a predicate that tests the value generated by this
to see
if it is greater than or equal to the supplied constant.
- isGreaterThanOrEqualTo(double) - Method in interface com.terracottatech.store.function.BuildableToDoubleFunction
-
Returns a predicate that tests the value generated by this
to see
if it is greater than or equal to the supplied constant.
- isGreaterThanOrEqualTo(int) - Method in interface com.terracottatech.store.function.BuildableToIntFunction
-
Returns a predicate that tests the value generated by this
to see
if it is greater than or equal to the supplied constant.
- isGreaterThanOrEqualTo(long) - Method in interface com.terracottatech.store.function.BuildableToLongFunction
-
Returns a predicate that tests the value generated by this
to see
if it is greater than or equal to the supplied constant.
- isLessThan(R) - Method in interface com.terracottatech.store.function.BuildableComparableFunction
-
Returns a predicate that tests the value generated by this
to see
if it is less than the supplied constant.
- isLessThan(R) - Method in interface com.terracottatech.store.function.BuildableComparableOptionalFunction
-
Returns a predicate that tests the value generated by this
to see
if it is less than the supplied constant.
- isLessThan(double) - Method in interface com.terracottatech.store.function.BuildableToDoubleFunction
-
Returns a predicate that tests the value generated by this
to see
if it is less than the supplied constant.
- isLessThan(int) - Method in interface com.terracottatech.store.function.BuildableToIntFunction
-
Returns a predicate that tests the value generated by this
to see
if it is less than the supplied constant.
- isLessThan(long) - Method in interface com.terracottatech.store.function.BuildableToLongFunction
-
Returns a predicate that tests the value generated by this
to see
if it is less than the supplied constant.
- isLessThanOrEqualTo(R) - Method in interface com.terracottatech.store.function.BuildableComparableFunction
-
Returns a predicate that tests the value generated by this
to see
if it is less than or equal to the supplied constant.
- isLessThanOrEqualTo(R) - Method in interface com.terracottatech.store.function.BuildableComparableOptionalFunction
-
Returns a predicate that tests the value generated by this
to see
if it is less than or equal to the supplied constant.
- isLessThanOrEqualTo(double) - Method in interface com.terracottatech.store.function.BuildableToDoubleFunction
-
Returns a predicate that tests the value generated by this
to see
if it is less than or equal to the supplied constant.
- isLessThanOrEqualTo(int) - Method in interface com.terracottatech.store.function.BuildableToIntFunction
-
Returns a predicate that tests the value generated by this
to see
if it is less than or equal to the supplied constant.
- isLessThanOrEqualTo(long) - Method in interface com.terracottatech.store.function.BuildableToLongFunction
-
Returns a predicate that tests the value generated by this
to see
if it is less than or equal to the supplied constant.
- isTrue() - Method in interface com.terracottatech.store.definition.BoolCellDefinition
-
Returns a record predicate derived from this cell value.
- iterator() - Method in interface com.terracottatech.store.async.AsyncDoubleStream
-
- iterator() - Method in interface com.terracottatech.store.async.AsyncIntStream
-
- iterator() - Method in interface com.terracottatech.store.async.AsyncLongStream
-
- iterator() - Method in class com.terracottatech.store.CellSet
-
Returns an Iterator
over the cells in this set.
- map(DoubleUnaryOperator) - Method in interface com.terracottatech.store.async.AsyncDoubleStream
-
An asynchronous equivalent to DoubleStream.map(java.util.function.DoubleUnaryOperator)
.
- map(IntUnaryOperator) - Method in interface com.terracottatech.store.async.AsyncIntStream
-
An asynchronous equivalent to IntStream.map(java.util.function.IntUnaryOperator)
.
- map(LongUnaryOperator) - Method in interface com.terracottatech.store.async.AsyncLongStream
-
An asynchronous equivalent to LongStream.map(java.util.function.LongUnaryOperator)
.
- map(Function<? super T, ? extends R>) - Method in interface com.terracottatech.store.async.AsyncStream
-
An asynchronous equivalent to Stream.map(java.util.function.Function)
.
- map(Function<? super T, ? extends U>) - Method in interface com.terracottatech.store.async.Operation
-
Returns a new Operation that represents the synchronous mapping of this stages result using the provided
function.
- mapping(Function<? super T, ? extends U>, Collector<? super U, A, R>) - Static method in class com.terracottatech.store.function.Collectors
-
Functionally transparent version of Collectors.mapping(Function, Collector)
- mapToDouble(IntToDoubleFunction) - Method in interface com.terracottatech.store.async.AsyncIntStream
-
An asynchronous equivalent to IntStream.mapToDouble(java.util.function.IntToDoubleFunction)
.
- mapToDouble(LongToDoubleFunction) - Method in interface com.terracottatech.store.async.AsyncLongStream
-
An asynchronous equivalent to LongStream.mapToDouble(java.util.function.LongToDoubleFunction)
.
- mapToDouble(ToDoubleFunction<? super T>) - Method in interface com.terracottatech.store.async.AsyncStream
-
An asynchronous equivalent to Stream.mapToDouble(java.util.function.ToDoubleFunction)
.
- mapToInt(DoubleToIntFunction) - Method in interface com.terracottatech.store.async.AsyncDoubleStream
-
An asynchronous equivalent to DoubleStream.mapToInt(java.util.function.DoubleToIntFunction)
.
- mapToInt(LongToIntFunction) - Method in interface com.terracottatech.store.async.AsyncLongStream
-
An asynchronous equivalent to LongStream.mapToInt(java.util.function.LongToIntFunction)
.
- mapToInt(ToIntFunction<? super T>) - Method in interface com.terracottatech.store.async.AsyncStream
-
An asynchronous equivalent to Stream.mapToInt(java.util.function.ToIntFunction)
.
- mapToLong(DoubleToLongFunction) - Method in interface com.terracottatech.store.async.AsyncDoubleStream
-
An asynchronous equivalent to DoubleStream.mapToLong(java.util.function.DoubleToLongFunction)
.
- mapToLong(IntToLongFunction) - Method in interface com.terracottatech.store.async.AsyncIntStream
-
An asynchronous equivalent to IntStream.mapToLong(java.util.function.IntToLongFunction)
.
- mapToLong(ToLongFunction<? super T>) - Method in interface com.terracottatech.store.async.AsyncStream
-
An asynchronous equivalent to Stream.mapToLong(java.util.function.ToLongFunction)
.
- mapToObj(DoubleFunction<? extends U>) - Method in interface com.terracottatech.store.async.AsyncDoubleStream
-
An asynchronous equivalent to DoubleStream.mapToObj(java.util.function.DoubleFunction)
.
- mapToObj(IntFunction<? extends U>) - Method in interface com.terracottatech.store.async.AsyncIntStream
-
An asynchronous equivalent to IntStream.mapToObj(java.util.function.IntFunction)
.
- mapToObj(LongFunction<? extends U>) - Method in interface com.terracottatech.store.async.AsyncLongStream
-
An asynchronous equivalent to LongStream.mapToObj(java.util.function.LongFunction)
.
- max() - Method in interface com.terracottatech.store.async.AsyncDoubleStream
-
An asynchronous equivalent to DoubleStream.max()
.
- max() - Method in interface com.terracottatech.store.async.AsyncIntStream
-
An asynchronous equivalent to IntStream.max()
.
- max() - Method in interface com.terracottatech.store.async.AsyncLongStream
-
An asynchronous equivalent to LongStream.max()
.
- max(Comparator<? super T>) - Method in interface com.terracottatech.store.async.AsyncStream
-
An asynchronous equivalent to Stream.max(java.util.Comparator)
.
- maxBy(Comparator<? super T>) - Static method in class com.terracottatech.store.function.Collectors
-
Functionally transparent version of Collectors.maxBy(Comparator)
- memberJoined(String) - Method in interface com.terracottatech.store.coordination.Listener
-
A member with the given name
joined the coordinator.
- memberLeft(String) - Method in interface com.terracottatech.store.coordination.Listener
-
A member with the given name
left the coordinator.
- MemoryUnit - Enum in com.terracottatech.store.configuration
-
- mergeConservatively(DiskDurability) - Method in class com.terracottatech.store.configuration.BaseDiskDurability
-
- mergeConservatively(DiskDurability) - Method in class com.terracottatech.store.configuration.BaseDiskDurability.Timed
-
- mergeConservatively(DiskDurability) - Method in interface com.terracottatech.store.configuration.DiskDurability
-
- min() - Method in interface com.terracottatech.store.async.AsyncDoubleStream
-
An asynchronous equivalent to DoubleStream.min()
.
- min() - Method in interface com.terracottatech.store.async.AsyncIntStream
-
An asynchronous equivalent to IntStream.min()
.
- min() - Method in interface com.terracottatech.store.async.AsyncLongStream
-
An asynchronous equivalent to LongStream.min()
.
- min(Comparator<? super T>) - Method in interface com.terracottatech.store.async.AsyncStream
-
An asynchronous equivalent to Stream.min(java.util.Comparator)
.
- minBy(Comparator<? super T>) - Static method in class com.terracottatech.store.function.Collectors
-
Functionally transparent version of Collectors.minBy(Comparator)
- missedEvents() - Method in interface com.terracottatech.store.ChangeListener
-
- multiply(double) - Method in interface com.terracottatech.store.function.BuildableToDoubleFunction
-
Returns a function that calculates the product of this
and
multiplier
.
- multiply(int) - Method in interface com.terracottatech.store.function.BuildableToIntFunction
-
Returns a function that calculates the product of this
and
multiplier
.
- multiply(long) - Method in interface com.terracottatech.store.function.BuildableToLongFunction
-
Returns a function that calculates the product of this
and
multiplier
.
- MutableRecordStream<K extends java.lang.Comparable<K>> - Interface in com.terracottatech.store.stream
-
A
Stream
of
Record
instances through which the
Record
s may be mutated.
- mutate(UpdateOperation<? super K>) - Method in interface com.terracottatech.store.async.AsyncMutableRecordStream
-
Performs an update transformation against the
Record
s in the stream.
- mutate(UpdateOperation<? super K>) - Method in interface com.terracottatech.store.stream.MutableRecordStream
-
Performs an update transformation against the
Record
s in the stream.
- mutateThen(UpdateOperation<? super K>) - Method in interface com.terracottatech.store.async.AsyncMutableRecordStream
-
Performs an update transformation against the
Record
s in the stream.
- mutateThen(UpdateOperation<? super K>) - Method in interface com.terracottatech.store.stream.MutableRecordStream
-
Performs an update transformation against the
Record
s in the stream.
- of(Cell<?>...) - Static method in class com.terracottatech.store.CellSet
-
Creates a new, mutable
CellSet
instance containing the specified
Cell
instances.
- of(T, U) - Static method in class com.terracottatech.store.Tuple
-
Creates a Tuple with two values.
- offheap(String) - Method in interface com.terracottatech.store.configuration.DatasetConfigurationBuilder
-
Set the name of the resource to use for offheap storage
- offheap(String, long, MemoryUnit) - Method in interface com.terracottatech.store.manager.EmbeddedDatasetManagerBuilder
-
Registers an amount of offheap memory
- on(K) - Method in interface com.terracottatech.store.async.AsyncDatasetReader
-
- on(K) - Method in interface com.terracottatech.store.async.AsyncDatasetWriterReader
-
- on(K) - Method in interface com.terracottatech.store.DatasetReader
-
Returns a ReadRecordAccessor which can be used to for fine-control of
read operations on the record held against the specified key.
- on(K) - Method in interface com.terracottatech.store.DatasetWriterReader
-
Returns a ReadWriteRecordAccessor which can be used to for fine-control of
read and write operations on the record held against the specified key.
- on() - Method in interface com.terracottatech.store.indexing.Index
-
- onChange(K, ChangeType) - Method in interface com.terracottatech.store.ChangeListener
-
This method will be called when a key is added or deleted, or when the record
against a key is mutated.
- onClose(Runnable) - Method in interface com.terracottatech.store.async.AsyncMutableRecordStream
-
- onClose(Runnable) - Method in interface com.terracottatech.store.async.AsyncRecordStream
-
- onClose(Runnable) - Method in interface com.terracottatech.store.stream.MutableRecordStream
-
- onClose(Runnable) - Method in interface com.terracottatech.store.stream.RecordStream
-
- Operation<T> - Interface in com.terracottatech.store.async
-
A representation of the asynchronous execution of an operation.
- operation(CompletableFuture<T>) - Static method in interface com.terracottatech.store.async.Operation
-
Create an operation who's completion is tied to the given CompletableFuture
.
- operation(CompletableFuture<T>, Executor) - Static method in interface com.terracottatech.store.async.Operation
-
/**
Create an operation who's completion is tied to the given CompletableFuture
.
- operation(Future<T>) - Static method in interface com.terracottatech.store.async.Operation
-
Create an operation who's completion is tied to the given Future
.
- operation(Future<T>, Executor) - Static method in interface com.terracottatech.store.async.Operation
-
Create an operation who's completion is tied to the given Future
.
- or(Predicate<? super T>) - Method in interface com.terracottatech.store.function.BuildablePredicate
-
- OS_DETERMINED - Static variable in class com.terracottatech.store.configuration.BaseDiskDurability
-
Static instance of
DiskDurability
representing disk durability
that is left to the operating system.
- output(Function<U, R>) - Static method in interface com.terracottatech.store.UpdateOperation
-
Creates a bi-function that returns the result of the second argument applied to the given function.
- read(Function<? super Record<K>, T>) - Method in interface com.terracottatech.store.async.AsyncConditionalReadRecordAccessor
-
- read() - Method in interface com.terracottatech.store.async.AsyncConditionalReadRecordAccessor
-
- read(Function<? super Record<K>, T>) - Method in interface com.terracottatech.store.async.AsyncReadRecordAccessor
-
- read(Function<? super Record<K>, T>) - Method in interface com.terracottatech.store.ConditionalReadRecordAccessor
-
Maps the record held against the key used to create this ConditionalReadRecordAccessor,
if that record matches the predicate used to create this ConditionalReadRecordAccessor.
- read() - Method in interface com.terracottatech.store.ConditionalReadRecordAccessor
-
Reads the record held against the key used to create this ConditionalReadRecordAccessor,
if that record matches the predicate used to create this ConditionalReadRecordAccessor.
- read(Function<? super Record<K>, T>) - Method in interface com.terracottatech.store.ReadRecordAccessor
-
Maps the record held against the key used to create this ReadRecordAccessor.
- reader() - Method in interface com.terracottatech.store.Dataset
-
Provides read-only access on to this dataset.
- ReadRecordAccessor<K extends java.lang.Comparable<K>> - Interface in com.terracottatech.store
-
A ReadRecordAccessor provides fine-control over read operations on
the record held against the key that was used to create the ReadRecordAccessor.
- ReadWriteRecordAccessor<K extends java.lang.Comparable<K>> - Interface in com.terracottatech.store
-
A ReadWriteRecordAccessor provides fine-control over read and write operations on
the record held against the key that was used to create the ReadWriteRecordAccessor.
- Record<K extends java.lang.Comparable<K>> - Interface in com.terracottatech.store
-
A record is a set of
Cell
s associated with a key.
- records() - Method in interface com.terracottatech.store.async.AsyncDatasetReader
-
- records() - Method in interface com.terracottatech.store.async.AsyncDatasetWriterReader
-
- records() - Method in interface com.terracottatech.store.DatasetReader
-
Returns a Stream
of the records in this dataset.
- records() - Method in interface com.terracottatech.store.DatasetWriterReader
-
Returns a Stream
of the records in this dataset.
- RecordStream<K extends java.lang.Comparable<K>> - Interface in com.terracottatech.store.stream
-
- reduce(double, DoubleBinaryOperator) - Method in interface com.terracottatech.store.async.AsyncDoubleStream
-
An asynchronous equivalent to DoubleStream.reduce(double, java.util.function.DoubleBinaryOperator)
.
- reduce(DoubleBinaryOperator) - Method in interface com.terracottatech.store.async.AsyncDoubleStream
-
An asynchronous equivalent to DoubleStream.reduce(java.util.function.DoubleBinaryOperator)
.
- reduce(int, IntBinaryOperator) - Method in interface com.terracottatech.store.async.AsyncIntStream
-
An asynchronous equivalent to IntStream.reduce(int, java.util.function.IntBinaryOperator)
.
- reduce(IntBinaryOperator) - Method in interface com.terracottatech.store.async.AsyncIntStream
-
An asynchronous equivalent to IntStream.reduce(java.util.function.IntBinaryOperator)
.
- reduce(long, LongBinaryOperator) - Method in interface com.terracottatech.store.async.AsyncLongStream
-
An asynchronous equivalent to LongStream.reduce(long, java.util.function.LongBinaryOperator)
.
- reduce(LongBinaryOperator) - Method in interface com.terracottatech.store.async.AsyncLongStream
-
An asynchronous equivalent to LongStream.reduce(java.util.function.LongBinaryOperator)
.
- reduce(T, BinaryOperator<T>) - Method in interface com.terracottatech.store.async.AsyncStream
-
An asynchronous equivalent to Stream.reduce(java.lang.Object, java.util.function.BinaryOperator)
.
- reduce(BinaryOperator<T>) - Method in interface com.terracottatech.store.async.AsyncStream
-
An asynchronous equivalent to Stream.reduce(java.util.function.BinaryOperator)
.
- reduce(U, BiFunction<U, ? super T, U>, BinaryOperator<U>) - Method in interface com.terracottatech.store.async.AsyncStream
-
An asynchronous equivalent to Stream.reduce(java.lang.Object, java.util.function.BiFunction, java.util.function.BinaryOperator)
.
- registerChangeListener(ChangeListener<K>) - Method in interface com.terracottatech.store.DatasetReader
-
Registers a listener that will receive an event for changes to a key.
- remove(Object) - Method in class com.terracottatech.store.AbstractRecord
-
- remove(Object) - Method in class com.terracottatech.store.CellSet
-
Removes the specified Cell
.
- remove(String) - Method in class com.terracottatech.store.CellSet
-
Removes a Cell
with the specified name.
- remove(CellDefinition<T>) - Method in class com.terracottatech.store.CellSet
-
Removes the Cell
with this definition from this set if it is present.
- remove(CellDefinition<T>) - Static method in interface com.terracottatech.store.UpdateOperation
-
Create a transform that removes a cell.
- removeAll(Collection<?>) - Method in class com.terracottatech.store.AbstractRecord
-
- removeIf(Predicate<? super Cell<?>>) - Method in class com.terracottatech.store.AbstractRecord
-
- resultOf(Function<Record<?>, T>) - Method in interface com.terracottatech.store.UpdateOperation.WriteOperationBuilder
-
Creates a transform that writes a cell with the supplied definition and value derived by applying the function
to the existing record.
- retainAll(Collection<?>) - Method in class com.terracottatech.store.AbstractRecord
-
- Role - Interface in com.terracottatech.store.coordination
-
A representation of a role.
- roleAcquiredBy(String, String) - Method in interface com.terracottatech.store.coordination.Listener
-
The given member acquired the given role.
- roleRelinquishedBy(String, String) - Method in interface com.terracottatech.store.coordination.Listener
-
The given member lost the given role.
- RoleViolationException - Exception in com.terracottatech.store.coordination
-
Thrown to indicate a role violation while attempting to execute a task.
- runAfterBoth(CompletionStage<?>, Runnable) - Method in interface com.terracottatech.store.async.Operation
-
- runAfterBothAsync(CompletionStage<?>, Runnable, Executor) - Method in interface com.terracottatech.store.async.Operation
-
- runAfterBothAsync(CompletionStage<?>, Runnable) - Method in interface com.terracottatech.store.async.Operation
-
- runAfterEither(CompletionStage<?>, Runnable) - Method in interface com.terracottatech.store.async.Operation
-
- runAfterEitherAsync(CompletionStage<?>, Runnable, Executor) - Method in interface com.terracottatech.store.async.Operation
-
- runAfterEitherAsync(CompletionStage<?>, Runnable) - Method in interface com.terracottatech.store.async.Operation
-
- second() - Static method in class com.terracottatech.store.Tuple
-
- secureClustered(URI, Path) - Static method in interface com.terracottatech.store.manager.DatasetManager
-
Creates a ClusteredDatasetManagerBuilder for configuring the interaction with a cluster where the network communication
is secured using SSL/TLS.
- secureClustered(Iterable<InetSocketAddress>, Path) - Static method in interface com.terracottatech.store.manager.DatasetManager
-
Creates a ClusteredDatasetManagerBuilder for configuring the interaction with a cluster where the network communication
is secured using SSL/TLS.
- sequential() - Method in interface com.terracottatech.store.async.AsyncDoubleStream
-
- sequential() - Method in interface com.terracottatech.store.async.AsyncIntStream
-
- sequential() - Method in interface com.terracottatech.store.async.AsyncLongStream
-
- sequential() - Method in interface com.terracottatech.store.async.AsyncMutableRecordStream
-
- sequential() - Method in interface com.terracottatech.store.async.AsyncRecordStream
-
- sequential() - Method in interface com.terracottatech.store.stream.MutableRecordStream
-
- sequential() - Method in interface com.terracottatech.store.stream.RecordStream
-
- set(Cell<?>) - Method in class com.terracottatech.store.CellSet
-
Adds the specified Cell
to this set if a cell having the same name is not already present or
replaces the existing cell if a cell of the same name is already present.
- shortNameToType(String) - Static method in interface com.terracottatech.store.configuration.PersistentStorageType
-
- size() - Method in class com.terracottatech.store.CellSet
- skip(long) - Method in interface com.terracottatech.store.async.AsyncDoubleStream
-
An asynchronous equivalent to DoubleStream.skip(long)
.
- skip(long) - Method in interface com.terracottatech.store.async.AsyncIntStream
-
An asynchronous equivalent to IntStream.skip(long)
.
- skip(long) - Method in interface com.terracottatech.store.async.AsyncLongStream
-
An asynchronous equivalent to LongStream.skip(long)
.
- skip(long) - Method in interface com.terracottatech.store.async.AsyncMutableRecordStream
-
- skip(long) - Method in interface com.terracottatech.store.async.AsyncRecordStream
-
- skip(long) - Method in interface com.terracottatech.store.async.AsyncStream
-
An asynchronous equivalent to Stream.skip(long)
.
- skip(long) - Method in interface com.terracottatech.store.stream.MutableRecordStream
-
- skip(long) - Method in interface com.terracottatech.store.stream.RecordStream
-
- sorted() - Method in interface com.terracottatech.store.async.AsyncDoubleStream
-
An asynchronous equivalent to DoubleStream.sorted()
.
- sorted() - Method in interface com.terracottatech.store.async.AsyncIntStream
-
An asynchronous equivalent to IntStream.sorted()
.
- sorted() - Method in interface com.terracottatech.store.async.AsyncLongStream
-
An asynchronous equivalent to LongStream.sorted()
.
- sorted() - Method in interface com.terracottatech.store.async.AsyncMutableRecordStream
-
- sorted(Comparator<? super Record<K>>) - Method in interface com.terracottatech.store.async.AsyncMutableRecordStream
-
- sorted() - Method in interface com.terracottatech.store.async.AsyncRecordStream
-
- sorted(Comparator<? super Record<K>>) - Method in interface com.terracottatech.store.async.AsyncRecordStream
-
- sorted() - Method in interface com.terracottatech.store.async.AsyncStream
-
An asynchronous equivalent to Stream.sorted()
.
- sorted(Comparator<? super T>) - Method in interface com.terracottatech.store.async.AsyncStream
-
An asynchronous equivalent to Stream.sorted(java.util.Comparator)
.
- sorted() - Method in interface com.terracottatech.store.stream.MutableRecordStream
-
This method will throw a
java.lang.UnsupportedOperationException
since
records
are not
Comparable
.
- sorted(Comparator<? super Record<K>>) - Method in interface com.terracottatech.store.stream.MutableRecordStream
-
Returns a RecordStream<K>
consisting of the elements of this stream, sorted
according to the provided Comparator
.
- sorted() - Method in interface com.terracottatech.store.stream.RecordStream
-
This method will throw a
java.lang.UnsupportedOperationException
since
records
are not
Comparable
.
- sorted(Comparator<? super Record<K>>) - Method in interface com.terracottatech.store.stream.RecordStream
-
Returns a RecordStream<K>
consisting of the elements of this stream, sorted
according to the provided Comparator
.
- spliterator() - Method in interface com.terracottatech.store.async.AsyncDoubleStream
-
- spliterator() - Method in interface com.terracottatech.store.async.AsyncIntStream
-
- spliterator() - Method in interface com.terracottatech.store.async.AsyncLongStream
-
- spliterator() - Method in class com.terracottatech.store.CellSet
-
Creates a Spliterator
over the cells in this set.
- startsWith(String) - Method in interface com.terracottatech.store.function.BuildableStringFunction
-
Returns a predicate that tests the strings generated by this
to see
if they start with the supplied constant string.
- startsWith(String) - Method in interface com.terracottatech.store.function.BuildableStringOptionalFunction
-
Returns a predicate that tests the strings generated by this
to see
if they start with the supplied constant string.
- status() - Method in interface com.terracottatech.store.indexing.Index
-
- StoreBusyException - Exception in com.terracottatech.store
-
Indicates a remote stream cannot be started due to current resource usage in the server.
- StoreBusyException(Throwable) - Constructor for exception com.terracottatech.store.StoreBusyException
-
- StoreBusyException(String) - Constructor for exception com.terracottatech.store.StoreBusyException
-
- StoreBusyException(String, Throwable) - Constructor for exception com.terracottatech.store.StoreBusyException
-
- StoreException - Exception in com.terracottatech.store
-
A checked exception that indicates a store operation has failed.
- StoreException(Throwable) - Constructor for exception com.terracottatech.store.StoreException
-
Create a StoreException with an underlying cause.
- StoreException(String) - Constructor for exception com.terracottatech.store.StoreException
-
Create a StoreException with a message.
- StoreException(String, Throwable) - Constructor for exception com.terracottatech.store.StoreException
-
Create a StoreException with a message and underlying cause.
- StoreIndexNotFoundException - Exception in com.terracottatech.store
-
Thrown when an operation requests the use of an index that does not exist.
- StoreIndexNotFoundException(String) - Constructor for exception com.terracottatech.store.StoreIndexNotFoundException
-
- StoreIndexNotFoundException(String, Throwable) - Constructor for exception com.terracottatech.store.StoreIndexNotFoundException
-
- StoreOperationAbandonedException - Exception in com.terracottatech.store
-
Throw to indicate an operation is abandoned due to a connection failure.
- StoreOperationAbandonedException(String) - Constructor for exception com.terracottatech.store.StoreOperationAbandonedException
-
- StoreOperationAbandonedException(Throwable) - Constructor for exception com.terracottatech.store.StoreOperationAbandonedException
-
- StoreOperationAbandonedException(String, Throwable) - Constructor for exception com.terracottatech.store.StoreOperationAbandonedException
-
- StoreReconnectFailedException - Exception in com.terracottatech.store
-
Thrown for operations attempted against a server connection for which all reconnection attempts have failed.
- StoreReconnectFailedException(Throwable) - Constructor for exception com.terracottatech.store.StoreReconnectFailedException
-
- StoreReconnectFailedException(String) - Constructor for exception com.terracottatech.store.StoreReconnectFailedException
-
- StoreReconnectFailedException(String, Throwable) - Constructor for exception com.terracottatech.store.StoreReconnectFailedException
-
- StoreReconnectInterruptedException - Exception in com.terracottatech.store
-
Thrown to indicate an operation is abandoned due to a connection failure and the thread is interrupted before a
reconnect is complete.
- StoreReconnectInterruptedException(String) - Constructor for exception com.terracottatech.store.StoreReconnectInterruptedException
-
- StoreReconnectInterruptedException(Throwable) - Constructor for exception com.terracottatech.store.StoreReconnectInterruptedException
-
- StoreReconnectInterruptedException(String, Throwable) - Constructor for exception com.terracottatech.store.StoreReconnectInterruptedException
-
- StoreRetryableStreamTerminatedException - Exception in com.terracottatech.store
-
Indicates that the retryable stream execution was prematurely terminated.
- StoreRetryableStreamTerminatedException(String) - Constructor for exception com.terracottatech.store.StoreRetryableStreamTerminatedException
-
- StoreRetryableStreamTerminatedException(String, Throwable) - Constructor for exception com.terracottatech.store.StoreRetryableStreamTerminatedException
-
- StoreRuntimeException - Exception in com.terracottatech.store
-
An unchecked exception that indicates a store operation has failed.
- StoreRuntimeException(Throwable) - Constructor for exception com.terracottatech.store.StoreRuntimeException
-
Create a StoreRuntimeException with an underlying cause.
- StoreRuntimeException(String) - Constructor for exception com.terracottatech.store.StoreRuntimeException
-
Create a StoreRuntimeException with a message.
- StoreRuntimeException(String, Throwable) - Constructor for exception com.terracottatech.store.StoreRuntimeException
-
Create a StoreRuntimeException with a message and underlying cause.
- StoreStreamNotFoundException - Exception in com.terracottatech.store
-
Thrown to indicate the requested stream is not among the streams registered for a dataset.
- StoreStreamNotFoundException(String) - Constructor for exception com.terracottatech.store.StoreStreamNotFoundException
-
- StoreStreamRegisteredException - Exception in com.terracottatech.store
-
Indicates an open request for a stream supplied a stream identifier that is already
in use.
- StoreStreamRegisteredException(Throwable) - Constructor for exception com.terracottatech.store.StoreStreamRegisteredException
-
- StoreStreamRegisteredException(String) - Constructor for exception com.terracottatech.store.StoreStreamRegisteredException
-
- StoreStreamRegisteredException(String, Throwable) - Constructor for exception com.terracottatech.store.StoreStreamRegisteredException
-
- StoreStreamTerminatedException - Exception in com.terracottatech.store
-
Indicates that the stream execution was prematurely terminated.
- StoreStreamTerminatedException(String) - Constructor for exception com.terracottatech.store.StoreStreamTerminatedException
-
- StoreStreamTerminatedException(String, Throwable) - Constructor for exception com.terracottatech.store.StoreStreamTerminatedException
-
- STRING - Static variable in class com.terracottatech.store.Type
-
The String
type.
- StringCellDefinition - Interface in com.terracottatech.store.definition
-
- subtract(double) - Method in interface com.terracottatech.store.function.BuildableToDoubleFunction
-
Returns a function that subtracts operand
from this
.
- subtract(int) - Method in interface com.terracottatech.store.function.BuildableToIntFunction
-
Returns a function that subtracts operand
from this
.
- subtract(long) - Method in interface com.terracottatech.store.function.BuildableToLongFunction
-
Returns a function that subtracts operand
from this
.
- sum() - Method in interface com.terracottatech.store.async.AsyncDoubleStream
-
An asynchronous equivalent to DoubleStream.sum()
.
- sum() - Method in interface com.terracottatech.store.async.AsyncIntStream
-
An asynchronous equivalent to IntStream.sum()
.
- sum() - Method in interface com.terracottatech.store.async.AsyncLongStream
-
An asynchronous equivalent to LongStream.sum()
.
- summarizingDouble(ToDoubleFunction<? super T>) - Static method in class com.terracottatech.store.function.Collectors
-
Functionally transparent version of Collectors.summarizingDouble(ToDoubleFunction)
- summarizingInt(ToIntFunction<? super T>) - Static method in class com.terracottatech.store.function.Collectors
-
Functionally transparent version of Collectors.summarizingInt(ToIntFunction)
- summarizingLong(ToLongFunction<? super T>) - Static method in class com.terracottatech.store.function.Collectors
-
Functionally transparent version of Collectors.summarizingLong(ToLongFunction)
- summaryStatistics() - Method in interface com.terracottatech.store.async.AsyncDoubleStream
-
An asynchronous equivalent to DoubleStream.summaryStatistics()
.
- summaryStatistics() - Method in interface com.terracottatech.store.async.AsyncIntStream
-
An asynchronous equivalent to IntStream.summaryStatistics()
.
- summaryStatistics() - Method in interface com.terracottatech.store.async.AsyncLongStream
-
An asynchronous equivalent to LongStream.summaryStatistics()
.
- summingDouble(ToDoubleFunction<? super T>) - Static method in class com.terracottatech.store.function.Collectors
-
Functionally transparent version of Collectors.summingDouble(ToDoubleFunction)
- summingInt(ToIntFunction<? super T>) - Static method in class com.terracottatech.store.function.Collectors
-
Functionally transparent version of Collectors.summingInt(ToIntFunction)
- summingLong(ToLongFunction<? super T>) - Static method in class com.terracottatech.store.function.Collectors
-
Functionally transparent version of Collectors.summingLong(ToLongFunction)
- unordered() - Method in interface com.terracottatech.store.async.AsyncMutableRecordStream
-
- unordered() - Method in interface com.terracottatech.store.async.AsyncRecordStream
-
- unordered() - Method in interface com.terracottatech.store.stream.MutableRecordStream
-
- unordered() - Method in interface com.terracottatech.store.stream.RecordStream
-
- unparse(DatasetManagerConfiguration) - Method in interface com.terracottatech.store.manager.DatasetManagerConfigurationParser
-
- update(UpdateOperation<? super K>, BiFunction<? super Record<K>, ? super Record<K>, T>) - Method in interface com.terracottatech.store.async.AsyncConditionalReadWriteRecordAccessor
-
- update(UpdateOperation<? super K>) - Method in interface com.terracottatech.store.async.AsyncConditionalReadWriteRecordAccessor
-
- update(K, UpdateOperation<? super K>) - Method in interface com.terracottatech.store.async.AsyncDatasetWriterReader
-
- update(UpdateOperation<? super K>, BiFunction<? super Record<K>, ? super Record<K>, T>) - Method in interface com.terracottatech.store.async.AsyncReadWriteRecordAccessor
-
- update(UpdateOperation<? super K>) - Method in interface com.terracottatech.store.async.AsyncReadWriteRecordAccessor
-
- update(UpdateOperation<? super K>, BiFunction<? super Record<K>, ? super Record<K>, T>) - Method in interface com.terracottatech.store.ConditionalReadWriteRecordAccessor
-
Updates the record held against the key used to create this ConditionalReadWriteRecordAccessor,
if that record matches the predicate used to create this ConditionalReadWriteRecordAccessor.
- update(UpdateOperation<? super K>) - Method in interface com.terracottatech.store.ConditionalReadWriteRecordAccessor
-
Updates the record held against the key used to create this ConditionalReadWriteRecordAccessor,
if that record matches the predicate used to create this ConditionalReadWriteRecordAccessor.
- update(K, UpdateOperation<? super K>) - Method in interface com.terracottatech.store.DatasetWriterReader
-
Updates a record for the specified key using the specified UpdateOperation.
- update(UpdateOperation<? super K>, BiFunction<? super Record<K>, ? super Record<K>, T>) - Method in interface com.terracottatech.store.ReadWriteRecordAccessor
-
Updates a record held against the key used to create this ReadWriteRecordAccessor.
- update(UpdateOperation<? super K>) - Method in interface com.terracottatech.store.ReadWriteRecordAccessor
-
Updates a record held against the key used to create this ReadWriteRecordAccessor.
- UpdateOperation<K extends java.lang.Comparable<K>> - Interface in com.terracottatech.store
-
A transform that updates a record.
- UpdateOperation.BoolWriteOperationBuilder - Interface in com.terracottatech.store
-
A builder for a transform that writes a single boolean cell.
- UpdateOperation.CellUpdateOperation<K extends java.lang.Comparable<K>,T> - Interface in com.terracottatech.store
-
A single cell transform.
- UpdateOperation.DoubleWriteOperationBuilder - Interface in com.terracottatech.store
-
A builder for a transform that writes a single double cell.
- UpdateOperation.IntWriteOperationBuilder - Interface in com.terracottatech.store
-
A builder for a transform that writes a single int cell.
- UpdateOperation.LongWriteOperationBuilder - Interface in com.terracottatech.store
-
A builder for a transform that writes a single long cell.
- UpdateOperation.WriteOperationBuilder<T> - Interface in com.terracottatech.store
-
A builder for a transform that writes a single cell.
- upsert(Cell<?>...) - Method in interface com.terracottatech.store.async.AsyncReadWriteRecordAccessor
-
- upsert(Iterable<Cell<?>>) - Method in interface com.terracottatech.store.async.AsyncReadWriteRecordAccessor
-
- upsert(Cell<?>...) - Method in interface com.terracottatech.store.ReadWriteRecordAccessor
-
Ensures that the record has the supplied cells.
- upsert(Iterable<Cell<?>>) - Method in interface com.terracottatech.store.ReadWriteRecordAccessor
-
Ensures that the record has the supplied cells.
- upsert(UpdateOperation<K>) - Method in interface com.terracottatech.store.ReadWriteRecordAccessor
-
Apply the given update against this record or the empty record if no record exists.
- using(DatasetManagerConfiguration) - Static method in interface com.terracottatech.store.manager.DatasetManager
-
- using(DatasetManagerConfiguration, ConfigurationMode) - Static method in interface com.terracottatech.store.manager.DatasetManager
-
- usingExecutor(Executor) - Method in interface com.terracottatech.store.async.Operation
-
Returns a new Operation that uses the supplied executor as it's default async executor.
- value() - Method in interface com.terracottatech.store.Cell
-
Returns the value held within this cell.
- value() - Method in class com.terracottatech.store.definition.CellDefinition.CellImpl
-
- value() - Method in interface com.terracottatech.store.definition.CellDefinition
-
Returns a function that extracts the value of this cell from a record.
- value() - Method in interface com.terracottatech.store.definition.ComparableCellDefinition
-
- value() - Method in interface com.terracottatech.store.definition.StringCellDefinition
-
- value(T) - Method in interface com.terracottatech.store.UpdateOperation.WriteOperationBuilder
-
Creates a transform that writes a cell with the supplied definition and value.
- valueOf(String) - Static method in enum com.terracottatech.store.ChangeType
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.terracottatech.store.configuration.DiskDurability.DiskDurabilityEnum
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.terracottatech.store.configuration.MemoryUnit
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.terracottatech.store.configuration.PersistentStorageEngine
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.terracottatech.store.configuration.ProductFeatureStatus
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.terracottatech.store.function.Collectors.VarianceType
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.terracottatech.store.indexing.Index.Status
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.terracottatech.store.manager.ConfigurationMode
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.terracottatech.store.manager.DatasetManagerConfiguration.Type
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.terracottatech.store.manager.EmbeddedDatasetManagerBuilder.FileMode
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.terracottatech.store.manager.EmbeddedDatasetManagerBuilder.PersistenceMode
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.terracottatech.store.Type.Enum
-
Returns the enum constant of this type with the specified name.
- valueOr(T) - Method in interface com.terracottatech.store.definition.CellDefinition
-
Returns a function that extracts the value of this cell from a record or
uses the given default if the cell is absent.
- valueOr(T) - Method in interface com.terracottatech.store.definition.ComparableCellDefinition
-
- valueOr(String) - Method in interface com.terracottatech.store.definition.StringCellDefinition
-
- valueOrFail() - Method in interface com.terracottatech.store.definition.CellDefinition
-
Returns a function that extracts the value of this cell from a record or
throws a NoSuchElementException
if the cell is absent.
- valueOrFail() - Method in interface com.terracottatech.store.definition.ComparableCellDefinition
-
- valueOrFail() - Method in interface com.terracottatech.store.definition.StringCellDefinition
-
- values() - Static method in enum com.terracottatech.store.ChangeType
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.terracottatech.store.configuration.DiskDurability.DiskDurabilityEnum
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.terracottatech.store.configuration.MemoryUnit
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.terracottatech.store.configuration.PersistentStorageEngine
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.terracottatech.store.configuration.ProductFeatureStatus
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.terracottatech.store.function.Collectors.VarianceType
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.terracottatech.store.indexing.Index.Status
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.terracottatech.store.manager.ConfigurationMode
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.terracottatech.store.manager.DatasetManagerConfiguration.Type
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.terracottatech.store.manager.EmbeddedDatasetManagerBuilder.FileMode
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.terracottatech.store.manager.EmbeddedDatasetManagerBuilder.PersistenceMode
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.terracottatech.store.Type.Enum
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- varianceOf(ToIntFunction<T>, Collectors.VarianceType) - Static method in class com.terracottatech.store.function.Collectors
-
- varianceOf(ToLongFunction<T>, Collectors.VarianceType) - Static method in class com.terracottatech.store.function.Collectors
-
- varianceOf(ToDoubleFunction<T>, Collectors.VarianceType) - Static method in class com.terracottatech.store.function.Collectors
-
- varianceOfDouble(ToDoubleFunction<T>, Collectors.VarianceType) - Static method in class com.terracottatech.store.function.Collectors
-
Returns a Collector
that produces the statistical variance of a double-valued function applied to the
input elements.
- varianceOfInt(ToIntFunction<T>, Collectors.VarianceType) - Static method in class com.terracottatech.store.function.Collectors
-
Returns a Collector
that produces the statistical variance of an integer-valued function applied to the
input elements.
- varianceOfLong(ToLongFunction<T>, Collectors.VarianceType) - Static method in class com.terracottatech.store.function.Collectors
-
Returns a Collector
that produces the statistical variance of a long-valued function applied to the
input elements.