class Impala::Protocol::TCLIService::Processor
Public Instance Methods
process_CancelDelegationToken(seqid, iprot, oprot)
click to toggle source
# File lib/impala/protocol/t_c_l_i_service.rb 440 def process_CancelDelegationToken(seqid, iprot, oprot) 441 args = read_args(iprot, CancelDelegationToken_args) 442 result = CancelDelegationToken_result.new() 443 result.success = @handler.CancelDelegationToken(args.req) 444 write_result(result, oprot, 'CancelDelegationToken', seqid) 445 end
process_CancelOperation(seqid, iprot, oprot)
click to toggle source
# File lib/impala/protocol/t_c_l_i_service.rb 405 def process_CancelOperation(seqid, iprot, oprot) 406 args = read_args(iprot, CancelOperation_args) 407 result = CancelOperation_result.new() 408 result.success = @handler.CancelOperation(args.req) 409 write_result(result, oprot, 'CancelOperation', seqid) 410 end
process_CloseOperation(seqid, iprot, oprot)
click to toggle source
# File lib/impala/protocol/t_c_l_i_service.rb 412 def process_CloseOperation(seqid, iprot, oprot) 413 args = read_args(iprot, CloseOperation_args) 414 result = CloseOperation_result.new() 415 result.success = @handler.CloseOperation(args.req) 416 write_result(result, oprot, 'CloseOperation', seqid) 417 end
process_CloseSession(seqid, iprot, oprot)
click to toggle source
# File lib/impala/protocol/t_c_l_i_service.rb 328 def process_CloseSession(seqid, iprot, oprot) 329 args = read_args(iprot, CloseSession_args) 330 result = CloseSession_result.new() 331 result.success = @handler.CloseSession(args.req) 332 write_result(result, oprot, 'CloseSession', seqid) 333 end
process_ExecuteStatement(seqid, iprot, oprot)
click to toggle source
# File lib/impala/protocol/t_c_l_i_service.rb 342 def process_ExecuteStatement(seqid, iprot, oprot) 343 args = read_args(iprot, ExecuteStatement_args) 344 result = ExecuteStatement_result.new() 345 result.success = @handler.ExecuteStatement(args.req) 346 write_result(result, oprot, 'ExecuteStatement', seqid) 347 end
process_FetchResults(seqid, iprot, oprot)
click to toggle source
# File lib/impala/protocol/t_c_l_i_service.rb 426 def process_FetchResults(seqid, iprot, oprot) 427 args = read_args(iprot, FetchResults_args) 428 result = FetchResults_result.new() 429 result.success = @handler.FetchResults(args.req) 430 write_result(result, oprot, 'FetchResults', seqid) 431 end
process_GetCatalogs(seqid, iprot, oprot)
click to toggle source
# File lib/impala/protocol/t_c_l_i_service.rb 356 def process_GetCatalogs(seqid, iprot, oprot) 357 args = read_args(iprot, GetCatalogs_args) 358 result = GetCatalogs_result.new() 359 result.success = @handler.GetCatalogs(args.req) 360 write_result(result, oprot, 'GetCatalogs', seqid) 361 end
process_GetColumns(seqid, iprot, oprot)
click to toggle source
# File lib/impala/protocol/t_c_l_i_service.rb 384 def process_GetColumns(seqid, iprot, oprot) 385 args = read_args(iprot, GetColumns_args) 386 result = GetColumns_result.new() 387 result.success = @handler.GetColumns(args.req) 388 write_result(result, oprot, 'GetColumns', seqid) 389 end
process_GetDelegationToken(seqid, iprot, oprot)
click to toggle source
# File lib/impala/protocol/t_c_l_i_service.rb 433 def process_GetDelegationToken(seqid, iprot, oprot) 434 args = read_args(iprot, GetDelegationToken_args) 435 result = GetDelegationToken_result.new() 436 result.success = @handler.GetDelegationToken(args.req) 437 write_result(result, oprot, 'GetDelegationToken', seqid) 438 end
process_GetFunctions(seqid, iprot, oprot)
click to toggle source
# File lib/impala/protocol/t_c_l_i_service.rb 391 def process_GetFunctions(seqid, iprot, oprot) 392 args = read_args(iprot, GetFunctions_args) 393 result = GetFunctions_result.new() 394 result.success = @handler.GetFunctions(args.req) 395 write_result(result, oprot, 'GetFunctions', seqid) 396 end
process_GetInfo(seqid, iprot, oprot)
click to toggle source
# File lib/impala/protocol/t_c_l_i_service.rb 335 def process_GetInfo(seqid, iprot, oprot) 336 args = read_args(iprot, GetInfo_args) 337 result = GetInfo_result.new() 338 result.success = @handler.GetInfo(args.req) 339 write_result(result, oprot, 'GetInfo', seqid) 340 end
process_GetLog(seqid, iprot, oprot)
click to toggle source
# File lib/impala/protocol/t_c_l_i_service.rb 454 def process_GetLog(seqid, iprot, oprot) 455 args = read_args(iprot, GetLog_args) 456 result = GetLog_result.new() 457 result.success = @handler.GetLog(args.req) 458 write_result(result, oprot, 'GetLog', seqid) 459 end
process_GetOperationStatus(seqid, iprot, oprot)
click to toggle source
# File lib/impala/protocol/t_c_l_i_service.rb 398 def process_GetOperationStatus(seqid, iprot, oprot) 399 args = read_args(iprot, GetOperationStatus_args) 400 result = GetOperationStatus_result.new() 401 result.success = @handler.GetOperationStatus(args.req) 402 write_result(result, oprot, 'GetOperationStatus', seqid) 403 end
process_GetResultSetMetadata(seqid, iprot, oprot)
click to toggle source
# File lib/impala/protocol/t_c_l_i_service.rb 419 def process_GetResultSetMetadata(seqid, iprot, oprot) 420 args = read_args(iprot, GetResultSetMetadata_args) 421 result = GetResultSetMetadata_result.new() 422 result.success = @handler.GetResultSetMetadata(args.req) 423 write_result(result, oprot, 'GetResultSetMetadata', seqid) 424 end
process_GetSchemas(seqid, iprot, oprot)
click to toggle source
# File lib/impala/protocol/t_c_l_i_service.rb 363 def process_GetSchemas(seqid, iprot, oprot) 364 args = read_args(iprot, GetSchemas_args) 365 result = GetSchemas_result.new() 366 result.success = @handler.GetSchemas(args.req) 367 write_result(result, oprot, 'GetSchemas', seqid) 368 end
process_GetTableTypes(seqid, iprot, oprot)
click to toggle source
# File lib/impala/protocol/t_c_l_i_service.rb 377 def process_GetTableTypes(seqid, iprot, oprot) 378 args = read_args(iprot, GetTableTypes_args) 379 result = GetTableTypes_result.new() 380 result.success = @handler.GetTableTypes(args.req) 381 write_result(result, oprot, 'GetTableTypes', seqid) 382 end
process_GetTables(seqid, iprot, oprot)
click to toggle source
# File lib/impala/protocol/t_c_l_i_service.rb 370 def process_GetTables(seqid, iprot, oprot) 371 args = read_args(iprot, GetTables_args) 372 result = GetTables_result.new() 373 result.success = @handler.GetTables(args.req) 374 write_result(result, oprot, 'GetTables', seqid) 375 end
process_GetTypeInfo(seqid, iprot, oprot)
click to toggle source
# File lib/impala/protocol/t_c_l_i_service.rb 349 def process_GetTypeInfo(seqid, iprot, oprot) 350 args = read_args(iprot, GetTypeInfo_args) 351 result = GetTypeInfo_result.new() 352 result.success = @handler.GetTypeInfo(args.req) 353 write_result(result, oprot, 'GetTypeInfo', seqid) 354 end
process_OpenSession(seqid, iprot, oprot)
click to toggle source
# File lib/impala/protocol/t_c_l_i_service.rb 321 def process_OpenSession(seqid, iprot, oprot) 322 args = read_args(iprot, OpenSession_args) 323 result = OpenSession_result.new() 324 result.success = @handler.OpenSession(args.req) 325 write_result(result, oprot, 'OpenSession', seqid) 326 end
process_RenewDelegationToken(seqid, iprot, oprot)
click to toggle source
# File lib/impala/protocol/t_c_l_i_service.rb 447 def process_RenewDelegationToken(seqid, iprot, oprot) 448 args = read_args(iprot, RenewDelegationToken_args) 449 result = RenewDelegationToken_result.new() 450 result.success = @handler.RenewDelegationToken(args.req) 451 write_result(result, oprot, 'RenewDelegationToken', seqid) 452 end