diff options
| author | gryzlov-ad <gryzlov-ad@yandex-team.com> | 2024-06-13 15:02:10 +0300 |
|---|---|---|
| committer | gryzlov-ad <gryzlov-ad@yandex-team.com> | 2024-06-13 15:20:52 +0300 |
| commit | 447c36130786f4d7ceb6ffb5f4dcc5f8181bb812 (patch) | |
| tree | 39c4dcce65fe9742f63e88dd513373b692ab408a /yt | |
| parent | fc10bc7b48b6bb61048459a18c0341f0bb483add (diff) | |
| download | ydb-447c36130786f4d7ceb6ffb5f4dcc5f8181bb812.tar.gz | |
Fix babenko-issues for watermark row merger
35578ca1f598ea49758c82e06d70191036ceded8
Diffstat (limited to 'yt')
| -rw-r--r-- | yt/yt/client/tablet_client/public.h | 1 | ||||
| -rw-r--r-- | yt/yt/client/tablet_client/watermark_runtime_data.cpp | 2 | ||||
| -rw-r--r-- | yt/yt/client/tablet_client/watermark_runtime_data.h | 15 |
3 files changed, 12 insertions, 6 deletions
diff --git a/yt/yt/client/tablet_client/public.h b/yt/yt/client/tablet_client/public.h index 5c62fac79f..f539be7892 100644 --- a/yt/yt/client/tablet_client/public.h +++ b/yt/yt/client/tablet_client/public.h @@ -228,6 +228,7 @@ DEFINE_ENUM(ERowMergerType, ((Watermark) (1)) ); +struct TWatermarkRuntimeDataConfig; struct TWatermarkRuntimeData; //////////////////////////////////////////////////////////////////////////////// diff --git a/yt/yt/client/tablet_client/watermark_runtime_data.cpp b/yt/yt/client/tablet_client/watermark_runtime_data.cpp index cdcfc86704..2301d3ac3d 100644 --- a/yt/yt/client/tablet_client/watermark_runtime_data.cpp +++ b/yt/yt/client/tablet_client/watermark_runtime_data.cpp @@ -4,7 +4,7 @@ namespace NYT::NTabletClient { //////////////////////////////////////////////////////////////////////////////// -void TWatermarkRuntimeData::Register(TRegistrar registrar) +void TWatermarkRuntimeDataConfig::Register(TRegistrar registrar) { registrar.Parameter("column_name", &TThis::ColumnName); registrar.Parameter("watermark", &TThis::Watermark); diff --git a/yt/yt/client/tablet_client/watermark_runtime_data.h b/yt/yt/client/tablet_client/watermark_runtime_data.h index 572acf5d99..54c62c27bd 100644 --- a/yt/yt/client/tablet_client/watermark_runtime_data.h +++ b/yt/yt/client/tablet_client/watermark_runtime_data.h @@ -8,20 +8,25 @@ namespace NYT::NTabletClient { //////////////////////////////////////////////////////////////////////////////// -struct TWatermarkRuntimeData +struct TWatermarkRuntimeDataConfig : public NYTree::TYsonStructLite { TString ColumnName; ui64 Watermark; - // Should be set manually using table schema after ColumnName is known. - int ColumnIndex; - - REGISTER_YSON_STRUCT_LITE(TWatermarkRuntimeData); + REGISTER_YSON_STRUCT_LITE(TWatermarkRuntimeDataConfig); static void Register(TRegistrar registrar); }; //////////////////////////////////////////////////////////////////////////////// +struct TWatermarkRuntimeData +{ + ui64 Watermark; + int ColumnIndex; +}; + +//////////////////////////////////////////////////////////////////////////////// + } // namespace NYT::NTabletClient |