class OdpsDatahub::OdpsTableSchema
Attributes
mCols[RW]
Public Class Methods
new(jsonobj = nil)
click to toggle source
# File lib/fluent/plugin/odps/odps_table_schema.rb, line 37 def initialize(jsonobj = nil) @mCols = Array.new if jsonobj != nil columns = jsonobj["columns"] columns.each do |object| appendColumn(object["name"], object["type"]) end end end
Public Instance Methods
appendColumn(name, type)
click to toggle source
# File lib/fluent/plugin/odps/odps_table_schema.rb, line 58 def appendColumn(name, type) col = OdpsTableColumn.new(name, type, @mCols.size) @mCols.push(col) end
getColumnCount()
click to toggle source
# File lib/fluent/plugin/odps/odps_table_schema.rb, line 47 def getColumnCount @mCols.size end
getColumnType(idx)
click to toggle source
# File lib/fluent/plugin/odps/odps_table_schema.rb, line 51 def getColumnType(idx) if idx < 0 or idx >= @mCols.size raise "idx out of range" end @mCols.at(idx).mType end