All Classes and Interfaces
Class
Description
Helper for preview table implementations that extracts the common logic.
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.Protobuf type
io.deephaven.proto.acl.AclGetPermissionsRequestProtobuf type
io.deephaven.proto.acl.AclGetPermissionsRequestProtobuf type
io.deephaven.proto.acl.AclGetPermissionsResponseProtobuf type
io.deephaven.proto.acl.AclGetPermissionsResponse
We have not created a service, but rather make a request using the oneof message; and reply using the corresponding
message in the AclPluginResponse.
We have not created a service, but rather make a request using the oneof message; and reply using the corresponding
message in the AclPluginResponse.
Protobuf type
io.deephaven.proto.acl.AclPluginResponseProtobuf type
io.deephaven.proto.acl.AclPluginResponseProcesses AclServicePlugin requests
ObjectType plugin to check ACL permissions.
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.
The interface encapsulates the table column properties and provides wrapper methods to invoke persist calls on
underlying
LocalAppendableColumnFactory class that provides factory methods for sink columns
This column sink is a wrapper that holds multiple column sinks that are sourced from the same source column.
This class is the Instant array column sink implementation to be supplied from the sink factory call for DHC CSV
Parser.
This class is the Instant column sink implementation to be supplied from the sink factory call for DHC CSV Parser.
Sink interface used in import csv.
A simple wrapper for string-to-array parsing.
Protobuf enum
io.deephaven.proto.jdbc.AssessmentMethodAutomatically generated Deephaven binary logger for DbInternal.AuditEventLog format 3
Interface that simply joins different AEL behavior into a single type.
The Base class for All types of implementations for
AppendableColumnSink.Encapsulates the functionality for custom setters that allow processing of
CustomSetterValueCreates BaseFieldWriter for passed ImporterColumnDefinitions
Default implementation of
BaseCsvFieldWriter.CustomSetterFactory that can be used to create a CustomSetterHolds the methods common to both CsvFieldWriter and CsvColumnDataTransformer.
Base class for import jobs.
An
FixedPartitionedEnterpriseTableLocationKey that simply wraps an enterprise
TableLocationKeyBuilder for creating instances of
BinaryImportOptions.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.Protobuf type
io.deephaven.proto.web.client.utils.BusinessDatesRequestProtobuf type
io.deephaven.proto.web.client.utils.BusinessDatesRequestProtobuf type
io.deephaven.proto.web.client.utils.BusinessDatesResponseProtobuf type
io.deephaven.proto.web.client.utils.BusinessDatesResponseAdapts a Legacy ColumnRegionByte to a Core ColumnRegionByte.
String formatting styles for use when standardizing externally supplied column names.
Adapts a Legacy ColumnRegionChar to a Core ColumnRegionChar.
A collection of
WhereFilters by group and column.ColumnRegionByte implementation for regions that support fetching primitive bytes from a
FileDataBufferStore as booleans, adjusting for legacy null values.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 columnThe dhc parser associates one sink and one parser for each source column.
An 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.
A concrete implementation of the replay configuration for one table.
Configure replay persistent queries.
AclFilterGenerator for combining the results of multiple AclFilterGenerators conjunctively, i.e.A
Table that wraps a Barrage subscription, but can gracefully handle upstream query state changes.Implementations of this interface provide parameters for a
ConnectionAwareRemoteTable to maintain a
subscription to a remote table.Implementations of this interface can be used to construct a new
ConnectionAwareRemoteTableParams.Gets groovy scripts over the network via controller client.
A lazy provider of the singleton controller client for queries.
A
RemoteTableStateWatcher that uses a PersistentQueryControllerClient to produce tokens backed by
PersistentQueryInfoMessages.A
RemoteTableStateWatcher.StateToken backed by a PersistentQueryInfoMessageThis class adapts a Legacy Enterprise TableLocationProvider into a Core TableLocationProvider.
Core+ ImportState for lastBy DIS instances.
LocalTableMap with an associated LiveTableRefreshCombiner.
A session factory that knows how to associate a barrage session and its managed channel; the session is created
authenticated to a DHE authentication service client.
Provides an expression validator that permits query admins to execute arbitrary filters and selects.
Processes CsvApiServiceService plugin requests.
Abstract class providing methods used when reading data from CSV files to be written to Deephaven columns.
Creates ColumnTransformers for passed ImporterColumnDefinitions
Default Factory class that creates the DataTransformers
Abstract class providing methods used when reading data from CSV files to be written to Deephaven columns.
The CSV importer class.
Thrown primarily when an unsupported format is specified
Enum of supported CSV formats.
Tools for programmatically executing CSV batch imports.
Class to assist with different styles of CSV files
Implementation of
CsvImporterHelper that handles BPIPE CSV import scenarios.Extends SkipLinesInputStream as that supports readLine functionality.
Implementation of
CsvImporterHelper that handles general CSV import scenarios.Defines options for a specific CSV import request so that they can be sent to a persistent query or the
CsvImport class.Builder for creating instances of
CsvImportOptions.Parser for Instant type object that supports error count tracking.
This is base class for custom parsers that have a non-primitive data type in general.
Context class that holds the attributes and functionality common to all custom parsers.
A class that holds the methods to build and associate the appropriate parser for ColumnSinks that are in source file.
The parser will be used for the partition column when the schema has a partition column defined.
The CsvPluginRequest is `oneof` available schema messages.
The CsvPluginRequest is `oneof` available schema messages.
Protobuf type
io.deephaven.proto.csv.CsvPluginResponseProtobuf type
io.deephaven.proto.csv.CsvPluginResponseReads a CSV file and attempts to infer column data types and create appropriate schema and importer instructions.
A Builder object for
CsvSchemaCreator.Factory for creating sinks that can write to array column sources.
Main CSV import tools class.
The CSV API service uses the Core version of CsvTools.
An interface that allows non-custom setter columns to publish their data while allowing custom setter columns to
retrieve and use the data appropriately
The implementation class for
CustomSetterSinkDataProcessor.The class is an implementation of RowSetter that in addition exposes the get methods to access the data value
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.Tests to assure the quality of the data in a table.
An exception thrown when an assertion fails.
Interface for testing monotonicity.
A marker interface for classes which implement data quality tests.
An interface for logging the results of data quality tests.
Machinery to run a collection of data quality tests.
Machinery to run a collection of data quality tests.
Simple machinery to run a collection of data quality tests.
Class to handle compatibility issues with legacy date-time parsing in Deephaven.
Defines Deephaven-supported timezones, which may be used for PQ-scheduling and display purposes.
An object that maintains connections to Deephaven services on a remote cluster.
A tagging interface for Deephaven formatted table locations.
Parser for Deephaven legacy time zones from
DateTimeCompatibility.DBTimeZone.A
MergeDestinationWriter implementation which writes TableLocation.Format.DEEPHAVEN to disk.Defines options for a specific merge-request.
This implementation of
SchemaInternal delegates to a Legacy Schema instanceProvides methods for interacting with the system Schema store using
Schema instances.This is a basic implementation that maintains the original IteratorHolder and delegates all calls directly to it.
An
UncoalescedTable that will apply row and column ACLs when it is coalesced.A TableDataService that delegates to another TableDataService.
A clock impl with a delta adjustment and a speed factor.
A clock impl with a delta adjustment and a speed factor.
Note this class is only to be used by the DerivedPartitionTableWriterImpl.
This interface is used internally by the PartitionedTable DerivedTableWriter.
Persist data from a
Table to Deephaven storage using an in-worker DataImportServer.Represents Options for ingesting a table to a DIS partition.
Represents options for partitioned table ingestion.
Used to notify that a sub-table has been written for a given identifier
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.
A table writer factory that takes a single destination directory.
A container for the configuration parameters of an Iceberg
discovery.The interface for constructing a
DiscoveryConfig.The result of an Iceberg table
discovery.The implementation of a
DiscoveryResultAclFilterGenerator for combining the results of multiple AclFilterGenerators disjunctively, i.e.Despite class name, this class doesn't extend the Groovy class loader, but rather handles getting Groovy script
resources.
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.Adapts a Legacy ColumnRegionDouble to a Core ColumnRegionDouble.
the column spec does not permit null primitives
the column spec does not permit null primitives
A TableDataService that can be dynamically updated when the source DataRoutingService changes.
A configuration defined data quality test case for DynamicValidator.
An exception thrown when problems are encountered converting strings into typed parameter values.
An exception thrown when attempting to set a parameter that does not exist in the method.
An exception resulting from reflection not being able to access parameter names.
An exception thrown when trying to invoke the test, but a required parameter has not been set.
An exception thrown when DynamicValidatorInterface contains multiple methods with the same name.
An exception thrown when the test method is not present in DynamicValidatorInterface.
Utilities for loading DynamicValidator test cases.
Pass-through/shim class so that customers do not need to change their PQs.
A user interface driven data validator.
Interface containing all tests than can be executed during dynamic data validation.
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.
Interface for end-of-record field writers.
Provides Core+ 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.
This is the root component definition for DnD workers.
The root builder for the DnD jetty component.
An interface to add methods needed by Enterprise TableDataService variants.
A
TableKey implementation for addressing Deephaven Enterprise Tables.A basic Enterprise format
TableKey.Provides utility methods to read and write individual Deephaven format Tables.
An enum column takes on a limited set of values
An enum column takes on a limited set of values
Protobuf type
io.deephaven.proto.acl.ErrorResponseProtobuf type
io.deephaven.proto.csv.ErrorResponseProtobuf type
io.deephaven.proto.jdbc.ErrorResponseProtobuf type
io.deephaven.proto.pivot.ErrorResponseProtobuf type
io.deephaven.proto.schema.ErrorResponseProtobuf type
io.deephaven.proto.web.client.utils.ErrorResponseProtobuf type
io.deephaven.proto.acl.ErrorResponseProtobuf type
io.deephaven.proto.csv.ErrorResponseProtobuf type
io.deephaven.proto.jdbc.ErrorResponseProtobuf type
io.deephaven.proto.pivot.ErrorResponseProtobuf type
io.deephaven.proto.schema.ErrorResponseProtobuf type
io.deephaven.proto.web.client.utils.ErrorResponseClass called from
Main to execute a CSV import job in Core+.Class called from
Main to execute a JDBC import job in Core+.Executes a Core+ Merge job
Executes a Core+ Validate job
Executes a Core+ WorkspaceSnapshot job
Implementations of this internal interface are used to create appropriate
TableLocationProvider instances for
various extended table types.Implementations of this create
ExtendedStorageProviders based on the inputs.The service for loading
ExtendedStorageProviders that provide special storage backends for the database.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
Adapts a Legacy ColumnRegionFloat to a Core ColumnRegionFloat.
the column spec does not permit null primitives
the column spec does not permit null primitives
A BufferedReader that skips a specified number of lines at the end of the stream.
Processes ForceLogoutProviderService requests
ObjectType plugin to enable clients to retrieve a revision history table for a specific query.
An
AclFilterGenerator that provides full access to everyone.Binary store importer that can be used in both persistent queries and command-line imports.
General CSV importer class to handle standard CSV imports
Abstract class providing methods used when importing data to be written to Deephaven columns.
Import data from a JDBC source.
A Transformer for handling ACLs on generic objects.
A thin wrapper around a
ScriptSession so that we can invalidate the controller class loader cache before
evaluating scripts.A provider for group membership information for users of the system.
A
TicketTransformer that handles transformation of HierarchicalTables to apply ACLs at the edge.The provider for the coreplus:hive format, where tables are stored in the Apache Hive layout.
The factory class for creating this provider.
A
TableLocationKeyFinder that discovers Deephaven and parquet
format tables that are laid out in Apache Hive style on disk.A
TableLocationKeyFinder that uses a table of file names, sizes, and partitioning columns to provide table
locations.A
TableLocationFactory for resolving Hive style keys to locations.A
PropertyInputStreamLoader that loads files via HTTP GET requests to the specified hostA
TableLocation backed by a TableLocationMetadataIndex.LocationSnapshot that does not refresh and
tries to avoid creating the actual location until it is truly needed.Contains the configuration parameters needed to connect to an Iceberg
Catalog and
fetch Iceberg Tables.This interface provides an adapter layer between type specific data instructions and JSON serialization for
IcebergEndpoint.The factory interface for injecting implementations using
ServiceLoader.The complete configuration required to locate an Iceberg table within a
Catalog
and then fetch the Iceberg table into Deephaven.A Builder object for construction of a
IcebergEndpoint.An
IcebergEndpoint that is also named.Deprecated.
The factory class for creating this provider.
Options for controlling how we merge a Deephaven table into an Iceberg table.
An implementation of
IcebergDataInstructions used to serialize and deserialize S3Instructions for
fetching tables from an S3 store.A deserializer for
S3Instructions.The factory instance.
A serializer for
S3Instructions that only writes values that do not match the deephaven default values.An
ExtendedStorageProvider for the "iceberg" type.The factory class for creating this provider.
The options to create a
Table from Iceberg.A builder for
IcebergTableOptions.Common utilities for loading Iceberg tables as Deephaven
TablesA class for abstracting away the different terminology and parameters for obtaining JDBC data; for use in the GUI
JDBC importing framework to make it friendlier for our users.
The necessary elements for a client UI to display information about this driver wrapper.
General factory interface for obtaining driver wrappers.
Interface for handling transformations from custom implementations of
Parser.Functionality for analyzing import details.
Encapsulates details about ImportColumns from the schema, such as sourceType, formulae, etc
Dummy class to mark fields to be populated from the CONSTANT_COLUMN_VALUE parameter
Exception class for errors encountered during import operations.
This class encapsulates common transformations that can be used in ImportSource elements.
Mode for importers.
Constants for import property names.
Helper methods for Import Queries.
Support classes for programmatic creation of ImportSource blocks for schema files.
A class to wrap up details of an ImportColumn.
Protobuf type
io.deephaven.proto.csv.ImportSourceRequestProtobuf type
io.deephaven.proto.jdbc.ImportSourceRequestProtobuf type
io.deephaven.proto.csv.ImportSourceRequestProtobuf type
io.deephaven.proto.jdbc.ImportSourceRequest
The first object is the table
The first object is the table
For the CompositeImportState we need to have a well-defined order.
An import state details provides the class, constructor arguments, and key columns for an ImportState.
This exists to overcome a shadow-based error related to
CheckpointRecord#readImporterState(DataInputStream).The style of import for schema discovery.
A Factory to generate
TableWriters for use with various importers.A base for table writer factories with common utility code to validate and prepare table destination directories, and
create the table writers.
Importer utilities required for the Illumon importers
A
LocalAppendableColumn implementation which stores column data in-memory.Tool to convert Legacy input tables into new Core+ input tables.
Tool to snapshot specified Core+ input tables.
Handles the targeting and reporting of Core+ executions on multiple input tables.
An extension of
InputTableUpdater that is a LivenessReferent and
allows materializing the resulting Table.Adapts a Legacy ColumnRegionInt to a Core ColumnRegionInt.
the column spec does not permit null primitives
the column spec does not permit null primitives
Placeholder schema for tables that delegate to nonexistent/invalid sources.
Placeholder instance for a TableDataService that could not be (re)created.
Utility functions for help in validation classes
Processes JdbcApiServiceService plugin requests.
Request catalog names
Request catalog names
Response for catalog names
Response for catalog names
Request a JDBC connection
Request a JDBC connection
Response for a JDBC connection
Response for a JDBC connection
Request a disconnect
Request a disconnect
Response for a disconnect
Response for a disconnect
Factory for JDBC Driver Wrappers.
Abstract class providing methods used when reading data from JDBC to be written to Deephaven columns.
The base class for JDBC field writers that use the standard type mappings (from JdbcTypeMapper) to convert from a
JDBC result set to a Deephaven column type.
Generate a schema
Generate a schema
Protobuf type
io.deephaven.proto.jdbc.JdbcGenerateSchemaResponseProtobuf type
io.deephaven.proto.jdbc.JdbcGenerateSchemaResponseTools for programmatically executing JDBC batch imports.
Defines options for a specific JDBC import request so that they can be sent to a persistent query.
Builder for creating instances of
JdbcImportOptions.
The JdbcPluginRequest is `oneof` available schema messages.
The JdbcPluginRequest is `oneof` available schema messages.
Protobuf type
io.deephaven.proto.jdbc.JdbcPluginResponseProtobuf type
io.deephaven.proto.jdbc.JdbcPluginResponseProtobuf type
io.deephaven.proto.jdbc.JdbcQueryTableRequestProtobuf type
io.deephaven.proto.jdbc.JdbcQueryTableRequest
The first object is the table
The first object is the table
Reads a JDBC result set and attempts to infer column data types and create appropriate schema and importer
instructions.
The assessment method to use when inferring schema.
A Builder object for
ImmutableJdbcSchemaCreatorException indicating an error during schema assessment.
A JdbcSession pairs a jdbc driver and connection for use until the session is closed.
Request table names
Request table names
Response for table names
Response for table names
A utility class for mapping JDBC SQL types to Deephaven column types.
A mapping that converts SQL booleans to Boolean.
Implementation of DataTypeMapping for byte arrays.
A mapping that converts SQL bytes to Byte.
A mapping that converts SQL chars to Character.
A closure that can be used to bind a ColumnSource to the given PreparedStatement and parameter index.
A catch-all bucket for settings used when converting Deephaven column values to and from JDBC values.
An abstraction for mapping a JDBC type to a Deephaven column type.
A mapping that converts SQL Dates to dates.
A mapping that converts SQL dates to LocalDate.
A mapping that converts SQL years to dates.
Implementation of DataTypeMapping for BigDecimal.
Provides a SQL decimal/numeric to double precision Deephaven type mapping
Provides a mapping from SQL decimal/numeric to BigDecimal.
A mapping that converts SQL doubles to Double.
A mapping that converts SQL double precision floating point to BigDecimal.
A mapping that converts SQL floats to Float.
A mapping that converts SQL single precision floating point to BigDecimal.
A mapping that converts SQL integers to BigDecimal.
A mapping that converts SQL longs to Long.
A mapping that converts SQL shorts to Short.
Implementation of DataTypeMapping for Strings.
A mapping for backward compatibility, converts a string column to a double array with a specified delimiter.
A mapping for backward compatibility, converts a string column to a long array with a specified delimiter
A mapping that converts SQL times to timestamps.
A mapping that converts SQL times to timestamps.
A mapping that converts SQL integers to BigDecimal.
A mapping that converts SQL timestamp to timestamps.
Exception thrown when a JDBC SQL type cannot be mapped to a Deephaven type.
Utility methods for JDBC imports.
A
SecretsProvider that sources secrets from a file on disk in Property format.A factory to create a
JsonFilesSecretsProvider from an XML Element.The KafkaTableWriter creates a Deephaven Core 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.
Provides function information about matching one-input, one-output Lambda functions based on input and output types
The LastByPartitionedTableFactory attaches to an Enterprise
DataImportServer and produces a Core
PartitionedTable with one constituent entry per partition for a given namespace and table name.Protobuf type
io.deephaven.proto.pqworker.ListenErrorRequestProtobuf type
io.deephaven.proto.pqworker.ListenErrorRequestProtobuf type
io.deephaven.proto.pqworker.ListenErrorResponseProtobuf type
io.deephaven.proto.pqworker.ListenErrorResponseAdapts a Legacy ColumnRegionLong to a Core ColumnRegionLong.
the column spec does not permit null primitives, null instants are represented as QueryConstants.NULL_LONG
the column spec does not permit null primitives, null instants are represented as QueryConstants.NULL_LONG
An object that produces a
ManagedChannel given host, port and max message size.A
TableLocationProvider that will perform a mark/sweep of active
locations on refresh.This abstract class is intended to provide "common" functionality to implementations
A
TableLocationKeyFinder that uses the Enterprise TableLocationMetadataIndex to find locations.An exception thrown when a
TableDefinition can not
be loaded from disk.A table writer factory that accepts a partition at runtime (used when we want to use data from an import column to
direct each row to a specific partition).
Driver wrapper for MySQL databases.
A
TableLocationKey in Deephaven columnar format, located on a locally accessible filesystem.A
TableLocationKeyFinder for locating tables stored in Legacy
Deephaven Enterprise structured database.A
TableLocationKey marking tables stored in a Deephaven Enterprise database in the Parquet format.A
TableLocationFactory for resolving NestedPartitionedUnresolvedTableLocationKey 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 NestedPartitionedTableLocationFactory.An
AclFilterGenerator that provides no access to anyonne.Pass-through/shim class so that customers do not need to change their PQs.
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.WorkspaceData.
A record class that represents a file or folder.
An exception thrown when a Notebook is not found.
Protobuf type
io.deephaven.proto.inputtable.NullableBooleanList
a regular "bool" does not permit us to have a null value; so we define our own enum
Protobuf type
io.deephaven.proto.inputtable.NullableBooleanList
a list of nullable strings
a list of nullable strings
a string that is optional; not present should be treated as null
a string that is optional; not present should be treated as null
Pass-through/shim class so that customers do not need to change their PQs.
A generic and very simple data validator.
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.Tools for reading offsets from existing partitions for use with in an Ingester.
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 TableDataServiceDescriptor for OnDiskTableDataService.
Builder interface for creating OnDiskTableDataServiceDescriptor instances.
A Mutable adapter for converting
OrderedKeys into a RowSequence.An
ExtendedStorageProvider implementation for parquet: types, including `flat` and `metadata`.The factory class for creating this provider.
A
MergeDestinationWriter implementation which writes TableLocation.Format.PARQUET to disk.Exception class to be thrown by subclasses when an error is encountered while parsing input.
Helper enumerations for producing useful partitioning formulas in
MergeData.Specialized enum used in conjunction with
PartitioningFormulaHelpersHolds the map of partition to its list of chunks (startIndex and size) in one parser chunk which is approximately
262K in size.
This is an Observer interface.
Specifies how to find the column partition value for a merge operation.
Automatically generated Deephaven binary logger for DbInternal.ProcessEventLog format 2
Builder class that accepts inputs as setters and uses said inputs to get a map of performance analysis tables and
plots.
Implementations of this interface provide a client that can communicate with the Persistent Query Controller to query
and manage the state of Persistent Queries.
An object that will be notified of changes to the state of the Controller.
A basic
PersistentQueryControllerClient.Observer implementation with do-nothing methods.A minimalistic interface that allows to get a controller client, either subscribed or not.
Implementations of this class provide a way to access script code and paths for execution.
Creates and makes available tables associated to controller subscriptions for PQ state changes.
A simple test adapter for using an
InMemoryPermissionFilterProvider as an
IrisGroupProvider for testing.Factory to handle Barrage DoExchange subscription requests.
We have not created a service, but rather make a request using the oneof message; and reply using the corresponding
message in the PivotPluginResponse.
We have not created a service, but rather make a request using the oneof message; and reply using the corresponding
message in the PivotPluginResponse.
Protobuf type
io.deephaven.proto.pivot.PivotPluginResponseProtobuf type
io.deephaven.proto.pivot.PivotPluginResponseA pivot table is a display-only object that aggregates using a list of row by-columns and column by-columns,
presenting the aggregated value for each combination of row and column by-column as a single cell.
A pivot snapshot contains three logical tables (represented as parallel definitions and chunks) that can be
assembled into a view on the screen:
Rows: The rows "table" contain the values of the row keys, their depth, and expanded state.
Opaque interface for objects used to cache snapshot state across multiple invocations of
PivotTable.snapshot(SnapshotState, Table, Table, ColumnName, ColumnName, Collection, RowSequence, RowSequence)Protobuf type
io.deephaven.proto.pivot.PivotTableApplyRequestProtobuf type
io.deephaven.proto.pivot.PivotTableApplyRequestProtobuf type
io.deephaven.proto.pivot.PivotTableApplyResponseProtobuf type
io.deephaven.proto.pivot.PivotTableApplyResponseProtobuf type
io.deephaven.proto.pivot.PivotTableCreationRequestProtobuf type
io.deephaven.proto.pivot.PivotTableCreationRequestProtobuf type
io.deephaven.proto.pivot.PivotTableCreationResponseProtobuf type
io.deephaven.proto.pivot.PivotTableCreationResponseProtobuf type
io.deephaven.proto.pivot.PivotTableDescriptorMessageProtobuf type
io.deephaven.proto.pivot.PivotTableDescriptorMessage
the first object is the pivot table
the first object is the pivot table
Protobuf type
io.deephaven.proto.pivot.PivotTableDescriptorResponseProtobuf type
io.deephaven.proto.pivot.PivotTableDescriptorResponse
the first object is the pivot table
the first object is the pivot table
the first object is the result rows expansion table
the second object is the result columns expansion table
the first object is the result rows expansion table
the second object is the result columns expansion table
Constants for interpreting Arrow schemas from io.deephaven.pivot.PivotTable instances.
Utilities for creating schemas from
PivotTable instances.
the first object is the pivot table
the first object is the pivot table
the first object is the result source table
the first object is the result source table
A
TicketTransformer that handles transformation of PivotTables to apply ACLs at
the edge.Server-side "view" object representing a client's snapshot target for HierarchicalTable data.
An ExchangeMarshaller for
PivotTableView.Protobuf type
io.deephaven.proto.pivot.PivotTableViewExpansionsMessageProtobuf type
io.deephaven.proto.pivot.PivotTableViewExpansionsMessageProtobuf type
io.deephaven.proto.pivot.PivotTableViewRequestProtobuf type
io.deephaven.proto.pivot.PivotTableViewRequestProtobuf type
io.deephaven.proto.pivot.PivotTableViewResponseProtobuf type
io.deephaven.proto.pivot.PivotTableViewResponseTool that manages an active subscription to a
PivotTableView.A data header describing the shared memory layout of a "record" or "row"
batch for a ticking barrage table.
Common functionality to send error responses for plugin service implementations
JDBC driver wrapper for PostgreSQL.
Create derived tables from PQ state base tables, with specific columns and types, as required by the web UI
A
UriResolver specifically for resolving requests for tables from persistent
queries by serial or name.A stub to allow clients to do limited synchronous rpc calls to service PQWorkerApi.
A stub to allow clients to do synchronous rpc calls to service PQWorkerApi.
A stub to allow clients to do ListenableFuture-style rpc calls to service PQWorkerApi.
Base class for the server implementation of the service PQWorkerApi.
A stub to allow clients to do asynchronous rpc calls to service PQWorkerApi.
ImportTableWriterFactory implementation used in Preview Import Table functionality.Static accessor for this worker's process information ID.
Automatically generated Deephaven binary logger for DbInternal.ProcessInfoLogCore format 1
Automatically generated Deephaven binary logger for DbInternal.ProcessMetricsLogCoreV2 format 1
Log the status and progress to a log file.
A
SecretsProvider that loads secrets from Configuration.The factory for creating a
SecretsProvider that loads secrets from configuration.This PropertyInputStreamLoader will load a configuration from etcd if is stored there, and will fall back to the
traditional (on-disk) loader if it is not stored in etcd
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.
Sets up the QueryLogs Query which supplies access to log tables for the web client.
Automatically generated Deephaven binary logger for DbInternal.QueryOperationPerformanceLogCoreV2 format 3
Automatically generated Deephaven binary logger for DbInternal.QueryPerformanceLogCoreV2 format 3
The options to read binary log files from a directory.
The options to read binary log file(s).
An adapter class to map a Community
WhereFilter.RecomputeListener onto
the Enterprise SelectFilter.RecomputeListener.JDBC driver wrapper for Amazon Redshift.
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 Builder class for creating reliable subscriptions to remote tables.
An interposed interface that forces users to authenticate with the remote system before they can call any
subscription methods.
A
TableDataService implementation that uses Enterprise's TableDataProtocol to locate tables.A TableDataServiceDescriptor for RemoteTableDataService.
Builder interface for creating RemoteTableDataServiceDescriptor instances.
A Factory class for creating
sessions for a ConnectionAwareRemoteTable to connect to.An Observable interface for
ConnectionAwareRemoteTable to monitor the state of a remote table.An Observer of state changes for this watcher.
A Token representing the state of the remote table object.
An interface for providing
TableReplayConfigurations by namespace and table name.A holder for TableReplayConfigurations, that allows the configurations to be accessed by namespace and tablename.
The ReplayDatabase wraps another Database implementation; applying
ClockFilters to liveTables before
returning them to the user.An
ArrayBackedOffsetLookupCache that allows for forward and backwards lookups of values.Processes RevertTableProviderService requests to retrieve a revision history table for a specific query.
ObjectType plugin to enable clients to retrieve a revision history table for a specific query.
Simple testcases to verify that Intraday and Historical Table sizes match for a given partition.
The Checked Exception thrown when error occurs while processing NonSourceColumn data.
A Mutable adapter for converting
RowSequence into an OrderedKeys.Given a Core RowSet.Iterator present it as a Legacy OrderedKeys.Iterator.
The Checked Exception thrown when error occurs while processing NonSourceColumn data.
This is an Observable interface that allows
RowUpdateObserver to register.This is an Observer interface.
This defines a minimal interface with commonly accessed scheme-related methods
Implement behaviors common to all implementations.
Delegate all method calls to an implementation object.
Executes SchemaApiService PQ initialization
Processes SchemaApiServiceService plugin requests.
A class to track details of data source columns while inspecting data to infer schema.
Support classes and methods for use by the CSV and JDBC schema creator utilities.
An entry for a match pattern, formula template, and source/target data types to be used when creating
ImportSource entries for data import.
Replacement options for schema creator operations.
Protobuf type
io.deephaven.proto.schema.SchemaDeleteRequestProtobuf type
io.deephaven.proto.schema.SchemaDeleteRequest
Empty response indicates the operation completed
An error response will be sent if it fails
Empty response indicates the operation completed
An error response will be sent if it fails
Protobuf type
io.deephaven.proto.csv.SchemaFromCsvCommonProtobuf type
io.deephaven.proto.csv.SchemaFromCsvCommonProtobuf type
io.deephaven.proto.csv.SchemaFromCsvRequestProtobuf type
io.deephaven.proto.csv.SchemaFromCsvRequestProtobuf type
io.deephaven.proto.csv.SchemaFromCsvResponseProtobuf type
io.deephaven.proto.csv.SchemaFromCsvResponseProtobuf type
io.deephaven.proto.schema.SchemaGetXmlRequestProtobuf type
io.deephaven.proto.schema.SchemaGetXmlRequestProtobuf type
io.deephaven.proto.schema.SchemaGetXmlResponseProtobuf type
io.deephaven.proto.schema.SchemaGetXmlResponseThe SchemaHelper assists query-builders with creating and validating Deephaven Enterprise schemas from a Core+
KafkaTableWriter.Options instance.Helpers intended to assist in various conversions related to
Schema and SchemaServiceThis defines a complete schema, including additional metadata for import, logging, validation, and others.
The SchemaPluginRequest is `oneof` available schema messages.
The SchemaPluginRequest is `oneof` available schema messages.
Protobuf type
io.deephaven.proto.schema.SchemaPluginResponseProtobuf type
io.deephaven.proto.schema.SchemaPluginResponseProtobuf type
io.deephaven.proto.schema.SchemaSaveRequestProtobuf type
io.deephaven.proto.schema.SchemaSaveRequest
Empty response indicates the operation completed
An error response will be sent if it fails
Empty response indicates the operation completed
An error response will be sent if it fails
Provides methods for interacting with the system Schema store.
Delegate all method calls to an implementation object.
Factory class providing access to various implementations of
SchemaService to allow retrieval and
manipulation of table schemata.Protobuf type
io.deephaven.proto.schema.SchemaTableNamesExistRequestProtobuf type
io.deephaven.proto.schema.SchemaTableNamesExistRequestProtobuf type
io.deephaven.proto.schema.SchemaTableNamesExistResponseProtobuf type
io.deephaven.proto.schema.SchemaTableNamesExistResponseProtobuf type
io.deephaven.proto.schema.SchemaTableNamesRequestProtobuf type
io.deephaven.proto.schema.SchemaTableNamesRequestProtobuf type
io.deephaven.proto.schema.SchemaTableNamesResponseProtobuf type
io.deephaven.proto.schema.SchemaTableNamesResponse
No arguments
No arguments
Empty response indicates the operation completed
An error response will be sent if it fails
Empty response indicates the operation completed
An error response will be sent if it fails
Implementations provide access to secrets.
Implementations create instances of
SecretsProviders.The service for loading
SecretsProviders to be used with various authentication methods.Protobuf type
io.deephaven.proto.pqworker.SendJdbcPasswordRequestProtobuf type
io.deephaven.proto.pqworker.SendJdbcPasswordRequestProtobuf type
io.deephaven.proto.pqworker.SendJdbcPasswordResponseProtobuf type
io.deephaven.proto.pqworker.SendJdbcPasswordResponseUsed to store objects which may be needed by specialized query-types
Automatically generated Deephaven binary logger for DbInternal.ServerStateLogCoreV2 format 1
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.
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.Adapts a Legacy ColumnRegionShort to a Core ColumnRegionShort.
Simple data quality test logger.
An
AclFilterGenerator that simply applies the specified WhereFilters in Disjunctive Normal FormA simple immutable location snapshot.
This should be used when a non-null single partition value should be used for import.
SkipLinesInputStream adds functionality to another InputStream namely the ability to skip header or footer lines.
A
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
An
EnterpriseTableLocationKey implementation which is backed by a
TableLocationMetadataIndex.LocationSnapshot instanceUsed to assist in the creation of
SortHelperA helper utility used to potentially apply sort-ordering to a
PartitionedTable and
Tables based on creation-time directivesA provider object for creating row and column ACLs from the data source.
Specifies where to find the source table for a merge operation.
JDBC driver wrapper for Microsoft SQL Server.
Standard class for importer arguments.
Identifies how a table is serialized to disk
Parquet-format implementation of
StorageTypeFactoryProtobuf type
io.deephaven.proto.pqworker.StringListProtobuf type
io.deephaven.proto.pqworker.StringListAn Exception thrown when there is a problem completing a subscription
Implementations of this interface provide parameters for a
ConnectionAwareRemoteTable to maintain a
subscription to a remote table.Implementations of this interface can be used to construct a new
SubscriptionOptions.Utility to log
Table objects to System tables via the Log Aggregator Server.Options for writing a system table using a logger.
Leverages
BinaryRowLoggerDnd's LAS writer to log a specified DHC table's row set with an arbitrary table
definition.Specific exception for when a table size exceeds the transaction size limit.
Immutable descriptor for a TableDataService.
The standard factory for creating
TableDataService instances using a DataRoutingService instanceEach top level creation of a TableDataService requires recursive calls with access to a consistent context.
A compatibility class for converting enterprise
TableDefinition into community
TableDefinitionProtobuf type
io.deephaven.proto.csv.TableFromCsvRequestProtobuf type
io.deephaven.proto.csv.TableFromCsvRequest
Common fields for table from csv requests
Common fields for table from csv requests
the first object is the table
the first object is the table
A filter interface for determining whether a
TableKey should be accepted.Gets a listener for a particular table and application (binlog) version.
An helper for
TableLocationProvider implementations that can mark and sweep table locations based on if they
have been visited in the current cycle.This 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 collection of options that control the construction of a
live tableA Builder object for
TableOptionsThe replay configuration for one table.
A
TicketTransformer that handles transformation of Tables to apply ACLs at the edge.Mode used to validate a table.
Annotation indicating that a test is only for execution when in the TableValidationMode.FULL_DATABASE mode.
Annotation indicating that a test is only for execution when in the TableValidationMode.SIMPLE_TABLE mode.
A suite of data quality tests for a table.
Holder for a TableWriter and the processor for use in implementing an ingester.
This class can be used to generate identical tables in memory to the ones stored in the resources for this project.
Protobuf type
io.deephaven.proto.pqworker.ThreadDumpRequestProtobuf type
io.deephaven.proto.pqworker.ThreadDumpRequestProtobuf type
io.deephaven.proto.pqworker.ThreadDumpResponseProtobuf type
io.deephaven.proto.pqworker.ThreadDumpResponseImplementations 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.
A filter generator that specifies a Timestamp column and a period to either include or exclude recent values.
Implementors provide a method to adapt a Legacy
Chunk into a Core WritableChunk.Implementors provide a method to adapt a Core
Chunk into a Legacy
WritableChunk.Utilities for converting types from Core to Enterprise for use in ingesters.
An
UncoalescedTable implementation that wraps another uncoalesced table.We would like to be able to put all of the test data files in one package and reuse them.
Automatically generated Deephaven binary logger for DbInternal.UpdatePerformanceAncestors format 1
Automatically generated Deephaven binary logger for DbInternal.UpdatePerformanceLogCoreV2 format 4
This module injects the
PQUriResolver into the URI Resolver set for the worker.An
EnterpriseTableLocationKey implementation which provides a URI to back a
keyed locationDefines a
EnterpriseTableLocationKey which is backed by both a URI location
and a
TableLocationMetadataIndex.LocationSnapshotUnchecked exception representing issues with Core+ user input tables.
Unchecked exception representing an incompatible user table definition.
Unchecked exception representing a failure in deleting part or all of a user table.
Unchecked exception representing a failure in IO, e.g.
Unchecked exception representing a missing user table definition.
Unchecked exception representing a user table operation specifying a system namespace.
Unchecked exception representing insufficient access permissions to a user table operation.
Unchecked exception representing a preexisting user table definition.
Unchecked exception representing an incompatible table storage type.
Unchecked exception representing a failure in writing part or all of a user table.
A description of a table to be validated.
Executes WebClientData2 PQ initialization
Create object and tables associated with the WebClientData PQ
Create, manage lifetimes and cache tables created on behalf of particular users, based on controller subscriptions
for that user.
ObjectType plugin to enable clients to create parameterized tables.
We have not created a service, but rather make a request using the oneof message; and reply using the corresponding
message in the WebClientUtilsResponse.
We have not created a service, but rather make a request using the oneof message; and reply using the corresponding
message in the WebClientUtilsResponse.
Protobuf type
io.deephaven.proto.web.client.utils.WebClientUtilsResponseProtobuf type
io.deephaven.proto.web.client.utils.WebClientUtilsResponseService providing utility functions for web clients.
ObjectType plugin for Web Client Utils Service.
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.Automatically generated Deephaven binary logger for DbInternal.WorkspaceData format 2
Processes WorkspaceDataWriterService plugin requests to create and update rows in the WorkspaceData table.
Simple data class to represent the payload for an individual row in a write request to WorkspaceData
ObjectType plugin to enable clients to write to WorkspaceDataLogger
A Simple
GroupProvider that wraps the Enterprise implementation IrisGroupProviderInterface for writing tables to persistent Deephaven storage.
A
ReplayDatabase that also wraps a WritableDatabase.
IcebergStorageProvider