java.lang.Object
com.gpudb.GPUdbBase
com.gpudb.GPUdb
Object that provides access to a specific GPUdb server.
GPUdb instances are thread safe and may be used from any number of threads simultaneously.Nested Class Summary
Nested classes/interfaces inherited from class com.gpudb.GPUdbBase
GPUdbBase.ClusterAddressInfo, GPUdbBase.FailbackOptions, GPUdbBase.GetRecordsJsonResponse, GPUdbBase.GPUdbExitException, GPUdbBase.GPUdbFailoverDisabledException, GPUdbBase.GPUdbHAUnavailableException, GPUdbBase.GPUdbHostnameRegexFailureException, GPUdbBase.GPUdbUnauthorizedAccessException, GPUdbBase.GPUdbVersion, GPUdbBase.HAFailoverOrder, GPUdbBase.HASynchronicityMode, GPUdbBase.InsertRecordsJsonRequest, GPUdbBase.JsonOptions, GPUdbBase.Options, GPUdbBase.SubmitExceptionField Summary
Fields inherited from class com.gpudb.GPUdbBase
END_OF_SET, HEADER_AUTHORIZATION, HEADER_CONTENT_TYPE, HEADER_HA_SYNC_MODE, HEADER_USER_AGENT, PROTECTED_HEADERS, SslErrorMessageFormat, USER_AGENT_PROGRAM_NAMEConstructor Summary
ConstructorsConstructorDescriptionCreates aGPUdbinstance for the GPUdb server at the specified URL using default options.GPUdb(String url, GPUdbBase.Options options) Creates aGPUdbinstance for the GPUdb server at the specified URL using the specified options.Creates aGPUdbinstance for the GPUdb server at the specified URL using default options.GPUdb(URL url, GPUdbBase.Options options) Creates aGPUdbinstance for the GPUdb server at the specified URL using the specified options.Creates aGPUdbinstance for the GPUdb server with the specified URLs using default options.GPUdb(List<URL> urls, GPUdbBase.Options options) Creates aGPUdbinstance for the GPUdb server with the specified URLs using the specified options.Method Summary
Modifier and TypeMethodDescriptionadminAddHost(AdminAddHostRequest request) Adds a host to an existing cluster.adminAddHost(String hostAddress, Map<String, String> options) Adds a host to an existing cluster.adminAddRanks(AdminAddRanksRequest request) Add one or more ranks to an existing Kinetica cluster.adminAddRanks(List<String> hosts, List<Map<String, String>> configParams, Map<String, String> options) Add one or more ranks to an existing Kinetica cluster.adminAlterHost(AdminAlterHostRequest request) Alter properties on an existing host in the cluster.adminAlterHost(String host, Map<String, String> options) Alter properties on an existing host in the cluster.adminAlterJobs(AdminAlterJobsRequest request) Perform the requested action on a list of one or more job(s).Perform the requested action on a list of one or more job(s).adminBackupBegin(AdminBackupBeginRequest request) Prepares the system for a backup by closing all open file handles after allowing current active jobs to complete.adminBackupBegin(Map<String, String> options) Prepares the system for a backup by closing all open file handles after allowing current active jobs to complete.adminBackupEnd(AdminBackupEndRequest request) Restores the system to normal operating mode after a backup has completed, allowing any queries that were blocked to complete.adminBackupEnd(Map<String, String> options) Restores the system to normal operating mode after a backup has completed, allowing any queries that were blocked to complete.adminHaOffline(boolean offline, Map<String, String> options) Pauses consumption of messages from other HA clusters to support data repair/recovery scenarios.adminHaOffline(AdminHaOfflineRequest request) Pauses consumption of messages from other HA clusters to support data repair/recovery scenarios.adminHaRefresh(AdminHaRefreshRequest request) Restarts the HA processing on the given cluster as a mechanism of accepting breaking HA conf changes.adminHaRefresh(Map<String, String> options) Restarts the HA processing on the given cluster as a mechanism of accepting breaking HA conf changes.adminOffline(boolean offline, Map<String, String> options) Take the system offline.adminOffline(AdminOfflineRequest request) Take the system offline.adminRebalance(AdminRebalanceRequest request) Rebalance the data in the cluster so that all nodes contain an equal number of records approximately and/or rebalance the shards to be equally distributed (as much as possible) across all the ranks.adminRebalance(Map<String, String> options) Rebalance the data in the cluster so that all nodes contain an equal number of records approximately and/or rebalance the shards to be equally distributed (as much as possible) across all the ranks.adminRemoveHost(AdminRemoveHostRequest request) Removes a host from an existing cluster.adminRemoveHost(String host, Map<String, String> options) Removes a host from an existing cluster.adminRemoveRanks(AdminRemoveRanksRequest request) Remove one or more ranks from an existing Kinetica cluster.Remove one or more ranks from an existing Kinetica cluster.adminRepairTable(AdminRepairTableRequest request) Manually repair a corrupted table.adminRepairTable(List<String> tableNames, Map<String, String> tableTypes, Map<String, String> options) Manually repair a corrupted table.adminSendAlert(AdminSendAlertRequest request) Sends a user generated alert to the monitoring system.Sends a user generated alert to the monitoring system.adminShowAlerts(int numAlerts, Map<String, String> options) Requests a list of the most recent alerts.adminShowAlerts(AdminShowAlertsRequest request) Requests a list of the most recent alerts.adminShowClusterOperations(int historyIndex, Map<String, String> options) Requests the detailed status of the current operation (by default) or a prior cluster operation specified byhistoryIndex.Requests the detailed status of the current operation (by default) or a prior cluster operation specified byhistoryIndex.adminShowJobs(AdminShowJobsRequest request) Get a list of the current jobs in GPUdb.adminShowJobs(Map<String, String> options) Get a list of the current jobs in GPUdb.adminShowShards(AdminShowShardsRequest request) Show the mapping of shards to the corresponding rank and tom.adminShowShards(Map<String, String> options) Show the mapping of shards to the corresponding rank and tom.adminShutdown(AdminShutdownRequest request) Exits the database server application.Exits the database server application.adminSwitchover(AdminSwitchoverRequest request) Manually switch over one or more processes to another host.Manually switch over one or more processes to another host.adminVerifyDb(AdminVerifyDbRequest request) Verify database is in a consistent state.adminVerifyDb(Map<String, String> options) Verify database is in a consistent state.Calculates and returns the convex hull for the values in a table specified bytableName.aggregateConvexHull(String tableName, String xColumnName, String yColumnName, Map<String, String> options) Calculates and returns the convex hull for the values in a table specified bytableName.aggregateGroupBy(AggregateGroupByRequest request) Calculates unique combinations (groups) of values for the given columns in a given table or view and computes aggregates on each unique combination.aggregateGroupBy(String tableName, List<String> columnNames, long offset, long limit, Map<String, String> options) Calculates unique combinations (groups) of values for the given columns in a given table or view and computes aggregates on each unique combination.Calculates unique combinations (groups) of values for the given columns in a given table or view and computes aggregates on each unique combination.Performs a histogram calculation given a table, a column, and an interval function.aggregateHistogram(String tableName, String columnName, double start, double end, double interval, Map<String, String> options) Performs a histogram calculation given a table, a column, and an interval function.aggregateKMeans(AggregateKMeansRequest request) This endpoint runs the k-means algorithm - a heuristic algorithm that attempts to do k-means clustering.aggregateKMeans(String tableName, List<String> columnNames, int k, double tolerance, Map<String, String> options) This endpoint runs the k-means algorithm - a heuristic algorithm that attempts to do k-means clustering.aggregateMinMax(AggregateMinMaxRequest request) Calculates and returns the minimum and maximum values of a particular column in a table.Calculates and returns the minimum and maximum values of a particular column in a table.Calculates and returns the minimum and maximum x- and y-coordinates of a particular geospatial geometry column in a table.Calculates and returns the minimum and maximum x- and y-coordinates of a particular geospatial geometry column in a table.Calculates the requested statistics of the given column(s) in a given table.Calculates the requested statistics of the given column(s) in a given table.Divides the given set into bins and calculates statistics of the values of a value-column in each bin.aggregateStatisticsByRange(String tableName, String selectExpression, String columnName, String valueColumnName, String stats, double start, double end, double interval, Map<String, String> options) Divides the given set into bins and calculates statistics of the values of a value-column in each bin.aggregateUnique(AggregateUniqueRequest request) Returns all the unique values from a particular column (specified bycolumnName) of a particular table or view (specified bytableName).aggregateUnique(String tableName, String columnName, long offset, long limit, Map<String, String> options) Returns all the unique values from a particular column (specified bycolumnName) of a particular table or view (specified bytableName).aggregateUniqueRaw(AggregateUniqueRequest request) Returns all the unique values from a particular column (specified bycolumnName) of a particular table or view (specified bytableName).aggregateUnpivot(AggregateUnpivotRequest request) Rotate the column values into rows values.aggregateUnpivot(String tableName, List<String> columnNames, String variableColumnName, String valueColumnName, List<String> pivotedColumns, Map<String, String> options) Rotate the column values into rows values.Rotate the column values into rows values.alterBackup(AlterBackupRequest request) alterBackup(String backupName, String action, String value, String datasinkName, Map<String, String> options) alterCredential(AlterCredentialRequest request) Alter the properties of an existing credential.alterCredential(String credentialName, Map<String, String> credentialUpdatesMap, Map<String, String> options) Alter the properties of an existing credential.alterDatasink(AlterDatasinkRequest request) Alters the properties of an existing data sink.Alters the properties of an existing data sink.alterDatasource(AlterDatasourceRequest request) Alters the properties of an existing data source.Alters the properties of an existing data source.alterDirectory(AlterDirectoryRequest request) Alters an existing directory in KiFS.alterDirectory(String directoryName, Map<String, String> directoryUpdatesMap, Map<String, String> options) Alters an existing directory in KiFS.alterEnvironment(AlterEnvironmentRequest request) Alters an existing environment which can be referenced by a user-defined function (UDF).Alters an existing environment which can be referenced by a user-defined function (UDF).alterGraph(AlterGraphRequest request) alterModel(AlterModelRequest request) Alters the properties of an existing resource group to facilitate resource management.alterResourceGroup(String name, Map<String, Map<String, String>> tierAttributes, String ranking, String adjoiningResourceGroup, Map<String, String> options) Alters the properties of an existing resource group to facilitate resource management.alterRole(AlterRoleRequest request) Alters a Role.Alters a Role.alterSchema(AlterSchemaRequest request) Used to change the name of a SQL-style schema, specified inschemaName.Used to change the name of a SQL-style schema, specified inschemaName.ThealterSystemPropertiesendpoint is primarily used to simplify the testing of the system and is not expected to be used during normal execution.ThealterSystemPropertiesendpoint is primarily used to simplify the testing of the system and is not expected to be used during normal execution.alterTable(AlterTableRequest request) Apply various modifications to a table or view.Apply various modifications to a table or view.Apply various modifications to columns in a table, view.alterTableColumns(String tableName, List<Map<String, String>> columnAlterations, Map<String, String> options) Apply various modifications to columns in a table, view.Updates (adds or changes) metadata for tables.alterTableMetadata(List<String> tableNames, Map<String, String> metadataMap, Map<String, String> options) Updates (adds or changes) metadata for tables.Alters a table monitor previously created withcreateTableMonitor.Alters a table monitor previously created withcreateTableMonitor.alterTier(AlterTierRequest request) Alters properties of an existing tier to facilitate resource management.Alters properties of an existing tier to facilitate resource management.alterUser(AlterUserRequest request) Alters a user.Alters a user.alterVideo(AlterVideoRequest request) Alters a video.alterVideo(String path, Map<String, String> options) Alters a video.alterWal(AlterWalRequest request) Alters table write-ahead log (WAL) settings.Alters table write-ahead log (WAL) settings.appendRecords(AppendRecordsRequest request) Append (or insert) all records from a source table (specified bysourceTableName) to a particular target table (specified bytableName).appendRecords(String tableName, String sourceTableName, Map<String, String> fieldMap, Map<String, String> options) Append (or insert) all records from a source table (specified bysourceTableName) to a particular target table (specified bytableName).checkTable(CheckTableRequest request) Scans the requested tables as specified intableNamesfor integrity.Scans the requested tables as specified intableNamesfor integrity.clearStatistics(ClearStatisticsRequest request) Clears statistics (cardinality, mean value, etc.) for a column in a specified table.Clears statistics (cardinality, mean value, etc.) for a column in a specified table.clearTable(ClearTableRequest request) Clears (drops) one or all tables in the database cluster.Clears (drops) one or all tables in the database cluster.Deactivates a table monitor previously created withcreateTableMonitor.clearTableMonitor(String topicId, Map<String, String> options) Deactivates a table monitor previously created withcreateTableMonitor.clearTables(ClearTablesRequest request) Clears (drops) tables in the database cluster.Clears (drops) tables in the database cluster.clearTrigger(ClearTriggerRequest request) Clears or cancels the trigger identified by the specified handle.clearTrigger(String triggerId, Map<String, String> options) Clears or cancels the trigger identified by the specified handle.Collect statistics for a column(s) in a specified table.Collect statistics for a column(s) in a specified table.createBackup(CreateBackupRequest request) Creates a database backup, containing a snapshot of existing objects, at the remote file store accessible via the data sink specified bydatasinkName.createBackup(String backupName, String backupType, Map<String, String> backupObjectsMap, String datasinkName, Map<String, String> options) createCatalog(CreateCatalogRequest request) Creates a catalog, which contains the location and connection information for a deltalake catalog that is external to the database.createCatalog(String name, String tableFormat, String location, String type, String credential, String datasource, Map<String, String> options) Creates a catalog, which contains the location and connection information for a deltalake catalog that is external to the database.createContainerRegistry(String registryName, String uri, String credential, Map<String, String> options) createCredential(CreateCredentialRequest request) Create a new credential.createCredential(String credentialName, String type, String identity, String secret, Map<String, String> options) Create a new credential.createDatasink(CreateDatasinkRequest request) Creates a data sink, which contains the destination information for a data sink that is external to the database.Creates a data sink, which contains the destination information for a data sink that is external to the database.createDatasource(CreateDatasourceRequest request) Creates a data source, which contains the location and connection information for a data store that is external to the database.createDatasource(String name, String location, String userName, String password, Map<String, String> options) Creates a data source, which contains the location and connection information for a data store that is external to the database.createDeltaTable(CreateDeltaTableRequest request) createDirectory(CreateDirectoryRequest request) Creates a new directory in KiFS.createDirectory(String directoryName, Map<String, String> options) Creates a new directory in KiFS.Creates a new environment which can be used by user-defined functions (UDF).createEnvironment(String environmentName, Map<String, String> options) Creates a new environment which can be used by user-defined functions (UDF).createGraph(CreateGraphRequest request) Creates a new graph network using given nodes, edges, weights, and restrictions.createGraph(String graphName, boolean directedGraph, List<String> nodes, List<String> edges, List<String> weights, List<String> restrictions, Map<String, String> options) Creates a new graph network using given nodes, edges, weights, and restrictions.createJob(CreateJobRequest request) Create a job which will run asynchronously.createJob(String endpoint, String requestEncoding, ByteBuffer data, String dataStr, Map<String, String> options) Create a job which will run asynchronously.createJoinTable(CreateJoinTableRequest request) Creates a table that is the result of a SQL JOIN.createJoinTable(String joinTableName, List<String> tableNames, List<String> columnNames, List<String> expressions, Map<String, String> options) Creates a table that is the result of a SQL JOIN.Initiates the process of creating a materialized view, reserving the view’s name to prevent other views or tables from being created with that name.createMaterializedView(String tableName, Map<String, String> options) Initiates the process of creating a materialized view, reserving the view’s name to prevent other views or tables from being created with that name.createProc(CreateProcRequest request) Creates an instance (proc) of the user-defined functions (UDF) specified by the given command, options, and files, and makes it available for execution.createProc(String procName, String executionMode, Map<String, ByteBuffer> files, String command, List<String> args, Map<String, String> options) Creates an instance (proc) of the user-defined functions (UDF) specified by the given command, options, and files, and makes it available for execution.createProjection(CreateProjectionRequest request) Creates a new projection of an existing table.createProjection(String tableName, String projectionName, List<String> columnNames, Map<String, String> options) Creates a new projection of an existing table.Creates a new resource group to facilitate resource management.createResourceGroup(String name, Map<String, Map<String, String>> tierAttributes, String ranking, String adjoiningResourceGroup, Map<String, String> options) Creates a new resource group to facilitate resource management.createRole(CreateRoleRequest request) Creates a new role.createRole(String name, Map<String, String> options) Creates a new role.createSchema(CreateSchemaRequest request) Creates a SQL-style schema.createSchema(String schemaName, Map<String, String> options) Creates a SQL-style schema.createStateTable(CreateStateTableRequest request) createStateTable(String tableName, String inputTableName, String initTableName, Map<String, String> options) createTable(CreateTableRequest request) Creates a new table with the given type (definition of columns).Creates a new table with the given type (definition of columns).Creates a new external table, which is a local database object whose source data is located externally to the database.createTableExternal(String tableName, List<String> filepaths, Map<String, Map<String, String>> modifyColumns, Map<String, String> createTableOptions, Map<String, String> options) Creates a new external table, which is a local database object whose source data is located externally to the database.Creates a monitor that watches for a single table modification event type (insert, update, or delete) on a particular table (identified bytableName) and forwards event notifications to subscribers via ZMQ.createTableMonitor(String tableName, Map<String, String> options) Creates a monitor that watches for a single table modification event type (insert, update, or delete) on a particular table (identified bytableName) and forwards event notifications to subscribers via ZMQ.Sets up an area trigger mechanism for two column_names for one or more tables.createTriggerByArea(String requestId, List<String> tableNames, String xColumnName, List<Double> xVector, String yColumnName, List<Double> yVector, Map<String, String> options) Sets up an area trigger mechanism for two column_names for one or more tables.Sets up a simple range trigger for a column_name for one or more tables.createTriggerByRange(String requestId, List<String> tableNames, String columnName, double min, double max, Map<String, String> options) Sets up a simple range trigger for a column_name for one or more tables.createType(CreateTypeRequest request) Creates a new type describing the columns of a table.createType(String typeDefinition, String label, Map<String, List<String>> properties, Map<String, String> options) Creates a new type describing the columns of a table.createUnion(CreateUnionRequest request) Merges data from one or more tables with comparable data types into a new table.createUnion(String tableName, List<String> tableNames, List<List<String>> inputColumnNames, List<String> outputColumnNames, Map<String, String> options) Merges data from one or more tables with comparable data types into a new table.Creates a new external user (a user whose credentials are managed by an external LDAP).createUserExternal(String name, Map<String, String> options) Creates a new external user (a user whose credentials are managed by an external LDAP).Creates a new internal user (a user whose credentials are managed by the database system).Creates a new internal user (a user whose credentials are managed by the database system).createVideo(CreateVideoRequest request) Creates a job to generate a sequence of raster images that visualize data over a specified time.createVideo(String attribute, String begin, double durationSeconds, String end, double framesPerSecond, String style, String path, String styleParameters, Map<String, String> options) Creates a job to generate a sequence of raster images that visualize data over a specified time.deleteDirectory(DeleteDirectoryRequest request) Deletes a directory from KiFS.deleteDirectory(String directoryName, Map<String, String> options) Deletes a directory from KiFS.deleteFiles(DeleteFilesRequest request) Deletes one or more files from KiFS.Deletes one or more files from KiFS.deleteGraph(DeleteGraphRequest request) Deletes an existing graph from the graph server and/or persist.deleteGraph(String graphName, Map<String, String> options) Deletes an existing graph from the graph server and/or persist.deleteProc(DeleteProcRequest request) Deletes a proc.deleteProc(String procName, Map<String, String> options) Deletes a proc.deleteRecords(DeleteRecordsRequest request) Deletes record(s) matching the provided criteria from the given table.Deletes record(s) matching the provided criteria from the given table.Deletes a resource group.deleteResourceGroup(String name, Map<String, String> options) Deletes a resource group.deleteRole(DeleteRoleRequest request) Deletes an existing role.deleteRole(String name, Map<String, String> options) Deletes an existing role.deleteUser(DeleteUserRequest request) Deletes an existing user.deleteUser(String name, Map<String, String> options) Deletes an existing user.downloadFiles(DownloadFilesRequest request) Downloads one or more files from KiFS.downloadFiles(List<String> fileNames, List<Long> readOffsets, List<Long> readLengths, Map<String, String> options) Downloads one or more files from KiFS.dropBackup(DropBackupRequest request) Deletes one or more existing database backups and contained snapshots, accessible via the data sink specified bydatasinkName.dropCatalog(DropCatalogRequest request) Drops an existing catalog.dropCatalog(String name, Map<String, String> options) Drops an existing catalog.dropContainerRegistry(String registryName, Map<String, String> options) dropCredential(DropCredentialRequest request) Drop an existing credential.dropCredential(String credentialName, Map<String, String> options) Drop an existing credential.dropDatasink(DropDatasinkRequest request) Drops an existing data sink.dropDatasink(String name, Map<String, String> options) Drops an existing data sink.dropDatasource(DropDatasourceRequest request) Drops an existing data source.dropDatasource(String name, Map<String, String> options) Drops an existing data source.dropEnvironment(DropEnvironmentRequest request) Drop an existing user-defined function (UDF) environment.dropEnvironment(String environmentName, Map<String, String> options) Drop an existing user-defined function (UDF) environment.dropModel(DropModelRequest request) dropSchema(DropSchemaRequest request) Drops an existing SQL-style schema, specified inschemaName.dropSchema(String schemaName, Map<String, String> options) Drops an existing SQL-style schema, specified inschemaName.evaluateModel(EvaluateModelRequest request) evaluateModel(String modelName, int replicas, String deploymentMode, String sourceTable, String destinationTable, Map<String, String> options) executeProc(ExecuteProcRequest request) Executes a proc.executeProc(String procName, Map<String, String> params, Map<String, ByteBuffer> binParams, List<String> inputTableNames, Map<String, List<String>> inputColumnNames, List<String> outputTableNames, Map<String, String> options) Executes a proc.executeSql(ExecuteSqlRequest request) Execute a SQL statement (query, DML, or DDL).executeSql(String statement, long offset, long limit, String requestSchemaStr, List<ByteBuffer> data, Map<String, String> options) Execute a SQL statement (query, DML, or DDL).executeSqlRaw(ExecuteSqlRequest request) Execute a SQL statement (query, DML, or DDL).Export query metrics to a given destination.exportQueryMetrics(Map<String, String> options) Export query metrics to a given destination.Export records from a table to files.Export records from a table to files.Exports records from source table to the specified target table in an external database.Exports records from source table to the specified target table in an external database.filter(FilterRequest request) Filters data based on the specified expression.Filters data based on the specified expression.filterByArea(FilterByAreaRequest request) Calculates which objects from a table are within a named area of interest (NAI/polygon).filterByArea(String tableName, String viewName, String xColumnName, List<Double> xVector, String yColumnName, List<Double> yVector, Map<String, String> options) Calculates which objects from a table are within a named area of interest (NAI/polygon).Calculates which geospatial geometry objects from a table intersect a named area of interest (NAI/polygon).filterByAreaGeometry(String tableName, String viewName, String columnName, List<Double> xVector, List<Double> yVector, Map<String, String> options) Calculates which geospatial geometry objects from a table intersect a named area of interest (NAI/polygon).filterByBox(FilterByBoxRequest request) Calculates how many objects within the given table lie in a rectangular box.filterByBox(String tableName, String viewName, String xColumnName, double minX, double maxX, String yColumnName, double minY, double maxY, Map<String, String> options) Calculates how many objects within the given table lie in a rectangular box.Calculates which geospatial geometry objects from a table intersect a rectangular box.filterByBoxGeometry(String tableName, String viewName, String columnName, double minX, double maxX, double minY, double maxY, Map<String, String> options) Calculates which geospatial geometry objects from a table intersect a rectangular box.filterByGeometry(FilterByGeometryRequest request) Applies a geometry filter against a geospatial geometry column in a given table or view.filterByGeometry(String tableName, String viewName, String columnName, String inputWkt, String operation, Map<String, String> options) Applies a geometry filter against a geospatial geometry column in a given table or view.filterByList(FilterByListRequest request) Calculates which records from a table have values in the given list for the corresponding column.filterByList(String tableName, String viewName, Map<String, List<String>> columnValuesMap, Map<String, String> options) Calculates which records from a table have values in the given list for the corresponding column.filterByRadius(FilterByRadiusRequest request) Calculates which objects from a table lie within a circle with the given radius and center point (i.e. circular NAI).filterByRadius(String tableName, String viewName, String xColumnName, double xCenter, String yColumnName, double yCenter, double radius, Map<String, String> options) Calculates which objects from a table lie within a circle with the given radius and center point (i.e. circular NAI).Calculates which geospatial geometry objects from a table intersect a circle with the given radius and center point (i.e. circular NAI).filterByRadiusGeometry(String tableName, String viewName, String columnName, double xCenter, double yCenter, double radius, Map<String, String> options) Calculates which geospatial geometry objects from a table intersect a circle with the given radius and center point (i.e. circular NAI).filterByRange(FilterByRangeRequest request) Calculates which objects from a table have a column that is within the given bounds.filterByRange(String tableName, String viewName, String columnName, double lowerBound, double upperBound, Map<String, String> options) Calculates which objects from a table have a column that is within the given bounds.filterBySeries(FilterBySeriesRequest request) Filters objects matching all points of the given track (works only on track type data).filterBySeries(String tableName, String viewName, String trackId, List<String> targetTrackIds, Map<String, String> options) Filters objects matching all points of the given track (works only on track type data).filterByString(FilterByStringRequest request) Calculates which objects from a table or view match a string expression for the given string columns.filterByString(String tableName, String viewName, String expression, String mode, List<String> columnNames, Map<String, String> options) Calculates which objects from a table or view match a string expression for the given string columns.filterByTable(FilterByTableRequest request) Filters objects in one table based on objects in another table.filterByTable(String tableName, String viewName, String columnName, String sourceTableName, String sourceTableColumnName, Map<String, String> options) Filters objects in one table based on objects in another table.filterByValue(FilterByValueRequest request) Calculates which objects from a table has a particular value for a particular column.filterByValue(String tableName, String viewName, boolean isString, double value, String valueStr, String columnName, Map<String, String> options) Calculates which objects from a table has a particular value for a particular column.getGraphEntities(GetGraphEntitiesRequest request) Retrieves node or edge entities from an existing graph, with pagination support via offset and limit.getGraphEntities(String graphName, long offset, long limit, Map<String, String> options) Retrieves node or edge entities from an existing graph, with pagination support via offset and limit.Get the status and result of asynchronously running job.getJob(GetJobRequest request) Get the status and result of asynchronously running job.<TResponse>
GetRecordsResponse<TResponse> getRecords(GetRecordsRequest request) Retrieves records from a given table, optionally filtered by an expression and/or sorted by a column.<TResponse>
GetRecordsResponse<TResponse> getRecords(Object typeDescriptor, GetRecordsRequest request) Retrieves records from a given table, optionally filtered by an expression and/or sorted by a column.<TResponse>
GetRecordsResponse<TResponse> getRecords(Object typeDescriptor, String tableName, long offset, long limit, Map<String, String> options) Retrieves records from a given table, optionally filtered by an expression and/or sorted by a column.<TResponse>
GetRecordsResponse<TResponse> getRecords(String tableName, long offset, long limit, Map<String, String> options) Retrieves records from a given table, optionally filtered by an expression and/or sorted by a column.For a given table, retrieves the values from the requested column(s).getRecordsByColumn(String tableName, List<String> columnNames, long offset, long limit, Map<String, String> options) For a given table, retrieves the values from the requested column(s).For a given table, retrieves the values from the requested column(s).<TResponse>
GetRecordsBySeriesResponse<TResponse> Retrieves the complete series/track records from the givenworldTableNamebased on the partial track information contained in thetableName.<TResponse>
GetRecordsBySeriesResponse<TResponse> getRecordsBySeries(Object typeDescriptor, GetRecordsBySeriesRequest request) Retrieves the complete series/track records from the givenworldTableNamebased on the partial track information contained in thetableName.<TResponse>
GetRecordsBySeriesResponse<TResponse> getRecordsBySeries(Object typeDescriptor, String tableName, String worldTableName, int offset, int limit, Map<String, String> options) Retrieves the complete series/track records from the givenworldTableNamebased on the partial track information contained in thetableName.<TResponse>
GetRecordsBySeriesResponse<TResponse> getRecordsBySeries(String tableName, String worldTableName, int offset, int limit, Map<String, String> options) Retrieves the complete series/track records from the givenworldTableNamebased on the partial track information contained in thetableName.Retrieves the complete series/track records from the givenworldTableNamebased on the partial track information contained in thetableName.<TResponse>
GetRecordsFromCollectionResponse<TResponse> Retrieves records from a collection.<TResponse>
GetRecordsFromCollectionResponse<TResponse> getRecordsFromCollection(Object typeDescriptor, GetRecordsFromCollectionRequest request) Retrieves records from a collection.<TResponse>
GetRecordsFromCollectionResponse<TResponse> getRecordsFromCollection(Object typeDescriptor, String tableName, long offset, long limit, Map<String, String> options) Retrieves records from a collection.<TResponse>
GetRecordsFromCollectionResponse<TResponse> getRecordsFromCollection(String tableName, long offset, long limit, Map<String, String> options) Retrieves records from a collection.Retrieves records from a collection.getRecordsRaw(GetRecordsRequest request) Retrieves records from a given table, optionally filtered by an expression and/or sorted by a column.getVectortile(GetVectortileRequest request) getVectortile(List<String> tableNames, List<String> columnNames, Map<String, List<String>> layers, int tileX, int tileY, int zoom, Map<String, String> options) grantPermission(GrantPermissionRequest request) Grant user or role the specified permission on the specified object.grantPermission(String principal, String object, String objectType, String permission, Map<String, String> options) Grant user or role the specified permission on the specified object.[DEPRECATED—please usegrantPermissioninstead] Grants a credential-level permission to a user or role.grantPermissionCredential(String name, String permission, String credentialName, Map<String, String> options) [DEPRECATED—please usegrantPermissioninstead] Grants a credential-level permission to a user or role.[DEPRECATED—please usegrantPermissioninstead] Grants a data source permission to a user or role.grantPermissionDatasource(String name, String permission, String datasourceName, Map<String, String> options) [DEPRECATED—please usegrantPermissioninstead] Grants a data source permission to a user or role.[DEPRECATED—please usegrantPermissioninstead] Grants a KiFS directory-level permission to a user or role.grantPermissionDirectory(String name, String permission, String directoryName, Map<String, String> options) [DEPRECATED—please usegrantPermissioninstead] Grants a KiFS directory-level permission to a user or role.[DEPRECATED—please usegrantPermissioninstead] Grants a proc-level permission to a user or role.[DEPRECATED—please usegrantPermissioninstead] Grants a proc-level permission to a user or role.[DEPRECATED—please usegrantPermissioninstead] Grants a system-level permission to a user or role.[DEPRECATED—please usegrantPermissioninstead] Grants a system-level permission to a user or role.[DEPRECATED—please usegrantPermissioninstead] Grants a table-level permission to a user or role.grantPermissionTable(String name, String permission, String tableName, String filterExpression, Map<String, String> options) [DEPRECATED—please usegrantPermissioninstead] Grants a table-level permission to a user or role.grantRole(GrantRoleRequest request) Grants membership in a role to a user or role.Grants membership in a role to a user or role.hasPermission(HasPermissionRequest request) Checks if the specified user has the specified permission on the specified object.hasPermission(String principal, String object, String objectType, String permission, Map<String, String> options) Checks if the specified user has the specified permission on the specified object.hasProc(HasProcRequest request) Checks the existence of a proc with the given name.Checks the existence of a proc with the given name.hasRole(HasRoleRequest request) Checks if the specified user has the specified role.Checks if the specified user has the specified role.hasSchema(HasSchemaRequest request) Checks for the existence of a schema with the given name.Checks for the existence of a schema with the given name.hasTable(HasTableRequest request) Checks for the existence of a table with the given name.Checks for the existence of a table with the given name.hasType(HasTypeRequest request) Check for the existence of a type.Check for the existence of a type.importModel(ImportModelRequest request) importModel(String modelName, String registryName, String container, String runFunction, String modelType, Map<String, String> options) <TRequest> InsertRecordsResponseinsertRecords(InsertRecordsRequest<TRequest> request) Adds multiple records to the specified table.<TRequest> InsertRecordsResponseinsertRecords(TypeObjectMap<TRequest> typeObjectMap, InsertRecordsRequest<TRequest> request) Adds multiple records to the specified table.<TRequest> InsertRecordsResponseinsertRecords(TypeObjectMap<TRequest> typeObjectMap, String tableName, List<TRequest> data, Map<String, String> options) Adds multiple records to the specified table.<TRequest> InsertRecordsResponseAdds multiple records to the specified table.Reads from one or more files and inserts the data into a new or existing table.insertRecordsFromFiles(String tableName, List<String> filepaths, Map<String, Map<String, String>> modifyColumns, Map<String, String> createTableOptions, Map<String, String> options) Reads from one or more files and inserts the data into a new or existing table.Reads from the given text-based or binary payload and inserts the data into a new or existing table.insertRecordsFromPayload(String tableName, String dataText, ByteBuffer dataBytes, Map<String, Map<String, String>> modifyColumns, Map<String, String> createTableOptions, Map<String, String> options) Reads from the given text-based or binary payload and inserts the data into a new or existing table.Computes remote query result and inserts the result data into a new or existing table.insertRecordsFromQuery(String tableName, String remoteQuery, Map<String, Map<String, String>> modifyColumns, Map<String, String> createTableOptions, Map<String, String> options) Computes remote query result and inserts the result data into a new or existing table.Generates a specified number of random records and adds them to the given table.Generates a specified number of random records and adds them to the given table.insertRecordsRaw(RawInsertRecordsRequest request) Adds multiple records to the specified table.insertSymbol(InsertSymbolRequest request) Adds a symbol or icon (i.e. an image) to represent data points when data is rendered visually.insertSymbol(String symbolId, String symbolFormat, ByteBuffer symbolData, Map<String, String> options) Adds a symbol or icon (i.e. an image) to represent data points when data is rendered visually.killProc(KillProcRequest request) Kills a running proc instance.Kills a running proc instance.listGraph(ListGraphRequest request) lockTable(LockTableRequest request) Manages global access to a table’s data.Manages global access to a table’s data.matchGraph(MatchGraphRequest request) Matches a directed route implied by a given set of latitude/longitude points to an existing underlying road network graph using a given solution type.matchGraph(String graphName, List<String> samplePoints, String solveMethod, String solutionTable, Map<String, String> options) Matches a directed route implied by a given set of latitude/longitude points to an existing underlying road network graph using a given solution type.modifyGraph(ModifyGraphRequest request) Update an existing graph network using given nodes, edges, weights, restrictions, and options.modifyGraph(String graphName, List<String> nodes, List<String> edges, List<String> weights, List<String> restrictions, Map<String, String> options) Update an existing graph network using given nodes, edges, weights, restrictions, and options.queryGraph(QueryGraphRequest request) Employs a topological query on a graph generated a-priori bycreateGraphand returns a list of adjacent edge(s) or node(s), also known as an adjacency list, depending on what’s been provided to the endpoint; providing edges will return nodes and providing nodes will return edges.queryGraph(String graphName, List<String> queries, List<String> restrictions, String adjacencyTable, int rings, Map<String, String> options) Employs a topological query on a graph generated a-priori bycreateGraphand returns a list of adjacent edge(s) or node(s), also known as an adjacency list, depending on what’s been provided to the endpoint; providing edges will return nodes and providing nodes will return edges.repartitionGraph(RepartitionGraphRequest request) Rebalances an existing partitioned graph.repartitionGraph(String graphName, Map<String, String> options) Rebalances an existing partitioned graph.reserveResource(ReserveResourceRequest request) reserveResource(String component, String name, String action, long bytesRequested, long ownerId, Map<String, String> options) restoreBackup(RestoreBackupRequest request) restoreBackup(String backupName, Map<String, String> restoreObjectsMap, String datasourceName, Map<String, String> options) revokePermission(RevokePermissionRequest request) Revoke user or role the specified permission on the specified object.revokePermission(String principal, String object, String objectType, String permission, Map<String, String> options) Revoke user or role the specified permission on the specified object.[DEPRECATED—please userevokePermissioninstead] Revokes a credential-level permission from a user or role.revokePermissionCredential(String name, String permission, String credentialName, Map<String, String> options) [DEPRECATED—please userevokePermissioninstead] Revokes a credential-level permission from a user or role.[DEPRECATED—please userevokePermissioninstead] Revokes a data source permission from a user or role.revokePermissionDatasource(String name, String permission, String datasourceName, Map<String, String> options) [DEPRECATED—please userevokePermissioninstead] Revokes a data source permission from a user or role.[DEPRECATED—please userevokePermissioninstead] Revokes a KiFS directory-level permission from a user or role.revokePermissionDirectory(String name, String permission, String directoryName, Map<String, String> options) [DEPRECATED—please userevokePermissioninstead] Revokes a KiFS directory-level permission from a user or role.[DEPRECATED—please userevokePermissioninstead] Revokes a proc-level permission from a user or role.[DEPRECATED—please userevokePermissioninstead] Revokes a proc-level permission from a user or role.[DEPRECATED—please userevokePermissioninstead] Revokes a system-level permission from a user or role.[DEPRECATED—please userevokePermissioninstead] Revokes a system-level permission from a user or role.[DEPRECATED—please userevokePermissioninstead] Revokes a table-level permission from a user or role.[DEPRECATED—please userevokePermissioninstead] Revokes a table-level permission from a user or role.revokeRole(RevokeRoleRequest request) Revokes membership in a role from a user or role.Revokes membership in a role from a user or role.showBackup(ShowBackupRequest request) Shows information about one or more backups accessible via the data source specified bydatasourceName.Shows information about one or more backups accessible via the data source specified bydatasourceName.showContainerRegistry(String registryName, Map<String, String> options) showCredential(ShowCredentialRequest request) Shows information about a specified credential or all credentials.showCredential(String credentialName, Map<String, String> options) Shows information about a specified credential or all credentials.showDatasink(ShowDatasinkRequest request) Shows information about a specified data sink or all data sinks.showDatasink(String name, Map<String, String> options) Shows information about a specified data sink or all data sinks.showDatasource(ShowDatasourceRequest request) Shows information about a specified data source or all data sources.showDatasource(String name, Map<String, String> options) Shows information about a specified data source or all data sources.showDirectories(ShowDirectoriesRequest request) Shows information about directories in KiFS.showDirectories(String directoryName, Map<String, String> options) Shows information about directories in KiFS.showEnvironment(ShowEnvironmentRequest request) Shows information about a specified user-defined function (UDF) environment or all environments.showEnvironment(String environmentName, Map<String, String> options) Shows information about a specified user-defined function (UDF) environment or all environments.showFiles(ShowFilesRequest request) Shows information about files in KiFS.Shows information about files in KiFS.showFunctions(ShowFunctionsRequest request) showGraph(ShowGraphRequest request) Shows information and characteristics of graphs that exist on the graph server.Shows information and characteristics of graphs that exist on the graph server.showGraphGrammar(ShowGraphGrammarRequest request) showGraphGrammar(Map<String, String> options) showModel(ShowModelRequest request) showProc(ShowProcRequest request) Shows information about a proc.Shows information about a proc.showProcStatus(ShowProcStatusRequest request) Shows the statuses of running or completed proc instances.showProcStatus(String runId, Map<String, String> options) Shows the statuses of running or completed proc instances.Requests resource group properties.Requests resource group properties.Returns information about the internal sub-components (tiered objects) which use resources of the system.showResourceObjects(Map<String, String> options) Returns information about the internal sub-components (tiered objects) which use resources of the system.Requests various statistics for storage/memory tiers and resource groups.showResourceStatistics(Map<String, String> options) Requests various statistics for storage/memory tiers and resource groups.showSchema(ShowSchemaRequest request) Retrieves information about a schema (or all schemas), as specified inschemaName.showSchema(String schemaName, Map<String, String> options) Retrieves information about a schema (or all schemas), as specified inschemaName.showSecurity(ShowSecurityRequest request) Shows security information relating to users and/or roles.Shows security information relating to users and/or roles.showSqlProc(ShowSqlProcRequest request) Shows information about SQL procedures, including the full definition of each requested procedure.showSqlProc(String procedureName, Map<String, String> options) Shows information about SQL procedures, including the full definition of each requested procedure.showStatistics(ShowStatisticsRequest request) Retrieves the collected column statistics for the specified table(s).Retrieves the collected column statistics for the specified table(s).Returns server configuration and version related information to the caller.showSystemProperties(Map<String, String> options) Returns server configuration and version related information to the caller.showSystemStatus(ShowSystemStatusRequest request) Provides server configuration and health related status to the caller.showSystemStatus(Map<String, String> options) Provides server configuration and health related status to the caller.showSystemTiming(ShowSystemTimingRequest request) Returns the last 100 database requests along with the request timing and internal job ID.showSystemTiming(Map<String, String> options) Returns the last 100 database requests along with the request timing and internal job ID.showTable(ShowTableRequest request) Retrieves detailed information about a table, view, or schema, specified intableName.Retrieves detailed information about a table, view, or schema, specified intableName.Retrieves the user provided metadata for the specified tables.Retrieves the user provided metadata for the specified tables.Show table monitors and their properties.Show table monitors and their properties.showTablesByType(ShowTablesByTypeRequest request) Gets names of the tables whose type matches the given criteria.Gets names of the tables whose type matches the given criteria.showTriggers(ShowTriggersRequest request) Retrieves information regarding the specified triggers or all existing triggers currently active.Retrieves information regarding the specified triggers or all existing triggers currently active.showTypes(ShowTypesRequest request) Retrieves information for the specified data type ID or type label.Retrieves information for the specified data type ID or type label.showVideo(ShowVideoRequest request) Retrieves information about rendered videos.Retrieves information about rendered videos.showWal(ShowWalRequest request) Requests table write-ahead log (WAL) properties.Requests table write-ahead log (WAL) properties.solveGraph(SolveGraphRequest request) Solves an existing graph for a type of problem (e.g., shortest path, page rank, traveling salesman, etc.) using source nodes, destination nodes, and additional, optional weights and restrictions.solveGraph(String graphName, List<String> weightsOnEdges, List<String> restrictions, String solverType, List<String> sourceNodes, List<String> destinationNodes, String solutionTable, Map<String, String> options) Solves an existing graph for a type of problem (e.g., shortest path, page rank, traveling salesman, etc.) using source nodes, destination nodes, and additional, optional weights and restrictions.<TRequest> UpdateRecordsResponseupdateRecords(UpdateRecordsRequest<TRequest> request) Runs multiple predicate-based updates in a single call.<TRequest> UpdateRecordsResponseupdateRecords(TypeObjectMap<TRequest> typeObjectMap, UpdateRecordsRequest<TRequest> request) Runs multiple predicate-based updates in a single call.<TRequest> UpdateRecordsResponseupdateRecords(TypeObjectMap<TRequest> typeObjectMap, String tableName, List<String> expressions, List<Map<String, String>> newValuesMaps, List<TRequest> data, Map<String, String> options) Runs multiple predicate-based updates in a single call.<TRequest> UpdateRecordsResponseupdateRecords(String tableName, List<String> expressions, List<Map<String, String>> newValuesMaps, List<TRequest> data, Map<String, String> options) Runs multiple predicate-based updates in a single call.updateRecordsRaw(RawUpdateRecordsRequest request) Runs multiple predicate-based updates in a single call.uploadFiles(UploadFilesRequest request) Uploads one or more files to KiFS.uploadFiles(List<String> fileNames, List<ByteBuffer> fileData, Map<String, String> options) Uploads one or more files to KiFS.Uploads one or more files to KiFS.Uploads one or more files to KiFS.verifyBackup(VerifyBackupRequest request) Inspects the requested database backup(s) for conformity at the remote file store accessible via the data source specified bydatasourceName.Inspects the requested database backup(s) for conformity at the remote file store accessible via the data source specified bydatasourceName.visualizeGetFeatureInfo(List<String> tableNames, List<String> xColumnNames, List<String> yColumnNames, List<String> geometryColumnNames, List<List<String>> queryColumnNames, String projection, double minX, double maxX, double minY, double maxY, int width, int height, int x, int y, int radius, long limit, String encoding, Map<String, String> options) visualizeImage(VisualizeImageRequest request) visualizeImage(List<String> tableNames, List<String> worldTableNames, String xColumnName, String yColumnName, String symbolColumnName, String geometryColumnName, List<List<String>> trackIds, double minX, double maxX, double minY, double maxY, int width, int height, String projection, long bgColor, Map<String, List<String>> styleOptions, Map<String, String> options) Scatter plot is the only plot type currently supported.visualizeImageChart(String tableName, List<String> xColumnNames, List<String> yColumnNames, double minX, double maxX, double minY, double maxY, int width, int height, String bgColor, Map<String, List<String>> styleOptions, Map<String, String> options) Scatter plot is the only plot type currently supported.visualizeImageClassbreak(List<String> tableNames, List<String> worldTableNames, String xColumnName, String yColumnName, String symbolColumnName, String geometryColumnName, List<List<String>> trackIds, String cbAttr, List<String> cbVals, String cbPointcolorAttr, List<String> cbPointcolorVals, String cbPointalphaAttr, List<String> cbPointalphaVals, String cbPointsizeAttr, List<String> cbPointsizeVals, String cbPointshapeAttr, List<String> cbPointshapeVals, double minX, double maxX, double minY, double maxY, int width, int height, String projection, long bgColor, Map<String, List<String>> styleOptions, Map<String, String> options, List<Integer> cbTransparencyVec) visualizeImageContour(List<String> tableNames, String xColumnName, String yColumnName, String valueColumnName, double minX, double maxX, double minY, double maxY, int width, int height, String projection, Map<String, String> styleOptions, Map<String, String> options) visualizeImageHeatmap(List<String> tableNames, String xColumnName, String yColumnName, String valueColumnName, String geometryColumnName, double minX, double maxX, double minY, double maxY, int width, int height, String projection, Map<String, String> styleOptions, Map<String, String> options) visualizeImageLabels(String tableName, String xColumnName, String yColumnName, String xOffset, String yOffset, String textString, String font, String textColor, String textAngle, String textScale, String drawBox, String drawLeader, String lineWidth, String lineColor, String fillColor, String leaderXColumnName, String leaderYColumnName, String filter, double minX, double maxX, double minY, double maxY, int width, int height, String projection, Map<String, String> options) Generate an image containing isolines for travel results using an existing graph.visualizeIsochrone(String graphName, String sourceNode, double maxSolutionRadius, List<String> weightsOnEdges, List<String> restrictions, int numLevels, boolean generateImage, String levelsTable, Map<String, String> styleOptions, Map<String, String> solveOptions, Map<String, String> contourOptions, Map<String, String> options) Generate an image containing isolines for travel results using an existing graph.Methods inherited from class com.gpudb.GPUdbBase
addHttpHeader, addKnownType, addKnownType, addKnownTypeFromTable, addKnownTypeFromTable, addKnownTypeObjectMap, buildUserAgent, createAuthorizationHeader, createHASyncModeHeader, decode, decode, decode, decodeMultiple, decodeMultiple, encode, encode, execute, execute, execute, finalize, getApiVersion, getAuthorizationFromHttpHeaders, getBypassSslCertCheck, getClientName, getClientVersion, getClusterInfo, getExecutor, getFailoverURLs, getHARingInfo, getHARingSize, getHASyncMode, getHmURL, getHmURLs, getHostAddresses, getHttpHeaders, getMaxRetries, getNumClusterSwitches, getOptions, getPassword, getPrimaryHostname, getPrimaryUrl, getRecordsJson, getRecordsJson, getRecordsJson, getRecordsJson, getRecordsJson, getRecordsJson, getServerVersion, getSystemProperties, getThreadCount, getTimeout, getTypeDescriptor, getTypeObjectMap, getURL, getURLs, getUserAgent, getUsername, getUseSnappy, incrementNumClusterSwitches, initializeHttpConnection, initializeHttpConnection, initializeHttpPostRequest, initializeHttpPostRequest, insertRecordsFromJson, insertRecordsFromJson, insertRecordsFromJson, isAutoDiscoveryEnabled, isKineticaRunning, list, options, ping, ping, ping, query, query, query, removeHttpHeader, removeProtectedHttpHeaders, selectNextCluster, setHASyncMode, setHostManagerPort, setTypeDescriptorIfMissing, submitRequest, submitRequest, submitRequest, submitRequest, submitRequest, submitRequest, submitRequest, submitRequest, submitRequestRaw, submitRequestRaw, submitRequestRaw, submitRequestRaw, submitRequestRaw, submitRequestRaw, submitRequestToHM, submitRequestToHM, switchURL