Skip to content

Commit 14db5b5

Browse files
committed
Add trace token to query events
1 parent bb0fd12 commit 14db5b5

File tree

2 files changed

+10
-0
lines changed

2 files changed

+10
-0
lines changed

presto-main/src/main/java/io/prestosql/event/QueryMonitor.java

+1
Original file line numberDiff line numberDiff line change
@@ -234,6 +234,7 @@ private QueryContext createQueryContext(SessionRepresentation session, Optional<
234234
return new QueryContext(
235235
session.getUser(),
236236
session.getPrincipal(),
237+
session.getTraceToken(),
237238
session.getRemoteUserAddress(),
238239
session.getUserAgent(),
239240
session.getClientInfo(),

presto-spi/src/main/java/io/prestosql/spi/eventlistener/QueryContext.java

+9
Original file line numberDiff line numberDiff line change
@@ -27,6 +27,7 @@ public class QueryContext
2727
{
2828
private final String user;
2929
private final Optional<String> principal;
30+
private final Optional<String> traceToken;
3031
private final Optional<String> remoteClientAddress;
3132
private final Optional<String> userAgent;
3233
private final Optional<String> clientInfo;
@@ -49,6 +50,7 @@ public class QueryContext
4950
public QueryContext(
5051
String user,
5152
Optional<String> principal,
53+
Optional<String> traceToken,
5254
Optional<String> remoteClientAddress,
5355
Optional<String> userAgent,
5456
Optional<String> clientInfo,
@@ -66,6 +68,7 @@ public QueryContext(
6668
{
6769
this.user = requireNonNull(user, "user is null");
6870
this.principal = requireNonNull(principal, "principal is null");
71+
this.traceToken = requireNonNull(traceToken, "traceToken is null");
6972
this.remoteClientAddress = requireNonNull(remoteClientAddress, "remoteClientAddress is null");
7073
this.userAgent = requireNonNull(userAgent, "userAgent is null");
7174
this.clientInfo = requireNonNull(clientInfo, "clientInfo is null");
@@ -94,6 +97,12 @@ public Optional<String> getPrincipal()
9497
return principal;
9598
}
9699

100+
@JsonProperty
101+
public Optional<String> getTraceToken()
102+
{
103+
return traceToken;
104+
}
105+
97106
@JsonProperty
98107
public Optional<String> getRemoteClientAddress()
99108
{

0 commit comments

Comments
 (0)