Class: ArrowDuckDB::Result

Inherits:

Object

• Object
• ArrowDuckDB::Result

Includes:

Enumerable

Defined in:

lib/arrow-duckdb/result.rb,
ext/arrow-duckdb/arrow-duckdb.cpp

Instance Method Summary

• #each ⇒ Object
• #fetch ⇒ Object
• #n_changed_rows ⇒ Object
• #n_columns ⇒ Object
• #n_rows ⇒ Object
• #schema ⇒ Object
• #to_table ⇒ Object

Instance Method Details

#each ⇒ Object

# File 'ext/arrow-duckdb/arrow-duckdb.cpp', line 160

VALUE
result_each(VALUE self)
{
  RETURN_ENUMERATOR(self, 0, 0);

  Result *result;
  TypedData_Get_Struct(self, Result, &result_type, result);

  result_ensure_gschema(result);

  while (true) {
    auto record_batch = result_fetch_internal(self, result);
    if (NIL_P(record_batch)) {
      break;
    }
    rb_yield(record_batch);
  }

  return self;
}

#fetch ⇒ Object

# File 'ext/arrow-duckdb/arrow-duckdb.cpp', line 149

VALUE
result_fetch(VALUE self)
{
  Result *result;
  TypedData_Get_Struct(self, Result, &result_type, result);

  result_ensure_gschema(result);

  return result_fetch_internal(self, result);
}

#n_changed_rows ⇒ Object

# File 'ext/arrow-duckdb/arrow-duckdb.cpp', line 210

VALUE
result_n_changed_rows(VALUE self)
{
  Result *result;
  TypedData_Get_Struct(self, Result, &result_type, result);

  return ULL2NUM(duckdb_arrow_rows_changed(result->arrow));
}

#n_columns ⇒ Object

# File 'ext/arrow-duckdb/arrow-duckdb.cpp', line 192

VALUE
result_n_columns(VALUE self)
{
  Result *result;
  TypedData_Get_Struct(self, Result, &result_type, result);

  return ULL2NUM(duckdb_arrow_column_count(result->arrow));
}

#n_rows ⇒ Object

# File 'ext/arrow-duckdb/arrow-duckdb.cpp', line 201

VALUE
result_n_rows(VALUE self)
{
  Result *result;
  TypedData_Get_Struct(self, Result, &result_type, result);

  return ULL2NUM(duckdb_arrow_row_count(result->arrow));
}

#schema ⇒ Object

# File 'ext/arrow-duckdb/arrow-duckdb.cpp', line 181

VALUE
result_schema(VALUE self)
{
  Result *result;
  TypedData_Get_Struct(self, Result, &result_type, result);

  result_ensure_gschema(result);

  return GOBJ2RVAL(result->gschema);
}

#to_table ⇒ Object

# File 'lib/arrow-duckdb/result.rb', line 17

def to_table
  Arrow::Table.new(schema, to_a)
end