Browse Source

YT-21664: Add enable dump-parquet in parallel mode
commit_hash:291e284c82403a19d99fcd49028cd47d331981cb

nadya02 5 months ago
parent
commit
e21cdb7047
2 changed files with 2 additions and 1 deletions
  1. 1 1
      yt/python/yt/yson/__init__.py
  2. 1 0
      yt/yt/core/concurrency/public.h

+ 1 - 1
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)

+ 1 - 0
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)