in src/parquet/util/comparison.cc [27:64]
std::shared_ptr<Comparator> Comparator::Make(const ColumnDescriptor* descr) {
if (SortOrder::SIGNED == descr->sort_order()) {
switch (descr->physical_type()) {
case Type::BOOLEAN:
return std::make_shared<CompareDefaultBoolean>();
case Type::INT32:
return std::make_shared<CompareDefaultInt32>();
case Type::INT64:
return std::make_shared<CompareDefaultInt64>();
case Type::FLOAT:
return std::make_shared<CompareDefaultFloat>();
case Type::DOUBLE:
return std::make_shared<CompareDefaultDouble>();
case Type::BYTE_ARRAY:
return std::make_shared<CompareDefaultByteArray>();
case Type::FIXED_LEN_BYTE_ARRAY:
return std::make_shared<CompareDefaultFLBA>(descr->type_length());
default:
ParquetException::NYI("Signed Compare not implemented");
}
} else if (SortOrder::UNSIGNED == descr->sort_order()) {
switch (descr->physical_type()) {
case Type::INT32:
return std::make_shared<CompareUnsignedInt32>();
case Type::INT64:
return std::make_shared<CompareUnsignedInt64>();
case Type::BYTE_ARRAY:
return std::make_shared<CompareUnsignedByteArray>();
case Type::FIXED_LEN_BYTE_ARRAY:
return std::make_shared<CompareUnsignedFLBA>(descr->type_length());
default:
ParquetException::NYI("Unsigned Compare not implemented");
}
} else {
throw ParquetException("UNKNOWN Sort Order");
}
return nullptr;
}