MCPcopy Create free account
hub / github.com/brimdata/super / Query

Method Query

db/api/local.go:110–120  ·  view source on GitHub ↗
(ctx context.Context, inputs []srcfiles.Input)

Source from the content-addressed store, hash-verified

108}
109
110func (l *local) Query(ctx context.Context, inputs []srcfiles.Input) (vio.Scanner, error) {
111 ast, err := parser.ParseFiles(inputs)
112 if err != nil {
113 return nil, err
114 }
115 q, err := runtime.CompileQueryForDB(ctx, super.NewContext(), l.compiler, ast)
116 if err != nil {
117 return nil, err
118 }
119 return q, nil
120}
121
122func (l *local) PoolID(ctx context.Context, poolName string) (ksuid.KSUID, error) {
123 if poolName == "" {

Callers

nothing calls this directly

Calls 3

ParseFilesFunction · 0.92
CompileQueryForDBFunction · 0.92
NewContextFunction · 0.92

Tested by

no test coverage detected