MCPcopy Create free account
hub / github.com/PostHog/duckgres / compactParquet

Method compactParquet

server/querylog.go:376–381  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

374 return strings.Contains(upper, "SYSTEM.QUERY_LOG")
375}
376
377// queryLogSink resolves where this connection's query-log entries go. The
378// executor sink (the worker, in control-plane mode) wins: the worker owns the
379// tenant's query-log storage.
380func (c *clientConn) queryLogSink() queryLogEntrySink {
381 if c.server != nil && c.server.cfg.QueryLog.Enabled && c.executor != nil {
382 if sink, ok := c.executor.(queryLogEntrySink); ok {
383 return sink
384 }

Callers 1

flushLoopMethod · 0.95

Calls 1

ExecMethod · 0.65

Tested by

no test coverage detected