class Hive::Thrift::ThriftHive::Processor
Public Instance Methods
process_execute(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive.rb 149 def process_execute(seqid, iprot, oprot) 150 args = read_args(iprot, Execute_args) 151 result = Execute_result.new() 152 begin 153 @handler.execute(args.query) 154 rescue ::Hive::Thrift::HiveServerException => ex 155 result.ex = ex 156 end 157 write_result(result, oprot, 'execute', seqid) 158 end
process_fetchAll(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive.rb 182 def process_fetchAll(seqid, iprot, oprot) 183 args = read_args(iprot, FetchAll_args) 184 result = FetchAll_result.new() 185 begin 186 result.success = @handler.fetchAll() 187 rescue ::Hive::Thrift::HiveServerException => ex 188 result.ex = ex 189 end 190 write_result(result, oprot, 'fetchAll', seqid) 191 end
process_fetchN(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive.rb 171 def process_fetchN(seqid, iprot, oprot) 172 args = read_args(iprot, FetchN_args) 173 result = FetchN_result.new() 174 begin 175 result.success = @handler.fetchN(args.numRows) 176 rescue ::Hive::Thrift::HiveServerException => ex 177 result.ex = ex 178 end 179 write_result(result, oprot, 'fetchN', seqid) 180 end
process_fetchOne(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive.rb 160 def process_fetchOne(seqid, iprot, oprot) 161 args = read_args(iprot, FetchOne_args) 162 result = FetchOne_result.new() 163 begin 164 result.success = @handler.fetchOne() 165 rescue ::Hive::Thrift::HiveServerException => ex 166 result.ex = ex 167 end 168 write_result(result, oprot, 'fetchOne', seqid) 169 end
process_getClusterStatus(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive.rb 215 def process_getClusterStatus(seqid, iprot, oprot) 216 args = read_args(iprot, GetClusterStatus_args) 217 result = GetClusterStatus_result.new() 218 begin 219 result.success = @handler.getClusterStatus() 220 rescue ::Hive::Thrift::HiveServerException => ex 221 result.ex = ex 222 end 223 write_result(result, oprot, 'getClusterStatus', seqid) 224 end
process_getQueryPlan(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive.rb 226 def process_getQueryPlan(seqid, iprot, oprot) 227 args = read_args(iprot, GetQueryPlan_args) 228 result = GetQueryPlan_result.new() 229 begin 230 result.success = @handler.getQueryPlan() 231 rescue ::Hive::Thrift::HiveServerException => ex 232 result.ex = ex 233 end 234 write_result(result, oprot, 'getQueryPlan', seqid) 235 end
process_getSchema(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive.rb 193 def process_getSchema(seqid, iprot, oprot) 194 args = read_args(iprot, GetSchema_args) 195 result = GetSchema_result.new() 196 begin 197 result.success = @handler.getSchema() 198 rescue ::Hive::Thrift::HiveServerException => ex 199 result.ex = ex 200 end 201 write_result(result, oprot, 'getSchema', seqid) 202 end
process_getThriftSchema(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive.rb 204 def process_getThriftSchema(seqid, iprot, oprot) 205 args = read_args(iprot, GetThriftSchema_args) 206 result = GetThriftSchema_result.new() 207 begin 208 result.success = @handler.getThriftSchema() 209 rescue ::Hive::Thrift::HiveServerException => ex 210 result.ex = ex 211 end 212 write_result(result, oprot, 'getThriftSchema', seqid) 213 end