Index
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form
A
- absSumBy(SelectColumn...) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- accept(TableKey) - Method in class io.deephaven.enterprise.tabledataservice.filter.EnterpriseFilterWrapper
- accept(TableLocationKey) - Method in class io.deephaven.enterprise.tabledataservice.filter.EnterpriseFilterWrapper
- ACL_ATTRIBUTE - Static variable in interface io.deephaven.enterprise.acl.EdgeAclProvider
- AclFilterGenerator - Interface in io.deephaven.enterprise.acl
-
This interface defines an object that generates
WhereFilter
s to apply as ACLs to tables based upon aUserContext
and potentially a namespace and table name. - AclHelper - Class in io.deephaven.enterprise.acl.impl
- AclHelper() - Constructor for class io.deephaven.enterprise.acl.impl.AclHelper
- AclSupport - Interface in io.deephaven.enterprise.acl
-
A support object to assist in the creation of Row and column ACLs.
- activateUnderlyingDataSource() - Method in class io.deephaven.enterprise.locations.local.deephaven.OnDiskDeephavenTableLocation
- activateUnderlyingDataSource() - Method in class io.deephaven.enterprise.locations.remote.RemoteDeephavenTableLocation
- adapt() - Method in interface io.deephaven.enterprise.locations.EnterpriseTableKey
-
Get an Enterprise formatted version of this
EnterpriseTableKey
- adapt() - Method in interface io.deephaven.enterprise.locations.FixedPartitionedEnterpriseTableLocationKey
-
Return an Enterprise
TableLocationKey
version of this key. - adapt() - Method in class io.deephaven.enterprise.locations.impl.BasicFixedPartitionedDeephavenTableLocationKey
- adapt() - Method in class io.deephaven.enterprise.locations.impl.EnterpriseTableKeyImpl
- adaptFlags(Row.Flags) - Static method in class io.deephaven.enterprise.dnd.logger.engine.impl.BinaryRowUtils
-
Adapt flags from Community Core to Enterprise Shadowed flags.
- adaptOrderedKeys(OrderedKeys) - Method in class io.deephaven.enterprise.compatibility.chunk.FillContextWrapper
- addAcl(String, Object) - Static method in interface io.deephaven.enterprise.acl.EdgeAclProvider
- addAcl(String, Object) - Static method in class io.deephaven.enterprise.acl.transform.GenericObjectTransformer
-
Add visibility for the specified object to the specified group.
- addAllObjectNames(Iterable<String>) - Method in class io.deephaven.proto.pqworker.ObjectAccessRequest.Builder
-
repeated string objectNames = 1;
- addAllValues(Iterable<String>) - Method in class io.deephaven.proto.pqworker.StringList.Builder
-
repeated string values = 1;
- addFilter(String, AclFilterGenerator) - Method in class io.deephaven.enterprise.acl.generator.CombiningFilterGenerator
-
Add a
AclFilterGenerator
that will be applied only if the user is a member of the specified group. - addNotification(NotificationQueue.Notification) - Method in class io.deephaven.enterprise.compatibility.NotificationQueueAdapter
- addObjectNames(String) - Method in class io.deephaven.proto.pqworker.ObjectAccessRequest.Builder
-
repeated string objectNames = 1;
- addObjectNamesBytes(ByteString) - Method in class io.deephaven.proto.pqworker.ObjectAccessRequest.Builder
-
repeated string objectNames = 1;
- addObserver(ControllerClientGrpc.Observer) - Method in class io.deephaven.enterprise.dnd.controller.client.ControllerClientGrpc
-
Add a status listener.
- addQueryConfiguration(PersistentQueryConfigMessage) - Method in class io.deephaven.enterprise.dnd.controller.client.ControllerClientGrpc
-
Adds a configuration to the controller's hash table.
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class io.deephaven.proto.pqworker.ListenErrorRequest.Builder
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class io.deephaven.proto.pqworker.ListenErrorResponse.Builder
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class io.deephaven.proto.pqworker.ObjectAccessRequest.Builder
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse.Builder
- addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class io.deephaven.proto.pqworker.StringList.Builder
- addTable(LiveTable) - Method in class io.deephaven.enterprise.compatibility.LiveTableRegistrarAdapter
- addValues(String) - Method in class io.deephaven.proto.pqworker.StringList.Builder
-
repeated string values = 1;
- addValuesBytes(ByteString) - Method in class io.deephaven.proto.pqworker.StringList.Builder
-
repeated string values = 1;
- AdminOnlyConsoleAuthWiring - Class in io.deephaven.enterprise.dnd.authentication
-
This auth wiring only allows users marked as administrators for the query to perform console operations.
- AdminOnlyConsoleAuthWiring() - Constructor for class io.deephaven.enterprise.dnd.authentication.AdminOnlyConsoleAuthWiring
- AdminOnlyWorkerAuthWiring - Class in io.deephaven.enterprise.dnd.authentication
-
This auth wiring only allows users marked as administrators for the query to perform console operations.
- AdminOnlyWorkerAuthWiring() - Constructor for class io.deephaven.enterprise.dnd.authentication.AdminOnlyWorkerAuthWiring
- advance(long) - Method in class io.deephaven.enterprise.compatibility.rowset.OrderedKeysToRowSequenceIteratorAdapter
- aj(Table, MatchPair[], MatchPair[], Table.AsOfMatchRule) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- allocator - Variable in class io.deephaven.enterprise.dnd.client.DndSession
- allocator() - Method in class io.deephaven.enterprise.dnd.client.DndSession
-
Get the underlying
RootAllocator
- allowsReinterpret(Class<ALTERNATE_DATA_TYPE>) - Method in class io.deephaven.enterprise.compatibility.filter.ColumnSourceAdapterForFilter
- append(LogOutput) - Method in class io.deephaven.enterprise.locations.impl.EnterpriseTableKeyImpl
- append(LogOutput) - Method in interface io.deephaven.enterprise.locations.DeephavenFormatTableLocation
- append(LogOutput) - Method in class io.deephaven.enterprise.locations.remote.RemoteDeephavenTableLocation
- append(ILoggingEvent) - Method in class io.deephaven.enterprise.dnd.ProcessEventLogAppender
- append(LogOutput) - Method in class io.deephaven.enterprise.dnd.authentication.DheAuthContext
- append(LogOutput) - Method in class io.deephaven.enterprise.locations.impl.BasicFixedPartitionedDeephavenTableLocationKey
- append(LogOutput) - Method in class io.deephaven.enterprise.dnd.authentication.DheAuthContext
- applicationVersion() - Method in class io.deephaven.enterprise.database.SystemTableLogger.Options
-
Get the application version used to write the log file.
- applicationVersion(int) - Method in interface io.deephaven.enterprise.database.SystemTableLogger.Options.Builder
-
What application log version should the table be logged with (defaults to zero)
- applyTo(Table) - Method in interface io.deephaven.enterprise.acl.EdgeAclProvider
-
Attach the ACLs to the specified table
- applyTo(Table) - Method in class io.deephaven.enterprise.acl.impl.ColumnAcl
-
Apply these column ACLs to the specified base table
- applyToAllBy(String, String, SelectColumn...) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- ARRAY_PREFIX - Static variable in class io.deephaven.enterprise.compatibility.shadow.ShadowCompatibility
- asOfTime(Instant) - Method in class io.deephaven.enterprise.dnd.query.util.perf.PerformanceOverview
-
Set the start of the time range to filter performance data.
- asOfTimeString(String) - Method in class io.deephaven.enterprise.dnd.query.util.perf.PerformanceOverview
-
Set the start of the time range to filter performance data.
- asRowKeyChunk() - Method in class io.deephaven.enterprise.compatibility.rowset.OrderedKeysToRowSequenceAdapter
- asRowKeyRangesChunk() - Method in class io.deephaven.enterprise.compatibility.rowset.OrderedKeysToRowSequenceAdapter
- asRowSet() - Method in class io.deephaven.enterprise.compatibility.rowset.OrderedKeysToRowSequenceAdapter
- asyncStub - Variable in class io.deephaven.enterprise.dnd.controller.client.ControllerClientGrpc
- authenticate(AuthToken) - Method in class io.deephaven.enterprise.dnd.controller.client.ControllerClientGrpc
-
Use the specified auth token to authenticate this client to the hashtable server.
- authenticateAndObtainAuthenticationInfo(Channel, AuthToken) - Static method in class io.deephaven.enterprise.dnd.authentication.DndAuthUtils
- authenticateAsync(long, AuthToken) - Method in class io.deephaven.enterprise.dnd.controller.client.ControllerClientGrpc
- authenticateAsync(AuthToken) - Method in class io.deephaven.enterprise.dnd.controller.client.ControllerClientGrpc
-
Use the specified auth token to authenticate this client to the hashtable server.
- authRetryStrategy - Variable in class io.deephaven.enterprise.dnd.controller.client.ControllerClientGrpc
- AuthWiringBase - Class in io.deephaven.enterprise.dnd.authentication
- AuthWiringBase() - Constructor for class io.deephaven.enterprise.dnd.authentication.AuthWiringBase
- autoDelete(Boolean) - Method in interface io.deephaven.enterprise.dnd.EnterpriseJettyComponent.Builder
-
Set if the worker should delete its corresponding query on shutdown
- avgBy(SelectColumn...) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
B
- BasicFixedPartitionedDeephavenTableLocationKey - Class in io.deephaven.enterprise.locations.impl
-
An
FixedPartitionedEnterpriseTableLocationKey
that simply wraps an enterpriseTableLocationKey
- BasicFixedPartitionedDeephavenTableLocationKey(String, Map<String, Comparable<?>>) - Constructor for class io.deephaven.enterprise.locations.impl.BasicFixedPartitionedDeephavenTableLocationKey
- BasicFixedPartitionedDeephavenTableLocationKey(String, TableLocationKey) - Constructor for class io.deephaven.enterprise.locations.impl.BasicFixedPartitionedDeephavenTableLocationKey
- BasicObserver() - Constructor for class io.deephaven.enterprise.dnd.controller.client.ControllerClientGrpc.BasicObserver
- BinaryRowLoggerDnd - Class in io.deephaven.enterprise.dnd.logger.engine.impl
-
Base implementation for DnD components to log binary rows via LAS.
- BinaryRowLoggerDnd(String, String, String[], SupportedType[], Object[], Map<String, Object>, int, boolean, String, ZoneId, TableIdentifier.NamespaceSet, String, String) - Constructor for class io.deephaven.enterprise.dnd.logger.engine.impl.BinaryRowLoggerDnd
- binaryRowPool - Variable in class io.deephaven.enterprise.dnd.logger.engine.impl.BinaryRowLoggerDnd
- binaryRowPool - Variable in class io.deephaven.enterprise.dnd.logger.engine.impl.EngineTableLoggerDndImpl
- BinaryRowUtils - Class in io.deephaven.enterprise.dnd.logger.engine.impl
- BinaryRowUtils() - Constructor for class io.deephaven.enterprise.dnd.logger.engine.impl.BinaryRowUtils
- bindCsvResolver(CsvTableResolver) - Method in interface io.deephaven.enterprise.dnd.modules.URIModule
- bindDatabaseMethods(DatabaseAutocompleteDelegate) - Method in interface io.deephaven.enterprise.dnd.modules.GroovyConsoleSessionWithDatabaseModule
- bindObjectServiceGrpcImpl(ObjectServiceGrpcBinding) - Method in interface io.deephaven.enterprise.dnd.modules.ObjectModuleOverride
- bindParquetResolver(ParquetTableResolver) - Method in interface io.deephaven.enterprise.dnd.modules.URIModule
- bindQueryScopeResolver(QueryScopeResolver) - Method in interface io.deephaven.enterprise.dnd.modules.URIModule
- bindResolvers(Set<UriResolver>) - Static method in interface io.deephaven.enterprise.dnd.modules.URIModule
- bindsBarrageTableResolver(BarrageTableResolver) - Method in interface io.deephaven.enterprise.dnd.modules.URIModule
- bindService() - Method in class io.deephaven.enterprise.dnd.modules.ObjectServiceGrpcBinding
- bindService() - Method in class io.deephaven.proto.pqworker.grpc.PQWorkerApiGrpc.PQWorkerApiImplBase
- BUFFER_BYTE_SIZE - Static variable in enum class io.deephaven.enterprise.sources.regioned.BufferedType
- BufferedColumnRegion<ATTR extends Any> - Interface in io.deephaven.enterprise.sources.regioned
-
A
ColumnRegion
backed by a buffer of some sort. - BufferedColumnRegionBase<ATTR extends Values> - Class in io.deephaven.enterprise.sources.regioned.impl
-
The basic implementation for a
BufferedColumnRegion
. - BufferedColumnRegionByte<ATTR extends Values> - Class in io.deephaven.enterprise.sources.regioned.impl
-
ColumnRegionByte
implementation for regions that support fetching primitive bytes from aFileDataBufferStore
. - BufferedColumnRegionByte(FileDataBufferStore) - Constructor for class io.deephaven.enterprise.sources.regioned.impl.BufferedColumnRegionByte
- BufferedColumnRegionChar<ATTR extends Values> - Class in io.deephaven.enterprise.sources.regioned.impl
-
ColumnRegionChar
implementation for regions that support fetching primitive chars from aFileDataBufferStore
. - BufferedColumnRegionChar(FileDataBufferStore) - Constructor for class io.deephaven.enterprise.sources.regioned.impl.BufferedColumnRegionChar
- BufferedColumnRegionDouble<ATTR extends Values> - Class in io.deephaven.enterprise.sources.regioned.impl
-
ColumnRegionDouble
implementation for regions that support fetching primitive doubles from aFileDataBufferStore
. - BufferedColumnRegionDouble(FileDataBufferStore) - Constructor for class io.deephaven.enterprise.sources.regioned.impl.BufferedColumnRegionDouble
- BufferedColumnRegionFloat<ATTR extends Values> - Class in io.deephaven.enterprise.sources.regioned.impl
-
ColumnRegionFloat
implementation for regions that support fetching primitive floats from aFileDataBufferStore
. - BufferedColumnRegionFloat(FileDataBufferStore) - Constructor for class io.deephaven.enterprise.sources.regioned.impl.BufferedColumnRegionFloat
- BufferedColumnRegionInt<ATTR extends Values> - Class in io.deephaven.enterprise.sources.regioned.impl
-
ColumnRegionInt
implementation for regions that support fetching primitive ints from aFileDataBufferStore
. - BufferedColumnRegionInt(FileDataBufferStore) - Constructor for class io.deephaven.enterprise.sources.regioned.impl.BufferedColumnRegionInt
- BufferedColumnRegionIntAsLong<ATTR extends Values> - Class in io.deephaven.enterprise.sources.regioned.impl
-
ColumnRegionLong
implementation for regions that support fetching primitive ints from aFileDataBufferStore
. - BufferedColumnRegionIntAsLong(FileDataBufferStore) - Constructor for class io.deephaven.enterprise.sources.regioned.impl.BufferedColumnRegionIntAsLong
- BufferedColumnRegionLong<ATTR extends Values> - Class in io.deephaven.enterprise.sources.regioned.impl
-
ColumnRegionLongWithLength
implementation for regions that support fetching primitive longs from aFileDataBufferStore
. - BufferedColumnRegionLong(FileDataBufferStore) - Constructor for class io.deephaven.enterprise.sources.regioned.impl.BufferedColumnRegionLong
- BufferedColumnRegionShort<ATTR extends Values> - Class in io.deephaven.enterprise.sources.regioned.impl
-
ColumnRegionShort
implementation for regions that support fetching primitive shorts from aFileDataBufferStore
. - BufferedColumnRegionShort(FileDataBufferStore) - Constructor for class io.deephaven.enterprise.sources.regioned.impl.BufferedColumnRegionShort
- BufferedPage<ATTR extends Any> - Interface in io.deephaven.enterprise.sources.regioned
- BufferedPageByte<ATTR extends Any> - Class in io.deephaven.enterprise.sources.regioned.impl
- BufferedPageByte() - Constructor for class io.deephaven.enterprise.sources.regioned.impl.BufferedPageByte
- BufferedPageChar<ATTR extends Any> - Class in io.deephaven.enterprise.sources.regioned.impl
- BufferedPageChar() - Constructor for class io.deephaven.enterprise.sources.regioned.impl.BufferedPageChar
- BufferedPageDouble<ATTR extends Any> - Class in io.deephaven.enterprise.sources.regioned.impl
- BufferedPageDouble() - Constructor for class io.deephaven.enterprise.sources.regioned.impl.BufferedPageDouble
- BufferedPageFloat<ATTR extends Any> - Class in io.deephaven.enterprise.sources.regioned.impl
- BufferedPageFloat() - Constructor for class io.deephaven.enterprise.sources.regioned.impl.BufferedPageFloat
- BufferedPageInt<ATTR extends Any> - Class in io.deephaven.enterprise.sources.regioned.impl
- BufferedPageInt() - Constructor for class io.deephaven.enterprise.sources.regioned.impl.BufferedPageInt
- BufferedPageIntAsLong<ATTR extends Any> - Class in io.deephaven.enterprise.sources.regioned.impl
- BufferedPageIntAsLong() - Constructor for class io.deephaven.enterprise.sources.regioned.impl.BufferedPageIntAsLong
- BufferedPageLong<ATTR extends Any> - Class in io.deephaven.enterprise.sources.regioned.impl
- BufferedPageLong() - Constructor for class io.deephaven.enterprise.sources.regioned.impl.BufferedPageLong
- BufferedPageShort<ATTR extends Any> - Class in io.deephaven.enterprise.sources.regioned.impl
- BufferedPageShort() - Constructor for class io.deephaven.enterprise.sources.regioned.impl.BufferedPageShort
- bufferedType() - Method in interface io.deephaven.enterprise.sources.regioned.BufferedPage
-
The
BufferedType
associated with a buffer page has all the helper functions for calculating offsets, lengths, etc. - bufferedType() - Method in class io.deephaven.enterprise.sources.regioned.impl.BufferedPageByte
- bufferedType() - Method in class io.deephaven.enterprise.sources.regioned.impl.BufferedPageChar
- bufferedType() - Method in class io.deephaven.enterprise.sources.regioned.impl.BufferedPageDouble
- bufferedType() - Method in class io.deephaven.enterprise.sources.regioned.impl.BufferedPageFloat
- bufferedType() - Method in class io.deephaven.enterprise.sources.regioned.impl.BufferedPageInt
- bufferedType() - Method in class io.deephaven.enterprise.sources.regioned.impl.BufferedPageIntAsLong
- bufferedType() - Method in class io.deephaven.enterprise.sources.regioned.impl.BufferedPageLong
- bufferedType() - Method in class io.deephaven.enterprise.sources.regioned.impl.BufferedPageShort
- BufferedType - Enum Class in io.deephaven.enterprise.sources.regioned
- build() - Method in interface io.deephaven.enterprise.acl.EdgeAclProvider.Builder
-
Construct the ACL object.
- build() - Method in interface io.deephaven.enterprise.database.SystemTableLogger.Options.Builder
-
Build an immutable Options object.
- build() - Method in interface io.deephaven.enterprise.dnd.EnterpriseJettyComponent.Builder
- build() - Method in class io.deephaven.proto.pqworker.ListenErrorRequest.Builder
- build() - Method in class io.deephaven.proto.pqworker.ListenErrorResponse.Builder
- build() - Method in class io.deephaven.proto.pqworker.ObjectAccessRequest.Builder
- build() - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse.Builder
- build() - Method in class io.deephaven.proto.pqworker.StringList.Builder
- build(Channel, CallOptions) - Method in class io.deephaven.proto.pqworker.grpc.PQWorkerApiGrpc.PQWorkerApiBlockingStub
- build(Channel, CallOptions) - Method in class io.deephaven.proto.pqworker.grpc.PQWorkerApiGrpc.PQWorkerApiFutureStub
- build(Channel, CallOptions) - Method in class io.deephaven.proto.pqworker.grpc.PQWorkerApiGrpc.PQWorkerApiStub
- builder() - Static method in interface io.deephaven.enterprise.acl.EdgeAclProvider
-
Get a
EdgeAclProvider.Builder
to create ACLs for a table. - builder() - Static method in class io.deephaven.enterprise.acl.impl.EdgeAclImpl
-
Get a builder for constructing an EdgeAclImpl
- buildPartial() - Method in class io.deephaven.proto.pqworker.ListenErrorRequest.Builder
- buildPartial() - Method in class io.deephaven.proto.pqworker.ListenErrorResponse.Builder
- buildPartial() - Method in class io.deephaven.proto.pqworker.ObjectAccessRequest.Builder
- buildPartial() - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse.Builder
- buildPartial() - Method in class io.deephaven.proto.pqworker.StringList.Builder
- by(AggregationStateFactory, SelectColumn...) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- byExternal(boolean, String...) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- Byte - Enum constant in enum class io.deephaven.enterprise.sources.regioned.BufferedType
C
- canExecute(long) - Method in class io.deephaven.enterprise.compatibility.NotificationAdapter
- canMemoize() - Method in class io.deephaven.enterprise.compatibility.filter.EnterpriseFilterAdapter
- canTransform(T) - Method in class io.deephaven.enterprise.acl.transform.GenericObjectTransformer
- canTransform(T) - Method in class io.deephaven.enterprise.acl.transform.TableTicketTransformer
- canTransform(T) - Method in interface io.deephaven.enterprise.dnd.authentication.transform.TicketTransformer
-
Check if this transformer can apply a transformation to the specified value.
- catalogTable() - Static method in class io.deephaven.enterprise.dnd.client.DndSession
-
Create a
TableSpec
based on the catalog table from the server. - channel - Variable in class io.deephaven.enterprise.dnd.client.DndSession
- channel() - Method in class io.deephaven.enterprise.dnd.client.DndSession
-
Get the underlying
ManagedChannel
- Char - Enum constant in enum class io.deephaven.enterprise.sources.regioned.BufferedType
- checkWidth(int) - Method in class io.deephaven.enterprise.compatibility.shadow.ShadowingSerializableDecoder
- ChunkAdapter - Interface in io.deephaven.enterprise.compatibility.chunk
-
Implementors provide a method to adapt an Enterprise
WritableChunk
into a CommunityWritableChunk
. - clear() - Method in class io.deephaven.proto.pqworker.ListenErrorRequest.Builder
- clear() - Method in class io.deephaven.proto.pqworker.ListenErrorResponse.Builder
- clear() - Method in class io.deephaven.proto.pqworker.ObjectAccessRequest.Builder
- clear() - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse.Builder
- clear() - Method in class io.deephaven.proto.pqworker.StringList.Builder
- clearField(Descriptors.FieldDescriptor) - Method in class io.deephaven.proto.pqworker.ListenErrorRequest.Builder
- clearField(Descriptors.FieldDescriptor) - Method in class io.deephaven.proto.pqworker.ListenErrorResponse.Builder
- clearField(Descriptors.FieldDescriptor) - Method in class io.deephaven.proto.pqworker.ObjectAccessRequest.Builder
- clearField(Descriptors.FieldDescriptor) - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse.Builder
- clearField(Descriptors.FieldDescriptor) - Method in class io.deephaven.proto.pqworker.StringList.Builder
- clearMessage() - Method in class io.deephaven.proto.pqworker.ListenErrorResponse.Builder
-
string message = 1;
- clearObjectGroups() - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse.Builder
- clearObjectNames() - Method in class io.deephaven.proto.pqworker.ObjectAccessRequest.Builder
-
repeated string objectNames = 1;
- clearOneof(Descriptors.OneofDescriptor) - Method in class io.deephaven.proto.pqworker.ListenErrorRequest.Builder
- clearOneof(Descriptors.OneofDescriptor) - Method in class io.deephaven.proto.pqworker.ListenErrorResponse.Builder
- clearOneof(Descriptors.OneofDescriptor) - Method in class io.deephaven.proto.pqworker.ObjectAccessRequest.Builder
- clearOneof(Descriptors.OneofDescriptor) - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse.Builder
- clearOneof(Descriptors.OneofDescriptor) - Method in class io.deephaven.proto.pqworker.StringList.Builder
- clearShortCauses() - Method in class io.deephaven.proto.pqworker.ListenErrorResponse.Builder
-
string shortCauses = 3;
- clearSortingRestrictions() - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- clearStackTrace() - Method in class io.deephaven.proto.pqworker.ListenErrorResponse.Builder
-
string stackTrace = 2;
- clearValues() - Method in class io.deephaven.proto.pqworker.StringList.Builder
-
repeated string values = 1;
- clearWasUncaught() - Method in class io.deephaven.proto.pqworker.ListenErrorResponse.Builder
-
bool wasUncaught = 4;
- clone() - Method in class io.deephaven.proto.pqworker.ListenErrorRequest.Builder
- clone() - Method in class io.deephaven.proto.pqworker.ListenErrorResponse.Builder
- clone() - Method in class io.deephaven.proto.pqworker.ObjectAccessRequest.Builder
- clone() - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse.Builder
- clone() - Method in class io.deephaven.proto.pqworker.StringList.Builder
- close() - Method in class io.deephaven.enterprise.compatibility.chunk.FillContextWrapper
- close() - Method in class io.deephaven.enterprise.compatibility.rowset.OrderedKeysToRowSequenceAdapter
- close() - Method in class io.deephaven.enterprise.compatibility.rowset.OrderedKeysToRowSequenceIteratorAdapter
- close() - Method in class io.deephaven.enterprise.dnd.client.DndSession
-
Close and release the underlying session and channel for this session.
- close() - Method in class io.deephaven.enterprise.dnd.client.DndSessionFactoryBarrage
-
Close all resources and connections with the server.
- close() - Method in class io.deephaven.enterprise.dnd.logger.engine.impl.BinaryRowLoggerDnd
- close() - Method in class io.deephaven.enterprise.dnd.modules.DndSessionListenerModule.SessionMonitor
- close() - Method in class io.deephaven.enterprise.sources.regioned.impl.ColumnRegionFillContext
- close() - Method in class io.deephaven.enterprise.sources.regioned.impl.ObjectRegionFillContext
- CodecCompatibility - Class in io.deephaven.enterprise.compatibility
- CodecCompatibility() - Constructor for class io.deephaven.enterprise.compatibility.CodecCompatibility
- COLUMN_VERSION_COLUMN_NAME - Static variable in class io.deephaven.enterprise.locations.local.HiveLocationsTableKeyFinder
-
The column name containing the integer version of column files for Deephaven format.
- columnAcl(String, String, AclFilterGenerator) - Method in interface io.deephaven.enterprise.acl.EdgeAclProvider.Builder
-
Add a Column ACL for the specified group and column to the table.
- columnAcl(String, Collection<String>, AclFilterGenerator) - Method in interface io.deephaven.enterprise.acl.EdgeAclProvider.Builder
-
Add a Column ACL for the specified group and column to the table.
- ColumnAcl - Class in io.deephaven.enterprise.acl.impl
-
A collection of
WhereFilter
s by group and column. - ColumnRegionByteWithLength<ATTR extends Any> - Interface in io.deephaven.enterprise.sources.regioned
-
A
ColumnRegionByte
that supports querying its length. - ColumnRegionFillContext - Class in io.deephaven.enterprise.sources.regioned.impl
- ColumnRegionFillContext() - Constructor for class io.deephaven.enterprise.sources.regioned.impl.ColumnRegionFillContext
- ColumnRegionLongWithLength<ATTR extends Any> - Interface in io.deephaven.enterprise.sources.regioned
-
A
ColumnRegionLong
that supports querying its length. - ColumnRegionObjectCached<T,
ATTR extends Values, OFFSET_LOOKUP_CACHE extends OffsetLookupCache<T, ChunkSource.FillContext>> - Class in io.deephaven.enterprise.sources.regioned.impl -
Column region interface for regions that support fetching objects.
- ColumnRegionObjectCached(ColumnRegionObjectCached.CacheFactory<T, OFFSET_LOOKUP_CACHE>, FillContextMaker, ColumnRegionObject<T, ATTR>) - Constructor for class io.deephaven.enterprise.sources.regioned.impl.ColumnRegionObjectCached
- ColumnRegionObjectCached.CacheFactory<T,
OFFSET_LOOKUP_CACHE extends OffsetLookupCache<T, ChunkSource.FillContext>> - Interface in io.deephaven.enterprise.sources.regioned.impl - ColumnRegionObjectCodecFixed<T,
ATTR extends Values> - Class in io.deephaven.enterprise.sources.regioned.impl -
A
ColumnRegion
for non-primitive types that have a fixed size. - ColumnRegionObjectCodecFixed(ObjectDecoder<T>, ColumnRegionByteWithLength<EncodedObjects>) - Constructor for class io.deephaven.enterprise.sources.regioned.impl.ColumnRegionObjectCodecFixed
- ColumnRegionObjectCodecVariable<T,
ATTR extends Values> - Class in io.deephaven.enterprise.sources.regioned.impl -
A
ColumnRegion
for non-primitive types that have a variable size. - ColumnRegionObjectCodecVariable(ObjectDecoder<T>, ColumnRegionLongWithLength<Indices>, ColumnRegionByte<EncodedObjects>) - Constructor for class io.deephaven.enterprise.sources.regioned.impl.ColumnRegionObjectCodecVariable
- ColumnRegionObjectWithDictionary<T,
ATTR extends Values> - Class in io.deephaven.enterprise.sources.regioned.impl -
A Column region for objects that is backed by a dictionary of values.
- ColumnRegionObjectWithDictionary(ColumnRegionObject<T, ATTR>, ColumnRegionLong<DictionaryKeys>, int) - Constructor for class io.deephaven.enterprise.sources.regioned.impl.ColumnRegionObjectWithDictionary
- ColumnRegionStringSet<ATTR extends Values> - Class in io.deephaven.enterprise.sources.regioned.impl
-
A
ColumnRegionObject
implementation for Deephaven formatStringSet
columns where stringsets are stored as a bitmask and dictionary column - ColumnRegionStringSet(ColumnRegionLong<StringSetBitmasks>, ColumnRegionObjectCached<String, ATTR, ReversibleCache>) - Constructor for class io.deephaven.enterprise.sources.regioned.impl.ColumnRegionStringSet
- ColumnSourceAdapterForFilter<T> - Class in io.deephaven.enterprise.compatibility.filter
-
An adapter from Community
ColumnSource
to EnterpriseColumnSource
geared towards supportingTable.where()
. - ColumnSourceAdapterForFilter(ColumnSource<T>) - Constructor for class io.deephaven.enterprise.compatibility.filter.ColumnSourceAdapterForFilter
- CombiningFilterGenerator - Class in io.deephaven.enterprise.acl.generator
-
A Filter generator that provides a means to apply separate
AclFilterGenerator
sets based on a users groups. - CombiningFilterGenerator(CombiningFilterGenerator.Type) - Constructor for class io.deephaven.enterprise.acl.generator.CombiningFilterGenerator
- CombiningFilterGenerator(PermissionFilterProvider, Database, CombiningFilterGenerator.Type, Map<String, List<FilterGenerator>>) - Constructor for class io.deephaven.enterprise.acl.generator.CombiningFilterGenerator
-
This is a compatibility constructor for converting an Enterprise version to Community.
- commitToBroker(boolean) - Method in class io.deephaven.enterprise.kafkawriter.KafkaTableWriter.Options
-
Optionally, you can specify whether the ingester commits offsets to the Kafka broker.
- CommunityLongChunkAdapter - Class in io.deephaven.chunk
- CommunityLongChunkAdapter() - Constructor for class io.deephaven.chunk.CommunityLongChunkAdapter
- compareTo(TableLocationKey) - Method in class io.deephaven.enterprise.locations.impl.BasicFixedPartitionedDeephavenTableLocationKey
- compareTo(TableLocationKey) - Method in class io.deephaven.enterprise.locations.local.deephaven.DeephavenTableLocationKey
- compareTo(TableLocationKey) - Method in class io.deephaven.enterprise.locations.local.EnterpriseTableLocationKeyUnresolved
- compareTo(TableLocationKey) - Method in class io.deephaven.enterprise.locations.local.parquet.EnterpriseParquetTableLocationKey
- CompleteTableName - Class in io.deephaven.enterprise.dnd.autocomplete
-
A class specifically for completing table names; to be called after the completer has discovered the name of the table.
- CompleteTableName(ChunkerCompleter, ChunkerInvoke, Stream<String>) - Constructor for class io.deephaven.enterprise.dnd.autocomplete.CompleteTableName
- CompleteTableNamespace - Class in io.deephaven.enterprise.dnd.autocomplete
-
A class specifically for completing table namespaces; to be called after the completer has discovered the name of the namespace.
- CompleteTableNamespace(ChunkerCompleter, ChunkerInvoke, Stream<String>) - Constructor for class io.deephaven.enterprise.dnd.autocomplete.CompleteTableNamespace
- computeHashCode(EnterpriseTableLocationKey) - Static method in interface io.deephaven.enterprise.locations.EnterpriseTableLocationKey
-
Compute the hash code of the key using only the partitions.
- conjunctive(AclFilterGenerator...) - Static method in interface io.deephaven.enterprise.acl.AclFilterGenerator
-
Create an
AclFilterGenerator
that conjunctively combines the input generators. - conjunctive(Collection<AclFilterGenerator>) - Static method in interface io.deephaven.enterprise.acl.AclFilterGenerator
-
Create an
AclFilterGenerator
that conjunctively combines the input generators. - ConjunctiveFilterGenerator - Class in io.deephaven.enterprise.acl.generator
-
AclFilterGenerator
for combining the results of multipleAclFilterGenerator
s conjunctively, i.e. - ConjunctiveFilterGenerator(AclFilterGenerator...) - Constructor for class io.deephaven.enterprise.acl.generator.ConjunctiveFilterGenerator
-
Construct a
FilterGenerator
that will generate a singleWhereFilter
that expresses the conjunction of theWhereFilter
s generated byfilterGenerators
. - ConjunctiveFilterGenerator(PermissionFilterProvider, Database, FilterGenerator...) - Constructor for class io.deephaven.enterprise.acl.generator.ConjunctiveFilterGenerator
-
Construct a
FilterGenerator
that will generate a singleWhereFilter
that expresses the conjunction of theWhereFilter
s generated byfilterGenerators
. - connect(InetSocketAddress) - Method in class io.deephaven.enterprise.tabledataservice.RemoteTableDataService
-
Connect to a remote server.
- connect(Function.Nullary<SocketAddress>) - Method in class io.deephaven.enterprise.tabledataservice.RemoteTableDataService
-
Connect to a remote server by address function, allowing fallback to different server addresses.
- consumeToDis(KafkaTableWriter.Options) - Static method in class io.deephaven.enterprise.kafkawriter.KafkaTableWriter
-
Consume a Kafka stream to a persistent Deephaven table.
- containsObjectGroups(String) - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse.Builder
-
map<string, .io.deephaven.proto.pqworker.StringList> objectGroups = 1;
- containsObjectGroups(String) - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse
-
map<string, .io.deephaven.proto.pqworker.StringList> objectGroups = 1;
- containsObjectGroups(String) - Method in interface io.deephaven.proto.pqworker.ObjectAccessResponseOrBuilder
-
map<string, .io.deephaven.proto.pqworker.StringList> objectGroups = 1;
- ControllerClientFactory - Class in io.deephaven.enterprise.dnd
-
A lazy provider of the singleton controller client for queries.
- ControllerClientFactory() - Constructor for class io.deephaven.enterprise.dnd.ControllerClientFactory
- ControllerClientGrpc - Class in io.deephaven.enterprise.dnd.controller.client
-
A client for subscribing to state from the PersistentQueryController and manipulating persistent queries.
- ControllerClientGrpc(String, ManagedChannel, ScheduledExecutorService, GrpcAuthenticationClientManager, long, long) - Constructor for class io.deephaven.enterprise.dnd.controller.client.ControllerClientGrpc
- ControllerClientGrpc.BasicObserver - Class in io.deephaven.enterprise.dnd.controller.client
-
A basic
ControllerClientGrpc.Observer
implementation with do-nothing methods. - ControllerClientGrpc.Observer - Interface in io.deephaven.enterprise.dnd.controller.client
- convertAndGetChunk(WritableChunk<EATTR>) - Method in class io.deephaven.enterprise.compatibility.chunk.FillContextWrapper
-
Convert the input Enterprise
WritableChunk
into a CommunityWritableChunk
. - convertFilter(SelectFilter) - Static method in class io.deephaven.enterprise.compatibility.filter.FilterCompatibility
- convertFilterGenerator(FilterGenerator) - Static method in class io.deephaven.enterprise.acl.impl.AclHelper
-
Convert the specified Enterprise
FilterGenerator
into a DnDAclFilterGenerator
- convertRangeFilter(AbstractRangeFilter) - Static method in class io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.select.RangeFilterAdapter
- convertToCommunity(TableDefinition) - Static method in class io.deephaven.enterprise.compatibility.TableDefinitionCompatibility
-
Convert the specified Enterprise format definition to a community
TableDefinition
. - convertToEnterprise(TableDefinition) - Static method in class io.deephaven.enterprise.compatibility.TableDefinitionCompatibility
-
This method does it's best to convert a Community definition to an enterprise one.
- convertToIndex(RowSet) - Static method in class io.deephaven.enterprise.compatibility.rowset.RowSetCompatibility
- convertToRowSet(Index) - Static method in class io.deephaven.enterprise.compatibility.rowset.RowSetCompatibility
- convertWritableInto(WritableLongChunk, ResettableWritableLongChunk) - Static method in class io.deephaven.chunk.CommunityLongChunkAdapter
- convertWritableInto(WritableChunk<?>, ResettableWritableChunk<?>) - Method in class io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.sources.chunk.EnterpriseByteChunkAdapter
- convertWritableInto(WritableChunk<?>, ResettableWritableChunk<?>) - Method in class io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.sources.chunk.EnterpriseCharChunkAdapter
- convertWritableInto(WritableChunk<?>, ResettableWritableChunk<?>) - Method in class io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.sources.chunk.EnterpriseDoubleChunkAdapter
- convertWritableInto(WritableChunk<?>, ResettableWritableChunk<?>) - Method in class io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.sources.chunk.EnterpriseFloatChunkAdapter
- convertWritableInto(WritableChunk<?>, ResettableWritableChunk<?>) - Method in class io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.sources.chunk.EnterpriseIntChunkAdapter
- convertWritableInto(WritableChunk<?>, ResettableWritableChunk<?>) - Method in class io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.sources.chunk.EnterpriseLongChunkAdapter
- convertWritableInto(WritableChunk<?>, ResettableWritableChunk<?>) - Method in class io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.sources.chunk.EnterpriseObjectChunkAdapter
- convertWritableInto(WritableChunk<?>, ResettableWritableChunk<?>) - Method in class io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.sources.chunk.EnterpriseShortChunkAdapter
- convertWritableInto(WritableChunk<?>, ResettableWritableChunk<?>) - Method in interface io.deephaven.enterprise.compatibility.chunk.ChunkAdapter
-
Convert the input Enterprise
WritableChunk
into a CommunityWritableChunk
. - copy() - Method in class io.deephaven.enterprise.acl.impl.DeferredACLTable
- copy() - Method in class io.deephaven.enterprise.compatibility.filter.EnterpriseFilterAdapter
- CORE_PLUS - Static variable in class io.deephaven.enterprise.tabledataservice.OnDiskTableDataService
- CORE_PLUS_HIVE_TYPE - Static variable in class io.deephaven.enterprise.tabledataservice.OnDiskTableDataService
- countBy(String, SelectColumn...) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- create() - Method in class io.deephaven.enterprise.dnd.autocomplete.DatabaseAutocompleteDelegate
- create(OffsetLookup<T, ChunkSource.FillContext>, FillContextMaker) - Method in interface io.deephaven.enterprise.sources.regioned.impl.ColumnRegionObjectCached.CacheFactory
- create(String, Scheduler, long, boolean) - Method in interface io.deephaven.enterprise.tabledataservice.ProtocolDriverFactory
- createAdaptedCodecArgs(String, String) - Static method in class io.deephaven.enterprise.compatibility.CodecCompatibility
- createDisjunctiveFilter(Collection<WhereFilter>[]) - Static method in class io.deephaven.enterprise.acl.impl.AclHelper
-
Create single where filter in Disjunctive Normal Form of the input filter collections
- createNullLoggerWithInterceptor() - Static method in class io.deephaven.enterprise.dnd.EnterpriseProcessEnvironmentCommunityAdapter
- createNullLoggerWithInterceptor(Class<?>) - Static method in class io.deephaven.enterprise.dnd.EnterpriseProcessEnvironmentCommunityAdapter
- createPersistentQueryConfig(String, float, long) - Method in class io.deephaven.enterprise.dnd.client.DndSessionFactoryBarrage
-
Create a new Interactive Console Persistent Query configuration with a language set to `Python`
- CURRENT_DATE_SENTINEL - Static variable in class io.deephaven.enterprise.dnd.logger.engine.impl.BinaryRowLoggerDnd
-
Sentinel Object for current date partitioning.
- currentDateColumnPartition() - Method in class io.deephaven.enterprise.database.SystemTableLogger.Options
-
Should we write to a column partition that is set to the Date when the row is logged?
- currentDateColumnPartition(boolean) - Method in interface io.deephaven.enterprise.database.SystemTableLogger.Options.Builder
-
Should we write to a column partition that is set to the Date when the row is logged?
D
- daily() - Static method in class io.deephaven.enterprise.kafkawriter.TimePartitionRotation
-
Return a function suitable for creating a daily column partition from nanoseconds since the epoch.
- daily(ZoneId, int) - Static method in class io.deephaven.enterprise.kafkawriter.TimePartitionRotation
-
Return a function suitable for creating a daily column partition from nanoseconds since the epoch.
- Database - Interface in io.deephaven.enterprise.database
-
This interface presents a view of the data store for the system in both Live, and Historical versions.
- DatabaseAdapter - Class in io.deephaven.enterprise.database.impl
-
This class exists as an adapter shim between the Community implementation of
DatabaseInternal
and theenterprise version
. - DatabaseAdapter(DatabaseInternal) - Constructor for class io.deephaven.enterprise.database.impl.DatabaseAdapter
- DatabaseAutocompleteDelegate - Class in io.deephaven.enterprise.dnd.autocomplete
-
Custom autocomplete results for DHE.
- DatabaseAutocompleteDelegate(Database) - Constructor for class io.deephaven.enterprise.dnd.autocomplete.DatabaseAutocompleteDelegate
- DatabaseImpl - Class in io.deephaven.enterprise.database.impl
-
A basic implementation of the
Database
interface. - DatabaseImpl(TableDataService, SchemaService, GroupProvider, SourceAclProvider, UserContext, AuditEventLogger) - Constructor for class io.deephaven.enterprise.database.impl.DatabaseImpl
- DatabaseInternal - Interface in io.deephaven.enterprise.database.impl
-
This partial interface defines methods that we need to include in
Database
for various reasons, but are not intended for use by client code. - DatabaseModule - Interface in io.deephaven.enterprise.dnd.modules
- DatabaseTicketResolver - Class in io.deephaven.enterprise.dnd.service.ticket
- DatabaseTicketResolver(AuthorizationProvider, Database) - Constructor for class io.deephaven.enterprise.dnd.service.ticket.DatabaseTicketResolver
- databaseWrapper() - Static method in class io.deephaven.enterprise.acl.impl.AclHelper
-
Get the Database wrapper to use for Enterprise integration
- dataImportServer(DataImportServer) - Method in class io.deephaven.enterprise.kafkawriter.KafkaTableWriter.Options
-
The DataImportServer to use for ingestion.
- date(String) - Method in class io.deephaven.enterprise.dnd.query.util.perf.PerformanceOverview
-
Set the date to start filtering performance data
- DbArrayToByteVectorDecoder - Class in io.deephaven.enterprise.compatibility.vector
- DbArrayToByteVectorDecoder(String) - Constructor for class io.deephaven.enterprise.compatibility.vector.DbArrayToByteVectorDecoder
- DbArrayToCharVectorDecoder - Class in io.deephaven.enterprise.compatibility.vector
- DbArrayToCharVectorDecoder(String) - Constructor for class io.deephaven.enterprise.compatibility.vector.DbArrayToCharVectorDecoder
- DbArrayToDoubleVectorDecoder - Class in io.deephaven.enterprise.compatibility.vector
- DbArrayToDoubleVectorDecoder(String) - Constructor for class io.deephaven.enterprise.compatibility.vector.DbArrayToDoubleVectorDecoder
- DbArrayToFloatVectorDecoder - Class in io.deephaven.enterprise.compatibility.vector
- DbArrayToFloatVectorDecoder(String) - Constructor for class io.deephaven.enterprise.compatibility.vector.DbArrayToFloatVectorDecoder
- DbArrayToIntVectorDecoder - Class in io.deephaven.enterprise.compatibility.vector
- DbArrayToIntVectorDecoder(String) - Constructor for class io.deephaven.enterprise.compatibility.vector.DbArrayToIntVectorDecoder
- DbArrayToLongVectorDecoder - Class in io.deephaven.enterprise.compatibility.vector
- DbArrayToLongVectorDecoder(String) - Constructor for class io.deephaven.enterprise.compatibility.vector.DbArrayToLongVectorDecoder
- DbArrayToObjectVectorDecoder - Class in io.deephaven.enterprise.compatibility.vector
- DbArrayToObjectVectorDecoder(String) - Constructor for class io.deephaven.enterprise.compatibility.vector.DbArrayToObjectVectorDecoder
- DbArrayToShortVectorDecoder - Class in io.deephaven.enterprise.compatibility.vector
- DbArrayToShortVectorDecoder(String) - Constructor for class io.deephaven.enterprise.compatibility.vector.DbArrayToShortVectorDecoder
- deactivateUnderlyingDataSource() - Method in class io.deephaven.enterprise.locations.local.deephaven.OnDiskDeephavenTableLocation
- deactivateUnderlyingDataSource() - Method in class io.deephaven.enterprise.locations.remote.RemoteDeephavenTableLocation
- decode(byte[], int, int) - Method in class io.deephaven.enterprise.compatibility.ObjectCodecAdapter
- decode(byte[], int, int) - Method in class io.deephaven.enterprise.compatibility.shadow.ShadowingSerializableDecoder
- decode(byte[], int, int) - Method in class io.deephaven.enterprise.compatibility.vector.DbArrayToByteVectorDecoder
- decode(byte[], int, int) - Method in class io.deephaven.enterprise.compatibility.vector.DbArrayToCharVectorDecoder
- decode(byte[], int, int) - Method in class io.deephaven.enterprise.compatibility.vector.DbArrayToDoubleVectorDecoder
- decode(byte[], int, int) - Method in class io.deephaven.enterprise.compatibility.vector.DbArrayToFloatVectorDecoder
- decode(byte[], int, int) - Method in class io.deephaven.enterprise.compatibility.vector.DbArrayToIntVectorDecoder
- decode(byte[], int, int) - Method in class io.deephaven.enterprise.compatibility.vector.DbArrayToLongVectorDecoder
- decode(byte[], int, int) - Method in class io.deephaven.enterprise.compatibility.vector.DbArrayToObjectVectorDecoder
- decode(byte[], int, int) - Method in class io.deephaven.enterprise.compatibility.vector.DbArrayToShortVectorDecoder
- DEEPHAVEN_ENTERPRISE_ROOT_FILE_PROPERTY - Static variable in class io.deephaven.enterprise.dnd.Main
- DeephavenFormatColumnLocation - Interface in io.deephaven.enterprise.locations
- DeephavenFormatTableLocation - Interface in io.deephaven.enterprise.locations
-
A tagging interface for Deephaven formatted table locations.
- DeephavenTableLocationKey - Class in io.deephaven.enterprise.locations.local.deephaven
-
A
TableLocationKey
in Deephaven columnar format, located on a locally accessible filesystem. - DeephavenTableLocationKey(File, Map<String, Comparable<?>>) - Constructor for class io.deephaven.enterprise.locations.local.deephaven.DeephavenTableLocationKey
- DEFAULT - Static variable in interface io.deephaven.enterprise.tabledataservice.ProtocolDriverFactory
- DEFAULT_TABLE_DATA_SERVICE_REQUEST_TIMEOUT_MILLIS - Static variable in class io.deephaven.enterprise.tabledataservice.TableDataServiceFactory
- DeferredACLTable - Class in io.deephaven.enterprise.acl.impl
-
An
UncoalescedTable
that will apply row and column ACLs when it is coalesced. - DeferredACLTable(Table, Collection<WhereFilter>[], ColumnAcl) - Constructor for class io.deephaven.enterprise.acl.impl.DeferredACLTable
- delegate - Variable in class io.deephaven.enterprise.compatibility.filter.ColumnSourceAdapterForFilter
- delegate - Variable in class io.deephaven.enterprise.compatibility.ObjectCodecAdapter
- delegateToken() - Method in class io.deephaven.enterprise.dnd.client.DndSessionFactoryBarrage
-
Use a delegate token to authenticate; automatically calling the default
AuthenticationClientManager
. - delegateToken(AuthToken) - Method in class io.deephaven.enterprise.dnd.client.DndSessionFactoryBarrage
-
Use a delegate token to authenticate.
- describe() - Method in class io.deephaven.enterprise.tabledataservice.RemoteTableDataService
- determineDispatcher(PQDBServerConfigMessage, int, String) - Method in class io.deephaven.enterprise.dnd.controller.client.ControllerClientGrpc
- determineDispatcher(String, int, String) - Method in class io.deephaven.enterprise.dnd.controller.client.ControllerClientGrpc
- DHC_SHARED_CONTEXT_KEY - Static variable in class io.deephaven.enterprise.compatibility.filter.ColumnSourceAdapterForFilter
- DheAuthContext - Class in io.deephaven.enterprise.dnd.authentication
-
An
AuthContext
containing a singleUserContext
for Enterprise authentication. - DheAuthContext(UserContext) - Constructor for class io.deephaven.enterprise.dnd.authentication.DheAuthContext
- DheAuthenticationHandler - Class in io.deephaven.enterprise.dnd.authentication
-
The authentication hook for enterprise clients to DnD workers.
- DheAuthenticationHandler() - Constructor for class io.deephaven.enterprise.dnd.authentication.DheAuthenticationHandler
-
Create a new auth handler.
- DheAuthorizationProvider - Class in io.deephaven.enterprise.dnd.authentication
-
The authorization provider for access to the worker.
- DheAuthorizationProvider(UserContext, Set<TicketTransformer>) - Constructor for class io.deephaven.enterprise.dnd.authentication.DheAuthorizationProvider
- disjunctive(AclFilterGenerator...) - Static method in interface io.deephaven.enterprise.acl.AclFilterGenerator
-
Create an
AclFilterGenerator
that disjunctively combines the input generators. - disjunctive(Collection<AclFilterGenerator>) - Static method in interface io.deephaven.enterprise.acl.AclFilterGenerator
-
Create an
AclFilterGenerator
that disjunctively combines the input generators. - DisjunctiveFilterGenerator - Class in io.deephaven.enterprise.acl.generator
-
AclFilterGenerator
for combining the results of multipleAclFilterGenerator
s disjunctively, i.e. - DisjunctiveFilterGenerator(AclFilterGenerator...) - Constructor for class io.deephaven.enterprise.acl.generator.DisjunctiveFilterGenerator
-
Construct an
AclFilterGenerator
that will return an array of all theWhereFilter
s generated byfilterGenerators
, thereby expressing the disjunction of thoseWhereFilter
s. - DisjunctiveFilterGenerator(PermissionFilterProvider, Database, FilterGenerator...) - Constructor for class io.deephaven.enterprise.acl.generator.DisjunctiveFilterGenerator
- disName(String) - Method in class io.deephaven.enterprise.kafkawriter.KafkaTableWriter.Options
-
The name of the DataImportServer (dis) to use for ingestion.
- DISPATCHER_CLIENT_TYPE - Static variable in class io.deephaven.enterprise.dnd.Main
- DnDAuthorizationProvider - Interface in io.deephaven.enterprise.dnd.authentication
- DndAuthUtils - Class in io.deephaven.enterprise.dnd.authentication
- DndAuthUtils() - Constructor for class io.deephaven.enterprise.dnd.authentication.DndAuthUtils
- DndClientHelper - Class in io.deephaven.enterprise.dnd.client
- DndClientHelper() - Constructor for class io.deephaven.enterprise.dnd.client.DndClientHelper
- DndSession - Class in io.deephaven.enterprise.dnd.client
-
A basic gRPC connection to a DnD worker.
- DndSessionBarrage - Class in io.deephaven.enterprise.dnd.client
-
A session on a Persistent Query used to access tables using Barrage
- DndSessionFactoryBarrage - Class in io.deephaven.enterprise.dnd.client
-
A factory class for creating
barrage sessions
. - DndSessionFactoryBarrage(String) - Constructor for class io.deephaven.enterprise.dnd.client.DndSessionFactoryBarrage
-
Create a new
DndSessionFactoryBarrage
for fetching barrage tables from a Persistent Query - DndSessionListenerModule - Interface in io.deephaven.enterprise.dnd.modules
- DndSessionListenerModule.DndSessionCountListener - Interface in io.deephaven.enterprise.dnd.modules
- DndSessionListenerModule.SessionMonitor - Class in io.deephaven.enterprise.dnd.modules
- doCoalesce() - Method in class io.deephaven.enterprise.acl.impl.DeferredACLTable
- doCompare(EnterpriseTableLocationKey, TableLocationKey) - Static method in interface io.deephaven.enterprise.locations.EnterpriseTableLocationKey
-
Compare two location keys, automatically mapping the column and internal partition values.
- doCompletion(Node, Collection<CompletionItem.Builder>, CompletionRequest) - Method in class io.deephaven.enterprise.dnd.autocomplete.CompleteTableName
- doCompletion(Node, Collection<CompletionItem.Builder>, CompletionRequest) - Method in class io.deephaven.enterprise.dnd.autocomplete.CompleteTableNamespace
- doConvertInto(ByteChunk<?>, ResettableByteChunk<?>) - Static method in class io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.sources.chunk.EnterpriseByteChunkAdapter
- doConvertInto(CharChunk<?>, ResettableCharChunk<?>) - Static method in class io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.sources.chunk.EnterpriseCharChunkAdapter
- doConvertInto(DoubleChunk<?>, ResettableDoubleChunk<?>) - Static method in class io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.sources.chunk.EnterpriseDoubleChunkAdapter
- doConvertInto(FloatChunk<?>, ResettableFloatChunk<?>) - Static method in class io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.sources.chunk.EnterpriseFloatChunkAdapter
- doConvertInto(IntChunk<?>, ResettableIntChunk<?>) - Static method in class io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.sources.chunk.EnterpriseIntChunkAdapter
- doConvertInto(LongChunk<?>, ResettableLongChunk<?>) - Static method in class io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.sources.chunk.EnterpriseLongChunkAdapter
- doConvertInto(ObjectChunk<?, ?>, ResettableObjectChunk<?, ?>) - Static method in class io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.sources.chunk.EnterpriseObjectChunkAdapter
- doConvertInto(ShortChunk<?>, ResettableShortChunk<?>) - Static method in class io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.sources.chunk.EnterpriseShortChunkAdapter
- doConvertWritableInto(WritableByteChunk<?>, ResettableWritableByteChunk<?>) - Static method in class io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.sources.chunk.EnterpriseByteChunkAdapter
- doConvertWritableInto(WritableCharChunk<?>, ResettableWritableCharChunk<?>) - Static method in class io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.sources.chunk.EnterpriseCharChunkAdapter
- doConvertWritableInto(WritableDoubleChunk<?>, ResettableWritableDoubleChunk<?>) - Static method in class io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.sources.chunk.EnterpriseDoubleChunkAdapter
- doConvertWritableInto(WritableFloatChunk<?>, ResettableWritableFloatChunk<?>) - Static method in class io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.sources.chunk.EnterpriseFloatChunkAdapter
- doConvertWritableInto(WritableIntChunk<?>, ResettableWritableIntChunk<?>) - Static method in class io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.sources.chunk.EnterpriseIntChunkAdapter
- doConvertWritableInto(WritableLongChunk<?>, ResettableWritableLongChunk<?>) - Static method in class io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.sources.chunk.EnterpriseLongChunkAdapter
- doConvertWritableInto(WritableObjectChunk<?, ?>, ResettableWritableObjectChunk<?, ?>) - Static method in class io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.sources.chunk.EnterpriseObjectChunkAdapter
- doConvertWritableInto(WritableShortChunk<?>, ResettableWritableShortChunk<?>) - Static method in class io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.sources.chunk.EnterpriseShortChunkAdapter
- doEquals(EnterpriseTableLocationKey, Object) - Static method in interface io.deephaven.enterprise.locations.EnterpriseTableLocationKey
-
Check for equality between two location keys using only the partition values.
- doHttpGet(String) - Static method in class io.deephaven.enterprise.dnd.client.DndClientHelper
- doOnAuthenticated() - Method in class io.deephaven.enterprise.dnd.client.DndSessionFactoryBarrage
- Double - Enum constant in enum class io.deephaven.enterprise.sources.regioned.BufferedType
- dropColumns(String...) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- dropReference() - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- dynamicPartitionFunction(String, LongFunction<String>) - Method in class io.deephaven.enterprise.kafkawriter.KafkaTableWriter.Options
-
An input column (which must be a long) and a function to determine which column partition a row belongs to.
E
- EdgeAclImpl - Class in io.deephaven.enterprise.acl.impl
-
A implementation of
EdgeAclProvider
that stores immutable maps of group to ACL definition. - EdgeAclProvider - Interface in io.deephaven.enterprise.acl
-
Objects that implement this interface provide ACLs for tables based on the requesting user at request time, as opposed to
SourceAclProvider
which applies ACLS to the table when it is fetched from the data source. - EdgeAclProvider.Builder - Interface in io.deephaven.enterprise.acl
-
A Builder to construct a set of ACLs to apply to a table based on the user fetching it.
- encode(T) - Method in class io.deephaven.enterprise.compatibility.shadow.ShadowingSerializableDecoder
- encode(TYPE) - Method in class io.deephaven.enterprise.compatibility.ObjectCodecAdapter
- enforceSessionCount(int) - Method in interface io.deephaven.enterprise.dnd.EnterpriseJettyComponent.Builder
-
Set if the worker should time out when there are fewer than enforceSessionCount active sessions.
- EngineTableLoggerDndImpl - Class in io.deephaven.enterprise.dnd.logger.engine.impl
- EngineTableLoggerDndImpl(String, String, String[], SupportedType[], Object[], Map<String, Object>, int) - Constructor for class io.deephaven.enterprise.dnd.logger.engine.impl.EngineTableLoggerDndImpl
- EngineTableLoggersFactoryDndImpl - Class in io.deephaven.enterprise.dnd.logger.engine.impl
-
Provides DnD engine table logger implementations that will write DHE binary rows.
- EngineTableLoggersFactoryDndImpl(SimpleProcessEventLogger.PelInfo) - Constructor for class io.deephaven.enterprise.dnd.logger.engine.impl.EngineTableLoggersFactoryDndImpl
- EnterpriseAclAdapterProvider - Class in io.deephaven.enterprise.acl.impl
-
An
SourceAclProvider
that converts acls derived from EnterprisePermissionFilterProvider
into Community equivalents. - EnterpriseAclAdapterProvider(UserContext, PermissionFilterProvider) - Constructor for class io.deephaven.enterprise.acl.impl.EnterpriseAclAdapterProvider
- EnterpriseApiServerModule - Class in io.deephaven.enterprise.dnd.modules
- EnterpriseApiServerModule() - Constructor for class io.deephaven.enterprise.dnd.modules.EnterpriseApiServerModule
- EnterpriseAuthModule - Interface in io.deephaven.enterprise.dnd.modules
-
This dagger module provides the authorization bindings into the dagger context.
- EnterpriseByteChunkAdapter - Class in io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.sources.chunk
- EnterpriseCharChunkAdapter - Class in io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.sources.chunk
- EnterpriseDoubleChunkAdapter - Class in io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.sources.chunk
- EnterpriseFilterAdapter - Class in io.deephaven.enterprise.compatibility.filter
-
An adapter from
enterprise filters
tocommunity filters
. - EnterpriseFilterAdapter(SelectFilter) - Constructor for class io.deephaven.enterprise.compatibility.filter.EnterpriseFilterAdapter
- EnterpriseFilterWrapper - Class in io.deephaven.enterprise.tabledataservice.filter
-
A light wrapper around an Enterprise
Filter
. - EnterpriseFilterWrapper(Filter) - Constructor for class io.deephaven.enterprise.tabledataservice.filter.EnterpriseFilterWrapper
- EnterpriseFixedPartitionedKeyFinder - Class in io.deephaven.enterprise.locations.local
-
A
TableLocationKeyFinder
for locating tables stored in Legacy Deephaven Enterprise structured database. - EnterpriseFixedPartitionedKeyFinder(File, String, String, Predicate<String>) - Constructor for class io.deephaven.enterprise.locations.local.EnterpriseFixedPartitionedKeyFinder
- EnterpriseFloatChunkAdapter - Class in io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.sources.chunk
- EnterpriseIntChunkAdapter - Class in io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.sources.chunk
- EnterpriseJettyComponent - Interface in io.deephaven.enterprise.dnd
-
This is the root component definition for DnD workers.
- EnterpriseJettyComponent.Builder - Interface in io.deephaven.enterprise.dnd
-
The root builder for the DnD jetty component.
- EnterpriseLongChunkAdapter - Class in io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.sources.chunk
- EnterpriseObjectChunkAdapter - Class in io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.sources.chunk
- EnterpriseParquetTableLocationKey - Class in io.deephaven.enterprise.locations.local.parquet
-
A
TableLocationKey
marking tables stored in a Deephaven Enterprise database in the Parquet format. - EnterpriseParquetTableLocationKey(File, Map<String, Comparable<?>>) - Constructor for class io.deephaven.enterprise.locations.local.parquet.EnterpriseParquetTableLocationKey
- EnterpriseProcessEnvironmentCommunityAdapter - Class in io.deephaven.enterprise.dnd
- EnterpriseProcessEnvironmentCommunityAdapter(String, Logger) - Constructor for class io.deephaven.enterprise.dnd.EnterpriseProcessEnvironmentCommunityAdapter
- EnterpriseShortChunkAdapter - Class in io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.sources.chunk
- EnterpriseTableKey - Interface in io.deephaven.enterprise.locations
-
A
TableKey
implementation for addressing Deephaven Enterprise Tables. - EnterpriseTableKeyImpl - Class in io.deephaven.enterprise.locations.impl
-
A basic Enterprise format
TableKey
. - EnterpriseTableKeyImpl(String, String, TableType) - Constructor for class io.deephaven.enterprise.locations.impl.EnterpriseTableKeyImpl
- EnterpriseTableLocationFactory<TLK extends EnterpriseTableLocationKey> - Class in io.deephaven.enterprise.locations.local
-
A
TableLocationFactory
for resolvingEnterpriseTableLocationKeyUnresolved
to either aOnDiskDeephavenTableLocation
orParquetTableLocation
based on the data on disk. - EnterpriseTableLocationFactory() - Constructor for class io.deephaven.enterprise.locations.local.EnterpriseTableLocationFactory
- EnterpriseTableLocationKey - Interface in io.deephaven.enterprise.locations
- EnterpriseTableLocationKeyUnresolved - Class in io.deephaven.enterprise.locations.local
-
An
EnterpriseTableLocationKey
is an extension ofFileTableLocationKey
that defers the creation of the actual location key until the data is needed by theEnterpriseTableLocationFactory
. - EnterpriseTableLocationKeyUnresolved(File) - Constructor for class io.deephaven.enterprise.locations.local.EnterpriseTableLocationKeyUnresolved
-
Construct a new EnterpriseTableLocationKeyUnresolved for the supplied
file
without any partitioning support. - EnterpriseTableLocationKeyUnresolved(File, Map<String, Comparable<?>>) - Constructor for class io.deephaven.enterprise.locations.local.EnterpriseTableLocationKeyUnresolved
-
Construct a new EnterpriseTableLocationKeyUnresolved for the supplied
file
andpartitions
. - EnterpriseTableTools - Class in io.deephaven.enterprise.table
-
Provides utility methods to read and write individual Deephaven format Tables.
- ENVIRONMENT_KEY_DISPATCHER_NAME - Static variable in class io.deephaven.enterprise.dnd.Main
- ENVIRONMENT_KEY_WORKER_NONCE - Static variable in class io.deephaven.enterprise.dnd.Main
- equals(Object) - Method in class io.deephaven.enterprise.locations.impl.BasicFixedPartitionedDeephavenTableLocationKey
- equals(Object) - Method in class io.deephaven.enterprise.locations.local.deephaven.DeephavenTableLocationKey
- equals(Object) - Method in class io.deephaven.enterprise.locations.local.EnterpriseTableLocationKeyUnresolved
- equals(Object) - Method in class io.deephaven.enterprise.locations.local.parquet.EnterpriseParquetTableLocationKey
- equals(Object) - Method in class io.deephaven.enterprise.compatibility.filter.EnterpriseFilterAdapter
- equals(Object) - Method in class io.deephaven.proto.pqworker.ListenErrorRequest
- equals(Object) - Method in class io.deephaven.proto.pqworker.ListenErrorResponse
- equals(Object) - Method in class io.deephaven.proto.pqworker.ObjectAccessRequest
- equals(Object) - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse
- equals(Object) - Method in class io.deephaven.proto.pqworker.StringList
- event(AuditEvent) - Method in class io.deephaven.enterprise.dnd.SimpleAuditEventLogger
- exactJoin(Table, MatchPair[], MatchPair[]) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- executeCode(String) - Method in class io.deephaven.enterprise.dnd.client.DndSession
-
Execute the specified code on the server.
- exists() - Method in class io.deephaven.enterprise.locations.local.deephaven.OnDiskDeephavenColumnLocation
- expectedObjectWidth() - Method in class io.deephaven.enterprise.compatibility.ObjectCodecAdapter
- expectedObjectWidth() - Method in class io.deephaven.enterprise.compatibility.shadow.ShadowingSerializableDecoder
- expectedObjectWidth() - Method in class io.deephaven.enterprise.compatibility.vector.DbArrayToByteVectorDecoder
- expectedObjectWidth() - Method in class io.deephaven.enterprise.compatibility.vector.DbArrayToCharVectorDecoder
- expectedObjectWidth() - Method in class io.deephaven.enterprise.compatibility.vector.DbArrayToDoubleVectorDecoder
- expectedObjectWidth() - Method in class io.deephaven.enterprise.compatibility.vector.DbArrayToFloatVectorDecoder
- expectedObjectWidth() - Method in class io.deephaven.enterprise.compatibility.vector.DbArrayToIntVectorDecoder
- expectedObjectWidth() - Method in class io.deephaven.enterprise.compatibility.vector.DbArrayToLongVectorDecoder
- expectedObjectWidth() - Method in class io.deephaven.enterprise.compatibility.vector.DbArrayToObjectVectorDecoder
- expectedObjectWidth() - Method in class io.deephaven.enterprise.compatibility.vector.DbArrayToShortVectorDecoder
F
- fetchDheAuthContext() - Static method in class io.deephaven.enterprise.dnd.authentication.DheAuthenticationHandler
-
Fetch an Enterprise
DheAuthContext
from the currentExecutionContext
. - FILENAME_COLUMN_NAME - Static variable in class io.deephaven.enterprise.locations.local.HiveLocationsTableKeyFinder
-
The column of file names, relative to the root of this table.
- fillChunk(ChunkSource.FillContext, WritableChunk<? super Attributes.Values>, OrderedKeys) - Method in class io.deephaven.enterprise.compatibility.filter.ColumnSourceAdapterForFilter
- fillChunkAppend(ChunkSource.FillContext, WritableChunk<? super ATTR>, RowSequence) - Method in class io.deephaven.enterprise.sources.regioned.impl.BufferedPageByte
- fillChunkAppend(ChunkSource.FillContext, WritableChunk<? super ATTR>, RowSequence) - Method in class io.deephaven.enterprise.sources.regioned.impl.BufferedPageChar
- fillChunkAppend(ChunkSource.FillContext, WritableChunk<? super ATTR>, RowSequence) - Method in class io.deephaven.enterprise.sources.regioned.impl.BufferedPageDouble
- fillChunkAppend(ChunkSource.FillContext, WritableChunk<? super ATTR>, RowSequence) - Method in class io.deephaven.enterprise.sources.regioned.impl.BufferedPageFloat
- fillChunkAppend(ChunkSource.FillContext, WritableChunk<? super ATTR>, RowSequence) - Method in class io.deephaven.enterprise.sources.regioned.impl.BufferedPageInt
- fillChunkAppend(ChunkSource.FillContext, WritableChunk<? super ATTR>, RowSequence) - Method in class io.deephaven.enterprise.sources.regioned.impl.BufferedPageIntAsLong
- fillChunkAppend(ChunkSource.FillContext, WritableChunk<? super ATTR>, RowSequence) - Method in class io.deephaven.enterprise.sources.regioned.impl.BufferedPageLong
- fillChunkAppend(ChunkSource.FillContext, WritableChunk<? super ATTR>, RowSequence) - Method in class io.deephaven.enterprise.sources.regioned.impl.BufferedPageShort
- fillChunkAppend(ChunkSource.FillContext, WritableChunk<? super ATTR>, RowSequence) - Method in class io.deephaven.enterprise.sources.regioned.impl.ColumnRegionObjectCached
- fillChunkAppend(ChunkSource.FillContext, WritableChunk<? super ATTR>, RowSequence) - Method in class io.deephaven.enterprise.sources.regioned.impl.ColumnRegionObjectWithDictionary
- fillChunkAppend(ChunkSource.FillContext, WritableChunk<? super ATTR>, RowSequence) - Method in class io.deephaven.enterprise.sources.regioned.impl.ColumnRegionObjectCodecFixed
- fillChunkAppend(ChunkSource.FillContext, WritableChunk<? super ATTR>, RowSequence) - Method in class io.deephaven.enterprise.sources.regioned.impl.ColumnRegionObjectCodecVariable
- fillChunkAppend(ChunkSource.FillContext, WritableChunk<? super ATTR>, RowSequence) - Method in class io.deephaven.enterprise.sources.regioned.impl.ColumnRegionStringSet
- FillContextWrapper - Class in io.deephaven.enterprise.compatibility.chunk
-
An adapter FillContext for use when an Enterprise chunk must be filled by a Community source.
- FillContextWrapper(ChunkSource.FillContext, ChunkType) - Constructor for class io.deephaven.enterprise.compatibility.chunk.FillContextWrapper
- fillPrevChunk(ChunkSource.FillContext, WritableChunk<? super Attributes.Values>, OrderedKeys) - Method in class io.deephaven.enterprise.compatibility.filter.ColumnSourceAdapterForFilter
- fillRowKeyChunk(WritableLongChunk<? super OrderedRowKeys>) - Method in class io.deephaven.enterprise.compatibility.rowset.OrderedKeysToRowSequenceAdapter
- fillRowKeyRangesChunk(WritableLongChunk<OrderedRowKeyRanges>) - Method in class io.deephaven.enterprise.compatibility.rowset.OrderedKeysToRowSequenceAdapter
- filter(RowSet, RowSet, Table, boolean) - Method in class io.deephaven.enterprise.compatibility.filter.EnterpriseFilterAdapter
- FilterCompatibility - Class in io.deephaven.enterprise.compatibility.filter
- FilterCompatibility() - Constructor for class io.deephaven.enterprise.compatibility.filter.FilterCompatibility
- FilterGeneratorAdapter - Class in io.deephaven.enterprise.acl.generator
- FilterGeneratorAdapter(FilterGenerator, PermissionFilterProvider, Database) - Constructor for class io.deephaven.enterprise.acl.generator.FilterGeneratorAdapter
- findKeys(Consumer<EnterpriseTableLocationKey>) - Method in class io.deephaven.enterprise.locations.local.HiveLocationsTableKeyFinder
- findKeys(Consumer<EnterpriseTableLocationKey>) - Method in class io.deephaven.enterprise.locations.local.MetadataIndexKeyFinder
- firstBy(SelectColumn...) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- firstRowKey() - Method in class io.deephaven.enterprise.compatibility.rowset.OrderedKeysToRowSequenceAdapter
- firstRowOffset() - Method in interface io.deephaven.enterprise.sources.regioned.BufferedPage
- fixedColumnPartition() - Method in class io.deephaven.enterprise.database.SystemTableLogger.Options
-
What column partition should we write to?
- fixedColumnPartition(String) - Method in interface io.deephaven.enterprise.database.SystemTableLogger.Options.Builder
-
What column partition should we write to?
- FixedPartitionedEnterpriseTableLocationKey - Interface in io.deephaven.enterprise.locations
-
This class represents an instance of a legacy style Deephaven table where there are two fixed partitions, the column partition and the internal partition
- flatten() - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- flightInfoFor(SessionState, Flight.FlightDescriptor, String) - Method in class io.deephaven.enterprise.dnd.service.ticket.DatabaseTicketResolver
- Float - Enum constant in enum class io.deephaven.enterprise.sources.regioned.BufferedType
- forAllFlightInfo(SessionState, Consumer<Flight.FlightInfo>) - Method in class io.deephaven.enterprise.dnd.service.ticket.DatabaseTicketResolver
- forEachRowKey(LongAbortableConsumer) - Method in class io.deephaven.enterprise.compatibility.rowset.OrderedKeysToRowSequenceAdapter
- forEachRowKeyRange(LongRangeAbortableConsumer) - Method in class io.deephaven.enterprise.compatibility.rowset.OrderedKeysToRowSequenceAdapter
- FORMAT_COLUMN_NAME - Static variable in class io.deephaven.enterprise.locations.local.HiveLocationsTableKeyFinder
-
The column name containing the format as a String value of
TableLocation.Format
(either "DEEPHAVEN" or "PARQUET"). - fullAccess() - Static method in interface io.deephaven.enterprise.acl.AclFilterGenerator
-
Create an
AclFilterGenerator
that gives full access to the table. - FullAccessFilterGenerator - Class in io.deephaven.enterprise.acl.generator
-
An
AclFilterGenerator
that provides full access to everyone. - FullAccessFilterGenerator() - Constructor for class io.deephaven.enterprise.acl.generator.FullAccessFilterGenerator
G
- gatherDictionaryValuesRowSet(RowSet.SearchIterator, RowSequence.Iterator, RowSetBuilderSequential) - Method in class io.deephaven.enterprise.sources.regioned.impl.ColumnRegionObjectCached
- gatherDictionaryValuesRowSet(RowSet.SearchIterator, RowSequence.Iterator, RowSetBuilderSequential) - Method in class io.deephaven.enterprise.sources.regioned.impl.ColumnRegionObjectCodecFixed
- gatherDictionaryValuesRowSet(RowSet.SearchIterator, RowSequence.Iterator, RowSetBuilderSequential) - Method in class io.deephaven.enterprise.sources.regioned.impl.ColumnRegionObjectCodecVariable
- generateFilter(AclSupport, UserContext, String, String, boolean) - Method in interface io.deephaven.enterprise.acl.AclFilterGenerator
-
Generate a filter for a table access.
- generateFilter(AclSupport, UserContext, String, String, boolean) - Method in class io.deephaven.enterprise.acl.generator.CombiningFilterGenerator
-
Generate a filter for table access, combining the filters between groups as specified.
- generateFilter(AclSupport, UserContext, String, String, boolean) - Method in class io.deephaven.enterprise.acl.generator.ConjunctiveFilterGenerator
- generateFilter(AclSupport, UserContext, String, String, boolean) - Method in class io.deephaven.enterprise.acl.generator.DisjunctiveFilterGenerator
- generateFilter(AclSupport, UserContext, String, String, boolean) - Method in class io.deephaven.enterprise.acl.generator.FilterGeneratorAdapter
- generateFilter(AclSupport, UserContext, String, String, boolean) - Method in class io.deephaven.enterprise.acl.generator.FullAccessFilterGenerator
- generateFilter(AclSupport, UserContext, String, String, boolean) - Method in class io.deephaven.enterprise.acl.generator.NoAccessFilterGenerator
- generateFilter(AclSupport, UserContext, String, String, boolean) - Method in class io.deephaven.enterprise.acl.generator.SimpleFilterGenerator
- generateFilter(AclSupport, UserContext, String, String, boolean) - Method in class io.deephaven.enterprise.acl.generator.WhereInFilterGenerator
- generateLocationsTable(File, Schema) - Static method in class io.deephaven.enterprise.locations.local.HiveLocationsTableKeyFinder
-
Produce an in-memory table containing the files and relevant metadata for a given directory.
- GenericObjectTransformer - Class in io.deephaven.enterprise.acl.transform
-
A Transformer for handling ACLs on generic objects.
- get() - Static method in class io.deephaven.enterprise.dnd.ProcessInfoId
- get(long) - Method in class io.deephaven.enterprise.compatibility.filter.ColumnSourceAdapterForFilter
- get(long) - Method in class io.deephaven.enterprise.sources.regioned.impl.ReversibleCache
- get(GroupProvider) - Static method in class io.deephaven.enterprise.acl.transform.GenericObjectTransformer
-
Get the singleton instance of this transformer.
- get(Database) - Method in class io.deephaven.enterprise.dnd.query.util.perf.PerformanceOverview
-
If process info id is not specified, then it will be inferred by other inputs like worker or PQ name.
- getAllGroups() - Method in class io.deephaven.enterprise.test.PFPBackedTestGroupProvider
- getAllowedGroups(T) - Method in class io.deephaven.enterprise.acl.transform.GenericObjectTransformer
- getAllowedGroups(T) - Method in class io.deephaven.enterprise.acl.transform.TableTicketTransformer
- getAllowedGroups(T) - Method in interface io.deephaven.enterprise.dnd.authentication.transform.TicketTransformer
-
Get a set of groups that may access the specified object.
- getAllUsers() - Method in class io.deephaven.enterprise.test.PFPBackedTestGroupProvider
- getApplicationServiceAuthWiring() - Method in class io.deephaven.enterprise.dnd.authentication.DheAuthorizationProvider
- getAttribute(String) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- getAttributeNames() - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- getAttributes(Collection<String>) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- getAuthCookie(String, RetryBackoffContext) - Method in class io.deephaven.enterprise.dnd.controller.client.ControllerClientGrpc
- getAuthenticatedUser() - Method in class io.deephaven.enterprise.dnd.authentication.DheAuthContext
- getAuthenticatedUser() - Method in class io.deephaven.enterprise.dnd.SimpleProcessEventLogger.PelInfo
- getAuthType() - Method in class io.deephaven.enterprise.dnd.authentication.DheAuthenticationHandler
- getAverageRunLengthEstimate() - Method in class io.deephaven.enterprise.compatibility.rowset.OrderedKeysToRowSequenceAdapter
- getBoolean(long) - Method in class io.deephaven.enterprise.compatibility.filter.ColumnSourceAdapterForFilter
- getBufferProvider() - Method in interface io.deephaven.enterprise.sources.regioned.BufferedColumnRegion
- getBufferProvider() - Method in class io.deephaven.enterprise.sources.regioned.impl.BufferedColumnRegionBase
- getBufferSize() - Method in enum class io.deephaven.enterprise.sources.regioned.BufferedType
- getByte(long) - Method in class io.deephaven.enterprise.compatibility.filter.ColumnSourceAdapterForFilter
- getByte(long) - Method in class io.deephaven.enterprise.sources.regioned.impl.BufferedColumnRegionByte
- getByte(ChunkSource.FillContext, long) - Method in class io.deephaven.enterprise.sources.regioned.impl.BufferedColumnRegionByte
- getByteOrder() - Method in interface io.deephaven.enterprise.locations.DeephavenFormatColumnLocation
-
Get the
ByteOrder
used by allFileDataBufferStore
s associated with this column location. - getByteOrder() - Method in class io.deephaven.enterprise.locations.local.deephaven.OnDiskDeephavenColumnLocation
- getBytes() - Method in enum class io.deephaven.enterprise.sources.regioned.BufferedType
- getBytes(long, byte[], int, int) - Method in class io.deephaven.enterprise.sources.regioned.impl.BufferedColumnRegionByte
- getCache() - Method in class io.deephaven.enterprise.sources.regioned.impl.ColumnRegionObjectCached
- getCatalogTable() - Method in interface io.deephaven.enterprise.database.Database
-
Retrieve a table containing the tables that exist in this database.
- getCatalogTable() - Method in class io.deephaven.enterprise.database.impl.DatabaseImpl
- getChar(long) - Method in class io.deephaven.enterprise.compatibility.filter.ColumnSourceAdapterForFilter
- getChar(long) - Method in class io.deephaven.enterprise.sources.regioned.impl.BufferedColumnRegionChar
- getChar(ChunkSource.FillContext, long) - Method in class io.deephaven.enterprise.sources.regioned.impl.BufferedColumnRegionChar
- getChunkType() - Method in class io.deephaven.enterprise.sources.regioned.impl.BufferedPageByte
- getChunkType() - Method in class io.deephaven.enterprise.sources.regioned.impl.BufferedPageChar
- getChunkType() - Method in class io.deephaven.enterprise.sources.regioned.impl.BufferedPageDouble
- getChunkType() - Method in class io.deephaven.enterprise.sources.regioned.impl.BufferedPageFloat
- getChunkType() - Method in class io.deephaven.enterprise.sources.regioned.impl.BufferedPageInt
- getChunkType() - Method in class io.deephaven.enterprise.sources.regioned.impl.BufferedPageIntAsLong
- getChunkType() - Method in class io.deephaven.enterprise.sources.regioned.impl.BufferedPageLong
- getChunkType() - Method in class io.deephaven.enterprise.sources.regioned.impl.BufferedPageShort
- getCodecAdapterClassName(String) - Static method in class io.deephaven.enterprise.compatibility.CodecCompatibility
- getCodecArgs(TableDefinition, String) - Static method in class io.deephaven.enterprise.compatibility.CodecCompatibility
- getCodecArgs(String) - Method in class io.deephaven.enterprise.locations.local.deephaven.OnDiskDeephavenTableLocation
- getCodecArgs(String) - Method in class io.deephaven.enterprise.locations.remote.RemoteDeephavenTableLocation
- getCodecArgs(String, String, Class<?>) - Static method in class io.deephaven.enterprise.compatibility.CodecCompatibility
- getCodecName(TableDefinition, String) - Static method in class io.deephaven.enterprise.compatibility.CodecCompatibility
- getCodecName(String) - Method in class io.deephaven.enterprise.locations.local.deephaven.OnDiskDeephavenTableLocation
- getCodecName(String) - Method in class io.deephaven.enterprise.locations.remote.RemoteDeephavenTableLocation
- getCodecName(String, Class<?>) - Static method in class io.deephaven.enterprise.compatibility.CodecCompatibility
- getColumn(String) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- getColumnArrays() - Method in class io.deephaven.enterprise.compatibility.filter.EnterpriseFilterAdapter
- getColumnFileBufferStore(ColumnFileType) - Method in interface io.deephaven.enterprise.locations.DeephavenFormatColumnLocation
-
Get the
FileDataBufferStore
for buffers from this column location for the specifiedColumnFileType
. - getColumnFileBufferStore(ColumnFileType) - Method in class io.deephaven.enterprise.locations.local.deephaven.OnDiskDeephavenColumnLocation
- getColumnFilters(AclSupport, UserContext, String[], boolean) - Method in interface io.deephaven.enterprise.acl.EdgeAclProvider
-
Get the column ACLs to apply to requested tables.
- getColumnFilters(AclSupport, UserContext, String[], boolean) - Method in class io.deephaven.enterprise.acl.impl.EdgeAclImpl
- getColumnFilters(AclSupport, String, String, String[], boolean) - Method in class io.deephaven.enterprise.acl.impl.EnterpriseAclAdapterProvider
- getColumnFilters(AclSupport, String, String, String[], boolean) - Method in interface io.deephaven.enterprise.acl.SourceAclProvider
-
Get the column ACLs to apply to requested tables.
- getColumns() - Method in class io.deephaven.enterprise.compatibility.filter.EnterpriseFilterAdapter
- getColumnSource(String) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- getColumnSourceMap() - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- getColumnSources() - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- getComponentType() - Method in class io.deephaven.enterprise.compatibility.filter.ColumnSourceAdapterForFilter
- getConfigServiceAuthWiring() - Method in class io.deephaven.enterprise.dnd.authentication.DheAuthorizationProvider
- getConfiguration() - Method in class io.deephaven.enterprise.dnd.controller.client.ControllerClientGrpc
-
Gets the server configuration from the controller.
- getConsoleServiceAuthWiring() - Method in class io.deephaven.enterprise.dnd.authentication.DheAuthorizationProvider
- getContents() - Method in class io.deephaven.enterprise.dnd.notebook.NotebookReader.FileOrFolder
- getDefaultInstance() - Static method in class io.deephaven.proto.pqworker.ListenErrorRequest
- getDefaultInstance() - Static method in class io.deephaven.proto.pqworker.ListenErrorResponse
- getDefaultInstance() - Static method in class io.deephaven.proto.pqworker.ObjectAccessRequest
- getDefaultInstance() - Static method in class io.deephaven.proto.pqworker.ObjectAccessResponse
- getDefaultInstance() - Static method in class io.deephaven.proto.pqworker.StringList
- getDefaultInstanceForType() - Method in class io.deephaven.proto.pqworker.ListenErrorRequest.Builder
- getDefaultInstanceForType() - Method in class io.deephaven.proto.pqworker.ListenErrorRequest
- getDefaultInstanceForType() - Method in class io.deephaven.proto.pqworker.ListenErrorResponse.Builder
- getDefaultInstanceForType() - Method in class io.deephaven.proto.pqworker.ListenErrorResponse
- getDefaultInstanceForType() - Method in class io.deephaven.proto.pqworker.ObjectAccessRequest.Builder
- getDefaultInstanceForType() - Method in class io.deephaven.proto.pqworker.ObjectAccessRequest
- getDefaultInstanceForType() - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse.Builder
- getDefaultInstanceForType() - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse
- getDefaultInstanceForType() - Method in class io.deephaven.proto.pqworker.StringList.Builder
- getDefaultInstanceForType() - Method in class io.deephaven.proto.pqworker.StringList
- getDefinition() - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- getDelegate() - Method in class io.deephaven.enterprise.compatibility.chunk.FillContextWrapper
-
Get the delegate Community
ChunkSource.FillContext
for the Community source to use. - getDescription() - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- getDescriptor() - Static method in class io.deephaven.proto.pqworker.grpc.PqworkerService
- getDescriptor() - Static method in class io.deephaven.proto.pqworker.ListenErrorRequest.Builder
- getDescriptor() - Static method in class io.deephaven.proto.pqworker.ListenErrorRequest
- getDescriptor() - Static method in class io.deephaven.proto.pqworker.ListenErrorResponse.Builder
- getDescriptor() - Static method in class io.deephaven.proto.pqworker.ListenErrorResponse
- getDescriptor() - Static method in class io.deephaven.proto.pqworker.ObjectAccessRequest.Builder
- getDescriptor() - Static method in class io.deephaven.proto.pqworker.ObjectAccessRequest
- getDescriptor() - Static method in class io.deephaven.proto.pqworker.ObjectAccessResponse.Builder
- getDescriptor() - Static method in class io.deephaven.proto.pqworker.ObjectAccessResponse
- getDescriptor() - Static method in class io.deephaven.proto.pqworker.Pqworker
- getDescriptor() - Static method in class io.deephaven.proto.pqworker.StringList.Builder
- getDescriptor() - Static method in class io.deephaven.proto.pqworker.StringList
- getDescriptorForType() - Method in class io.deephaven.proto.pqworker.ListenErrorRequest.Builder
- getDescriptorForType() - Method in class io.deephaven.proto.pqworker.ListenErrorResponse.Builder
- getDescriptorForType() - Method in class io.deephaven.proto.pqworker.ObjectAccessRequest.Builder
- getDescriptorForType() - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse.Builder
- getDescriptorForType() - Method in class io.deephaven.proto.pqworker.StringList.Builder
- getDheDefinition() - Method in class io.deephaven.enterprise.locations.local.deephaven.OnDiskDeephavenTableLocation
-
Get the Enterprise
TableDefinition
for this location. - getDictionaryKeysRegion() - Method in class io.deephaven.enterprise.sources.regioned.impl.ColumnRegionObjectCached
- getDictionaryKeysRegion() - Method in class io.deephaven.enterprise.sources.regioned.impl.ColumnRegionObjectWithDictionary
- getDictionaryValuesRegion() - Method in class io.deephaven.enterprise.sources.regioned.impl.ColumnRegionObjectCached
- getDictionaryValuesRegion() - Method in class io.deephaven.enterprise.sources.regioned.impl.ColumnRegionObjectWithDictionary
- getDisByName(String) - Static method in class io.deephaven.enterprise.kafkawriter.KafkaTableWriter
-
Retrieve a DataImportServer by name.
- getDouble(long) - Method in class io.deephaven.enterprise.compatibility.filter.ColumnSourceAdapterForFilter
- getDouble(long) - Method in class io.deephaven.enterprise.sources.regioned.impl.BufferedColumnRegionDouble
- getDouble(ChunkSource.FillContext, long) - Method in class io.deephaven.enterprise.sources.regioned.impl.BufferedColumnRegionDouble
- getEffectiveUser() - Method in class io.deephaven.enterprise.dnd.authentication.DheAuthContext
- getEffectiveUser() - Method in class io.deephaven.enterprise.dnd.SimpleProcessEventLogger.PelInfo
- getFileOrFolder(Database, String, boolean, String) - Static method in class io.deephaven.enterprise.dnd.notebook.NotebookReader
-
Gets a FileOrFolder pointed to by path.
- getFilters() - Method in class io.deephaven.enterprise.acl.generator.WhereInFilterGenerator
-
Get the filters to be applied before filtering by the groupColumn.
- getFloat(long) - Method in class io.deephaven.enterprise.compatibility.filter.ColumnSourceAdapterForFilter
- getFloat(long) - Method in class io.deephaven.enterprise.sources.regioned.impl.BufferedColumnRegionFloat
- getFloat(ChunkSource.FillContext, long) - Method in class io.deephaven.enterprise.sources.regioned.impl.BufferedColumnRegionFloat
- getGetObjectAccessMethod() - Static method in class io.deephaven.proto.pqworker.grpc.PQWorkerApiGrpc
- getGroupColumn() - Method in class io.deephaven.enterprise.acl.generator.WhereInFilterGenerator
-
Get the column in the set table that contains the Deephaven group name.
- getGroupingBuilder() - Method in class io.deephaven.enterprise.compatibility.filter.ColumnSourceAdapterForFilter
- getGroupingProvider() - Method in class io.deephaven.enterprise.compatibility.filter.ColumnSourceAdapterForFilter
- getGroupProvider() - Method in interface io.deephaven.enterprise.acl.AclSupport
- getGroupProvider() - Method in class io.deephaven.enterprise.database.impl.DatabaseImpl
- getGroups() - Method in interface io.deephaven.enterprise.acl.EdgeAclProvider
-
Get the set of groups that may access the table this ACL guards.
- getGroups() - Method in class io.deephaven.enterprise.acl.impl.EdgeAclImpl
- getGroupsForUser(UserContext) - Method in interface io.deephaven.enterprise.dnd.authentication.GroupProvider
-
Get the groups to which the specified user belongs.
- getGroupsForUser(UserContext) - Method in class io.deephaven.enterprise.dnd.authentication.WrappedGroupProvider
- getGroupsForUser(UserContext) - Method in class io.deephaven.enterprise.test.PFPBackedTestGroupProvider
- getHealthAuthWiring() - Method in class io.deephaven.enterprise.dnd.authentication.DheAuthorizationProvider
- getHierarchicalTableServiceContextualAuthWiring() - Method in class io.deephaven.enterprise.dnd.authentication.DheAuthorizationProvider
- getHost() - Method in class io.deephaven.enterprise.dnd.SimpleProcessEventLogger.PelInfo
- getId() - Method in class io.deephaven.enterprise.dnd.notebook.NotebookReader.FileOrFolder
- getIndex() - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- getInfo() - Method in class io.deephaven.enterprise.dnd.client.DndSession
-
Get the
query info
for the connected Persistent Query - getInputTableServiceContextualAuthWiring() - Method in class io.deephaven.enterprise.dnd.authentication.DheAuthorizationProvider
- getInstance() - Static method in class io.deephaven.enterprise.compatibility.shadow.ShadowingSerializableDecoder
- getInstance() - Static method in class io.deephaven.enterprise.dnd.SimpleAuditEventLogger
-
Retrieve the singleton instance of the SimpleAuditEventLogger.
- getInstanceAuthContext() - Method in class io.deephaven.enterprise.dnd.authentication.DheAuthorizationProvider
- getInt(long) - Method in class io.deephaven.enterprise.compatibility.filter.ColumnSourceAdapterForFilter
- getInt(long) - Method in class io.deephaven.enterprise.sources.regioned.impl.BufferedColumnRegionInt
- getInt(ChunkSource.FillContext, long) - Method in class io.deephaven.enterprise.sources.regioned.impl.BufferedColumnRegionInt
- getLastModifiedTimeMillis() - Method in class io.deephaven.enterprise.compatibility.TableLocationStateAdapter
- getListenForErrorMethod() - Static method in class io.deephaven.proto.pqworker.grpc.PQWorkerApiGrpc
- getLog(Class<?>) - Method in class io.deephaven.enterprise.dnd.EnterpriseProcessEnvironmentCommunityAdapter
- getLogNameFor(ByteBuffer, String) - Method in class io.deephaven.enterprise.dnd.service.ticket.DatabaseTicketResolver
- getLong(long) - Method in class io.deephaven.enterprise.compatibility.filter.ColumnSourceAdapterForFilter
- getLong(long) - Method in class io.deephaven.enterprise.sources.regioned.impl.BufferedColumnRegionIntAsLong
- getLong(long) - Method in class io.deephaven.enterprise.sources.regioned.impl.BufferedColumnRegionLong
- getLong(ChunkSource.FillContext, long) - Method in class io.deephaven.enterprise.sources.regioned.impl.BufferedColumnRegionIntAsLong
- getLong(ChunkSource.FillContext, long) - Method in class io.deephaven.enterprise.sources.regioned.impl.BufferedColumnRegionLong
- getMatchExpressions() - Method in class io.deephaven.enterprise.acl.generator.WhereInFilterGenerator
-
Get the MatchPairs used for the whereIn operation.
- getMessage() - Method in class io.deephaven.proto.pqworker.ListenErrorResponse.Builder
-
string message = 1;
- getMessage() - Method in class io.deephaven.proto.pqworker.ListenErrorResponse
-
string message = 1;
- getMessage() - Method in interface io.deephaven.proto.pqworker.ListenErrorResponseOrBuilder
-
string message = 1;
- getMessageBytes() - Method in class io.deephaven.proto.pqworker.ListenErrorResponse.Builder
-
string message = 1;
- getMessageBytes() - Method in class io.deephaven.proto.pqworker.ListenErrorResponse
-
string message = 1;
- getMessageBytes() - Method in interface io.deephaven.proto.pqworker.ListenErrorResponseOrBuilder
-
string message = 1;
- getMetadata() - Method in class io.deephaven.enterprise.locations.local.parquet.EnterpriseParquetTableLocationKey
- getMetadata(ColumnDefinition<?>) - Method in class io.deephaven.enterprise.locations.local.deephaven.OnDiskDeephavenColumnLocation
- getMutableObjectGroups() - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse.Builder
-
Deprecated.
- getNamespace() - Method in exception io.deephaven.enterprise.database.TableLoggerException
- getNamespace() - Method in interface io.deephaven.enterprise.locations.EnterpriseTableKey
-
Get the namespace of the table.
- getNamespace() - Method in class io.deephaven.enterprise.locations.impl.EnterpriseTableKeyImpl
- getNamespaces() - Method in interface io.deephaven.enterprise.database.Database
-
Get the available namespaces.
- getNamespaces() - Method in class io.deephaven.enterprise.database.impl.DatabaseImpl
- getNativeType() - Method in class io.deephaven.enterprise.compatibility.filter.ColumnSourceAdapterForFilter
- getNextRowSequenceThrough(long) - Method in class io.deephaven.enterprise.compatibility.rowset.OrderedKeysToRowSequenceIteratorAdapter
- getNextRowSequenceWithLength(long) - Method in class io.deephaven.enterprise.compatibility.rowset.OrderedKeysToRowSequenceIteratorAdapter
- getNotebookText(Database, String) - Static method in class io.deephaven.enterprise.dnd.notebook.NotebookReader
-
Get the text of a notebook at the given path.
- getObject(long) - Method in class io.deephaven.enterprise.sources.regioned.impl.ColumnRegionObjectCached
- getObject(long) - Method in class io.deephaven.enterprise.sources.regioned.impl.ColumnRegionObjectCodecFixed
- getObject(long) - Method in class io.deephaven.enterprise.sources.regioned.impl.ColumnRegionObjectCodecVariable
- getObject(long) - Method in class io.deephaven.enterprise.sources.regioned.impl.ColumnRegionObjectWithDictionary
- getObject(long) - Method in class io.deephaven.enterprise.sources.regioned.impl.ColumnRegionStringSet
- getObject(ChunkSource.FillContext, long) - Method in class io.deephaven.enterprise.sources.regioned.impl.ColumnRegionObjectCached
- getObject(ChunkSource.FillContext, long) - Method in class io.deephaven.enterprise.sources.regioned.impl.ColumnRegionObjectWithDictionary
- getObject(ChunkSource.FillContext, long) - Method in class io.deephaven.enterprise.sources.regioned.impl.ColumnRegionObjectCodecFixed
- getObject(ChunkSource.FillContext, long) - Method in class io.deephaven.enterprise.sources.regioned.impl.ColumnRegionObjectCodecVariable
- getObject(ChunkSource.FillContext, long) - Method in class io.deephaven.enterprise.sources.regioned.impl.ColumnRegionStringSet
- getObjectAccess(ObjectAccessRequest) - Method in class io.deephaven.proto.pqworker.grpc.PQWorkerApiGrpc.PQWorkerApiBlockingStub
- getObjectAccess(ObjectAccessRequest) - Method in class io.deephaven.proto.pqworker.grpc.PQWorkerApiGrpc.PQWorkerApiFutureStub
- getObjectAccess(ObjectAccessRequest, StreamObserver<ObjectAccessResponse>) - Method in class io.deephaven.enterprise.dnd.service.pqworker.PQWorkerServiceGrpcImpl
- getObjectAccess(ObjectAccessRequest, StreamObserver<ObjectAccessResponse>) - Method in class io.deephaven.proto.pqworker.grpc.PQWorkerApiGrpc.PQWorkerApiImplBase
- getObjectAccess(ObjectAccessRequest, StreamObserver<ObjectAccessResponse>) - Method in class io.deephaven.proto.pqworker.grpc.PQWorkerApiGrpc.PQWorkerApiStub
- getObjectGroups() - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse.Builder
-
Deprecated.
- getObjectGroups() - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse
-
Deprecated.
- getObjectGroups() - Method in interface io.deephaven.proto.pqworker.ObjectAccessResponseOrBuilder
-
Deprecated.
- getObjectGroupsCount() - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse.Builder
- getObjectGroupsCount() - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse
- getObjectGroupsCount() - Method in interface io.deephaven.proto.pqworker.ObjectAccessResponseOrBuilder
-
map<string, .io.deephaven.proto.pqworker.StringList> objectGroups = 1;
- getObjectGroupsMap() - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse.Builder
-
map<string, .io.deephaven.proto.pqworker.StringList> objectGroups = 1;
- getObjectGroupsMap() - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse
-
map<string, .io.deephaven.proto.pqworker.StringList> objectGroups = 1;
- getObjectGroupsMap() - Method in interface io.deephaven.proto.pqworker.ObjectAccessResponseOrBuilder
-
map<string, .io.deephaven.proto.pqworker.StringList> objectGroups = 1;
- getObjectGroupsOrDefault(String, StringList) - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse.Builder
-
map<string, .io.deephaven.proto.pqworker.StringList> objectGroups = 1;
- getObjectGroupsOrDefault(String, StringList) - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse
-
map<string, .io.deephaven.proto.pqworker.StringList> objectGroups = 1;
- getObjectGroupsOrDefault(String, StringList) - Method in interface io.deephaven.proto.pqworker.ObjectAccessResponseOrBuilder
-
map<string, .io.deephaven.proto.pqworker.StringList> objectGroups = 1;
- getObjectGroupsOrThrow(String) - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse.Builder
-
map<string, .io.deephaven.proto.pqworker.StringList> objectGroups = 1;
- getObjectGroupsOrThrow(String) - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse
-
map<string, .io.deephaven.proto.pqworker.StringList> objectGroups = 1;
- getObjectGroupsOrThrow(String) - Method in interface io.deephaven.proto.pqworker.ObjectAccessResponseOrBuilder
-
map<string, .io.deephaven.proto.pqworker.StringList> objectGroups = 1;
- getObjectNames(int) - Method in class io.deephaven.proto.pqworker.ObjectAccessRequest.Builder
-
repeated string objectNames = 1;
- getObjectNames(int) - Method in class io.deephaven.proto.pqworker.ObjectAccessRequest
-
repeated string objectNames = 1;
- getObjectNames(int) - Method in interface io.deephaven.proto.pqworker.ObjectAccessRequestOrBuilder
-
repeated string objectNames = 1;
- getObjectNamesBytes(int) - Method in class io.deephaven.proto.pqworker.ObjectAccessRequest.Builder
-
repeated string objectNames = 1;
- getObjectNamesBytes(int) - Method in class io.deephaven.proto.pqworker.ObjectAccessRequest
-
repeated string objectNames = 1;
- getObjectNamesBytes(int) - Method in interface io.deephaven.proto.pqworker.ObjectAccessRequestOrBuilder
-
repeated string objectNames = 1;
- getObjectNamesCount() - Method in class io.deephaven.proto.pqworker.ObjectAccessRequest.Builder
-
repeated string objectNames = 1;
- getObjectNamesCount() - Method in class io.deephaven.proto.pqworker.ObjectAccessRequest
-
repeated string objectNames = 1;
- getObjectNamesCount() - Method in interface io.deephaven.proto.pqworker.ObjectAccessRequestOrBuilder
-
repeated string objectNames = 1;
- getObjectNamesList() - Method in class io.deephaven.proto.pqworker.ObjectAccessRequest.Builder
-
repeated string objectNames = 1;
- getObjectNamesList() - Method in class io.deephaven.proto.pqworker.ObjectAccessRequest
-
repeated string objectNames = 1;
- getObjectNamesList() - Method in interface io.deephaven.proto.pqworker.ObjectAccessRequestOrBuilder
-
repeated string objectNames = 1;
- getObjectServiceAuthWiring() - Method in class io.deephaven.enterprise.dnd.authentication.DheAuthorizationProvider
- getOrCreateTableDataService(TableDataServiceConfig, boolean, boolean) - Method in class io.deephaven.enterprise.tabledataservice.TableDataServiceFactory
-
Create the TableDataService starting with an actual
TableDataServiceConfig
instance - getOrCreateTableDataService(String, boolean, boolean) - Method in class io.deephaven.enterprise.tabledataservice.TableDataServiceFactory
-
Get a
TableDataService
based on the routing instructions provided by theDataRoutingService
provided at construction time. - getOwnerCredentials() - Static method in class io.deephaven.enterprise.dnd.authentication.DheAuthenticationHandler
- getPageContaining(ChunkSource.FillContext, long) - Method in class io.deephaven.enterprise.sources.regioned.impl.BufferedColumnRegionBase
- getParserForType() - Method in class io.deephaven.proto.pqworker.ListenErrorRequest
- getParserForType() - Method in class io.deephaven.proto.pqworker.ListenErrorResponse
- getParserForType() - Method in class io.deephaven.proto.pqworker.ObjectAccessRequest
- getParserForType() - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse
- getParserForType() - Method in class io.deephaven.proto.pqworker.StringList
- getPartitionedTableServiceContextualAuthWiring() - Method in class io.deephaven.enterprise.dnd.authentication.DheAuthorizationProvider
- getPartitions() - Method in interface io.deephaven.enterprise.locations.EnterpriseTableLocationKey
-
Get the Column and Internal partitions as a map.
- getPartitions() - Method in class io.deephaven.enterprise.locations.impl.BasicFixedPartitionedDeephavenTableLocationKey
- getPartitions() - Method in class io.deephaven.enterprise.locations.local.deephaven.DeephavenTableLocationKey
- getPartitions() - Method in class io.deephaven.enterprise.locations.local.EnterpriseTableLocationKeyUnresolved
- getPartitions() - Method in class io.deephaven.enterprise.locations.local.parquet.EnterpriseParquetTableLocationKey
- getPathManager() - Method in class io.deephaven.enterprise.tabledataservice.OnDiskTableDataService
- getPQWorkerServiceAuthWiring() - Method in class io.deephaven.enterprise.dnd.authentication.DheAuthorizationProvider
- getPQWorkerServiceAuthWiring() - Method in interface io.deephaven.enterprise.dnd.authentication.DnDAuthorizationProvider
- getPrecision() - Method in class io.deephaven.enterprise.compatibility.ObjectCodecAdapter
- getPrecision() - Method in class io.deephaven.enterprise.compatibility.shadow.ShadowingSerializableDecoder
- getPrev(long) - Method in class io.deephaven.enterprise.compatibility.filter.ColumnSourceAdapterForFilter
- getPrevBoolean(long) - Method in class io.deephaven.enterprise.compatibility.filter.ColumnSourceAdapterForFilter
- getPrevByte(long) - Method in class io.deephaven.enterprise.compatibility.filter.ColumnSourceAdapterForFilter
- getPrevChar(long) - Method in class io.deephaven.enterprise.compatibility.filter.ColumnSourceAdapterForFilter
- getPrevDouble(long) - Method in class io.deephaven.enterprise.compatibility.filter.ColumnSourceAdapterForFilter
- getPrevFloat(long) - Method in class io.deephaven.enterprise.compatibility.filter.ColumnSourceAdapterForFilter
- getPrevInt(long) - Method in class io.deephaven.enterprise.compatibility.filter.ColumnSourceAdapterForFilter
- getPrevLong(long) - Method in class io.deephaven.enterprise.compatibility.filter.ColumnSourceAdapterForFilter
- getPrevShort(long) - Method in class io.deephaven.enterprise.compatibility.filter.ColumnSourceAdapterForFilter
- getPriority() - Method in class io.deephaven.enterprise.test.PropertyInputStreamLoaderResourcesOnly
- getProcessInfoId() - Method in class io.deephaven.enterprise.dnd.SimpleProcessEventLogger.PelInfo
- getProcessName() - Method in class io.deephaven.enterprise.dnd.SimpleProcessEventLogger.PelInfo
- getQuoteType(Node) - Method in class io.deephaven.enterprise.dnd.autocomplete.CompleteTableName
- getQuoteType(Node) - Method in class io.deephaven.enterprise.dnd.autocomplete.CompleteTableNamespace
- getReaderForType(String) - Method in class io.deephaven.enterprise.compatibility.shadow.ShadowingPersistentInputStream
-
There are a few different paths within WObjectInputStream that resolve packages to real classes, this one handles the path when the object is plainly encoded in the stream.
- getRecord(long, String...) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- getRelativePosition() - Method in class io.deephaven.enterprise.compatibility.rowset.OrderedKeysToRowSequenceIteratorAdapter
- getRowFilters(AclSupport, UserContext, boolean) - Method in interface io.deephaven.enterprise.acl.EdgeAclProvider
-
Get the set of
WhereFilter
s that should be disjunctively applied to requested tables. - getRowFilters(AclSupport, UserContext, boolean) - Method in class io.deephaven.enterprise.acl.impl.EdgeAclImpl
- getRowFilters(AclSupport, String, String, boolean) - Method in class io.deephaven.enterprise.acl.impl.EnterpriseAclAdapterProvider
- getRowFilters(AclSupport, String, String, boolean) - Method in interface io.deephaven.enterprise.acl.SourceAclProvider
-
Get the set of
WhereFilter
s that should be disjunctively applied to requested tables. - getRowSequenceByKeyRange(long, long) - Method in class io.deephaven.enterprise.compatibility.rowset.OrderedKeysToRowSequenceAdapter
- getRowSequenceByPosition(long, long) - Method in class io.deephaven.enterprise.compatibility.rowset.OrderedKeysToRowSequenceAdapter
- getRowSequenceIterator() - Method in class io.deephaven.enterprise.compatibility.rowset.OrderedKeysToRowSequenceAdapter
- getRowSet() - Method in class io.deephaven.enterprise.compatibility.TableLocationStateAdapter
- getScale() - Method in class io.deephaven.enterprise.compatibility.ObjectCodecAdapter
- getScale() - Method in class io.deephaven.enterprise.compatibility.shadow.ShadowingSerializableDecoder
- getScriptPath() - Method in class io.deephaven.enterprise.dnd.query.util.perf.PerformanceOverview.PerformanceOverviewTools
- getScriptSession() - Method in interface io.deephaven.enterprise.dnd.EnterpriseJettyComponent
- getSerializedSize() - Method in class io.deephaven.proto.pqworker.ListenErrorRequest
- getSerializedSize() - Method in class io.deephaven.proto.pqworker.ListenErrorResponse
- getSerializedSize() - Method in class io.deephaven.proto.pqworker.ObjectAccessRequest
- getSerializedSize() - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse
- getSerializedSize() - Method in class io.deephaven.proto.pqworker.StringList
- getServiceDescriptor() - Static method in class io.deephaven.proto.pqworker.grpc.PQWorkerApiGrpc
- getSessionServiceAuthWiring() - Method in class io.deephaven.enterprise.dnd.authentication.DheAuthorizationProvider
- getSetNamespace() - Method in class io.deephaven.enterprise.acl.generator.WhereInFilterGenerator
-
Get the namespace of the set table.
- getSetTable(AclSupport, UserContext, String, String) - Method in class io.deephaven.enterprise.acl.generator.WhereInFilterGenerator
-
Generate the set table for a particular userContext accessing namespace and table.
- getSetTableName() - Method in class io.deephaven.enterprise.acl.generator.WhereInFilterGenerator
-
Get the name of the set table.
- getShort(long) - Method in class io.deephaven.enterprise.compatibility.filter.ColumnSourceAdapterForFilter
- getShort(long) - Method in class io.deephaven.enterprise.sources.regioned.impl.BufferedColumnRegionShort
- getShort(ChunkSource.FillContext, long) - Method in class io.deephaven.enterprise.sources.regioned.impl.BufferedColumnRegionShort
- getShortCauses() - Method in class io.deephaven.proto.pqworker.ListenErrorResponse.Builder
-
string shortCauses = 3;
- getShortCauses() - Method in class io.deephaven.proto.pqworker.ListenErrorResponse
-
string shortCauses = 3;
- getShortCauses() - Method in interface io.deephaven.proto.pqworker.ListenErrorResponseOrBuilder
-
string shortCauses = 3;
- getShortCausesBytes() - Method in class io.deephaven.proto.pqworker.ListenErrorResponse.Builder
-
string shortCauses = 3;
- getShortCausesBytes() - Method in class io.deephaven.proto.pqworker.ListenErrorResponse
-
string shortCauses = 3;
- getShortCausesBytes() - Method in interface io.deephaven.proto.pqworker.ListenErrorResponseOrBuilder
-
string shortCauses = 3;
- getSize() - Method in class io.deephaven.enterprise.compatibility.TableLocationStateAdapter
- getSnapshot() - Method in class io.deephaven.enterprise.locations.local.SnapshotBackedTableLocationKey
- getStackTrace() - Method in class io.deephaven.proto.pqworker.ListenErrorResponse.Builder
-
string stackTrace = 2;
- getStackTrace() - Method in class io.deephaven.proto.pqworker.ListenErrorResponse
-
string stackTrace = 2;
- getStackTrace() - Method in interface io.deephaven.proto.pqworker.ListenErrorResponseOrBuilder
-
string stackTrace = 2;
- getStackTraceBytes() - Method in class io.deephaven.proto.pqworker.ListenErrorResponse.Builder
-
string stackTrace = 2;
- getStackTraceBytes() - Method in class io.deephaven.proto.pqworker.ListenErrorResponse
-
string stackTrace = 2;
- getStackTraceBytes() - Method in interface io.deephaven.proto.pqworker.ListenErrorResponseOrBuilder
-
string stackTrace = 2;
- getStateLock() - Method in class io.deephaven.enterprise.compatibility.TableLocationStateAdapter
- getStorageServiceAuthWiring() - Method in class io.deephaven.enterprise.dnd.authentication.DheAuthorizationProvider
- getSubscribed() - Method in class io.deephaven.enterprise.dnd.ControllerClientFactory
-
Get a controller client that is subscribed to all queries.
- getSubTable(Index) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- getTable() - Method in class io.deephaven.enterprise.compatibility.filter.RecomputeListenerAdapter
- getTableDefinition(String, String) - Method in interface io.deephaven.enterprise.database.Database
-
Fetch a
TableDefinition
from the database. - getTableDefinition(String, String) - Method in class io.deephaven.enterprise.database.impl.DatabaseImpl
- getTableDefinitionTable(String, String) - Method in interface io.deephaven.enterprise.database.Database
-
Fetch a table's definition table from the database.
- getTableDefinitionTable(String, String) - Method in class io.deephaven.enterprise.database.impl.DatabaseImpl
- getTableName() - Method in exception io.deephaven.enterprise.database.TableLoggerException
- getTableName() - Method in interface io.deephaven.enterprise.locations.EnterpriseTableKey
-
Get the name of the table.
- getTableName() - Method in class io.deephaven.enterprise.locations.impl.EnterpriseTableKeyImpl
- getTableNames(String) - Method in class io.deephaven.enterprise.database.impl.DatabaseImpl
- getTableNames(String) - Method in interface io.deephaven.enterprise.database.Database
-
Get the tables within a namespace
- getTableServiceContextualAuthWiring() - Method in class io.deephaven.enterprise.dnd.authentication.DheAuthorizationProvider
- getTableType() - Method in interface io.deephaven.enterprise.locations.EnterpriseTableKey
-
Get the table type.
- getTableType() - Method in class io.deephaven.enterprise.locations.impl.EnterpriseTableKeyImpl
- getTicketResolverAuthorization() - Method in class io.deephaven.enterprise.dnd.authentication.DheAuthorizationProvider
- getType() - Method in class io.deephaven.enterprise.compatibility.filter.ColumnSourceAdapterForFilter
- getType() - Method in class io.deephaven.enterprise.dnd.notebook.NotebookReader.FileOrFolder
- getUnknownFields() - Method in class io.deephaven.proto.pqworker.ListenErrorRequest
- getUnknownFields() - Method in class io.deephaven.proto.pqworker.ListenErrorResponse
- getUnknownFields() - Method in class io.deephaven.proto.pqworker.ObjectAccessRequest
- getUnknownFields() - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse
- getUnknownFields() - Method in class io.deephaven.proto.pqworker.StringList
- getUnsubscribed() - Method in class io.deephaven.enterprise.dnd.ControllerClientFactory
-
Get a (possibly) unsubscribed controller client.
- getUseHistorical() - Method in class io.deephaven.enterprise.acl.generator.WhereInFilterGenerator
-
Get whether or not this generator will fetch its set table data from historical or intraday
- getUserContext() - Method in class io.deephaven.enterprise.database.impl.DatabaseAdapter
- getUserContext() - Method in class io.deephaven.enterprise.database.impl.DatabaseImpl
- getUserContext() - Method in interface io.deephaven.enterprise.database.impl.DatabaseInternal
- getUsersForGroup(String) - Method in class io.deephaven.enterprise.test.PFPBackedTestGroupProvider
- getValues(int) - Method in class io.deephaven.proto.pqworker.StringList.Builder
-
repeated string values = 1;
- getValues(int) - Method in class io.deephaven.proto.pqworker.StringList
-
repeated string values = 1;
- getValues(int) - Method in interface io.deephaven.proto.pqworker.StringListOrBuilder
-
repeated string values = 1;
- getValuesBytes(int) - Method in class io.deephaven.proto.pqworker.StringList.Builder
-
repeated string values = 1;
- getValuesBytes(int) - Method in class io.deephaven.proto.pqworker.StringList
-
repeated string values = 1;
- getValuesBytes(int) - Method in interface io.deephaven.proto.pqworker.StringListOrBuilder
-
repeated string values = 1;
- getValuesCount() - Method in class io.deephaven.proto.pqworker.StringList.Builder
-
repeated string values = 1;
- getValuesCount() - Method in class io.deephaven.proto.pqworker.StringList
-
repeated string values = 1;
- getValuesCount() - Method in interface io.deephaven.proto.pqworker.StringListOrBuilder
-
repeated string values = 1;
- getValuesList() - Method in class io.deephaven.proto.pqworker.StringList.Builder
-
repeated string values = 1;
- getValuesList() - Method in class io.deephaven.proto.pqworker.StringList
-
repeated string values = 1;
- getValuesList() - Method in interface io.deephaven.proto.pqworker.StringListOrBuilder
-
repeated string values = 1;
- getWasUncaught() - Method in class io.deephaven.proto.pqworker.ListenErrorResponse.Builder
-
bool wasUncaught = 4;
- getWasUncaught() - Method in class io.deephaven.proto.pqworker.ListenErrorResponse
-
bool wasUncaught = 4;
- getWasUncaught() - Method in interface io.deephaven.proto.pqworker.ListenErrorResponseOrBuilder
-
bool wasUncaught = 4;
- getWeakReference() - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- GroovyConsoleSessionWithDatabaseModule - Interface in io.deephaven.enterprise.dnd.modules
- group(String) - Static method in interface io.deephaven.enterprise.acl.AclFilterGenerator
-
Create an
AclFilterGenerator
that filters rows based on group data contained within the table. - group(String, boolean) - Static method in interface io.deephaven.enterprise.acl.AclFilterGenerator
-
Create an
AclFilterGenerator
that filters rows based on group data contained within the table. - GroupProvider - Interface in io.deephaven.enterprise.dnd.authentication
-
A provider for group membership information for users of the system.
H
- handleConfigUpdate(ControllerConfigurationMessage) - Method in class io.deephaven.enterprise.dnd.controller.client.ControllerClientGrpc.BasicObserver
- handleConfigUpdate(ControllerConfigurationMessage) - Method in interface io.deephaven.enterprise.dnd.controller.client.ControllerClientGrpc.Observer
- handleConnectionEstablished() - Method in class io.deephaven.enterprise.dnd.controller.client.ControllerClientGrpc.BasicObserver
- handleConnectionEstablished() - Method in interface io.deephaven.enterprise.dnd.controller.client.ControllerClientGrpc.Observer
- handleConnectionLost() - Method in class io.deephaven.enterprise.dnd.controller.client.ControllerClientGrpc.BasicObserver
- handleConnectionLost() - Method in class io.deephaven.enterprise.dnd.controller.client.ControllerClientGrpc
- handleConnectionLost() - Method in interface io.deephaven.enterprise.dnd.controller.client.ControllerClientGrpc.Observer
- handleConnectionReestablished() - Method in class io.deephaven.enterprise.dnd.controller.client.ControllerClientGrpc
- handlePut(PersistentQueryInfoMessage) - Method in class io.deephaven.enterprise.dnd.controller.client.ControllerClientGrpc.BasicObserver
- handlePut(PersistentQueryInfoMessage) - Method in interface io.deephaven.enterprise.dnd.controller.client.ControllerClientGrpc.Observer
- handleRemove(long) - Method in class io.deephaven.enterprise.dnd.controller.client.ControllerClientGrpc.BasicObserver
- handleRemove(long) - Method in interface io.deephaven.enterprise.dnd.controller.client.ControllerClientGrpc.Observer
- handleUpdate(TableLocationState) - Method in class io.deephaven.enterprise.locations.remote.RemoteDeephavenTableLocation
- hasAttribute(String) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- hasGrouping() - Method in class io.deephaven.enterprise.compatibility.filter.ColumnSourceAdapterForFilter
- hashCode() - Method in class io.deephaven.enterprise.compatibility.filter.EnterpriseFilterAdapter
- hashCode() - Method in class io.deephaven.enterprise.locations.impl.BasicFixedPartitionedDeephavenTableLocationKey
- hashCode() - Method in class io.deephaven.enterprise.locations.local.deephaven.DeephavenTableLocationKey
- hashCode() - Method in class io.deephaven.enterprise.locations.local.EnterpriseTableLocationKeyUnresolved
- hashCode() - Method in class io.deephaven.enterprise.locations.local.parquet.EnterpriseParquetTableLocationKey
- hashCode() - Method in class io.deephaven.proto.pqworker.ListenErrorRequest
- hashCode() - Method in class io.deephaven.proto.pqworker.ListenErrorResponse
- hashCode() - Method in class io.deephaven.proto.pqworker.ObjectAccessRequest
- hashCode() - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse
- hashCode() - Method in class io.deephaven.proto.pqworker.StringList
- hasLocationSnapshot() - Method in interface io.deephaven.enterprise.locations.EnterpriseTableLocationKey
-
Check if this table has a metadata index
- hasLocationSnapshot() - Method in class io.deephaven.enterprise.locations.local.SnapshotBackedTableLocationKey
- hasMore() - Method in class io.deephaven.enterprise.compatibility.rowset.OrderedKeysToRowSequenceIteratorAdapter
- head(long) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- headBy(long, String...) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- headPct(double) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- historicalPartitionedTable(String, String) - Method in interface io.deephaven.enterprise.database.Database
-
Retrieve the specified historical table as a
PartitionedTable
from the Database. - historicalPartitionedTable(String, String) - Method in class io.deephaven.enterprise.database.impl.DatabaseImpl
- historicalTable(String, String) - Method in interface io.deephaven.enterprise.acl.AclSupport
-
Fetch the specified historical table.
- historicalTable(String, String) - Method in interface io.deephaven.enterprise.database.Database
-
Fetch a static historical
Table
from the database. - historicalTable(String, String) - Method in class io.deephaven.enterprise.database.impl.DatabaseImpl
- historicalTable(String, String) - Static method in class io.deephaven.enterprise.dnd.client.DndSession
-
Create a
TableSpec
based on a historical table from the server. - HiveLocationsTableKeyFinder - Class in io.deephaven.enterprise.locations.local
-
A
TableLocationKeyFinder
that uses a table of file names, sizes, and partitioning columns to provide table locations. - HiveLocationsTableKeyFinder(File, List<ColumnDefinition<?>>, Table) - Constructor for class io.deephaven.enterprise.locations.local.HiveLocationsTableKeyFinder
-
Construct a
HiveLocationsTableKeyFinder
using the tableRoot for resolving full paths and the specifiedlocationsTable
for locating keys. - hostName(String) - Method in class io.deephaven.enterprise.dnd.query.util.perf.PerformanceOverview
-
Set the host name of the desired worker.
- hourly() - Static method in class io.deephaven.enterprise.kafkawriter.TimePartitionRotation
-
Return a function suitable for creating an hourly column partition from nanoseconds since the epoch.
- hourly(ZoneId, int) - Static method in class io.deephaven.enterprise.kafkawriter.TimePartitionRotation
-
Return a function suitable for creating an hourly column partition from nanoseconds since the epoch.
I
- ignoreColumn(String) - Method in class io.deephaven.enterprise.kafkawriter.KafkaTableWriter.Options
-
Specify a column from the source Kafka table that are ignored.
- ignoreColumns(Collection<String>) - Method in class io.deephaven.enterprise.kafkawriter.KafkaTableWriter.Options
-
Specify columns from the source Kafka table that are ignored.
- ignoreOffsetFromBroker(boolean) - Method in class io.deephaven.enterprise.kafkawriter.KafkaTableWriter.Options
-
Set a flag to determine whether previously-committed offsets at the broker will be respected.
- ignoreOffsetFromCheckpoints(boolean) - Method in class io.deephaven.enterprise.kafkawriter.KafkaTableWriter.Options
-
Set a flag to determine whether previously-committed offsets from earlier checkpoint records will be respected.
- init(TableDefinition) - Method in class io.deephaven.enterprise.compatibility.filter.EnterpriseFilterAdapter
- INITIAL_DECODER_BUFFER_SIZE - Static variable in class io.deephaven.enterprise.sources.regioned.impl.RegionUtilities
-
Initial size for new decoder buffers.
- initialize(String) - Method in class io.deephaven.enterprise.dnd.authentication.DheAuthenticationHandler
- INSTANCE - Static variable in class io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.sources.chunk.EnterpriseByteChunkAdapter
- INSTANCE - Static variable in class io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.sources.chunk.EnterpriseCharChunkAdapter
- INSTANCE - Static variable in class io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.sources.chunk.EnterpriseDoubleChunkAdapter
- INSTANCE - Static variable in class io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.sources.chunk.EnterpriseFloatChunkAdapter
- INSTANCE - Static variable in class io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.sources.chunk.EnterpriseIntChunkAdapter
- INSTANCE - Static variable in class io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.sources.chunk.EnterpriseLongChunkAdapter
- INSTANCE - Static variable in class io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.sources.chunk.EnterpriseObjectChunkAdapter
- INSTANCE - Static variable in class io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.sources.chunk.EnterpriseShortChunkAdapter
- Int - Enum constant in enum class io.deephaven.enterprise.sources.regioned.BufferedType
- intercept(String, Throwable, boolean) - Method in class io.deephaven.enterprise.dnd.service.pqworker.PQWorkerServiceGrpcImpl
- intercept(PQWorkerApiGrpc.PQWorkerApiImplBase) - Method in interface io.deephaven.enterprise.dnd.authentication.PQWorkerServiceAuthWiring
-
Wrap the real implementation with authorization checks.
- internalGetFieldAccessorTable() - Method in class io.deephaven.proto.pqworker.ListenErrorRequest.Builder
- internalGetFieldAccessorTable() - Method in class io.deephaven.proto.pqworker.ListenErrorRequest
- internalGetFieldAccessorTable() - Method in class io.deephaven.proto.pqworker.ListenErrorResponse.Builder
- internalGetFieldAccessorTable() - Method in class io.deephaven.proto.pqworker.ListenErrorResponse
- internalGetFieldAccessorTable() - Method in class io.deephaven.proto.pqworker.ObjectAccessRequest.Builder
- internalGetFieldAccessorTable() - Method in class io.deephaven.proto.pqworker.ObjectAccessRequest
- internalGetFieldAccessorTable() - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse.Builder
- internalGetFieldAccessorTable() - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse
- internalGetFieldAccessorTable() - Method in class io.deephaven.proto.pqworker.StringList.Builder
- internalGetFieldAccessorTable() - Method in class io.deephaven.proto.pqworker.StringList
- internalGetMapField(int) - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse.Builder
- internalGetMapField(int) - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse
- internalGetMutableMapField(int) - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse.Builder
- internalPartition() - Method in class io.deephaven.enterprise.database.SystemTableLogger.Options
-
What internal partition should we write to?
- internalPartition(String) - Method in interface io.deephaven.enterprise.database.SystemTableLogger.Options.Builder
-
What internal partition should we write to?
- InvalidatableRegion<ATTR extends Values> - Class in io.deephaven.enterprise.sources.regioned.impl
- InvalidatableRegion() - Constructor for class io.deephaven.enterprise.sources.regioned.impl.InvalidatableRegion
- invalidate() - Method in class io.deephaven.enterprise.sources.regioned.impl.InvalidatableRegion
- io.deephaven.chunk - package io.deephaven.chunk
- io.deephaven.enterprise.acl - package io.deephaven.enterprise.acl
- io.deephaven.enterprise.acl.generator - package io.deephaven.enterprise.acl.generator
- io.deephaven.enterprise.acl.impl - package io.deephaven.enterprise.acl.impl
- io.deephaven.enterprise.acl.transform - package io.deephaven.enterprise.acl.transform
- io.deephaven.enterprise.compatibility - package io.deephaven.enterprise.compatibility
- io.deephaven.enterprise.compatibility.chunk - package io.deephaven.enterprise.compatibility.chunk
- io.deephaven.enterprise.compatibility.filter - package io.deephaven.enterprise.compatibility.filter
- io.deephaven.enterprise.compatibility.rowset - package io.deephaven.enterprise.compatibility.rowset
- io.deephaven.enterprise.compatibility.shadow - package io.deephaven.enterprise.compatibility.shadow
- io.deephaven.enterprise.compatibility.vector - package io.deephaven.enterprise.compatibility.vector
- io.deephaven.enterprise.database - package io.deephaven.enterprise.database
- io.deephaven.enterprise.database.impl - package io.deephaven.enterprise.database.impl
- io.deephaven.enterprise.dnd - package io.deephaven.enterprise.dnd
- io.deephaven.enterprise.dnd.authentication - package io.deephaven.enterprise.dnd.authentication
- io.deephaven.enterprise.dnd.authentication.transform - package io.deephaven.enterprise.dnd.authentication.transform
- io.deephaven.enterprise.dnd.autocomplete - package io.deephaven.enterprise.dnd.autocomplete
- io.deephaven.enterprise.dnd.client - package io.deephaven.enterprise.dnd.client
- io.deephaven.enterprise.dnd.client.exception - package io.deephaven.enterprise.dnd.client.exception
- io.deephaven.enterprise.dnd.controller.client - package io.deephaven.enterprise.dnd.controller.client
- io.deephaven.enterprise.dnd.logger.engine.impl - package io.deephaven.enterprise.dnd.logger.engine.impl
- io.deephaven.enterprise.dnd.modules - package io.deephaven.enterprise.dnd.modules
- io.deephaven.enterprise.dnd.notebook - package io.deephaven.enterprise.dnd.notebook
- io.deephaven.enterprise.dnd.query.util.perf - package io.deephaven.enterprise.dnd.query.util.perf
- io.deephaven.enterprise.dnd.service.pqworker - package io.deephaven.enterprise.dnd.service.pqworker
- io.deephaven.enterprise.dnd.service.ticket - package io.deephaven.enterprise.dnd.service.ticket
- io.deephaven.enterprise.dnd.uri - package io.deephaven.enterprise.dnd.uri
- io.deephaven.enterprise.kafkawriter - package io.deephaven.enterprise.kafkawriter
- io.deephaven.enterprise.locations - package io.deephaven.enterprise.locations
- io.deephaven.enterprise.locations.impl - package io.deephaven.enterprise.locations.impl
- io.deephaven.enterprise.locations.local - package io.deephaven.enterprise.locations.local
- io.deephaven.enterprise.locations.local.deephaven - package io.deephaven.enterprise.locations.local.deephaven
- io.deephaven.enterprise.locations.local.parquet - package io.deephaven.enterprise.locations.local.parquet
- io.deephaven.enterprise.locations.remote - package io.deephaven.enterprise.locations.remote
- io.deephaven.enterprise.sources.regioned - package io.deephaven.enterprise.sources.regioned
- io.deephaven.enterprise.sources.regioned.impl - package io.deephaven.enterprise.sources.regioned.impl
- io.deephaven.enterprise.table - package io.deephaven.enterprise.table
- io.deephaven.enterprise.tabledataservice - package io.deephaven.enterprise.tabledataservice
- io.deephaven.enterprise.tabledataservice.filter - package io.deephaven.enterprise.tabledataservice.filter
- io.deephaven.enterprise.test - package io.deephaven.enterprise.test
- io.deephaven.proto.pqworker - package io.deephaven.proto.pqworker
- io.deephaven.proto.pqworker.grpc - package io.deephaven.proto.pqworker.grpc
- io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.select - package io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.select
- io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.sources.chunk - package io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.sources.chunk
- isAdmin(UserContext) - Static method in class io.deephaven.enterprise.dnd.authentication.DheAuthenticationHandler
-
Check if the specified user is an administrator of this worker.
- isAutomatedFilter() - Method in class io.deephaven.enterprise.compatibility.filter.EnterpriseFilterAdapter
- isConnected() - Method in class io.deephaven.enterprise.dnd.controller.client.ControllerClientGrpc
-
Check if this client can communicate with the server.
- isContiguous() - Method in class io.deephaven.enterprise.compatibility.rowset.OrderedKeysToRowSequenceAdapter
- isEmpty() - Method in class io.deephaven.enterprise.compatibility.rowset.OrderedKeysToRowSequenceAdapter
- isFile() - Method in class io.deephaven.enterprise.dnd.notebook.NotebookReader.FileOrFolder
-
Is this a file?
- isFlat() - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- isFolder() - Method in class io.deephaven.enterprise.dnd.notebook.NotebookReader.FileOrFolder
-
Is this a folder?
- isImmutable() - Method in class io.deephaven.enterprise.compatibility.filter.ColumnSourceAdapterForFilter
- isInitialized() - Method in class io.deephaven.proto.pqworker.ListenErrorRequest.Builder
- isInitialized() - Method in class io.deephaven.proto.pqworker.ListenErrorRequest
- isInitialized() - Method in class io.deephaven.proto.pqworker.ListenErrorResponse.Builder
- isInitialized() - Method in class io.deephaven.proto.pqworker.ListenErrorResponse
- isInitialized() - Method in class io.deephaven.proto.pqworker.ObjectAccessRequest.Builder
- isInitialized() - Method in class io.deephaven.proto.pqworker.ObjectAccessRequest
- isInitialized() - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse.Builder
- isInitialized() - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse
- isInitialized() - Method in class io.deephaven.proto.pqworker.StringList.Builder
- isInitialized() - Method in class io.deephaven.proto.pqworker.StringList
- isIntraday(boolean) - Method in class io.deephaven.enterprise.dnd.query.util.perf.PerformanceOverview
-
Set if the performance overview should be generated from intraday data.
- isLive(boolean) - Method in class io.deephaven.enterprise.dnd.query.util.perf.PerformanceOverview
-
Set if the performance overview should refresh once generated.
- isMember(UserContext, String, String...) - Method in interface io.deephaven.enterprise.dnd.authentication.GroupProvider
-
Check if the specified user is a member or supervisor of any of the specified groups.
- isMember(UserContext, String, String...) - Method in class io.deephaven.enterprise.dnd.authentication.WrappedGroupProvider
- isNullable() - Method in class io.deephaven.enterprise.compatibility.ObjectCodecAdapter
- isNullable() - Method in class io.deephaven.enterprise.compatibility.shadow.ShadowingSerializableDecoder
- isNullOrTrueFilter(Filter) - Static method in class io.deephaven.enterprise.acl.impl.AclHelper
- isRefreshing() - Method in class io.deephaven.enterprise.compatibility.filter.EnterpriseFilterAdapter
- isResolvable(URI) - Method in class io.deephaven.enterprise.dnd.uri.PQUriResolver
- isRunning(PersistentQueryStatusEnum) - Method in class io.deephaven.enterprise.dnd.controller.client.ControllerClientGrpc
- isSimpleFilter() - Method in class io.deephaven.enterprise.compatibility.filter.EnterpriseFilterAdapter
- isSuperUser(UserContext) - Method in interface io.deephaven.enterprise.dnd.authentication.GroupProvider
-
Check if the specified user is a superuser.
- isSuperUser(UserContext) - Method in class io.deephaven.enterprise.dnd.authentication.WrappedGroupProvider
- isTerminal(PersistentQueryStatusEnum) - Method in class io.deephaven.enterprise.dnd.controller.client.ControllerClientGrpc
- isViewer(UserContext) - Static method in class io.deephaven.enterprise.dnd.authentication.DheAuthenticationHandler
-
Check if the specified user is a viewer of this worker.
J
- join(Table, MatchPair[], MatchPair[], int) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
K
- kafkaProperties(Properties) - Method in class io.deephaven.enterprise.kafkawriter.KafkaTableWriter.Options
-
Set the properties for the underlying
KafkaConsumer
, this is a required option. - KafkaTableWriter - Class in io.deephaven.enterprise.kafkawriter
-
The KafkaTableWriter creates a Community KafkaIngester that persists the data to disk and serves it to other queries using an in-worker instance of the DataImportServer.
- KafkaTableWriter() - Constructor for class io.deephaven.enterprise.kafkawriter.KafkaTableWriter
- KafkaTableWriter.Options - Class in io.deephaven.enterprise.kafkawriter
-
A builder class containing the options for Kafka ingestion.
- KEY_PROCESS_INFO_ID - Static variable in class io.deephaven.enterprise.dnd.Main
- keySpec(KafkaTools.Consume.KeyOrValueSpec) - Method in class io.deephaven.enterprise.kafkawriter.KafkaTableWriter.Options
-
Determine how the key is converted to table columns.
L
- lasEnabled() - Method in class io.deephaven.enterprise.database.SystemTableLogger.Options
-
If the LAS is explicitly specified, then use that value.
- LAST_MODIFIED_NANOS_COLUMN_NAME - Static variable in class io.deephaven.enterprise.locations.local.HiveLocationsTableKeyFinder
-
The column name containing the epoch timestamp of the time the partition was last modified.
- lastBy(SelectColumn...) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- lastRowKey() - Method in class io.deephaven.enterprise.compatibility.rowset.OrderedKeysToRowSequenceAdapter
- layoutHints(String) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- lazyUpdate(SelectColumn...) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- leftJoin(Table, MatchPair[], MatchPair[]) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- lengthItems() - Method in interface io.deephaven.enterprise.sources.regioned.ColumnRegionByteWithLength
-
Get the total number of bytes within the region.
- lengthItems() - Method in interface io.deephaven.enterprise.sources.regioned.ColumnRegionLongWithLength
-
Get the total number of longs within the region.
- lengthItems() - Method in class io.deephaven.enterprise.sources.regioned.impl.BufferedColumnRegionBase
- ListenErrorRequest - Class in io.deephaven.proto.pqworker
-
Protobuf type
io.deephaven.proto.pqworker.ListenErrorRequest
- ListenErrorRequest.Builder - Class in io.deephaven.proto.pqworker
-
Protobuf type
io.deephaven.proto.pqworker.ListenErrorRequest
- ListenErrorRequestOrBuilder - Interface in io.deephaven.proto.pqworker
- ListenErrorResponse - Class in io.deephaven.proto.pqworker
-
Protobuf type
io.deephaven.proto.pqworker.ListenErrorResponse
- ListenErrorResponse.Builder - Class in io.deephaven.proto.pqworker
-
Protobuf type
io.deephaven.proto.pqworker.ListenErrorResponse
- ListenErrorResponseOrBuilder - Interface in io.deephaven.proto.pqworker
- listenForError(ListenErrorRequest) - Method in class io.deephaven.proto.pqworker.grpc.PQWorkerApiGrpc.PQWorkerApiBlockingStub
- listenForError(ListenErrorRequest, StreamObserver<ListenErrorResponse>) - Method in class io.deephaven.enterprise.dnd.service.pqworker.PQWorkerServiceGrpcImpl
- listenForError(ListenErrorRequest, StreamObserver<ListenErrorResponse>) - Method in class io.deephaven.proto.pqworker.grpc.PQWorkerApiGrpc.PQWorkerApiImplBase
- listenForError(ListenErrorRequest, StreamObserver<ListenErrorResponse>) - Method in class io.deephaven.proto.pqworker.grpc.PQWorkerApiGrpc.PQWorkerApiStub
- livePartitionedTable(String, String) - Method in interface io.deephaven.enterprise.database.Database
-
Retrieve the specified live table as a
PartitionedTable
from the Database. - livePartitionedTable(String, String, boolean) - Method in interface io.deephaven.enterprise.database.Database
-
Retrieve the specified live table as a
PartitionedTable
from the Database. - livePartitionedTable(String, String, boolean) - Method in class io.deephaven.enterprise.database.impl.DatabaseImpl
- liveTable(String, String) - Method in interface io.deephaven.enterprise.database.Database
-
Fetch a live
Table
for the specified namespace and table name. - liveTable(String, String) - Static method in class io.deephaven.enterprise.dnd.client.DndSession
-
Create a
TableSpec
based on a live table from the server. - liveTable(String, String, boolean) - Method in interface io.deephaven.enterprise.acl.AclSupport
-
Fetch the specified live (intraday) table.
- liveTable(String, String, boolean) - Method in interface io.deephaven.enterprise.database.Database
-
Fetch a live
Table
for the specified namespace and table name. - liveTable(String, String, boolean) - Method in class io.deephaven.enterprise.database.impl.DatabaseImpl
- LiveTableRegistrarAdapter - Class in io.deephaven.enterprise.compatibility
- loadDefinitionFromDirectory(File, String) - Static method in class io.deephaven.enterprise.compatibility.TableDefinitionCompatibility
-
Load a TableDefinition from the definition file in the specified directory.
- LOCATIONS_SUBDIRECTORY - Static variable in class io.deephaven.enterprise.locations.local.HiveLocationsTableKeyFinder
-
The name of the subdirectory containing the locations table, in Deephaven format.
- log(long, String, String) - Method in class io.deephaven.enterprise.dnd.SimpleProcessEventLogger
- log(UserContext, String, String, String, String) - Method in class io.deephaven.enterprise.dnd.SimpleAuditEventLogger
- log(String, String) - Method in class io.deephaven.enterprise.dnd.SimpleAuditEventLogger
- log(String, String, String, String) - Method in class io.deephaven.enterprise.dnd.SimpleAuditEventLogger
- logDirectory() - Method in class io.deephaven.enterprise.database.SystemTableLogger.Options
-
Destination directory for binary log files.
- logDirectory(String) - Method in interface io.deephaven.enterprise.database.SystemTableLogger.Options.Builder
-
Where should binary log files be written.
- login(long, ByteBuffer, AuthenticationRequestHandler.HandshakeResponseListener) - Method in class io.deephaven.enterprise.dnd.authentication.DheAuthenticationHandler
- login(String, AuthenticationRequestHandler.MetadataResponseListener) - Method in class io.deephaven.enterprise.dnd.authentication.DheAuthenticationHandler
- logTable(Database, String, String, Table, SystemTableLogger.Options) - Static method in class io.deephaven.enterprise.database.SystemTableLogger
-
Write tableToLog to System storage.
- logTable(Database, String, String, Table, SystemTableLogger.Options) - Static method in class io.deephaven.enterprise.database.impl.SystemTableLoggerImpl
- logTableIncremental(Database, String, String, Table, SystemTableLogger.Options) - Static method in class io.deephaven.enterprise.database.SystemTableLogger
-
Write tableToLog and its updates to System storage.
- logTableIncremental(Database, String, String, Table, SystemTableLogger.Options) - Static method in class io.deephaven.enterprise.database.impl.SystemTableLoggerImpl
- logToRow(long, String, String) - Method in class io.deephaven.enterprise.dnd.SimpleProcessEventLogger
- Long - Enum constant in enum class io.deephaven.enterprise.sources.regioned.BufferedType
- lookup(int, ChunkSource.FillContext) - Method in class io.deephaven.enterprise.sources.regioned.impl.ColumnRegionObjectCached
M
- main(String[]) - Static method in class io.deephaven.enterprise.dnd.Main
- Main - Class in io.deephaven.enterprise.dnd
- Main() - Constructor for class io.deephaven.enterprise.dnd.Main
- make(ChunkType) - Static method in interface io.deephaven.enterprise.compatibility.chunk.ChunkAdapter
-
Create an appropriate adapter instance for the specified
ChunkType
- makeAndStartAuthRetryBackoffContext(long) - Method in class io.deephaven.enterprise.dnd.controller.client.ControllerClientGrpc
- makeColumnLocation(String) - Method in class io.deephaven.enterprise.locations.local.deephaven.OnDiskDeephavenTableLocation
- makeColumnLocation(String) - Method in class io.deephaven.enterprise.locations.local.SnapshotBackedTableLocation
- makeColumnLocation(String) - Method in class io.deephaven.enterprise.locations.remote.RemoteDeephavenTableLocation
- makeColumnRegionByte(ColumnDefinition<?>) - Method in interface io.deephaven.enterprise.locations.DeephavenFormatColumnLocation
- makeColumnRegionChar(ColumnDefinition<?>) - Method in interface io.deephaven.enterprise.locations.DeephavenFormatColumnLocation
- makeColumnRegionDouble(ColumnDefinition<?>) - Method in interface io.deephaven.enterprise.locations.DeephavenFormatColumnLocation
- makeColumnRegionFloat(ColumnDefinition<?>) - Method in interface io.deephaven.enterprise.locations.DeephavenFormatColumnLocation
- makeColumnRegionInt(ColumnDefinition<?>) - Method in interface io.deephaven.enterprise.locations.DeephavenFormatColumnLocation
- makeColumnRegionLong(ColumnDefinition<?>) - Method in interface io.deephaven.enterprise.locations.DeephavenFormatColumnLocation
- makeColumnRegionObject(ColumnDefinition<TYPE>) - Method in interface io.deephaven.enterprise.locations.DeephavenFormatColumnLocation
- makeColumnRegionShort(ColumnDefinition<?>) - Method in interface io.deephaven.enterprise.locations.DeephavenFormatColumnLocation
- makeControllerClientFactory() - Static method in class io.deephaven.enterprise.dnd.ControllerClientFactory
- makeDefinition(boolean) - Method in class io.deephaven.enterprise.test.TestTableGenerator
- makeDheDefinition() - Method in class io.deephaven.enterprise.test.TestTableGenerator
- makeDheTable(String, int, String, long) - Method in class io.deephaven.enterprise.test.TestTableGenerator
- makeDheTable(String, long) - Method in class io.deephaven.enterprise.test.TestTableGenerator
- makeFillContext(int, SharedContext) - Method in class io.deephaven.enterprise.sources.regioned.impl.BufferedColumnRegionBase
- makeFillContext(int, SharedContext) - Method in class io.deephaven.enterprise.sources.regioned.impl.ColumnRegionObjectCodecFixed
- makeFillContext(int, SharedContext) - Method in class io.deephaven.enterprise.sources.regioned.impl.ColumnRegionObjectCodecVariable
- makeFillContext(int, SharedContext) - Method in class io.deephaven.enterprise.sources.regioned.impl.ColumnRegionObjectWithDictionary
- makeFillContext(int, SharedContext) - Method in class io.deephaven.enterprise.compatibility.filter.ColumnSourceAdapterForFilter
- makeKey(Path, Map<String, Comparable<?>>) - Method in class io.deephaven.enterprise.locations.local.EnterpriseFixedPartitionedKeyFinder
- makeLocation(EnterpriseTableKey, EnterpriseTableLocationKey, TableDataRefreshService) - Method in class io.deephaven.enterprise.locations.local.EnterpriseTableLocationFactory
- makePartitionMap(String, TableLocationKey) - Static method in interface io.deephaven.enterprise.locations.FixedPartitionedEnterpriseTableLocationKey
-
Convert the enterprise
TableLocationKey
into a Community partition map. - makeRemoteTableDataService(String, DataRoutingService.PropertyProvider, boolean) - Method in class io.deephaven.enterprise.tabledataservice.TableDataServiceFactory
-
Create a new
RemoteTableDataService
, allowing for subclass overrides for testing. - makeSession(PersistentQueryInfoMessage, String, AuthToken, ScheduledExecutorService, boolean, ControllerClientGrpc, int) - Method in class io.deephaven.enterprise.dnd.client.DndSessionFactoryBarrage
- makeTable(ExecutionContext, String, int, String, long) - Method in class io.deephaven.enterprise.test.TestTableGenerator
- makeTable(ExecutionContext, String, long) - Method in class io.deephaven.enterprise.test.TestTableGenerator
- makeTableLocationProvider(TableKey) - Method in class io.deephaven.enterprise.tabledataservice.OnDiskTableDataService
- makeTableLocationProvider(TableKey) - Method in class io.deephaven.enterprise.tabledataservice.RemoteTableDataService
- MarkingPollingLocationProvider<TK extends TableKey,
TLK extends TableLocationKey> - Class in io.deephaven.enterprise.tabledataservice -
A
TableLocationProvider
that will perform a mark/sweep of active locations on refresh. - MarkingPollingLocationProvider(TK, TableLocationKeyFinder<TLK>, TableLocationFactory<TK, TLK>, TableDataRefreshService) - Constructor for class io.deephaven.enterprise.tabledataservice.MarkingPollingLocationProvider
- mask() - Method in interface io.deephaven.enterprise.sources.regioned.BufferedColumnRegion
- mask() - Method in interface io.deephaven.enterprise.sources.regioned.BufferedPage
- mask() - Method in class io.deephaven.enterprise.sources.regioned.impl.ColumnRegionObjectCached
- mask() - Method in class io.deephaven.enterprise.sources.regioned.impl.ColumnRegionObjectCodecFixed
- mask() - Method in class io.deephaven.enterprise.sources.regioned.impl.ColumnRegionObjectCodecVariable
- mask() - Method in class io.deephaven.enterprise.sources.regioned.impl.ColumnRegionObjectWithDictionary
- mask() - Method in class io.deephaven.enterprise.sources.regioned.impl.ColumnRegionStringSet
- match(boolean, boolean, boolean, ReadOnlyIndex, Object...) - Method in class io.deephaven.enterprise.compatibility.filter.ColumnSourceAdapterForFilter
- matchSubscriptionToken(T) - Method in class io.deephaven.enterprise.locations.local.deephaven.OnDiskDeephavenTableLocation
- matchSubscriptionToken(T) - Method in class io.deephaven.enterprise.locations.remote.RemoteDeephavenTableLocation
- maxBy(SelectColumn...) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- maybeAddNotification(NotificationQueue.Notification, long) - Method in class io.deephaven.enterprise.compatibility.NotificationQueueAdapter
- maybeGetSpecialDecoderClass(Class<?>) - Static method in class io.deephaven.enterprise.compatibility.CodecCompatibility
- maybeMutateCommunityType(Class<?>) - Static method in class io.deephaven.enterprise.compatibility.TableDefinitionCompatibility
-
Convert the column data types.
- maybeRefreshTable(LiveTable, boolean) - Method in class io.deephaven.enterprise.compatibility.LiveTableRegistrarAdapter
- maybeRemapShadowedClass(String) - Static method in class io.deephaven.enterprise.compatibility.shadow.ShadowCompatibility
-
Attempt to remap the specified type onto it's shadowed version.
- medianBy(SelectColumn...) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class io.deephaven.proto.pqworker.ListenErrorRequest.Builder
- mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class io.deephaven.proto.pqworker.ListenErrorResponse.Builder
- mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class io.deephaven.proto.pqworker.ObjectAccessRequest.Builder
- mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse.Builder
- mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class io.deephaven.proto.pqworker.StringList.Builder
- mergeFrom(Message) - Method in class io.deephaven.proto.pqworker.ListenErrorRequest.Builder
- mergeFrom(Message) - Method in class io.deephaven.proto.pqworker.ListenErrorResponse.Builder
- mergeFrom(Message) - Method in class io.deephaven.proto.pqworker.ObjectAccessRequest.Builder
- mergeFrom(Message) - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse.Builder
- mergeFrom(Message) - Method in class io.deephaven.proto.pqworker.StringList.Builder
- mergeFrom(ListenErrorRequest) - Method in class io.deephaven.proto.pqworker.ListenErrorRequest.Builder
- mergeFrom(ListenErrorResponse) - Method in class io.deephaven.proto.pqworker.ListenErrorResponse.Builder
- mergeFrom(ObjectAccessRequest) - Method in class io.deephaven.proto.pqworker.ObjectAccessRequest.Builder
- mergeFrom(ObjectAccessResponse) - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse.Builder
- mergeFrom(StringList) - Method in class io.deephaven.proto.pqworker.StringList.Builder
- mergeUnknownFields(UnknownFieldSet) - Method in class io.deephaven.proto.pqworker.ListenErrorRequest.Builder
- mergeUnknownFields(UnknownFieldSet) - Method in class io.deephaven.proto.pqworker.ListenErrorResponse.Builder
- mergeUnknownFields(UnknownFieldSet) - Method in class io.deephaven.proto.pqworker.ObjectAccessRequest.Builder
- mergeUnknownFields(UnknownFieldSet) - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse.Builder
- mergeUnknownFields(UnknownFieldSet) - Method in class io.deephaven.proto.pqworker.StringList.Builder
- MESSAGE_FIELD_NUMBER - Static variable in class io.deephaven.proto.pqworker.ListenErrorResponse
- MetadataIndexKeyFinder - Class in io.deephaven.enterprise.locations.local
-
A
TableLocationKeyFinder
that uses the EnterpriseTableLocationMetadataIndex
to find locations. - MetadataIndexKeyFinder(LocalTablePathManager, String, EnterpriseTableKey, TableLocationMetadataIndex) - Constructor for class io.deephaven.enterprise.locations.local.MetadataIndexKeyFinder
-
Construct a
MetadataIndexKeyFinder
using thepathManager
for resolving full paths and the specifiedmetadataIndex
for locating keys. - minBy(SelectColumn...) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- modifyQueryConfiguration(PersistentQueryConfigMessage) - Method in class io.deephaven.enterprise.dnd.controller.client.ControllerClientGrpc
-
Modifies a configuration in the controller's hash table, and restart the query if it was running.
- modifyQueryConfiguration(PersistentQueryConfigMessage, boolean) - Method in class io.deephaven.enterprise.dnd.controller.client.ControllerClientGrpc
-
Modifies a configuration in the controller's hash table.
N
- namespace(String) - Method in class io.deephaven.enterprise.kafkawriter.KafkaTableWriter.Options
-
The namespace of the table to ingest, this is a required option.
- NAMESPACE_PATH_INDEX - Static variable in class io.deephaven.enterprise.dnd.service.ticket.DatabaseTicketResolver
- naturalJoin(Table, MatchPair[], MatchPair[]) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- newBlockingStub(Channel) - Static method in class io.deephaven.proto.pqworker.grpc.PQWorkerApiGrpc
-
Creates a new blocking-style stub that supports unary and streaming output calls on the service
- newBuilder() - Static method in class io.deephaven.proto.pqworker.ListenErrorRequest
- newBuilder() - Static method in class io.deephaven.proto.pqworker.ListenErrorResponse
- newBuilder() - Static method in class io.deephaven.proto.pqworker.ObjectAccessRequest
- newBuilder() - Static method in class io.deephaven.proto.pqworker.ObjectAccessResponse
- newBuilder() - Static method in class io.deephaven.proto.pqworker.StringList
- newBuilder(ListenErrorRequest) - Static method in class io.deephaven.proto.pqworker.ListenErrorRequest
- newBuilder(ListenErrorResponse) - Static method in class io.deephaven.proto.pqworker.ListenErrorResponse
- newBuilder(ObjectAccessRequest) - Static method in class io.deephaven.proto.pqworker.ObjectAccessRequest
- newBuilder(ObjectAccessResponse) - Static method in class io.deephaven.proto.pqworker.ObjectAccessResponse
- newBuilder(StringList) - Static method in class io.deephaven.proto.pqworker.StringList
- newBuilderForType() - Method in class io.deephaven.proto.pqworker.ListenErrorRequest
- newBuilderForType() - Method in class io.deephaven.proto.pqworker.ListenErrorResponse
- newBuilderForType() - Method in class io.deephaven.proto.pqworker.ObjectAccessRequest
- newBuilderForType() - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse
- newBuilderForType() - Method in class io.deephaven.proto.pqworker.StringList
- newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class io.deephaven.proto.pqworker.ListenErrorRequest
- newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class io.deephaven.proto.pqworker.ListenErrorResponse
- newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class io.deephaven.proto.pqworker.ObjectAccessRequest
- newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse
- newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class io.deephaven.proto.pqworker.StringList
- newFutureStub(Channel) - Static method in class io.deephaven.proto.pqworker.grpc.PQWorkerApiGrpc
-
Creates a new ListenableFuture-style stub that supports unary calls on the service
- newInstance(GeneratedMessageV3.UnusedPrivateParameter) - Method in class io.deephaven.proto.pqworker.ListenErrorRequest
- newInstance(GeneratedMessageV3.UnusedPrivateParameter) - Method in class io.deephaven.proto.pqworker.ListenErrorResponse
- newInstance(GeneratedMessageV3.UnusedPrivateParameter) - Method in class io.deephaven.proto.pqworker.ObjectAccessRequest
- newInstance(GeneratedMessageV3.UnusedPrivateParameter) - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse
- newInstance(GeneratedMessageV3.UnusedPrivateParameter) - Method in class io.deephaven.proto.pqworker.StringList
- newOptionsBuilder() - Static method in class io.deephaven.enterprise.database.SystemTableLogger
-
Create an options builder for use with logTable.
- newStub(Channel) - Static method in class io.deephaven.proto.pqworker.grpc.PQWorkerApiGrpc
-
Creates a new async stub that supports all call types for the service
- newWorker(PersistentQueryConfigMessage, long) - Method in class io.deephaven.enterprise.dnd.client.DndSessionFactoryBarrage
-
Create a new Interactive Console Persistent Query session.
- newWorker(String, float, long, long) - Method in class io.deephaven.enterprise.dnd.client.DndSessionFactoryBarrage
- noAccess() - Static method in interface io.deephaven.enterprise.acl.AclFilterGenerator
-
Create an
AclFilterGenerator
that gives no access to the table. - NoAccessFilterGenerator - Class in io.deephaven.enterprise.acl.generator
-
An
AclFilterGenerator
that provides no access to anyonne. - NoAccessFilterGenerator() - Constructor for class io.deephaven.enterprise.acl.generator.NoAccessFilterGenerator
- NonSystemSchemaException - Exception in io.deephaven.enterprise.database
-
Exception thrown when an operation expects a System schema, but was passed a non-system schema.
- NonSystemSchemaException(String, String, String) - Constructor for exception io.deephaven.enterprise.database.NonSystemSchemaException
- NotebookReader - Class in io.deephaven.enterprise.dnd.notebook
-
Tools for getting Files and Folders out of the Web IDE notebooks that are stored in DbInternal.WebClientData.
- NotebookReader.FileOrFolder - Class in io.deephaven.enterprise.dnd.notebook
-
A record class that represents a file or folder.
- NotebookReader.NotFoundException - Exception in io.deephaven.enterprise.dnd.notebook
-
An exception thrown when a Notebook is not found.
- NotificationAdapter - Class in io.deephaven.enterprise.compatibility
- NotificationAdapter(NotificationQueue.Notification) - Constructor for class io.deephaven.enterprise.compatibility.NotificationAdapter
- NotificationQueueAdapter - Class in io.deephaven.enterprise.compatibility
O
- ObjectAccessRequest - Class in io.deephaven.proto.pqworker
-
Protobuf type
io.deephaven.proto.pqworker.ObjectAccessRequest
- ObjectAccessRequest.Builder - Class in io.deephaven.proto.pqworker
-
Protobuf type
io.deephaven.proto.pqworker.ObjectAccessRequest
- ObjectAccessRequestOrBuilder - Interface in io.deephaven.proto.pqworker
- ObjectAccessResponse - Class in io.deephaven.proto.pqworker
-
Protobuf type
io.deephaven.proto.pqworker.ObjectAccessResponse
- ObjectAccessResponse.Builder - Class in io.deephaven.proto.pqworker
-
Protobuf type
io.deephaven.proto.pqworker.ObjectAccessResponse
- ObjectAccessResponseOrBuilder - Interface in io.deephaven.proto.pqworker
- ObjectCodecAdapter<TYPE> - Class in io.deephaven.enterprise.compatibility
-
This class adapts the DHE
ObjectCodec
to the DHCObjectCodec
. - ObjectCodecAdapter(String) - Constructor for class io.deephaven.enterprise.compatibility.ObjectCodecAdapter
- OBJECTGROUPS_FIELD_NUMBER - Static variable in class io.deephaven.proto.pqworker.ObjectAccessResponse
- ObjectModuleOverride - Interface in io.deephaven.enterprise.dnd.modules
- OBJECTNAMES_FIELD_NUMBER - Static variable in class io.deephaven.proto.pqworker.ObjectAccessRequest
- ObjectRegionFillContext - Class in io.deephaven.enterprise.sources.regioned.impl
-
A
ChunkSource.GetContext
for Deephaven FormatColumnRegionObject
implementations containingChunkSource.GetContext
s for the offset, dictionary and bitmask regions. - ObjectRegionFillContext(int, int) - Constructor for class io.deephaven.enterprise.sources.regioned.impl.ObjectRegionFillContext
- ObjectServiceGrpcBinding - Class in io.deephaven.enterprise.dnd.modules
- ObjectServiceGrpcBinding(AuthorizationProvider, ObjectServiceGrpcImpl, SessionService) - Constructor for class io.deephaven.enterprise.dnd.modules.ObjectServiceGrpcBinding
- of(FilterGenerator) - Static method in interface io.deephaven.enterprise.acl.AclFilterGenerator
-
Create an
AclFilterGenerator
from an enterpriseFilterGenerator
. - of(String, TableLocationKey) - Static method in interface io.deephaven.enterprise.locations.FixedPartitionedEnterpriseTableLocationKey
-
Create a
TableLocationKey
from its enterprise equivalent and the partitioning column key. - of(Table) - Static method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
-
Create an adapter for presenting a Community
Table
as an EnterpriseTable
. - ofHistorical(String, String, TableType) - Static method in interface io.deephaven.enterprise.locations.EnterpriseTableKey
-
Create an
EnterpriseTableKey
for a historical table. - ofTicking(String, String, TableType) - Static method in interface io.deephaven.enterprise.locations.EnterpriseTableKey
-
Create an
EnterpriseTableKey
for an Intraday table. - onCallStartedAutoCompleteStream(AuthContext) - Method in class io.deephaven.enterprise.dnd.authentication.AdminOnlyConsoleAuthWiring
- onComplete(TableDataRequest) - Method in class io.deephaven.enterprise.locations.remote.RemoteDeephavenTableLocation
- OnDiskDeephavenColumnLocation - Class in io.deephaven.enterprise.locations.local.deephaven
-
The
ColumnLocation
implementation forOnDiskDeephavenTableLocation
locations. - OnDiskDeephavenColumnLocation(OnDiskDeephavenTableLocation, String) - Constructor for class io.deephaven.enterprise.locations.local.deephaven.OnDiskDeephavenColumnLocation
-
Construct a new LocalColumnLocation for the specified LocalTableLocation and column name.
- OnDiskDeephavenTableLocation - Class in io.deephaven.enterprise.locations.local.deephaven
-
A
TableLocation
for reading Deephaven format tables from a local filesystem. - OnDiskDeephavenTableLocation(EnterpriseTableKey, EnterpriseTableLocationKey, File, boolean, TableDataRefreshService) - Constructor for class io.deephaven.enterprise.locations.local.deephaven.OnDiskDeephavenTableLocation
- OnDiskTableDataService - Class in io.deephaven.enterprise.tabledataservice
-
A
TableDataService
implementation that expects data to be located on a local filesystem. - OnDiskTableDataService(Logger, String, Path, SchemaService, boolean) - Constructor for class io.deephaven.enterprise.tabledataservice.OnDiskTableDataService
-
Construct a
TableDataService
that sources tables from the local filesystem. - onGetObjectAccess(AuthContext, ObjectAccessRequest) - Method in class io.deephaven.enterprise.dnd.authentication.AdminOnlyWorkerAuthWiring
- onGetObjectAccess(AuthContext, ObjectAccessRequest) - Method in interface io.deephaven.enterprise.dnd.authentication.PQWorkerServiceAuthWiring
- onListenForError(AuthContext, ListenErrorRequest) - Method in class io.deephaven.enterprise.dnd.authentication.AdminOnlyWorkerAuthWiring
- onListenForError(AuthContext, ListenErrorRequest) - Method in interface io.deephaven.enterprise.dnd.authentication.PQWorkerServiceAuthWiring
- onMessageReceivedAutoCompleteStream(AuthContext, AutoCompleteRequest) - Method in class io.deephaven.enterprise.dnd.authentication.AdminOnlyConsoleAuthWiring
- onMessageReceivedBindTableToVariable(AuthContext, BindTableToVariableRequest) - Method in class io.deephaven.enterprise.dnd.authentication.AdminOnlyConsoleAuthWiring
- onMessageReceivedCancelAutoComplete(AuthContext, CancelAutoCompleteRequest) - Method in class io.deephaven.enterprise.dnd.authentication.AdminOnlyConsoleAuthWiring
- onMessageReceivedCancelCommand(AuthContext, CancelCommandRequest) - Method in class io.deephaven.enterprise.dnd.authentication.AdminOnlyConsoleAuthWiring
- onMessageReceivedExecuteCommand(AuthContext, ExecuteCommandRequest) - Method in class io.deephaven.enterprise.dnd.authentication.AdminOnlyConsoleAuthWiring
- onMessageReceivedGetConsoleTypes(AuthContext, GetConsoleTypesRequest) - Method in class io.deephaven.enterprise.dnd.authentication.AdminOnlyConsoleAuthWiring
- onMessageReceivedGetHeapInfo(AuthContext, GetHeapInfoRequest) - Method in class io.deephaven.enterprise.dnd.authentication.AdminOnlyConsoleAuthWiring
- onMessageReceivedNewSession(AuthContext, HandshakeRequest) - Method in class io.deephaven.enterprise.dnd.authentication.SessionServiceAuthWiringImpl
- onMessageReceivedNextAutoCompleteStream(AuthContext, AutoCompleteRequest) - Method in class io.deephaven.enterprise.dnd.authentication.AdminOnlyConsoleAuthWiring
- onMessageReceivedOpenAutoCompleteStream(AuthContext, AutoCompleteRequest) - Method in class io.deephaven.enterprise.dnd.authentication.AdminOnlyConsoleAuthWiring
- onMessageReceivedRefreshSessionToken(AuthContext, HandshakeRequest) - Method in class io.deephaven.enterprise.dnd.authentication.SessionServiceAuthWiringImpl
- onMessageReceivedStartConsole(AuthContext, StartConsoleRequest) - Method in class io.deephaven.enterprise.dnd.authentication.AdminOnlyConsoleAuthWiring
- onMessageReceivedSubscribeToLogs(AuthContext, LogSubscriptionRequest) - Method in class io.deephaven.enterprise.dnd.authentication.AdminOnlyConsoleAuthWiring
- onRejection(TableDataRequest, String, TableDataProtocol.RequestRejectionType) - Method in class io.deephaven.enterprise.locations.remote.RemoteDeephavenTableLocation
- onSessionCount(int, long) - Method in interface io.deephaven.enterprise.dnd.modules.DndSessionListenerModule.DndSessionCountListener
- onSessionCreate(SessionState) - Method in class io.deephaven.enterprise.dnd.modules.DndSessionListenerModule.SessionMonitor
- onShutdown() - Method in class io.deephaven.enterprise.dnd.EnterpriseProcessEnvironmentCommunityAdapter
- onStartup() - Method in class io.deephaven.enterprise.dnd.EnterpriseProcessEnvironmentCommunityAdapter
- onTableLocationKeyAdded(TableLocationKey) - Method in class io.deephaven.enterprise.locations.remote.RemoteDeephavenTableLocation
- onTableLocationKeyRemoved(TableLocationKey) - Method in class io.deephaven.enterprise.locations.remote.RemoteDeephavenTableLocation
- onTableLocationState(TableLocationState) - Method in class io.deephaven.enterprise.locations.remote.RemoteDeephavenTableLocation
- onTerminate() - Method in interface io.deephaven.enterprise.dnd.modules.DndSessionListenerModule.DndSessionCountListener
- onTimeout(TableDataRequest) - Method in class io.deephaven.enterprise.locations.remote.RemoteDeephavenTableLocation
- openConfiguration(String) - Method in class io.deephaven.enterprise.test.PropertyInputStreamLoaderResourcesOnly
- Options() - Constructor for class io.deephaven.enterprise.database.SystemTableLogger.Options
- Options() - Constructor for class io.deephaven.enterprise.kafkawriter.KafkaTableWriter.Options
- OrderedKeysToRowSequenceAdapter - Class in io.deephaven.enterprise.compatibility.rowset
-
A Mutable adapter for converting
OrderedKeys
into aRowSequence
. - OrderedKeysToRowSequenceAdapter() - Constructor for class io.deephaven.enterprise.compatibility.rowset.OrderedKeysToRowSequenceAdapter
- OrderedKeysToRowSequenceAdapter(OrderedKeys) - Constructor for class io.deephaven.enterprise.compatibility.rowset.OrderedKeysToRowSequenceAdapter
- OrderedKeysToRowSequenceIteratorAdapter - Class in io.deephaven.enterprise.compatibility.rowset
- OrderedKeysToRowSequenceIteratorAdapter(OrderedKeys.Iterator) - Constructor for class io.deephaven.enterprise.compatibility.rowset.OrderedKeysToRowSequenceIteratorAdapter
- owner(String) - Method in class io.deephaven.enterprise.dnd.query.util.perf.PerformanceOverview
-
Set the expected owner of the desired query
P
- PARQUET_EXTENDED_PREFIX - Static variable in class io.deephaven.enterprise.tabledataservice.OnDiskTableDataService
- PARQUET_FLAT_TYPE - Static variable in class io.deephaven.enterprise.tabledataservice.OnDiskTableDataService
- PARQUET_KV_TYPE - Static variable in class io.deephaven.enterprise.tabledataservice.OnDiskTableDataService
- PARQUET_METADATA_TYPE - Static variable in class io.deephaven.enterprise.tabledataservice.OnDiskTableDataService
- parseDelimitedFrom(InputStream) - Static method in class io.deephaven.proto.pqworker.ListenErrorRequest
- parseDelimitedFrom(InputStream) - Static method in class io.deephaven.proto.pqworker.ListenErrorResponse
- parseDelimitedFrom(InputStream) - Static method in class io.deephaven.proto.pqworker.ObjectAccessRequest
- parseDelimitedFrom(InputStream) - Static method in class io.deephaven.proto.pqworker.ObjectAccessResponse
- parseDelimitedFrom(InputStream) - Static method in class io.deephaven.proto.pqworker.StringList
- parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class io.deephaven.proto.pqworker.ListenErrorRequest
- parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class io.deephaven.proto.pqworker.ListenErrorResponse
- parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class io.deephaven.proto.pqworker.ObjectAccessRequest
- parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class io.deephaven.proto.pqworker.ObjectAccessResponse
- parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class io.deephaven.proto.pqworker.StringList
- parseFrom(byte[]) - Static method in class io.deephaven.proto.pqworker.ListenErrorRequest
- parseFrom(byte[]) - Static method in class io.deephaven.proto.pqworker.ListenErrorResponse
- parseFrom(byte[]) - Static method in class io.deephaven.proto.pqworker.ObjectAccessRequest
- parseFrom(byte[]) - Static method in class io.deephaven.proto.pqworker.ObjectAccessResponse
- parseFrom(byte[]) - Static method in class io.deephaven.proto.pqworker.StringList
- parseFrom(byte[], ExtensionRegistryLite) - Static method in class io.deephaven.proto.pqworker.ListenErrorRequest
- parseFrom(byte[], ExtensionRegistryLite) - Static method in class io.deephaven.proto.pqworker.ListenErrorResponse
- parseFrom(byte[], ExtensionRegistryLite) - Static method in class io.deephaven.proto.pqworker.ObjectAccessRequest
- parseFrom(byte[], ExtensionRegistryLite) - Static method in class io.deephaven.proto.pqworker.ObjectAccessResponse
- parseFrom(byte[], ExtensionRegistryLite) - Static method in class io.deephaven.proto.pqworker.StringList
- parseFrom(ByteString) - Static method in class io.deephaven.proto.pqworker.ListenErrorRequest
- parseFrom(ByteString) - Static method in class io.deephaven.proto.pqworker.ListenErrorResponse
- parseFrom(ByteString) - Static method in class io.deephaven.proto.pqworker.ObjectAccessRequest
- parseFrom(ByteString) - Static method in class io.deephaven.proto.pqworker.ObjectAccessResponse
- parseFrom(ByteString) - Static method in class io.deephaven.proto.pqworker.StringList
- parseFrom(ByteString, ExtensionRegistryLite) - Static method in class io.deephaven.proto.pqworker.ListenErrorRequest
- parseFrom(ByteString, ExtensionRegistryLite) - Static method in class io.deephaven.proto.pqworker.ListenErrorResponse
- parseFrom(ByteString, ExtensionRegistryLite) - Static method in class io.deephaven.proto.pqworker.ObjectAccessRequest
- parseFrom(ByteString, ExtensionRegistryLite) - Static method in class io.deephaven.proto.pqworker.ObjectAccessResponse
- parseFrom(ByteString, ExtensionRegistryLite) - Static method in class io.deephaven.proto.pqworker.StringList
- parseFrom(CodedInputStream) - Static method in class io.deephaven.proto.pqworker.ListenErrorRequest
- parseFrom(CodedInputStream) - Static method in class io.deephaven.proto.pqworker.ListenErrorResponse
- parseFrom(CodedInputStream) - Static method in class io.deephaven.proto.pqworker.ObjectAccessRequest
- parseFrom(CodedInputStream) - Static method in class io.deephaven.proto.pqworker.ObjectAccessResponse
- parseFrom(CodedInputStream) - Static method in class io.deephaven.proto.pqworker.StringList
- parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class io.deephaven.proto.pqworker.ListenErrorRequest
- parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class io.deephaven.proto.pqworker.ListenErrorResponse
- parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class io.deephaven.proto.pqworker.ObjectAccessRequest
- parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class io.deephaven.proto.pqworker.ObjectAccessResponse
- parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class io.deephaven.proto.pqworker.StringList
- parseFrom(InputStream) - Static method in class io.deephaven.proto.pqworker.ListenErrorRequest
- parseFrom(InputStream) - Static method in class io.deephaven.proto.pqworker.ListenErrorResponse
- parseFrom(InputStream) - Static method in class io.deephaven.proto.pqworker.ObjectAccessRequest
- parseFrom(InputStream) - Static method in class io.deephaven.proto.pqworker.ObjectAccessResponse
- parseFrom(InputStream) - Static method in class io.deephaven.proto.pqworker.StringList
- parseFrom(InputStream, ExtensionRegistryLite) - Static method in class io.deephaven.proto.pqworker.ListenErrorRequest
- parseFrom(InputStream, ExtensionRegistryLite) - Static method in class io.deephaven.proto.pqworker.ListenErrorResponse
- parseFrom(InputStream, ExtensionRegistryLite) - Static method in class io.deephaven.proto.pqworker.ObjectAccessRequest
- parseFrom(InputStream, ExtensionRegistryLite) - Static method in class io.deephaven.proto.pqworker.ObjectAccessResponse
- parseFrom(InputStream, ExtensionRegistryLite) - Static method in class io.deephaven.proto.pqworker.StringList
- parseFrom(ByteBuffer) - Static method in class io.deephaven.proto.pqworker.ListenErrorRequest
- parseFrom(ByteBuffer) - Static method in class io.deephaven.proto.pqworker.ListenErrorResponse
- parseFrom(ByteBuffer) - Static method in class io.deephaven.proto.pqworker.ObjectAccessRequest
- parseFrom(ByteBuffer) - Static method in class io.deephaven.proto.pqworker.ObjectAccessResponse
- parseFrom(ByteBuffer) - Static method in class io.deephaven.proto.pqworker.StringList
- parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class io.deephaven.proto.pqworker.ListenErrorRequest
- parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class io.deephaven.proto.pqworker.ListenErrorResponse
- parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class io.deephaven.proto.pqworker.ObjectAccessRequest
- parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class io.deephaven.proto.pqworker.ObjectAccessResponse
- parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class io.deephaven.proto.pqworker.StringList
- parser() - Static method in class io.deephaven.proto.pqworker.ListenErrorRequest
- parser() - Static method in class io.deephaven.proto.pqworker.ListenErrorResponse
- parser() - Static method in class io.deephaven.proto.pqworker.ObjectAccessRequest
- parser() - Static method in class io.deephaven.proto.pqworker.ObjectAccessResponse
- parser() - Static method in class io.deephaven.proto.pqworker.StringList
- partialProcessInfoId(String) - Method in class io.deephaven.enterprise.dnd.query.util.perf.PerformanceOverview
-
Set a part of the ProcessInfoId.
- partitionFilter(IntPredicate) - Method in class io.deephaven.enterprise.kafkawriter.KafkaTableWriter.Options
-
Set a filter to select which partitions to ingest.
- partitionFormatter - Static variable in class io.deephaven.enterprise.dnd.logger.engine.impl.EngineTableLoggerDndImpl
- partitionToInitialOffsetFallback(IntToLongFunction) - Method in class io.deephaven.enterprise.kafkawriter.KafkaTableWriter.Options
-
Set a function to determine what offset to consume from when other methods fail.
- partitionValue(String) - Method in class io.deephaven.enterprise.kafkawriter.KafkaTableWriter.Options
-
The fixed column partition value to ingest into.
- password(String, String) - Method in class io.deephaven.enterprise.dnd.client.DndSessionFactoryBarrage
-
Authenticate with the server using a username and password
- peekNextKey() - Method in class io.deephaven.enterprise.compatibility.rowset.OrderedKeysToRowSequenceIteratorAdapter
- PelInfo(String, String, String, String, String) - Constructor for class io.deephaven.enterprise.dnd.SimpleProcessEventLogger.PelInfo
- PerformanceOverview - Class in io.deephaven.enterprise.dnd.query.util.perf
-
Builder class that accepts inputs as setters and uses said inputs to get a map of performance analysis tables and plots.
- PerformanceOverview() - Constructor for class io.deephaven.enterprise.dnd.query.util.perf.PerformanceOverview
- PerformanceOverview.PerformanceOverviewTools - Class in io.deephaven.enterprise.dnd.query.util.perf
- PerformanceOverviewTools() - Constructor for class io.deephaven.enterprise.dnd.query.util.perf.PerformanceOverview.PerformanceOverviewTools
- permissionFilterProvider() - Static method in class io.deephaven.enterprise.acl.impl.AclHelper
-
Get the
PermissionFilterProvider
to use for Enterprise integration - persistentQuery(long) - Method in class io.deephaven.enterprise.dnd.client.DndSessionFactoryBarrage
-
Create a new
DndSession
to the specified Persistent Query by serial. - persistentQuery(String) - Method in class io.deephaven.enterprise.dnd.client.DndSessionFactoryBarrage
-
Create a new
DndSession
to the specified Persistent Query by name. - PFPBackedTestGroupProvider - Class in io.deephaven.enterprise.test
-
A simple test adapter for using an
InMemoryPermissionFilterProvider
as anIrisGroupProvider
for testing. - PFPBackedTestGroupProvider(InMemoryPermissionFilterProvider) - Constructor for class io.deephaven.enterprise.test.PFPBackedTestGroupProvider
- pqName(String) - Method in class io.deephaven.enterprise.dnd.query.util.perf.PerformanceOverview
-
Set the PQ name of the desired worker.
- PQUriResolver - Class in io.deephaven.enterprise.dnd.uri
-
A
UriResolver
specifically for resolving requests for tables from persistent queries by serial or name. - PQUriResolver(BarrageSessionFactoryBuilder, ScheduledExecutorService, BufferAllocator, SSLConfig, ClientChannelFactory, ControllerClientFactory) - Constructor for class io.deephaven.enterprise.dnd.uri.PQUriResolver
- Pqworker - Class in io.deephaven.proto.pqworker
- PQWorkerApiGrpc - Class in io.deephaven.proto.pqworker.grpc
- PQWorkerApiGrpc.PQWorkerApiBlockingStub - Class in io.deephaven.proto.pqworker.grpc
- PQWorkerApiGrpc.PQWorkerApiFutureStub - Class in io.deephaven.proto.pqworker.grpc
- PQWorkerApiGrpc.PQWorkerApiImplBase - Class in io.deephaven.proto.pqworker.grpc
- PQWorkerApiGrpc.PQWorkerApiStub - Class in io.deephaven.proto.pqworker.grpc
- PQWorkerApiImplBase() - Constructor for class io.deephaven.proto.pqworker.grpc.PQWorkerApiGrpc.PQWorkerApiImplBase
- PqworkerService - Class in io.deephaven.proto.pqworker.grpc
- PQWorkerServiceAuthWiring - Interface in io.deephaven.enterprise.dnd.authentication
- PQWorkerServiceGrpcImpl - Class in io.deephaven.enterprise.dnd.service.pqworker
- PQWorkerServiceGrpcImpl(Provider<ScriptSession>, Set<TicketTransformer>) - Constructor for class io.deephaven.enterprise.dnd.service.pqworker.PQWorkerServiceGrpcImpl
- PQWorkerServiceModule - Interface in io.deephaven.enterprise.dnd.modules
- preemptiveSnapshotTable(long) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- preemptiveUpdatesTable(long) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- priority() - Method in class io.deephaven.enterprise.acl.transform.GenericObjectTransformer
- priority() - Method in class io.deephaven.enterprise.acl.transform.TableTicketTransformer
- priority() - Method in interface io.deephaven.enterprise.dnd.authentication.transform.TicketTransformer
-
The relative priority of the transformer.
- priority() - Method in class io.deephaven.enterprise.dnd.query.util.perf.PerformanceOverview.PerformanceOverviewTools
- privateKey(String) - Method in class io.deephaven.enterprise.dnd.client.DndSessionFactoryBarrage
-
Authenticate to the server using a private key file.
- ProcessEventLogAppender - Class in io.deephaven.enterprise.dnd
- ProcessEventLogAppender() - Constructor for class io.deephaven.enterprise.dnd.ProcessEventLogAppender
- processInfoId(String) - Method in class io.deephaven.enterprise.dnd.query.util.perf.PerformanceOverview
-
Set the ProcessInfoId to narrow the performance data.
- ProcessInfoId - Class in io.deephaven.enterprise.dnd
-
Static accessor for this worker's process information ID.
- processInfoLogLogger() - Method in class io.deephaven.enterprise.dnd.logger.engine.impl.EngineTableLoggersFactoryDndImpl
- processMetricsLogLogger() - Method in class io.deephaven.enterprise.dnd.logger.engine.impl.EngineTableLoggersFactoryDndImpl
- PropertyInputStreamLoaderResourcesOnly - Class in io.deephaven.enterprise.test
-
A
PropertyInputStreamLoader
that loads the property input stream from resources only. - PropertyInputStreamLoaderResourcesOnly() - Constructor for class io.deephaven.enterprise.test.PropertyInputStreamLoaderResourcesOnly
- ProtocolDriverFactory - Interface in io.deephaven.enterprise.tabledataservice
-
An interface for creating
TableDataProtocolDriver
instances for use withRemoteTableDataService
andRemoteTableLocationImpl
- provideAppStateListener(ApplicationServiceGrpcImpl) - Static method in class io.deephaven.enterprise.dnd.modules.EnterpriseApiServerModule
- provideDatabase(DatabaseImpl) - Static method in interface io.deephaven.enterprise.dnd.modules.DatabaseModule
- provideGroovySession(UpdateGraph, ObjectTypeLookup, ScriptSession.Listener, GroovyDeephavenSession.RunScripts, Database) - Static method in interface io.deephaven.enterprise.dnd.modules.GroovyConsoleSessionWithDatabaseModule
- provideObjectTransformer(GroupProvider) - Static method in interface io.deephaven.enterprise.dnd.modules.EnterpriseAuthModule
- providePythonSession(UpdateGraph, ObjectTypeLookup, ScriptSession.Listener, PythonEvaluatorJpy, Database, String) - Static method in interface io.deephaven.enterprise.dnd.modules.PythonConsoleSessionWithDatabaseModule
- providesAclprovider(UserContext, PermissionFilterProvider) - Static method in interface io.deephaven.enterprise.dnd.modules.EnterpriseAuthModule
- providesAppStateFactory() - Static method in class io.deephaven.enterprise.dnd.modules.EnterpriseApiServerModule
- providesAuth(DheAuthorizationProvider) - Static method in interface io.deephaven.enterprise.dnd.modules.EnterpriseAuthModule
- provideScheduler(UpdateGraph, int) - Static method in class io.deephaven.enterprise.dnd.modules.EnterpriseApiServerModule
- provideScriptSession(GroovyDeephavenSession) - Static method in interface io.deephaven.enterprise.dnd.modules.GroovyConsoleSessionWithDatabaseModule
- provideScriptSession(PythonDeephavenSession) - Static method in interface io.deephaven.enterprise.dnd.modules.PythonConsoleSessionWithDatabaseModule
- provideScriptSession(Map<String, Provider<ScriptSession>>) - Method in class io.deephaven.enterprise.dnd.modules.EnterpriseApiServerModule
- providesDatabaseTicketResolver(DatabaseTicketResolver) - Method in interface io.deephaven.enterprise.dnd.modules.DatabaseModule
- providesDheAuthProvider(UserContext, Set<String>, Set<String>, Set<TicketTransformer>) - Static method in interface io.deephaven.enterprise.dnd.modules.EnterpriseAuthModule
- providesDnDAuth(DheAuthorizationProvider) - Static method in interface io.deephaven.enterprise.dnd.modules.EnterpriseAuthModule
- provideSessionListener(int, Long, PrintStream, DispatcherClient, Set<DndSessionListenerModule.DndSessionCountListener>) - Static method in interface io.deephaven.enterprise.dnd.modules.DndSessionListenerModule
- providesGroupProvider(PermissionFilterProvider) - Static method in interface io.deephaven.enterprise.dnd.modules.EnterpriseAuthModule
- providesImpl(UserContext, PermissionFilterProvider, GroupProvider, SourceAclProvider, AuditEventLogger) - Static method in interface io.deephaven.enterprise.dnd.modules.DatabaseModule
- providesListener(ApplicationServiceGrpcImpl, Set<ScriptSession.Listener>) - Static method in class io.deephaven.enterprise.dnd.modules.EnterpriseApiServerModule
- providesPermissionFilterProvider(UserContext) - Static method in interface io.deephaven.enterprise.dnd.modules.EnterpriseAuthModule
- providesPQUriResolver(PQUriResolver) - Method in interface io.deephaven.enterprise.dnd.modules.URIModule
- providesPQWorkerService(DnDAuthorizationProvider, Provider<ScriptSession>, Set<TicketTransformer>) - Static method in interface io.deephaven.enterprise.dnd.modules.PQWorkerServiceModule
- providesSupport(DatabaseImpl) - Static method in interface io.deephaven.enterprise.dnd.modules.DatabaseModule
- provideTableTransformer(AclSupport) - Static method in interface io.deephaven.enterprise.dnd.modules.EnterpriseAuthModule
- provideUpdateGraph() - Static method in class io.deephaven.enterprise.dnd.modules.EnterpriseApiServerModule
- provideUriConfig(boolean) - Static method in interface io.deephaven.enterprise.dnd.modules.SSLConfigModule
- publish(SessionState, ByteBuffer, String, Runnable) - Method in class io.deephaven.enterprise.dnd.service.ticket.DatabaseTicketResolver
- publish(SessionState, Flight.FlightDescriptor, String, Runnable) - Method in class io.deephaven.enterprise.dnd.service.ticket.DatabaseTicketResolver
- PushSessionChangeListener - Class in io.deephaven.enterprise.dnd
-
The PushSessionChangeListener creates a ScriptSession.Listener when enabled that tracks changes to the query scope and sends them to the Controller to update a query state.
- PushSessionChangeListener() - Constructor for class io.deephaven.enterprise.dnd.PushSessionChangeListener
- pushSessionChanges(boolean) - Method in interface io.deephaven.enterprise.dnd.EnterpriseJettyComponent.Builder
-
Set if the worker should push session changes to the controller.
- putAllObjectGroups(Map<String, StringList>) - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse.Builder
-
map<string, .io.deephaven.proto.pqworker.StringList> objectGroups = 1;
- putObjectGroups(String, StringList) - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse.Builder
-
map<string, .io.deephaven.proto.pqworker.StringList> objectGroups = 1;
- PythonConsoleSessionWithDatabaseModule - Interface in io.deephaven.enterprise.dnd.modules
Q
- queryDeletionHook(Boolean, Long, ControllerClientFactory) - Static method in class io.deephaven.enterprise.dnd.QueryDeletionHook
- QueryDeletionHook - Class in io.deephaven.enterprise.dnd
-
A hook that is called from the session monitor to delete our persistent query when we are complete.
- QueryDeletionHook() - Constructor for class io.deephaven.enterprise.dnd.QueryDeletionHook
- queryOperationPerformanceLogLogger() - Method in class io.deephaven.enterprise.dnd.logger.engine.impl.EngineTableLoggersFactoryDndImpl
- queryPerformanceLogLogger() - Method in class io.deephaven.enterprise.dnd.logger.engine.impl.EngineTableLoggersFactoryDndImpl
R
- raj(Table, MatchPair[], MatchPair[], Table.AsOfMatchRule) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- RangeFilterAdapter - Class in io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.select
- RangeFilterAdapter() - Constructor for class io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.select.RangeFilterAdapter
- readTable(String) - Static method in class io.deephaven.enterprise.table.EnterpriseTableTools
-
Read the Deephaven format table at the specified path.
- readTable(File) - Static method in class io.deephaven.enterprise.table.EnterpriseTableTools
-
Read the Deephaven format table at the specified path.
- RecomputeListenerAdapter - Class in io.deephaven.enterprise.compatibility.filter
-
An adapter class to map a Community
WhereFilter.RecomputeListener
onto the EnterpriseSelectFilter.RecomputeListener
. - RecomputeListenerAdapter(WhereFilter.RecomputeListener) - Constructor for class io.deephaven.enterprise.compatibility.filter.RecomputeListenerAdapter
- refresh() - Method in class io.deephaven.enterprise.locations.local.deephaven.OnDiskDeephavenTableLocation
- refresh() - Method in class io.deephaven.enterprise.locations.local.SnapshotBackedTableLocation
- refresh() - Method in class io.deephaven.enterprise.locations.remote.RemoteDeephavenTableLocation
- refresh() - Method in class io.deephaven.enterprise.tabledataservice.MarkingPollingLocationProvider
- RegionUtilities - Class in io.deephaven.enterprise.sources.regioned.impl
-
Minor utility methods used by column region and
RegionedColumnSource
implementations. - registerAllExtensions(ExtensionRegistry) - Static method in class io.deephaven.proto.pqworker.grpc.PqworkerService
- registerAllExtensions(ExtensionRegistry) - Static method in class io.deephaven.proto.pqworker.Pqworker
- registerAllExtensions(ExtensionRegistryLite) - Static method in class io.deephaven.proto.pqworker.grpc.PqworkerService
- registerAllExtensions(ExtensionRegistryLite) - Static method in class io.deephaven.proto.pqworker.Pqworker
- reinterpret(Class<ALTERNATE_DATA_TYPE>) - Method in class io.deephaven.enterprise.compatibility.filter.ColumnSourceAdapterForFilter
- releaseCachedResources() - Method in class io.deephaven.enterprise.sources.regioned.impl.BufferedColumnRegionBase
- releaseCachedResources() - Method in class io.deephaven.enterprise.sources.regioned.impl.ColumnRegionObjectCached
- releaseCachedResources() - Method in class io.deephaven.enterprise.sources.regioned.impl.ColumnRegionObjectCodecFixed
- releaseCachedResources() - Method in class io.deephaven.enterprise.sources.regioned.impl.ColumnRegionObjectCodecVariable
- releaseCachedResources() - Method in class io.deephaven.enterprise.sources.regioned.impl.ColumnRegionObjectWithDictionary
- releaseCachedResources() - Method in class io.deephaven.enterprise.sources.regioned.impl.ColumnRegionStringSet
- RELOCATED_PACKAGES - Static variable in class io.deephaven.enterprise.compatibility.shadow.ShadowCompatibility
- RemoteDeephavenTableLocation - Class in io.deephaven.enterprise.locations.remote
-
A
TableLocation
implementation for remote table subscriptions discovered by a io.deephaven.enterprise.tabledataservice.RemoteTableDataService. - RemoteDeephavenTableLocation(TableDataProtocolDriver, EnterpriseTableKey, EnterpriseTableLocationKey, TableDefinition) - Constructor for class io.deephaven.enterprise.locations.remote.RemoteDeephavenTableLocation
-
Create a remote table location using the specified
protocol driver
for acquiring table data. - RemoteTableDataService - Class in io.deephaven.enterprise.tabledataservice
-
A
TableDataService
implementation that uses Enterprise'sTableDataProtocol
to locate tables. - RemoteTableDataService(SchemaService, TableDataProtocolDriver, String) - Constructor for class io.deephaven.enterprise.tabledataservice.RemoteTableDataService
-
Construct a new remote table data service, ready to be connected.
- removeObjectGroups(String) - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse.Builder
-
map<string, .io.deephaven.proto.pqworker.StringList> objectGroups = 1;
- removeObserver(ControllerClientGrpc.Observer) - Method in class io.deephaven.enterprise.dnd.controller.client.ControllerClientGrpc
- removeQueryConfiguration(PersistentQueryConfigMessage) - Method in class io.deephaven.enterprise.dnd.controller.client.ControllerClientGrpc
-
Removes a configuration from the controller's hash table.
- removeQueryConfigurationBySerial(long) - Method in class io.deephaven.enterprise.dnd.controller.client.ControllerClientGrpc
-
Removes a configuration from the controller's hash table by serial ID.
- removeTable(LiveTable) - Method in class io.deephaven.enterprise.compatibility.LiveTableRegistrarAdapter
- renameColumns(MatchPair...) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- requestRecompute() - Method in class io.deephaven.enterprise.compatibility.filter.RecomputeListenerAdapter
- requestRecomputeMatched() - Method in class io.deephaven.enterprise.compatibility.filter.RecomputeListenerAdapter
- requestRecomputeUnmatched() - Method in class io.deephaven.enterprise.compatibility.filter.RecomputeListenerAdapter
- requestRefresh(LiveTable) - Method in class io.deephaven.enterprise.compatibility.LiveTableRegistrarAdapter
- requireAclsToExport() - Static method in class io.deephaven.enterprise.acl.impl.AclHelper
-
If any ACLs have been applied, then any exported table must have ACLs applied.
- resolve(SessionState, ByteBuffer, String) - Method in class io.deephaven.enterprise.dnd.service.ticket.DatabaseTicketResolver
- resolve(SessionState, Flight.FlightDescriptor, String) - Method in class io.deephaven.enterprise.dnd.service.ticket.DatabaseTicketResolver
- resolve(URI) - Method in class io.deephaven.enterprise.dnd.uri.PQUriResolver
- resolveClassDescriptorOverride(ObjectStreamClass) - Method in class io.deephaven.enterprise.compatibility.shadow.ShadowingObjectInputStream
- resolveClassDescriptorOverride(ObjectStreamClass) - Method in class io.deephaven.enterprise.compatibility.shadow.ShadowingPersistentInputStream
- restartQueries(List<PersistentQueryConfigMessage>) - Method in class io.deephaven.enterprise.dnd.controller.client.ControllerClientGrpc
-
Restarts one or more persistent queries.
- restartQueriesBySerial(long[]) - Method in class io.deephaven.enterprise.dnd.controller.client.ControllerClientGrpc
-
Restarts one or more persistent queries.
- restartQueriesBySerial(List<Long>) - Method in class io.deephaven.enterprise.dnd.controller.client.ControllerClientGrpc
-
Restarts one or more persistent queries.
- restartQuery(PersistentQueryConfigMessage) - Method in class io.deephaven.enterprise.dnd.controller.client.ControllerClientGrpc
-
Restart a persistent query.
- restrictSortTo(String...) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- resumeFrom(UnaryOperator<String>) - Method in class io.deephaven.enterprise.kafkawriter.KafkaTableWriter.Options
-
Optional function that determines a prior column partition to read a size record from.
- reverse() - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- ReversibleCache - Class in io.deephaven.enterprise.sources.regioned.impl
-
An
ArrayBackedOffsetLookupCache
that allows for forward and backwards lookups of values. - ReversibleCache(OffsetLookup<String, ChunkSource.FillContext>, FillContextMaker) - Constructor for class io.deephaven.enterprise.sources.regioned.impl.ReversibleCache
- rget(int, String) - Method in class io.deephaven.enterprise.sources.regioned.impl.ReversibleCache
- rollup(ComboAggregateFactory, boolean, SelectColumn...) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- rowAcl(String, AclFilterGenerator) - Method in interface io.deephaven.enterprise.acl.EdgeAclProvider.Builder
-
Add a Row ACL for the specified group to the table.
- RowSetCompatibility - Class in io.deephaven.enterprise.compatibility.rowset
- RowSetCompatibility() - Constructor for class io.deephaven.enterprise.compatibility.rowset.RowSetCompatibility
- run() - Method in class io.deephaven.enterprise.compatibility.NotificationAdapter
- runDhcServer(Configuration, PrintStream, PrintStream, UserContext, int, DispatcherClient, Future<Boolean>, AuditEventLogger, WorkerDetails, CreationJsonParser, String, Logger) - Static method in class io.deephaven.enterprise.dnd.Main
- runDispatcherClient(PrintStream, PrintStream, String) - Static method in class io.deephaven.enterprise.dnd.Main
S
- schemes() - Method in class io.deephaven.enterprise.dnd.uri.PQUriResolver
- scopeTable(String) - Static method in class io.deephaven.enterprise.dnd.client.DndSession
-
Create a
TableSpec
based on a table from the server query scope. - select(SelectColumn...) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- selectDistinct(SelectColumn...) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- serverStateLogLogger() - Method in class io.deephaven.enterprise.dnd.logger.engine.impl.EngineTableLoggersFactoryDndImpl
- SERVICE_NAME - Static variable in class io.deephaven.proto.pqworker.grpc.PQWorkerApiGrpc
- session() - Method in class io.deephaven.enterprise.dnd.client.DndSession
-
Get the underlying
SessionImpl
- sessionImpl - Variable in class io.deephaven.enterprise.dnd.client.DndSession
- SessionServiceAuthWiringImpl - Class in io.deephaven.enterprise.dnd.authentication
-
This auth wiring explicitly denies the newSession and refreshSession calls as they are deprecated on the upstream
- SessionServiceAuthWiringImpl() - Constructor for class io.deephaven.enterprise.dnd.authentication.SessionServiceAuthWiringImpl
- sessionTimeoutMillis(Long) - Method in interface io.deephaven.enterprise.dnd.EnterpriseJettyComponent.Builder
-
How long is the session timeout grace period.
- setAclsApplied() - Static method in class io.deephaven.enterprise.acl.impl.AclHelper
-
Note that ACLs have been applied and our return policy has changed.
- setAdminGroups(Set<String>) - Static method in class io.deephaven.enterprise.dnd.authentication.DheAuthenticationHandler
- setAttribute(String, Object) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- setAutomatedFilter(boolean) - Method in class io.deephaven.enterprise.compatibility.filter.EnterpriseFilterAdapter
- setCatalog(DatabaseCatalog) - Method in class io.deephaven.enterprise.database.impl.DatabaseImpl
- setClassFinderLogic() - Static method in class io.deephaven.enterprise.compatibility.shadow.ShadowCompatibility
-
Injects logic into DHE ClassFinder to remap to fully qualified shadow class names.
- setColumnRenderers(ColumnRenderersBuilder) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- setDatabaseWrapper(Database) - Static method in class io.deephaven.enterprise.acl.impl.AclHelper
-
Set the Enterprise Database to use for integrating with Enterprise classes
- setDelegate(OrderedKeys) - Method in class io.deephaven.enterprise.compatibility.rowset.OrderedKeysToRowSequenceAdapter
- setEphemeral() - Method in class io.deephaven.enterprise.dnd.controller.client.ControllerClientGrpc
-
Set the channel as ephemeral.
- setField(Descriptors.FieldDescriptor, Object) - Method in class io.deephaven.proto.pqworker.ListenErrorRequest.Builder
- setField(Descriptors.FieldDescriptor, Object) - Method in class io.deephaven.proto.pqworker.ListenErrorResponse.Builder
- setField(Descriptors.FieldDescriptor, Object) - Method in class io.deephaven.proto.pqworker.ObjectAccessRequest.Builder
- setField(Descriptors.FieldDescriptor, Object) - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse.Builder
- setField(Descriptors.FieldDescriptor, Object) - Method in class io.deephaven.proto.pqworker.StringList.Builder
- setGroupingProvider(GroupingProvider) - Method in class io.deephaven.enterprise.compatibility.filter.ColumnSourceAdapterForFilter
- setGroupProvider(GroupProvider) - Static method in class io.deephaven.enterprise.dnd.authentication.DheAuthenticationHandler
- setInstance(SimpleAuditEventLogger) - Static method in class io.deephaven.enterprise.dnd.SimpleAuditEventLogger
-
Set an instance of the SimpleAuditEventLogger.
- setIsRefreshing(boolean) - Method in class io.deephaven.enterprise.compatibility.filter.RecomputeListenerAdapter
- setMaxInboundMessageSize(int) - Method in class io.deephaven.enterprise.dnd.client.DndSessionFactoryBarrage
- setMessage(String) - Method in class io.deephaven.proto.pqworker.ListenErrorResponse.Builder
-
string message = 1;
- setMessageBytes(ByteString) - Method in class io.deephaven.proto.pqworker.ListenErrorResponse.Builder
-
string message = 1;
- setObjectNames(int, String) - Method in class io.deephaven.proto.pqworker.ObjectAccessRequest.Builder
-
repeated string objectNames = 1;
- setOwnerCredentials(UserContext) - Static method in class io.deephaven.enterprise.dnd.authentication.DheAuthenticationHandler
- setPermissionFilterProvider(PermissionFilterProvider) - Static method in class io.deephaven.enterprise.acl.impl.AclHelper
-
Set the Enterprise
PermissionFilterProvider
to be used when calling enterprse acl code - setRecomputeListener(WhereFilter.RecomputeListener) - Method in class io.deephaven.enterprise.compatibility.filter.EnterpriseFilterAdapter
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class io.deephaven.proto.pqworker.ListenErrorRequest.Builder
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class io.deephaven.proto.pqworker.ListenErrorResponse.Builder
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class io.deephaven.proto.pqworker.ObjectAccessRequest.Builder
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse.Builder
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class io.deephaven.proto.pqworker.StringList.Builder
- setShortCauses(String) - Method in class io.deephaven.proto.pqworker.ListenErrorResponse.Builder
-
string shortCauses = 3;
- setShortCausesBytes(ByteString) - Method in class io.deephaven.proto.pqworker.ListenErrorResponse.Builder
-
string shortCauses = 3;
- setSimpleProcessEventLogger(SimpleProcessEventLogger) - Static method in class io.deephaven.enterprise.dnd.ProcessEventLogAppender
- setSnapshot(TableLocationMetadataIndex.LocationSnapshot) - Method in class io.deephaven.enterprise.locations.local.deephaven.OnDiskDeephavenTableLocation
-
Set the location snapshot data from the
metadata index
. - setStackTrace(String) - Method in class io.deephaven.proto.pqworker.ListenErrorResponse.Builder
-
string stackTrace = 2;
- setStackTraceBytes(ByteString) - Method in class io.deephaven.proto.pqworker.ListenErrorResponse.Builder
-
string stackTrace = 2;
- setTotalsTable(TotalsTableBuilder) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- setUnknownFields(UnknownFieldSet) - Method in class io.deephaven.proto.pqworker.ListenErrorRequest.Builder
- setUnknownFields(UnknownFieldSet) - Method in class io.deephaven.proto.pqworker.ListenErrorResponse.Builder
- setUnknownFields(UnknownFieldSet) - Method in class io.deephaven.proto.pqworker.ObjectAccessRequest.Builder
- setUnknownFields(UnknownFieldSet) - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse.Builder
- setUnknownFields(UnknownFieldSet) - Method in class io.deephaven.proto.pqworker.StringList.Builder
- setupAsyncStub(long) - Method in class io.deephaven.enterprise.dnd.controller.client.ControllerClientGrpc
- setValues(int, String) - Method in class io.deephaven.proto.pqworker.StringList.Builder
-
repeated string values = 1;
- setViewerGroups(Set<String>) - Static method in class io.deephaven.enterprise.dnd.authentication.DheAuthenticationHandler
- setWasUncaught(boolean) - Method in class io.deephaven.proto.pqworker.ListenErrorResponse.Builder
-
bool wasUncaught = 4;
- SHADOW_PREFIX - Static variable in class io.deephaven.enterprise.compatibility.shadow.ShadowCompatibility
- ShadowCompatibility - Class in io.deephaven.enterprise.compatibility.shadow
-
This class contains static methods and fields that help in converting serialized non-shadowed enterprise types into their shadowed packages before they're classloaded
- ShadowCompatibility() - Constructor for class io.deephaven.enterprise.compatibility.shadow.ShadowCompatibility
- ShadowingObjectInputStream - Class in io.deephaven.enterprise.compatibility.shadow
-
Enterprise makes extensive use of Java serialization through WObjectOutput/InputStream.
- ShadowingObjectInputStream(InputStream) - Constructor for class io.deephaven.enterprise.compatibility.shadow.ShadowingObjectInputStream
- ShadowingPersistentInputStream - Class in io.deephaven.enterprise.compatibility.shadow
-
Enterprise makes extensive use of Java serialization through WObjectOutput/InputStream.
- ShadowingPersistentInputStream(InputStream, ClassLoader) - Constructor for class io.deephaven.enterprise.compatibility.shadow.ShadowingPersistentInputStream
- ShadowingSerializableDecoder<T> - Class in io.deephaven.enterprise.compatibility.shadow
-
An
ObjectCodec
implementation forSerializable
object that internally uses aShadowingObjectInputStream
to automatically replace detected shadowed classes in the object stream with their shadowed versions. - ShadowingSerializableDecoder(String) - Constructor for class io.deephaven.enterprise.compatibility.shadow.ShadowingSerializableDecoder
- Short - Enum constant in enum class io.deephaven.enterprise.sources.regioned.BufferedType
- SHORTCAUSES_FIELD_NUMBER - Static variable in class io.deephaven.proto.pqworker.ListenErrorResponse
- shutdown() - Method in class io.deephaven.enterprise.dnd.controller.client.ControllerClientGrpc
- SimpleAuditEventLogger - Class in io.deephaven.enterprise.dnd
- SimpleAuditEventLogger(Map<String, Object>, UserContext) - Constructor for class io.deephaven.enterprise.dnd.SimpleAuditEventLogger
- SimpleFilterGenerator - Class in io.deephaven.enterprise.acl.generator
-
An
AclFilterGenerator
that simply applies the specifiedWhereFilter
s in Disjunctive Normal Form - SimpleFilterGenerator(Collection<WhereFilter>...) - Constructor for class io.deephaven.enterprise.acl.generator.SimpleFilterGenerator
- SimpleProcessEventLogger - Class in io.deephaven.enterprise.dnd
- SimpleProcessEventLogger(LogAggregatorServiceBinaryStoreWriterFactory, SimpleProcessEventLogger.PelInfo) - Constructor for class io.deephaven.enterprise.dnd.SimpleProcessEventLogger
- SimpleProcessEventLogger(String, SimpleProcessEventLogger.PelInfo) - Constructor for class io.deephaven.enterprise.dnd.SimpleProcessEventLogger
- SimpleProcessEventLogger.PelInfo - Class in io.deephaven.enterprise.dnd
- size() - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- size() - Method in class io.deephaven.enterprise.compatibility.rowset.OrderedKeysToRowSequenceAdapter
- SIZE_COLUMN_NAME - Static variable in class io.deephaven.enterprise.locations.local.HiveLocationsTableKeyFinder
-
The column of partition sizes, in rows.
- slice(long, long) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- snapshot(Table, boolean, String...) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- SnapshotBackedTableLocation<LOCATION_TYPE extends AbstractTableLocation> - Class in io.deephaven.enterprise.locations.local
-
A
TableLocation
backed by aTableLocationMetadataIndex.TableLocationSnapshot
that does not refresh and tries to avoid creating the actual location until it is truly needed. - SnapshotBackedTableLocation(TableKey, TableLocationKey, boolean, TableLocationMetadataIndex.LocationSnapshot, Supplier<LOCATION_TYPE>) - Constructor for class io.deephaven.enterprise.locations.local.SnapshotBackedTableLocation
- SnapshotBackedTableLocationKey - Class in io.deephaven.enterprise.locations.local
- SnapshotBackedTableLocationKey(File, String, TableLocationMetadataIndex.TableLocationSnapshot) - Constructor for class io.deephaven.enterprise.locations.local.SnapshotBackedTableLocationKey
- SnapshotBackedTableLocationKey(File, Map<String, Comparable<?>>, TableLocationMetadataIndex.LocationSnapshot) - Constructor for class io.deephaven.enterprise.locations.local.SnapshotBackedTableLocationKey
- SnapshotException - Exception in io.deephaven.enterprise.dnd.client.exception
-
An Exception thrown when there is a problem completing a Snapshot
- SnapshotException(String, Throwable) - Constructor for exception io.deephaven.enterprise.dnd.client.exception.SnapshotException
- snapshotHistory(Table) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- snapshotIncremental(Table, boolean, String...) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- snapshotOf(TableSpec) - Method in class io.deephaven.enterprise.dnd.client.DndSessionBarrage
-
Fetch a snapshot of the table from the server.
- sort(SortPair...) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- SourceAclProvider - Interface in io.deephaven.enterprise.acl
-
A provider object for creating row and column ACLs from the data source.
- splitAndLinearizeAndFilters(Filter) - Static method in class io.deephaven.enterprise.acl.impl.AclHelper
-
If a filter is a conjunction of filters (an "and" of filters), decompose it in a list of element filters.
- SSLConfigModule - Interface in io.deephaven.enterprise.dnd.modules
- STACKTRACE_FIELD_NUMBER - Static variable in class io.deephaven.proto.pqworker.ListenErrorResponse
- STANDALONE - Static variable in interface io.deephaven.enterprise.locations.EnterpriseTableKey
- start() - Method in class io.deephaven.enterprise.dnd.ProcessEventLogAppender
- stdBy(SelectColumn...) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- stopQueries(List<PersistentQueryConfigMessage>) - Method in class io.deephaven.enterprise.dnd.controller.client.ControllerClientGrpc
-
Stops one or more persistent queries.
- stopQuery(PersistentQueryConfigMessage) - Method in class io.deephaven.enterprise.dnd.controller.client.ControllerClientGrpc
-
Stops a persistent query.
- stopQueryBySerial(long[]) - Method in class io.deephaven.enterprise.dnd.controller.client.ControllerClientGrpc
-
Stops one or more persistent query by serial id.
- stopQueryBySerial(List<Long>) - Method in class io.deephaven.enterprise.dnd.controller.client.ControllerClientGrpc
- StringList - Class in io.deephaven.proto.pqworker
-
Protobuf type
io.deephaven.proto.pqworker.StringList
- StringList.Builder - Class in io.deephaven.proto.pqworker
-
Protobuf type
io.deephaven.proto.pqworker.StringList
- StringListOrBuilder - Interface in io.deephaven.proto.pqworker
- stringLiteral(Node) - Static method in class io.deephaven.enterprise.dnd.autocomplete.DatabaseAutocompleteDelegate
- subscribeTo(TableSpec) - Method in class io.deephaven.enterprise.dnd.client.DndSessionBarrage
-
Fetch a fully subscribed table from the server.
- subscribeToAll() - Method in class io.deephaven.enterprise.dnd.controller.client.ControllerClientGrpc
-
Subscribe to the complete hash table.
- SubscriptionException - Exception in io.deephaven.enterprise.dnd.client.exception
-
An Exception thrown when there is a problem completing a subscription
- SubscriptionException(String, Throwable) - Constructor for exception io.deephaven.enterprise.dnd.client.exception.SubscriptionException
- sumBy(SelectColumn...) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- supportsDictionaryFormat(RowSet.SearchIterator) - Method in class io.deephaven.enterprise.sources.regioned.impl.ColumnRegionObjectCached
- supportsDictionaryFormat(RowSet.SearchIterator) - Method in class io.deephaven.enterprise.sources.regioned.impl.ColumnRegionObjectWithDictionary
- symbolFileExists() - Method in interface io.deephaven.enterprise.locations.DeephavenFormatColumnLocation
-
Check if the symbol table file exists.
- symbolFileExists() - Method in class io.deephaven.enterprise.locations.local.deephaven.OnDiskDeephavenColumnLocation
- SystemTableLogger - Class in io.deephaven.enterprise.database
-
Utility to log
Table
objects to System tables via the Log Aggregator Server. - SystemTableLogger() - Constructor for class io.deephaven.enterprise.database.SystemTableLogger
- SystemTableLogger.Options - Class in io.deephaven.enterprise.database
-
Options for writing a system table using a logger.
- SystemTableLogger.Options.Builder - Interface in io.deephaven.enterprise.database
- SystemTableLoggerImpl - Class in io.deephaven.enterprise.database.impl
- SystemTableLoggerImpl() - Constructor for class io.deephaven.enterprise.database.impl.SystemTableLoggerImpl
- SystemTableMissingSchemaException - Exception in io.deephaven.enterprise.database
- SystemTableMissingSchemaException(String, String) - Constructor for exception io.deephaven.enterprise.database.SystemTableMissingSchemaException
T
- TABLE_NAME_PATH_INDEX - Static variable in class io.deephaven.enterprise.dnd.service.ticket.DatabaseTicketResolver
- TableAdapterForFilters - Class in io.deephaven.enterprise.compatibility.filter
- TableAdapterForFilters(Table) - Constructor for class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- TableDataServiceFactory - Class in io.deephaven.enterprise.tabledataservice
-
The standard factory for creating
TableDataService
instances using aDataRoutingService
instance - TableDataServiceFactory(DataRoutingService, SchemaService, ProtocolDriverFactory) - Constructor for class io.deephaven.enterprise.tabledataservice.TableDataServiceFactory
- TableDefinitionCompatibility - Class in io.deephaven.enterprise.compatibility
-
A compatibility class for converting enterprise
TableDefinition
into communityTableDefinition
- TableLocationStateAdapter - Class in io.deephaven.enterprise.compatibility
-
This class adapts an enterprise
TableLocationState
into a Community formattedTableLocationState
for use for Table data subscriptions - TableLocationStateAdapter(TableLocationState) - Constructor for class io.deephaven.enterprise.compatibility.TableLocationStateAdapter
- TableLoggerException - Exception in io.deephaven.enterprise.database
-
Unchecked exception that is decorated with the namespace and table was being operated on.
- TableLoggerException(String, String) - Constructor for exception io.deephaven.enterprise.database.TableLoggerException
- TableLoggerException(String, String, String) - Constructor for exception io.deephaven.enterprise.database.TableLoggerException
- tableName(String) - Method in class io.deephaven.enterprise.kafkawriter.KafkaTableWriter.Options
-
The name of the table to ingest, this is a required option.
- TableTicketTransformer - Class in io.deephaven.enterprise.acl.transform
-
A
TicketTransformer
that handles transformation ofTable
s to apply ACLs at the edge. - TableTicketTransformer(AclSupport) - Constructor for class io.deephaven.enterprise.acl.transform.TableTicketTransformer
- tail(long) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- tailBy(long, String...) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- tailPct(double) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- TestTableGenerator - Class in io.deephaven.enterprise.test
-
This class can be used to generate identical tables in memory to the ones stored in the resources for this project.
- TestTableGenerator(int, int) - Constructor for class io.deephaven.enterprise.test.TestTableGenerator
- throwIfInvalidated() - Method in class io.deephaven.enterprise.sources.regioned.impl.InvalidatableRegion
- TicketTransformer - Interface in io.deephaven.enterprise.dnd.authentication.transform
-
Implementations of this interface provide transformations of values before they are returned as
Export
s to clients. - TimePartitionRotation - Class in io.deephaven.enterprise.kafkawriter
-
Create functions for generating column partitions from an epoch timestamp.
- toBufferByteOffset(long) - Method in enum class io.deephaven.enterprise.sources.regioned.BufferedType
- toBufferIndex(long) - Method in enum class io.deephaven.enterprise.sources.regioned.BufferedType
- toBufferOffset(long) - Method in enum class io.deephaven.enterprise.sources.regioned.BufferedType
- toBufferSizeInBytes(long) - Method in enum class io.deephaven.enterprise.sources.regioned.BufferedType
- toBuilder() - Method in class io.deephaven.proto.pqworker.ListenErrorRequest
- toBuilder() - Method in class io.deephaven.proto.pqworker.ListenErrorResponse
- toBuilder() - Method in class io.deephaven.proto.pqworker.ObjectAccessRequest
- toBuilder() - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse
- toBuilder() - Method in class io.deephaven.proto.pqworker.StringList
- topic(String) - Method in class io.deephaven.enterprise.kafkawriter.KafkaTableWriter.Options
-
Set the topic to consume, this is a required option.
- toRegionByteOffset(long) - Method in enum class io.deephaven.enterprise.sources.regioned.BufferedType
- toRegionSizeInBytes(long) - Method in enum class io.deephaven.enterprise.sources.regioned.BufferedType
- toString() - Method in class io.deephaven.enterprise.locations.impl.BasicFixedPartitionedDeephavenTableLocationKey
- toString() - Method in class io.deephaven.enterprise.locations.impl.EnterpriseTableKeyImpl
- toString() - Method in class io.deephaven.enterprise.tabledataservice.filter.EnterpriseFilterWrapper
- toString() - Method in class io.deephaven.enterprise.tabledataservice.OnDiskTableDataService
- toString() - Method in class io.deephaven.enterprise.tabledataservice.RemoteTableDataService
- transactionsEnabled(boolean) - Method in class io.deephaven.enterprise.kafkawriter.KafkaTableWriter.Options
-
Deephaven tables support transactions, which allow a set of contiguous rows to be appended to a table atomically or not at all.
- transform(DheAuthContext, T) - Method in class io.deephaven.enterprise.acl.transform.GenericObjectTransformer
- transform(DheAuthContext, T) - Method in class io.deephaven.enterprise.acl.transform.TableTicketTransformer
- transform(DheAuthContext, T) - Method in interface io.deephaven.enterprise.dnd.authentication.transform.TicketTransformer
-
Transform the specified object using the auth context.
- treeTable(String, String) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- trustAll(boolean) - Method in interface io.deephaven.enterprise.dnd.EnterpriseJettyComponent.Builder
-
Set if the worker should ignore the truststore with regard for PQ uri resolution.
- tryAdapt(TableLocationKey) - Static method in interface io.deephaven.enterprise.locations.FixedPartitionedEnterpriseTableLocationKey
- tryManage(LivenessReferent) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- tryRetainReference() - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- TYPE_PATH_INDEX - Static variable in class io.deephaven.enterprise.dnd.service.ticket.DatabaseTicketResolver
U
- UGP_ADAPTER - Static variable in class io.deephaven.enterprise.compatibility.LiveTableRegistrarAdapter
- UGP_ADAPTER - Static variable in class io.deephaven.enterprise.compatibility.NotificationQueueAdapter
- ungroup(boolean, String...) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- unpackTo(String, Path) - Static method in class io.deephaven.enterprise.test.UnpackUtils
-
Locate the specified resource on the classpath and unpack it onto the filesystem at the specified path.
- UnpackUtils - Class in io.deephaven.enterprise.test
-
We would like to be able to put all of the test data files in one package and reuse them.
- UnpackUtils() - Constructor for class io.deephaven.enterprise.test.UnpackUtils
- UNPARTITIONED_KEY_PLACEHOLDER - Static variable in interface io.deephaven.enterprise.locations.FixedPartitionedEnterpriseTableLocationKey
- update(SelectColumn...) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- updateBy(UpdateByControl, Collection<UpdateByClause>, MatchPair...) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- updatePerformanceLogLogger() - Method in class io.deephaven.enterprise.dnd.logger.engine.impl.EngineTableLoggersFactoryDndImpl
- updateView(SelectColumn...) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- URIModule - Interface in io.deephaven.enterprise.dnd.modules
-
This module injects the
PQUriResolver
into the URI Resolver set for the worker. - USE_RANGES_AVERAGE_RUN_LENGTH - Static variable in interface io.deephaven.enterprise.sources.regioned.BufferedPage
-
Minimum average run length in an
RowSequence
that should trigger copy-by-ranges in BufferedPage implementations. - useLas() - Method in class io.deephaven.enterprise.database.SystemTableLogger.Options
-
Get if we should use the Log Aggregator service to write the table.
- useLas(boolean) - Method in interface io.deephaven.enterprise.database.SystemTableLogger.Options.Builder
-
Should the table be written via the log aggregator service (LAS)?
V
- validateSelect(SelectColumn...) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- valueOf(String) - Static method in enum class io.deephaven.enterprise.sources.regioned.BufferedType
-
Returns the enum constant of this class with the specified name.
- values() - Static method in enum class io.deephaven.enterprise.sources.regioned.BufferedType
-
Returns an array containing the constants of this enum class, in the order they are declared.
- VALUES_FIELD_NUMBER - Static variable in class io.deephaven.proto.pqworker.StringList
- valueSpec(KafkaTools.Consume.KeyOrValueSpec) - Method in class io.deephaven.enterprise.kafkawriter.KafkaTableWriter.Options
-
Determine how the value is converted to table columns.
- varBy(SelectColumn...) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- view(SelectColumn...) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- visitLocationKey(TableLocationKey) - Method in class io.deephaven.enterprise.tabledataservice.MarkingPollingLocationProvider
W
- WASUNCAUGHT_FIELD_NUMBER - Static variable in class io.deephaven.proto.pqworker.ListenErrorResponse
- wavgBy(String, SelectColumn...) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- where(WhereFilter...) - Static method in interface io.deephaven.enterprise.acl.AclFilterGenerator
-
Create an
AclFilterGenerator
from a set of simplewhere
clauses. - where(String...) - Static method in interface io.deephaven.enterprise.acl.AclFilterGenerator
-
Create an
AclFilterGenerator
from a set of simplewhere
clauses. - where(Collection<WhereFilter>) - Static method in interface io.deephaven.enterprise.acl.AclFilterGenerator
-
Create an
AclFilterGenerator
from a set of simplewhere
clauses. - where(Filter) - Method in class io.deephaven.enterprise.acl.impl.DeferredACLTable
- where(SelectFilter...) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- whereIn(Table, String, String[], String...) - Static method in interface io.deephaven.enterprise.acl.AclFilterGenerator
-
Create an
AclFilterGenerator
that applies aTableOperations.whereIn(Object, String...)
filter from a "Set" table containing the group information. - whereIn(String, String, String, String[], boolean, String...) - Static method in interface io.deephaven.enterprise.acl.AclFilterGenerator
-
Create an
AclFilterGenerator
that applies aTableOperations.whereIn(Object, String...)
filter from a "Set" table containing the group information. - whereIn(Table, boolean, MatchPair...) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- WhereInFilterGenerator - Class in io.deephaven.enterprise.acl.generator
-
A filter generator that specifies a set table, and a list of match expressions (FilteredColumn=SetColumn), to apply a
TableOperations.whereIn(Object, String...)
operation to the filtered table. - WhereInFilterGenerator(Table, String, String[], MatchPair...) - Constructor for class io.deephaven.enterprise.acl.generator.WhereInFilterGenerator
-
Creates a whereIn filter generator, using the given set table, filters, and groupColumn to determine the visible rows for a given user.
- WhereInFilterGenerator(String, String, String, String[], boolean, MatchPair...) - Constructor for class io.deephaven.enterprise.acl.generator.WhereInFilterGenerator
-
Creates a whereIn filter generator, using the given namespace, tablename, filters, and groupColumn to determine the visible rows for a given user.
- WhereInFilterGenerator(String, String, String, String[], boolean, MatchPair...) - Constructor for class io.deephaven.enterprise.acl.generator.WhereInFilterGenerator
-
Creates a whereIn filter generator, using the given namespace, tablename, filters, and groupColumn to determine the visible rows for a given user.
- withAdminGroups(Set<String>) - Method in interface io.deephaven.enterprise.dnd.EnterpriseJettyComponent.Builder
- withAuditEventLogger(AuditEventLogger) - Method in interface io.deephaven.enterprise.dnd.EnterpriseJettyComponent.Builder
- withColumnDescription(Map<String, String>) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- withDispatcherClient(DispatcherClient) - Method in interface io.deephaven.enterprise.dnd.EnterpriseJettyComponent.Builder
-
Set the
DispatcherClient
for components. - withJettyConfig(JettyConfig) - Method in interface io.deephaven.enterprise.dnd.EnterpriseJettyComponent.Builder
-
Set the Jetty configuration to use for the server.
- withKeys(String...) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- withPersistentQuerySerial(long) - Method in interface io.deephaven.enterprise.dnd.EnterpriseJettyComponent.Builder
- withRetriesAndReAuth(String, Function<ByteString, ReqT>, LongFunction<Stub>, Function<Stub, BiConsumer<ReqT, StreamObserver<RespT>>>, long) - Method in class io.deephaven.enterprise.dnd.controller.client.ControllerClientGrpc
- withRetriesAndReAuth(String, Function<ByteString, ReqT>, LongFunction<Stub>, Function<Stub, BiConsumer<ReqT, StreamObserver<RespT>>>, Function<RespT, V>, long) - Method in class io.deephaven.enterprise.dnd.controller.client.ControllerClientGrpc
-
Perform an RPC call with retries if necessary, including both call retries and necessary authentication retries depending on type of failure.
- withTableDescription(String) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- withUniqueKeys(String...) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- withUserContext(UserContext) - Method in interface io.deephaven.enterprise.dnd.EnterpriseJettyComponent.Builder
-
Set the user context of the owning user
- withViewerGroups(Set<String>) - Method in interface io.deephaven.enterprise.dnd.EnterpriseJettyComponent.Builder
- withVirtualEnvironment(String) - Method in interface io.deephaven.enterprise.dnd.EnterpriseJettyComponent.Builder
- workerName(String) - Method in class io.deephaven.enterprise.dnd.query.util.perf.PerformanceOverview
-
Set the name of the worker to filter performamnce data
- wouldMatch(WouldMatchPair...) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
- wrap(Filter) - Static method in class io.deephaven.enterprise.tabledataservice.filter.EnterpriseFilterWrapper
- WrappedGroupProvider - Class in io.deephaven.enterprise.dnd.authentication
-
A Simple
GroupProvider
that wraps the Enterprise implementationIrisGroupProvider
- WrappedGroupProvider(IrisGroupProvider) - Constructor for class io.deephaven.enterprise.dnd.authentication.WrappedGroupProvider
-
Create a new provider delegating to the underlying Enterprise provider.
- writeLocationsTable(File, Schema) - Static method in class io.deephaven.enterprise.locations.local.HiveLocationsTableKeyFinder
-
Write a locations table to disk for the given directory and schema.
- writeTable(Table, TableDefinition, File) - Static method in class io.deephaven.enterprise.table.EnterpriseTableTools
-
Write the input table to the specified path in Deephaven format.
- writeTable(Table, TableDefinition, String) - Static method in class io.deephaven.enterprise.table.EnterpriseTableTools
-
Write the input table to the specified path in Deephaven format.
- writeTable(Table, File) - Static method in class io.deephaven.enterprise.table.EnterpriseTableTools
-
Write the input table to the specified path in Deephaven format.
- writeTable(Table, String) - Static method in class io.deephaven.enterprise.table.EnterpriseTableTools
-
Write the input table to the specified path in Deephaven format.
- writeTo(CodedOutputStream) - Method in class io.deephaven.proto.pqworker.ListenErrorRequest
- writeTo(CodedOutputStream) - Method in class io.deephaven.proto.pqworker.ListenErrorResponse
- writeTo(CodedOutputStream) - Method in class io.deephaven.proto.pqworker.ObjectAccessRequest
- writeTo(CodedOutputStream) - Method in class io.deephaven.proto.pqworker.ObjectAccessResponse
- writeTo(CodedOutputStream) - Method in class io.deephaven.proto.pqworker.StringList
- wsumBy(String, SelectColumn...) - Method in class io.deephaven.enterprise.compatibility.filter.TableAdapterForFilters
Z
- ZERO_LENGTH_FILTER_GENERATOR_ARRAY - Static variable in interface io.deephaven.enterprise.acl.AclFilterGenerator
- zoneId() - Method in class io.deephaven.enterprise.database.SystemTableLogger.Options
-
Get the zone ID used for binary log files.
- zoneId(ZoneId) - Method in interface io.deephaven.enterprise.database.SystemTableLogger.Options.Builder
-
ZoneId for binary log files.
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form