5#include <unordered_map>
6#include <unordered_set>
22class NodeTableCatalogEntry;
140 std::is_same_v<T, int8_t> || std::is_same_v<T, int16_t> || std::is_same_v<T, int32_t> ||
141 std::is_same_v<T, int64_t> || std::is_same_v<T, int128_t>;
145 std::is_same_v<T, uint8_t> || std::is_same_v<T, uint16_t> || std::is_same_v<T, uint32_t> ||
146 std::is_same_v<T, uint64_t> || std::is_same_v<T, uint128_t>;
159 std::is_same_v<T, interval_t> || std::is_same_v<T, bool>;
163 ((std::integral<T> && !std::is_same_v<T, bool>) || std::floating_point<T> ||
164 std::is_same_v<T, int128_t> || std::is_same_v<T, uint128_t>);
166concept IndexHashable = ((std::integral<T> && !std::is_same_v<T, bool>) || std::floating_point<T> ||
167 std::is_same_v<T, int128_t> || std::is_same_v<T, uint128_t> ||
168 std::is_same_v<T, ku_string_t> || std::is_same_v<T, std::string_view> ||
169 std::same_as<T, std::string>);
173 (std::integral<T> || std::floating_point<T> || std::is_same_v<T, int128_t> ||
174 std::is_same_v<T, uint128_t> || std::is_same_v<T, internalID_t> ||
175 std::is_same_v<T, interval_t> || std::is_same_v<T, ku_string_t>);
179 (std::is_same_v<T, list_entry_t> || std::is_same_v<T, struct_entry_t>);
294 const std::unique_ptr<ExtraTypeInfo>& extraTypeInfo =
nullptr);
297 extraTypeInfo = std::move(typeInfo);
306 LBUG_API static std::vector<LogicalType>
copy(
const std::vector<LogicalType>& types);
307 LBUG_API static std::vector<LogicalType>
copy(
const std::vector<LogicalType*>& types);
316 ret.physicalType = physicalType;
354 static LBUG_API LogicalType
REL(std::vector<StructField>&& fields);
360 static inline LogicalType
LIST(T&& childType) {
364 static LBUG_API LogicalType
MAP(LogicalType keyType, LogicalType valueType);
366 static LogicalType
MAP(T&& keyType, T&& valueType) {
371 static LBUG_API LogicalType
ARRAY(LogicalType childType, uint64_t numElements);
373 static LogicalType
ARRAY(T&& childType, uint64_t numElements) {
386 std::unique_ptr<ExtraTypeInfo> extraTypeInfo;
400 virtual std::unique_ptr<ExtraTypeInfo>
copy()
const = 0;
402 template<
class TARGET>
413 explicit UDTTypeInfo(std::string typeName) : typeName{std::move(typeName)} {}
421 std::unique_ptr<ExtraTypeInfo>
copy()
const override;
423 static std::unique_ptr<ExtraTypeInfo>
deserialize(Deserializer& deserializer);
426 void serializeInternal(Serializer& serializer)
const override;
429 std::string typeName;
444 std::unique_ptr<ExtraTypeInfo>
copy()
const override;
446 static std::unique_ptr<ExtraTypeInfo>
deserialize(Deserializer& deserializer);
465 std::unique_ptr<ExtraTypeInfo>
copy()
const override;
467 static std::unique_ptr<ExtraTypeInfo>
deserialize(Deserializer& deserializer);
486 static std::unique_ptr<ExtraTypeInfo>
deserialize(Deserializer& deserializer);
488 std::unique_ptr<ExtraTypeInfo>
copy()
const override;
491 void serializeInternal(Serializer& serializer)
const override;
494 uint64_t numElements;
501 : name{std::move(name)}, type{std::move(type)} {};
530 const std::vector<LogicalType>& fieldTypes);
547 static std::unique_ptr<ExtraTypeInfo>
deserialize(Deserializer& deserializer);
548 std::unique_ptr<ExtraTypeInfo>
copy()
const override;
551 void serializeInternal(Serializer& serializer)
const override;
554 std::vector<StructField> fields;
555 std::unordered_map<std::string, struct_field_idx_t> fieldNameToIdxMap;
633 static std::string
toString(
const std::vector<LogicalType>& dataTypes);
634 static std::string
toString(
const std::vector<LogicalTypeID>& dataTypeIDs);
#define LBUG_API
Definition api.h:25
std::unique_ptr< ExtraTypeInfo > copy() const override
bool operator==(const ExtraTypeInfo &other) const override
ArrayTypeInfo(LogicalType childType, uint64_t numElements)
Definition types.h:479
static std::unique_ptr< ExtraTypeInfo > deserialize(Deserializer &deserializer)
ArrayTypeInfo()
Definition types.h:478
uint64_t getNumElements() const
Definition types.h:482
std::unique_ptr< ExtraTypeInfo > copy() const override
static std::unique_ptr< ExtraTypeInfo > deserialize(Deserializer &deserializer)
bool containsAny() const override
Definition types.h:440
uint32_t scale
Definition types.h:451
bool operator==(const ExtraTypeInfo &other) const override
uint32_t precision
Definition types.h:451
DecimalTypeInfo(uint32_t precision=18, uint32_t scale=3)
Definition types.h:434
void serializeInternal(Serializer &serializer) const override
uint32_t getPrecision() const
Definition types.h:437
uint32_t getScale() const
Definition types.h:438
std::unique_ptr< ExtraTypeInfo > copy() const override
void serializeInternal(Serializer &serializer) const override
const LogicalType & getChildType() const
Definition types.h:459
bool containsAny() const override
static std::unique_ptr< ExtraTypeInfo > deserialize(Deserializer &deserializer)
LogicalType childType
Definition types.h:473
bool operator==(const ExtraTypeInfo &other) const override
ListTypeInfo(LogicalType childType)
Definition types.h:457
static LogicalType BLOB()
Definition types.h:345
LBUG_API bool operator==(const LogicalType &other) const
static LogicalType TIMESTAMP_MS()
Definition types.h:335
static LogicalType LIST(T &&childType)
Definition types.h:360
static LogicalType BOOL()
Definition types.h:320
static LogicalType INT16()
Definition types.h:324
static LBUG_API LogicalType LIST(LogicalType childType)
static LogicalType TIMESTAMP_TZ()
Definition types.h:337
friend struct DecimalType
Definition types.h:267
static LBUG_API LogicalType UNION(std::vector< StructField > &&fields)
static LogicalType UUID()
Definition types.h:346
static LogicalType ARRAY(T &&childType, uint64_t numElements)
Definition types.h:373
static LogicalType UINT8()
Definition types.h:329
static LogicalType TIMESTAMP_NS()
Definition types.h:334
static LogicalType TIMESTAMP_SEC()
Definition types.h:336
static LogicalType ANY(PhysicalTypeID physicalType)
Definition types.h:314
static LBUG_API LogicalType DECIMAL(uint32_t precision, uint32_t scale)
static LogicalType deserialize(Deserializer &deserializer)
static LBUG_API PhysicalTypeID getPhysicalType(LogicalTypeID logicalType, const std::unique_ptr< ExtraTypeInfo > &extraTypeInfo=nullptr)
bool isInternalType() const
Definition types.h:290
void serialize(Serializer &serializer) const
static LogicalType POINTER()
Definition types.h:347
static LBUG_API std::vector< LogicalType > copy(const std::vector< LogicalType > &types)
static LogicalType HASH()
Definition types.h:321
static LogicalType UINT32()
Definition types.h:327
static LogicalType UINT16()
Definition types.h:328
friend struct LogicalTypeUtils
Definition types.h:266
static LogicalType STRING()
Definition types.h:344
static LogicalType convertFromString(const std::string &str, main::ClientContext *context)
LogicalType()
Definition types.h:275
static bool isBuiltInType(const std::string &str)
static LBUG_API std::vector< LogicalType > copy(const std::vector< LogicalType * > &types)
static LogicalType MAP(T &&keyType, T &&valueType)
Definition types.h:366
static LogicalType DOUBLE()
Definition types.h:331
static LBUG_API LogicalType REL(std::vector< StructField > &&fields)
LBUG_API bool operator!=(const LogicalType &other) const
static LogicalType UINT64()
Definition types.h:326
void setExtraTypeInfo(std::unique_ptr< ExtraTypeInfo > typeInfo)
Definition types.h:296
friend struct StructType
Definition types.h:268
static LogicalType INTERNAL_ID()
Definition types.h:341
static LBUG_API LogicalType MAP(LogicalType keyType, LogicalType valueType)
const ExtraTypeInfo * getExtraTypeInfo() const
Definition types.h:300
static LogicalType INT128()
Definition types.h:330
static LBUG_API LogicalType STRUCT(std::vector< StructField > &&fields)
static LogicalType INTERVAL()
Definition types.h:339
static LogicalType DATE()
Definition types.h:333
friend struct CAPIHelper
Definition types.h:378
LBUG_API std::string toString() const
static LBUG_API LogicalType RECURSIVE_REL(std::vector< StructField > &&fields)
static LogicalType INT64()
Definition types.h:322
EXPLICIT_COPY_DEFAULT_MOVE(LogicalType)
LBUG_API LogicalType(LogicalTypeID typeID, TypeCategory info=TypeCategory::INTERNAL)
static LogicalType FLOAT()
Definition types.h:332
friend struct JavaAPIHelper
Definition types.h:379
static LogicalType UINT128()
Definition types.h:342
PhysicalTypeID getPhysicalType() const
Definition types.h:292
static LogicalType ANY()
Definition types.h:309
friend struct ArrayType
Definition types.h:270
static LogicalType INT8()
Definition types.h:325
static LBUG_API LogicalType NODE(std::vector< StructField > &&fields)
static LogicalType INT32()
Definition types.h:323
LogicalTypeID getLogicalTypeID() const
Definition types.h:288
friend struct ListType
Definition types.h:269
static LBUG_API LogicalType ARRAY(LogicalType childType, uint64_t numElements)
static LogicalType TIMESTAMP()
Definition types.h:338
friend class lbug::processor::ParquetReader
Definition types.h:380
static LogicalType SERIAL()
Definition types.h:343
StructField()
Definition types.h:499
bool operator==(const StructField &other) const
bool operator!=(const StructField &other) const
Definition types.h:512
const LogicalType & getType() const
Definition types.h:507
StructField(std::string name, LogicalType type)
Definition types.h:500
static StructField deserialize(Deserializer &deserializer)
std::string getName() const
Definition types.h:505
void serialize(Serializer &serializer) const
DELETE_COPY_DEFAULT_MOVE(StructField)
static std::unique_ptr< ExtraTypeInfo > deserialize(Deserializer &deserializer)
std::unique_ptr< ExtraTypeInfo > copy() const override
const StructField & getStructField(const std::string &fieldName) const
StructTypeInfo(const std::vector< std::string > &fieldNames, const std::vector< LogicalType > &fieldTypes)
std::vector< const LogicalType * > getChildrenTypes() const
const std::vector< StructField > & getStructFields() const
bool hasField(const std::string &fieldName) const
bool containsAny() const override
const StructField & getStructField(struct_field_idx_t idx) const
const LogicalType & getChildType(struct_field_idx_t idx) const
StructTypeInfo(std::vector< StructField > &&fields)
bool operator==(const ExtraTypeInfo &other) const override
std::vector< std::string > getChildrenNames() const
struct_field_idx_t getStructFieldIdx(std::string fieldName) const
std::string getTypeName() const
Definition types.h:415
static std::unique_ptr< ExtraTypeInfo > deserialize(Deserializer &deserializer)
bool operator==(const ExtraTypeInfo &other) const override
std::unique_ptr< ExtraTypeInfo > copy() const override
UDTTypeInfo(std::string typeName)
Definition types.h:413
bool containsAny() const override
Definition types.h:417
Contain client side configuration. We make profiler associated per query, so the profiler is not main...
Definition client_context.h:72
Definition client_context.h:25
Definition array_utils.h:7
page_group_idx_t frame_group_idx_t
Definition types.h:40
constexpr offset_t INVALID_LIMIT
Definition types.h:87
constexpr block_idx_t INVALID_BLOCK_IDX
Definition types.h:48
TO ku_dynamic_cast(FROM *old)
Definition cast.h:11
uint32_t list_size_t
Definition types.h:61
uint32_t page_idx_t
Definition types.h:33
uint64_t node_group_idx_t
Definition types.h:55
uint64_t block_idx_t
Definition types.h:47
uint32_t idx_t
Definition types.h:45
uint64_t cardinality_t
Definition types.h:86
constexpr sel_t INVALID_SEL
Definition types.h:31
uint64_t row_idx_t
Definition types.h:52
uint64_t sel_t
Definition types.h:30
uint64_t executor_id_t
Definition types.h:68
struct_field_idx_t union_field_idx_t
Definition types.h:50
uint16_t struct_field_idx_t
Definition types.h:49
std::vector< table_id_t > table_id_vector_t
Definition types.h:73
constexpr idx_t INVALID_IDX
Definition types.h:46
constexpr column_id_t INVALID_COLUMN_ID
Definition types.h:43
constexpr column_id_t ROW_IDX_COLUMN_ID
Definition types.h:44
internalID_t relID_t
Definition types.h:84
constexpr file_idx_t INVALID_FILE_IDX
Definition types.h:38
constexpr offset_t INVALID_OFFSET
Definition types.h:80
internalID_t nodeID_t
Definition types.h:83
uint64_t transaction_t
Definition types.h:66
std::unordered_map< executor_id_t, uint64_t > executor_info
Definition types.h:69
uint32_t column_id_t
Definition types.h:41
uint64_t hash_t
Definition types.h:32
page_idx_t frame_idx_t
Definition types.h:34
uint32_t file_idx_t
Definition types.h:37
std::vector< offset_t > offset_vec_t
Definition types.h:88
uint64_t oid_t
Definition types.h:63
constexpr partition_idx_t INVALID_PARTITION_IDX
Definition types.h:58
constexpr uint32_t UNDEFINED_CAST_COST
Definition types.h:54
constexpr transaction_t INVALID_TRANSACTION
Definition types.h:67
PhysicalTypeID
Definition types.h:230
@ ALP_EXCEPTION_DOUBLE
Definition types.h:248
@ ALP_EXCEPTION_FLOAT
Definition types.h:247
uint64_t sequence_id_t
Definition types.h:62
LogicalTypeID
Definition types.h:184
@ NODE
Definition types.h:186
@ DECIMAL
Definition types.h:212
@ BLOB
Definition types.h:217
@ UINT32
Definition types.h:199
@ INTERVAL
Definition types.h:211
@ LIST
Definition types.h:219
@ RECURSIVE_REL
Definition types.h:188
@ TIMESTAMP_NS
Definition types.h:209
@ UINT16
Definition types.h:200
@ INT64
Definition types.h:194
@ UUID
Definition types.h:226
@ MAP
Definition types.h:222
@ INT16
Definition types.h:196
@ DATE
Definition types.h:205
@ STRING
Definition types.h:216
@ INT32
Definition types.h:195
@ UINT64
Definition types.h:198
@ SERIAL
Definition types.h:191
@ TIMESTAMP
Definition types.h:206
@ ANY
Definition types.h:185
@ INTERNAL_ID
Definition types.h:213
@ POINTER
Definition types.h:224
@ BOOL
Definition types.h:193
@ STRUCT
Definition types.h:221
@ TIMESTAMP_TZ
Definition types.h:210
@ INT128
Definition types.h:202
@ ARRAY
Definition types.h:220
@ UINT128
Definition types.h:214
@ TIMESTAMP_MS
Definition types.h:208
@ TIMESTAMP_SEC
Definition types.h:207
@ FLOAT
Definition types.h:204
@ REL
Definition types.h:187
@ UNION
Definition types.h:223
@ UINT8
Definition types.h:201
@ INT8
Definition types.h:197
@ DOUBLE
Definition types.h:203
std::unordered_map< table_id_t, T > table_id_map_t
Definition types.h:76
oid_t table_id_t
Definition types.h:72
uint32_t property_id_t
Definition types.h:42
constexpr page_idx_t INVALID_PAGE_IDX
Definition types.h:36
uint64_t offset_t
Definition types.h:79
constexpr node_group_idx_t INVALID_NODE_GROUP_IDX
Definition types.h:56
constexpr struct_field_idx_t INVALID_STRUCT_FIELD_IDX
Definition types.h:51
constexpr row_idx_t INVALID_ROW_IDX
Definition types.h:53
constexpr table_id_t INVALID_TABLE_ID
Definition types.h:77
FileVersionType
Definition types.h:674
@ WAL_VERSION
Definition types.h:674
@ ORIGINAL
Definition types.h:674
TypeCategory
Definition types.h:263
@ INTERNAL
Definition types.h:263
@ UDT
Definition types.h:263
uint64_t length_t
Definition types.h:59
constexpr oid_t INVALID_OID
Definition types.h:64
std::unordered_set< table_id_t > table_id_set_t
Definition types.h:74
uint32_t page_offset_t
Definition types.h:35
std::vector< LogicalType > logical_type_vec_t
Definition types.h:558
constexpr length_t INVALID_LENGTH
Definition types.h:60
uint32_t page_group_idx_t
Definition types.h:39
uint64_t partition_idx_t
Definition types.h:57
Definition bind_input.h:16
Definition client_context.h:41
Definition array_utils.h:7
static uint64_t getNumElements(const LogicalType &type)
static const LogicalType & getChildType(const LogicalType &type)
static uint32_t getPrecision(const LogicalType &type)
static std::string insertDecimalPoint(const std::string &value, uint32_t posFromEnd)
static uint32_t getScale(const LogicalType &type)
static const LogicalType & getChildType(const LogicalType &type)
static bool isUnsigned(const LogicalType &dataType)
static std::vector< LogicalType > getAllValidLogicTypes()
static std::string toString(LogicalTypeID dataTypeID)
static bool isNested(LogicalTypeID logicalTypeID)
static bool isUnsigned(const LogicalTypeID &dataType)
static bool isDate(const LogicalType &dataType)
static std::vector< LogicalTypeID > getAllValidComparableLogicalTypes()
static LogicalType purgeAny(const LogicalType &type, const LogicalType &replacement)
static bool isFloatingPoint(const LogicalTypeID &dataType)
static bool isIntegral(const LogicalTypeID &dataType)
static LogicalType combineTypes(const std::vector< LogicalType > &types)
static std::vector< LogicalTypeID > getIntegerTypeIDs()
static bool isNumerical(const LogicalType &dataType)
static std::string toString(const std::vector< LogicalType > &dataTypes)
static bool isTimestamp(const LogicalTypeID &dataType)
static bool isNested(const LogicalType &dataType)
static LogicalType combineTypes(const LogicalType &left, const LogicalType &right)
static bool isTimestamp(const LogicalType &dataType)
static uint32_t getRowLayoutSize(const LogicalType &logicalType)
static std::string toString(const std::vector< LogicalTypeID > &dataTypeIDs)
static std::vector< LogicalTypeID > getAllValidLogicTypeIDs()
static std::vector< LogicalTypeID > getFloatingPointTypeIDs()
static bool tryGetMaxLogicalType(const LogicalType &left, const LogicalType &right, LogicalType &result)
static bool isIntegral(const LogicalType &dataType)
static std::vector< LogicalTypeID > getNumericalLogicalTypeIDs()
static bool isDate(const LogicalTypeID &dataType)
static bool isNumerical(const LogicalTypeID &dataType)
static bool tryGetMaxLogicalType(const std::vector< LogicalType > &types, LogicalType &result)
static const LogicalType & getKeyType(const LogicalType &type)
static const LogicalType & getValueType(const LogicalType &type)
static std::string toString(PhysicalTypeID physicalType)
static uint32_t getFixedTypeSize(PhysicalTypeID physicalType)
static struct_field_idx_t getFieldIdx(const LogicalType &type, const std::string &key)
static const LogicalType & getFieldType(const LogicalType &type, const std::string &key)
static std::vector< const LogicalType * > getFieldTypes(const LogicalType &type)
static std::vector< std::string > getFieldNames(const LogicalType &type)
static const LogicalType & getFieldType(const LogicalType &type, struct_field_idx_t idx)
static uint64_t getNumFields(const LogicalType &type)
static bool hasField(const LogicalType &type, const std::string &key)
static const StructField & getField(const LogicalType &type, struct_field_idx_t idx)
static const std::vector< StructField > & getFields(const LogicalType &type)
static const StructField & getField(const LogicalType &type, const std::string &key)
static constexpr char TAG_FIELD_NAME[]
Definition types.h:609
static std::string getFieldName(const LogicalType &type, union_field_idx_t idx)
static const LogicalType & getFieldType(const LogicalType &type, union_field_idx_t idx)
static union_field_idx_t getFieldIdx(const LogicalType &type, const std::string &key)
static constexpr auto TAG_FIELD_TYPE
Definition types.h:607
static constexpr union_field_idx_t TAG_FIELD_IDX
Definition types.h:605
static bool hasField(const LogicalType &type, const std::string &key)
static const LogicalType & getFieldType(const LogicalType &type, const std::string &key)
static uint64_t getNumFields(const LogicalType &type)
static union_field_idx_t getInternalFieldIdx(union_field_idx_t idx)
internalID_t(offset_t offset, table_id_t tableID)
bool operator<(const internalID_t &rhs) const
offset_t offset
Definition types.h:91
bool operator>(const internalID_t &rhs) const
table_id_t tableID
Definition types.h:92
bool operator!=(const internalID_t &rhs) const
bool operator<=(const internalID_t &rhs) const
bool operator==(const internalID_t &rhs) const
bool operator>=(const internalID_t &rhs) const
Definition ku_string.h:12
constexpr list_entry_t(offset_t offset, list_size_t size)
Definition types.h:119
offset_t offset
Definition types.h:115
list_size_t size
Definition types.h:116
constexpr list_entry_t()
Definition types.h:118
list_entry_t entry
Definition types.h:127
uint8_t * value
Definition types.h:111
uint64_t numElements
Definition types.h:110
int64_t pos
Definition types.h:123
Definition uint128_t.h:15
struct_entry_t entry
Definition types.h:131