Method VectorOpen

runtime/exec/environment.go:173–201

(ctx context.Context, sctx *super.Context, path, format string, p sbuf.Pushdown, concurrentReaders int)

}

func (e *Environment) VectorOpen(ctx context.Context, sctx *super.Context, path, format string, p sbuf.Pushdown, concurrentReaders int) (VectorConcurrentPuller, error) {
	if path == "-" {
		path = "stdio:stdin"
	}
	uri, err := storage.ParseURI(path)
	if err != nil {
		return nil, err
	}
	reader, err := e.engine.Get(ctx, uri)
	if err != nil {
		return nil, err
	}
	var puller VectorConcurrentPuller
	switch format {
	case "csup":
		puller, err = csupio.NewVectorReader(ctx, sctx, reader, p, concurrentReaders)
	case "parquet":
		puller, err = parquetio.NewVectorReader(ctx, sctx, reader, p, concurrentReaders)
	default:
		var sbufPuller sbuf.Puller
		sbufPuller, err = e.Open(ctx, sctx, path, format, p)
		puller = sbuf.NewDematerializer(sctx, sbufPuller)
	}
	if err != nil {
		reader.Close()
		return nil, err
	}
	return puller, nil
}