diff options
| author | nadya02 <nadya02@yandex-team.com> | 2024-09-17 11:13:10 +0300 |
|---|---|---|
| committer | nadya02 <nadya02@yandex-team.com> | 2024-09-17 11:38:14 +0300 |
| commit | e21cdb7047c5fc686d211be13f6466d6d0c5a9cf (patch) | |
| tree | ab5f52e28f17e9bf01aeb312c71dcda45718618a | |
| parent | 73f3c1ee49b505f2c5907d72e6e06b35887c814b (diff) | |
| download | ydb-e21cdb7047c5fc686d211be13f6466d6d0c5a9cf.tar.gz | |
YT-21664: Add enable dump-parquet in parallel mode
commit_hash:291e284c82403a19d99fcd49028cd47d331981cb
| -rw-r--r-- | yt/python/yt/yson/__init__.py | 2 | ||||
| -rw-r--r-- | yt/yt/core/concurrency/public.h | 1 |
2 files changed, 2 insertions, 1 deletions
diff --git a/yt/python/yt/yson/__init__.py b/yt/python/yt/yson/__init__.py index d3eb9d5dca..2d5dad9663 100644 --- a/yt/python/yt/yson/__init__.py +++ b/yt/python/yt/yson/__init__.py @@ -54,7 +54,7 @@ except ImportError as error: print("Warning! Failed to import YSON bindings: " + message, file=_sys.stderr) try: - from yt_yson_bindings import upload_parquet, dump_parquet, dump_orc, upload_orc # noqa + from yt_yson_bindings import upload_parquet, dump_parquet, dump_orc, upload_orc, async_dump_parquet # noqa HAS_PARQUET = True except ImportError as error: message = str(error) diff --git a/yt/yt/core/concurrency/public.h b/yt/yt/core/concurrency/public.h index 4cab384b88..151120cbc7 100644 --- a/yt/yt/core/concurrency/public.h +++ b/yt/yt/core/concurrency/public.h @@ -51,6 +51,7 @@ DECLARE_REFCOUNTED_STRUCT(IAsyncZeroCopyOutputStream) DECLARE_REFCOUNTED_STRUCT(IFairShareThreadPool) DECLARE_REFCOUNTED_CLASS(TAsyncStreamPipe) +DECLARE_REFCOUNTED_CLASS(TBoundedAsyncStreamPipe) DEFINE_ENUM(EWaitForStrategy, (WaitFor) |