diff options
| author | coteeq <[email protected]> | 2025-09-01 11:44:49 +0300 |
|---|---|---|
| committer | coteeq <[email protected]> | 2025-09-01 12:05:04 +0300 |
| commit | 017114507f2e3904bd7601c6f19e21b60f33dbf7 (patch) | |
| tree | ca52fe057376abdc29b2e6fbd819732f1cbc8f6b | |
| parent | c904febe080a338b2eecc2f5d329abb76db43c22 (diff) | |
YT-19137: RLS in schemaless readers
* Changelog entry
Type: feature
Component: proxy
Support RLS (Row-Level Security) in read_table command.
commit_hash:8027b77287c54cbd27ed4207b3e2a1ed1125aa2c
| -rw-r--r-- | yt/yt/client/api/table_client.h | 1 | ||||
| -rw-r--r-- | yt/yt/client/driver/table_commands.cpp | 12 |
2 files changed, 11 insertions, 2 deletions
diff --git a/yt/yt/client/api/table_client.h b/yt/yt/client/api/table_client.h index 2fe79053784..5686cebb8a4 100644 --- a/yt/yt/client/api/table_client.h +++ b/yt/yt/client/api/table_client.h @@ -33,6 +33,7 @@ struct TTableReaderOptions { bool Unordered = false; bool OmitInaccessibleColumns = false; + bool OmitInaccessibleRows = false; bool EnableTableIndex = false; bool EnableRowIndex = false; bool EnableRangeIndex = false; diff --git a/yt/yt/client/driver/table_commands.cpp b/yt/yt/client/driver/table_commands.cpp index 69b48b15cd5..b0caa111544 100644 --- a/yt/yt/client/driver/table_commands.cpp +++ b/yt/yt/client/driver/table_commands.cpp @@ -87,16 +87,24 @@ void TReadTableCommand::Register(TRegistrar registrar) return command->Options.OmitInaccessibleColumns; }) .Default(false); + + registrar.ParameterWithUniversalAccessor<bool>( + "omit_inaccessible_rows", + [] (TThis* command) -> auto& { + return command->Options.OmitInaccessibleRows; + }) + .Default(false); } void TReadTableCommand::DoExecute(ICommandContextPtr context) { YT_LOG_DEBUG("Executing \"read_table\" command (Path: %v, Unordered: %v, StartRowIndexOnly: %v, " - "OmitInaccessibleColumns: %v)", + "OmitInaccessibleColumns: %v, OmitInaccessibleRows: %v)", Path, Unordered, StartRowIndexOnly, - Options.OmitInaccessibleColumns); + Options.OmitInaccessibleColumns, + Options.OmitInaccessibleRows); Options.Ping = true; Options.EnableTableIndex = ControlAttributes->EnableTableIndex; Options.EnableRowIndex = ControlAttributes->EnableRowIndex; |
