Skip to content

Commit 88b6b4a

Browse files
author
sabdenovch
committed
Add expression builder version to python API
commit_hash:de73008f5814cf275c59895f15f5d5c5a62cf3bc
1 parent 097c6b0 commit 88b6b4a

File tree

2 files changed

+10
-6
lines changed

2 files changed

+10
-6
lines changed

yt/python/yt/wrapper/client_impl.py

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -844,7 +844,7 @@ def explain_query(
844844
timestamp=None, input_row_limit=None, output_row_limit=None, range_expansion_limit=None,
845845
max_subqueries=None, workload_descriptor=None, allow_full_scan=None, allow_join_without_index=None,
846846
format=None, raw=None, execution_pool=None, retention_timestamp=None, syntax_version=None,
847-
udf_registry_path=None):
847+
expression_builder_version=None, udf_registry_path=None):
848848
"""
849849
Explains a SQL-like query on dynamic table.
850850
@@ -864,7 +864,7 @@ def explain_query(
864864
range_expansion_limit=range_expansion_limit, max_subqueries=max_subqueries, workload_descriptor=workload_descriptor,
865865
allow_full_scan=allow_full_scan, allow_join_without_index=allow_join_without_index, format=format,
866866
raw=raw, execution_pool=execution_pool, retention_timestamp=retention_timestamp, syntax_version=syntax_version,
867-
udf_registry_path=udf_registry_path)
867+
expression_builder_version=expression_builder_version, udf_registry_path=udf_registry_path)
868868

869869
def externalize(
870870
self,
@@ -2924,7 +2924,8 @@ def select_rows(
29242924
workload_descriptor=None, allow_full_scan=None, allow_join_without_index=None, format=None,
29252925
raw=None, execution_pool=None, response_parameters=None, retention_timestamp=None, placeholder_values=None,
29262926
use_canonical_null_relations=None, merge_versioned_rows=None, syntax_version=None, versioned_read_options=None,
2927-
with_timestamps=None, udf_registry_path=None, use_lookup_cache=None, execution_backend=None):
2927+
with_timestamps=None, udf_registry_path=None, use_lookup_cache=None, execution_backend=None,
2928+
expression_builder_version=None):
29282929
"""
29292930
Executes a SQL-like query on dynamic table.
29302931
@@ -2948,7 +2949,7 @@ def select_rows(
29482949
retention_timestamp=retention_timestamp, placeholder_values=placeholder_values, use_canonical_null_relations=use_canonical_null_relations,
29492950
merge_versioned_rows=merge_versioned_rows, syntax_version=syntax_version, versioned_read_options=versioned_read_options,
29502951
with_timestamps=with_timestamps, udf_registry_path=udf_registry_path, use_lookup_cache=use_lookup_cache,
2951-
execution_backend=execution_backend)
2952+
execution_backend=execution_backend, expression_builder_version=expression_builder_version)
29522953

29532954
def set(
29542955
self,

yt/python/yt/wrapper/dynamic_table_commands.py

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -203,7 +203,8 @@ def select_rows(query, timestamp=None, input_row_limit=None, output_row_limit=No
203203
workload_descriptor=None, allow_full_scan=None, allow_join_without_index=None, format=None, raw=None,
204204
execution_pool=None, response_parameters=None, retention_timestamp=None, placeholder_values=None,
205205
use_canonical_null_relations=None, merge_versioned_rows=None, syntax_version=None, versioned_read_options=None,
206-
with_timestamps=None, udf_registry_path=None, use_lookup_cache=None, execution_backend=None, client=None):
206+
with_timestamps=None, udf_registry_path=None, use_lookup_cache=None, execution_backend=None,
207+
expression_builder_version=None, client=None):
207208
"""Executes a SQL-like query on dynamic table.
208209
209210
.. seealso:: `supported features <https://ytsaurus.tech/docs/en/user-guide/dynamic-tables/dyn-query-language>`_
@@ -241,6 +242,7 @@ def select_rows(query, timestamp=None, input_row_limit=None, output_row_limit=No
241242
set_param(params, "merge_versioned_rows", merge_versioned_rows)
242243
set_param(params, "use_lookup_cache", use_lookup_cache)
243244
set_param(params, "syntax_version", syntax_version)
245+
set_param(params, "expression_builder_version", expression_builder_version)
244246
set_param(params, "versioned_read_options", _get_versioned_read_options(versioned_read_options, with_timestamps))
245247
set_param(params, "udf_registry_path", udf_registry_path)
246248
set_param(params, "execution_backend", execution_backend)
@@ -323,7 +325,7 @@ def explain_query(
323325
query, timestamp=None, input_row_limit=None, output_row_limit=None, range_expansion_limit=None,
324326
max_subqueries=None, workload_descriptor=None, allow_full_scan=None, allow_join_without_index=None,
325327
format=None, raw=None, execution_pool=None, retention_timestamp=None,
326-
syntax_version=None, udf_registry_path=None, client=None):
328+
syntax_version=None, expression_builder_version=None, udf_registry_path=None, client=None):
327329
"""Explains a SQL-like query on dynamic table.
328330
329331
.. seealso:: `supported features <https://ytsaurus.tech/docs/en/user-guide/dynamic-tables/dyn-query-language>`_
@@ -353,6 +355,7 @@ def explain_query(
353355
set_param(params, "execution_pool", execution_pool)
354356
set_param(params, "timeout", get_config(client)["proxy"]["heavy_request_timeout"])
355357
set_param(params, "syntax_version", syntax_version)
358+
set_param(params, "expression_builder_version", expression_builder_version)
356359
set_param(params, "udf_registry_path", udf_registry_path)
357360

358361
_check_transaction_type(client)

0 commit comments

Comments
 (0)