kuzu::processor Namespace Reference

Classes
struct	CopyFromFileError
struct	DataChunkDescriptor
struct	DataPos
class	FlatTuple
	Stores a vector of Values. More...
struct	LineContext
struct	OperatorMetrics
class	PhysicalOperator
class	PhysicalOperatorUtils
struct	PopulatedCopyFromError
class	ResultSet
struct	ResultSetDescriptor
class	WarningContext
struct	WarningInfo
struct	WarningSourceData

Concepts
concept	DataSource

Typedefs
using	data_chunk_pos_t = common::idx_t
using	value_vector_pos_t = common::idx_t
using	physical_op_id = uint32_t
using	physical_op_vector_t = std::vector<std::unique_ptr<PhysicalOperator>>
using	populate_func_t = std::function<PopulatedCopyFromError(CopyFromFileError, common::idx_t)>
using	get_file_idx_func_t = std::function<common::idx_t(const CopyFromFileError&)>

Enumerations
enum class	PhysicalOperatorType : uint8_t {   ALTER , AGGREGATE , AGGREGATE_FINALIZE , AGGREGATE_SCAN ,   ATTACH_DATABASE , BATCH_INSERT , COPY_TO , CREATE_MACRO ,   CREATE_SEQUENCE , CREATE_TABLE , CREATE_TYPE , CROSS_PRODUCT ,   DETACH_DATABASE , DELETE_ , DROP , DUMMY_SINK ,   EMPTY_RESULT , EXPORT_DATABASE , FILTER , FLATTEN ,   GDS_CALL , HASH_JOIN_BUILD , HASH_JOIN_PROBE , IMPORT_DATABASE ,   INDEX_LOOKUP , INSERT , INTERSECT_BUILD , INTERSECT ,   INSTALL_EXTENSION , LIMIT , LOAD_EXTENSION , MERGE ,   MULTIPLICITY_REDUCER , OFFSET_SCAN_NODE_TABLE , PARTITIONER , PATH_PROPERTY_PROBE ,   PRIMARY_KEY_SCAN_NODE_TABLE , PROJECTION , PROFILE , RECURSIVE_JOIN ,   RESULT_COLLECTOR , SCAN_NODE_TABLE , SCAN_REL_TABLE , SEMI_MASKER ,   SET_PROPERTY , SKIP , STANDALONE_CALL , TABLE_FUNCTION_CALL ,   TOP_K , TOP_K_SCAN , TRANSACTION , ORDER_BY ,   ORDER_BY_MERGE , ORDER_BY_SCAN , UNION_ALL_SCAN , UNWIND ,   USE_DATABASE }

Variables
constexpr data_chunk_pos_t	INVALID_DATA_CHUNK_POS = common::INVALID_IDX
constexpr value_vector_pos_t	INVALID_VALUE_VECTOR_POS = common::INVALID_IDX

Typedef Documentation

data_chunk_pos_t

using kuzu::processor::data_chunk_pos_t = common::idx_t

get_file_idx_func_t

using kuzu::processor::get_file_idx_func_t = std::function<common::idx_t(const CopyFromFileError&)>

physical_op_id

using kuzu::processor::physical_op_id = uint32_t

physical_op_vector_t

using kuzu::processor::physical_op_vector_t = std::vector<std::unique_ptr<PhysicalOperator>>

populate_func_t

using kuzu::processor::populate_func_t = std::function<PopulatedCopyFromError(CopyFromFileError, common::idx_t)>

value_vector_pos_t

using kuzu::processor::value_vector_pos_t = common::idx_t

Enumeration Type Documentation

PhysicalOperatorType

enum class kuzu::processor::PhysicalOperatorType : uint8_t

strong

Enumerator
ALTER
AGGREGATE
AGGREGATE_FINALIZE
AGGREGATE_SCAN
ATTACH_DATABASE
BATCH_INSERT
COPY_TO
CREATE_MACRO
CREATE_SEQUENCE
CREATE_TABLE
CREATE_TYPE
CROSS_PRODUCT
DETACH_DATABASE
DELETE_
DROP
DUMMY_SINK
EMPTY_RESULT
EXPORT_DATABASE
FILTER
FLATTEN
GDS_CALL
HASH_JOIN_BUILD
HASH_JOIN_PROBE
IMPORT_DATABASE
INDEX_LOOKUP
INSERT
INTERSECT_BUILD
INTERSECT
INSTALL_EXTENSION
LIMIT
LOAD_EXTENSION
MERGE
MULTIPLICITY_REDUCER
OFFSET_SCAN_NODE_TABLE
PARTITIONER
PATH_PROPERTY_PROBE
PRIMARY_KEY_SCAN_NODE_TABLE
PROJECTION
PROFILE
RECURSIVE_JOIN
RESULT_COLLECTOR
SCAN_NODE_TABLE
SCAN_REL_TABLE
SEMI_MASKER
SET_PROPERTY
SKIP
STANDALONE_CALL
TABLE_FUNCTION_CALL
TOP_K
TOP_K_SCAN
TRANSACTION
ORDER_BY
ORDER_BY_MERGE
ORDER_BY_SCAN
UNION_ALL_SCAN
UNWIND
USE_DATABASE

Variable Documentation

INVALID_DATA_CHUNK_POS

data_chunk_pos_t kuzu::processor::INVALID_DATA_CHUNK_POS = common::INVALID_IDX

constexpr

INVALID_VALUE_VECTOR_POS

value_vector_pos_t kuzu::processor::INVALID_VALUE_VECTOR_POS = common::INVALID_IDX

constexpr