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

Method Open

cli/outputflags/flags.go:128–151  ·  view source on GitHub ↗
(ctx context.Context, engine storage.Engine)

Source from the content-addressed store, hash-verified

126}
127
128func (f *Flags) Open(ctx context.Context, engine storage.Engine) (vio.PushCloser, error) {
129 if f.split != "" {
130 dir, err := storage.ParseURI(f.split)
131 if err != nil {
132 return nil, fmt.Errorf("-split option: %w", err)
133 }
134 if size := f.splitSize.Bytes; size > 0 {
135 return emitter.NewSizeSplitter(ctx, engine, dir, f.outputFile, f.unbuffered, f.WriterOpts, int64(size))
136 }
137 d, err := emitter.NewSplit(ctx, engine, dir, f.outputFile, f.unbuffered, f.WriterOpts)
138 if err != nil {
139 return nil, err
140 }
141 return d, nil
142 }
143 if f.outputFile == "" && f.color && terminal.IsTerminalFile(os.Stdout) {
144 color.Enabled = true
145 }
146 w, err := emitter.NewFileFromPath(ctx, engine, f.outputFile, f.unbuffered, f.WriterOpts)
147 if err != nil {
148 return nil, err
149 }
150 return w, nil
151}

Callers

nothing calls this directly

Calls 5

ParseURIFunction · 0.92
NewSizeSplitterFunction · 0.92
NewSplitFunction · 0.92
IsTerminalFileFunction · 0.92
NewFileFromPathFunction · 0.92

Tested by

no test coverage detected