(pf *parquet.File, colName string)
| 805 | } |
| 806 | |
| 807 | func rowCount(pf *parquet.File, colName string) (count uint64, err error) { |
| 808 | index, _, _ := parquetquery.GetColumnIndexByPath(pf, colName) |
| 809 | if index == -1 { |
| 810 | return 0, errors.New("column not found in parquet file:" + colName) |
| 811 | } |
| 812 | |
| 813 | for _, rg := range pf.RowGroups() { |
| 814 | count += uint64(rg.ColumnChunks()[index].NumValues()) |
| 815 | } |
| 816 | |
| 817 | return count, nil |
| 818 | } |
| 819 | |
| 820 | func printSimpleSummary(scope string, maxAttr int, summary attributeSummary) { |
| 821 | if maxAttr > len(summary.attributes) { |
no test coverage detected