All Classes and Interfaces
Class
Description
This interface defines an object that generates
WhereFilters to apply as ACLs to tables based upon a
UserContext and potentially a namespace and table name.A support object to assist in the creation of Row and column ACLs.
This auth wiring only allows users marked as administrators for the query to perform console operations.
This auth wiring only allows users marked as administrators for the query to perform console operations.
An
FixedPartitionedEnterpriseTableLocationKey that simply wraps an enterprise
TableLocationKeyBase implementation for DnD components to log binary rows via LAS.
A
ColumnRegion backed by a buffer of some sort.The basic implementation for a
BufferedColumnRegion.ColumnRegionByte implementation for regions that support fetching primitive bytes from a
FileDataBufferStore.ColumnRegionChar implementation for regions that support fetching primitive chars from a
FileDataBufferStore.ColumnRegionDouble implementation for regions that support fetching primitive doubles from a
FileDataBufferStore.ColumnRegionFloat implementation for regions that support fetching primitive floats from a
FileDataBufferStore.ColumnRegionInt implementation for regions that support fetching primitive ints from a
FileDataBufferStore.ColumnRegionLong implementation for regions that support fetching primitive ints from a
FileDataBufferStore.ColumnRegionLongWithLength implementation for regions that support fetching primitive longs from a
FileDataBufferStore.ColumnRegionShort implementation for regions that support fetching primitive shorts from a
FileDataBufferStore.Implementors provide a method to adapt an Enterprise
WritableChunk into a Community
WritableChunk.A collection of
WhereFilters by group and column.A
ColumnRegionByte that supports querying its length.A
ColumnRegionLong that supports querying its length.ColumnRegionObjectCached<T,ATTR extends Values,OFFSET_LOOKUP_CACHE extends OffsetLookupCache<T,ChunkSource.FillContext>>
Column region interface for regions that support fetching objects.
ColumnRegionObjectCached.CacheFactory<T,OFFSET_LOOKUP_CACHE extends OffsetLookupCache<T,ChunkSource.FillContext>>
A
ColumnRegion for non-primitive types that have a fixed size.A
ColumnRegion for non-primitive types that have a variable size.A Column region for objects that is backed by a dictionary of values.
A
ColumnRegionObject implementation for Deephaven format StringSet columns where stringsets are
stored as a bitmask and dictionary columnAn adapter from Community
ColumnSource to Enterprise ColumnSource geared
towards supporting Table.where().A Filter generator that provides a means to apply separate
AclFilterGenerator sets based on a users groups.A class specifically for completing table names; to be called after the completer has discovered the name of the
table.
A class specifically for completing table namespaces; to be called after the completer has discovered the name of the
namespace.
AclFilterGenerator for combining the results of multiple AclFilterGenerators conjunctively, i.e.A lazy provider of the singleton controller client for queries.
A client for subscribing to state from the PersistentQueryController and manipulating persistent queries.
A basic
ControllerClientGrpc.Observer implementation with do-nothing methods.This interface presents a view of the data store for the system in both Live, and Historical versions.
This class exists as an adapter shim between the Community implementation of
DatabaseInternal and the enterprise version.Custom autocomplete results for DHE.
A basic implementation of the
Database interface.This partial interface defines methods that we need to include in
Database
for various reasons, but are not intended for use by client code.A tagging interface for Deephaven formatted table locations.
A
TableLocationKey in Deephaven columnar format, located on a locally accessible filesystem.An
UncoalescedTable that will apply row and column ACLs when it is coalesced.An
AuthContext containing a single UserContext for Enterprise authentication.The authentication hook for enterprise clients to DnD workers.
The authorization provider for access to the worker.
AclFilterGenerator for combining the results of multiple AclFilterGenerators disjunctively, i.e.A basic gRPC connection to a DnD worker.
A session on a Persistent Query used to access tables using Barrage
A factory class for creating
barrage sessions.A implementation of
EdgeAclProvider that stores immutable maps of group to ACL definition.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.A Builder to construct a set of ACLs to apply to a table based on the user fetching it.
Provides DnD engine table logger implementations that will write DHE binary rows.
An
SourceAclProvider that converts acls derived from Enterprise PermissionFilterProvider into
Community equivalents.This dagger module provides the authorization bindings into the dagger context.
An adapter from
enterprise filters to community filters.A light wrapper around an Enterprise
Filter.A
TableLocationKeyFinder for locating tables stored in Legacy
Deephaven Enterprise structured database.
This is the root component definition for DnD workers.
The root builder for the DnD jetty component.
A
TableLocationKey marking tables stored in a Deephaven Enterprise database in the Parquet format.A
TableKey implementation for addressing Deephaven Enterprise Tables.A basic Enterprise format
TableKey.A
TableLocationFactory for resolving EnterpriseTableLocationKeyUnresolved to either a
OnDiskDeephavenTableLocation or ParquetTableLocation based on the data on disk.An
EnterpriseTableLocationKey is an extension of FileTableLocationKey that defers the creation of the
actual location key until the data is needed by the EnterpriseTableLocationFactory.Provides utility methods to read and write individual Deephaven format Tables.
An adapter FillContext for use when an Enterprise chunk must be filled by a Community source.
This class represents an instance of a legacy style Deephaven table where there are two fixed partitions, the column
partition and the internal partition
An
AclFilterGenerator that provides full access to everyone.A Transformer for handling ACLs on generic objects.
A provider for group membership information for users of the system.
A
TableLocationKeyFinder that uses a table of file names, sizes, and partitioning columns to provide table
locations.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.
A builder class containing the options for Kafka ingestion.
Protobuf type
io.deephaven.proto.pqworker.ListenErrorRequestProtobuf type
io.deephaven.proto.pqworker.ListenErrorRequestProtobuf type
io.deephaven.proto.pqworker.ListenErrorResponseProtobuf type
io.deephaven.proto.pqworker.ListenErrorResponseA
TableLocationProvider that will perform a mark/sweep of active
locations on refresh.A
TableLocationKeyFinder that uses the Enterprise TableLocationMetadataIndex to find locations.An
AclFilterGenerator that provides no access to anyonne.Exception thrown when an operation expects a System schema, but was passed a non-system schema.
Tools for getting Files and Folders out of the Web IDE notebooks that are stored in DbInternal.WebClientData.
A record class that represents a file or folder.
An exception thrown when a Notebook is not found.
Protobuf type
io.deephaven.proto.pqworker.ObjectAccessRequestProtobuf type
io.deephaven.proto.pqworker.ObjectAccessRequestProtobuf type
io.deephaven.proto.pqworker.ObjectAccessResponseProtobuf type
io.deephaven.proto.pqworker.ObjectAccessResponseThis class adapts the DHE
ObjectCodec to the DHC
ObjectCodec.A
ChunkSource.GetContext for Deephaven Format ColumnRegionObject implementations containing
ChunkSource.GetContexts for the offset, dictionary and bitmask regions.The
ColumnLocation implementation for OnDiskDeephavenTableLocation locations.A
TableLocation for reading Deephaven format tables from a local
filesystem.A
TableDataService implementation that expects data to be located on
a local filesystem.A Mutable adapter for converting
OrderedKeys into a RowSequence.Builder class that accepts inputs as setters and uses said inputs to get a map of performance analysis tables and
plots.
A simple test adapter for using an
InMemoryPermissionFilterProvider as an
IrisGroupProvider for testing.A
UriResolver specifically for resolving requests for tables from persistent
queries by serial or name.Static accessor for this worker's process information ID.
A
PropertyInputStreamLoader that loads the property input stream from resources only.An interface for creating
TableDataProtocolDriver instances for use with RemoteTableDataService and
RemoteTableLocationImplThe 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.
A hook that is called from the session monitor to delete our persistent query when we are complete.
An adapter class to map a Community
WhereFilter.RecomputeListener onto
the Enterprise SelectFilter.RecomputeListener.Minor utility methods used by column region and
RegionedColumnSource implementations.A
TableLocation implementation for remote table subscriptions discovered by a
io.deephaven.enterprise.tabledataservice.RemoteTableDataService.A
TableDataService implementation that uses Enterprise's TableDataProtocol to locate tables.An
ArrayBackedOffsetLookupCache that allows for forward and backwards lookups of values.This auth wiring explicitly denies the newSession and refreshSession calls as they are deprecated on the upstream
This class contains static methods and fields that help in converting serialized non-shadowed enterprise types into
their shadowed packages before they're classloaded
Enterprise makes extensive use of Java serialization through WObjectOutput/InputStream.
Enterprise makes extensive use of Java serialization through WObjectOutput/InputStream.
An
ObjectCodec implementation for Serializable object that internally uses a
ShadowingObjectInputStream to automatically replace detected shadowed classes in the object stream with their
shadowed versions.An
AclFilterGenerator that simply applies the specified WhereFilters in Disjunctive Normal FormA
TableLocation backed by a TableLocationMetadataIndex.TableLocationSnapshot that does not refresh and tries to avoid creating
the actual location until it is truly needed.An Exception thrown when there is a problem completing a Snapshot
A provider object for creating row and column ACLs from the data source.
Protobuf type
io.deephaven.proto.pqworker.StringListProtobuf type
io.deephaven.proto.pqworker.StringListAn Exception thrown when there is a problem completing a subscription
Utility to log
Table objects to System tables via the Log Aggregator Server.Options for writing a system table using a logger.
The standard factory for creating
TableDataService instances using a DataRoutingService instanceA compatibility class for converting enterprise
TableDefinition into community
TableDefinitionThis class adapts an enterprise
TableLocationState into a Community formatted
TableLocationState for use for Table data subscriptionsUnchecked exception that is decorated with the namespace and table was being operated on.
A
TicketTransformer that handles transformation of Tables to apply ACLs at the edge.This class can be used to generate identical tables in memory to the ones stored in the resources for this project.
Implementations of this interface provide transformations of values before they are returned as
Exports to clients.Create functions for generating column partitions from an epoch timestamp.
We would like to be able to put all of the test data files in one package and reuse them.
This module injects the
PQUriResolver into the URI Resolver set for the worker.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.A Simple
GroupProvider that wraps the Enterprise implementation IrisGroupProvider