class Impala::Protocol::Hive::TCLIService::Processor
Public Instance Methods
process_CancelOperation(seqid, iprot, oprot)
click to toggle source
# 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)
click to toggle source
# 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)
click to toggle source
# 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)
click to toggle source
# 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)
click to toggle source
# 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)
click to toggle source
# 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)
click to toggle source
# 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)
click to toggle source
# 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)
click to toggle source
# 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)
click to toggle source
# 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)
click to toggle source
# 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
process_GetResultSetMetadata(seqid, iprot, oprot)
click to toggle source
# 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)
click to toggle source
# 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_GetTableTypes(seqid, iprot, oprot)
click to toggle source
# 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_GetTables(seqid, iprot, oprot)
click to toggle source
# 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_GetTypeInfo(seqid, iprot, oprot)
click to toggle source
# 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)
click to toggle source
# 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