Class: Impala::Protocol::Hive::TCLIService::Processor
- Inherits:
-
Object
- Object
- Impala::Protocol::Hive::TCLIService::Processor
show all
- Includes:
- Thrift::Processor
- Defined in:
- lib/impala/protocol/t_c_l_i_service.rb
Instance Method Summary
collapse
-
#process_CancelOperation(seqid, iprot, oprot) ⇒ Object
-
#process_CloseOperation(seqid, iprot, oprot) ⇒ Object
-
#process_CloseSession(seqid, iprot, oprot) ⇒ Object
-
#process_ExecuteStatement(seqid, iprot, oprot) ⇒ Object
-
#process_FetchResults(seqid, iprot, oprot) ⇒ Object
-
#process_GetCatalogs(seqid, iprot, oprot) ⇒ Object
-
#process_GetColumns(seqid, iprot, oprot) ⇒ Object
-
#process_GetFunctions(seqid, iprot, oprot) ⇒ Object
-
#process_GetInfo(seqid, iprot, oprot) ⇒ Object
-
#process_GetLog(seqid, iprot, oprot) ⇒ Object
-
#process_GetOperationStatus(seqid, iprot, oprot) ⇒ Object
-
#process_GetResultSetMetadata(seqid, iprot, oprot) ⇒ Object
-
#process_GetSchemas(seqid, iprot, oprot) ⇒ Object
-
#process_GetTables(seqid, iprot, oprot) ⇒ Object
-
#process_GetTableTypes(seqid, iprot, oprot) ⇒ Object
-
#process_GetTypeInfo(seqid, iprot, oprot) ⇒ Object
-
#process_OpenSession(seqid, iprot, oprot) ⇒ Object
Instance Method Details
#process_CancelOperation(seqid, iprot, oprot) ⇒ Object
361
362
363
364
365
366
|
# File 'lib/impala/protocol/t_c_l_i_service.rb', line 361
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
368
369
370
371
372
373
|
# File 'lib/impala/protocol/t_c_l_i_service.rb', line 368
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
284
285
286
287
288
289
|
# File 'lib/impala/protocol/t_c_l_i_service.rb', line 284
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
298
299
300
301
302
303
|
# File 'lib/impala/protocol/t_c_l_i_service.rb', line 298
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
382
383
384
385
386
387
|
# File 'lib/impala/protocol/t_c_l_i_service.rb', line 382
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
312
313
314
315
316
317
|
# File 'lib/impala/protocol/t_c_l_i_service.rb', line 312
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
340
341
342
343
344
345
|
# File 'lib/impala/protocol/t_c_l_i_service.rb', line 340
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
347
348
349
350
351
352
|
# File 'lib/impala/protocol/t_c_l_i_service.rb', line 347
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
291
292
293
294
295
296
|
# File 'lib/impala/protocol/t_c_l_i_service.rb', line 291
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_GetLog(seqid, iprot, oprot) ⇒ Object
389
390
391
392
393
394
|
# File 'lib/impala/protocol/t_c_l_i_service.rb', line 389
def process_GetLog(seqid, iprot, oprot)
args = read_args(iprot, GetLog_args)
result = GetLog_result.new()
result.success = @handler.GetLog(args.req)
write_result(result, oprot, 'GetLog', seqid)
end
|
#process_GetOperationStatus(seqid, iprot, oprot) ⇒ Object
354
355
356
357
358
359
|
# File 'lib/impala/protocol/t_c_l_i_service.rb', line 354
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
|
375
376
377
378
379
380
|
# File 'lib/impala/protocol/t_c_l_i_service.rb', line 375
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
319
320
321
322
323
324
|
# File 'lib/impala/protocol/t_c_l_i_service.rb', line 319
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
326
327
328
329
330
331
|
# File 'lib/impala/protocol/t_c_l_i_service.rb', line 326
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
333
334
335
336
337
338
|
# File 'lib/impala/protocol/t_c_l_i_service.rb', line 333
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
305
306
307
308
309
310
|
# File 'lib/impala/protocol/t_c_l_i_service.rb', line 305
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
277
278
279
280
281
282
|
# File 'lib/impala/protocol/t_c_l_i_service.rb', line 277
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
|