(pf *parquet.File, colName string)
| 761 | } |
| 762 | |
| 763 | func aggregateIntegerColumn(pf *parquet.File, colName string) (uint64, error) { |
| 764 | var ( |
| 765 | iter = makeIterFunc(context.Background(), pf)(colName, parquetquery.NewSkipNilsPredicate(), "") |
| 766 | count uint64 |
| 767 | ) |
| 768 | |
| 769 | for res, err := iter.Next(); res != nil; res, err = iter.Next() { |
| 770 | if err != nil { |
| 771 | return 0, err |
| 772 | } |
| 773 | count++ |
| 774 | } |
| 775 | |
| 776 | return count, nil |
| 777 | } |
| 778 | |
| 779 | func aggregateStringColumn(pf *parquet.File, colName string) (cardinality, error) { |
| 780 | var ( |
no test coverage detected