Theme by the Executable Book Project

Class abstractsql_parser¶

Defined in File AbstractSQLParser.h

Inheritance Relationships¶

Base Type¶

public ral::io::data_parser (Class data_parser)

Derived Types¶

public ral::io::mysql_parser (Class mysql_parser)
public ral::io::postgresql_parser (Class postgresql_parser)
public ral::io::sqlite_parser (Class sqlite_parser)

Class Documentation¶

class ral::io::abstractsql_parser : public ral::io::data_parser ¶

Subclassed by ral::io::mysql_parser, ral::io::postgresql_parser, ral::io::sqlite_parser

Public Functions

abstractsql_parser(DataType sql_datatype)¶

virtual ~abstractsql_parser()¶

virtual std::unique_ptr<ral::frame::BlazingTable> parse_batch(ral::io::data_handle handle, const Schema &schema, std::vector<int> column_indices, std::vector<cudf::size_type> row_groups) override¶

virtual void parse_schema(ral::io::data_handle handle, Schema &schema) override¶

virtual std::unique_ptr<ral::frame::BlazingTable> get_metadata(std::vector<ral::io::data_handle> handles, int offset) override¶

inline virtual DataType type() const override¶

Protected Functions

virtual void read_sql_loop(void *src, const std::vector<cudf::type_id> &cudf_types, const std::vector<int> &column_indices, std::vector<void*> &host_cols, std::vector<std::vector<cudf::bitmask_type>> &null_masks) = 0¶

virtual cudf::type_id get_cudf_type_id(const std::string &sql_column_type) = 0¶

virtual uint8_t parse_cudf_int8(void *src, size_t col, size_t row, std::vector<int8_t> *v) = 0¶

virtual uint8_t parse_cudf_int16(void *src, size_t col, size_t row, std::vector<int16_t> *v) = 0¶

virtual uint8_t parse_cudf_int32(void *src, size_t col, size_t row, std::vector<int32_t> *v) = 0¶

virtual uint8_t parse_cudf_int64(void *src, size_t col, size_t row, std::vector<int64_t> *v) = 0¶

virtual uint8_t parse_cudf_uint8(void *src, size_t col, size_t row, std::vector<uint8_t> *v) = 0¶

virtual uint8_t parse_cudf_uint16(void *src, size_t col, size_t row, std::vector<uint16_t> *v) = 0¶

virtual uint8_t parse_cudf_uint32(void *src, size_t col, size_t row, std::vector<uint32_t> *v) = 0¶

virtual uint8_t parse_cudf_uint64(void *src, size_t col, size_t row, std::vector<uint64_t> *v) = 0¶

virtual uint8_t parse_cudf_float32(void *src, size_t col, size_t row, std::vector<float> *v) = 0¶

virtual uint8_t parse_cudf_float64(void *src, size_t col, size_t row, std::vector<double> *v) = 0¶

virtual uint8_t parse_cudf_bool8(void *src, size_t col, size_t row, std::vector<int8_t> *v) = 0¶

virtual uint8_t parse_cudf_timestamp_days(void *src, size_t col, size_t row, cudf_string_col *v) = 0¶

virtual uint8_t parse_cudf_timestamp_seconds(void *src, size_t col, size_t row, cudf_string_col *v) = 0¶

virtual uint8_t parse_cudf_timestamp_milliseconds(void *src, size_t col, size_t row, cudf_string_col *v) = 0¶

virtual uint8_t parse_cudf_timestamp_microseconds(void *src, size_t col, size_t row, cudf_string_col *v) = 0¶

virtual uint8_t parse_cudf_timestamp_nanoseconds(void *src, size_t col, size_t row, cudf_string_col *v) = 0¶

virtual uint8_t parse_cudf_string(void *src, size_t col, size_t row, cudf_string_col *v) = 0¶

void parse_sql(void *src, const std::vector<int> &column_indices, const std::vector<cudf::type_id> &cudf_types, size_t row, std::vector<void*> &host_cols, std::vector<std::vector<cudf::bitmask_type>> &null_masks)¶

Class abstractsql_data_provider Class arrow_parser