Class: ThriftHive::Processor

Inherits:
ThriftHiveMetastore::Processor show all
Includes:
Thrift::Processor
Defined in:
lib/thrift/thrift_hive.rb

Instance Method Summary collapse

Methods inherited from ThriftHiveMetastore::Processor

#process_add_index, #process_add_partition, #process_alter_partition, #process_alter_table, #process_append_partition, #process_append_partition_by_name, #process_create_database, #process_create_table, #process_create_type, #process_drop_database, #process_drop_index_by_name, #process_drop_partition, #process_drop_partition_by_name, #process_drop_table, #process_drop_type, #process_get_all_databases, #process_get_all_tables, #process_get_config_value, #process_get_database, #process_get_databases, #process_get_fields, #process_get_index_by_name, #process_get_index_names, #process_get_indexes, #process_get_partition, #process_get_partition_by_name, #process_get_partition_names, #process_get_partition_names_ps, #process_get_partitions, #process_get_partitions_by_filter, #process_get_partitions_ps, #process_get_schema, #process_get_table, #process_get_tables, #process_get_type, #process_get_type_all, #process_partition_name_to_spec, #process_partition_name_to_vals

Methods inherited from FacebookService::Processor

#process_aliveSince, #process_getCounter, #process_getCounters, #process_getCpuProfile, #process_getName, #process_getOption, #process_getOptions, #process_getStatus, #process_getStatusDetails, #process_getVersion, #process_reinitialize, #process_setOption, #process_shutdown

Instance Method Details

#process_execute(seqid, iprot, oprot) ⇒ Object 



147
148
149
150
151
152
153
154
155
156
 
# File 'lib/thrift/thrift_hive.rb', line 147

def process_execute(seqid, iprot, oprot)
  args = read_args(iprot, Execute_args)
  result = Execute_result.new()
  begin
    @handler.execute(args.query)
  rescue HiveServerException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'execute', seqid)
end

#process_fetchAll(seqid, iprot, oprot) ⇒ Object 



180
181
182
183
184
185
186
187
188
189
 
# File 'lib/thrift/thrift_hive.rb', line 180

def process_fetchAll(seqid, iprot, oprot)
  args = read_args(iprot, FetchAll_args)
  result = FetchAll_result.new()
  begin
    result.success = @handler.fetchAll()
  rescue HiveServerException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'fetchAll', seqid)
end

#process_fetchN(seqid, iprot, oprot) ⇒ Object 



169
170
171
172
173
174
175
176
177
178
 
# File 'lib/thrift/thrift_hive.rb', line 169

def process_fetchN(seqid, iprot, oprot)
  args = read_args(iprot, FetchN_args)
  result = FetchN_result.new()
  begin
    result.success = @handler.fetchN(args.numRows)
  rescue HiveServerException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'fetchN', seqid)
end

#process_fetchOne(seqid, iprot, oprot) ⇒ Object 



158
159
160
161
162
163
164
165
166
167
 
# File 'lib/thrift/thrift_hive.rb', line 158

def process_fetchOne(seqid, iprot, oprot)
  args = read_args(iprot, FetchOne_args)
  result = FetchOne_result.new()
  begin
    result.success = @handler.fetchOne()
  rescue HiveServerException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'fetchOne', seqid)
end

#process_getClusterStatus(seqid, iprot, oprot) ⇒ Object 



213
214
215
216
217
218
219
220
221
222
 
# File 'lib/thrift/thrift_hive.rb', line 213

def process_getClusterStatus(seqid, iprot, oprot)
  args = read_args(iprot, GetClusterStatus_args)
  result = GetClusterStatus_result.new()
  begin
    result.success = @handler.getClusterStatus()
  rescue HiveServerException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'getClusterStatus', seqid)
end

#process_getQueryPlan(seqid, iprot, oprot) ⇒ Object 



224
225
226
227
228
229
230
231
232
233
 
# File 'lib/thrift/thrift_hive.rb', line 224

def process_getQueryPlan(seqid, iprot, oprot)
  args = read_args(iprot, GetQueryPlan_args)
  result = GetQueryPlan_result.new()
  begin
    result.success = @handler.getQueryPlan()
  rescue HiveServerException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'getQueryPlan', seqid)
end

#process_getSchema(seqid, iprot, oprot) ⇒ Object 



191
192
193
194
195
196
197
198
199
200
 
# File 'lib/thrift/thrift_hive.rb', line 191

def process_getSchema(seqid, iprot, oprot)
  args = read_args(iprot, GetSchema_args)
  result = GetSchema_result.new()
  begin
    result.success = @handler.getSchema()
  rescue HiveServerException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'getSchema', seqid)
end

#process_getThriftSchema(seqid, iprot, oprot) ⇒ Object 



202
203
204
205
206
207
208
209
210
211
 
# File 'lib/thrift/thrift_hive.rb', line 202

def process_getThriftSchema(seqid, iprot, oprot)
  args = read_args(iprot, GetThriftSchema_args)
  result = GetThriftSchema_result.new()
  begin
    result.success = @handler.getThriftSchema()
  rescue HiveServerException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'getThriftSchema', seqid)
end