Class: Hive2::Thrift::TCLIService::Processor

Inherits:
Object
  • Object
show all
Includes:
Thrift::Processor
Defined in:
lib/thrift/t_c_l_i_service.rb

Instance Method Summary collapse

Instance Method Details

#process_CancelOperation(seqid, iprot, oprot) ⇒ Object 



345
346
347
348
349
350
 
# File 'lib/thrift/t_c_l_i_service.rb', line 345

def process_CancelOperation(seqid, iprot, oprot)
  args = read_args(iprot, CancelOperation_args)
  result = CancelOperation_result.new()
  result.success = @handler.CancelOperation(args.req)
  write_result(result, oprot, 'CancelOperation', seqid)
end

#process_CloseOperation(seqid, iprot, oprot) ⇒ Object 



352
353
354
355
356
357
 
# File 'lib/thrift/t_c_l_i_service.rb', line 352

def process_CloseOperation(seqid, iprot, oprot)
  args = read_args(iprot, CloseOperation_args)
  result = CloseOperation_result.new()
  result.success = @handler.CloseOperation(args.req)
  write_result(result, oprot, 'CloseOperation', seqid)
end

#process_CloseSession(seqid, iprot, oprot) ⇒ Object 



268
269
270
271
272
273
 
# File 'lib/thrift/t_c_l_i_service.rb', line 268

def process_CloseSession(seqid, iprot, oprot)
  args = read_args(iprot, CloseSession_args)
  result = CloseSession_result.new()
  result.success = @handler.CloseSession(args.req)
  write_result(result, oprot, 'CloseSession', seqid)
end

#process_ExecuteStatement(seqid, iprot, oprot) ⇒ Object 



282
283
284
285
286
287
 
# File 'lib/thrift/t_c_l_i_service.rb', line 282

def process_ExecuteStatement(seqid, iprot, oprot)
  args = read_args(iprot, ExecuteStatement_args)
  result = ExecuteStatement_result.new()
  result.success = @handler.ExecuteStatement(args.req)
  write_result(result, oprot, 'ExecuteStatement', seqid)
end

#process_FetchResults(seqid, iprot, oprot) ⇒ Object 



366
367
368
369
370
371
 
# File 'lib/thrift/t_c_l_i_service.rb', line 366

def process_FetchResults(seqid, iprot, oprot)
  args = read_args(iprot, FetchResults_args)
  result = FetchResults_result.new()
  result.success = @handler.FetchResults(args.req)
  write_result(result, oprot, 'FetchResults', seqid)
end

#process_GetCatalogs(seqid, iprot, oprot) ⇒ Object 



296
297
298
299
300
301
 
# File 'lib/thrift/t_c_l_i_service.rb', line 296

def process_GetCatalogs(seqid, iprot, oprot)
  args = read_args(iprot, GetCatalogs_args)
  result = GetCatalogs_result.new()
  result.success = @handler.GetCatalogs(args.req)
  write_result(result, oprot, 'GetCatalogs', seqid)
end

#process_GetColumns(seqid, iprot, oprot) ⇒ Object 



324
325
326
327
328
329
 
# File 'lib/thrift/t_c_l_i_service.rb', line 324

def process_GetColumns(seqid, iprot, oprot)
  args = read_args(iprot, GetColumns_args)
  result = GetColumns_result.new()
  result.success = @handler.GetColumns(args.req)
  write_result(result, oprot, 'GetColumns', seqid)
end

#process_GetFunctions(seqid, iprot, oprot) ⇒ Object 



331
332
333
334
335
336
 
# File 'lib/thrift/t_c_l_i_service.rb', line 331

def process_GetFunctions(seqid, iprot, oprot)
  args = read_args(iprot, GetFunctions_args)
  result = GetFunctions_result.new()
  result.success = @handler.GetFunctions(args.req)
  write_result(result, oprot, 'GetFunctions', seqid)
end

#process_GetInfo(seqid, iprot, oprot) ⇒ Object 



275
276
277
278
279
280
 
# File 'lib/thrift/t_c_l_i_service.rb', line 275

def process_GetInfo(seqid, iprot, oprot)
  args = read_args(iprot, GetInfo_args)
  result = GetInfo_result.new()
  result.success = @handler.GetInfo(args.req)
  write_result(result, oprot, 'GetInfo', seqid)
end

#process_GetOperationStatus(seqid, iprot, oprot) ⇒ Object 



338
339
340
341
342
343
 
# File 'lib/thrift/t_c_l_i_service.rb', line 338

def process_GetOperationStatus(seqid, iprot, oprot)
  args = read_args(iprot, GetOperationStatus_args)
  result = GetOperationStatus_result.new()
  result.success = @handler.GetOperationStatus(args.req)
  write_result(result, oprot, 'GetOperationStatus', seqid)
end

#process_GetResultSetMetadata(seqid, iprot, oprot) ⇒ Object 



359
360
361
362
363
364
 
# File 'lib/thrift/t_c_l_i_service.rb', line 359

def process_GetResultSetMetadata(seqid, iprot, oprot)
  args = read_args(iprot, GetResultSetMetadata_args)
  result = GetResultSetMetadata_result.new()
  result.success = @handler.GetResultSetMetadata(args.req)
  write_result(result, oprot, 'GetResultSetMetadata', seqid)
end

#process_GetSchemas(seqid, iprot, oprot) ⇒ Object 



303
304
305
306
307
308
 
# File 'lib/thrift/t_c_l_i_service.rb', line 303

def process_GetSchemas(seqid, iprot, oprot)
  args = read_args(iprot, GetSchemas_args)
  result = GetSchemas_result.new()
  result.success = @handler.GetSchemas(args.req)
  write_result(result, oprot, 'GetSchemas', seqid)
end

#process_GetTables(seqid, iprot, oprot) ⇒ Object 



310
311
312
313
314
315
 
# File 'lib/thrift/t_c_l_i_service.rb', line 310

def process_GetTables(seqid, iprot, oprot)
  args = read_args(iprot, GetTables_args)
  result = GetTables_result.new()
  result.success = @handler.GetTables(args.req)
  write_result(result, oprot, 'GetTables', seqid)
end

#process_GetTableTypes(seqid, iprot, oprot) ⇒ Object 



317
318
319
320
321
322
 
# File 'lib/thrift/t_c_l_i_service.rb', line 317

def process_GetTableTypes(seqid, iprot, oprot)
  args = read_args(iprot, GetTableTypes_args)
  result = GetTableTypes_result.new()
  result.success = @handler.GetTableTypes(args.req)
  write_result(result, oprot, 'GetTableTypes', seqid)
end

#process_GetTypeInfo(seqid, iprot, oprot) ⇒ Object 



289
290
291
292
293
294
 
# File 'lib/thrift/t_c_l_i_service.rb', line 289

def process_GetTypeInfo(seqid, iprot, oprot)
  args = read_args(iprot, GetTypeInfo_args)
  result = GetTypeInfo_result.new()
  result.success = @handler.GetTypeInfo(args.req)
  write_result(result, oprot, 'GetTypeInfo', seqid)
end

#process_OpenSession(seqid, iprot, oprot) ⇒ Object 



261
262
263
264
265
266
 
# File 'lib/thrift/t_c_l_i_service.rb', line 261

def process_OpenSession(seqid, iprot, oprot)
  args = read_args(iprot, OpenSession_args)
  result = OpenSession_result.new()
  result.success = @handler.OpenSession(args.req)
  write_result(result, oprot, 'OpenSession', seqid)
end