Class: Hadoop::API::HadoopServiceBase::Processor

Inherits:
Object
  • Object
show all
Includes:
Thrift::Processor
Defined in:
lib/thrift/hadoop_service_base.rb

Direct Known Subclasses

Jobtracker::Jobtracker::Processor

Instance Method Summary collapse

Instance Method Details

#process_getAllMetrics(seqid, iprot, oprot) ⇒ Object 



119
120
121
122
123
124
125
126
127
128
 
# File 'lib/thrift/hadoop_service_base.rb', line 119

def process_getAllMetrics(seqid, iprot, oprot)
  args = read_args(iprot, GetAllMetrics_args)
  result = GetAllMetrics_result.new()
  begin
    result.success = @handler.getAllMetrics(args.ctx)
  rescue Hadoop::API::IOException => err
    result.err = err
  end
  write_result(result, oprot, 'getAllMetrics', seqid)
end

#process_getMetricsContext(seqid, iprot, oprot) ⇒ Object 



130
131
132
133
134
135
136
137
138
139
 
# File 'lib/thrift/hadoop_service_base.rb', line 130

def process_getMetricsContext(seqid, iprot, oprot)
  args = read_args(iprot, GetMetricsContext_args)
  result = GetMetricsContext_result.new()
  begin
    result.success = @handler.getMetricsContext(args.ctx, args.contextName)
  rescue Hadoop::API::IOException => err
    result.err = err
  end
  write_result(result, oprot, 'getMetricsContext', seqid)
end

#process_getRuntimeInfo(seqid, iprot, oprot) ⇒ Object 



105
106
107
108
109
110
 
# File 'lib/thrift/hadoop_service_base.rb', line 105

def process_getRuntimeInfo(seqid, iprot, oprot)
  args = read_args(iprot, GetRuntimeInfo_args)
  result = GetRuntimeInfo_result.new()
  result.success = @handler.getRuntimeInfo(args.ctx)
  write_result(result, oprot, 'getRuntimeInfo', seqid)
end

#process_getThreadDump(seqid, iprot, oprot) ⇒ Object 



112
113
114
115
116
117
 
# File 'lib/thrift/hadoop_service_base.rb', line 112

def process_getThreadDump(seqid, iprot, oprot)
  args = read_args(iprot, GetThreadDump_args)
  result = GetThreadDump_result.new()
  result.success = @handler.getThreadDump(args.ctx)
  write_result(result, oprot, 'getThreadDump', seqid)
end

#process_getVersionInfo(seqid, iprot, oprot) ⇒ Object 



98
99
100
101
102
103
 
# File 'lib/thrift/hadoop_service_base.rb', line 98

def process_getVersionInfo(seqid, iprot, oprot)
  args = read_args(iprot, GetVersionInfo_args)
  result = GetVersionInfo_result.new()
  result.success = @handler.getVersionInfo(args.ctx)
  write_result(result, oprot, 'getVersionInfo', seqid)
end