-
Notifications
You must be signed in to change notification settings - Fork 2.9k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Record filters and masks #3183
Record filters and masks #3183
Conversation
f4554f3
to
1d1e0b6
Compare
1d1e0b6
to
24c0e4c
Compare
presto-main/src/main/java/io/prestosql/sql/analyzer/Analysis.java
Outdated
Show resolved
Hide resolved
presto-main/src/main/java/io/prestosql/sql/analyzer/Analysis.java
Outdated
Show resolved
Hide resolved
presto-main/src/main/java/io/prestosql/dispatcher/FailedDispatchQuery.java
Show resolved
Hide resolved
@@ -226,6 +226,7 @@ private static QueryInfo immediateFailureQueryInfo( | |||
ImmutableList.of(), | |||
ImmutableSet.of(), |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
There are missing information about accessed:
- procedures (must have)
- functions (must have)
- DDL queries
- set session
- SHOW queries
- query checks
All these surely should go as separate pull requests.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
DDL queries can be inferred from the query type + user + target table. Session properties can be inferred from the session properties in the query + user. Functions and procedures can be added, but I'll do it in a separate PR.
24c0e4c
to
85faf5e
Compare
Updated |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
% comments about tests
presto-main/src/main/java/io/prestosql/sql/analyzer/Analysis.java
Outdated
Show resolved
Hide resolved
presto-main/src/main/java/io/prestosql/sql/analyzer/Analysis.java
Outdated
Show resolved
Hide resolved
presto-main/src/main/java/io/prestosql/sql/analyzer/RelationId.java
Outdated
Show resolved
Hide resolved
presto-spi/src/main/java/io/prestosql/spi/eventlistener/TableInfo.java
Outdated
Show resolved
Hide resolved
presto-spi/src/main/java/io/prestosql/spi/eventlistener/TableInfo.java
Outdated
Show resolved
Hide resolved
presto-tests/src/test/java/io/prestosql/execution/TestEventListener.java
Show resolved
Hide resolved
03180de
to
01a27a4
Compare
01a27a4
to
69063bd
Compare
32ff774
to
db2dd44
Compare
It adds a field to the query metadata event with the following structure: "tables": [ { "catalog": "...", "schema": "...", "table": "...", "authorization": "...", "filters": [ "...", ... ] "columns": [ { "column": "..." "masks": [ "...", ...] }, ... ] }, ... ]
db2dd44
to
16c0355
Compare
Adds a new field to query metadata section in the query completion event with the following structure: