8 using System.Collections.
Generic;
12 public partial class Kinetica
27 AdminAddHostResponse actualResponse_ = SubmitRequest<AdminAddHostResponse>(
"/admin/add/host", request_,
false);
29 return actualResponse_;
142 IDictionary<string, string> options =
null )
184 AdminAddRanksResponse actualResponse_ = SubmitRequest<AdminAddRanksResponse>(
"/admin/add/ranks", request_,
false);
186 return actualResponse_;
285 IList<IDictionary<string, string>> config_params,
286 IDictionary<string, string> options =
null )
302 AdminAlterHostResponse actualResponse_ = SubmitRequest<AdminAlterHostResponse>(
"/admin/alter/host", request_,
false);
304 return actualResponse_;
347 IDictionary<string, string> options =
null )
367 AdminAlterJobsResponse actualResponse_ = SubmitRequest<AdminAlterJobsResponse>(
"/admin/alter/jobs", request_,
false);
369 return actualResponse_;
407 IDictionary<string, string> options =
null )
426 AdminBackupBeginResponse actualResponse_ = SubmitRequest<AdminBackupBeginResponse>(
"/admin/backup/begin", request_,
false);
428 return actualResponse_;
458 AdminBackupEndResponse actualResponse_ = SubmitRequest<AdminBackupEndResponse>(
"/admin/backup/end", request_,
false);
460 return actualResponse_;
487 AdminHaOfflineResponse actualResponse_ = SubmitRequest<AdminHaOfflineResponse>(
"/admin/ha/offline", request_,
false);
489 return actualResponse_;
512 IDictionary<string, string> options =
null )
528 AdminHaRefreshResponse actualResponse_ = SubmitRequest<AdminHaRefreshResponse>(
"/admin/ha/refresh", request_,
false);
530 return actualResponse_;
558 AdminOfflineResponse actualResponse_ = SubmitRequest<AdminOfflineResponse>(
"/admin/offline", request_,
false);
560 return actualResponse_;
604 IDictionary<string, string> options =
null )
645 AdminRebalanceResponse actualResponse_ = SubmitRequest<AdminRebalanceResponse>(
"/admin/rebalance", request_,
false);
647 return actualResponse_;
902 AdminRemoveHostResponse actualResponse_ = SubmitRequest<AdminRemoveHostResponse>(
"/admin/remove/host", request_,
false);
904 return actualResponse_;
954 IDictionary<string, string> options =
null )
988 AdminRemoveRanksResponse actualResponse_ = SubmitRequest<AdminRemoveRanksResponse>(
"/admin/remove/ranks", request_,
false);
990 return actualResponse_;
1106 IDictionary<string, string> options =
null )
1120 AdminRepairTableResponse actualResponse_ = SubmitRequest<AdminRepairTableResponse>(
"/admin/repair/table", request_,
false);
1122 return actualResponse_;
1201 IDictionary<string, string> table_types,
1202 IDictionary<string, string> options =
null )
1205 table_types, options ) );
1217 AdminSendAlertResponse actualResponse_ = SubmitRequest<AdminSendAlertResponse>(
"/admin/send/alert", request_,
false);
1219 return actualResponse_;
1265 IDictionary<string, string> options =
null )
1280 AdminShowAlertsResponse actualResponse_ = SubmitRequest<AdminShowAlertsResponse>(
"/admin/show/alerts", request_,
false);
1282 return actualResponse_;
1297 IDictionary<string, string> options =
null )
1317 return actualResponse_;
1335 IDictionary<string, string> options =
null )
1349 AdminShowJobsResponse actualResponse_ = SubmitRequest<AdminShowJobsResponse>(
"/admin/show/jobs", request_,
false);
1351 return actualResponse_;
1427 AdminShowShardsResponse actualResponse_ = SubmitRequest<AdminShowShardsResponse>(
"/admin/show/shards", request_,
false);
1429 return actualResponse_;
1455 AdminShutdownResponse actualResponse_ = SubmitRequest<AdminShutdownResponse>(
"/admin/shutdown", request_,
false);
1457 return actualResponse_;
1471 string authorization,
1472 IDictionary<string, string> options =
null )
1491 AdminSwitchoverResponse actualResponse_ = SubmitRequest<AdminSwitchoverResponse>(
"/admin/switchover", request_,
false);
1493 return actualResponse_;
1553 IList<string> destinations,
1554 IDictionary<string, string> options =
null )
1571 AdminVerifyDbResponse actualResponse_ = SubmitRequest<AdminVerifyDbResponse>(
"/admin/verifydb", request_,
false);
1573 return actualResponse_;
1807 AggregateConvexHullResponse actualResponse_ = SubmitRequest<AggregateConvexHullResponse>(
"/aggregate/convexhull", request_,
false);
1809 return actualResponse_;
1831 string x_column_name,
1832 string y_column_name,
1833 IDictionary<string, string> options =
null )
1922 response_.
info = actualResponse_.
info;
2429 IList<string> column_names,
2432 IDictionary<string, string> options =
null )
2435 column_names, offset,
2465 AggregateHistogramResponse actualResponse_ = SubmitRequest<AggregateHistogramResponse>(
"/aggregate/histogram", request_,
false);
2467 return actualResponse_;
2543 IDictionary<string, string> options =
null )
2570 AggregateKMeansResponse actualResponse_ = SubmitRequest<AggregateKMeansResponse>(
"/aggregate/kmeans", request_,
false);
2572 return actualResponse_;
2719 IList<string> column_names,
2722 IDictionary<string, string> options =
null )
2725 k, tolerance, options ) );
2737 AggregateMinMaxResponse actualResponse_ = SubmitRequest<AggregateMinMaxResponse>(
"/aggregate/minmax", request_,
false);
2739 return actualResponse_;
2758 IDictionary<string, string> options =
null )
2776 return actualResponse_;
2796 IDictionary<string, string> options =
null )
2876 AggregateStatisticsResponse actualResponse_ = SubmitRequest<AggregateStatisticsResponse>(
"/aggregate/statistics", request_,
false);
2878 return actualResponse_;
3089 IDictionary<string, string> options =
null )
3134 return actualResponse_;
3225 string select_expression,
3227 string value_column_name,
3232 IDictionary<string, string> options =
null )
3290 RawAggregateUniqueResponse actualResponse_ = SubmitRequest<RawAggregateUniqueResponse>(
"/aggregate/unique", request_,
false);
3296 response_.
info = actualResponse_.
info;
3607 IDictionary<string, string> options =
null )
3610 offset, limit, options ) );
3643 response_.
info = actualResponse_.
info;
3898 IList<string> column_names,
3899 string variable_column_name,
3900 string value_column_name,
3901 IList<string> pivoted_columns,
3902 IDictionary<string, string> options =
null )
3906 variable_column_name,
3908 pivoted_columns, options ) );
3925 AlterBackupResponse actualResponse_ = SubmitRequest<AlterBackupResponse>(
"/alter/backup", request_,
false);
3927 return actualResponse_;
4022 string datasink_name,
4023 IDictionary<string, string> options =
null )
4026 datasink_name, options ) );
4039 AlterCredentialResponse actualResponse_ = SubmitRequest<AlterCredentialResponse>(
"/alter/credential", request_,
false);
4041 return actualResponse_;
4145 IDictionary<string, string> credential_updates_map,
4146 IDictionary<string, string> options )
4149 credential_updates_map,
4163 AlterDatasinkResponse actualResponse_ = SubmitRequest<AlterDatasinkResponse>(
"/alter/datasink", request_,
false);
4165 return actualResponse_;
4587 IDictionary<string, string> datasink_updates_map,
4588 IDictionary<string, string> options )
4604 AlterDatasourceResponse actualResponse_ = SubmitRequest<AlterDatasourceResponse>(
"/alter/datasource", request_,
false);
4606 return actualResponse_;
5027 IDictionary<string, string> datasource_updates_map,
5028 IDictionary<string, string> options )
5031 datasource_updates_map,
5044 AlterDirectoryResponse actualResponse_ = SubmitRequest<AlterDirectoryResponse>(
"/alter/directory", request_,
false);
5046 return actualResponse_;
5071 IDictionary<string, string> directory_updates_map,
5072 IDictionary<string, string> options =
null )
5075 directory_updates_map,
5089 AlterEnvironmentResponse actualResponse_ = SubmitRequest<AlterEnvironmentResponse>(
"/alter/environment", request_,
false);
5091 return actualResponse_;
5179 IDictionary<string, string> options =
null )
5182 action, _value, options ) );
5186 public AlterGraphResponse alterGraph( AlterGraphRequest request_ )
5188 AlterGraphResponse actualResponse_ = SubmitRequest<AlterGraphResponse>(
"/alter/graph", request_,
false);
5190 return actualResponse_;
5195 public AlterGraphResponse alterGraph(
string graph_name,
5198 IDictionary<string, string> options =
null )
5200 return alterGraph(
new AlterGraphRequest( graph_name, action, action_arg,
5206 public AlterModelResponse alterModel( AlterModelRequest request_ )
5208 AlterModelResponse actualResponse_ = SubmitRequest<AlterModelResponse>(
"/alter/model", request_,
false);
5210 return actualResponse_;
5215 public AlterModelResponse alterModel(
string model_name,
5218 IDictionary<string, string> options =
null )
5220 return alterModel(
new AlterModelRequest( model_name, action, _value, options ) );
5233 AlterResourceGroupResponse actualResponse_ = SubmitRequest<AlterResourceGroupResponse>(
"/alter/resourcegroup", request_,
false);
5235 return actualResponse_;
5413 IDictionary<
string, IDictionary<string, string>> tier_attributes =
null,
5415 string adjoining_resource_group =
"",
5416 IDictionary<string, string> options =
null )
5421 adjoining_resource_group,
5433 AlterRoleResponse actualResponse_ = SubmitRequest<AlterRoleResponse>(
"/alter/role", request_,
false);
5435 return actualResponse_;
5472 IDictionary<string, string> options =
null )
5488 AlterSchemaResponse actualResponse_ = SubmitRequest<AlterSchemaResponse>(
"/alter/schema", request_,
false);
5490 return actualResponse_;
5530 IDictionary<string, string> options =
null )
5554 return actualResponse_;
6004 IDictionary<string, string> options =
null )
6067 AlterTableResponse actualResponse_ = SubmitRequest<AlterTableResponse>(
"/alter/table", request_,
false);
6069 return actualResponse_;
6769 IDictionary<string, string> options =
null )
6796 AlterTableColumnsResponse actualResponse_ = SubmitRequest<AlterTableColumnsResponse>(
"/alter/table/columns", request_,
false);
6798 return actualResponse_;
6834 IList<IDictionary<string, string>> column_alterations,
6835 IDictionary<string, string> options )
6854 AlterTableMetadataResponse actualResponse_ = SubmitRequest<AlterTableMetadataResponse>(
"/alter/table/metadata", request_,
false);
6856 return actualResponse_;
6880 IDictionary<string, string> metadata_map,
6881 IDictionary<string, string> options =
null )
6898 AlterTableMonitorResponse actualResponse_ = SubmitRequest<AlterTableMonitorResponse>(
"/alter/tablemonitor", request_,
false);
6900 return actualResponse_;
6959 IDictionary<string, string> monitor_updates_map,
6960 IDictionary<string, string> options =
null )
6963 monitor_updates_map,
6985 AlterTierResponse actualResponse_ = SubmitRequest<AlterTierResponse>(
"/alter/tier", request_,
false);
6987 return actualResponse_;
7081 IDictionary<string, string> options =
null )
7094 AlterUserResponse actualResponse_ = SubmitRequest<AlterUserResponse>(
"/alter/user", request_,
false);
7096 return actualResponse_;
7164 IDictionary<string, string> options =
null )
7177 AlterVideoResponse actualResponse_ = SubmitRequest<AlterVideoResponse>(
"/alter/video", request_,
false);
7179 return actualResponse_;
7199 IDictionary<string, string> options =
null )
7213 AlterWalResponse actualResponse_ = SubmitRequest<AlterWalResponse>(
"/alter/wal", request_,
false);
7215 return actualResponse_;
7392 IDictionary<string, string> options =
null )
7413 AppendRecordsResponse actualResponse_ = SubmitRequest<AppendRecordsResponse>(
"/append/records", request_,
false);
7415 return actualResponse_;
7630 string source_table_name,
7631 IDictionary<string, string> field_map,
7632 IDictionary<string, string> options =
null )
7635 field_map, options ) );
7647 ClearStatisticsResponse actualResponse_ = SubmitRequest<ClearStatisticsResponse>(
"/clear/statistics", request_,
false);
7649 return actualResponse_;
7669 string column_name =
"",
7670 IDictionary<string, string> options =
null )
7689 ClearTableResponse actualResponse_ = SubmitRequest<ClearTableResponse>(
"/clear/table", request_,
false);
7691 return actualResponse_;
7745 string authorization =
"",
7746 IDictionary<string, string> options =
null )
7761 ClearTableMonitorResponse actualResponse_ = SubmitRequest<ClearTableMonitorResponse>(
"/clear/tablemonitor", request_,
false);
7763 return actualResponse_;
7834 IDictionary<string, string> options =
null )
7851 ClearTablesResponse actualResponse_ = SubmitRequest<ClearTablesResponse>(
"/clear/tables", request_,
false);
7853 return actualResponse_;
7904 IDictionary<string, string> options =
null )
7921 ClearTriggerResponse actualResponse_ = SubmitRequest<ClearTriggerResponse>(
"/clear/trigger", request_,
false);
7923 return actualResponse_;
7939 IDictionary<string, string> options =
null )
7953 CollectStatisticsResponse actualResponse_ = SubmitRequest<CollectStatisticsResponse>(
"/collect/statistics", request_,
false);
7955 return actualResponse_;
7974 IList<string> column_names,
7975 IDictionary<string, string> options =
null )
7978 column_names, options ) );
7996 CreateBackupResponse actualResponse_ = SubmitRequest<CreateBackupResponse>(
"/create/backup", request_,
false);
7998 return actualResponse_;
8295 IDictionary<string, string> backup_objects_map,
8296 string datasink_name,
8297 IDictionary<string, string> options =
null )
8301 datasink_name, options ) );
8314 CreateCatalogResponse actualResponse_ = SubmitRequest<CreateCatalogResponse>(
"/create/catalog", request_,
false);
8316 return actualResponse_;
8387 string table_format,
8392 IDictionary<string, string> options =
null )
8395 type, credential, datasource,
8400 public CreateContainerRegistryResponse createContainerRegistry( CreateContainerRegistryRequest request_ )
8402 CreateContainerRegistryResponse actualResponse_ = SubmitRequest<CreateContainerRegistryResponse>(
"/create/container/registry", request_,
false);
8404 return actualResponse_;
8409 public CreateContainerRegistryResponse createContainerRegistry(
string registry_name,
8412 IDictionary<string, string> options =
null )
8414 return createContainerRegistry(
new CreateContainerRegistryRequest( registry_name,
8430 CreateCredentialResponse actualResponse_ = SubmitRequest<CreateCredentialResponse>(
"/create/credential", request_,
false);
8432 return actualResponse_;
8535 IDictionary<string, string> options =
null )
8553 CreateDatasinkResponse actualResponse_ = SubmitRequest<CreateDatasinkResponse>(
"/create/datasink", request_,
false);
8555 return actualResponse_;
8929 IDictionary<string, string> options =
null )
8945 CreateDatasourceResponse actualResponse_ = SubmitRequest<CreateDatasourceResponse>(
"/create/datasource", request_,
false);
8947 return actualResponse_;
9357 IDictionary<string, string> options =
null )
9360 user_name, password,
9365 public CreateDeltaTableResponse createDeltaTable( CreateDeltaTableRequest request_ )
9367 CreateDeltaTableResponse actualResponse_ = SubmitRequest<CreateDeltaTableResponse>(
"/create/deltatable", request_,
false);
9369 return actualResponse_;
9374 public CreateDeltaTableResponse createDeltaTable(
string delta_table_name,
9376 IDictionary<string, string> options =
null )
9378 return createDeltaTable(
new CreateDeltaTableRequest( delta_table_name,
9379 table_name, options ) );
9396 CreateDirectoryResponse actualResponse_ = SubmitRequest<CreateDirectoryResponse>(
"/create/directory", request_,
false);
9398 return actualResponse_;
9459 IDictionary<string, string> options =
null )
9474 CreateEnvironmentResponse actualResponse_ = SubmitRequest<CreateEnvironmentResponse>(
"/create/environment", request_,
false);
9476 return actualResponse_;
9490 IDictionary<string, string> options =
null )
9512 CreateGraphResponse actualResponse_ = SubmitRequest<CreateGraphResponse>(
"/create/graph", request_,
false);
9514 return actualResponse_;
9831 bool directed_graph,
9832 IList<string> nodes,
9833 IList<string> edges,
9834 IList<string> weights,
9835 IList<string> restrictions,
9836 IDictionary<string, string> options =
null )
9839 edges, weights, restrictions,
9855 CreateJobResponse actualResponse_ = SubmitRequest<CreateJobResponse>(
"/create/job", request_,
false);
9857 return actualResponse_;
9924 string request_encoding,
9927 IDictionary<string, string> options =
null )
9930 data_str, options ) );
9947 CreateJoinTableResponse actualResponse_ = SubmitRequest<CreateJoinTableResponse>(
"/create/jointable", request_,
false);
9949 return actualResponse_;
10140 IList<string> table_names,
10141 IList<string> column_names,
10142 IList<string> expressions =
null,
10143 IDictionary<string, string> options =
null )
10146 table_names, column_names,
10147 expressions, options ) );
10170 return actualResponse_;
10391 IDictionary<string, string> options =
null )
10408 CreateProcResponse actualResponse_ = SubmitRequest<CreateProcResponse>(
"/create/proc", request_,
false);
10410 return actualResponse_;
10496 IDictionary<
string,
byte[]> files =
null,
10497 string command =
"",
10498 IList<string> args =
null,
10499 IDictionary<string, string> options =
null )
10502 command, args, options ) );
10543 CreateProjectionResponse actualResponse_ = SubmitRequest<CreateProjectionResponse>(
"/create/projection", request_,
false);
10545 return actualResponse_;
10997 string projection_name,
10998 IList<string> column_names,
10999 IDictionary<string, string> options =
null )
11003 column_names, options ) );
11015 CreateResourceGroupResponse actualResponse_ = SubmitRequest<CreateResourceGroupResponse>(
"/create/resourcegroup", request_,
false);
11017 return actualResponse_;
11128 IDictionary<
string, IDictionary<string, string>> tier_attributes,
11130 string adjoining_resource_group =
"",
11131 IDictionary<string, string> options =
null )
11136 adjoining_resource_group,
11150 CreateRoleResponse actualResponse_ = SubmitRequest<CreateRoleResponse>(
"/create/role", request_,
false);
11152 return actualResponse_;
11177 IDictionary<string, string> options =
null )
11194 CreateSchemaResponse actualResponse_ = SubmitRequest<CreateSchemaResponse>(
"/create/schema", request_,
false);
11196 return actualResponse_;
11240 IDictionary<string, string> options =
null )
11246 public CreateStateTableResponse createStateTable( CreateStateTableRequest request_ )
11248 CreateStateTableResponse actualResponse_ = SubmitRequest<CreateStateTableResponse>(
"/create/statetable", request_,
false);
11250 return actualResponse_;
11255 public CreateStateTableResponse createStateTable(
string table_name,
11256 string input_table_name,
11257 string init_table_name,
11258 IDictionary<string, string> options =
null )
11260 return createStateTable(
new CreateStateTableRequest( table_name,
11262 init_table_name, options ) );
11315 CreateTableResponse actualResponse_ = SubmitRequest<CreateTableResponse>(
"/create/table", request_,
false);
11317 return actualResponse_;
11806 IDictionary<string, string> options =
null )
11832 CreateTableExternalResponse actualResponse_ = SubmitRequest<CreateTableExternalResponse>(
"/create/table/external", request_,
false);
11834 return actualResponse_;
13283 IList<string> filepaths,
13284 IDictionary<
string, IDictionary<string, string>> modify_columns =
null,
13285 IDictionary<string, string> create_table_options =
null,
13286 IDictionary<string, string> options =
null )
13291 create_table_options,
13321 CreateTableMonitorResponse actualResponse_ = SubmitRequest<CreateTableMonitorResponse>(
"/create/tablemonitor", request_,
false);
13323 return actualResponse_;
13548 IDictionary<string, string> options =
null )
13578 CreateTriggerByAreaResponse actualResponse_ = SubmitRequest<CreateTriggerByAreaResponse>(
"/create/trigger/byarea", request_,
false);
13580 return actualResponse_;
13628 IList<string> table_names,
13629 string x_column_name,
13630 IList<double> x_vector,
13631 string y_column_name,
13632 IList<double> y_vector,
13633 IDictionary<string, string> options =
null )
13640 y_vector, options ) );
13665 CreateTriggerByRangeResponse actualResponse_ = SubmitRequest<CreateTriggerByRangeResponse>(
"/create/trigger/byrange", request_,
false);
13667 return actualResponse_;
13704 IList<string> table_names,
13705 string column_name,
13708 IDictionary<string, string> options =
null )
13774 CreateTypeResponse actualResponse_ = SubmitRequest<CreateTypeResponse>(
"/create/type", request_,
false);
13776 SetDecoderIfMissing( actualResponse_.
type_id,
13777 actualResponse_.
label,
13780 return actualResponse_;
14196 IDictionary<
string, IList<string>> properties =
null,
14197 IDictionary<string, string> options =
null )
14228 CreateUnionResponse actualResponse_ = SubmitRequest<CreateUnionResponse>(
"/create/union", request_,
false);
14230 return actualResponse_;
14517 IList<string> table_names,
14518 IList<IList<string>> input_column_names,
14519 IList<string> output_column_names,
14520 IDictionary<string, string> options =
null )
14523 input_column_names,
14524 output_column_names, options ) );
14538 CreateUserExternalResponse actualResponse_ = SubmitRequest<CreateUserExternalResponse>(
"/create/user/external", request_,
false);
14540 return actualResponse_;
14632 IDictionary<string, string> options =
null )
14646 CreateUserInternalResponse actualResponse_ = SubmitRequest<CreateUserInternalResponse>(
"/create/user/internal", request_,
false);
14648 return actualResponse_;
14742 IDictionary<string, string> options =
null )
14757 CreateVideoResponse actualResponse_ = SubmitRequest<CreateVideoResponse>(
"/create/video", request_,
false);
14759 return actualResponse_;
14900 double duration_seconds,
14902 double frames_per_second,
14905 string style_parameters,
14906 IDictionary<string, string> options =
null )
14909 duration_seconds, end,
14910 frames_per_second, style, path,
14911 style_parameters, options ) );
14923 DeleteDirectoryResponse actualResponse_ = SubmitRequest<DeleteDirectoryResponse>(
"/delete/directory", request_,
false);
14925 return actualResponse_;
14991 IDictionary<string, string> options =
null )
15005 DeleteFilesResponse actualResponse_ = SubmitRequest<DeleteFilesResponse>(
"/delete/files", request_,
false);
15007 return actualResponse_;
15050 IDictionary<string, string> options =
null )
15064 DeleteGraphResponse actualResponse_ = SubmitRequest<DeleteGraphResponse>(
"/delete/graph", request_,
false);
15066 return actualResponse_;
15116 IDictionary<string, string> options =
null )
15131 DeleteProcResponse actualResponse_ = SubmitRequest<DeleteProcResponse>(
"/delete/proc", request_,
false);
15133 return actualResponse_;
15147 IDictionary<string, string> options =
null )
15173 DeleteRecordsResponse actualResponse_ = SubmitRequest<DeleteRecordsResponse>(
"/delete/records", request_,
false);
15175 return actualResponse_;
15259 IList<string> expressions,
15260 IDictionary<string, string> options =
null )
15274 DeleteResourceGroupResponse actualResponse_ = SubmitRequest<DeleteResourceGroupResponse>(
"/delete/resourcegroup", request_,
false);
15276 return actualResponse_;
15316 IDictionary<string, string> options =
null )
15331 DeleteRoleResponse actualResponse_ = SubmitRequest<DeleteRoleResponse>(
"/delete/role", request_,
false);
15333 return actualResponse_;
15347 IDictionary<string, string> options =
null )
15362 DeleteUserResponse actualResponse_ = SubmitRequest<DeleteUserResponse>(
"/delete/user", request_,
false);
15364 return actualResponse_;
15378 IDictionary<string, string> options =
null )
15392 DownloadFilesResponse actualResponse_ = SubmitRequest<DownloadFilesResponse>(
"/download/files", request_,
false);
15394 return actualResponse_;
15453 IList<long> read_offsets,
15454 IList<long> read_lengths,
15455 IDictionary<string, string> options =
null )
15458 read_lengths, options ) );
15475 DropBackupResponse actualResponse_ = SubmitRequest<DropBackupResponse>(
"/drop/backup", request_,
false);
15477 return actualResponse_;
15573 string datasink_name,
15574 IDictionary<string, string> options =
null )
15589 DropCatalogResponse actualResponse_ = SubmitRequest<DropCatalogResponse>(
"/drop/catalog", request_,
false);
15591 return actualResponse_;
15605 IDictionary<string, string> options =
null )
15611 public DropContainerRegistryResponse dropContainerRegistry( DropContainerRegistryRequest request_ )
15613 DropContainerRegistryResponse actualResponse_ = SubmitRequest<DropContainerRegistryResponse>(
"/drop/container/registry", request_,
false);
15615 return actualResponse_;
15620 public DropContainerRegistryResponse dropContainerRegistry(
string registry_name,
15621 IDictionary<string, string> options =
null )
15623 return dropContainerRegistry(
new DropContainerRegistryRequest( registry_name,
15637 DropCredentialResponse actualResponse_ = SubmitRequest<DropCredentialResponse>(
"/drop/credential", request_,
false);
15639 return actualResponse_;
15652 IDictionary<string, string> options =
null )
15673 DropDatasinkResponse actualResponse_ = SubmitRequest<DropDatasinkResponse>(
"/drop/datasink", request_,
false);
15675 return actualResponse_;
15723 IDictionary<string, string> options =
null )
15740 DropDatasourceResponse actualResponse_ = SubmitRequest<DropDatasourceResponse>(
"/drop/datasource", request_,
false);
15742 return actualResponse_;
15758 IDictionary<string, string> options =
null )
15773 DropEnvironmentResponse actualResponse_ = SubmitRequest<DropEnvironmentResponse>(
"/drop/environment", request_,
false);
15775 return actualResponse_;
15821 IDictionary<string, string> options =
null )
15827 public DropModelResponse dropModel( DropModelRequest request_ )
15829 DropModelResponse actualResponse_ = SubmitRequest<DropModelResponse>(
"/drop/model", request_,
false);
15831 return actualResponse_;
15836 public DropModelResponse dropModel(
string model_name,
15837 IDictionary<string, string> options =
null )
15839 return dropModel(
new DropModelRequest( model_name, options ) );
15854 DropSchemaResponse actualResponse_ = SubmitRequest<DropSchemaResponse>(
"/drop/schema", request_,
false);
15856 return actualResponse_;
15926 IDictionary<string, string> options =
null )
15932 public EvaluateModelResponse evaluateModel( EvaluateModelRequest request_ )
15934 EvaluateModelResponse actualResponse_ = SubmitRequest<EvaluateModelResponse>(
"/evaluate/model", request_,
false);
15936 return actualResponse_;
15941 public EvaluateModelResponse evaluateModel(
string model_name,
15943 string deployment_mode,
15944 string source_table,
15945 string destination_table,
15946 IDictionary<string, string> options =
null )
15948 return evaluateModel(
new EvaluateModelRequest( model_name, replicas,
15949 deployment_mode, source_table,
15950 destination_table, options ) );
15973 ExecuteProcResponse actualResponse_ = SubmitRequest<ExecuteProcResponse>(
"/execute/proc", request_,
false);
15975 return actualResponse_;
16113 IDictionary<string, string> _params =
null,
16114 IDictionary<
string,
byte[]> bin_params =
null,
16115 IList<string> input_table_names =
null,
16116 IDictionary<
string, IList<string>> input_column_names =
null,
16117 IList<string> output_table_names =
null,
16118 IDictionary<string, string> options =
null )
16122 input_column_names,
16123 output_table_names, options ) );
16159 RawExecuteSqlResponse actualResponse_ = SubmitRequest<RawExecuteSqlResponse>(
"/execute/sql", request_,
false);
16167 response_.
info = actualResponse_.
info;
16687 long limit = -9999,
16688 string request_schema_str =
"",
16689 IList<
byte[]> data =
null,
16690 IDictionary<string, string> options =
null )
16693 request_schema_str, data, options ) );
16705 ExportQueryMetricsResponse actualResponse_ = SubmitRequest<ExportQueryMetricsResponse>(
"/export/query/metrics", request_,
false);
16707 return actualResponse_;
16803 ExportRecordsToFilesResponse actualResponse_ = SubmitRequest<ExportRecordsToFilesResponse>(
"/export/records/tofiles", request_,
false);
16805 return actualResponse_;
17130 IDictionary<string, string> options =
null )
17146 ExportRecordsToTableResponse actualResponse_ = SubmitRequest<ExportRecordsToTableResponse>(
"/export/records/totable", request_,
false);
17148 return actualResponse_;
17255 string remote_query =
"",
17256 IDictionary<string, string> options =
null )
17280 FilterResponse actualResponse_ = SubmitRequest<FilterResponse>(
"/filter", request_,
false);
17282 return actualResponse_;
17374 IDictionary<string, string> options =
null )
17395 FilterByAreaResponse actualResponse_ = SubmitRequest<FilterByAreaResponse>(
"/filter/byarea", request_,
false);
17397 return actualResponse_;
17481 string x_column_name,
17482 IList<double> x_vector,
17483 string y_column_name,
17484 IList<double> y_vector,
17485 IDictionary<string, string> options =
null )
17488 x_column_name, x_vector,
17489 y_column_name, y_vector, options ) );
17508 FilterByAreaGeometryResponse actualResponse_ = SubmitRequest<FilterByAreaGeometryResponse>(
"/filter/byarea/geometry", request_,
false);
17510 return actualResponse_;
17591 string column_name,
17592 IList<double> x_vector,
17593 IList<double> y_vector,
17594 IDictionary<string, string> options =
null )
17620 FilterByBoxResponse actualResponse_ = SubmitRequest<FilterByBoxResponse>(
"/filter/bybox", request_,
false);
17622 return actualResponse_;
17713 string x_column_name,
17716 string y_column_name,
17719 IDictionary<string, string> options =
null )
17722 x_column_name, min_x, max_x,
17723 y_column_name, min_y, max_y,
17743 FilterByBoxGeometryResponse actualResponse_ = SubmitRequest<FilterByBoxGeometryResponse>(
"/filter/bybox/geometry", request_,
false);
17745 return actualResponse_;
17835 string column_name,
17840 IDictionary<string, string> options =
null )
17862 FilterByGeometryResponse actualResponse_ = SubmitRequest<FilterByGeometryResponse>(
"/filter/bygeometry", request_,
false);
17864 return actualResponse_;
18003 string column_name,
18006 IDictionary<string, string> options =
null )
18009 column_name, input_wkt,
18010 operation, options ) );
18037 FilterByListResponse actualResponse_ = SubmitRequest<FilterByListResponse>(
"/filter/bylist", request_,
false);
18039 return actualResponse_;
18151 IDictionary<
string, IList<string>> column_values_map,
18152 IDictionary<string, string> options =
null )
18155 column_values_map, options ) );
18178 FilterByRadiusResponse actualResponse_ = SubmitRequest<FilterByRadiusResponse>(
"/filter/byradius", request_,
false);
18180 return actualResponse_;
18275 string x_column_name,
18277 string y_column_name,
18280 IDictionary<string, string> options =
null )
18283 x_column_name, x_center,
18284 y_column_name, y_center,
18285 radius, options ) );
18307 return actualResponse_;
18398 string column_name,
18402 IDictionary<string, string> options =
null )
18435 FilterByRangeResponse actualResponse_ = SubmitRequest<FilterByRangeResponse>(
"/filter/byrange", request_,
false);
18437 return actualResponse_;
18523 string column_name,
18524 double lower_bound,
18525 double upper_bound,
18526 IDictionary<string, string> options =
null )
18529 column_name, lower_bound,
18530 upper_bound, options ) );
18556 FilterBySeriesResponse actualResponse_ = SubmitRequest<FilterBySeriesResponse>(
"/filter/byseries", request_,
false);
18558 return actualResponse_;
18691 IList<string> target_track_ids,
18692 IDictionary<string, string> options =
null )
18695 track_id, target_track_ids,
18715 FilterByStringResponse actualResponse_ = SubmitRequest<FilterByStringResponse>(
"/filter/bystring", request_,
false);
18717 return actualResponse_;
18872 IList<string> column_names,
18873 IDictionary<string, string> options =
null )
18877 column_names, options ) );
18899 FilterByTableResponse actualResponse_ = SubmitRequest<FilterByTableResponse>(
"/filter/bytable", request_,
false);
18901 return actualResponse_;
19112 string column_name,
19113 string source_table_name,
19114 string source_table_column_name,
19115 IDictionary<string, string> options =
null )
19120 source_table_column_name,
19143 FilterByValueResponse actualResponse_ = SubmitRequest<FilterByValueResponse>(
"/filter/byvalue", request_,
false);
19145 return actualResponse_;
19233 string column_name,
19234 IDictionary<string, string> options =
null )
19237 is_string, _value, value_str,
19238 column_name, options ) );
19254 GetJobResponse actualResponse_ = SubmitRequest<GetJobResponse>(
"/get/job", request_,
false);
19256 return actualResponse_;
19282 IDictionary<string, string> options =
null )
19307 RawGetRecordsResponse actualResponse_ = SubmitRequest<RawGetRecordsResponse>(
"/get/records", request_,
false);
19310 response_.table_name = actualResponse_.
table_name;
19311 response_.type_name = actualResponse_.
type_name;
19312 response_.type_schema = actualResponse_.
type_schema;
19313 response_.data =
new List<T>();
19317 response_.info = actualResponse_.
info;
19427 long limit = -9999,
19428 IDictionary<string, string> options =
null ) where T : new()
19478 response_.
info = actualResponse_.
info;
19634 IList<string> column_names,
19636 long limit = -9999,
19637 IDictionary<string, string> options =
null )
19676 response_.table_names = actualResponse_.
table_names;
19677 response_.type_names = actualResponse_.
type_names;
19678 response_.type_schemas = actualResponse_.
type_schemas;
19679 response_.data =
new List<IList<T>>();
19681 response_.info = actualResponse_.
info;
19729 string world_table_name,
19732 IDictionary<string, string> options =
null ) where T : new()
19763 response_.table_name = actualResponse_.
table_name;
19764 response_.type_names = actualResponse_.
type_names;
19765 response_.data =
new List<T>();
19767 response_.record_ids = actualResponse_.
record_ids;
19768 response_.info = actualResponse_.
info;
19844 long limit = -9999,
19845 IDictionary<string, string> options =
null ) where T : new()
19854 public GetVectortileResponse getVectortile( GetVectortileRequest request_ )
19856 GetVectortileResponse actualResponse_ = SubmitRequest<GetVectortileResponse>(
"/get/vectortile", request_,
false);
19858 return actualResponse_;
19863 public GetVectortileResponse getVectortile( IList<string> table_names,
19864 IList<string> column_names,
19865 IDictionary<
string, IList<string>> layers,
19869 IDictionary<string, string> options =
null )
19871 return getVectortile(
new GetVectortileRequest( table_names, column_names,
19872 layers, tile_x, tile_y, zoom,
19886 GrantPermissionResponse actualResponse_ = SubmitRequest<GrantPermissionResponse>(
"/grant/permission", request_,
false);
19888 return actualResponse_;
20111 string object_type,
20113 IDictionary<string, string> options =
null )
20116 object_type, permission,
20133 return actualResponse_;
20170 string credential_name,
20171 IDictionary<string, string> options =
null )
20191 return actualResponse_;
20227 string datasource_name,
20228 IDictionary<string, string> options =
null )
20248 return actualResponse_;
20286 string directory_name,
20287 IDictionary<string, string> options =
null )
20304 GrantPermissionProcResponse actualResponse_ = SubmitRequest<GrantPermissionProcResponse>(
"/grant/permission/proc", request_,
false);
20306 return actualResponse_;
20340 IDictionary<string, string> options =
null )
20343 proc_name, options ) );
20357 return actualResponse_;
20408 IDictionary<string, string> options =
null )
20424 GrantPermissionTableResponse actualResponse_ = SubmitRequest<GrantPermissionTableResponse>(
"/grant/permission/table", request_,
false);
20426 return actualResponse_;
20494 string filter_expression =
"",
20495 IDictionary<string, string> options =
null )
20512 GrantRoleResponse actualResponse_ = SubmitRequest<GrantRoleResponse>(
"/grant/role", request_,
false);
20514 return actualResponse_;
20530 IDictionary<string, string> options =
null )
20544 HasPermissionResponse actualResponse_ = SubmitRequest<HasPermissionResponse>(
"/has/permission", request_,
false);
20546 return actualResponse_;
20761 string object_type,
20763 IDictionary<string, string> options =
null )
20766 object_type, permission,
20779 HasProcResponse actualResponse_ = SubmitRequest<HasProcResponse>(
"/has/proc", request_,
false);
20781 return actualResponse_;
20794 IDictionary<string, string> options =
null )
20808 HasRoleResponse actualResponse_ = SubmitRequest<HasRoleResponse>(
"/has/role", request_,
false);
20810 return actualResponse_;
20885 IDictionary<string, string> options =
null )
20899 HasSchemaResponse actualResponse_ = SubmitRequest<HasSchemaResponse>(
"/has/schema", request_,
false);
20901 return actualResponse_;
20916 IDictionary<string, string> options =
null )
20930 HasTableResponse actualResponse_ = SubmitRequest<HasTableResponse>(
"/has/table", request_,
false);
20932 return actualResponse_;
20947 IDictionary<string, string> options =
null )
20960 HasTypeResponse actualResponse_ = SubmitRequest<HasTypeResponse>(
"/has/type", request_,
false);
20962 return actualResponse_;
20975 IDictionary<string, string> options =
null )
20981 public ImportModelResponse importModel( ImportModelRequest request_ )
20983 ImportModelResponse actualResponse_ = SubmitRequest<ImportModelResponse>(
"/import/model", request_,
false);
20985 return actualResponse_;
20990 public ImportModelResponse importModel(
string model_name,
20991 string registry_name,
20993 string run_function,
20995 IDictionary<string, string> options =
null )
20997 return importModel(
new ImportModelRequest( model_name, registry_name,
20998 container, run_function,
20999 model_type, options ) );
21028 InsertRecordsResponse actualResponse_ = SubmitRequest<InsertRecordsResponse>(
"/insert/records", request_,
true);
21030 return actualResponse_;
21061 actualRequest_.
table_name = request_.table_name;
21062 foreach (var thisObj
in request_.data) actualRequest_.list.Add( AvroEncode( thisObj ) );
21063 actualRequest_.options = request_.options;
21064 InsertRecordsResponse actualResponse_ = SubmitRequest<InsertRecordsResponse>(
"/insert/records", actualRequest_,
true);
21066 return actualResponse_;
21349 IDictionary<string, string> options =
null )
21394 return actualResponse_;
22742 IList<string> filepaths,
22743 IDictionary<
string, IDictionary<string, string>> modify_columns =
null,
22744 IDictionary<string, string> create_table_options =
null,
22745 IDictionary<string, string> options =
null )
22750 create_table_options,
22768 return actualResponse_;
23963 IDictionary<
string, IDictionary<string, string>> modify_columns =
null,
23964 IDictionary<string, string> create_table_options =
null,
23965 IDictionary<string, string> options =
null )
23971 create_table_options,
23986 return actualResponse_;
24644 string remote_query,
24645 IDictionary<
string, IDictionary<string, string>> modify_columns =
null,
24646 IDictionary<string, string> create_table_options =
null,
24647 IDictionary<string, string> options =
null )
24652 create_table_options,
24673 InsertRecordsRandomResponse actualResponse_ = SubmitRequest<InsertRecordsRandomResponse>(
"/insert/records/random", request_,
false);
24675 return actualResponse_;
24975 IDictionary<
string, IDictionary<string, double>> options =
null )
25000 InsertSymbolResponse actualResponse_ = SubmitRequest<InsertSymbolResponse>(
"/insert/symbol", request_,
false);
25002 return actualResponse_;
25060 string symbol_format,
25061 byte[] symbol_data,
25062 IDictionary<string, string> options =
null )
25065 symbol_data, options ) );
25076 KillProcResponse actualResponse_ = SubmitRequest<KillProcResponse>(
"/kill/proc", request_,
false);
25078 return actualResponse_;
25138 IDictionary<string, string> options =
null )
25144 public ListGraphResponse listGraph( ListGraphRequest request_ )
25146 ListGraphResponse actualResponse_ = SubmitRequest<ListGraphResponse>(
"/list/graph", request_,
false);
25148 return actualResponse_;
25153 public ListGraphResponse listGraph(
string graph_name =
"",
25154 IDictionary<string, string> options =
null )
25156 return listGraph(
new ListGraphRequest( graph_name, options ) );
25183 LockTableResponse actualResponse_ = SubmitRequest<LockTableResponse>(
"/lock/table", request_,
false);
25185 return actualResponse_;
25254 IDictionary<string, string> options =
null )
25277 MatchGraphResponse actualResponse_ = SubmitRequest<MatchGraphResponse>(
"/match/graph", request_,
false);
25279 return actualResponse_;
26287 IList<string> sample_points,
26289 string solution_table =
"",
26290 IDictionary<string, string> options =
null )
26293 solve_method, solution_table,
26311 ModifyGraphResponse actualResponse_ = SubmitRequest<ModifyGraphResponse>(
"/modify/graph", request_,
false);
26313 return actualResponse_;
26675 IList<string> nodes,
26676 IList<string> edges,
26677 IList<string> weights,
26678 IList<string> restrictions,
26679 IDictionary<string, string> options =
null )
26682 restrictions, options ) );
26715 QueryGraphResponse actualResponse_ = SubmitRequest<QueryGraphResponse>(
"/query/graph", request_,
false);
26717 return actualResponse_;
26935 IList<string> queries,
26936 IList<string> restrictions =
null,
26937 string adjacency_table =
"",
26939 IDictionary<string, string> options =
null )
26942 adjacency_table, rings, options ) );
26960 RepartitionGraphResponse actualResponse_ = SubmitRequest<RepartitionGraphResponse>(
"/repartition/graph", request_,
false);
26962 return actualResponse_;
27006 IDictionary<string, string> options =
null )
27012 public ReserveResourceResponse reserveResource( ReserveResourceRequest request_ )
27014 ReserveResourceResponse actualResponse_ = SubmitRequest<ReserveResourceResponse>(
"/reserve/resource", request_,
false);
27016 return actualResponse_;
27021 public ReserveResourceResponse reserveResource(
string component,
27024 long bytes_requested = 0,
27026 IDictionary<string, string> options =
null )
27028 return reserveResource(
new ReserveResourceRequest( component, name, action,
27029 bytes_requested, owner_id,
27048 RestoreBackupResponse actualResponse_ = SubmitRequest<RestoreBackupResponse>(
"/restore/backup", request_,
false);
27050 return actualResponse_;
27368 IDictionary<string, string> restore_objects_map,
27369 string datasource_name,
27370 IDictionary<string, string> options =
null )
27373 restore_objects_map,
27374 datasource_name, options ) );
27386 RevokePermissionResponse actualResponse_ = SubmitRequest<RevokePermissionResponse>(
"/revoke/permission", request_,
false);
27388 return actualResponse_;
27580 string object_type,
27582 IDictionary<string, string> options =
null )
27585 object_type, permission,
27602 return actualResponse_;
27641 string credential_name,
27642 IDictionary<string, string> options =
null )
27662 return actualResponse_;
27700 string datasource_name,
27701 IDictionary<string, string> options =
null )
27721 return actualResponse_;
27760 string directory_name,
27761 IDictionary<string, string> options =
null )
27778 RevokePermissionProcResponse actualResponse_ = SubmitRequest<RevokePermissionProcResponse>(
"/revoke/permission/proc", request_,
false);
27780 return actualResponse_;
27816 IDictionary<string, string> options =
null )
27835 return actualResponse_;
27888 IDictionary<string, string> options =
null )
27906 return actualResponse_;
27972 IDictionary<string, string> options =
null )
27989 RevokeRoleResponse actualResponse_ = SubmitRequest<RevokeRoleResponse>(
"/revoke/role", request_,
false);
27991 return actualResponse_;
28008 IDictionary<string, string> options =
null )
28027 ShowBackupResponse actualResponse_ = SubmitRequest<ShowBackupResponse>(
"/show/backup", request_,
false);
28029 return actualResponse_;
28117 string datasource_name,
28118 IDictionary<string, string> options =
null )
28125 public ShowContainerRegistryResponse showContainerRegistry( ShowContainerRegistryRequest request_ )
28127 ShowContainerRegistryResponse actualResponse_ = SubmitRequest<ShowContainerRegistryResponse>(
"/show/container/registry", request_,
false);
28129 return actualResponse_;
28134 public ShowContainerRegistryResponse showContainerRegistry(
string registry_name,
28135 IDictionary<string, string> options =
null )
28137 return showContainerRegistry(
new ShowContainerRegistryRequest( registry_name,
28152 ShowCredentialResponse actualResponse_ = SubmitRequest<ShowCredentialResponse>(
"/show/credential", request_,
false);
28154 return actualResponse_;
28170 IDictionary<string, string> options =
null )
28185 ShowDatasinkResponse actualResponse_ = SubmitRequest<ShowDatasinkResponse>(
"/show/datasink", request_,
false);
28187 return actualResponse_;
28203 IDictionary<string, string> options =
null )
28218 ShowDatasourceResponse actualResponse_ = SubmitRequest<ShowDatasourceResponse>(
"/show/datasource", request_,
false);
28220 return actualResponse_;
28236 IDictionary<string, string> options =
null )
28252 ShowDirectoriesResponse actualResponse_ = SubmitRequest<ShowDirectoriesResponse>(
"/show/directories", request_,
false);
28254 return actualResponse_;
28269 IDictionary<string, string> options =
null )
28285 ShowEnvironmentResponse actualResponse_ = SubmitRequest<ShowEnvironmentResponse>(
"/show/environment", request_,
false);
28287 return actualResponse_;
28362 IDictionary<string, string> options =
null )
28378 ShowFilesResponse actualResponse_ = SubmitRequest<ShowFilesResponse>(
"/show/files", request_,
false);
28380 return actualResponse_;
28399 IDictionary<string, string> options =
null )
28405 public ShowFunctionsResponse showFunctions( ShowFunctionsRequest request_ )
28407 ShowFunctionsResponse actualResponse_ = SubmitRequest<ShowFunctionsResponse>(
"/show/functions", request_,
false);
28409 return actualResponse_;
28414 public ShowFunctionsResponse showFunctions( IList<string> names,
28415 IDictionary<string, string> options =
null )
28417 return showFunctions(
new ShowFunctionsRequest( names, options ) );
28430 ShowGraphResponse actualResponse_ = SubmitRequest<ShowGraphResponse>(
"/show/graph", request_,
false);
28432 return actualResponse_;
28481 IDictionary<string, string> options =
null )
28487 public ShowGraphGrammarResponse showGraphGrammar( ShowGraphGrammarRequest request_ )
28489 ShowGraphGrammarResponse actualResponse_ = SubmitRequest<ShowGraphGrammarResponse>(
"/show/graph/grammar", request_,
false);
28491 return actualResponse_;
28496 public ShowGraphGrammarResponse showGraphGrammar( IDictionary<string, string> options =
null )
28498 return showGraphGrammar(
new ShowGraphGrammarRequest( options ) );
28503 public ShowModelResponse showModel( ShowModelRequest request_ )
28505 ShowModelResponse actualResponse_ = SubmitRequest<ShowModelResponse>(
"/show/model", request_,
false);
28507 return actualResponse_;
28512 public ShowModelResponse showModel( IList<string> model_names =
null,
28513 IDictionary<string, string> options =
null )
28515 return showModel(
new ShowModelRequest( model_names, options ) );
28527 ShowProcResponse actualResponse_ = SubmitRequest<ShowProcResponse>(
"/show/proc", request_,
false);
28529 return actualResponse_;
28571 IDictionary<string, string> options =
null )
28589 ShowProcStatusResponse actualResponse_ = SubmitRequest<ShowProcStatusResponse>(
"/show/proc/status", request_,
false);
28591 return actualResponse_;
28653 IDictionary<string, string> options =
null )
28671 ShowResourceObjectsResponse actualResponse_ = SubmitRequest<ShowResourceObjectsResponse>(
"/show/resource/objects", request_,
false);
28673 return actualResponse_;
28805 return actualResponse_;
28829 ShowResourceGroupsResponse actualResponse_ = SubmitRequest<ShowResourceGroupsResponse>(
"/show/resourcegroups", request_,
false);
28831 return actualResponse_;
28922 IDictionary<string, string> options =
null )
28938 ShowSchemaResponse actualResponse_ = SubmitRequest<ShowSchemaResponse>(
"/show/schema", request_,
false);
28940 return actualResponse_;
28986 IDictionary<string, string> options =
null )
29003 ShowSecurityResponse actualResponse_ = SubmitRequest<ShowSecurityResponse>(
"/show/security", request_,
false);
29005 return actualResponse_;
29048 IDictionary<string, string> options =
null )
29062 ShowSqlProcResponse actualResponse_ = SubmitRequest<ShowSqlProcResponse>(
"/show/sql/proc", request_,
false);
29064 return actualResponse_;
29108 IDictionary<string, string> options =
null )
29122 ShowStatisticsResponse actualResponse_ = SubmitRequest<ShowStatisticsResponse>(
"/show/statistics", request_,
false);
29124 return actualResponse_;
29171 IDictionary<string, string> options =
null )
29187 ShowSystemPropertiesResponse actualResponse_ = SubmitRequest<ShowSystemPropertiesResponse>(
"/show/system/properties", request_,
false);
29189 return actualResponse_;
29227 ShowSystemStatusResponse actualResponse_ = SubmitRequest<ShowSystemStatusResponse>(
"/show/system/status", request_,
false);
29229 return actualResponse_;
29257 ShowSystemTimingResponse actualResponse_ = SubmitRequest<ShowSystemTimingResponse>(
"/show/system/timing", request_,
false);
29259 return actualResponse_;
29319 ShowTableResponse actualResponse_ = SubmitRequest<ShowTableResponse>(
"/show/table", request_,
false);
29322 for (
int i_ = 0; i_ < actualResponse_.
type_ids.Count; ++i_ )
29324 SetDecoderIfMissing( actualResponse_.
type_ids[i_],
29330 return actualResponse_;
29661 IDictionary<string, string> options =
null )
29675 ShowTableMetadataResponse actualResponse_ = SubmitRequest<ShowTableMetadataResponse>(
"/show/table/metadata", request_,
false);
29677 return actualResponse_;
29693 IDictionary<string, string> options =
null )
29710 ShowTableMonitorsResponse actualResponse_ = SubmitRequest<ShowTableMonitorsResponse>(
"/show/tablemonitors", request_,
false);
29712 return actualResponse_;
29729 IDictionary<string, string> options =
null )
29748 ShowTablesByTypeResponse actualResponse_ = SubmitRequest<ShowTablesByTypeResponse>(
"/show/tables/bytype", request_,
false);
29750 return actualResponse_;
29773 IDictionary<string, string> options =
null )
29787 ShowTriggersResponse actualResponse_ = SubmitRequest<ShowTriggersResponse>(
"/show/triggers", request_,
false);
29789 return actualResponse_;
29803 IDictionary<string, string> options =
null )
29820 ShowTypesResponse actualResponse_ = SubmitRequest<ShowTypesResponse>(
"/show/types", request_,
false);
29823 for (
int i_ = 0; i_ < actualResponse_.
type_ids.Count; ++i_ )
29825 SetDecoderIfMissing( actualResponse_.
type_ids[i_],
29826 actualResponse_.
labels[i_],
29831 return actualResponse_;
29879 IDictionary<string, string> options =
null )
29892 ShowVideoResponse actualResponse_ = SubmitRequest<ShowVideoResponse>(
"/show/video", request_,
false);
29894 return actualResponse_;
29907 IDictionary<string, string> options =
null )
29921 ShowWalResponse actualResponse_ = SubmitRequest<ShowWalResponse>(
"/show/wal", request_,
false);
29923 return actualResponse_;
29962 IDictionary<string, string> options =
null )
29986 SolveGraphResponse actualResponse_ = SubmitRequest<SolveGraphResponse>(
"/solve/graph", request_,
false);
29988 return actualResponse_;
30442 IList<string> weights_on_edges =
null,
30443 IList<string> restrictions =
null,
30445 IList<string> source_nodes =
null,
30446 IList<string> destination_nodes =
null,
30447 string solution_table =
"graph_solutions",
30448 IDictionary<string, string> options =
null )
30451 restrictions, solver_type,
30452 source_nodes, destination_nodes,
30453 solution_table, options ) );
30495 UpdateRecordsResponse actualResponse_ = SubmitRequest<UpdateRecordsResponse>(
"/update/records", request_,
true);
30497 return actualResponse_;
30542 actualRequest_.
table_name = request_.table_name;
30543 actualRequest_.
expressions = request_.expressions;
30545 foreach (var thisObj
in request_.data) actualRequest_.records_to_insert.Add( AvroEncode( thisObj ) );
30546 actualRequest_.options = request_.options;
30547 UpdateRecordsResponse actualResponse_ = SubmitRequest<UpdateRecordsResponse>(
"/update/records", actualRequest_,
true);
30549 return actualResponse_;
30852 IList<string> expressions,
30853 IList<IDictionary<string, string>> new_values_maps,
30854 IList<T> data =
null,
30855 IDictionary<string, string> options =
null )
30858 new_values_maps, data,
30933 UploadFilesResponse actualResponse_ = SubmitRequest<UploadFilesResponse>(
"/upload/files", request_,
false);
30935 return actualResponse_;
31136 IList<
byte[]> file_data,
31137 IDictionary<string, string> options =
null )
31161 UploadFilesFromurlResponse actualResponse_ = SubmitRequest<UploadFilesFromurlResponse>(
"/upload/files/fromurl", request_,
false);
31163 return actualResponse_;
31192 IList<string> urls,
31193 IDictionary<string, string> options =
null )
31200 public VisualizeGetFeatureInfoResponse visualizeGetFeatureInfo( VisualizeGetFeatureInfoRequest request_ )
31202 VisualizeGetFeatureInfoResponse actualResponse_ = SubmitRequest<VisualizeGetFeatureInfoResponse>(
"/visualize/getfeatureinfo", request_,
false);
31204 return actualResponse_;
31209 public VisualizeGetFeatureInfoResponse visualizeGetFeatureInfo( IList<string> table_names,
31210 IList<string> x_column_names,
31211 IList<string> y_column_names,
31212 IList<string> geometry_column_names,
31213 IList<IList<string>> query_column_names,
31226 IDictionary<string, string> options =
null )
31228 return visualizeGetFeatureInfo(
new VisualizeGetFeatureInfoRequest( table_names,
31231 geometry_column_names,
31232 query_column_names,
31248 public VisualizeImageResponse visualizeImage( VisualizeImageRequest request_ )
31250 VisualizeImageResponse actualResponse_ = SubmitRequest<VisualizeImageResponse>(
"/visualize/image", request_,
false);
31252 return actualResponse_;
31257 public VisualizeImageResponse visualizeImage( IList<string> table_names,
31258 IList<string> world_table_names,
31259 string x_column_name,
31260 string y_column_name,
31261 string symbol_column_name,
31262 string geometry_column_name,
31263 IList<IList<string>> track_ids,
31272 IDictionary<
string, IList<string>> style_options,
31273 IDictionary<string, string> options =
null )
31275 return visualizeImage(
new VisualizeImageRequest( table_names,
31279 symbol_column_name,
31280 geometry_column_name,
31281 track_ids, min_x, max_x,
31282 min_y, max_y, width, height,
31283 projection, bg_color,
31284 style_options, options ) );
31303 VisualizeImageChartResponse actualResponse_ = SubmitRequest<VisualizeImageChartResponse>(
"/visualize/image/chart", request_,
false);
31305 return actualResponse_;
31597 IList<string> x_column_names,
31598 IList<string> y_column_names,
31606 IDictionary<
string, IList<string>> style_options,
31607 IDictionary<string, string> options =
null )
31621 public VisualizeImageClassbreakResponse visualizeImageClassbreak( VisualizeImageClassbreakRequest request_ )
31623 VisualizeImageClassbreakResponse actualResponse_ = SubmitRequest<VisualizeImageClassbreakResponse>(
"/visualize/image/classbreak", request_,
false);
31625 return actualResponse_;
31630 public VisualizeImageClassbreakResponse visualizeImageClassbreak( IList<string> table_names,
31631 IList<string> world_table_names,
31632 string x_column_name,
31633 string y_column_name,
31634 string symbol_column_name,
31635 string geometry_column_name,
31636 IList<IList<string>> track_ids,
31638 IList<string> cb_vals,
31639 string cb_pointcolor_attr,
31640 IList<string> cb_pointcolor_vals,
31641 string cb_pointalpha_attr,
31642 IList<string> cb_pointalpha_vals,
31643 string cb_pointsize_attr,
31644 IList<string> cb_pointsize_vals,
31645 string cb_pointshape_attr,
31646 IList<string> cb_pointshape_vals,
31655 IDictionary<
string, IList<string>> style_options,
31656 IDictionary<string, string> options,
31657 IList<int> cb_transparency_vec )
31659 return visualizeImageClassbreak(
new VisualizeImageClassbreakRequest( table_names,
31663 symbol_column_name,
31664 geometry_column_name,
31668 cb_pointcolor_attr,
31669 cb_pointcolor_vals,
31670 cb_pointalpha_attr,
31671 cb_pointalpha_vals,
31674 cb_pointshape_attr,
31675 cb_pointshape_vals,
31686 cb_transparency_vec ) );
31691 public VisualizeImageContourResponse visualizeImageContour( VisualizeImageContourRequest request_ )
31693 VisualizeImageContourResponse actualResponse_ = SubmitRequest<VisualizeImageContourResponse>(
"/visualize/image/contour", request_,
false);
31695 return actualResponse_;
31700 public VisualizeImageContourResponse visualizeImageContour( IList<string> table_names,
31701 string x_column_name,
31702 string y_column_name,
31703 string value_column_name,
31711 IDictionary<string, string> style_options,
31712 IDictionary<string, string> options =
null )
31714 return visualizeImageContour(
new VisualizeImageContourRequest( table_names,
31728 public VisualizeImageHeatmapResponse visualizeImageHeatmap( VisualizeImageHeatmapRequest request_ )
31730 VisualizeImageHeatmapResponse actualResponse_ = SubmitRequest<VisualizeImageHeatmapResponse>(
"/visualize/image/heatmap", request_,
false);
31732 return actualResponse_;
31737 public VisualizeImageHeatmapResponse visualizeImageHeatmap( IList<string> table_names,
31738 string x_column_name,
31739 string y_column_name,
31740 string value_column_name,
31741 string geometry_column_name,
31749 IDictionary<string, string> style_options,
31750 IDictionary<string, string> options =
null )
31752 return visualizeImageHeatmap(
new VisualizeImageHeatmapRequest( table_names,
31756 geometry_column_name,
31767 public VisualizeImageLabelsResponse visualizeImageLabels( VisualizeImageLabelsRequest request_ )
31769 VisualizeImageLabelsResponse actualResponse_ = SubmitRequest<VisualizeImageLabelsResponse>(
"/visualize/image/labels", request_,
false);
31771 return actualResponse_;
31776 public VisualizeImageLabelsResponse visualizeImageLabels(
string table_name,
31777 string x_column_name,
31778 string y_column_name,
31781 string text_string,
31787 string draw_leader,
31791 string leader_x_column_name,
31792 string leader_y_column_name,
31800 string projection = VisualizeImageLabelsRequest.Projection.PLATE_CARREE,
31801 IDictionary<string, string> options =
null )
31803 return visualizeImageLabels(
new VisualizeImageLabelsRequest( table_name,
31818 leader_x_column_name,
31819 leader_y_column_name,
31844 VisualizeIsochroneResponse actualResponse_ = SubmitRequest<VisualizeIsochroneResponse>(
"/visualize/isochrone", request_,
false);
31846 return actualResponse_;
32778 string source_node,
32779 double max_solution_radius,
32780 IList<string> weights_on_edges,
32781 IList<string> restrictions,
32783 bool generate_image,
32784 string levels_table,
32785 IDictionary<string, string> style_options,
32786 IDictionary<string, string> solve_options =
null,
32787 IDictionary<string, string> contour_options =
null,
32788 IDictionary<string, string> options =
null )
32792 max_solution_radius,
A set of parameters for Kinetica.grantPermissionProc.
AdminHaOfflineResponse adminHaOffline(bool offline, IDictionary< string, string > options=null)
Pauses consumption of messages from other HA clusters to support data repair/recovery scenarios.
A set of parameters for Kinetica.aggregateMinMax.
A set of results returned by Kinetica.createUnion.
AdminSwitchoverResponse adminSwitchover(AdminSwitchoverRequest request_)
Manually switch over one or more processes to another host.
A set of results returned by Kinetica.grantRole.
A set of results returned by Kinetica.showResourceObjects.
A set of results returned by Kinetica.aggregateConvexHull.
const string EMPTY_STRING
Don't change the ranking
UpdateRecordsResponse updateRecords< T >(UpdateRecordsRequest< T > request_)
Runs multiple predicate-based updates in a single call.
A set of results returned by Kinetica.hasPermission.
string label
Value of label.
FilterByTableResponse filterByTable(string table_name, string view_name, string column_name, string source_table_name, string source_table_column_name, IDictionary< string, string > options=null)
Filters objects in one table based on objects in another table.
IDictionary< string, string > info
Additional information.
CreateProcResponse createProc(string proc_name, string execution_mode=CreateProcRequest.ExecutionMode.DISTRIBUTED, IDictionary< string, byte[]> files=null, string command="", IList< string > args=null, IDictionary< string, string > options=null)
Creates an instance (proc) of the user-defined functions (UDF) specified by the given command,...
FilterByStringResponse filterByString(FilterByStringRequest request_)
Calculates which objects from a table or view match a string expression for the given string columns.
A set of results returned by Kinetica.clearTables.
IList< string > type_schemas
A set of parameters for Kinetica.modifyGraph.
byte [] binary_encoded_response
Avro binary encoded response.
long total_number_of_records
Total/Filtered number of records.
CreateTriggerByRangeResponse createTriggerByRange(string request_id, IList< string > table_names, string column_name, double min, double max, IDictionary< string, string > options=null)
Sets up a simple range trigger for a column_name for one or more tables.
A set of parameters for Kinetica.hasPermission.
HasTableResponse hasTable(HasTableRequest request_)
Checks for the existence of a table with the given name.
GrantPermissionDirectoryResponse grantPermissionDirectory(string name, string permission, string directory_name, IDictionary< string, string > options=null)
Grants a KiFS directory-level permission to a user or role.
A set of results returned by Kinetica.aggregateKMeans.
A set of results returned by Kinetica.dropEnvironment.
A set of parameters for Kinetica.getRecordsBySeries.
ShowProcStatusResponse showProcStatus(ShowProcStatusRequest request_)
Shows the statuses of running or completed proc instances.
string table_name
Value of table_name.
A set of results returned by Kinetica.adminRebalance.
A set of results returned by Kinetica.createEnvironment.
A set of results returned by Kinetica.showSystemProperties.
bool has_more_records
Too many records.
A set of parameters for Kinetica.dropDatasink.
long total_number_of_records
Total/Filtered number of records.
A set of results returned by Kinetica.getRecordsByColumn.
A set of results returned by Kinetica.insertRecordsRandom.
A set of results returned by Kinetica.aggregateGroupBy.
A set of results returned by Kinetica.grantPermissionSystem.
DeleteRecordsResponse deleteRecords(DeleteRecordsRequest request_)
Deletes record(s) matching the provided criteria from the given table.
AdminHaRefreshResponse adminHaRefresh(IDictionary< string, string > options=null)
Restarts the HA processing on the given cluster as a mechanism of accepting breaking HA conf changes.
AlterTableColumnsResponse alterTableColumns(AlterTableColumnsRequest request_)
Apply various modifications to columns in a table, view.
AlterTableMetadataResponse alterTableMetadata(AlterTableMetadataRequest request_)
Updates (adds or changes) metadata for tables.
A set of results returned by Kinetica.revokePermissionSystem.
AggregateConvexHullResponse aggregateConvexHull(AggregateConvexHullRequest request_)
Calculates and returns the convex hull for the values in a table specified by table_name.
A set of results returned by Kinetica.adminAddRanks.
AdminRemoveHostResponse adminRemoveHost(AdminRemoveHostRequest request_)
Removes a host from an existing cluster.
HasTypeResponse hasType(HasTypeRequest request_)
Check for the existence of a type.
ShowStatisticsResponse showStatistics(IList< string > table_names, IDictionary< string, string > options=null)
Retrieves the collected column statistics for the specified table(s).
AggregateUniqueResponse aggregateUnique(string table_name, string column_name, long offset=0, long limit=-9999, IDictionary< string, string > options=null)
Returns all the unique values from a particular column (specified by column_name ) of a particular ta...
CreateCredentialResponse createCredential(CreateCredentialRequest request_)
Create a new credential.
ShowTableResponse showTable(string table_name, IDictionary< string, string > options=null)
Retrieves detailed information about a table, view, or schema, specified in table_name .
A set of results returned by Kinetica.showDatasource.
A set of parameters for Kinetica.alterTableMonitor.
A set of results returned by Kinetica.createDatasink.
GrantPermissionDirectoryResponse grantPermissionDirectory(GrantPermissionDirectoryRequest request_)
Grants a KiFS directory-level permission to a user or role.
DeleteGraphResponse deleteGraph(string graph_name, IDictionary< string, string > options=null)
Deletes an existing graph from the graph server and/or persist.
FilterByListResponse filterByList(string table_name, string view_name, IDictionary< string, IList< string >> column_values_map, IDictionary< string, string > options=null)
Calculates which records from a table have values in the given list for the corresponding column.
HasTypeResponse hasType(string type_id, IDictionary< string, string > options=null)
Check for the existence of a type.
A set of parameters for Kinetica.createType.
AggregateMinMaxGeometryResponse aggregateMinMaxGeometry(string table_name, string column_name, IDictionary< string, string > options=null)
Calculates and returns the minimum and maximum x- and y-coordinates of a particular geospatial geomet...
A set of parameters for Kinetica.updateRecords.
A set of parameters for Kinetica.deleteFiles.
A set of results returned by Kinetica.exportQueryMetrics.
A set of parameters for Kinetica.createDatasink.
A set of parameters for Kinetica.alterResourceGroup.
A set of results returned by Kinetica.createUserInternal.
A set of parameters for Kinetica.showResourceObjects.
ShowDirectoriesResponse showDirectories(string directory_name="", IDictionary< string, string > options=null)
Shows information about directories in KiFS.
A set of results returned by Kinetica.hasSchema.
AdminRebalanceResponse adminRebalance(AdminRebalanceRequest request_)
Rebalance the data in the cluster so that all nodes contain an equal number of records approximately ...
A set of parameters for Kinetica.showFiles.
AggregateGroupByResponse aggregateGroupBy(string table_name, IList< string > column_names, long offset=0, long limit=-9999, IDictionary< string, string > options=null)
Calculates unique combinations (groups) of values for the given columns in a given table or view and ...
A set of results returned by Kinetica.exportRecordsToTable.
CreateUnionResponse createUnion(CreateUnionRequest request_)
Merges data from one or more tables with comparable data types into a new table.
A set of results returned by Kinetica.createCredential.
DropCredentialResponse dropCredential(DropCredentialRequest request_)
Drop an existing credential.
FilterByTableResponse filterByTable(FilterByTableRequest request_)
Filters objects in one table based on objects in another table.
VisualizeImageChartResponse visualizeImageChart(string table_name, IList< string > x_column_names, IList< string > y_column_names, double min_x, double max_x, double min_y, double max_y, int width, int height, string bg_color, IDictionary< string, IList< string >> style_options, IDictionary< string, string > options=null)
Scatter plot is the only plot type currently supported.
A set of parameters for Kinetica.alterTableColumns.
string response_schema_str
Avro schema of binary_encoded_response or json_encoded_response.
A set of results returned by Kinetica.createTableMonitor.
AdminRemoveRanksResponse adminRemoveRanks(IList< string > ranks, IDictionary< string, string > options=null)
Remove one or more ranks from an existing Kinetica cluster.
IDictionary< string, string > info
Additional information.
CreateJobResponse createJob(CreateJobRequest request_)
Create a job which will run asynchronously.
A set of results returned by Kinetica.showSystemTiming.
string table_name
Name of table to which the records are to be added, in [schema_name.
ShowTriggersResponse showTriggers(ShowTriggersRequest request_)
Retrieves information regarding the specified triggers or all existing triggers currently active.
A set of results returned by Kinetica.alterSystemProperties.
A set of results returned by Kinetica.dropDatasource.
ShowSchemaResponse showSchema(string schema_name, IDictionary< string, string > options=null)
Retrieves information about a schema (or all schemas), as specified in schema_name .
GrantRoleResponse grantRole(GrantRoleRequest request_)
Grants membership in a role to a user or role.
IDictionary< string, string > info
Additional information.
A set of results returned by Kinetica.adminShowClusterOperations.
LockTableResponse lockTable(string table_name, string lock_type=LockTableRequest.LockType.STATUS, IDictionary< string, string > options=null)
Manages global access to a table's data.
ShowGraphResponse showGraph(ShowGraphRequest request_)
Shows information and characteristics of graphs that exist on the graph server.
A set of parameters for Kinetica.uploadFilesFromurl.
AdminOfflineResponse adminOffline(bool offline, IDictionary< string, string > options=null)
Take the system offline.
RevokePermissionTableResponse revokePermissionTable(RevokePermissionTableRequest request_)
Revokes a table-level permission from a user or role.
RevokeRoleResponse revokeRole(string role, string member, IDictionary< string, string > options=null)
Revokes membership in a role from a user or role.
A set of parameters for Kinetica.adminBackupBegin.
KillProcResponse killProc(string run_id="", IDictionary< string, string > options=null)
Kills a running proc instance.
A set of results returned by Kinetica.clearTable.
long total_number_of_records
Total/Filtered number of records.
A set of results returned by Kinetica.clearTableMonitor.
A set of parameters for Kinetica.dropSchema.
A set of results returned by Kinetica.adminRemoveHost.
DropDatasourceResponse dropDatasource(string name, IDictionary< string, string > options=null)
Drops an existing data source.
DeleteFilesResponse deleteFiles(IList< string > file_names, IDictionary< string, string > options=null)
Deletes one or more files from KiFS.
RevokePermissionDatasourceResponse revokePermissionDatasource(RevokePermissionDatasourceRequest request_)
Revokes a data source permission from a user or role.
CreateCatalogResponse createCatalog(string name, string table_format, string location, string type, string credential, string datasource, IDictionary< string, string > options=null)
Creates a catalog, which contains the location and connection information for a deltalake catalog tha...
ShowWalResponse showWal(ShowWalRequest request_)
Requests table write-ahead log (WAL) properties.Returns information about the requested table WAL ent...
CreateBackupResponse createBackup(string backup_name, string backup_type, IDictionary< string, string > backup_objects_map, string datasink_name, IDictionary< string, string > options=null)
Creates a database backup, containing a snapshot of existing objects, at the remote file store access...
AdminShowShardsResponse adminShowShards(AdminShowShardsRequest request_)
Show the mapping of shards to the corresponding rank and tom.
HasPermissionResponse hasPermission(string principal, string _object, string object_type, string permission, IDictionary< string, string > options=null)
Checks if the specified user has the specified permission on the specified object.
QueryGraphResponse queryGraph(QueryGraphRequest request_)
Employs a topological query on a graph generated a-priori by createGraph and returns a list of adjace...
AlterSystemPropertiesResponse alterSystemProperties(AlterSystemPropertiesRequest request_)
The alterSystemProperties endpoint is primarily used to simplify the testing of the system and is not...
bool has_more_records
Too many records.
A set of results returned by Kinetica.alterRole.
A set of parameters for Kinetica.alterTable.
AggregateMinMaxGeometryResponse aggregateMinMaxGeometry(AggregateMinMaxGeometryRequest request_)
Calculates and returns the minimum and maximum x- and y-coordinates of a particular geospatial geomet...
ShowDatasinkResponse showDatasink(ShowDatasinkRequest request_)
Shows information about a specified data sink or all data sinks.
A set of results returned by Kinetica.filterBySeries.
A set of parameters for Kinetica.createProc.
ShowTableMonitorsResponse showTableMonitors(IList< string > monitor_ids, IDictionary< string, string > options=null)
Show table monitors and their properties.
A set of results returned by Kinetica.grantPermission.
bool has_more_records
Too many records.
A set of parameters for Kinetica.adminAlterHost.
bool has_more_records
Too many records.
AdminAddRanksResponse adminAddRanks(AdminAddRanksRequest request_)
Add one or more ranks to an existing Kinetica cluster.
InsertRecordsRandomResponse insertRecordsRandom(string table_name, long count, IDictionary< string, IDictionary< string, double >> options=null)
Generates a specified number of random records and adds them to the given table.
HasProcResponse hasProc(string proc_name, IDictionary< string, string > options=null)
Checks the existence of a proc with the given name.
string table_name
The same table name as was passed in the parameter list.
AggregateMinMaxResponse aggregateMinMax(AggregateMinMaxRequest request_)
Calculates and returns the minimum and maximum values of a particular column in a table.
A set of results returned by Kinetica.insertSymbol.
DeleteFilesResponse deleteFiles(DeleteFilesRequest request_)
Deletes one or more files from KiFS.
AdminBackupBeginResponse adminBackupBegin(AdminBackupBeginRequest request_)
Prepares the system for a backup by closing all open file handles after allowing current active jobs ...
FilterByAreaResponse filterByArea(FilterByAreaRequest request_)
Calculates which objects from a table are within a named area of interest (NAI/polygon).
string response_schema_str
Avro schema of binary_encoded_response or json_encoded_response.
DropDatasinkResponse dropDatasink(string name, IDictionary< string, string > options=null)
Drops an existing data sink.
AdminShowClusterOperationsResponse adminShowClusterOperations(AdminShowClusterOperationsRequest request_)
Requests the detailed status of the current operation (by default) or a prior cluster operation speci...
ShowWalResponse showWal(IList< string > table_names, IDictionary< string, string > options=null)
Requests table write-ahead log (WAL) properties.Returns information about the requested table WAL ent...
KillProcResponse killProc(KillProcRequest request_)
Kills a running proc instance.
AlterWalResponse alterWal(AlterWalRequest request_)
Alters table write-ahead log (WAL) settings.Returns information about the requested table WAL modific...
string table_name
The same table name as was passed in the parameter list.
A set of parameters for Kinetica.aggregateHistogram.
A set of parameters for Kinetica.alterSchema.
IList< string > type_names
The type IDs (one per series/track) of the returned series/tracks.
bool has_more_records
Too many records.
A set of results returned by Kinetica.visualizeImageChart.
A set of results returned by Kinetica.alterResourceGroup.
A set of parameters for Kinetica.insertRecordsFromQuery.
A set of results returned by Kinetica.getRecords.
A set of parameters for Kinetica.grantPermissionDirectory.
A set of results returned by Kinetica.createTriggerByRange.
CreateTableResponse createTable(CreateTableRequest request_)
Creates a new table with the given type (definition of columns).
AdminRepairTableResponse adminRepairTable(IList< string > table_names, IDictionary< string, string > table_types, IDictionary< string, string > options=null)
Manually repair a corrupted table.Returns information about affected tables.
A set of parameters for Kinetica.deleteRecords.
A set of parameters for Kinetica.lockTable.
A set of parameters for Kinetica.deleteRole.
AlterSchemaResponse alterSchema(AlterSchemaRequest request_)
Used to change the name of a SQL-style schema, specified in schema_name.
A set of parameters for Kinetica.showProcStatus.
A set of results returned by Kinetica.downloadFiles.
AlterSchemaResponse alterSchema(string schema_name, string action, string _value, IDictionary< string, string > options=null)
Used to change the name of a SQL-style schema, specified in schema_name .
A set of results returned by Kinetica.clearStatistics.
DropDatasinkResponse dropDatasink(DropDatasinkRequest request_)
Drops an existing data sink.
AlterDirectoryResponse alterDirectory(AlterDirectoryRequest request_)
Alters an existing directory in KiFS.
long total_number_of_records
Total/Filtered number of records.
string paging_table
Name of the table that has the result records of the query.
A set of parameters for Kinetica.aggregateStatisticsByRange.
AdminSendAlertResponse adminSendAlert(string message, string label, string log_level, IDictionary< string, string > options=null)
Sends a user generated alert to the monitoring system.
A set of results returned by Kinetica.exportRecordsToFiles.
IList< KineticaRecord > data
Avro binary encoded response.
A set of parameters for Kinetica.appendRecords.
A set of parameters for Kinetica.revokePermissionCredential.
A set of parameters for Kinetica.createTableMonitor.
A set of parameters for Kinetica.downloadFiles.
CreateDirectoryResponse createDirectory(string directory_name, IDictionary< string, string > options=null)
Creates a new directory in KiFS.
A set of results returned by Kinetica.aggregateMinMax.
A set of parameters for Kinetica.alterDatasink.
A set of results returned by Kinetica.filterByRadius.
AggregateStatisticsResponse aggregateStatistics(AggregateStatisticsRequest request_)
Calculates the requested statistics of the given column(s) in a given table.
A set of parameters for Kinetica.clearTable.
string type_definition
Value of type_definition.
A set of parameters for Kinetica.createUnion.
InsertRecordsFromPayloadResponse insertRecordsFromPayload(string table_name, string data_text, byte[] data_bytes, IDictionary< string, IDictionary< string, string >> modify_columns=null, IDictionary< string, string > create_table_options=null, IDictionary< string, string > options=null)
Reads from the given text-based or binary payload and inserts the data into a new or existing table.
AlterDirectoryResponse alterDirectory(string directory_name, IDictionary< string, string > directory_updates_map, IDictionary< string, string > options=null)
Alters an existing directory in KiFS.
A set of results returned by Kinetica.createTriggerByArea.
CreateDatasinkResponse createDatasink(CreateDatasinkRequest request_)
Creates a data sink, which contains the destination information for a data sink that is external to t...
A set of parameters for Kinetica.showSystemTiming.
bool has_more_records
Too many records.
A set of results returned by Kinetica.adminShowJobs.
ShowEnvironmentResponse showEnvironment(ShowEnvironmentRequest request_)
Shows information about a specified user-defined function (UDF) environment or all environments....
string response_schema_str
Avro schema of binary_encoded_response or json_encoded_response.
AlterVideoResponse alterVideo(string path, IDictionary< string, string > options=null)
Alters a video.
AdminShutdownResponse adminShutdown(AdminShutdownRequest request_)
Exits the database server application.
GrantPermissionProcResponse grantPermissionProc(GrantPermissionProcRequest request_)
Grants a proc-level permission to a user or role.
A set of results returned by Kinetica.aggregateUnpivot.
IList< string > type_names
The type IDs of the corresponding records in records_binary or records_json.
const string DISTRIBUTED
Input table data will be divided into data segments that are distributed across all nodes in the clus...
ShowSecurityResponse showSecurity(ShowSecurityRequest request_)
Shows security information relating to users and/or roles.
A set of parameters for Kinetica.deleteResourceGroup.
A set of results returned by Kinetica.alterTier.
A set of results returned by Kinetica.adminAlterHost.
A set of results returned by Kinetica.clearTrigger.
ShowTablesByTypeResponse showTablesByType(ShowTablesByTypeRequest request_)
Gets names of the tables whose type matches the given criteria.
A set of results returned by Kinetica.createDatasource.
GrantPermissionCredentialResponse grantPermissionCredential(GrantPermissionCredentialRequest request_)
Grants a credential-level permission to a user or role.
A set of results returned by Kinetica.dropCatalog.
ExecuteSqlResponse executeSql(ExecuteSqlRequest request_)
Execute a SQL statement (query, DML, or DDL).
A set of parameters for Kinetica.revokePermissionDatasource.
A set of parameters for Kinetica.createEnvironment.
ShowBackupResponse showBackup(ShowBackupRequest request_)
Shows information about one or more backups accessible via the data source specified by datasource_na...
A set of results returned by Kinetica.revokePermission.
RepartitionGraphResponse repartitionGraph(string graph_name, IDictionary< string, string > options=null)
Rebalances an existing partitioned graph.
A set of results returned by Kinetica.adminSwitchover.
CreateJoinTableResponse createJoinTable(CreateJoinTableRequest request_)
Creates a table that is the result of a SQL JOIN.
ShowDatasourceResponse showDatasource(string name, IDictionary< string, string > options=null)
Shows information about a specified data source or all data sources.
InsertRecordsFromQueryResponse insertRecordsFromQuery(InsertRecordsFromQueryRequest request_)
Computes remote query result and inserts the result data into a new or existing table
FilterByAreaGeometryResponse filterByAreaGeometry(string table_name, string view_name, string column_name, IList< double > x_vector, IList< double > y_vector, IDictionary< string, string > options=null)
Calculates which geospatial geometry objects from a table intersect a named area of interest (NAI/pol...
CreateGraphResponse createGraph(CreateGraphRequest request_)
Creates a new graph network using given nodes, edges, weights, and restrictions.
ShowSqlProcResponse showSqlProc(string procedure_name="", IDictionary< string, string > options=null)
Shows information about SQL procedures, including the full definition of each requested procedure.
RevokePermissionProcResponse revokePermissionProc(RevokePermissionProcRequest request_)
Revokes a proc-level permission from a user or role.
GrantPermissionSystemResponse grantPermissionSystem(GrantPermissionSystemRequest request_)
Grants a system-level permission to a user or role.
AdminRemoveRanksResponse adminRemoveRanks(AdminRemoveRanksRequest request_)
Remove one or more ranks from an existing Kinetica cluster.
CreateJobResponse createJob(string endpoint, string request_encoding, byte[] data, string data_str, IDictionary< string, string > options=null)
Create a job which will run asynchronously.
A set of parameters for Kinetica.filterByRadius.
A set of results returned by Kinetica.hasTable.
A set of results returned by Kinetica.adminBackupBegin.
A set of results returned by Kinetica.dropCredential.
ShowProcStatusResponse showProcStatus(string run_id="", IDictionary< string, string > options=null)
Shows the statuses of running or completed proc instances.
A set of parameters for Kinetica.adminAddHost.
ShowVideoResponse showVideo(ShowVideoRequest request_)
Retrieves information about rendered videos.
ShowTriggersResponse showTriggers(IList< string > trigger_ids, IDictionary< string, string > options=null)
Retrieves information regarding the specified triggers or all existing triggers currently active.
A set of parameters for Kinetica.exportRecordsToTable.
DropDatasourceResponse dropDatasource(DropDatasourceRequest request_)
Drops an existing data source.
FilterByValueResponse filterByValue(string table_name, string view_name, bool is_string, double _value, string value_str, string column_name, IDictionary< string, string > options=null)
Calculates which objects from a table has a particular value for a particular column.
RevokePermissionTableResponse revokePermissionTable(string name, string permission, string table_name, IDictionary< string, string > options=null)
Revokes a table-level permission from a user or role.
A set of parameters for Kinetica.createMaterializedView.
A set of parameters for Kinetica.alterVideo.
A set of results returned by Kinetica.adminBackupEnd.
A set of results returned by Kinetica.grantPermissionProc.
A set of parameters for Kinetica.createUserExternal.
string table_name
Value of table_name.
A set of parameters for Kinetica.showGraph.
bool has_more_records
Too many records.
ExportRecordsToTableResponse exportRecordsToTable(string table_name, string remote_query="", IDictionary< string, string > options=null)
Exports records from source table to the specified target table in an external database
bool has_more_records
Too many records.
DeleteProcResponse deleteProc(string proc_name, IDictionary< string, string > options=null)
Deletes a proc.
string table_name
The same table name as was passed in the parameter list.
A set of results returned by Kinetica.aggregateUnpivot.
CreateCredentialResponse createCredential(string credential_name, string type, string identity, string secret, IDictionary< string, string > options=null)
Create a new credential.
A set of parameters for Kinetica.adminShutdown.
A set of results returned by Kinetica.filterByValue.
A set of parameters for Kinetica.filterByAreaGeometry.
AlterDatasourceResponse alterDatasource(AlterDatasourceRequest request_)
Alters the properties of an existing data source
A set of results returned by Kinetica.filterByString.
A set of parameters for Kinetica.updateRecordsRaw.
GrantPermissionDatasourceResponse grantPermissionDatasource(GrantPermissionDatasourceRequest request_)
Grants a data source permission to a user or role.
ShowSchemaResponse showSchema(ShowSchemaRequest request_)
Retrieves information about a schema (or all schemas), as specified in schema_name.
GetRecordsBySeriesResponse< T > getRecordsBySeries< T >(GetRecordsBySeriesRequest request_)
Retrieves the complete series/track records from the given world_table_name based on the partial trac...
A set of parameters for Kinetica.clearStatistics.
DeleteRoleResponse deleteRole(DeleteRoleRequest request_)
Deletes an existing role.
ClearTableMonitorResponse clearTableMonitor(string topic_id, IDictionary< string, string > options=null)
Deactivates a table monitor previously created with createTableMonitor.
ShowSystemStatusResponse showSystemStatus(ShowSystemStatusRequest request_)
Provides server configuration and health related status to the caller.
CreateMaterializedViewResponse createMaterializedView(CreateMaterializedViewRequest request_)
Initiates the process of creating a materialized view, reserving the view's name to prevent other vie...
IDictionary< string, string > info
Additional information.
DropBackupResponse dropBackup(string backup_name, string datasink_name, IDictionary< string, string > options=null)
Deletes one or more existing database backups and contained snapshots, accessible via the data sink s...
ShowResourceObjectsResponse showResourceObjects(IDictionary< string, string > options=null)
Returns information about the internal sub-components (tiered objects) which use resources of the sys...
A set of results returned by Kinetica.alterUser.
AppendRecordsResponse appendRecords(string table_name, string source_table_name, IDictionary< string, string > field_map, IDictionary< string, string > options=null)
Append (or insert) all records from a source table (specified by source_table_name ) to a particular ...
const string STATUS
Show locked status
A set of results returned by Kinetica.updateRecords.
Convenience class for using Avro.Generic.GenericRecord objects.
RevokePermissionSystemResponse revokePermissionSystem(string name, string permission, IDictionary< string, string > options=null)
Revokes a system-level permission from a user or role.
GrantPermissionResponse grantPermission(GrantPermissionRequest request_)
Grant user or role the specified permission on the specified object.
A set of parameters for Kinetica.showResourceStatistics.
GetRecordsByColumnResponse getRecordsByColumn(string table_name, IList< string > column_names, long offset=0, long limit=-9999, IDictionary< string, string > options=null)
For a given table, retrieves the values from the requested column(s).
A set of parameters for Kinetica.getRecordsByColumn.
A set of results returned by Kinetica.alterDatasink.
A set of parameters for Kinetica.grantPermissionDatasource.
string table_name
The same table name as was passed in the parameter list.
A set of parameters for Kinetica.revokePermissionSystem.
A set of parameters for Kinetica.createDatasource.
bool has_more_records
Too many records.
ShowFilesResponse showFiles(IList< string > paths, IDictionary< string, string > options=null)
Shows information about files in KiFS.
A set of parameters for Kinetica.createBackup.
AdminVerifyDbResponse adminVerifyDb(IDictionary< string, string > options=null)
Verify database is in a consistent state.
InsertSymbolResponse insertSymbol(string symbol_id, string symbol_format, byte[] symbol_data, IDictionary< string, string > options=null)
Adds a symbol or icon (i.e.
AdminSwitchoverResponse adminSwitchover(IList< string > processes, IList< string > destinations, IDictionary< string, string > options=null)
Manually switch over one or more processes to another host.
RepartitionGraphResponse repartitionGraph(RepartitionGraphRequest request_)
Rebalances an existing partitioned graph.
const string MARKOV_CHAIN
Matches sample_points to the graph using the Hidden Markov Model (HMM)-based method,...
A set of parameters for Kinetica.restoreBackup.
InsertRecordsFromFilesResponse insertRecordsFromFiles(InsertRecordsFromFilesRequest request_)
Reads from one or more files and inserts the data into a new or existing table.
A set of parameters for Kinetica.showCredential.
A set of parameters for Kinetica.grantPermissionCredential.
A set of parameters for Kinetica.adminAlterJobs.
GrantRoleResponse grantRole(string role, string member, IDictionary< string, string > options=null)
Grants membership in a role to a user or role.
CreateTriggerByAreaResponse createTriggerByArea(string request_id, IList< string > table_names, string x_column_name, IList< double > x_vector, string y_column_name, IList< double > y_vector, IDictionary< string, string > options=null)
Sets up an area trigger mechanism for two column_names for one or more tables.
CreateGraphResponse createGraph(string graph_name, bool directed_graph, IList< string > nodes, IList< string > edges, IList< string > weights, IList< string > restrictions, IDictionary< string, string > options=null)
Creates a new graph network using given nodes, edges, weights, and restrictions.
ShowDirectoriesResponse showDirectories(ShowDirectoriesRequest request_)
Shows information about directories in KiFS.
A set of results returned by Kinetica.alterTableColumns.
A set of parameters for Kinetica.exportRecordsToFiles.
A set of results returned by Kinetica.deleteDirectory.
AlterTableColumnsResponse alterTableColumns(string table_name, IList< IDictionary< string, string >> column_alterations, IDictionary< string, string > options)
Apply various modifications to columns in a table, view.
AdminOfflineResponse adminOffline(AdminOfflineRequest request_)
Take the system offline.
HasSchemaResponse hasSchema(HasSchemaRequest request_)
Checks for the existence of a schema with the given name.
InsertRecordsFromQueryResponse insertRecordsFromQuery(string table_name, string remote_query, IDictionary< string, IDictionary< string, string >> modify_columns=null, IDictionary< string, string > create_table_options=null, IDictionary< string, string > options=null)
Computes remote query result and inserts the result data into a new or existing table
GrantPermissionDatasourceResponse grantPermissionDatasource(string name, string permission, string datasource_name, IDictionary< string, string > options=null)
Grants a data source permission to a user or role.
ShowSystemTimingResponse showSystemTiming(IDictionary< string, string > options=null)
Returns the last 100 database requests along with the request timing and internal job ID.
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
A set of parameters for Kinetica.clearTables.
GetRecordsResponse< T > getRecords< T >(GetRecordsRequest request_)
Retrieves records from a given table, optionally filtered by an expression and/or sorted by a column.
A set of results returned by Kinetica.killProc.
A set of results returned by Kinetica.adminAlterJobs.
FilterByStringResponse filterByString(string table_name, string view_name, string expression, string mode, IList< string > column_names, IDictionary< string, string > options=null)
Calculates which objects from a table or view match a string expression for the given string columns.
RevokePermissionProcResponse revokePermissionProc(string name, string permission, string proc_name, IDictionary< string, string > options=null)
Revokes a proc-level permission from a user or role.
A set of results returned by Kinetica.alterDatasource.
byte [] binary_encoded_response
Avro binary encoded response.
A set of results returned by Kinetica.grantPermissionDatasource.
AlterDatasinkResponse alterDatasink(AlterDatasinkRequest request_)
Alters the properties of an existing data sink
UploadFilesFromurlResponse uploadFilesFromurl(UploadFilesFromurlRequest request_)
Uploads one or more files to KiFS.
DropSchemaResponse dropSchema(DropSchemaRequest request_)
Drops an existing SQL-style schema, specified in schema_name.
A set of parameters for Kinetica.showSystemProperties.
RevokePermissionCredentialResponse revokePermissionCredential(string name, string permission, string credential_name, IDictionary< string, string > options=null)
Revokes a credential-level permission from a user or role.
ShowResourceStatisticsResponse showResourceStatistics(ShowResourceStatisticsRequest request_)
Requests various statistics for storage/memory tiers and resource groups.Returns statistics on a per-...
A set of parameters for Kinetica.showDatasink.
CreateUserInternalResponse createUserInternal(string name, string password, IDictionary< string, string > options=null)
Creates a new internal user (a user whose credentials are managed by the database system).
ClearStatisticsResponse clearStatistics(ClearStatisticsRequest request_)
Clears statistics (cardinality, mean value, etc.) for a column in a specified table.
AdminShowShardsResponse adminShowShards(IDictionary< string, string > options=null)
Show the mapping of shards to the corresponding rank and tom.
ShowResourceStatisticsResponse showResourceStatistics(IDictionary< string, string > options=null)
Requests various statistics for storage/memory tiers and resource groups.Returns statistics on a per-...
A set of results returned by Kinetica.createProjection.
CreateUnionResponse createUnion(string table_name, IList< string > table_names, IList< IList< string >> input_column_names, IList< string > output_column_names, IDictionary< string, string > options=null)
Merges data from one or more tables with comparable data types into a new table.
CreateTableResponse createTable(string table_name, string type_id, IDictionary< string, string > options=null)
Creates a new table with the given type (definition of columns).
AlterWalResponse alterWal(IList< string > table_names, IDictionary< string, string > options=null)
Alters table write-ahead log (WAL) settings.Returns information about the requested table WAL modific...
CreateMaterializedViewResponse createMaterializedView(string table_name, IDictionary< string, string > options=null)
Initiates the process of creating a materialized view, reserving the view's name to prevent other vie...
IList< string > type_schemas
The type schemas (one per series/track) of the returned series/tracks.
long total_number_of_records
Total/Filtered number of records.
A set of results returned by Kinetica.revokePermissionProc.
A set of parameters for Kinetica.alterRole.
FilterByRadiusResponse filterByRadius(FilterByRadiusRequest request_)
Calculates which objects from a table lie within a circle with the given radius and center point (i....
void DecodeRawBinaryDataUsingTypeIDs< T >(IList< string > type_ids, IList< byte[]> records_binary, IList< T > records)
Given IDs of records types registered with Kinetica, decode binary data into distinct records (object...
ShowStatisticsResponse showStatistics(ShowStatisticsRequest request_)
Retrieves the collected column statistics for the specified table(s).
AppendRecordsResponse appendRecords(AppendRecordsRequest request_)
Append (or insert) all records from a source table (specified by source_table_name) to a particular t...
A set of results returned by Kinetica.showSqlProc.
A set of parameters for Kinetica.deleteProc.
A set of parameters for Kinetica.hasProc.
string type_schema
Avro schema of records_binary or records_json
ShowResourceGroupsResponse showResourceGroups(IList< string > names, IDictionary< string, string > options=null)
Requests resource group properties.Returns detailed information about the requested resource groups.
A set of parameters for Kinetica.solveGraph.
A set of results returned by Kinetica.showGraph.
AlterRoleResponse alterRole(AlterRoleRequest request_)
Alters a Role.
A set of parameters for Kinetica.filterBySeries.
A set of results returned by Kinetica.adminShutdown.
A set of parameters for Kinetica.showDirectories.
A set of parameters for Kinetica.grantPermissionTable.
AdminBackupEndResponse adminBackupEnd(AdminBackupEndRequest request_)
Restores the system to normal operating mode after a backup has completed, allowing any queries that ...
A set of results returned by Kinetica.grantPermissionTable.
A set of results returned by Kinetica.showTable.
A set of results returned by Kinetica.aggregateHistogram.
HasProcResponse hasProc(HasProcRequest request_)
Checks the existence of a proc with the given name.
string table_name
Typically shows the result-table name if provided in the request (Ignore otherwise).
AlterDatasinkResponse alterDatasink(string name, IDictionary< string, string > datasink_updates_map, IDictionary< string, string > options)
Alters the properties of an existing data sink
CollectStatisticsResponse collectStatistics(CollectStatisticsRequest request_)
Collect statistics for a column(s) in a specified table.
A set of string constants for the parameter ranking.
A set of parameters for Kinetica.adminBackupEnd.
A set of parameters for Kinetica.showEnvironment.
A set of results returned by Kinetica.showDirectories.
A set of parameters for Kinetica.alterTier.
AlterUserResponse alterUser(AlterUserRequest request_)
Alters a user.
ShowSystemTimingResponse showSystemTiming(ShowSystemTimingRequest request_)
Returns the last 100 database requests along with the request timing and internal job ID.
VisualizeIsochroneResponse visualizeIsochrone(string graph_name, string source_node, double max_solution_radius, IList< string > weights_on_edges, IList< string > restrictions, int num_levels, bool generate_image, string levels_table, IDictionary< string, string > style_options, IDictionary< string, string > solve_options=null, IDictionary< string, string > contour_options=null, IDictionary< string, string > options=null)
Generate an image containing isolines for travel results using an existing graph.
AdminRebalanceResponse adminRebalance(IDictionary< string, string > options=null)
Rebalance the data in the cluster so that all nodes contain an equal number of records approximately ...
byte [] binary_encoded_response
Avro binary encoded response.
MatchGraphResponse matchGraph(string graph_name, IList< string > sample_points, string solve_method=MatchGraphRequest.SolveMethod.MARKOV_CHAIN, string solution_table="", IDictionary< string, string > options=null)
Matches a directed route implied by a given set of latitude/longitude points to an existing underlyin...
A set of results returned by Kinetica.createDirectory.
AlterSystemPropertiesResponse alterSystemProperties(IDictionary< string, string > property_updates_map, IDictionary< string, string > options=null)
The alterSystemProperties endpoint is primarily used to simplify the testing of the system and is not...
A set of results returned by Kinetica.aggregateUnique.
A set of results returned by Kinetica.filterByBoxGeometry.
RevokePermissionCredentialResponse revokePermissionCredential(RevokePermissionCredentialRequest request_)
Revokes a credential-level permission from a user or role.
A set of parameters for Kinetica.adminShowShards.
A set of parameters for Kinetica.showTypes.
A set of results returned by Kinetica.showResourceGroups.
A set of parameters for Kinetica.filterByArea.
A set of results returned by Kinetica.repartitionGraph.
ShowGraphResponse showGraph(string graph_name="", IDictionary< string, string > options=null)
Shows information and characteristics of graphs that exist on the graph server.
ShowFilesResponse showFiles(ShowFilesRequest request_)
Shows information about files in KiFS.
AdminBackupBeginResponse adminBackupBegin(IDictionary< string, string > options=null)
Prepares the system for a backup by closing all open file handles after allowing current active jobs ...
CollectStatisticsResponse collectStatistics(string table_name, IList< string > column_names, IDictionary< string, string > options=null)
Collect statistics for a column(s) in a specified table.
A set of results returned by Kinetica.deleteRecords.
byte [] binary_encoded_response
Avro binary encoded response.
AggregateGroupByResponse aggregateGroupBy(AggregateGroupByRequest request_)
Calculates unique combinations (groups) of values for the given columns in a given table or view and ...
A set of parameters for Kinetica.grantPermissionSystem.
A set of results returned by Kinetica.deleteResourceGroup.
GetJobResponse getJob(long job_id, IDictionary< string, string > options=null)
Get the status and result of asynchronously running job.
AdminHaOfflineResponse adminHaOffline(AdminHaOfflineRequest request_)
Pauses consumption of messages from other HA clusters to support data repair/recovery scenarios.
RevokeRoleResponse revokeRole(RevokeRoleRequest request_)
Revokes membership in a role from a user or role.
A set of results returned by Kinetica.getRecordsBySeries.
A set of results returned by Kinetica.adminAddHost.
DeleteResourceGroupResponse deleteResourceGroup(string name, IDictionary< string, string > options=null)
Deletes a resource group.
A set of results returned by Kinetica.executeSql.
AlterEnvironmentResponse alterEnvironment(string environment_name, string action, string _value, IDictionary< string, string > options=null)
Alters an existing environment which can be referenced by a user-defined function (UDF).
AdminHaRefreshResponse adminHaRefresh(AdminHaRefreshRequest request_)
Restarts the HA processing on the given cluster as a mechanism of accepting breaking HA conf changes.
CreateTableMonitorResponse createTableMonitor(CreateTableMonitorRequest request_)
Creates a monitor that watches for a single table modification event type (insert,...
AlterTierResponse alterTier(AlterTierRequest request_)
Alters properties of an existing tier to facilitate resource management.
LockTableResponse lockTable(LockTableRequest request_)
Manages global access to a table's data.
CreateResourceGroupResponse createResourceGroup(CreateResourceGroupRequest request_)
Creates a new resource group to facilitate resource management.
AlterTableMonitorResponse alterTableMonitor(AlterTableMonitorRequest request_)
Alters a table monitor previously created with createTableMonitor.
A set of results returned by Kinetica.showVideo.
A set of results returned by Kinetica.grantPermissionCredential.
SolveGraphResponse solveGraph(SolveGraphRequest request_)
Solves an existing graph for a type of problem (e.g., shortest path, page rank, traveling salesman,...
A set of results returned by Kinetica.alterSchema.
A set of parameters for Kinetica.grantRole.
A set of results returned by Kinetica.alterEnvironment.
A set of results returned by Kinetica.deleteRole.
A set of results returned by Kinetica.createMaterializedView.
string response_schema_str
Avro schema of binary_encoded_response or json_encoded_response.
CreateTypeResponse createType(string type_definition, string label, IDictionary< string, IList< string >> properties=null, IDictionary< string, string > options=null)
Creates a new type describing the columns of a table.
CreateTableExternalResponse createTableExternal(CreateTableExternalRequest request_)
Creates a new external table, which is a local database object whose source data is located externall...
AlterTierResponse alterTier(string name, IDictionary< string, string > options=null)
Alters properties of an existing tier to facilitate resource management.
A set of parameters for Kinetica.filterByList.
AlterDatasourceResponse alterDatasource(string name, IDictionary< string, string > datasource_updates_map, IDictionary< string, string > options)
Alters the properties of an existing data source
A set of parameters for Kinetica.showDatasource.
A set of parameters for Kinetica.createTableExternal.
GetRecordsFromCollectionResponse< T > getRecordsFromCollection< T >(GetRecordsFromCollectionRequest request_)
Retrieves records from a collection.
A set of parameters for Kinetica.filterByValue.
CreateJoinTableResponse createJoinTable(string join_table_name, IList< string > table_names, IList< string > column_names, IList< string > expressions=null, IDictionary< string, string > options=null)
Creates a table that is the result of a SQL JOIN.
A set of results returned by Kinetica.filterByTable.
CreateProcResponse createProc(CreateProcRequest request_)
Creates an instance (proc) of the user-defined functions (UDF) specified by the given command,...
AlterCredentialResponse alterCredential(string credential_name, IDictionary< string, string > credential_updates_map, IDictionary< string, string > options)
Alter the properties of an existing credential.
RevokePermissionDatasourceResponse revokePermissionDatasource(string name, string permission, string datasource_name, IDictionary< string, string > options=null)
Revokes a data source permission from a user or role.
AlterBackupResponse alterBackup(string backup_name, string action, string _value, string datasink_name, IDictionary< string, string > options=null)
Alters an existing database backup, accessible via the data sink specified by datasink_name .
AggregateStatisticsByRangeResponse aggregateStatisticsByRange(AggregateStatisticsByRangeRequest request_)
Divides the given set into bins and calculates statistics of the values of a value-column in each bin...
IList< IDictionary< string, IList< string > > > properties
GetJobResponse getJob(GetJobRequest request_)
Get the status and result of asynchronously running job.
A set of results returned by Kinetica.showStatistics.
A set of parameters for Kinetica.createProjection.
A set of parameters for Kinetica.createTriggerByRange.
FilterByAreaGeometryResponse filterByAreaGeometry(FilterByAreaGeometryRequest request_)
Calculates which geospatial geometry objects from a table intersect a named area of interest (NAI/pol...
AdminAddHostResponse adminAddHost(string host_address, IDictionary< string, string > options=null)
Adds a host to an existing cluster.
IDictionary< string, string > info
Additional information.
FilterByBoxResponse filterByBox(string table_name, string view_name, string x_column_name, double min_x, double max_x, string y_column_name, double min_y, double max_y, IDictionary< string, string > options=null)
Calculates how many objects within the given table lie in a rectangular box.
A set of parameters for Kinetica.revokePermissionDirectory.
FilterByGeometryResponse filterByGeometry(string table_name, string view_name, string column_name, string input_wkt, string operation, IDictionary< string, string > options=null)
Applies a geometry filter against a geospatial geometry column in a given table or view.
A set of parameters for Kinetica.showBackup.
A set of results returned by Kinetica.createJob.
IDictionary< string, string > info
Additional information.
A set of parameters for Kinetica.adminRemoveHost.
UploadFilesResponse uploadFiles(IList< string > file_names, IList< byte[]> file_data, IDictionary< string, string > options=null)
Uploads one or more files to KiFS.
DownloadFilesResponse downloadFiles(DownloadFilesRequest request_)
Downloads one or more files from KiFS.
FilterByRangeResponse filterByRange(FilterByRangeRequest request_)
Calculates which objects from a table have a column that is within the given bounds.
A set of parameters for Kinetica.dropEnvironment.
CreateSchemaResponse createSchema(CreateSchemaRequest request_)
Creates a SQL-style schema.
A set of parameters for Kinetica.revokePermission.
HasRoleResponse hasRole(string principal, string role, IDictionary< string, string > options=null)
Checks if the specified user has the specified role.
InsertRecordsFromFilesResponse insertRecordsFromFiles(string table_name, IList< string > filepaths, IDictionary< string, IDictionary< string, string >> modify_columns=null, IDictionary< string, string > create_table_options=null, IDictionary< string, string > options=null)
Reads from one or more files and inserts the data into a new or existing table.
A set of results returned by Kinetica.matchGraph.
A set of results returned by Kinetica.revokePermissionCredential.
ClearStatisticsResponse clearStatistics(string table_name="", string column_name="", IDictionary< string, string > options=null)
Clears statistics (cardinality, mean value, etc.) for a column in a specified table.
CreateTriggerByRangeResponse createTriggerByRange(CreateTriggerByRangeRequest request_)
Sets up a simple range trigger for a column_name for one or more tables.
A set of parameters for Kinetica.alterDatasource.
bool has_more_records
Too many records.
AdminShowAlertsResponse adminShowAlerts(int num_alerts, IDictionary< string, string > options=null)
Requests a list of the most recent alerts.Returns lists of alert data, including timestamp and type.
A set of parameters for Kinetica.hasSchema.
long total_number_of_records
Total/Filtered number of records.
A set of parameters for Kinetica.createGraph.
A set of parameters for Kinetica.insertRecords.
DropSchemaResponse dropSchema(string schema_name, IDictionary< string, string > options=null)
Drops an existing SQL-style schema, specified in schema_name .
AggregateUnpivotResponse aggregateUnpivot(AggregateUnpivotRequest request_)
Rotate the column values into rows values.
AdminShutdownResponse adminShutdown(string exit_type, string authorization, IDictionary< string, string > options=null)
Exits the database server application.
A set of results returned by Kinetica.createRole.
A set of parameters for Kinetica.executeSql.
FilterByRadiusResponse filterByRadius(string table_name, string view_name, string x_column_name, double x_center, string y_column_name, double y_center, double radius, IDictionary< string, string > options=null)
Calculates which objects from a table lie within a circle with the given radius and center point (i....
A set of parameters for Kinetica.aggregateUnpivot.
const string SHORTEST_PATH
Solves for the optimal (shortest) path based on weights and restrictions from one source to destinati...
A set of results returned by Kinetica.getRecordsByColumn.
RevokePermissionDirectoryResponse revokePermissionDirectory(RevokePermissionDirectoryRequest request_)
Revokes a KiFS directory-level permission from a user or role.
A set of parameters for Kinetica.alterUser.
A set of parameters for Kinetica.adminRepairTable.
UploadFilesResponse uploadFiles(UploadFilesRequest request_)
Uploads one or more files to KiFS.
A set of parameters for Kinetica.exportQueryMetrics.
A set of parameters for Kinetica.uploadFiles.
ShowDatasinkResponse showDatasink(string name, IDictionary< string, string > options=null)
Shows information about a specified data sink or all data sinks.
IList< string > record_ids
If the 'return_record_ids' option of the request was 'true', then this list contains the internal ID ...
HasSchemaResponse hasSchema(string schema_name, IDictionary< string, string > options=null)
Checks for the existence of a schema with the given name.
A set of parameters for Kinetica.hasRole.
A set of results returned by Kinetica.filterByArea.
CreateUserExternalResponse createUserExternal(string name, IDictionary< string, string > options=null)
Creates a new external user (a user whose credentials are managed by an external LDAP).
A set of parameters for Kinetica.createCredential.
AdminShowJobsResponse adminShowJobs(AdminShowJobsRequest request_)
Get a list of the current jobs in GPUdb.
FilterBySeriesResponse filterBySeries(string table_name, string view_name, string track_id, IList< string > target_track_ids, IDictionary< string, string > options=null)
Filters objects matching all points of the given track (works only on track type data).
A set of parameters for Kinetica.adminRemoveRanks.
A set of parameters for Kinetica.createTable.
AlterVideoResponse alterVideo(AlterVideoRequest request_)
Alters a video.
AlterUserResponse alterUser(string name, string action, string _value, IDictionary< string, string > options=null)
Alters a user.
IList< IDictionary< string, IList< string > > > properties
Property maps of the respective tables in table_names.
IList< IDictionary< string, string > > new_values_maps
List of new values for the matching records.
A set of parameters for Kinetica.getRecords.
CreateEnvironmentResponse createEnvironment(CreateEnvironmentRequest request_)
Creates a new environment which can be used by user-defined functions (UDF).
A set of results returned by Kinetica.revokeRole.
ShowBackupResponse showBackup(string backup_name, string datasource_name, IDictionary< string, string > options=null)
Shows information about one or more backups accessible via the data source specified by datasource_na...
RestoreBackupResponse restoreBackup(RestoreBackupRequest request_)
Restores database objects from a backup accessible via the data source specified by datasource_name.
string table_name
Typically shows the result-table name if provided in the request (Ignore otherwise).
IDictionary< string, string > info
Additional information.
A set of results returned by Kinetica.createJoinTable.
A set of results returned by Kinetica.createBackup.
A set of parameters for Kinetica.filterByBoxGeometry.
ShowProcResponse showProc(string proc_name="", IDictionary< string, string > options=null)
Shows information about a proc.
ClearTableMonitorResponse clearTableMonitor(ClearTableMonitorRequest request_)
Deactivates a table monitor previously created with createTableMonitor.
IDictionary< string, string > info
Additional information.
void DecodeRawBinaryDataUsingSchemaString< T >(string schema_string, IList< byte[]> records_binary, IList< T > records)
Given a schema string for a certain record type, decode binary data into distinct records (objects).
AggregateHistogramResponse aggregateHistogram(AggregateHistogramRequest request_)
Performs a histogram calculation given a table, a column, and an interval function.
IList< byte[]> records_binary
If the encoding parameter of the request was 'binary' then this list contains the binary encoded reco...
ExecuteProcResponse executeProc(string proc_name, IDictionary< string, string > _params=null, IDictionary< string, byte[]> bin_params=null, IList< string > input_table_names=null, IDictionary< string, IList< string >> input_column_names=null, IList< string > output_table_names=null, IDictionary< string, string > options=null)
Executes a proc.
FilterByGeometryResponse filterByGeometry(FilterByGeometryRequest request_)
Applies a geometry filter against a geospatial geometry column in a given table or view.
A set of results returned by Kinetica.showTableMonitors.
string table_name
Name of table to be updated, in [schema_name.
A set of results returned by Kinetica.showTablesByType.
A set of parameters for Kinetica.adminSwitchover.
CreateTypeResponse createType(CreateTypeRequest request_)
Creates a new type describing the columns of a table.
AlterTableMetadataResponse alterTableMetadata(IList< string > table_names, IDictionary< string, string > metadata_map, IDictionary< string, string > options=null)
Updates (adds or changes) metadata for tables.
FilterByRadiusGeometryResponse filterByRadiusGeometry(string table_name, string view_name, string column_name, double x_center, double y_center, double radius, IDictionary< string, string > options=null)
Calculates which geospatial geometry objects from a table intersect a circle with the given radius an...
A set of parameters for Kinetica.insertSymbol.
IList< KineticaRecord > data
Avro binary encoded response.
DeleteGraphResponse deleteGraph(DeleteGraphRequest request_)
Deletes an existing graph from the graph server and/or persist.
A set of results returned by Kinetica.revokePermissionTable.
A set of results returned by Kinetica.adminSendAlert.
DeleteUserResponse deleteUser(string name, IDictionary< string, string > options=null)
Deletes an existing user.
CreateBackupResponse createBackup(CreateBackupRequest request_)
Creates a database backup, containing a snapshot of existing objects, at the remote file store access...
AlterCredentialResponse alterCredential(AlterCredentialRequest request_)
Alter the properties of an existing credential.
AdminShowJobsResponse adminShowJobs(IDictionary< string, string > options=null)
Get a list of the current jobs in GPUdb.
A set of string constants for the parameter solve_method.
CreateDatasinkResponse createDatasink(string name, string destination, IDictionary< string, string > options=null)
Creates a data sink, which contains the destination information for a data sink that is external to t...
long total_number_of_records
Total/Filtered number of records.
CreateUserInternalResponse createUserInternal(CreateUserInternalRequest request_)
Creates a new internal user (a user whose credentials are managed by the database system).
A set of parameters for Kinetica.getRecordsFromCollection.
A set of parameters for Kinetica.adminRebalance.
ClearTableResponse clearTable(ClearTableRequest request_)
Clears (drops) one or all tables in the database cluster.
ShowTableResponse showTable(ShowTableRequest request_)
Retrieves detailed information about a table, view, or schema, specified in table_name.
DropEnvironmentResponse dropEnvironment(string environment_name, IDictionary< string, string > options=null)
Drop an existing user-defined function (UDF) environment.
RevokePermissionResponse revokePermission(string principal, string _object, string object_type, string permission, IDictionary< string, string > options=null)
Revoke user or role the specified permission on the specified object.
A set of results returned by Kinetica.showSystemStatus.
A set of results returned by Kinetica.insertRecordsFromFiles.
ShowSystemPropertiesResponse showSystemProperties(IDictionary< string, string > options=null)
Returns server configuration and version related information to the caller.
A set of results returned by Kinetica.aggregateUnique.
AggregateStatisticsResponse aggregateStatistics(string table_name, string column_name, string stats, IDictionary< string, string > options=null)
Calculates the requested statistics of the given column(s) in a given table.
DeleteUserResponse deleteUser(DeleteUserRequest request_)
Deletes an existing user.
A set of parameters for Kinetica.hasType.
A set of parameters for Kinetica.filterByGeometry.
A set of parameters for Kinetica.grantPermission.
A set of parameters for Kinetica.adminShowAlerts.
ClearTriggerResponse clearTrigger(string trigger_id, IDictionary< string, string > options=null)
Clears or cancels the trigger identified by the specified handle.
ExportRecordsToFilesResponse exportRecordsToFiles(ExportRecordsToFilesRequest request_)
Export records from a table to files.
A set of parameters for Kinetica.repartitionGraph.
A set of results returned by Kinetica.executeProc.
A set of results returned by Kinetica.createVideo.
FilterByBoxGeometryResponse filterByBoxGeometry(FilterByBoxGeometryRequest request_)
Calculates which geospatial geometry objects from a table intersect a rectangular box.
A set of parameters for Kinetica.adminSendAlert.
CreateEnvironmentResponse createEnvironment(string environment_name, IDictionary< string, string > options=null)
Creates a new environment which can be used by user-defined functions (UDF).
byte [] binary_encoded_response
Avro binary encoded response.
CreateDatasourceResponse createDatasource(string name, string location, string user_name, string password, IDictionary< string, string > options=null)
Creates a data source, which contains the location and connection information for a data store that i...
AdminRemoveHostResponse adminRemoveHost(string host, IDictionary< string, string > options=null)
Removes a host from an existing cluster.
IDictionary< string, IList< string > > properties
Value of properties.
FilterByAreaResponse filterByArea(string table_name, string view_name, string x_column_name, IList< double > x_vector, string y_column_name, IList< double > y_vector, IDictionary< string, string > options=null)
Calculates which objects from a table are within a named area of interest (NAI/polygon).
ShowCredentialResponse showCredential(string credential_name, IDictionary< string, string > options=null)
Shows information about a specified credential or all credentials.
CreateCatalogResponse createCatalog(CreateCatalogRequest request_)
Creates a catalog, which contains the location and connection information for a deltalake catalog tha...
A set of parameters for Kinetica.visualizeIsochrone.
CreateProjectionResponse createProjection(string table_name, string projection_name, IList< string > column_names, IDictionary< string, string > options=null)
Creates a new projection of an existing table.
A set of results returned by Kinetica.createCatalog.
A set of parameters for Kinetica.aggregateConvexHull.
GrantPermissionProcResponse grantPermissionProc(string name, string permission, string proc_name, IDictionary< string, string > options=null)
Grants a proc-level permission to a user or role.
ExportQueryMetricsResponse exportQueryMetrics(IDictionary< string, string > options=null)
Export query metrics to a given destination.Returns query metrics.
A set of parameters for Kinetica.showTable.
A set of results returned by Kinetica.alterTableMonitor.
A set of results returned by Kinetica.showSchema.
long total_number_of_records
Total/Filtered number of records.
A set of results returned by Kinetica.createProc.
AlterBackupResponse alterBackup(AlterBackupRequest request_)
Alters an existing database backup, accessible via the data sink specified by datasink_name.
A set of parameters for Kinetica.alterSystemProperties.
A set of parameters for Kinetica.showSqlProc.
ShowSystemPropertiesResponse showSystemProperties(ShowSystemPropertiesRequest request_)
Returns server configuration and version related information to the caller.
A set of results returned by Kinetica.createGraph.
CreateDatasourceResponse createDatasource(CreateDatasourceRequest request_)
Creates a data source, which contains the location and connection information for a data store that i...
A set of parameters for Kinetica.filterByRange.
AggregateStatisticsByRangeResponse aggregateStatisticsByRange(string table_name, string select_expression, string column_name, string value_column_name, string stats, double start, double end, double interval, IDictionary< string, string > options=null)
Divides the given set into bins and calculates statistics of the values of a value-column in each bin...
AggregateHistogramResponse aggregateHistogram(string table_name, string column_name, double start, double end, double interval, IDictionary< string, string > options=null)
Performs a histogram calculation given a table, a column, and an interval function.
AdminAlterHostResponse adminAlterHost(string host, IDictionary< string, string > options=null)
Alter properties on an existing host in the cluster.
A set of parameters for Kinetica.revokeRole.
A set of results returned by Kinetica.dropDatasink.
A set of parameters for Kinetica.deleteDirectory.
FilterBySeriesResponse filterBySeries(FilterBySeriesRequest request_)
Filters objects matching all points of the given track (works only on track type data).
ShowTypesResponse showTypes(string type_id, string label, IDictionary< string, string > options=null)
Retrieves information for the specified data type ID or type label.
A set of parameters for Kinetica.showProc.
A set of results returned by Kinetica.aggregateGroupBy.
A set of parameters for Kinetica.showSchema.
ExecuteProcResponse executeProc(ExecuteProcRequest request_)
Executes a proc.
A set of results returned by Kinetica.getRecordsFromCollection.
A set of parameters for Kinetica.dropCredential.
string paging_table
Name of the table that has the result records of the query.
FilterByRangeResponse filterByRange(string table_name, string view_name, string column_name, double lower_bound, double upper_bound, IDictionary< string, string > options=null)
Calculates which objects from a table have a column that is within the given bounds.
A set of results returned by Kinetica.alterVideo.
string type_id
An identifier representing the created type.
A set of parameters for Kinetica.insertRecordsRaw.
AggregateMinMaxResponse aggregateMinMax(string table_name, string column_name, IDictionary< string, string > options=null)
Calculates and returns the minimum and maximum values of a particular column in a table.
InsertRecordsResponse insertRecords< T >(InsertRecordsRequest< T > request_)
Adds multiple records to the specified table.
A set of parameters for Kinetica.filterByRadiusGeometry.
AlterTableResponse alterTable(AlterTableRequest request_)
Apply various modifications to a table or view.
CreateVideoResponse createVideo(string attribute, string begin, double duration_seconds, string end, double frames_per_second, string style, string path, string style_parameters, IDictionary< string, string > options=null)
Creates a job to generate a sequence of raster images that visualize data over a specified time.
A set of results returned by Kinetica.showTriggers.
A set of parameters for Kinetica.aggregateKMeans.
MatchGraphResponse matchGraph(MatchGraphRequest request_)
Matches a directed route implied by a given set of latitude/longitude points to an existing underlyin...
A set of parameters for Kinetica.createJob.
A set of results returned by Kinetica.showDatasink.
A set of parameters for Kinetica.alterCredential.
CreateTriggerByAreaResponse createTriggerByArea(CreateTriggerByAreaRequest request_)
Sets up an area trigger mechanism for two column_names for one or more tables.
A set of parameters for Kinetica.createDirectory.
A set of results returned by Kinetica.revokePermissionDirectory.
GrantPermissionTableResponse grantPermissionTable(GrantPermissionTableRequest request_)
Grants a table-level permission to a user or role.
A set of results returned by Kinetica.appendRecords.
A set of results returned by Kinetica.dropSchema.
A set of results returned by Kinetica.filterByRadiusGeometry.
A set of string constants for the parameter lock_type.
A set of parameters for Kinetica.collectStatistics.
A set of results returned by Kinetica.filterByBox.
A set of results returned by Kinetica.showProc.
AlterTableResponse alterTable(string table_name, string action, string _value, IDictionary< string, string > options=null)
Apply various modifications to a table or view.
A set of results returned by Kinetica.createUserExternal.
AdminBackupEndResponse adminBackupEnd(IDictionary< string, string > options=null)
Restores the system to normal operating mode after a backup has completed, allowing any queries that ...
A set of results returned by Kinetica.insertRecordsFromPayload.
A set of results returned by Kinetica.filterByAreaGeometry.
CreateResourceGroupResponse createResourceGroup(string name, IDictionary< string, IDictionary< string, string >> tier_attributes, string ranking, string adjoining_resource_group="", IDictionary< string, string > options=null)
Creates a new resource group to facilitate resource management.
FilterByRadiusGeometryResponse filterByRadiusGeometry(FilterByRadiusGeometryRequest request_)
Calculates which geospatial geometry objects from a table intersect a circle with the given radius an...
InsertSymbolResponse insertSymbol(InsertSymbolRequest request_)
Adds a symbol or icon (i.e.
A set of results returned by Kinetica.hasRole.
IDictionary< string, string > info
Additional information.
A set of parameters for Kinetica.adminHaOffline.
AdminShowClusterOperationsResponse adminShowClusterOperations(int history_index=0, IDictionary< string, string > options=null)
Requests the detailed status of the current operation (by default) or a prior cluster operation speci...
CreateUserExternalResponse createUserExternal(CreateUserExternalRequest request_)
Creates a new external user (a user whose credentials are managed by an external LDAP).
AggregateKMeansResponse aggregateKMeans(AggregateKMeansRequest request_)
This endpoint runs the k-means algorithm - a heuristic algorithm that attempts to do k-means clusteri...
A set of parameters for Kinetica.dropDatasource.
ShowTableMonitorsResponse showTableMonitors(ShowTableMonitorsRequest request_)
Show table monitors and their properties.
ShowTableMetadataResponse showTableMetadata(ShowTableMetadataRequest request_)
Retrieves the user provided metadata for the specified tables.
A set of results returned by Kinetica.adminVerifyDb.
long count_affected
The number of objects/records affected.
A set of results returned by Kinetica.solveGraph.
AdminAlterJobsResponse adminAlterJobs(AdminAlterJobsRequest request_)
Perform the requested action on a list of one or more job(s).
AlterEnvironmentResponse alterEnvironment(AlterEnvironmentRequest request_)
Alters an existing environment which can be referenced by a user-defined function (UDF).
A set of results returned by Kinetica.uploadFiles.
FilterByValueResponse filterByValue(FilterByValueRequest request_)
Calculates which objects from a table has a particular value for a particular column.
A set of results returned by Kinetica.getJob.
SolveGraphResponse solveGraph(string graph_name, IList< string > weights_on_edges=null, IList< string > restrictions=null, string solver_type=SolveGraphRequest.SolverType.SHORTEST_PATH, IList< string > source_nodes=null, IList< string > destination_nodes=null, string solution_table="graph_solutions", IDictionary< string, string > options=null)
Solves an existing graph for a type of problem (e.g., shortest path, page rank, traveling salesman,...
GrantPermissionResponse grantPermission(string principal, string _object, string object_type, string permission, IDictionary< string, string > options=null)
Grant user or role the specified permission on the specified object.
GrantPermissionSystemResponse grantPermissionSystem(string name, string permission, IDictionary< string, string > options=null)
Grants a system-level permission to a user or role.
A set of parameters for Kinetica.showSecurity.
UploadFilesFromurlResponse uploadFilesFromurl(IList< string > file_names, IList< string > urls, IDictionary< string, string > options=null)
Uploads one or more files to KiFS.
FilterByListResponse filterByList(FilterByListRequest request_)
Calculates which records from a table have values in the given list for the corresponding column.
A set of parameters for Kinetica.createCatalog.
string response_schema_str
Avro schema of binary_encoded_response or json_encoded_response.
IDictionary< string, string > info
Additional information.
CreateDirectoryResponse createDirectory(CreateDirectoryRequest request_)
Creates a new directory in KiFS.
FilterByBoxGeometryResponse filterByBoxGeometry(string table_name, string view_name, string column_name, double min_x, double max_x, double min_y, double max_y, IDictionary< string, string > options=null)
Calculates which geospatial geometry objects from a table intersect a rectangular box.
AggregateUnpivotResponse aggregateUnpivot(string table_name, IList< string > column_names, string variable_column_name, string value_column_name, IList< string > pivoted_columns, IDictionary< string, string > options=null)
Rotate the column values into rows values.
RestoreBackupResponse restoreBackup(string backup_name, IDictionary< string, string > restore_objects_map, string datasource_name, IDictionary< string, string > options=null)
Restores database objects from a backup accessible via the data source specified by datasource_name .
A set of results returned by Kinetica.restoreBackup.
A set of results returned by Kinetica.showResourceStatistics.
FilterResponse filter(string table_name, string view_name, string expression, IDictionary< string, string > options=null)
Filters data based on the specified expression.
A set of parameters for Kinetica.killProc.
A set of parameters for Kinetica.filterByString.
A set of results returned by Kinetica.createSchema.
A set of parameters for Kinetica.filter.
A set of results returned by Kinetica.hasProc.
HasTableResponse hasTable(string table_name, IDictionary< string, string > options=null)
Checks for the existence of a table with the given name.
A set of parameters for Kinetica.showVideo.
A set of parameters for Kinetica.revokePermissionProc.
A set of parameters for Kinetica.aggregateMinMaxGeometry.
CreateVideoResponse createVideo(CreateVideoRequest request_)
Creates a job to generate a sequence of raster images that visualize data over a specified time.
A set of results returned by Kinetica.visualizeIsochrone.
IDictionary< string, string > info
Additional information.
A set of parameters for Kinetica.createTriggerByArea.
A set of results returned by Kinetica.hasType.
A set of parameters for Kinetica.alterEnvironment.
ShowTablesByTypeResponse showTablesByType(string type_id, string label, IDictionary< string, string > options=null)
Gets names of the tables whose type matches the given criteria.
FilterResponse filter(FilterRequest request_)
Filters data based on the specified expression.
A set of parameters for Kinetica.showTableMonitors.
A set of parameters for Kinetica.createVideo.
A set of results returned by Kinetica.showBackup.
A set of parameters for Kinetica.alterDirectory.
DropCredentialResponse dropCredential(string credential_name, IDictionary< string, string > options=null)
Drop an existing credential.
VisualizeImageChartResponse visualizeImageChart(VisualizeImageChartRequest request_)
Scatter plot is the only plot type currently supported.
CreateRoleResponse createRole(CreateRoleRequest request_)
Creates a new role.
ClearTriggerResponse clearTrigger(ClearTriggerRequest request_)
Clears or cancels the trigger identified by the specified handle.
A set of results returned by Kinetica.filterByGeometry.
A set of results returned by Kinetica.showCredential.
A set of results returned by Kinetica.createTableExternal.
A set of parameters for Kinetica.adminAddRanks.
A set of parameters for Kinetica.adminHaRefresh.
A set of parameters for Kinetica.matchGraph.
UpdateRecordsResponse updateRecordsRaw(RawUpdateRecordsRequest request_)
Runs multiple predicate-based updates in a single call.
RevokePermissionDirectoryResponse revokePermissionDirectory(string name, string permission, string directory_name, IDictionary< string, string > options=null)
Revokes a KiFS directory-level permission from a user or role.
ExecuteSqlResponse executeSql(string statement, long offset=0, long limit=-9999, string request_schema_str="", IList< byte[]> data=null, IDictionary< string, string > options=null)
Execute a SQL statement (query, DML, or DDL).
IList< string > type_labels
Type labels of the respective tables in table_names.
A set of results returned by Kinetica.filterByRange.
IList< string > type_ids
Type IDs of the respective tables in table_names.
A set of parameters for Kinetica.clearTableMonitor.
ShowTableMetadataResponse showTableMetadata(IList< string > table_names, IDictionary< string, string > options=null)
Retrieves the user provided metadata for the specified tables.
A set of results returned by Kinetica.getRecordsFromCollection.
A set of parameters for Kinetica.dropBackup.
static IList< KineticaRecord > DecodeDynamicTableRecords(string dynamic_table_schema_string, byte[] encoded_data)
Decodes binary encoded data of a dynamically created table returned by the server.
A set of results returned by Kinetica.deleteGraph.
ShowProcResponse showProc(ShowProcRequest request_)
Shows information about a proc.
A set of parameters for Kinetica.deleteUser.
A set of parameters for Kinetica.showTablesByType.
A set of results returned by Kinetica.grantPermissionDirectory.
GrantPermissionTableResponse grantPermissionTable(string name, string permission, string table_name, string filter_expression="", IDictionary< string, string > options=null)
Grants a table-level permission to a user or role.
A set of results returned by Kinetica.adminHaOffline.
bool has_more_records
Too many records.
AlterTableMonitorResponse alterTableMonitor(string topic_id, IDictionary< string, string > monitor_updates_map, IDictionary< string, string > options=null)
Alters a table monitor previously created with createTableMonitor.
A set of results returned by Kinetica.showSecurity.
A set of results returned by Kinetica.filter.
IList< KineticaRecord > data
Avro binary encoded response.
CreateTableExternalResponse createTableExternal(string table_name, IList< string > filepaths, IDictionary< string, IDictionary< string, string >> modify_columns=null, IDictionary< string, string > create_table_options=null, IDictionary< string, string > options=null)
Creates a new external table, which is a local database object whose source data is located externall...
A set of results returned by Kinetica.createTable.
A set of results returned by Kinetica.showWal.
ShowDatasourceResponse showDatasource(ShowDatasourceRequest request_)
Shows information about a specified data source or all data sources.
IList< string > expressions
A list of the actual predicates, one for each update; format should follow the guidelines here.
AdminAddRanksResponse adminAddRanks(IList< string > hosts, IList< IDictionary< string, string >> config_params, IDictionary< string, string > options=null)
Add one or more ranks to an existing Kinetica cluster.
IList< IList< byte[]> > list_records_binary
If the encoding parameter of the request was 'binary' then this list-of-lists contains the binary enc...
AdminShowAlertsResponse adminShowAlerts(AdminShowAlertsRequest request_)
Requests a list of the most recent alerts.Returns lists of alert data, including timestamp and type.
AdminAlterJobsResponse adminAlterJobs(IList< long > job_ids, string action, IDictionary< string, string > options=null)
Perform the requested action on a list of one or more job(s).
InsertRecordsRandomResponse insertRecordsRandom(InsertRecordsRandomRequest request_)
Generates a specified number of random records and adds them to the given table.
A set of parameters for Kinetica.adminShowClusterOperations.
DropBackupResponse dropBackup(DropBackupRequest request_)
Deletes one or more existing database backups and contained snapshots, accessible via the data sink s...
ShowSystemStatusResponse showSystemStatus(IDictionary< string, string > options=null)
Provides server configuration and health related status to the caller.
AggregateUniqueResponse aggregateUnique(AggregateUniqueRequest request_)
Returns all the unique values from a particular column (specified by column_name) of a particular tab...
A set of results returned by Kinetica.insertRecordsFromQuery.
HasRoleResponse hasRole(HasRoleRequest request_)
Checks if the specified user has the specified role.
A set of parameters for Kinetica.clearTrigger.
RevokePermissionResponse revokePermission(RevokePermissionRequest request_)
Revoke user or role the specified permission on the specified object.
A set of parameters for Kinetica.aggregateStatistics.
ModifyGraphResponse modifyGraph(string graph_name, IList< string > nodes, IList< string > edges, IList< string > weights, IList< string > restrictions, IDictionary< string, string > options=null)
Update an existing graph network using given nodes, edges, weights, restrictions, and options.
ShowTypesResponse showTypes(ShowTypesRequest request_)
Retrieves information for the specified data type ID or type label.
QueryGraphResponse queryGraph(string graph_name, IList< string > queries, IList< string > restrictions=null, string adjacency_table="", int rings=1, IDictionary< string, string > options=null)
Employs a topological query on a graph generated a-priori by createGraph and returns a list of adjace...
long total_number_of_records
Total/Filtered number of records.
RevokePermissionSystemResponse revokePermissionSystem(RevokePermissionSystemRequest request_)
Revokes a system-level permission from a user or role.
CreateSchemaResponse createSchema(string schema_name, IDictionary< string, string > options=null)
Creates a SQL-style schema.
A set of results returned by Kinetica.modifyGraph.
AlterRoleResponse alterRole(string name, string action, string _value, IDictionary< string, string > options=null)
Alters a Role.
A set of results returned by Kinetica.insertRecords.
A set of parameters for Kinetica.insertRecordsRandom.
A set of parameters for Kinetica.queryGraph.
A set of parameters for Kinetica.adminVerifyDb.
ClearTablesResponse clearTables(IList< string > table_names=null, IDictionary< string, string > options=null)
Clears (drops) tables in the database cluster.
A set of results returned by Kinetica.dropBackup.
DownloadFilesResponse downloadFiles(IList< string > file_names, IList< long > read_offsets, IList< long > read_lengths, IDictionary< string, string > options=null)
Downloads one or more files from KiFS.
GetRecordsByColumnResponse getRecordsByColumn(GetRecordsByColumnRequest request_)
For a given table, retrieves the values from the requested column(s).
VisualizeIsochroneResponse visualizeIsochrone(VisualizeIsochroneRequest request_)
Generate an image containing isolines for travel results using an existing graph.
A set of parameters for Kinetica.filterByTable.
A set of results returned by Kinetica.aggregateStatisticsByRange.
FilterByBoxResponse filterByBox(FilterByBoxRequest request_)
Calculates how many objects within the given table lie in a rectangular box.
A set of results returned by Kinetica.adminRemoveRanks.
AdminRepairTableResponse adminRepairTable(AdminRepairTableRequest request_)
Manually repair a corrupted table.Returns information about affected tables.
ShowCredentialResponse showCredential(ShowCredentialRequest request_)
Shows information about a specified credential or all credentials.
A set of results returned by Kinetica.createResourceGroup.
A set of parameters for Kinetica.showResourceGroups.
A set of results returned by Kinetica.queryGraph.
ModifyGraphResponse modifyGraph(ModifyGraphRequest request_)
Update an existing graph network using given nodes, edges, weights, restrictions, and options.
A set of results returned by Kinetica.showProcStatus.
A set of parameters for Kinetica.createUserInternal.
A set of parameters for Kinetica.insertRecordsFromFiles.
IDictionary< string, string > info
Additional information.
A set of string constants for the parameter solver_type.
DeleteRoleResponse deleteRole(string name, IDictionary< string, string > options=null)
Deletes an existing role.
A set of parameters for Kinetica.createSchema.
A set of parameters for Kinetica.visualizeImageChart.
A set of results returned by Kinetica.showEnvironment.
ClearTableResponse clearTable(string table_name="", string authorization="", IDictionary< string, string > options=null)
Clears (drops) one or all tables in the database cluster.
A set of parameters for Kinetica.showStatistics.
AdminSendAlertResponse adminSendAlert(AdminSendAlertRequest request_)
Sends a user generated alert to the monitoring system.
A set of results returned by Kinetica.deleteFiles.
ShowEnvironmentResponse showEnvironment(string environment_name="", IDictionary< string, string > options=null)
Shows information about a specified user-defined function (UDF) environment or all environments....
A set of results returned by Kinetica.uploadFilesFromurl.
A set of results returned by Kinetica.lockTable.
A set of results returned by Kinetica.alterDirectory.
ShowResourceGroupsResponse showResourceGroups(ShowResourceGroupsRequest request_)
Requests resource group properties.Returns detailed information about the requested resource groups.
A set of results returned by Kinetica.aggregateStatistics.
IList< byte[]> records_binary
If the encoding was 'binary', then this list contains the binary encoded records retrieved from the t...
long count_affected
The number of objects/records affected.
DeleteResourceGroupResponse deleteResourceGroup(DeleteResourceGroupRequest request_)
Deletes a resource group.
ExportRecordsToTableResponse exportRecordsToTable(ExportRecordsToTableRequest request_)
Exports records from source table to the specified target table in an external database
A set of results returned by Kinetica.alterTable.
IList< string > table_names
The table name (one per series/track) of the returned series/tracks.
A set of parameters for Kinetica.showWal.
CreateProjectionResponse createProjection(CreateProjectionRequest request_)
Creates a new projection of an existing table.
A set of parameters for Kinetica.alterWal.
InsertRecordsResponse insertRecordsRaw(RawInsertRecordsRequest request_)
Adds multiple records to the specified table.
AdminVerifyDbResponse adminVerifyDb(AdminVerifyDbRequest request_)
Verify database is in a consistent state.
A set of parameters for Kinetica.getJob.
A set of parameters for Kinetica.createJoinTable.
A set of parameters for Kinetica.showSystemStatus.
A set of parameters for Kinetica.executeProc.
DeleteDirectoryResponse deleteDirectory(DeleteDirectoryRequest request_)
Deletes a directory from KiFS.
ShowSecurityResponse showSecurity(IList< string > names, IDictionary< string, string > options=null)
Shows security information relating to users and/or roles.
A set of results returned by Kinetica.adminRepairTable.
ShowVideoResponse showVideo(IList< string > paths, IDictionary< string, string > options=null)
Retrieves information about rendered videos.
IList< KineticaRecord > data
Avro binary encoded response.
InsertRecordsFromPayloadResponse insertRecordsFromPayload(InsertRecordsFromPayloadRequest request_)
Reads from the given text-based or binary payload and inserts the data into a new or existing table.
ShowSqlProcResponse showSqlProc(ShowSqlProcRequest request_)
Shows information about SQL procedures, including the full definition of each requested procedure.
A set of parameters for Kinetica.alterBackup.
A set of results returned by Kinetica.getRecordsBySeries.
A set of parameters for Kinetica.createRole.
A set of parameters for Kinetica.adminShowJobs.
A set of results returned by Kinetica.showFiles.
AdminAlterHostResponse adminAlterHost(AdminAlterHostRequest request_)
Alter properties on an existing host in the cluster.
A set of string constants for the parameter execution_mode.
A set of results returned by Kinetica.createType.
A set of results returned by Kinetica.adminShowAlerts.
A set of parameters for Kinetica.aggregateUnique.
A set of results returned by Kinetica.showTypes.
IList< KineticaRecord > data
Avro binary encoded response.
A set of results returned by Kinetica.adminHaRefresh.
A set of results returned by Kinetica.deleteUser.
AggregateKMeansResponse aggregateKMeans(string table_name, IList< string > column_names, int k, double tolerance, IDictionary< string, string > options=null)
This endpoint runs the k-means algorithm - a heuristic algorithm that attempts to do k-means clusteri...
A set of results returned by Kinetica.adminShowShards.
A set of results returned by Kinetica.adminOffline.
DeleteProcResponse deleteProc(DeleteProcRequest request_)
Deletes a proc.
A set of results returned by Kinetica.filterByList.
DeleteRecordsResponse deleteRecords(string table_name, IList< string > expressions, IDictionary< string, string > options=null)
Deletes record(s) matching the provided criteria from the given table.
CreateTableMonitorResponse createTableMonitor(string table_name, IDictionary< string, string > options=null)
Creates a monitor that watches for a single table modification event type (insert,...
A set of results returned by Kinetica.getRecords.
ShowResourceObjectsResponse showResourceObjects(ShowResourceObjectsRequest request_)
Returns information about the internal sub-components (tiered objects) which use resources of the sys...
A set of parameters for Kinetica.insertRecordsFromPayload.
A set of parameters for Kinetica.adminOffline.
A set of results returned by Kinetica.collectStatistics.
AlterResourceGroupResponse alterResourceGroup(AlterResourceGroupRequest request_)
Alters the properties of an existing resource group to facilitate resource management.
A set of results returned by Kinetica.alterWal.
AlterResourceGroupResponse alterResourceGroup(string name, IDictionary< string, IDictionary< string, string >> tier_attributes=null, string ranking=AlterResourceGroupRequest.Ranking.EMPTY_STRING, string adjoining_resource_group="", IDictionary< string, string > options=null)
Alters the properties of an existing resource group to facilitate resource management.
ClearTablesResponse clearTables(ClearTablesRequest request_)
Clears (drops) tables in the database cluster.
A set of parameters for Kinetica.createResourceGroup.
DropCatalogResponse dropCatalog(DropCatalogRequest request_)
Drops an existing catalog.
DropCatalogResponse dropCatalog(string name, IDictionary< string, string > options=null)
Drops an existing catalog.
A set of results returned by Kinetica.aggregateMinMaxGeometry.
DeleteDirectoryResponse deleteDirectory(string directory_name, IDictionary< string, string > options=null)
Deletes a directory from KiFS.
IList< string > type_schemas
Type schemas of the respective tables in table_names.
A set of parameters for Kinetica.hasTable.
A set of results returned by Kinetica.revokePermissionDatasource.
A set of parameters for Kinetica.deleteGraph.
GrantPermissionCredentialResponse grantPermissionCredential(string name, string permission, string credential_name, IDictionary< string, string > options=null)
Grants a credential-level permission to a user or role.
AggregateConvexHullResponse aggregateConvexHull(string table_name, string x_column_name, string y_column_name, IDictionary< string, string > options=null)
Calculates and returns the convex hull for the values in a table specified by table_name .
A set of results returned by Kinetica.alterCredential.
CreateRoleResponse createRole(string name, IDictionary< string, string > options=null)
Creates a new role.
A set of parameters for Kinetica.aggregateGroupBy.
A set of results returned by Kinetica.deleteProc.
A set of results returned by Kinetica.executeSql.
AdminAddHostResponse adminAddHost(AdminAddHostRequest request_)
Adds a host to an existing cluster.
HasPermissionResponse hasPermission(HasPermissionRequest request_)
Checks if the specified user has the specified permission on the specified object.
A set of parameters for Kinetica.dropCatalog.
A set of parameters for Kinetica.revokePermissionTable.
A set of parameters for Kinetica.filterByBox.
A set of parameters for Kinetica.showTriggers.
DropEnvironmentResponse dropEnvironment(DropEnvironmentRequest request_)
Drop an existing user-defined function (UDF) environment.
ExportRecordsToFilesResponse exportRecordsToFiles(string table_name, string filepath, IDictionary< string, string > options=null)
Export records from a table to files.
ExportQueryMetricsResponse exportQueryMetrics(ExportQueryMetricsRequest request_)
Export query metrics to a given destination.Returns query metrics.
IDictionary< string, string > info
Additional information.
A set of results returned by Kinetica.alterBackup.