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