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_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_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
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 |