Class: Hive2::Thrift::TCLIService::Processor
- Inherits:
-
Object
- Object
- Hive2::Thrift::TCLIService::Processor
- Includes:
- Thrift::Processor
- Defined in:
- lib/thrift/t_c_l_i_service.rb
Instance Method Summary collapse
- #process_CancelDelegationToken(seqid, iprot, oprot) ⇒ Object
- #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_GetDelegationToken(seqid, iprot, oprot) ⇒ Object
- #process_GetFunctions(seqid, iprot, oprot) ⇒ Object
- #process_GetInfo(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
- #process_RenewDelegationToken(seqid, iprot, oprot) ⇒ Object
Instance Method Details
#process_CancelDelegationToken(seqid, iprot, oprot) ⇒ Object
425 426 427 428 429 430 |
# File 'lib/thrift/t_c_l_i_service.rb', line 425 def process_CancelDelegationToken(seqid, iprot, oprot) args = read_args(iprot, CancelDelegationToken_args) result = CancelDelegationToken_result.new() result.success = @handler.CancelDelegationToken(args.req) write_result(result, oprot, 'CancelDelegationToken', seqid) end |
#process_CancelOperation(seqid, iprot, oprot) ⇒ Object
390 391 392 393 394 395 |
# File 'lib/thrift/t_c_l_i_service.rb', line 390 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
397 398 399 400 401 402 |
# File 'lib/thrift/t_c_l_i_service.rb', line 397 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
313 314 315 316 317 318 |
# File 'lib/thrift/t_c_l_i_service.rb', line 313 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
327 328 329 330 331 332 |
# File 'lib/thrift/t_c_l_i_service.rb', line 327 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
411 412 413 414 415 416 |
# File 'lib/thrift/t_c_l_i_service.rb', line 411 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
341 342 343 344 345 346 |
# File 'lib/thrift/t_c_l_i_service.rb', line 341 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
369 370 371 372 373 374 |
# File 'lib/thrift/t_c_l_i_service.rb', line 369 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_GetDelegationToken(seqid, iprot, oprot) ⇒ Object
418 419 420 421 422 423 |
# File 'lib/thrift/t_c_l_i_service.rb', line 418 def process_GetDelegationToken(seqid, iprot, oprot) args = read_args(iprot, GetDelegationToken_args) result = GetDelegationToken_result.new() result.success = @handler.GetDelegationToken(args.req) write_result(result, oprot, 'GetDelegationToken', seqid) end |
#process_GetFunctions(seqid, iprot, oprot) ⇒ Object
376 377 378 379 380 381 |
# File 'lib/thrift/t_c_l_i_service.rb', line 376 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
320 321 322 323 324 325 |
# File 'lib/thrift/t_c_l_i_service.rb', line 320 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
383 384 385 386 387 388 |
# File 'lib/thrift/t_c_l_i_service.rb', line 383 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
404 405 406 407 408 409 |
# File 'lib/thrift/t_c_l_i_service.rb', line 404 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
348 349 350 351 352 353 |
# File 'lib/thrift/t_c_l_i_service.rb', line 348 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
355 356 357 358 359 360 |
# File 'lib/thrift/t_c_l_i_service.rb', line 355 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
362 363 364 365 366 367 |
# File 'lib/thrift/t_c_l_i_service.rb', line 362 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
334 335 336 337 338 339 |
# File 'lib/thrift/t_c_l_i_service.rb', line 334 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
306 307 308 309 310 311 |
# File 'lib/thrift/t_c_l_i_service.rb', line 306 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 |
#process_RenewDelegationToken(seqid, iprot, oprot) ⇒ Object
432 433 434 435 436 437 |
# File 'lib/thrift/t_c_l_i_service.rb', line 432 def process_RenewDelegationToken(seqid, iprot, oprot) args = read_args(iprot, RenewDelegationToken_args) result = RenewDelegationToken_result.new() result.success = @handler.RenewDelegationToken(args.req) write_result(result, oprot, 'RenewDelegationToken', seqid) end |