Package | Description |
---|---|
com.gpudb | |
com.gpudb.filesystem | |
com.gpudb.filesystem.common | |
com.gpudb.filesystem.download | |
com.gpudb.filesystem.ingest | |
com.gpudb.filesystem.upload |
Modifier and Type | Class and Description |
---|---|
static class |
BulkInserter.InsertException
An exception that occurred during the insertion of records into GPUdb.
|
static class |
GPUdbBase.GPUdbExitException
A special exception indicating the server is shutting down
|
static class |
GPUdbBase.GPUdbFailoverDisabledException |
static class |
GPUdbBase.GPUdbHAUnavailableException |
static class |
GPUdbBase.GPUdbHostnameRegexFailureException |
static class |
GPUdbBase.GPUdbUnauthorizedAccessException
Indicates that there is an authorization-related problem occurred.
|
static class |
GPUdbBase.SubmitException
An exception that occurred during the submission of a request to GPUdb.
|
Modifier and Type | Method and Description | ||||||||||||||||||||||||
---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
void |
GPUdbBase.addHttpHeader(String header,
String value)
Adds an HTTP header to the map of additional HTTP headers to send to
GPUdb with each request.
|
||||||||||||||||||||||||
<T> void |
GPUdbBase.addKnownTypeFromTable(String tableName,
Class<T> objectClass,
TypeObjectMap<T> typeObjectMap)
Adds a type object map for the specified class as a type descriptor for
the GPUdb type stored in the specified table to the known type list, and
also adds the type object map to the known type object map list.
|
||||||||||||||||||||||||
void |
GPUdbBase.addKnownTypeFromTable(String tableName,
Object typeDescriptor)
Adds a type descriptor for the GPUdb type stored in the specified table
to the known type list.
|
||||||||||||||||||||||||
AdminAddHostResponse |
GPUdb.adminAddHost(AdminAddHostRequest request)
Adds a host to an existing cluster.
|
||||||||||||||||||||||||
AdminAddHostResponse |
GPUdb.adminAddHost(String hostAddress,
Map<String,String> options)
Adds a host to an existing cluster.
|
||||||||||||||||||||||||
AdminAddRanksResponse |
GPUdb.adminAddRanks(AdminAddRanksRequest request)
Add one or more ranks to an existing Kinetica cluster.
|
||||||||||||||||||||||||
AdminAddRanksResponse |
GPUdb.adminAddRanks(List<String> hosts,
List<Map<String,String>> configParams,
Map<String,String> options)
Add one or more ranks to an existing Kinetica cluster.
|
||||||||||||||||||||||||
AdminAlterHostResponse |
GPUdb.adminAlterHost(AdminAlterHostRequest request)
Alter properties on an existing host in the cluster.
|
||||||||||||||||||||||||
AdminAlterHostResponse |
GPUdb.adminAlterHost(String host,
Map<String,String> options)
Alter properties on an existing host in the cluster.
|
||||||||||||||||||||||||
AdminAlterJobsResponse |
GPUdb.adminAlterJobs(AdminAlterJobsRequest request)
Perform the requested action on a list of one or more job(s).
|
||||||||||||||||||||||||
AdminAlterJobsResponse |
GPUdb.adminAlterJobs(List<Long> jobIds,
String action,
Map<String,String> options)
Perform the requested action on a list of one or more job(s).
|
||||||||||||||||||||||||
AdminBackupBeginResponse |
GPUdb.adminBackupBegin(AdminBackupBeginRequest request)
Prepares the system for a backup by closing all open file handles after
allowing current active jobs to complete.
|
||||||||||||||||||||||||
AdminBackupBeginResponse |
GPUdb.adminBackupBegin(Map<String,String> options)
Prepares the system for a backup by closing all open file handles after
allowing current active jobs to complete.
|
||||||||||||||||||||||||
AdminBackupEndResponse |
GPUdb.adminBackupEnd(AdminBackupEndRequest request)
Restores the system to normal operating mode after a backup has
completed, allowing any queries that were blocked to complete.
|
||||||||||||||||||||||||
AdminBackupEndResponse |
GPUdb.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.
|
||||||||||||||||||||||||
AdminHaRefreshResponse |
GPUdb.adminHaRefresh(AdminHaRefreshRequest request)
Restarts the HA processing on the given cluster as a mechanism of
accepting breaking HA conf changes.
|
||||||||||||||||||||||||
AdminHaRefreshResponse |
GPUdb.adminHaRefresh(Map<String,String> options)
Restarts the HA processing on the given cluster as a mechanism of
accepting breaking HA conf changes.
|
||||||||||||||||||||||||
AdminOfflineResponse |
GPUdb.adminOffline(AdminOfflineRequest request)
Take the system offline.
|
||||||||||||||||||||||||
AdminOfflineResponse |
GPUdb.adminOffline(boolean offline,
Map<String,String> options)
Take the system offline.
|
||||||||||||||||||||||||
AdminRebalanceResponse |
GPUdb.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.
|
||||||||||||||||||||||||
AdminRebalanceResponse |
GPUdb.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.
|
||||||||||||||||||||||||
AdminRemoveHostResponse |
GPUdb.adminRemoveHost(AdminRemoveHostRequest request)
Removes a host from an existing cluster.
|
||||||||||||||||||||||||
AdminRemoveHostResponse |
GPUdb.adminRemoveHost(String host,
Map<String,String> options)
Removes a host from an existing cluster.
|
||||||||||||||||||||||||
AdminRemoveRanksResponse |
GPUdb.adminRemoveRanks(AdminRemoveRanksRequest request)
Remove one or more ranks from an existing Kinetica cluster.
|
||||||||||||||||||||||||
AdminRemoveRanksResponse |
GPUdb.adminRemoveRanks(List<String> ranks,
Map<String,String> options)
Remove one or more ranks from an existing Kinetica cluster.
|
||||||||||||||||||||||||
AdminShowAlertsResponse |
GPUdb.adminShowAlerts(AdminShowAlertsRequest request)
Requests a list of the most recent alerts.
|
||||||||||||||||||||||||
AdminShowAlertsResponse |
GPUdb.adminShowAlerts(int numAlerts,
Map<String,String> options)
Requests a list of the most recent alerts.
|
||||||||||||||||||||||||
AdminShowClusterOperationsResponse |
GPUdb.adminShowClusterOperations(AdminShowClusterOperationsRequest request)
Requests the detailed status of the current operation (by default) or a
prior cluster operation specified by
historyIndex . |
||||||||||||||||||||||||
AdminShowClusterOperationsResponse |
GPUdb.adminShowClusterOperations(int historyIndex,
Map<String,String> options)
Requests the detailed status of the current operation (by default) or a
prior cluster operation specified by
historyIndex . |
||||||||||||||||||||||||
AdminShowJobsResponse |
GPUdb.adminShowJobs(AdminShowJobsRequest request)
Get a list of the current jobs in GPUdb.
|
||||||||||||||||||||||||
AdminShowJobsResponse |
GPUdb.adminShowJobs(Map<String,String> options)
Get a list of the current jobs in GPUdb.
|
||||||||||||||||||||||||
AdminShowShardsResponse |
GPUdb.adminShowShards(AdminShowShardsRequest request)
Show the mapping of shards to the corresponding rank and tom.
|
||||||||||||||||||||||||
AdminShowShardsResponse |
GPUdb.adminShowShards(Map<String,String> options)
Show the mapping of shards to the corresponding rank and tom.
|
||||||||||||||||||||||||
AdminShutdownResponse |
GPUdb.adminShutdown(AdminShutdownRequest request)
Exits the database server application.
|
||||||||||||||||||||||||
AdminShutdownResponse |
GPUdb.adminShutdown(String exitType,
String authorization,
Map<String,String> options)
Exits the database server application.
|
||||||||||||||||||||||||
AdminSwitchoverResponse |
GPUdb.adminSwitchover(AdminSwitchoverRequest request)
Manually switch over one or more processes to another host.
|
||||||||||||||||||||||||
AdminSwitchoverResponse |
GPUdb.adminSwitchover(List<String> processes,
List<String> destinations,
Map<String,String> options)
Manually switch over one or more processes to another host.
|
||||||||||||||||||||||||
AdminVerifyDbResponse |
GPUdb.adminVerifyDb(AdminVerifyDbRequest request)
Verify database is in a consistent state.
|
||||||||||||||||||||||||
AdminVerifyDbResponse |
GPUdb.adminVerifyDb(Map<String,String> options)
Verify database is in a consistent state.
|
||||||||||||||||||||||||
AggregateConvexHullResponse |
GPUdb.aggregateConvexHull(AggregateConvexHullRequest request)
Calculates and returns the convex hull for the values in a table
specified by
tableName . |
||||||||||||||||||||||||
AggregateConvexHullResponse |
GPUdb.aggregateConvexHull(String tableName,
String xColumnName,
String yColumnName,
Map<String,String> options)
Calculates and returns the convex hull for the values in a table
specified by
tableName . |
||||||||||||||||||||||||
AggregateGroupByResponse |
GPUdb.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.
|
||||||||||||||||||||||||
AggregateGroupByResponse |
GPUdb.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.
|
||||||||||||||||||||||||
RawAggregateGroupByResponse |
GPUdb.aggregateGroupByRaw(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.
|
||||||||||||||||||||||||
AggregateHistogramResponse |
GPUdb.aggregateHistogram(AggregateHistogramRequest request)
Performs a histogram calculation given a table, a column, and an
interval function.
|
||||||||||||||||||||||||
AggregateHistogramResponse |
GPUdb.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.
|
||||||||||||||||||||||||
AggregateKMeansResponse |
GPUdb.aggregateKMeans(AggregateKMeansRequest request)
This endpoint runs the k-means algorithm - a heuristic algorithm
that attempts to do k-means clustering.
|
||||||||||||||||||||||||
AggregateKMeansResponse |
GPUdb.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.
|
||||||||||||||||||||||||
AggregateMinMaxResponse |
GPUdb.aggregateMinMax(AggregateMinMaxRequest request)
Calculates and returns the minimum and maximum values of a particular
column in a table.
|
||||||||||||||||||||||||
AggregateMinMaxResponse |
GPUdb.aggregateMinMax(String tableName,
String columnName,
Map<String,String> options)
Calculates and returns the minimum and maximum values of a particular
column in a table.
|
||||||||||||||||||||||||
AggregateMinMaxGeometryResponse |
GPUdb.aggregateMinMaxGeometry(AggregateMinMaxGeometryRequest request)
Calculates and returns the minimum and maximum x- and y-coordinates
of a particular geospatial geometry column in a table.
|
||||||||||||||||||||||||
AggregateMinMaxGeometryResponse |
GPUdb.aggregateMinMaxGeometry(String tableName,
String columnName,
Map<String,String> options)
Calculates and returns the minimum and maximum x- and y-coordinates
of a particular geospatial geometry column in a table.
|
||||||||||||||||||||||||
AggregateStatisticsResponse |
GPUdb.aggregateStatistics(AggregateStatisticsRequest request)
Calculates the requested statistics of the given column(s) in a
given table.
|
||||||||||||||||||||||||
AggregateStatisticsResponse |
GPUdb.aggregateStatistics(String tableName,
String columnName,
String stats,
Map<String,String> options)
Calculates the requested statistics of the given column(s) in a
given table.
|
||||||||||||||||||||||||
AggregateStatisticsByRangeResponse |
GPUdb.aggregateStatisticsByRange(AggregateStatisticsByRangeRequest request)
Divides the given set into bins and calculates statistics of the
values of a value-column in each bin.
|
||||||||||||||||||||||||
AggregateStatisticsByRangeResponse |
GPUdb.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.
|
||||||||||||||||||||||||
AggregateUniqueResponse |
GPUdb.aggregateUnique(AggregateUniqueRequest request)
Returns all the unique values from a particular column
(specified by
columnName ) of a particular table or view
(specified by tableName ). |
||||||||||||||||||||||||
AggregateUniqueResponse |
GPUdb.aggregateUnique(String tableName,
String columnName,
long offset,
long limit,
Map<String,String> options)
Returns all the unique values from a particular column
(specified by
columnName ) of a particular table or view
(specified by tableName ). |
||||||||||||||||||||||||
RawAggregateUniqueResponse |
GPUdb.aggregateUniqueRaw(AggregateUniqueRequest request)
Returns all the unique values from a particular column
(specified by
columnName ) of a particular table or view
(specified by tableName ). |
||||||||||||||||||||||||
AggregateUnpivotResponse |
GPUdb.aggregateUnpivot(AggregateUnpivotRequest request)
Rotate the column values into rows values.
|
||||||||||||||||||||||||
AggregateUnpivotResponse |
GPUdb.aggregateUnpivot(String tableName,
List<String> columnNames,
String variableColumnName,
String valueColumnName,
List<String> pivotedColumns,
Map<String,String> options)
Rotate the column values into rows values.
|
||||||||||||||||||||||||
RawAggregateUnpivotResponse |
GPUdb.aggregateUnpivotRaw(AggregateUnpivotRequest request)
Rotate the column values into rows values.
|
||||||||||||||||||||||||
AlterCredentialResponse |
GPUdb.alterCredential(AlterCredentialRequest request)
Alter the properties of an existing
AlterCredentialResponse GPUdb. | alterCredential(String credentialName,
Map<String,String> credentialUpdatesMap,
Map<String,String> options)
Alter the properties of an existing
AlterDatasinkResponse GPUdb. | alterDatasink(AlterDatasinkRequest request)
Alters the properties of an existing
AlterDatasinkResponse GPUdb. | alterDatasink(String name,
Map<String,String> datasinkUpdatesMap,
Map<String,String> options)
Alters the properties of an existing
AlterDatasourceResponse GPUdb. | alterDatasource(AlterDatasourceRequest request)
Alters the properties of an existing
AlterDatasourceResponse GPUdb. | alterDatasource(String name,
Map<String,String> datasourceUpdatesMap,
Map<String,String> options)
Alters the properties of an existing
AlterDirectoryResponse GPUdb. | alterDirectory(AlterDirectoryRequest request)
Alters an existing directory in
AlterDirectoryResponse GPUdb. | alterDirectory(String directoryName,
Map<String,String> directoryUpdatesMap,
Map<String,String> options)
Alters an existing directory in
AlterEnvironmentResponse GPUdb. | alterEnvironment(AlterEnvironmentRequest request)
Alters an existing environment which can be referenced by a
AlterEnvironmentResponse GPUdb. | alterEnvironment(String environmentName,
String action,
String value,
Map<String,String> options)
Alters an existing environment which can be referenced by a
AlterGraphResponse GPUdb. |
alterGraph(AlterGraphRequest request) | ||||||||||||||
AlterGraphResponse |
GPUdb.alterGraph(String graphName,
String action,
String actionArg,
Map<String,String> options) |
||||||||||||||||||||||||
AlterModelResponse |
GPUdb.alterModel(AlterModelRequest request) |
||||||||||||||||||||||||
AlterModelResponse |
GPUdb.alterModel(String modelName,
String action,
String value,
Map<String,String> options) |
||||||||||||||||||||||||
AlterResourceGroupResponse |
GPUdb.alterResourceGroup(AlterResourceGroupRequest request)
Alters the properties of an exisiting resource group to facilitate
resource management.
|
||||||||||||||||||||||||
AlterResourceGroupResponse |
GPUdb.alterResourceGroup(String name,
Map<String,Map<String,String>> tierAttributes,
String ranking,
String adjoiningResourceGroup,
Map<String,String> options)
Alters the properties of an exisiting resource group to facilitate
resource management.
|
||||||||||||||||||||||||
AlterRoleResponse |
GPUdb.alterRole(AlterRoleRequest request)
Alters a Role.
|
||||||||||||||||||||||||
AlterRoleResponse |
GPUdb.alterRole(String name,
String action,
String value,
Map<String,String> options)
Alters a Role.
|
||||||||||||||||||||||||
AlterSchemaResponse |
GPUdb.alterSchema(AlterSchemaRequest request)
Used to change the name of a SQL-style
AlterSchemaResponse GPUdb. | alterSchema(String schemaName,
String action,
String value,
Map<String,String> options)
Used to change the name of a SQL-style
AlterSystemPropertiesResponse GPUdb. |
alterSystemProperties(AlterSystemPropertiesRequest request)
The
GPUdb.alterSystemProperties(AlterSystemPropertiesRequest)
endpoint is primarily used to simplify the testing of the system and is
not expected to be used during normal execution. | ||||||||||||||||||||||
AlterSystemPropertiesResponse |
GPUdb.alterSystemProperties(Map<String,String> propertyUpdatesMap,
Map<String,String> options)
The
GPUdb.alterSystemProperties(Map, Map) endpoint is primarily
used to simplify the testing of the system and is not expected to be
used during normal execution. |
||||||||||||||||||||||||
AlterTableResponse |
GPUdb.alterTable(AlterTableRequest request)
Apply various modifications to a table or view.
|
||||||||||||||||||||||||
AlterTableResponse |
GPUdb.alterTable(String tableName,
String action,
String value,
Map<String,String> options)
Apply various modifications to a table or view.
|
||||||||||||||||||||||||
AlterTableColumnsResponse |
GPUdb.alterTableColumns(AlterTableColumnsRequest request)
Apply various modifications to columns in a table, view.
|
||||||||||||||||||||||||
AlterTableColumnsResponse |
GPUdb.alterTableColumns(String tableName,
List<Map<String,String>> columnAlterations,
Map<String,String> options)
Apply various modifications to columns in a table, view.
|
||||||||||||||||||||||||
AlterTableMetadataResponse |
GPUdb.alterTableMetadata(AlterTableMetadataRequest request)
Updates (adds or changes) metadata for tables.
|
||||||||||||||||||||||||
AlterTableMetadataResponse |
GPUdb.alterTableMetadata(List<String> tableNames,
Map<String,String> metadataMap,
Map<String,String> options)
Updates (adds or changes) metadata for tables.
|
||||||||||||||||||||||||
AlterTableMonitorResponse |
GPUdb.alterTableMonitor(AlterTableMonitorRequest request)
Alters a table monitor previously created with
GPUdb.createTableMonitor(CreateTableMonitorRequest) . |
||||||||||||||||||||||||
AlterTableMonitorResponse |
GPUdb.alterTableMonitor(String topicId,
Map<String,String> monitorUpdatesMap,
Map<String,String> options)
Alters a table monitor previously created with
GPUdb.createTableMonitor(String, Map) . |
||||||||||||||||||||||||
AlterTierResponse |
GPUdb.alterTier(AlterTierRequest request)
Alters properties of an exisiting
AlterTierResponse GPUdb. | alterTier(String name,
Map<String,String> options)
Alters properties of an exisiting
AlterUserResponse GPUdb. |
alterUser(AlterUserRequest request)
Alters a user.
| ||||||||||||||||||||||
AlterUserResponse |
GPUdb.alterUser(String name,
String action,
String value,
Map<String,String> options)
Alters a user.
|
||||||||||||||||||||||||
AlterVideoResponse |
GPUdb.alterVideo(AlterVideoRequest request)
Alters a video.
|
||||||||||||||||||||||||
AlterVideoResponse |
GPUdb.alterVideo(String path,
Map<String,String> options)
Alters a video.
|
||||||||||||||||||||||||
AppendRecordsResponse |
GPUdb.appendRecords(AppendRecordsRequest request)
Append (or insert) all records from a source table
(specified by
sourceTableName ) to a particular target table
(specified by tableName ). |
||||||||||||||||||||||||
AppendRecordsResponse |
GPUdb.appendRecords(String tableName,
String sourceTableName,
Map<String,String> fieldMap,
Map<String,String> options)
Append (or insert) all records from a source table
(specified by
sourceTableName ) to a particular target table
(specified by tableName ). |
||||||||||||||||||||||||
ClearStatisticsResponse |
GPUdb.clearStatistics(ClearStatisticsRequest request)
Clears statistics (cardinality, mean value, etc.) for a column in a
specified table.
|
||||||||||||||||||||||||
ClearStatisticsResponse |
GPUdb.clearStatistics(String tableName,
String columnName,
Map<String,String> options)
Clears statistics (cardinality, mean value, etc.) for a column in a
specified table.
|
||||||||||||||||||||||||
ClearTableResponse |
GPUdb.clearTable(ClearTableRequest request)
Clears (drops) one or all tables in the database cluster.
|
||||||||||||||||||||||||
ClearTableResponse |
GPUdb.clearTable(String tableName,
String authorization,
Map<String,String> options)
Clears (drops) one or all tables in the database cluster.
|
||||||||||||||||||||||||
ClearTableMonitorResponse |
GPUdb.clearTableMonitor(ClearTableMonitorRequest request)
Deactivates a table monitor previously created with
GPUdb.createTableMonitor(CreateTableMonitorRequest) . |
||||||||||||||||||||||||
ClearTableMonitorResponse |
GPUdb.clearTableMonitor(String topicId,
Map<String,String> options)
Deactivates a table monitor previously created with
GPUdb.createTableMonitor(String, Map) . |
||||||||||||||||||||||||
ClearTriggerResponse |
GPUdb.clearTrigger(ClearTriggerRequest request)
Clears or cancels the trigger identified by the specified handle.
|
||||||||||||||||||||||||
ClearTriggerResponse |
GPUdb.clearTrigger(String triggerId,
Map<String,String> options)
Clears or cancels the trigger identified by the specified handle.
|
||||||||||||||||||||||||
CollectStatisticsResponse |
GPUdb.collectStatistics(CollectStatisticsRequest request)
Collect statistics for a column(s) in a specified table.
|
||||||||||||||||||||||||
CollectStatisticsResponse |
GPUdb.collectStatistics(String tableName,
List<String> columnNames,
Map<String,String> options)
Collect statistics for a column(s) in a specified table.
|
||||||||||||||||||||||||
String |
Type.create(GPUdb gpudb)
Creates a type in GPUdb based on the metadata in the
Type object
and returns the type ID for reference. |
||||||||||||||||||||||||
CreateContainerRegistryResponse |
GPUdb.createContainerRegistry(CreateContainerRegistryRequest request) |
||||||||||||||||||||||||
CreateContainerRegistryResponse |
GPUdb.createContainerRegistry(String registryName,
String uri,
String credential,
Map<String,String> options) |
||||||||||||||||||||||||
CreateCredentialResponse |
GPUdb.createCredential(CreateCredentialRequest request)
Create a new
CreateCredentialResponse GPUdb. | createCredential(String credentialName,
String type,
String identity,
String secret,
Map<String,String> options)
Create a new
CreateDatasinkResponse GPUdb. | createDatasink(CreateDatasinkRequest request)
Creates a
CreateDatasinkResponse GPUdb. | createDatasink(String name,
String destination,
Map<String,String> options)
Creates a
CreateDatasourceResponse GPUdb. | createDatasource(CreateDatasourceRequest request)
Creates a
CreateDatasourceResponse GPUdb. | createDatasource(String name,
String location,
String userName,
String password,
Map<String,String> options)
| |||||||||||||||||||
CreateDeltaTableResponse |
GPUdb.createDeltaTable(String deltaTableName,
String tableName,
Map<String,String> options) |
||||||||||||||||||||||||
CreateDirectoryResponse |
GPUdb.createDirectory(CreateDirectoryRequest request)
Creates a new directory in
CreateDirectoryResponse GPUdb. | createDirectory(String directoryName,
Map<String,String> options)
Creates a new directory in
CreateEnvironmentResponse GPUdb. | createEnvironment(CreateEnvironmentRequest request)
Creates a new environment which can be used by
CreateEnvironmentResponse GPUdb. | createEnvironment(String environmentName,
Map<String,String> options)
Creates a new environment which can be used by
CreateGraphResponse GPUdb. |
createGraph(CreateGraphRequest request)
Creates a new graph network using given nodes, edges, weights, and
restrictions.
| ||||||||||||||||||||
CreateGraphResponse |
GPUdb.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.
|
||||||||||||||||||||||||
CreateJobResponse |
GPUdb.createJob(CreateJobRequest request)
Create a job which will run asynchronously.
|
||||||||||||||||||||||||
CreateJobResponse |
GPUdb.createJob(String endpoint,
String requestEncoding,
ByteBuffer data,
String dataStr,
Map<String,String> options)
Create a job which will run asynchronously.
|
||||||||||||||||||||||||
CreateJoinTableResponse |
GPUdb.createJoinTable(CreateJoinTableRequest request)
Creates a table that is the result of a SQL JOIN.
|
||||||||||||||||||||||||
CreateJoinTableResponse |
GPUdb.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.
|
||||||||||||||||||||||||
CreateMaterializedViewResponse |
GPUdb.createMaterializedView(CreateMaterializedViewRequest request)
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.
|
||||||||||||||||||||||||
CreateMaterializedViewResponse |
GPUdb.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.
|
||||||||||||||||||||||||
CreateProcResponse |
GPUdb.createProc(CreateProcRequest request)
Creates an instance (proc) of the
CreateProcResponse GPUdb. | createProc(String procName,
String executionMode,
Map<String,ByteBuffer> files,
String command,
List<String> args,
Map<String,String> options)
Creates an instance (proc) of the
CreateProjectionResponse GPUdb. | createProjection(CreateProjectionRequest request)
Creates a new
CreateProjectionResponse GPUdb. | createProjection(String tableName,
String projectionName,
List<String> columnNames,
Map<String,String> options)
Creates a new
CreateResourceGroupResponse GPUdb. |
createResourceGroup(CreateResourceGroupRequest request)
Creates a new resource group to facilitate resource management.
| ||||||||||||||||||||
CreateResourceGroupResponse |
GPUdb.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.
|
||||||||||||||||||||||||
CreateRoleResponse |
GPUdb.createRole(CreateRoleRequest request)
Creates a new role.
|
||||||||||||||||||||||||
CreateRoleResponse |
GPUdb.createRole(String name,
Map<String,String> options)
Creates a new role.
|
||||||||||||||||||||||||
CreateSchemaResponse |
GPUdb.createSchema(CreateSchemaRequest request)
Creates a SQL-style
CreateSchemaResponse GPUdb. | createSchema(String schemaName,
Map<String,String> options)
Creates a SQL-style
CreateStateTableResponse GPUdb. |
createStateTable(CreateStateTableRequest request) | ||||||||||||||||||||||
CreateStateTableResponse |
GPUdb.createStateTable(String tableName,
String inputTableName,
String initTableName,
Map<String,String> options) |
||||||||||||||||||||||||
CreateTableResponse |
GPUdb.createTable(CreateTableRequest request)
Creates a new table.
|
||||||||||||||||||||||||
CreateTableResponse |
GPUdb.createTable(String tableName,
String typeId,
Map<String,String> options)
Creates a new table.
|
||||||||||||||||||||||||
CreateTableExternalResponse |
GPUdb.createTableExternal(CreateTableExternalRequest request)
Creates a new
CreateTableExternalResponse GPUdb. | createTableExternal(String tableName,
List<String> filepaths,
Map<String,Map<String,String>> modifyColumns,
Map<String,String> createTableOptions,
Map<String,String> options)
Creates a new
CreateTableMonitorResponse GPUdb. |
createTableMonitor(CreateTableMonitorRequest request)
Creates a monitor that watches for a single table modification event
type (insert, update, or delete) on a particular table (identified by
tableName ) and forwards event notifications to subscribers via
ZMQ. | ||||||||||||||||||||||
CreateTableMonitorResponse |
GPUdb.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 by
tableName ) and forwards event notifications to subscribers via
ZMQ. |
||||||||||||||||||||||||
CreateTriggerByAreaResponse |
GPUdb.createTriggerByArea(CreateTriggerByAreaRequest request)
Sets up an area trigger mechanism for two column_names for one or
more tables.
|
||||||||||||||||||||||||
CreateTriggerByAreaResponse |
GPUdb.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.
|
||||||||||||||||||||||||
CreateTriggerByRangeResponse |
GPUdb.createTriggerByRange(CreateTriggerByRangeRequest request)
Sets up a simple range trigger for a column_name for one or more
tables.
|
||||||||||||||||||||||||
CreateTriggerByRangeResponse |
GPUdb.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.
|
||||||||||||||||||||||||
static String |
RecordObject.createType(Class<? extends RecordObject> type,
GPUdb gpudb)
Creates a type in GPUdb based on the metadata in the specified
RecordObject class and returns the type ID for reference. |
||||||||||||||||||||||||
CreateTypeResponse |
GPUdb.createType(CreateTypeRequest request)
Creates a new type describing the layout of a table.
|
||||||||||||||||||||||||
String |
TypeObjectMap.createType(GPUdb gpudb)
Creates a type in GPUdb based on the metadata in the specified
TypeObjectMap object and returns the type ID for reference. |
||||||||||||||||||||||||
CreateTypeResponse |
GPUdb.createType(String typeDefinition,
String label,
Map<String,List<String>> properties,
Map<String,String> options)
Creates a new type describing the layout of a table.
|
||||||||||||||||||||||||
CreateUnionResponse |
GPUdb.createUnion(CreateUnionRequest request)
Merges data from one or more tables with comparable data types into a
new table.
|
||||||||||||||||||||||||
CreateUnionResponse |
GPUdb.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.
|
||||||||||||||||||||||||
CreateUserExternalResponse |
GPUdb.createUserExternal(CreateUserExternalRequest request)
Creates a new external user (a user whose credentials are managed by an
external LDAP).
|
||||||||||||||||||||||||
CreateUserExternalResponse |
GPUdb.createUserExternal(String name,
Map<String,String> options)
Creates a new external user (a user whose credentials are managed by an
external LDAP).
|
||||||||||||||||||||||||
CreateUserInternalResponse |
GPUdb.createUserInternal(CreateUserInternalRequest request)
Creates a new internal user (a user whose credentials are managed by the
database system).
|
||||||||||||||||||||||||
CreateUserInternalResponse |
GPUdb.createUserInternal(String name,
String password,
Map<String,String> options)
Creates a new internal user (a user whose credentials are managed by the
database system).
|
||||||||||||||||||||||||
CreateVideoResponse |
GPUdb.createVideo(CreateVideoRequest request)
Creates a job to generate a sequence of raster images that visualize
data over a specified time.
|
||||||||||||||||||||||||
CreateVideoResponse |
GPUdb.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.
|
||||||||||||||||||||||||
protected <T> List<T> |
GPUdbBase.decode(List<String> typeIds,
List<ByteBuffer> data) |
||||||||||||||||||||||||
static <T> T |
Avro.decode(Object typeDescriptor,
ByteBuffer encodedObject)
Decodes an Avro binary object.
|
||||||||||||||||||||||||
protected <T> List<T> |
GPUdbBase.decode(Object typeDescriptor,
List<ByteBuffer> data) |
||||||||||||||||||||||||
static <T> List<T> |
Avro.decode(Object typeDescriptor,
List<ByteBuffer> encodedObjects)
Decodes a homogeneous list of Avro binary objects.
|
||||||||||||||||||||||||
static <T> List<T> |
Avro.decode(Object typeDescriptor,
List<ByteBuffer> encodedObjects,
int threadCount,
ExecutorService executor)
Decodes a homogeneous list of Avro binary objects, optionally using
multiple threads and/or a supplied executor.
|
||||||||||||||||||||||||
static <T> List<T> |
Avro.decode(Object typeDescriptor,
List<ByteBuffer> encodedObjects,
int start,
int count)
Decodes a homogeneous portion of a list of Avro binary objects.
|
||||||||||||||||||||||||
static <T> List<T> |
Avro.decode(Object typeDescriptor,
List<ByteBuffer> encodedObjects,
int start,
int count,
int threadCount,
ExecutorService executor)
Decodes a homogeneous portion of a list of Avro binary objects,
optionally using multiple threads, with or without a supplied executor.
|
||||||||||||||||||||||||
protected <T> List<T> |
GPUdbBase.decode(String typeId,
List<ByteBuffer> data) |
||||||||||||||||||||||||
static <T extends org.apache.avro.generic.IndexedRecord> |
Avro.decode(T object,
ByteBuffer encodedObject)
Decodes an Avro binary object into a pre-created destination object.
|
||||||||||||||||||||||||
protected <T> List<List<T>> |
GPUdbBase.decodeMultiple(List<String> typeIds,
List<List<ByteBuffer>> data) |
||||||||||||||||||||||||
protected <T> List<List<T>> |
GPUdbBase.decodeMultiple(Object typeDescriptor,
List<List<ByteBuffer>> data) |
||||||||||||||||||||||||
DeleteDirectoryResponse |
GPUdb.deleteDirectory(DeleteDirectoryRequest request)
Deletes a directory from
DeleteDirectoryResponse GPUdb. | deleteDirectory(String directoryName,
Map<String,String> options)
Deletes a directory from
DeleteFilesResponse GPUdb. | deleteFiles(DeleteFilesRequest request)
Deletes one or more files from
DeleteFilesResponse GPUdb. | deleteFiles(List<String> fileNames,
Map<String,String> options)
Deletes one or more files from
DeleteGraphResponse GPUdb. |
deleteGraph(DeleteGraphRequest request)
Deletes an existing graph from the graph server and/or persist.
| ||||||||||||||||||||
DeleteGraphResponse |
GPUdb.deleteGraph(String graphName,
Map<String,String> options)
Deletes an existing graph from the graph server and/or persist.
|
||||||||||||||||||||||||
DeleteProcResponse |
GPUdb.deleteProc(DeleteProcRequest request)
Deletes a proc.
|
||||||||||||||||||||||||
DeleteProcResponse |
GPUdb.deleteProc(String procName,
Map<String,String> options)
Deletes a proc.
|
||||||||||||||||||||||||
DeleteRecordsResponse |
GPUdb.deleteRecords(DeleteRecordsRequest request)
Deletes record(s) matching the provided criteria from the given table.
|
||||||||||||||||||||||||
DeleteRecordsResponse |
GPUdb.deleteRecords(String tableName,
List<String> expressions,
Map<String,String> options)
Deletes record(s) matching the provided criteria from the given table.
|
||||||||||||||||||||||||
DeleteResourceGroupResponse |
GPUdb.deleteResourceGroup(DeleteResourceGroupRequest request)
Deletes a resource group.
|
||||||||||||||||||||||||
DeleteResourceGroupResponse |
GPUdb.deleteResourceGroup(String name,
Map<String,String> options)
Deletes a resource group.
|
||||||||||||||||||||||||
DeleteRoleResponse |
GPUdb.deleteRole(DeleteRoleRequest request)
Deletes an existing role.
|
||||||||||||||||||||||||
DeleteRoleResponse |
GPUdb.deleteRole(String name,
Map<String,String> options)
Deletes an existing role.
|
||||||||||||||||||||||||
DeleteUserResponse |
GPUdb.deleteUser(DeleteUserRequest request)
Deletes an existing user.
|
||||||||||||||||||||||||
DeleteUserResponse |
GPUdb.deleteUser(String name,
Map<String,String> options)
Deletes an existing user.
|
||||||||||||||||||||||||
DownloadFilesResponse |
GPUdb.downloadFiles(DownloadFilesRequest request)
Downloads one or more files from
DownloadFilesResponse GPUdb. | downloadFiles(List<String> fileNames,
List<Long> readOffsets,
List<Long> readLengths,
Map<String,String> options)
Downloads one or more files from
DropContainerRegistryResponse GPUdb. |
dropContainerRegistry(DropContainerRegistryRequest request) | ||||||||||||||||||||||
DropContainerRegistryResponse |
GPUdb.dropContainerRegistry(String registryName,
Map<String,String> options) |
||||||||||||||||||||||||
DropCredentialResponse |
GPUdb.dropCredential(DropCredentialRequest request)
Drop an existing
DropCredentialResponse GPUdb. | dropCredential(String credentialName,
Map<String,String> options)
Drop an existing
DropDatasinkResponse GPUdb. | dropDatasink(DropDatasinkRequest request)
Drops an existing
DropDatasinkResponse GPUdb. | dropDatasink(String name,
Map<String,String> options)
Drops an existing
DropDatasourceResponse GPUdb. | dropDatasource(DropDatasourceRequest request)
Drops an existing
DropDatasourceResponse GPUdb. | dropDatasource(String name,
Map<String,String> options)
Drops an existing
DropEnvironmentResponse GPUdb. | dropEnvironment(DropEnvironmentRequest request)
Drop an existing
DropEnvironmentResponse GPUdb. | dropEnvironment(String environmentName,
Map<String,String> options)
| |||||||||||||||||
DropModelResponse |
GPUdb.dropModel(String modelName,
Map<String,String> options) |
||||||||||||||||||||||||
DropSchemaResponse |
GPUdb.dropSchema(DropSchemaRequest request)
Drops an existing SQL-style
DropSchemaResponse GPUdb. | dropSchema(String schemaName,
Map<String,String> options)
| |||||||||||||||||||||||
static <T> ArrayList<ByteBuffer> |
Avro.encode(List<T> objects)
Encodes a list of Avro-compatible objects into Avro binary format.
|
||||||||||||||||||||||||
static <T extends org.apache.avro.generic.IndexedRecord> |
Avro.encode(T object)
Encodes an Avro-compatible object into Avro binary format.
|
||||||||||||||||||||||||
protected <T> List<ByteBuffer> |
GPUdbBase.encode(TypeObjectMap<T> typeObjectMap,
List<T> data) |
||||||||||||||||||||||||
static <T> ByteBuffer |
Avro.encode(TypeObjectMap<T> typeObjectMap,
T object)
Encodes a non-Avro-compatible object into Avro binary format using the
specified type object map.
|
||||||||||||||||||||||||
EvaluateModelResponse |
GPUdb.evaluateModel(EvaluateModelRequest request) |
||||||||||||||||||||||||
EvaluateModelResponse |
GPUdb.evaluateModel(String modelName,
int replicas,
String deploymentMode,
String sourceTable,
String destinationTable,
Map<String,String> options) |
||||||||||||||||||||||||
ExecuteProcResponse |
GPUdb.executeProc(ExecuteProcRequest request)
Executes a proc.
|
||||||||||||||||||||||||
ExecuteProcResponse |
GPUdb.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.
|
||||||||||||||||||||||||
ExecuteSqlResponse |
GPUdb.executeSql(ExecuteSqlRequest request)
Execute a SQL statement (query, DML, or DDL).
|
||||||||||||||||||||||||
ExecuteSqlResponse |
GPUdb.executeSql(String statement,
long offset,
long limit,
String requestSchemaStr,
List<ByteBuffer> data,
Map<String,String> options)
Execute a SQL statement (query, DML, or DDL).
|
||||||||||||||||||||||||
RawExecuteSqlResponse |
GPUdb.executeSqlRaw(ExecuteSqlRequest request)
Execute a SQL statement (query, DML, or DDL).
|
||||||||||||||||||||||||
ExportRecordsToFilesResponse |
GPUdb.exportRecordsToFiles(ExportRecordsToFilesRequest request)
Export records from a table to files.
|
||||||||||||||||||||||||
ExportRecordsToFilesResponse |
GPUdb.exportRecordsToFiles(String tableName,
String filepath,
Map<String,String> options)
Export records from a table to files.
|
||||||||||||||||||||||||
ExportRecordsToTableResponse |
GPUdb.exportRecordsToTable(ExportRecordsToTableRequest request)
Exports records from source table to the specified target table in an
external database
|
||||||||||||||||||||||||
ExportRecordsToTableResponse |
GPUdb.exportRecordsToTable(String tableName,
String remoteQuery,
Map<String,String> options)
Exports records from source table to the specified target table in an
external database
|
||||||||||||||||||||||||
FilterResponse |
GPUdb.filter(FilterRequest request)
Filters data based on the specified expression.
|
||||||||||||||||||||||||
FilterResponse |
GPUdb.filter(String tableName,
String viewName,
String expression,
Map<String,String> options)
Filters data based on the specified expression.
|
||||||||||||||||||||||||
FilterByAreaResponse |
GPUdb.filterByArea(FilterByAreaRequest request)
Calculates which objects from a table are within a named area of
interest (NAI/polygon).
|
||||||||||||||||||||||||
FilterByAreaResponse |
GPUdb.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).
|
||||||||||||||||||||||||
FilterByAreaGeometryResponse |
GPUdb.filterByAreaGeometry(FilterByAreaGeometryRequest request)
Calculates which geospatial geometry objects from a table intersect
a named area of interest (NAI/polygon).
|
||||||||||||||||||||||||
FilterByAreaGeometryResponse |
GPUdb.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).
|
||||||||||||||||||||||||
FilterByBoxResponse |
GPUdb.filterByBox(FilterByBoxRequest request)
Calculates how many objects within the given table lie in a
rectangular box.
|
||||||||||||||||||||||||
FilterByBoxResponse |
GPUdb.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.
|
||||||||||||||||||||||||
FilterByBoxGeometryResponse |
GPUdb.filterByBoxGeometry(FilterByBoxGeometryRequest request)
Calculates which geospatial geometry objects from a table intersect
a rectangular box.
|
||||||||||||||||||||||||
FilterByBoxGeometryResponse |
GPUdb.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.
|
||||||||||||||||||||||||
FilterByGeometryResponse |
GPUdb.filterByGeometry(FilterByGeometryRequest request)
Applies a geometry filter against a geospatial geometry column in a
given table or view.
|
||||||||||||||||||||||||
FilterByGeometryResponse |
GPUdb.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.
|
||||||||||||||||||||||||
FilterByListResponse |
GPUdb.filterByList(FilterByListRequest request)
Calculates which records from a table have values in the given list
for the corresponding column.
|
||||||||||||||||||||||||
FilterByListResponse |
GPUdb.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.
|
||||||||||||||||||||||||
FilterByRadiusResponse |
GPUdb.filterByRadius(FilterByRadiusRequest request)
Calculates which objects from a table lie within a circle with the
given radius and center point (i.e. circular NAI).
|
||||||||||||||||||||||||
FilterByRadiusResponse |
GPUdb.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).
|
||||||||||||||||||||||||
FilterByRadiusGeometryResponse |
GPUdb.filterByRadiusGeometry(FilterByRadiusGeometryRequest request)
Calculates which geospatial geometry objects from a table intersect
a circle with the given radius and center point (i.e. circular NAI).
|
||||||||||||||||||||||||
FilterByRadiusGeometryResponse |
GPUdb.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).
|
||||||||||||||||||||||||
FilterByRangeResponse |
GPUdb.filterByRange(FilterByRangeRequest request)
Calculates which objects from a table have a column that is within
the given bounds.
|
||||||||||||||||||||||||
FilterByRangeResponse |
GPUdb.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.
|
||||||||||||||||||||||||
FilterBySeriesResponse |
GPUdb.filterBySeries(FilterBySeriesRequest request)
Filters objects matching all points of the given track (works only
on track type data).
|
||||||||||||||||||||||||
FilterBySeriesResponse |
GPUdb.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).
|
||||||||||||||||||||||||
FilterByStringResponse |
GPUdb.filterByString(FilterByStringRequest request)
Calculates which objects from a table or view match a string
expression for the given string columns.
|
||||||||||||||||||||||||
FilterByStringResponse |
GPUdb.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.
|
||||||||||||||||||||||||
FilterByTableResponse |
GPUdb.filterByTable(FilterByTableRequest request)
Filters objects in one table based on objects in another table.
|
||||||||||||||||||||||||
FilterByTableResponse |
GPUdb.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.
|
||||||||||||||||||||||||
FilterByValueResponse |
GPUdb.filterByValue(FilterByValueRequest request)
Calculates which objects from a table has a particular value for a
particular column.
|
||||||||||||||||||||||||
FilterByValueResponse |
GPUdb.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.
|
||||||||||||||||||||||||
static Type |
Type.fromDynamicSchema(String schemaString,
ByteBuffer encodedData)
Creates a
Type object with the specified dynamic schema metadata and
encoded dynamic table data. |
||||||||||||||||||||||||
static Type |
Type.fromTable(GPUdb gpudb,
String tableName)
Creates a
Type object containing metadata for the GPUdb type of
an existing table in GPUdb. |
||||||||||||||||||||||||
static Type |
Type.fromType(GPUdb gpudb,
String typeId)
Creates a
Type object containing metadata for an existing type
in GPUdb. |
||||||||||||||||||||||||
GetRecordsResponse<T> |
RecordRetriever.getByKey(List<Object> keyValues,
String expression)
Retrieves records with the given key values and filter expression from
the database using a direct-to-rank fast key lookup, if possible, and
falling back to a standard lookup via the head node, if not.
|
||||||||||||||||||||||||
GetJobResponse |
GPUdb.getJob(GetJobRequest request)
Get the status and result of asynchronously running job.
|
||||||||||||||||||||||||
GetJobResponse |
GPUdb.getJob(long jobId,
Map<String,String> options)
Get the status and result of asynchronously running job.
|
||||||||||||||||||||||||
<TResponse> |
GPUdb.getRecords(GetRecordsRequest request)
Retrieves records from a given table, optionally filtered by an
expression and/or sorted by a column.
|
||||||||||||||||||||||||
<TResponse> |
GPUdb.getRecords(Object typeDescriptor,
GetRecordsRequest request)
Retrieves records from a given table, optionally filtered by an
expression and/or sorted by a column.
|
||||||||||||||||||||||||
<TResponse> |
GPUdb.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> |
GPUdb.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.
|
||||||||||||||||||||||||
GetRecordsByColumnResponse |
GPUdb.getRecordsByColumn(GetRecordsByColumnRequest request)
For a given table, retrieves the values from the requested
column(s).
|
||||||||||||||||||||||||
GetRecordsByColumnResponse |
GPUdb.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).
|
||||||||||||||||||||||||
RawGetRecordsByColumnResponse |
GPUdb.getRecordsByColumnRaw(GetRecordsByColumnRequest request)
For a given table, retrieves the values from the requested
column(s).
|
||||||||||||||||||||||||
<TResponse> |
GPUdb.getRecordsBySeries(GetRecordsBySeriesRequest request)
Retrieves the complete series/track records from the given
worldTableName based on the partial track information contained
in
the tableName . |
||||||||||||||||||||||||
<TResponse> |
GPUdb.getRecordsBySeries(Object typeDescriptor,
GetRecordsBySeriesRequest request)
Retrieves the complete series/track records from the given
worldTableName based on the partial track information contained
in
the tableName . |
||||||||||||||||||||||||
<TResponse> |
GPUdb.getRecordsBySeries(Object typeDescriptor,
String tableName,
String worldTableName,
int offset,
int limit,
Map<String,String> options)
Retrieves the complete series/track records from the given
worldTableName based on the partial track information contained
in
the tableName . |
||||||||||||||||||||||||
<TResponse> |
GPUdb.getRecordsBySeries(String tableName,
String worldTableName,
int offset,
int limit,
Map<String,String> options)
Retrieves the complete series/track records from the given
worldTableName based on the partial track information contained
in
the tableName . |
||||||||||||||||||||||||
RawGetRecordsBySeriesResponse |
GPUdb.getRecordsBySeriesRaw(GetRecordsBySeriesRequest request)
Retrieves the complete series/track records from the given
worldTableName based on the partial track information contained
in
the tableName . |
||||||||||||||||||||||||
<TResponse> |
GPUdb.getRecordsFromCollection(GetRecordsFromCollectionRequest request)
Retrieves records from a collection.
|
||||||||||||||||||||||||
<TResponse> |
GPUdb.getRecordsFromCollection(Object typeDescriptor,
GetRecordsFromCollectionRequest request)
Retrieves records from a collection.
|
||||||||||||||||||||||||
<TResponse> |
GPUdb.getRecordsFromCollection(Object typeDescriptor,
String tableName,
long offset,
long limit,
Map<String,String> options)
Retrieves records from a collection.
|
||||||||||||||||||||||||
<TResponse> |
GPUdb.getRecordsFromCollection(String tableName,
long offset,
long limit,
Map<String,String> options)
Retrieves records from a collection.
|
||||||||||||||||||||||||
RawGetRecordsFromCollectionResponse |
GPUdb.getRecordsFromCollectionRaw(GetRecordsFromCollectionRequest request)
Retrieves records from a collection.
|
||||||||||||||||||||||||
GPUdbBase.GetRecordsJsonResponse |
GPUdbBase.getRecordsJson(String tableName,
List<String> columnNames,
long offset,
long limit)
This method is used to retrieve records from a Kinetica table in the form of
a JSON array (stringified).
|
||||||||||||||||||||||||
GPUdbBase.GetRecordsJsonResponse |
GPUdbBase.getRecordsJson(String tableName,
List<String> columnNames,
long offset,
long limit,
List<String> orderByColumns)
This method is used to retrieve records from a Kinetica table in the form of
a JSON array (stringified).
|
||||||||||||||||||||||||
GPUdbBase.GetRecordsJsonResponse |
GPUdbBase.getRecordsJson(String tableName,
List<String> columnNames,
long offset,
long limit,
String expression)
This method is used to retrieve records from a Kinetica table in the form of
a JSON array (stringified).
|
||||||||||||||||||||||||
GPUdbBase.GetRecordsJsonResponse |
GPUdbBase.getRecordsJson(String tableName,
List<String> columnNames,
long offset,
long limit,
String expression,
List<String> orderByColumns)
This method is used to retrieve records from a Kinetica table in the form of
a JSON array (stringified).
|
||||||||||||||||||||||||
GPUdbBase.GetRecordsJsonResponse |
GPUdbBase.getRecordsJson(String tableName,
List<String> columnNames,
long offset,
long limit,
String expression,
List<String> orderByColumns,
String havingClause)
This method is used to retrieve records from a Kinetica table in the form of
a JSON array (stringified).
|
||||||||||||||||||||||||
GPUdbBase.GetRecordsJsonResponse |
GPUdbBase.getRecordsJson(String tableName,
List<String> columnNames,
long offset,
long limit,
String expression,
String havingClause)
This method is used to retrieve records from a Kinetica table in the form of
a JSON array (stringified).
|
||||||||||||||||||||||||
RawGetRecordsResponse |
GPUdb.getRecordsRaw(GetRecordsRequest request)
Retrieves records from a given table, optionally filtered by an
expression and/or sorted by a column.
|
||||||||||||||||||||||||
protected Object |
GPUdbBase.getTypeDescriptor(String typeId) |
||||||||||||||||||||||||
protected <T> TypeObjectMap<T> |
GPUdbBase.getTypeObjectMap(Class<T> objectClass) |
||||||||||||||||||||||||
GetVectortileResponse |
GPUdb.getVectortile(GetVectortileRequest request) |
||||||||||||||||||||||||
GetVectortileResponse |
GPUdb.getVectortile(List<String> tableNames,
List<String> columnNames,
Map<String,List<String>> layers,
int tileX,
int tileY,
int zoom,
Map<String,String> options) |
||||||||||||||||||||||||
GrantPermissionResponse |
GPUdb.grantPermission(GrantPermissionRequest request)
Grant user or role the specified permission on the specified object.
|
||||||||||||||||||||||||
GrantPermissionResponse |
GPUdb.grantPermission(String principal,
String object,
String objectType,
String permission,
Map<String,String> options)
Grant user or role the specified permission on the specified object.
|
||||||||||||||||||||||||
GrantPermissionCredentialResponse |
GPUdb.grantPermissionCredential(GrantPermissionCredentialRequest request)
Grants a
GrantPermissionCredentialResponse GPUdb. | grantPermissionCredential(String name,
String permission,
String credentialName,
Map<String,String> options)
Grants a
GrantPermissionDatasourceResponse GPUdb. | grantPermissionDatasource(GrantPermissionDatasourceRequest request)
Grants a
GrantPermissionDatasourceResponse GPUdb. | grantPermissionDatasource(String name,
String permission,
String datasourceName,
Map<String,String> options)
Grants a
GrantPermissionDirectoryResponse GPUdb. | grantPermissionDirectory(GrantPermissionDirectoryRequest request)
Grants a
GrantPermissionDirectoryResponse GPUdb. | grantPermissionDirectory(String name,
String permission,
String directoryName,
Map<String,String> options)
Grants a
GrantPermissionProcResponse GPUdb. |
grantPermissionProc(GrantPermissionProcRequest request)
Grants a proc-level permission to a user or role.
| ||||||||||||||||||
GrantPermissionProcResponse |
GPUdb.grantPermissionProc(String name,
String permission,
String procName,
Map<String,String> options)
Grants a proc-level permission to a user or role.
|
||||||||||||||||||||||||
GrantPermissionSystemResponse |
GPUdb.grantPermissionSystem(GrantPermissionSystemRequest request)
Grants a system-level permission to a user or role.
|
||||||||||||||||||||||||
GrantPermissionSystemResponse |
GPUdb.grantPermissionSystem(String name,
String permission,
Map<String,String> options)
Grants a system-level permission to a user or role.
|
||||||||||||||||||||||||
GrantPermissionTableResponse |
GPUdb.grantPermissionTable(GrantPermissionTableRequest request)
Grants a table-level permission to a user or role.
|
||||||||||||||||||||||||
GrantPermissionTableResponse |
GPUdb.grantPermissionTable(String name,
String permission,
String tableName,
String filterExpression,
Map<String,String> options)
Grants a table-level permission to a user or role.
|
||||||||||||||||||||||||
GrantRoleResponse |
GPUdb.grantRole(GrantRoleRequest request)
Grants membership in a role to a user or role.
|
||||||||||||||||||||||||
GrantRoleResponse |
GPUdb.grantRole(String role,
String member,
Map<String,String> options)
Grants membership in a role to a user or role.
|
||||||||||||||||||||||||
HasPermissionResponse |
GPUdb.hasPermission(HasPermissionRequest request)
Checks if the specified user has the specified permission on the
specified object.
|
||||||||||||||||||||||||
HasPermissionResponse |
GPUdb.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.
|
||||||||||||||||||||||||
HasProcResponse |
GPUdb.hasProc(HasProcRequest request)
Checks the existence of a proc with the given name.
|
||||||||||||||||||||||||
HasProcResponse |
GPUdb.hasProc(String procName,
Map<String,String> options)
Checks the existence of a proc with the given name.
|
||||||||||||||||||||||||
HasRoleResponse |
GPUdb.hasRole(HasRoleRequest request)
Checks if the specified user has the specified role.
|
||||||||||||||||||||||||
HasRoleResponse |
GPUdb.hasRole(String principal,
String role,
Map<String,String> options)
Checks if the specified user has the specified role.
|
||||||||||||||||||||||||
HasSchemaResponse |
GPUdb.hasSchema(HasSchemaRequest request)
Checks for the existence of a schema with the given name.
|
||||||||||||||||||||||||
HasSchemaResponse |
GPUdb.hasSchema(String schemaName,
Map<String,String> options)
Checks for the existence of a schema with the given name.
|
||||||||||||||||||||||||
HasTableResponse |
GPUdb.hasTable(HasTableRequest request)
Checks for the existence of a table with the given name.
|
||||||||||||||||||||||||
HasTableResponse |
GPUdb.hasTable(String tableName,
Map<String,String> options)
Checks for the existence of a table with the given name.
|
||||||||||||||||||||||||
HasTypeResponse |
GPUdb.hasType(HasTypeRequest request)
Check for the existence of a type.
|
||||||||||||||||||||||||
HasTypeResponse |
GPUdb.hasType(String typeId,
Map<String,String> options)
Check for the existence of a type.
|
||||||||||||||||||||||||
ImportModelResponse |
GPUdb.importModel(ImportModelRequest request) |
||||||||||||||||||||||||
ImportModelResponse |
GPUdb.importModel(String modelName,
String registryName,
String container,
String runFunction,
String modelType,
Map<String,String> options) |
||||||||||||||||||||||||
<TRequest> InsertRecordsResponse |
GPUdb.insertRecords(InsertRecordsRequest<TRequest> request)
Adds multiple records to the specified table.
|
||||||||||||||||||||||||
<TRequest> InsertRecordsResponse |
GPUdb.insertRecords(String tableName,
List<TRequest> data,
Map<String,String> options)
Adds multiple records to the specified table.
|
||||||||||||||||||||||||
<TRequest> InsertRecordsResponse |
GPUdb.insertRecords(TypeObjectMap<TRequest> typeObjectMap,
InsertRecordsRequest<TRequest> request)
Adds multiple records to the specified table.
|
||||||||||||||||||||||||
<TRequest> InsertRecordsResponse |
GPUdb.insertRecords(TypeObjectMap<TRequest> typeObjectMap,
String tableName,
List<TRequest> data,
Map<String,String> options)
Adds multiple records to the specified table.
|
||||||||||||||||||||||||
InsertRecordsFromFilesResponse |
GPUdb.insertRecordsFromFiles(InsertRecordsFromFilesRequest request)
Reads from one or more files and inserts the data into a new or existing
table.
|
||||||||||||||||||||||||
InsertRecordsFromFilesResponse |
GPUdb.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.
|
||||||||||||||||||||||||
Map<String,Object> |
GPUdbBase.insertRecordsFromJson(GPUdbBase.InsertRecordsJsonRequest insertRecordsJsonRequest,
GPUdbBase.JsonOptions jsonOptions)
This method inserts a JSON payload (either a single JSON record or an array) into a Kinetica table
|
||||||||||||||||||||||||
Map<String,Object> |
GPUdbBase.insertRecordsFromJson(String jsonRecords,
String tableName)
This method inserts a JSON payload (either a single JSON record or an array) into a Kinetica table
with all default options
|
||||||||||||||||||||||||
Map<String,Object> |
GPUdbBase.insertRecordsFromJson(String jsonRecords,
String tableName,
GPUdbBase.JsonOptions jsonOptions,
Map<String,String> createTableOptions,
Map<String,String> options)
This method inserts a JSON payload (either a single JSON record or an array) into a Kinetica table
|
||||||||||||||||||||||||
InsertRecordsFromPayloadResponse |
GPUdb.insertRecordsFromPayload(InsertRecordsFromPayloadRequest request)
Reads from the given text-based or binary payload and inserts the
data into a new or existing table.
|
||||||||||||||||||||||||
InsertRecordsFromPayloadResponse |
GPUdb.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.
|
||||||||||||||||||||||||
InsertRecordsFromQueryResponse |
GPUdb.insertRecordsFromQuery(InsertRecordsFromQueryRequest request)
Computes remote query result and inserts the result data into a new or
existing table
|
||||||||||||||||||||||||
InsertRecordsFromQueryResponse |
GPUdb.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
|
||||||||||||||||||||||||
InsertRecordsRandomResponse |
GPUdb.insertRecordsRandom(InsertRecordsRandomRequest request)
Generates a specified number of random records and adds them to the
given table.
|
||||||||||||||||||||||||
InsertRecordsRandomResponse |
GPUdb.insertRecordsRandom(String tableName,
long count,
Map<String,Map<String,Double>> options)
Generates a specified number of random records and adds them to the
given table.
|
||||||||||||||||||||||||
InsertRecordsResponse |
GPUdb.insertRecordsRaw(RawInsertRecordsRequest request)
Adds multiple records to the specified table.
|
||||||||||||||||||||||||
InsertSymbolResponse |
GPUdb.insertSymbol(InsertSymbolRequest request)
Adds a symbol or icon (i.e. an image) to represent data points when data
is rendered visually.
|
||||||||||||||||||||||||
InsertSymbolResponse |
GPUdb.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.
|
||||||||||||||||||||||||
boolean |
BulkInserter.isMultiHeadEnabled() |
||||||||||||||||||||||||
KillProcResponse |
GPUdb.killProc(KillProcRequest request)
Kills a running proc instance.
|
||||||||||||||||||||||||
KillProcResponse |
GPUdb.killProc(String runId,
Map<String,String> options)
Kills a running proc instance.
|
||||||||||||||||||||||||
ListGraphResponse |
GPUdb.listGraph(ListGraphRequest request) |
||||||||||||||||||||||||
ListGraphResponse |
GPUdb.listGraph(String graphName,
Map<String,String> options) |
||||||||||||||||||||||||
LockTableResponse |
GPUdb.lockTable(LockTableRequest request)
Manages global access to a table's data.
|
||||||||||||||||||||||||
LockTableResponse |
GPUdb.lockTable(String tableName,
String lockType,
Map<String,String> options)
Manages global access to a table's data.
|
||||||||||||||||||||||||
MatchGraphResponse |
GPUdb.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.
|
||||||||||||||||||||||||
MatchGraphResponse |
GPUdb.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.
|
||||||||||||||||||||||||
MergeRecordsResponse |
GPUdb.mergeRecords(MergeRecordsRequest request)
Create a new empty result table (specified by
tableName ),
and insert all records from source tables
(specified by sourceTableNames ) based on the field mapping
information (specified by fieldMaps ). |
||||||||||||||||||||||||
MergeRecordsResponse |
GPUdb.mergeRecords(String tableName,
List<String> sourceTableNames,
List<Map<String,String>> fieldMaps,
Map<String,String> options)
Create a new empty result table (specified by
tableName ),
and insert all records from source tables
(specified by sourceTableNames ) based on the field mapping
information (specified by fieldMaps ). |
||||||||||||||||||||||||
ModifyGraphResponse |
GPUdb.modifyGraph(ModifyGraphRequest request)
Update an existing graph network using given nodes, edges, weights,
restrictions, and options.
|
||||||||||||||||||||||||
ModifyGraphResponse |
GPUdb.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.
|
||||||||||||||||||||||||
void |
GPUdbBase.ping()
Verifies that GPUdb is running on the server.
|
||||||||||||||||||||||||
void |
GenericRecord.putDateTime(int index,
Object value)
For string columns with date, time, or datetime property, parse the
string and convert to the appropriate Kinetica format using the system
timezone.
|
||||||||||||||||||||||||
void |
GenericRecord.putDateTime(int index,
Object value,
TimeZone timezone)
For string columns with date, time, or datetime property, parse the
string and convert to the appropriate Kinetica format using the given
timezone (system timezone if none given).
|
||||||||||||||||||||||||
void |
GenericRecord.putDateTime(String name,
Object value)
For string columns with date, time, or datetime property, parse the
string and convert to the appropriate Kinetica format using the system
timezone.
|
||||||||||||||||||||||||
void |
GenericRecord.putDateTime(String name,
Object value,
TimeZone timezone)
For string columns with date, time, or datetime property, parse the
string and convert to the appropriate Kinetica format using the given
timezone (system timezone if none given).
|
||||||||||||||||||||||||
QueryGraphResponse |
GPUdb.queryGraph(QueryGraphRequest request)
Employs a topological query on a network graph generated a-priori by
GPUdb.createGraph(CreateGraphRequest) and 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. |
||||||||||||||||||||||||
QueryGraphResponse |
GPUdb.queryGraph(String graphName,
List<String> queries,
List<String> restrictions,
String adjacencyTable,
int rings,
Map<String,String> options)
Employs a topological query on a network graph generated a-priori by
GPUdb.createGraph(String, boolean, List, List, List, List, Map)
and 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. |
||||||||||||||||||||||||
void |
GPUdbBase.removeHttpHeader(String header)
Removes the given HTTP header from the map of additional HTTP headers to
send to GPUdb with each request.
|
||||||||||||||||||||||||
RepartitionGraphResponse |
GPUdb.repartitionGraph(RepartitionGraphRequest request)
Rebalances an existing partitioned graph.
|
||||||||||||||||||||||||
RepartitionGraphResponse |
GPUdb.repartitionGraph(String graphName,
Map<String,String> options)
Rebalances an existing partitioned graph.
|
||||||||||||||||||||||||
ReserveResourceResponse |
GPUdb.reserveResource(ReserveResourceRequest request) |
||||||||||||||||||||||||
ReserveResourceResponse |
GPUdb.reserveResource(String component,
String name,
String action,
long bytesRequested,
long ownerId,
Map<String,String> options) |
||||||||||||||||||||||||
RevokePermissionResponse |
GPUdb.revokePermission(RevokePermissionRequest request)
Revoke user or role the specified permission on the specified object.
|
||||||||||||||||||||||||
RevokePermissionResponse |
GPUdb.revokePermission(String principal,
String object,
String objectType,
String permission,
Map<String,String> options)
Revoke user or role the specified permission on the specified object.
|
||||||||||||||||||||||||
RevokePermissionCredentialResponse |
GPUdb.revokePermissionCredential(RevokePermissionCredentialRequest request)
Revokes a
RevokePermissionCredentialResponse GPUdb. | revokePermissionCredential(String name,
String permission,
String credentialName,
Map<String,String> options)
Revokes a
RevokePermissionDatasourceResponse GPUdb. | revokePermissionDatasource(RevokePermissionDatasourceRequest request)
Revokes a
RevokePermissionDatasourceResponse GPUdb. | revokePermissionDatasource(String name,
String permission,
String datasourceName,
Map<String,String> options)
Revokes a
RevokePermissionDirectoryResponse GPUdb. | revokePermissionDirectory(RevokePermissionDirectoryRequest request)
Revokes a
RevokePermissionDirectoryResponse GPUdb. | revokePermissionDirectory(String name,
String permission,
String directoryName,
Map<String,String> options)
Revokes a
RevokePermissionProcResponse GPUdb. |
revokePermissionProc(RevokePermissionProcRequest request)
Revokes a proc-level permission from a user or role.
| ||||||||||||||||||
RevokePermissionProcResponse |
GPUdb.revokePermissionProc(String name,
String permission,
String procName,
Map<String,String> options)
Revokes a proc-level permission from a user or role.
|
||||||||||||||||||||||||
RevokePermissionSystemResponse |
GPUdb.revokePermissionSystem(RevokePermissionSystemRequest request)
Revokes a system-level permission from a user or role.
|
||||||||||||||||||||||||
RevokePermissionSystemResponse |
GPUdb.revokePermissionSystem(String name,
String permission,
Map<String,String> options)
Revokes a system-level permission from a user or role.
|
||||||||||||||||||||||||
RevokePermissionTableResponse |
GPUdb.revokePermissionTable(RevokePermissionTableRequest request)
Revokes a table-level permission from a user or role.
|
||||||||||||||||||||||||
RevokePermissionTableResponse |
GPUdb.revokePermissionTable(String name,
String permission,
String tableName,
Map<String,String> options)
Revokes a table-level permission from a user or role.
|
||||||||||||||||||||||||
RevokeRoleResponse |
GPUdb.revokeRole(RevokeRoleRequest request)
Revokes membership in a role from a user or role.
|
||||||||||||||||||||||||
RevokeRoleResponse |
GPUdb.revokeRole(String role,
String member,
Map<String,String> options)
Revokes membership in a role from a user or role.
|
||||||||||||||||||||||||
GPUdbBase |
GPUdbBase.setHostManagerPort(int value)
Deprecated.
As of version 7.1.0.0, this method will no longer be
functional. This method will be a no-op, not changing host manager
port. The method will be removed in version 7.2.0.0.
|
||||||||||||||||||||||||
GPUdbBase.Options |
GPUdbBase.Options.setHostnameRegex(String value)
Sets the IP address or hostname regex against which the server's
rank URLs would be matched when obtaining them.
|
||||||||||||||||||||||||
void |
BulkInserter.setTimedFlushOptions(BulkInserter.FlushOptions flushOptions)
This method could potentially result in two different scenarios
1.
|
||||||||||||||||||||||||
protected void |
GPUdbBase.setTypeDescriptorIfMissing(String typeId,
String label,
String typeSchema,
Map<String,List<String>> properties) |
||||||||||||||||||||||||
ShowContainerRegistryResponse |
GPUdb.showContainerRegistry(ShowContainerRegistryRequest request) |
||||||||||||||||||||||||
ShowContainerRegistryResponse |
GPUdb.showContainerRegistry(String registryName,
Map<String,String> options) |
||||||||||||||||||||||||
ShowCredentialResponse |
GPUdb.showCredential(ShowCredentialRequest request)
Shows information about a specified
ShowCredentialResponse GPUdb. | showCredential(String credentialName,
Map<String,String> options)
Shows information about a specified
ShowDatasinkResponse GPUdb. | showDatasink(ShowDatasinkRequest request)
Shows information about a specified
ShowDatasinkResponse GPUdb. | showDatasink(String name,
Map<String,String> options)
Shows information about a specified
ShowDatasourceResponse GPUdb. | showDatasource(ShowDatasourceRequest request)
Shows information about a specified
ShowDatasourceResponse GPUdb. | showDatasource(String name,
Map<String,String> options)
Shows information about a specified
ShowDirectoriesResponse GPUdb. | showDirectories(ShowDirectoriesRequest request)
Shows information about directories in
ShowDirectoriesResponse GPUdb. | showDirectories(String directoryName,
Map<String,String> options)
Shows information about directories in
ShowEnvironmentResponse GPUdb. | showEnvironment(ShowEnvironmentRequest request)
Shows information about a specified
ShowEnvironmentResponse GPUdb. | showEnvironment(String environmentName,
Map<String,String> options)
Shows information about a specified
ShowFilesResponse GPUdb. | showFiles(List<String> paths,
Map<String,String> options)
Shows information about files in
ShowFilesResponse GPUdb. | showFiles(ShowFilesRequest request)
Shows information about files in
ShowFunctionsResponse GPUdb. |
showFunctions(List<String> names,
Map<String,String> options) | ||||||||||||
ShowFunctionsResponse |
GPUdb.showFunctions(ShowFunctionsRequest request) |
||||||||||||||||||||||||
ShowGraphResponse |
GPUdb.showGraph(ShowGraphRequest request)
Shows information and characteristics of graphs that exist on the graph
server.
|
||||||||||||||||||||||||
ShowGraphResponse |
GPUdb.showGraph(String graphName,
Map<String,String> options)
Shows information and characteristics of graphs that exist on the graph
server.
|
||||||||||||||||||||||||
ShowGraphGrammarResponse |
GPUdb.showGraphGrammar(Map<String,String> options) |
||||||||||||||||||||||||
ShowGraphGrammarResponse |
GPUdb.showGraphGrammar(ShowGraphGrammarRequest request) |
||||||||||||||||||||||||
ShowModelResponse |
GPUdb.showModel(List<String> modelNames,
Map<String,String> options) |
||||||||||||||||||||||||
ShowModelResponse |
GPUdb.showModel(ShowModelRequest request) |
||||||||||||||||||||||||
ShowProcResponse |
GPUdb.showProc(ShowProcRequest request)
Shows information about a proc.
|
||||||||||||||||||||||||
ShowProcResponse |
GPUdb.showProc(String procName,
Map<String,String> options)
Shows information about a proc.
|
||||||||||||||||||||||||
ShowProcStatusResponse |
GPUdb.showProcStatus(ShowProcStatusRequest request)
Shows the statuses of running or completed proc instances.
|
||||||||||||||||||||||||
ShowProcStatusResponse |
GPUdb.showProcStatus(String runId,
Map<String,String> options)
Shows the statuses of running or completed proc instances.
|
||||||||||||||||||||||||
ShowResourceGroupsResponse |
GPUdb.showResourceGroups(List<String> names,
Map<String,String> options)
Requests resource group properties.
|
||||||||||||||||||||||||
ShowResourceGroupsResponse |
GPUdb.showResourceGroups(ShowResourceGroupsRequest request)
Requests resource group properties.
|
||||||||||||||||||||||||
ShowResourceObjectsResponse |
GPUdb.showResourceObjects(Map<String,String> options)
Returns information about the internal sub-components (tiered objects)
which use resources of the system.
|
||||||||||||||||||||||||
ShowResourceObjectsResponse |
GPUdb.showResourceObjects(ShowResourceObjectsRequest request)
Returns information about the internal sub-components (tiered objects)
which use resources of the system.
|
||||||||||||||||||||||||
ShowResourceStatisticsResponse |
GPUdb.showResourceStatistics(Map<String,String> options)
Requests various statistics for storage/memory tiers and resource
groups.
|
||||||||||||||||||||||||
ShowResourceStatisticsResponse |
GPUdb.showResourceStatistics(ShowResourceStatisticsRequest request)
Requests various statistics for storage/memory tiers and resource
groups.
|
||||||||||||||||||||||||
ShowSchemaResponse |
GPUdb.showSchema(ShowSchemaRequest request)
Retrieves information about a
ShowSchemaResponse GPUdb. | showSchema(String schemaName,
Map<String,String> options)
Retrieves information about a
ShowSecurityResponse GPUdb. |
showSecurity(List<String> names,
Map<String,String> options)
Shows security information relating to users and/or roles.
| ||||||||||||||||||||||
ShowSecurityResponse |
GPUdb.showSecurity(ShowSecurityRequest request)
Shows security information relating to users and/or roles.
|
||||||||||||||||||||||||
ShowSqlProcResponse |
GPUdb.showSqlProc(ShowSqlProcRequest request)
Shows information about SQL procedures, including the full definition of
each requested procedure.
|
||||||||||||||||||||||||
ShowSqlProcResponse |
GPUdb.showSqlProc(String procedureName,
Map<String,String> options)
Shows information about SQL procedures, including the full definition of
each requested procedure.
|
||||||||||||||||||||||||
ShowStatisticsResponse |
GPUdb.showStatistics(List<String> tableNames,
Map<String,String> options)
Retrieves the collected column statistics for the specified table(s).
|
||||||||||||||||||||||||
ShowStatisticsResponse |
GPUdb.showStatistics(ShowStatisticsRequest request)
Retrieves the collected column statistics for the specified table(s).
|
||||||||||||||||||||||||
ShowSystemPropertiesResponse |
GPUdb.showSystemProperties(Map<String,String> options)
Returns server configuration and version related information to the
caller.
|
||||||||||||||||||||||||
ShowSystemPropertiesResponse |
GPUdb.showSystemProperties(ShowSystemPropertiesRequest request)
Returns server configuration and version related information to the
caller.
|
||||||||||||||||||||||||
ShowSystemStatusResponse |
GPUdb.showSystemStatus(Map<String,String> options)
Provides server configuration and health related status to the caller.
|
||||||||||||||||||||||||
ShowSystemStatusResponse |
GPUdb.showSystemStatus(ShowSystemStatusRequest request)
Provides server configuration and health related status to the caller.
|
||||||||||||||||||||||||
ShowSystemTimingResponse |
GPUdb.showSystemTiming(Map<String,String> options)
Returns the last 100 database requests along with the request timing and
internal job id.
|
||||||||||||||||||||||||
ShowSystemTimingResponse |
GPUdb.showSystemTiming(ShowSystemTimingRequest request)
Returns the last 100 database requests along with the request timing and
internal job id.
|
||||||||||||||||||||||||
ShowTableResponse |
GPUdb.showTable(ShowTableRequest request)
Retrieves detailed information about a table, view, or schema,
specified in
tableName . |
||||||||||||||||||||||||
ShowTableResponse |
GPUdb.showTable(String tableName,
Map<String,String> options)
Retrieves detailed information about a table, view, or schema,
specified in
tableName . |
||||||||||||||||||||||||
ShowTableMetadataResponse |
GPUdb.showTableMetadata(List<String> tableNames,
Map<String,String> options)
Retrieves the user provided metadata for the specified tables.
|
||||||||||||||||||||||||
ShowTableMetadataResponse |
GPUdb.showTableMetadata(ShowTableMetadataRequest request)
Retrieves the user provided metadata for the specified tables.
|
||||||||||||||||||||||||
ShowTableMonitorsResponse |
GPUdb.showTableMonitors(List<String> monitorIds,
Map<String,String> options)
Show table monitors and their properties.
|
||||||||||||||||||||||||
ShowTableMonitorsResponse |
GPUdb.showTableMonitors(ShowTableMonitorsRequest request)
Show table monitors and their properties.
|
||||||||||||||||||||||||
ShowTablesByTypeResponse |
GPUdb.showTablesByType(ShowTablesByTypeRequest request)
Gets names of the tables whose type matches the given criteria.
|
||||||||||||||||||||||||
ShowTablesByTypeResponse |
GPUdb.showTablesByType(String typeId,
String label,
Map<String,String> options)
Gets names of the tables whose type matches the given criteria.
|
||||||||||||||||||||||||
ShowTriggersResponse |
GPUdb.showTriggers(List<String> triggerIds,
Map<String,String> options)
Retrieves information regarding the specified triggers or all existing
triggers currently active.
|
||||||||||||||||||||||||
ShowTriggersResponse |
GPUdb.showTriggers(ShowTriggersRequest request)
Retrieves information regarding the specified triggers or all existing
triggers currently active.
|
||||||||||||||||||||||||
ShowTypesResponse |
GPUdb.showTypes(ShowTypesRequest request)
Retrieves information for the specified data type ID or type label.
|
||||||||||||||||||||||||
ShowTypesResponse |
GPUdb.showTypes(String typeId,
String label,
Map<String,String> options)
Retrieves information for the specified data type ID or type label.
|
||||||||||||||||||||||||
ShowVideoResponse |
GPUdb.showVideo(List<String> paths,
Map<String,String> options)
Retrieves information about rendered videos.
|
||||||||||||||||||||||||
ShowVideoResponse |
GPUdb.showVideo(ShowVideoRequest request)
Retrieves information about rendered videos.
|
||||||||||||||||||||||||
SolveGraphResponse |
GPUdb.solveGraph(SolveGraphRequest request)
Solves an existing graph for a type of problem (e.g., shortest path,
page rank, travelling salesman, etc.) using source nodes, destination
nodes, and
additional, optional weights and restrictions.
|
||||||||||||||||||||||||
SolveGraphResponse |
GPUdb.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, travelling salesman, etc.) using source nodes, destination
nodes, and
additional, optional weights and restrictions.
|
||||||||||||||||||||||||
String |
GPUdbBase.submitRequest(String endpoint,
boolean enableCompression)
Submits an arbitrary request to GPUdb and saves the response into a
pre-created response object, optionally compressing the request before
sending.
|
||||||||||||||||||||||||
<T extends org.apache.avro.generic.IndexedRecord> |
GPUdbBase.submitRequest(String endpoint,
org.apache.avro.generic.IndexedRecord request,
T response)
Submits an arbitrary request to GPUdb and saves the response into a
pre-created response object.
|
||||||||||||||||||||||||
<T extends org.apache.avro.generic.IndexedRecord> |
GPUdbBase.submitRequest(String endpoint,
org.apache.avro.generic.IndexedRecord request,
T response,
boolean enableCompression)
Submits an arbitrary request to GPUdb and saves the response into a
pre-created response object, optionally compressing the request before
sending.
|
||||||||||||||||||||||||
Map<String,Object> |
GPUdbBase.submitRequest(String endpoint,
String payload,
boolean enableCompression)
Submits an arbitrary request to GPUdb and saves the response into a
pre-created response object, optionally compressing the request before
sending.
|
||||||||||||||||||||||||
String |
GPUdbBase.submitRequest(URL url,
boolean enableCompression)
Submits an arbitrary request to GPUdb via the specified URL and saves the
response into a pre-created response object, optionally compressing the
request before sending.
|
||||||||||||||||||||||||
<T extends org.apache.avro.generic.IndexedRecord> |
GPUdbBase.submitRequest(URL url,
org.apache.avro.generic.IndexedRecord request,
T response,
boolean enableCompression)
Submits an arbitrary request to GPUdb via the specified URL and saves the
response into a pre-created response object, optionally compressing the
request before sending.
|
||||||||||||||||||||||||
<T extends org.apache.avro.generic.IndexedRecord> |
GPUdbBase.submitRequest(URL url,
org.apache.avro.generic.IndexedRecord request,
T response,
boolean enableCompression,
int timeout)
Submits an arbitrary request to GPUdb via the specified URL and saves the
response into a pre-created response object, optionally compressing the
request before sending.
|
||||||||||||||||||||||||
Map<String,Object> |
GPUdbBase.submitRequest(URL url,
String payload,
boolean enableCompression)
Submits an arbitrary request to GPUdb via the specified URL and saves the
response into a pre-created response object, optionally compressing the
request before sending.
|
||||||||||||||||||||||||
String |
GPUdbBase.submitRequestRaw(URL url,
boolean enableCompression)
Submits an arbitrary request to GPUdb via the specified URL and saves the
response into a pre-created response object, optionally compressing the
request before sending.
|
||||||||||||||||||||||||
String |
GPUdbBase.submitRequestRaw(URL url,
boolean enableCompression,
int timeout)
Submits an arbitrary request to GPUdb via the specified URL and saves the
response into a pre-created response object, optionally compressing the
request before sending.
|
||||||||||||||||||||||||
<T extends org.apache.avro.generic.IndexedRecord> |
GPUdbBase.submitRequestRaw(URL url,
org.apache.avro.generic.IndexedRecord request,
T response,
boolean enableCompression)
Submits an arbitrary request to GPUdb via the specified URL and saves the
response into a pre-created response object, optionally compressing the
request before sending.
|
||||||||||||||||||||||||
<T extends org.apache.avro.generic.IndexedRecord> |
GPUdbBase.submitRequestRaw(URL url,
org.apache.avro.generic.IndexedRecord request,
T response,
boolean enableCompression,
int timeout)
Submits an arbitrary request to GPUdb via the specified URL and saves the
response into a pre-created response object, optionally compressing the
request before sending.
|
||||||||||||||||||||||||
Map<String,Object> |
GPUdbBase.submitRequestRaw(URL url,
String payload,
boolean enableCompression)
Submits an arbitrary request to GPUdb via the specified URL and saves the
response into a pre-created response object, optionally compressing the
request before sending.
|
||||||||||||||||||||||||
Map<String,Object> |
GPUdbBase.submitRequestRaw(URL url,
String payload,
boolean enableCompression,
int timeout)
Submits an arbitrary request to GPUdb via the specified URL and saves the
response into a pre-created response object, optionally compressing the
request before sending.
|
||||||||||||||||||||||||
<T extends org.apache.avro.generic.IndexedRecord> |
GPUdbBase.submitRequestToHM(String endpoint,
org.apache.avro.generic.IndexedRecord request,
T response)
Submits an arbitrary request to the GPUdb host manager and saves the
response into a pre-created response object.
|
||||||||||||||||||||||||
<T extends org.apache.avro.generic.IndexedRecord> |
GPUdbBase.submitRequestToHM(String endpoint,
org.apache.avro.generic.IndexedRecord request,
T response,
boolean enableCompression)
Submits an arbitrary request to the GPUdb host manager and saves the
response into a pre-created response object, optionally compressing
the request before sending.
|
||||||||||||||||||||||||
<TRequest> UpdateRecordsResponse |
GPUdb.updateRecords(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> UpdateRecordsResponse |
GPUdb.updateRecords(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> UpdateRecordsResponse |
GPUdb.updateRecords(TypeObjectMap<TRequest> typeObjectMap,
UpdateRecordsRequest<TRequest> request)
Runs multiple predicate-based updates in a single call.
|
||||||||||||||||||||||||
<TRequest> UpdateRecordsResponse |
GPUdb.updateRecords(UpdateRecordsRequest<TRequest> request)
Runs multiple predicate-based updates in a single call.
|
||||||||||||||||||||||||
UpdateRecordsBySeriesResponse |
GPUdb.updateRecordsBySeries(String tableName,
String worldTableName,
String viewName,
List<String> reserved,
Map<String,String> options)
Updates the view specified by
tableName to include full
series (track) information from the worldTableName for the
series
(tracks) present in the viewName . |
||||||||||||||||||||||||
UpdateRecordsBySeriesResponse |
GPUdb.updateRecordsBySeries(UpdateRecordsBySeriesRequest request)
Updates the view specified by
tableName to include full
series (track) information from the worldTableName for the
series
(tracks) present in the viewName . |
||||||||||||||||||||||||
UpdateRecordsResponse |
GPUdb.updateRecordsRaw(RawUpdateRecordsRequest request)
Runs multiple predicate-based updates in a single call.
|
||||||||||||||||||||||||
protected void |
GPUdbBase.updateServerVersion()
If the database version hasn't been set already, update it by querying
the server about its system properties.
|
||||||||||||||||||||||||
UploadFilesResponse |
GPUdb.uploadFiles(List<String> fileNames,
List<ByteBuffer> fileData,
Map<String,String> options)
Uploads one or more files to
UploadFilesResponse GPUdb. | uploadFiles(UploadFilesRequest request)
Uploads one or more files to
UploadFilesFromurlResponse GPUdb. | uploadFilesFromurl(List<String> fileNames,
List<String> urls,
Map<String,String> options)
Uploads one or more files to
UploadFilesFromurlResponse GPUdb. | uploadFilesFromurl(UploadFilesFromurlRequest request)
Uploads one or more files to
VisualizeGetFeatureInfoResponse GPUdb. |
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) | ||||||||||||||||||||
VisualizeGetFeatureInfoResponse |
GPUdb.visualizeGetFeatureInfo(VisualizeGetFeatureInfoRequest request) |
||||||||||||||||||||||||
VisualizeImageResponse |
GPUdb.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) |
||||||||||||||||||||||||
VisualizeImageResponse |
GPUdb.visualizeImage(VisualizeImageRequest request) |
||||||||||||||||||||||||
VisualizeImageChartResponse |
GPUdb.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.
|
||||||||||||||||||||||||
VisualizeImageChartResponse |
GPUdb.visualizeImageChart(VisualizeImageChartRequest request)
Scatter plot is the only plot type currently supported.
|
||||||||||||||||||||||||
VisualizeImageClassbreakResponse |
GPUdb.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) |
||||||||||||||||||||||||
VisualizeImageClassbreakResponse |
GPUdb.visualizeImageClassbreak(VisualizeImageClassbreakRequest request) |
||||||||||||||||||||||||
VisualizeImageContourResponse |
GPUdb.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) |
||||||||||||||||||||||||
VisualizeImageContourResponse |
GPUdb.visualizeImageContour(VisualizeImageContourRequest request) |
||||||||||||||||||||||||
VisualizeImageHeatmapResponse |
GPUdb.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) |
||||||||||||||||||||||||
VisualizeImageHeatmapResponse |
GPUdb.visualizeImageHeatmap(VisualizeImageHeatmapRequest request) |
||||||||||||||||||||||||
VisualizeImageLabelsResponse |
GPUdb.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) |
||||||||||||||||||||||||
VisualizeImageLabelsResponse |
GPUdb.visualizeImageLabels(VisualizeImageLabelsRequest request) |
||||||||||||||||||||||||
VisualizeIsochroneResponse |
GPUdb.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.
|
||||||||||||||||||||||||
VisualizeIsochroneResponse |
GPUdb.visualizeIsochrone(VisualizeIsochroneRequest request)
Generate an image containing isolines for travel results using an
existing graph.
|
Constructor and Description |
---|
BulkInserter(GPUdb gpudb,
String tableName,
Type type,
int batchSize,
Map<String,String> options)
Creates a
BulkInserter with the specified parameters. |
BulkInserter(GPUdb gpudb,
String tableName,
Type type,
int batchSize,
Map<String,String> options,
WorkerList workers)
Creates a
BulkInserter with the specified parameters. |
BulkInserter(GPUdb gpudb,
String tableName,
Type type,
int batchSize,
Map<String,String> options,
WorkerList workers,
BulkInserter.FlushOptions flushOptions)
Creates a
BulkInserter with the specified parameters. |
BulkInserter(GPUdb gpudb,
String tableName,
Type type,
int batchSize,
Map<String,String> options,
WorkerList workers,
BulkInserter.FlushOptions flushOptions,
GPUdbBase.JsonOptions jsonOptions)
Creates a
BulkInserter with the specified parameters. |
BulkInserter(GPUdb gpudb,
String tableName,
Type type,
int batchSize,
Map<String,String> options,
WorkerList workers,
GPUdbBase.JsonOptions jsonOptions)
Creates a
BulkInserter with the specified parameters. |
BulkInserter(GPUdb gpudb,
String tableName,
TypeObjectMap<T> typeObjectMap,
int batchSize,
Map<String,String> options)
Creates a
BulkInserter with the specified parameters. |
BulkInserter(GPUdb gpudb,
String tableName,
TypeObjectMap<T> typeObjectMap,
int batchSize,
Map<String,String> options,
WorkerList workers)
Creates a
BulkInserter with the specified parameters. |
BulkInserter(GPUdb gpudb,
String tableName,
TypeObjectMap<T> typeObjectMap,
int batchSize,
Map<String,String> options,
WorkerList workers,
BulkInserter.FlushOptions flushOptions)
Creates a
BulkInserter with the specified parameters. |
BulkInserter(GPUdb gpudb,
String tableName,
TypeObjectMap<T> typeObjectMap,
int batchSize,
Map<String,String> options,
WorkerList workers,
BulkInserter.FlushOptions flushOptions,
GPUdbBase.JsonOptions jsonOptions)
Creates a
BulkInserter with the specified parameters. |
BulkInserter(GPUdb gpudb,
String tableName,
TypeObjectMap<T> typeObjectMap,
int batchSize,
Map<String,String> options,
WorkerList workers,
GPUdbBase.JsonOptions jsonOptions)
Creates a
BulkInserter with the specified parameters. |
ClusterAddressInfo(URL activeHeadNodeUrl) |
ClusterAddressInfo(URL activeHeadNodeUrl,
int hostManagerPort) |
ClusterAddressInfo(URL activeHeadNodeUrl,
List<URL> workerRankUrls,
Set<String> hostNames,
URL hostManagerUrl,
boolean isPrimaryCluster) |
ClusterAddressInfo(URL activeHeadNodeUrl,
List<URL> workerRankUrls,
Set<String> hostNames,
URL hostManagerUrl,
boolean isPrimaryCluster,
boolean isIntraClusterFailoverEnabled)
Deprecated.
Constructor for intra-cluster failover-enabled systems
|
GPUdb(List<URL> urls)
Creates a
GPUdb instance for the GPUdb server with the
specified URLs using default options. |
GPUdb(List<URL> urls,
GPUdbBase.Options options)
Creates a
GPUdb instance for the GPUdb server with the
specified URLs using the specified options. |
GPUdb(String url)
Creates a
GPUdb instance for the GPUdb server at the
specified URL using default options. |
GPUdb(String url,
GPUdbBase.Options options)
Creates a
GPUdb instance for the GPUdb server at the
specified URL using the specified options. |
GPUdb(URL url)
Creates a
GPUdb instance for the GPUdb server at the
specified URL using default options. |
GPUdb(URL url,
GPUdbBase.Options options)
Creates a
GPUdb instance for the GPUdb server at the
specified URL using the specified options. |
GPUdbBase(List<URL> urls,
GPUdbBase.Options options) |
GPUdbBase(String url,
GPUdbBase.Options options) |
GPUdbBase(URL url,
GPUdbBase.Options options) |
RecordRetriever(GPUdb gpudb,
String tableName,
Type type)
Creates a
RecordRetriever with the specified parameters. |
RecordRetriever(GPUdb gpudb,
String tableName,
Type type,
Map<String,String> options)
Creates a
RecordRetriever with the specified parameters. |
RecordRetriever(GPUdb gpudb,
String tableName,
TypeObjectMap<T> typeObjectMap)
Creates a
RecordRetriever with the specified parameters. |
RecordRetriever(GPUdb gpudb,
String tableName,
TypeObjectMap<T> typeObjectMap,
Map<String,String> options)
Creates a
RecordRetriever with the specified parameters. |
RecordRetriever(GPUdb gpudb,
String tableName,
TypeObjectMap<T> typeObjectMap,
WorkerList workers)
Creates a
RecordRetriever with the specified parameters. |
RecordRetriever(GPUdb gpudb,
String tableName,
TypeObjectMap<T> typeObjectMap,
WorkerList workers,
Map<String,String> options)
Creates a
RecordRetriever with the specified parameters. |
RecordRetriever(GPUdb gpudb,
String tableName,
Type type,
WorkerList workers)
Creates a
RecordRetriever with the specified parameters. |
RecordRetriever(GPUdb gpudb,
String tableName,
Type type,
WorkerList workers,
Map<String,String> options)
Creates a
RecordRetriever with the specified parameters. |
WorkerList(GPUdb gpudb)
Creates a
WorkerList and automatically populates it with the
worker URLs from GPUdb to support multi-head operations. |
WorkerList(GPUdb gpudb)
Deprecated.
This class has been superseded by
com.gpudb.WorkerList . |
WorkerList(GPUdb gpudb,
Pattern ipRegex)
Creates a
WorkerList and automatically populates it with the
worker URLs from GPUdb to support multi-head operations. |
WorkerList(GPUdb gpudb,
Pattern ipRegex)
Deprecated.
This class has been superseded by
com.gpudb.WorkerList . |
WorkerList(GPUdb gpudb,
String ipPrefix)
Creates a
WorkerList and automatically populates it with the
worker URLs from GPUdb to support multi-head operations. |
WorkerList(GPUdb gpudb,
String ipPrefix)
Deprecated.
This class has been superseded by
com.gpudb.WorkerList . |
Modifier and Type | Method and Description |
---|---|
void |
GPUdbFileHandler.createDirectory(String remoteDirName)
This method will create a KIFS directory with default options
|
void |
GPUdbFileHandler.createDirectory(String remoteDirName,
boolean noErrorIfExists)
This method will create a KIFS directory with options as explained
below.
|
void |
GPUdbFileHandler.deleteDirectory(String remoteDirName)
This method deletes a KIFS directory.
|
void |
GPUdbFileHandler.deleteDirectory(String remoteDirName,
boolean recursive,
boolean noErrorIfNotExists)
This method deletes a KIFS directory.
|
void |
GPUdbFileHandler.deleteFiles(List<String> fileNames)
This method takes a list of fully qualified KIFS file paths and deletes
the files in one go.
|
void |
GPUdbFileHandler.deleteFiles(List<String> fileNames,
boolean noErrorIfNotExists)
This method takes a list of fully qualified KIFS file paths and deletes
the files in one go.
|
void |
GPUdbFileHandler.deleteFilesInDir(String remoteDirName)
This method deletes files in the KIFS directory whose name is passed in
using
remoteDirName . |
void |
GPUdbFileHandler.deleteFilesInDir(String remoteDirName,
boolean noErrorIfNotExists)
This method deletes files in the KIFS directory whose name is passes in
using
remoteDirName . |
void |
GPUdbFileHandler.download(List<String> fileNames,
String localDirName)
This method downloads files from a KIFS
directory to a local directory.
|
void |
GPUdbFileHandler.download(List<String> fileNames,
String localDirName,
DownloadOptions downloadOptions,
FileDownloadListener callback)
This method downloads files from a KIFS
directory to a local directory.
|
void |
GPUdbFileHandler.download(String fileName,
String localDirName)
This method downloads a single file from a KIFS
directory to a local directory.
|
void |
GPUdbFileHandler.download(String fileName,
String localDirName,
DownloadOptions downloadOptions,
FileDownloadListener callback)
This method downloads a single file from a KIFS
directory to a local directory.
|
void |
GPUdbFileHandler.downloadDir(String remoteDirName,
String localDirName,
DownloadOptions downloadOptions,
FileDownloadListener callback)
This method will download all files in a KIFS directory to a directory on
the local filesystem.
|
void |
GPUdbFileHandler.ingest(List<String> fileNames,
String tableName,
IngestOptions ingestOptions,
TableCreationOptions createTableOptions)
This method will ingest several files in one go.
|
void |
GPUdbFileHandler.Options.setFileSizeToSplit(long fileSizeToSplit)
Split files greater than this size so that they are uploaded multi-part.
|
GPUdbFileHandler.Options |
GPUdbFileHandler.Options.setFullFileDispatcherThreadpoolSize(int fullFileDispatcherThreadpoolSize)
This value is used to configure the size of the thread pool used
internally to handle batches of full file uploads.
|
List<KifsDirectoryInfo> |
GPUdbFileHandler.showAllDirectories()
This method retrieves the directory information all KIFS
directories and returns the information as a list of
KifsDirectoryInfo
objects. |
List<KifsDirectoryInfo> |
GPUdbFileHandler.showAllDirectories(Map<String,String> options)
This method retrieves the directory information all KIFS
directories and returns the information as a list of
KifsDirectoryInfo
objects. |
List<KifsDirectoryInfo> |
GPUdbFileHandler.showDirectories(Set<String> remoteDirNames)
This method retrieves the directory information for a given list of KIFS
directories and returns the information as a list of
KifsDirectoryInfo
objects. |
List<KifsDirectoryInfo> |
GPUdbFileHandler.showDirectories(Set<String> remoteDirNames,
Map<String,String> options)
This method retrieves the directory information for a given list of KIFS
directories and returns the information as a list of
KifsDirectoryInfo
objects. |
List<KifsDirectoryInfo> |
GPUdbFileHandler.showDirectory(String remoteDirName)
This method retrieves the directory information for a given KIFS
directory and returns the information as a list of
KifsDirectoryInfo
objects. |
List<KifsDirectoryInfo> |
GPUdbFileHandler.showDirectory(String remoteDirName,
Map<String,String> options)
This method retrieves the directory information for a given KIFS
directory and returns the information as a list of
KifsDirectoryInfo
objects. |
List<KifsFileInfo> |
GPUdbFileHandler.showFiles(List<String> remoteDirNames)
This method shows the files
|
void |
GPUdbFileHandler.upload(List<String> fileNames,
String remoteDirName)
This method facilitates uploading of multiple files from the same
local directory to a given remote directory.
|
void |
GPUdbFileHandler.upload(List<String> fileNames,
String remoteDirName,
UploadOptions uploadOptions,
FileUploadListener callback)
This method facilitates uploading of multiple files from the same
local directory to a given remote directory.
|
void |
GPUdbFileHandler.upload(String fileName,
String remoteDirName)
This method facilitates the upload of a single file from a given
local directory to a given remote directory.
|
void |
GPUdbFileHandler.upload(String fileName,
String remoteDirName,
UploadOptions options,
FileUploadListener callback)
This method facilitates the upload of a single file from a given
local directory to a given remote directory.
|
Modifier and Type | Method and Description |
---|---|
protected void |
FileOperation.decideMultiPart(OpMode opMode)
This method resolves the file names passed in and decides on which could
be downloaded in one go and which ones are large enough to be downloaded
in parts.
|
protected List<KifsFileInfo> |
FileOperation.getFileInfoFromServer(String dirName)
This method gets the file stats for the files residing on the KIFS.
|
protected List<KifsFileInfo> |
FileOperation.getFileInfoFromServer(String dirName,
String fileName)
This method gets the file stats for the files residing on the KIFS.
|
Constructor and Description |
---|
FileOperation(GPUdb db,
OpMode opMode,
List<String> fileNames,
String dirName,
boolean recursive,
GPUdbFileHandler.Options fileHandlerOptions) |
Modifier and Type | Method and Description |
---|---|
static org.apache.commons.lang3.tuple.Pair<String,DownloadIoJob> |
DownloadIoJob.createNewJob(GPUdb db,
GPUdbFileHandler.Options fileHandlerOptions,
String dirName,
String fileName,
String localFileName,
KifsFileInfo kifsFileInfo,
DownloadOptions downloadOptions,
FileDownloadListener callback)
Static helper method to create new instance of
DownloadIoJob |
void |
FileDownloader.download()
This is the main download method which is to be called by the users of
this class.
|
void |
DownloadIoJob.start()
This method starts the job to download the multipart file by submitting
different segments of the file according to the value returned by
getFileSizeToSplit() method of GPUdbFileHandler.Options class.
|
Constructor and Description |
---|
FileDownloader(GPUdb db,
List<String> fileNames,
String localDirName,
DownloadOptions downloadOptions,
FileDownloadListener callback,
GPUdbFileHandler.Options fileHandlerOptions)
Constructor
|
Modifier and Type | Method and Description |
---|---|
IngestOptions |
IngestOptions.setColumnsToLoad(Set<String> columnsToLoad)
Sets the set of column names to load
|
IngestOptions |
IngestOptions.setColumnsToSkip(Set<String> columnsToSkip)
Sets the column names to skip
|
Constructor and Description |
---|
FileIngestor(GPUdb db,
String tableName,
List<String> fileNames,
IngestOptions ingestOptions,
TableCreationOptions createTableOptions) |
Modifier and Type | Method and Description |
---|---|
void |
FullFileDispatcher.collect()
Wait for the tasks submitted to the thread pool and collect the
results
Result using the futures accessed using the
FullFileDispatcher.jobExecutor object. |
static org.apache.commons.lang3.tuple.Pair<String,UploadIoJob> |
UploadIoJob.createNewJob(GPUdb db,
GPUdbFileHandler.Options fileHandlerOptions,
OpMode opMode,
String dirName,
String fileName,
String remoteFileName,
UploadOptions uploadOptions,
FileUploadListener callback)
Factory method for creating a new IoJob instance.
|
void |
UploadIoJob.start()
This method starts the job to upload the multipart file by submitting
different stages
MultiPartUploadInfo.MultiPartOperation
to indicate which stage is being executed. |
void |
FileUploader.upload()
This is the main upload method which is to be called by the users of
this class.
|
Constructor and Description |
---|
FileUploader(GPUdb db,
List<String> fileNames,
String remoteDirName,
UploadOptions options,
FileUploadListener callback,
GPUdbFileHandler.Options fileHandlerOptions)
Constructor -
|
Copyright © 2024. All rights reserved.