(blockPath string)
| 116 | } |
| 117 | |
| 118 | func openParquetFile(blockPath string) (*os.File, *parquet.File, error) { |
| 119 | inFile := filepath.Join(blockPath, "data.parquet") |
| 120 | in, err := os.Open(inFile) |
| 121 | if err != nil { |
| 122 | return nil, nil, err |
| 123 | } |
| 124 | |
| 125 | inStat, err := in.Stat() |
| 126 | if err != nil { |
| 127 | return nil, nil, err |
| 128 | } |
| 129 | |
| 130 | pf, err := parquet.OpenFile(in, inStat.Size()) |
| 131 | if err != nil { |
| 132 | return nil, nil, err |
| 133 | } |
| 134 | |
| 135 | return in, pf, nil |
| 136 | } |
| 137 | |
| 138 | func readBlockMeta(blockPath string) (*backend.BlockMeta, error) { |
| 139 | metaFile := filepath.Join(blockPath, "meta.json") |
no test coverage detected