AbstractColumnLocation<TLT extends TableLocation> |
Partial ColumnLocation implementation for use by TableDataService implementations.
|
AbstractTableDataService |
Partial TableDataService implementation for use by TableDataService implementations.
|
AbstractTableLocation<TKT extends TableKey,CLT extends ColumnLocation> |
Partial TableLocation implementation for use by TableDataService implementations.
|
AbstractTableLocationProvider |
Partial TableLocationProvider implementation for use by TableDataService implementations.
|
CompositeTableDataService |
Routing TableDataService that applies a selector function to pick service(s) for each request.
|
CompositeTableDataServiceConsistencyMonitor |
A consistency monitor for use in the CompositeTableDataService.
|
CompositeTableDataServiceConsistencyMonitor.ConsistentSupplier<T> |
|
DeferredTableLocation<CLT extends ColumnLocation> |
|
DeferredTableLocation.DataDriven<CLT extends ColumnLocation> |
DeferredTableLocation that needs to initialize its inner location for all non-key methods.
|
DeferredTableLocation.SnapshotDriven<CLT extends ColumnLocation> |
DeferredTableLocation that implements metadata getters by delegating to a snapshot.
|
FileDataBufferStore |
Ordered buffer tracking system for a file, used to represent the data region of a column file.
|
FileDataBufferStore.StoredBufferMessage |
Message implementation to wrap a stored buffer and associated boundaries.
|
FilteredTableDataService |
TableDataService implementation with support to filter the provided TableLocations.
|
FullTableLocationKey |
|
FullTableLocationKey.AggregateTableLocationKey |
FullTableLocationKey representing all internal partition values.
|
FunctionConsistencyMonitor |
|
FunctionConsistencyMonitor.ConsistentSupplier<T> |
A supplier that uses a FunctionConsistencyMonitor to ensure that multiple invocations to the same function
always return the same value, even if underlying conditions (like the date) change.
|
LazyFileAccessor |
Lazily-initialized FileAccessor implementation.
|
OffsetFileAccessor<UFAT extends FileAccessor> |
Wrap an underlying FileAccessor, providing an offset view into the underlying accessor's data.
|
RandomGroupingBuilder<DATA_TYPE> |
Builder for constructing groupings from one or more <value, key range> pairs, with no requirement that
key ranges be sequential.
|
SimpleTableLocationKey |
Table location key for simple (i.e.
|
SingleTableLocationProvider |
|
StandaloneTableKey |
Table location key for simple standalone tables.
|
SubscriptionAggregator<LISTENER_TYPE extends BasicTableDataListener> |
Implement optional subscription support suitable for multiple TableDataService components.
|
TableDataProtocol |
Defines a protocol for requesting and sending table data.
|
TableDataProtocol.LocalClient |
|
TableDataProtocol.LocalServer |
|
TableDataProtocol.RemoteClient |
|
TableDataProtocol.RemoteServer |
|
TableDataService.Null |
|
TableKey.KeyedObjectKeyImpl<VALUE_TYPE> |
|
TableKey.SelfKeyedObjectKeyImpl<VALUE_TYPE extends TableKey> |
|
TableLocationKey.ComparatorImpl |
|
TableLocationKey.KeyedObjectKeyImpl<VALUE_TYPE> |
|
TableLocationKey.SelfKeyedObjectKeyImpl<VALUE_TYPE extends TableLocationKey> |
|
TableLocationLookupKey<TYPE extends CharSequence> |
A simple implementation of TableLocationKey for use in hash lookups.
|
TableLocationLookupKey.Immutable |
|
TableLocationLookupKey.Reusable |
|
TableLocationStateHolder |
Tool for generic multi-field "atomic" get/set of state values for a table location.
|
TableLocationSubscriptionBuffer |
Intermediates between push-based subscription to a TableLocationProvider and polling on LiveTable refresh.
|
TableLocationUpdateSubscriptionBuffer |
Intermediates between push-based subscription to a TableLocation and polling on LiveTable refresh.
|
TableLookupKey<NAME_TYPE extends CharSequence> |
A simple implementation of TableKey for use in hash lookups, or as a parent class for complex sub-classes.
|
TableLookupKey.Immutable |
An immutable TableLookupKey
|
TableLookupKey.Reusable |
|
WatchServiceTrial |
This is simply a test / proof-of-concept of WatchServices.
|