class OdpsDatahub::StreamReader

Attributes

mPackId[R]
mPackStream[R]
mPath[R]
mProject[R]
mReadMode[R]
mSchema[R]
mShardId[R]
mTable[R]

Public Class Methods

new(project, table, shardId, path, schema, packId = PackType.FIRST_PACK_ID) click to toggle source
# File lib/fluent/plugin/stream_reader.rb, line 32
def initialize(project, table, shardId, path, schema, packId = PackType.FIRST_PACK_ID)
  @mProject = project
  @mTable = table
  @mPath = path
  @mShardId = shardId
  @mSchema = schema
  @mPackId = packId
  @mReadMode = ReadMode.SEEK_BEGIN
end

Public Instance Methods

getPack() click to toggle source

TODO

# File lib/fluent/plugin/stream_reader.rb, line 49
def getPack #get cur pack stream

end
read() click to toggle source

TODO

# File lib/fluent/plugin/stream_reader.rb, line 42
def read #return a pack stream of this pack
  if mPackStream != nil
    mPackStream = getPack
  end

end