forked from heavyai/heavydb
-
Notifications
You must be signed in to change notification settings - Fork 0
/
omnisci.thrift
652 lines (576 loc) · 21.9 KB
/
omnisci.thrift
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
608
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
643
644
645
646
647
648
649
650
651
652
namespace java com.omnisci.thrift.server
namespace py omnisci.thrift
include "common.thrift"
include "completion_hints.thrift"
include "QueryEngine/serialized_result_set.thrift"
include "QueryEngine/extension_functions.thrift"
enum TExecuteMode {
GPU = 1,
CPU
}
enum TFileType {
DELIMITED,
POLYGON,
PARQUET
}
enum TPartitionDetail {
DEFAULT,
REPLICATED,
SHARDED,
OTHER
}
enum TGeoFileLayerContents {
EMPTY,
GEO,
NON_GEO,
UNSUPPORTED_GEO
}
enum TImportHeaderRow {
AUTODETECT,
NO_HEADER,
HAS_HEADER
}
enum TRole {
SERVER, // A single node instance
AGGREGATOR,
LEAF,
STRING_DICTIONARY
}
/* union */ struct TDatumVal {
1: i64 int_val;
2: double real_val;
3: string str_val;
4: list<TDatum> arr_val;
}
struct TDatum {
1: TDatumVal val;
2: bool is_null;
}
struct TStringValue {
1: string str_val;
2: bool is_null;
}
struct TColumnType {
1: string col_name;
2: common.TTypeInfo col_type;
3: bool is_reserved_keyword;
4: string src_name;
5: bool is_system;
6: bool is_physical;
7: i64 col_id;
8: optional string default_value;
}
struct TRow {
1: list<TDatum> cols;
}
/* union */ struct TColumnData {
1: list<i64> int_col;
2: list<double> real_col;
3: list<string> str_col;
4: list<TColumn> arr_col;
}
struct TColumn {
1: TColumnData data;
2: list<bool> nulls;
}
struct TStringRow {
1: list<TStringValue> cols;
}
typedef list<TColumnType> TRowDescriptor
typedef string TSessionId
typedef string TKrb5Token
typedef i64 TQueryId
typedef i64 TSubqueryId
struct TKrb5Session {
1: TSessionId sessionId;
2: TKrb5Token krbToken;
}
enum TMergeType {
UNION,
REDUCE
}
struct TStepResult {
1: serialized_result_set.TSerializedRows serialized_rows;
2: bool execution_finished;
3: TMergeType merge_type;
4: bool sharded;
5: TRowDescriptor row_desc;
6: i32 node_id;
}
struct TRowSet {
1: TRowDescriptor row_desc;
2: list<TRow> rows;
3: list<TColumn> columns;
4: bool is_columnar;
}
enum TQueryType {
UNKNOWN,
READ,
WRITE,
SCHEMA_READ,
SCHEMA_WRITE
}
enum TArrowTransport {
SHARED_MEMORY,
WIRE
}
struct TQueryResult {
1: TRowSet row_set;
2: i64 execution_time_ms;
3: i64 total_time_ms;
4: string nonce;
5: string debug;
6: bool success=true;
7: TQueryType query_type=TQueryType.UNKNOWN;
}
struct TDataFrame {
1: binary sm_handle;
2: i64 sm_size;
3: binary df_handle;
4: i64 df_size;
5: i64 execution_time_ms;
6: i64 arrow_conversion_time_ms;
7: binary df_buffer;
}
struct TDBInfo {
1: string db_name;
2: string db_owner;
}
exception TOmniSciException {
1: string error_msg;
}
struct TCopyParams {
1: string delimiter;
2: string null_str;
3: TImportHeaderRow has_header=TImportHeaderRow.AUTODETECT;
4: bool quoted;
5: string quote;
6: string escape;
7: string line_delim;
8: string array_delim;
9: string array_begin;
10: string array_end;
11: i32 threads;
12: TFileType file_type=TFileType.DELIMITED;
13: string s3_access_key;
14: string s3_secret_key;
15: string s3_region;
16: common.TEncodingType geo_coords_encoding=TEncodingType.GEOINT;
17: i32 geo_coords_comp_param=32;
18: common.TDatumType geo_coords_type=TDatumType.GEOMETRY;
19: i32 geo_coords_srid=4326;
20: bool sanitize_column_names=true;
21: string geo_layer_name;
22: string s3_endpoint;
23: bool geo_assign_render_groups=true;
24: bool geo_explode_collections=false;
25: i32 source_srid=0;
26: string s3_session_token;
}
struct TCreateParams {
1: bool is_replicated;
}
struct TDetectResult {
1: TRowSet row_set;
2: TCopyParams copy_params;
}
struct TImportStatus {
1: i64 elapsed;
2: i64 rows_completed;
3: i64 rows_estimated;
4: i64 rows_rejected;
}
struct TFrontendView {
1: string view_name;
2: string view_state;
3: string image_hash;
4: string update_time;
5: string view_metadata;
}
struct TServerStatus {
1: bool read_only;
2: string version;
3: bool rendering_enabled;
4: i64 start_time;
5: string edition;
6: string host_name;
7: bool poly_rendering_enabled;
8: TRole role;
9: string renderer_status_json;
}
struct TPixel {
1: i64 x;
2: i64 y;
}
struct TPixelTableRowResult {
1: TPixel pixel;
2: string vega_table_name;
3: list<i64> table_id;
4: list<i64> row_id;
5: TRowSet row_set;
6: string nonce;
}
struct TRenderResult {
1: binary image;
2: string nonce;
3: i64 execution_time_ms;
4: i64 render_time_ms;
5: i64 total_time_ms;
6: string vega_metadata;
}
struct TGpuSpecification {
1: i32 num_sm;
2: i64 clock_frequency_kHz;
3: i64 memory;
4: i16 compute_capability_major;
5: i16 compute_capability_minor;
}
struct THardwareInfo {
1: i16 num_gpu_hw;
2: i16 num_cpu_hw;
3: i16 num_gpu_allocated;
4: i16 start_gpu;
5: string host_name;
6: list<TGpuSpecification> gpu_info;
}
struct TClusterHardwareInfo {
1: list<THardwareInfo> hardware_info;
}
struct TMemoryData {
1: i64 slab;
2: i32 start_page;
3: i64 num_pages;
4: i32 touch;
5: list<i64> chunk_key;
6: i32 buffer_epoch;
7: bool is_free;
}
struct TNodeMemoryInfo {
1: string host_name;
2: i64 page_size;
3: i64 max_num_pages;
4: i64 num_pages_allocated;
5: bool is_allocation_capped;
6: list<TMemoryData> node_memory_data;
}
struct TTableMeta {
1: string table_name;
2: i64 num_cols;
4: bool is_view;
5: bool is_replicated;
6: i64 shard_count;
7: i64 max_rows;
8: i64 table_id;
9: i64 max_table_id;
10: list<common.TTypeInfo> col_types;
11: list<string> col_names;
}
struct TTableDetails {
1: TRowDescriptor row_desc;
2: i64 fragment_size;
3: i64 page_size;
4: i64 max_rows;
5: string view_sql;
6: i64 shard_count;
7: string key_metainfo;
8: bool is_temporary;
9: TPartitionDetail partition_detail;
}
enum TExpressionRangeType {
INVALID,
INTEGER,
FLOAT,
DOUBLE
}
struct TColumnRange {
1: TExpressionRangeType type;
2: i32 col_id;
3: i32 table_id;
4: bool has_nulls;
5: i64 int_min;
6: i64 int_max;
7: i64 bucket;
8: double fp_min;
9: double fp_max;
}
struct TDictionaryGeneration {
1: i32 dict_id;
2: i64 entry_count;
}
struct TTableGeneration {
1: i32 table_id;
2: i64 tuple_count;
3: i64 start_rowid;
}
struct TPendingQuery {
1: TQueryId id;
2: list<TColumnRange> column_ranges;
3: list<TDictionaryGeneration> dictionary_generations;
4: list<TTableGeneration> table_generations;
5: TSessionId parent_session_id;
}
struct TVarLen {
1: binary payload;
2: bool is_null;
}
union TDataBlockPtr {
1: binary fixed_len_data;
2: list<TVarLen> var_len_data;
}
struct TInsertData {
1: i32 db_id;
2: i32 table_id;
3: list<i32> column_ids;
4: list<TDataBlockPtr> data;
5: i64 num_rows;
6: list<bool> is_default;
}
struct TPendingRenderQuery {
1: TQueryId id;
}
struct TRenderParseResult {
1: TMergeType merge_type;
2: i32 node_id;
3: i64 execution_time_ms;
4: i64 render_time_ms;
5: i64 total_time_ms;
}
struct TRawRenderPassDataResult {
1: i32 num_pixel_channels;
2: i32 num_pixel_samples;
3: binary pixels;
4: binary row_ids_A;
5: binary row_ids_B;
6: binary table_ids;
7: binary accum_data;
8: i32 accum_depth;
}
typedef map<i32, TRawRenderPassDataResult> TRenderPassMap
struct TRawPixelData {
1: i32 width;
2: i32 height;
3: TRenderPassMap render_pass_map;
}
struct TRenderDatum {
1: common.TDatumType type;
2: i32 cnt;
3: binary value;
}
typedef map<string, map<string, map<string, map<string, list<TRenderDatum>>>>> TRenderAggDataMap
struct TRenderStepResult {
1: TRenderAggDataMap merge_data;
2: TRawPixelData raw_pixel_data;
3: i64 execution_time_ms;
4: i64 render_time_ms;
5: i64 total_time_ms;
}
struct TDatabasePermissions {
1: bool create_;
2: bool delete_;
3: bool view_sql_editor_;
4: bool access_;
}
struct TTablePermissions {
1: bool create_;
2: bool drop_;
3: bool select_;
4: bool insert_;
5: bool update_;
6: bool delete_;
7: bool truncate_;
8: bool alter_;
}
struct TDashboardPermissions {
1: bool create_;
2: bool delete_;
3: bool view_;
4: bool edit_;
}
struct TViewPermissions {
1: bool create_;
2: bool drop_;
3: bool select_;
4: bool insert_;
5: bool update_;
6: bool delete_;
}
struct TServerPermissions {
1: bool create_;
2: bool drop_;
3: bool alter_;
4: bool usage_;
}
union TDBObjectPermissions {
1: TDatabasePermissions database_permissions_;
2: TTablePermissions table_permissions_;
3: TDashboardPermissions dashboard_permissions_;
4: TViewPermissions view_permissions_;
5: TServerPermissions server_permissions_;
}
enum TDBObjectType {
AbstractDBObjectType = 0,
DatabaseDBObjectType,
TableDBObjectType,
DashboardDBObjectType,
ViewDBObjectType,
ServerDBObjectType
}
struct TDBObject {
1: string objectName;
2: TDBObjectType objectType;
3: list<bool> privs;
4: string grantee;
5: TDBObjectType privilegeObjectType;
6: i32 objectId;
}
struct TDashboardGrantees {
1: string name;
2: bool is_user;
3: TDashboardPermissions permissions;
}
struct TDashboard {
1: string dashboard_name;
2: string dashboard_state;
3: string image_hash;
4: string update_time;
5: string dashboard_metadata;
6: i32 dashboard_id;
7: string dashboard_owner;
8: bool is_dash_shared;
9: TDashboardPermissions dashboard_permissions;
}
struct TLicenseInfo {
1: list<string> claims;
}
struct TSessionInfo {
1: string user;
2: string database;
3: i64 start_time;
4: bool is_super;
}
struct TGeoFileLayerInfo {
1: string name;
2: TGeoFileLayerContents contents;
}
struct TTableEpochInfo {
1: i32 table_id;
2: i32 table_epoch;
3: i32 leaf_index;
}
enum TDataSourceType {
TABLE
}
struct TCustomExpression {
1: i32 id;
2: string name;
4: string expression_json;
5: TDataSourceType data_source_type;
6: i32 data_source_id;
7: bool is_deleted;
}
service OmniSci {
# connection, admin
TSessionId connect(1: string user, 2: string passwd, 3: string dbname) throws (1: TOmniSciException e)
TKrb5Session krb5_connect(1: string inputToken, 2: string dbname) throws (1: TOmniSciException e)
void disconnect(1: TSessionId session) throws (1: TOmniSciException e)
void switch_database(1: TSessionId session, 2: string dbname) throws(1: TOmniSciException e)
TSessionId clone_session(1: TSessionId session) throws(1: TOmniSciException e)
TServerStatus get_server_status(1: TSessionId session) throws (1: TOmniSciException e)
list<TServerStatus> get_status(1: TSessionId session) throws (1: TOmniSciException e)
TClusterHardwareInfo get_hardware_info(1: TSessionId session) throws (1: TOmniSciException e)
list<string> get_tables(1: TSessionId session) throws (1: TOmniSciException e)
list<string> get_tables_for_database(1: TSessionId session, 2: string database_name) throws (1: TOmniSciException e)
list<string> get_physical_tables(1: TSessionId session) throws (1: TOmniSciException e)
list<string> get_views(1: TSessionId session) throws (1: TOmniSciException e)
list<TTableMeta> get_tables_meta(1: TSessionId session) throws (1: TOmniSciException e)
TTableDetails get_table_details(1: TSessionId session, 2: string table_name) throws (1: TOmniSciException e)
TTableDetails get_table_details_for_database(1: TSessionId session, 2: string table_name, 3: string database_name) throws (1: TOmniSciException e)
TTableDetails get_internal_table_details(1: TSessionId session, 2: string table_name) throws (1: TOmniSciException e)
TTableDetails get_internal_table_details_for_database(1: TSessionId session, 2: string table_name, 3: string database_name) throws (1: TOmniSciException e)
list<string> get_users(1: TSessionId session) throws (1: TOmniSciException e)
list<TDBInfo> get_databases(1: TSessionId session) throws (1: TOmniSciException e)
string get_version() throws (1: TOmniSciException e)
void start_heap_profile(1: TSessionId session) throws (1: TOmniSciException e)
void stop_heap_profile(1: TSessionId session) throws (1: TOmniSciException e)
string get_heap_profile(1: TSessionId session) throws (1: TOmniSciException e)
list<TNodeMemoryInfo> get_memory(1: TSessionId session, 2: string memory_level) throws (1: TOmniSciException e)
void clear_cpu_memory(1: TSessionId session) throws (1: TOmniSciException e)
void clear_gpu_memory(1: TSessionId session) throws (1: TOmniSciException e)
void set_cur_session(1: TSessionId parent_session, 2: TSessionId leaf_session, 3: string start_time_str, 4: string label, 5: bool for_running_query_kernel) throws (1: TOmniSciException e)
void invalidate_cur_session(1: TSessionId parent_session, 2: TSessionId leaf_session, 3: string start_time_str, 4: string label, 5: bool for_running_query_kernel) throws (1: TOmniSciException e)
void set_table_epoch (1: TSessionId session, 2: i32 db_id, 3: i32 table_id, 4: i32 new_epoch) throws (1: TOmniSciException e)
void set_table_epoch_by_name (1: TSessionId session, 2: string table_name, 3: i32 new_epoch) throws (1: TOmniSciException e)
i32 get_table_epoch (1: TSessionId session, 2: i32 db_id, 3: i32 table_id)
i32 get_table_epoch_by_name (1: TSessionId session, 2: string table_name)
list<TTableEpochInfo> get_table_epochs(1: TSessionId session, 2: i32 db_id, 3: i32 table_id)
void set_table_epochs(1: TSessionId session, 2: i32 db_id, 3: list<TTableEpochInfo> table_epochs)
TSessionInfo get_session_info(1: TSessionId session) throws (1: TOmniSciException e)
# query, render
TQueryResult sql_execute(1: TSessionId session, 2: string query, 3: bool column_format, 4: string nonce, 5: i32 first_n = -1, 6: i32 at_most_n = -1) throws (1: TOmniSciException e)
TDataFrame sql_execute_df(1: TSessionId session, 2: string query, 3: common.TDeviceType device_type, 4: i32 device_id = 0, 5: i32 first_n = -1, 6: TArrowTransport transport_method) throws (1: TOmniSciException e)
TDataFrame sql_execute_gdf(1: TSessionId session, 2: string query, 3: i32 device_id = 0, 4: i32 first_n = -1) throws (1: TOmniSciException e)
void deallocate_df(1: TSessionId session, 2: TDataFrame df, 3: common.TDeviceType device_type, 4: i32 device_id = 0) throws (1: TOmniSciException e)
void interrupt(1: TSessionId query_session, 2: TSessionId interrupt_session) throws (1: TOmniSciException e)
TRowDescriptor sql_validate(1: TSessionId session, 2: string query) throws (1: TOmniSciException e)
list<completion_hints.TCompletionHint> get_completion_hints(1: TSessionId session, 2: string sql, 3: i32 cursor) throws (1: TOmniSciException e)
void set_execution_mode(1: TSessionId session, 2: TExecuteMode mode) throws (1: TOmniSciException e)
TRenderResult render_vega(1: TSessionId session, 2: i64 widget_id, 3: string vega_json, 4: i32 compression_level, 5: string nonce) throws (1: TOmniSciException e)
TPixelTableRowResult get_result_row_for_pixel(1: TSessionId session, 2: i64 widget_id, 3: TPixel pixel, 4: map<string, list<string>> table_col_names, 5: bool column_format, 6: i32 pixelRadius, 7: string nonce) throws (1: TOmniSciException e)
# custom expressions
i32 create_custom_expression(1: TSessionId session, 2: TCustomExpression custom_expression) throws (1: TOmniSciException e)
list<TCustomExpression> get_custom_expressions(1: TSessionId session) throws (1: TOmniSciException e)
void update_custom_expression(1: TSessionId session, 2: i32 id, 3: string expression_json) throws (1: TOmniSciException e)
void delete_custom_expressions(1: TSessionId session, 2: list<i32> custom_expression_ids, 3: bool do_soft_delete) throws (1: TOmniSciException e)
# dashboards
TDashboard get_dashboard(1: TSessionId session, 2: i32 dashboard_id) throws (1: TOmniSciException e)
list<TDashboard> get_dashboards(1: TSessionId session) throws (1: TOmniSciException e)
i32 create_dashboard(1: TSessionId session, 2: string dashboard_name, 3: string dashboard_state, 4: string image_hash, 5: string dashboard_metadata) throws (1: TOmniSciException e)
void replace_dashboard(1: TSessionId session, 2: i32 dashboard_id, 3: string dashboard_name, 4: string dashboard_owner, 5: string dashboard_state, 6: string image_hash, 7: string dashboard_metadata) throws (1: TOmniSciException e)
void delete_dashboard(1: TSessionId session, 2: i32 dashboard_id) throws (1: TOmniSciException e)
void share_dashboards(1: TSessionId session, 2: list<i32> dashboard_ids, 3: list<string> groups, 4: TDashboardPermissions permissions) throws (1: TOmniSciException e)
void delete_dashboards(1: TSessionId session, 2: list<i32> dashboard_ids) throws (1: TOmniSciException e)
void share_dashboard(1: TSessionId session, 2: i32 dashboard_id, 3: list<string> groups, 4: list<string> objects, 5: TDashboardPermissions permissions, 6: bool grant_role = false) throws (1: TOmniSciException e)
void unshare_dashboard(1: TSessionId session, 2: i32 dashboard_id, 3: list<string> groups, 4: list<string> objects, 5: TDashboardPermissions permissions) throws (1: TOmniSciException e)
void unshare_dashboards(1: TSessionId session, 2: list<i32> dashboard_ids, 3: list<string> groups, 4: TDashboardPermissions permissions) throws (1: TOmniSciException e)
list<TDashboardGrantees> get_dashboard_grantees(1: TSessionId session, 2: i32 dashboard_id) throws (1: TOmniSciException e)
#dashboard links
TFrontendView get_link_view(1: TSessionId session, 2: string link) throws (1: TOmniSciException e)
string create_link(1: TSessionId session, 2: string view_state, 3: string view_metadata) throws (1: TOmniSciException e)
# import
void load_table_binary(1: TSessionId session, 2: string table_name, 3: list<TRow> rows, 4: list<string> column_names = {}) throws (1: TOmniSciException e)
void load_table_binary_columnar(1: TSessionId session, 2: string table_name, 3: list<TColumn> cols, 4: list<string> column_names = {}) throws (1: TOmniSciException e)
void load_table_binary_columnar_polys(1: TSessionId session, 2: string table_name, 3: list<TColumn> cols, 4: list<string> column_names = {}, 5: bool assign_render_groups = true) throws (1: TOmniSciException e)
void load_table_binary_arrow(1: TSessionId session, 2: string table_name, 3: binary arrow_stream, 4: bool use_column_names = false) throws (1: TOmniSciException e)
void load_table(1: TSessionId session, 2: string table_name, 3: list<TStringRow> rows, 4: list<string> column_names = {}) throws (1: TOmniSciException e)
TDetectResult detect_column_types(1: TSessionId session, 2: string file_name, 3: TCopyParams copy_params) throws (1: TOmniSciException e)
void create_table(1: TSessionId session, 2: string table_name, 3: TRowDescriptor row_desc, 4: TFileType file_type=TFileType.DELIMITED, 5: TCreateParams create_params) throws (1: TOmniSciException e)
void import_table(1: TSessionId session, 2: string table_name, 3: string file_name, 4: TCopyParams copy_params) throws (1: TOmniSciException e)
void import_geo_table(1: TSessionId session, 2: string table_name, 3: string file_name, 4: TCopyParams copy_params, 5: TRowDescriptor row_desc, 6: TCreateParams create_params) throws (1: TOmniSciException e)
TImportStatus import_table_status(1: TSessionId session, 2: string import_id) throws (1: TOmniSciException e)
string get_first_geo_file_in_archive(1: TSessionId session, 2: string archive_path, 3: TCopyParams copy_params) throws (1: TOmniSciException e)
list<string> get_all_files_in_archive(1: TSessionId session, 2: string archive_path, 3: TCopyParams copy_params) throws (1: TOmniSciException e)
list<TGeoFileLayerInfo> get_layers_in_geo_file(1: TSessionId session, 2: string file_name, 3: TCopyParams copy_params) throws (1: TOmniSciException e)
# distributed
i64 query_get_outer_fragment_count(1: TSessionId session, 2: string query) throws(1: TOmniSciException e)
TTableMeta check_table_consistency(1: TSessionId session, 2: i32 table_id) throws (1: TOmniSciException e)
TPendingQuery start_query(1: TSessionId leaf_session, 2: TSessionId parent_session, 3: string query_ra, 4: string start_time_str, 5: bool just_explain, 6: list<i64> outer_fragment_indices) throws (1: TOmniSciException e)
TStepResult execute_query_step(1: TPendingQuery pending_query, 2: TSubqueryId subquery_id, 3: string start_time_str) throws (1: TOmniSciException e)
void broadcast_serialized_rows(1: serialized_result_set.TSerializedRows serialized_rows, 2: TRowDescriptor row_desc, 3: TQueryId query_id, 4: TSubqueryId subquery_id, 5: bool is_final_subquery_result) throws (1: TOmniSciException e)
TPendingRenderQuery start_render_query(1: TSessionId session, 2: i64 widget_id, 3: i16 node_idx, 4: string vega_json) throws (1: TOmniSciException e)
TRenderStepResult execute_next_render_step(1: TPendingRenderQuery pending_render, 2: TRenderAggDataMap merged_data) throws (1: TOmniSciException e)
void insert_data(1: TSessionId session, 2: TInsertData insert_data) throws (1: TOmniSciException e)
void checkpoint(1: TSessionId session, 2: i32 table_id) throws (1: TOmniSciException e)
# object privileges
list<string> get_roles(1: TSessionId session) throws (1: TOmniSciException e)
list<TDBObject> get_db_objects_for_grantee(1: TSessionId session, 2: string roleName) throws (1: TOmniSciException e)
list<TDBObject> get_db_object_privs(1: TSessionId session, 2: string objectName, 3: TDBObjectType type) throws (1: TOmniSciException e)
list<string> get_all_roles_for_user(1: TSessionId session, 2: string userName) throws (1: TOmniSciException e)
bool has_role(1: TSessionId session, 2: string granteeName, 3: string roleName) throws (1: TOmniSciException e)
bool has_object_privilege(1: TSessionId session, 2: string granteeName, 3: string ObjectName, 4: TDBObjectType objectType, 5: TDBObjectPermissions permissions) throws (1: TOmniSciException e)
# licensing
TLicenseInfo set_license_key(1: TSessionId session, 2: string key, 3: string nonce = "") throws (1: TOmniSciException e)
TLicenseInfo get_license_claims(1: TSessionId session, 2: string nonce = "") throws (1: TOmniSciException e)
# user-defined functions
map<string, string> get_device_parameters(1: TSessionId session) throws (1: TOmniSciException e)
void register_runtime_extension_functions(1: TSessionId session, 2: list<extension_functions.TUserDefinedFunction> udfs, 3: list<extension_functions.TUserDefinedTableFunction> udtfs, 4: map<string, string> device_ir_map) throws (1: TOmniSciException e)
}