Class: Hadoop::API::Jobtracker::ThriftJobInProgress

Inherits:

Object

• Object
• Hadoop::API::Jobtracker::ThriftJobInProgress

Includes:

Thrift::Struct, Thrift::Struct_Union

Defined in:

lib/thrift/jobtracker_types.rb

Overview

Status of all jobs, not just currently running ones

Constant Summary

PROFILE =

1

STATUS =

2

JOBID =

3

DESIREDMAPS =

4

DESIREDREDUCES =

5

FINISHEDMAPS =

6

FINISHEDREDUCES =

7

PRIORITY =

8

STARTTIME =

11

FINISHTIME =

12

LAUNCHTIME =

13

TASKS =

23

FIELDS =

{
  PROFILE => {:type => ::Thrift::Types::STRUCT, :name => 'profile', :class => Hadoop::API::Jobtracker::ThriftJobProfile},
  STATUS => {:type => ::Thrift::Types::STRUCT, :name => 'status', :class => Hadoop::API::Jobtracker::ThriftJobStatus},
  JOBID => {:type => ::Thrift::Types::STRUCT, :name => 'jobID', :class => Hadoop::API::Jobtracker::ThriftJobID},
  DESIREDMAPS => {:type => ::Thrift::Types::I32, :name => 'desiredMaps'},
  DESIREDREDUCES => {:type => ::Thrift::Types::I32, :name => 'desiredReduces'},
  FINISHEDMAPS => {:type => ::Thrift::Types::I32, :name => 'finishedMaps'},
  FINISHEDREDUCES => {:type => ::Thrift::Types::I32, :name => 'finishedReduces'},
  PRIORITY => {:type => ::Thrift::Types::I32, :name => 'priority', :enum_class => Hadoop::API::Jobtracker::ThriftJobPriority},
  STARTTIME => {:type => ::Thrift::Types::I64, :name => 'startTime'},
  FINISHTIME => {:type => ::Thrift::Types::I64, :name => 'finishTime'},
  LAUNCHTIME => {:type => ::Thrift::Types::I64, :name => 'launchTime'},
  TASKS => {:type => ::Thrift::Types::STRUCT, :name => 'tasks', :class => Hadoop::API::Jobtracker::ThriftTaskInProgressList}
}

Instance Method Summary

• #struct_fields ⇒ Object
• #validate ⇒ Object

Instance Method Details

#struct_fields ⇒ Object

# File 'lib/thrift/jobtracker_types.rb', line 557

def struct_fields; FIELDS; end

#validate ⇒ Object

# File 'lib/thrift/jobtracker_types.rb', line 559

def validate
  unless @priority.nil? || Hadoop::API::Jobtracker::ThriftJobPriority::VALID_VALUES.include?(@priority)
    raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field priority!')
  end
end