summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorcoteeq <[email protected]>2025-09-01 11:44:49 +0300
committercoteeq <[email protected]>2025-09-01 12:05:04 +0300
commit017114507f2e3904bd7601c6f19e21b60f33dbf7 (patch)
treeca52fe057376abdc29b2e6fbd819732f1cbc8f6b
parentc904febe080a338b2eecc2f5d329abb76db43c22 (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.h1
-rw-r--r--yt/yt/client/driver/table_commands.cpp12
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;