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