diff options
| author | akozhikhov <akozhikhov@yandex-team.com> | 2024-03-19 04:35:40 +0300 |
|---|---|---|
| committer | akozhikhov <akozhikhov@yandex-team.com> | 2024-03-19 04:45:56 +0300 |
| commit | 9c56c1cc02be61a9e90449afc47bfbbd0f50bab0 (patch) | |
| tree | 813cf5c7d14ec384865df44abda09cb34843748b | |
| parent | fdb6d908123026b562a0781a6656c74217cbae88 (diff) | |
| download | ydb-9c56c1cc02be61a9e90449afc47bfbbd0f50bab0.tar.gz | |
YT-17316: Prefetching chunk fragment reader
8cfdde973b41ffcb84c44f00faa7254fabeb3855
| -rw-r--r-- | yt/yt/client/chunk_client/config.cpp | 3 | ||||
| -rw-r--r-- | yt/yt/client/chunk_client/config.h | 3 |
2 files changed, 6 insertions, 0 deletions
diff --git a/yt/yt/client/chunk_client/config.cpp b/yt/yt/client/chunk_client/config.cpp index 67a492aba1..dbf22f06d3 100644 --- a/yt/yt/client/chunk_client/config.cpp +++ b/yt/yt/client/chunk_client/config.cpp @@ -423,6 +423,9 @@ void TChunkFragmentReaderConfig::Register(TRegistrar registrar) .Default(16_MB); registrar.Parameter("max_inflight_fragment_count", &TThis::MaxInflightFragmentCount) .Default(8192); + + registrar.Parameter("prefetch_whole_blocks", &TThis::PrefetchWholeBlocks) + .Default(false); } //////////////////////////////////////////////////////////////////////////////// diff --git a/yt/yt/client/chunk_client/config.h b/yt/yt/client/chunk_client/config.h index 9f3488b003..8b4b02638f 100644 --- a/yt/yt/client/chunk_client/config.h +++ b/yt/yt/client/chunk_client/config.h @@ -487,6 +487,9 @@ public: //! Upper bound on count of simultaneously requested fragments within a reading session. i64 MaxInflightFragmentCount; + // If |true| will request full blocks and store them in a cache for further access. + bool PrefetchWholeBlocks; + REGISTER_YSON_STRUCT(TChunkFragmentReaderConfig); static void Register(TRegistrar registrar); |