Class: Iceberg::Table

Inherits:
Object
  • Object
show all
Defined in:
lib/iceberg/table.rb

Direct Known Subclasses

StaticTable

Instance Method Summary collapse

Constructor Details

#initialize(table, catalog) ⇒ Table

Returns a new instance of Table.



3
4
5
6
 
# File 'lib/iceberg/table.rb', line 3

def initialize(table, catalog)
  @table = table
  @catalog = catalog
end

Instance Method Details

#append(df) ⇒ Object 



100
101
102
103
104
 
# File 'lib/iceberg/table.rb', line 100

def append(df)
  check_catalog
  @table = @table.append(df.arrow_c_stream, @catalog)
  nil
end

#current_schema ⇒ Object Also known as: schema 



44
45
46
 
# File 'lib/iceberg/table.rb', line 44

def current_schema
  @table.current_schema
end

#current_schema_id ⇒ Object Also known as: schema_id 



49
50
51
 
# File 'lib/iceberg/table.rb', line 49

def current_schema_id
  @table.current_schema_id
end

#current_snapshot ⇒ Object 



74
75
76
 
# File 'lib/iceberg/table.rb', line 74

def current_snapshot
  @table.current_snapshot
end

#current_snapshot_id ⇒ Object 



78
79
80
 
# File 'lib/iceberg/table.rb', line 78

def current_snapshot_id
  @table.current_snapshot_id
end

#default_partition_spec_id ⇒ Object 



54
55
56
 
# File 'lib/iceberg/table.rb', line 54

def default_partition_spec_id
  @table.default_partition_spec_id
end

#format_version ⇒ Object 



8
9
10
 
# File 'lib/iceberg/table.rb', line 8

def format_version
  @table.format_version
end

#history ⇒ Object 



66
67
68
 
# File 'lib/iceberg/table.rb', line 66

def history
  @table.history
end

#inspect ⇒ Object

hide internal state



107
108
109
 
# File 'lib/iceberg/table.rb', line 107

def inspect
  to_s
end

#last_column_id ⇒ Object 



28
29
30
 
# File 'lib/iceberg/table.rb', line 28

def last_column_id
  @table.last_column_id
end

#last_partition_id ⇒ Object 



32
33
34
 
# File 'lib/iceberg/table.rb', line 32

def last_partition_id
  @table.last_partition_id
end

#last_sequence_number ⇒ Object 



20
21
22
 
# File 'lib/iceberg/table.rb', line 20

def last_sequence_number
  @table.last_sequence_number
end

#location ⇒ Object 



16
17
18
 
# File 'lib/iceberg/table.rb', line 16

def location
  @table.location
end

#metadata_log ⇒ Object 



70
71
72
 
# File 'lib/iceberg/table.rb', line 70

def metadata_log
  @table.metadata_log
end

#next_sequence_number ⇒ Object 



24
25
26
 
# File 'lib/iceberg/table.rb', line 24

def next_sequence_number
  @table.next_sequence_number
end

#properties ⇒ Object 



82
83
84
 
# File 'lib/iceberg/table.rb', line 82

def properties
  @table.properties
end

#scan(snapshot_id: nil) ⇒ Object 



86
87
88
 
# File 'lib/iceberg/table.rb', line 86

def scan(snapshot_id: nil)
  TableScan.new(@table.scan(snapshot_id), self)
end

#schema_by_id(schema_id) ⇒ Object 



40
41
42
 
# File 'lib/iceberg/table.rb', line 40

def schema_by_id(schema_id)
  @table.schema_by_id(schema_id)
end

#schemas ⇒ Object 



36
37
38
 
# File 'lib/iceberg/table.rb', line 36

def schemas
  @table.schemas
end

#snapshot_by_id(snapshot_id) ⇒ Object 



62
63
64
 
# File 'lib/iceberg/table.rb', line 62

def snapshot_by_id(snapshot_id)
  @table.snapshot_by_id(snapshot_id)
end

#snapshots ⇒ Object 



58
59
60
 
# File 'lib/iceberg/table.rb', line 58

def snapshots
  @table.snapshots
end

#to_polars(snapshot_id: nil, storage_options: nil) ⇒ Object 



90
91
92
93
94
95
96
97
98
 
# File 'lib/iceberg/table.rb', line 90

def to_polars(snapshot_id: nil, storage_options: nil)
  require "polars-df"

  if Gem::Version.new(Polars::VERSION) < Gem::Version.new("0.23")
    raise "Requires polars-df >= 0.23"
  end

  Polars.scan_iceberg(self, snapshot_id:, storage_options:)
end

#uuid ⇒ Object 



12
13
14
 
# File 'lib/iceberg/table.rb', line 12

def uuid
  @table.uuid
end