Class: ThriftHive::Processor
Instance Method Summary
collapse
-
#process_execute(seqid, iprot, oprot) ⇒ Object
-
#process_fetchAll(seqid, iprot, oprot) ⇒ Object
-
#process_fetchN(seqid, iprot, oprot) ⇒ Object
-
#process_fetchOne(seqid, iprot, oprot) ⇒ Object
-
#process_getClusterStatus(seqid, iprot, oprot) ⇒ Object
-
#process_getQueryPlan(seqid, iprot, oprot) ⇒ Object
-
#process_getSchema(seqid, iprot, oprot) ⇒ Object
-
#process_getThriftSchema(seqid, iprot, oprot) ⇒ Object
#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
#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
|