Class: Hadoop::API::Jobtracker::ThriftJobStatus

Inherits:
Object
  • Object
show all
Includes:
Thrift::Struct, Thrift::Struct_Union
Defined in:
lib/thrift/jobtracker_types.rb

Overview

Status of a job

Constant Summary collapse

JOBID =
1
MAPPROGRESS =
2
REDUCEPROGRESS =
3
CLEANUPPROGRESS =
4
SETUPPROGRESS =
5
RUNSTATE =
6
STARTTIME =
7
USER =
8
PRIORITY =
9
SCHEDULINGINFO =
10
FIELDS =
{
  JOBID => {:type => ::Thrift::Types::STRUCT, :name => 'jobID', :class => Hadoop::API::Jobtracker::ThriftJobID},
  MAPPROGRESS => {:type => ::Thrift::Types::DOUBLE, :name => 'mapProgress'},
  REDUCEPROGRESS => {:type => ::Thrift::Types::DOUBLE, :name => 'reduceProgress'},
  CLEANUPPROGRESS => {:type => ::Thrift::Types::DOUBLE, :name => 'cleanupProgress'},
  SETUPPROGRESS => {:type => ::Thrift::Types::DOUBLE, :name => 'setupProgress'},
  RUNSTATE => {:type => ::Thrift::Types::I32, :name => 'runState', :enum_class => Hadoop::API::Jobtracker::ThriftJobState},
  STARTTIME => {:type => ::Thrift::Types::I64, :name => 'startTime'},
  USER => {:type => ::Thrift::Types::STRING, :name => 'user'},
  PRIORITY => {:type => ::Thrift::Types::I32, :name => 'priority', :enum_class => Hadoop::API::Jobtracker::ThriftJobPriority},
  SCHEDULINGINFO => {:type => ::Thrift::Types::STRING, :name => 'schedulingInfo'}
}

Instance Method Summary collapse

Instance Method Details

#struct_fieldsObject



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

def struct_fields; FIELDS; end

#validateObject



466
467
468
469
470
471
472
473
# File 'lib/thrift/jobtracker_types.rb', line 466

def validate
  unless @runState.nil? || Hadoop::API::Jobtracker::ThriftJobState::VALID_VALUES.include?(@runState)
    raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field runState!')
  end
  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