Class: Hadoop::API::Jobtracker::ThriftTaskInProgress

Inherits:

Object

• Object
• Hadoop::API::Jobtracker::ThriftTaskInProgress

Includes:

Thrift::Struct, Thrift::Struct_Union

Defined in:

lib/thrift/jobtracker_types.rb

Overview

A ThriftTaskInProgress contains a list of task attempts (speculatively executed instances of the same task). These are indexed by TaskAttemptID. For simplicity, we convert maps keyed on TaskAttemptIDs to maps keyed on their string representation.

Assumption: there won’t be so many task attempts that retrieving a single task will be too expensive.

Constant Summary

EXECSTARTTIME =

2

EXECFINISHTIME =

3

PROGRESS =

4

STARTTIME =

5

FAILED =

6

COMPLETE =

7

TASKID =

8

TASKS =

9

TASKSTATUSES =

10

TASKDIAGNOSTICDATA =

11

COUNTERS =

12

MOSTRECENTSTATE =

13

RUNNINGATTEMPTS =

14

SUCCESSFULATTEMPT =

15

FIELDS =

{
  EXECSTARTTIME => {:type => ::Thrift::Types::I64, :name => 'execStartTime'},
  EXECFINISHTIME => {:type => ::Thrift::Types::I64, :name => 'execFinishTime'},
  PROGRESS => {:type => ::Thrift::Types::DOUBLE, :name => 'progress'},
  STARTTIME => {:type => ::Thrift::Types::I64, :name => 'startTime'},
  FAILED => {:type => ::Thrift::Types::BOOL, :name => 'failed'},
  COMPLETE => {:type => ::Thrift::Types::BOOL, :name => 'complete'},
  TASKID => {:type => ::Thrift::Types::STRUCT, :name => 'taskID', :class => Hadoop::API::Jobtracker::ThriftTaskID},
  TASKS => {:type => ::Thrift::Types::LIST, :name => 'tasks', :element => {:type => ::Thrift::Types::STRUCT, :class => Hadoop::API::Jobtracker::ThriftTaskAttemptID}},
  # TaskAttemptID (string) to ThriftTaskStatus map
  TASKSTATUSES => {:type => ::Thrift::Types::MAP, :name => 'taskStatuses', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::STRUCT, :class => Hadoop::API::Jobtracker::ThriftTaskStatus}},
  TASKDIAGNOSTICDATA => {:type => ::Thrift::Types::MAP, :name => 'taskDiagnosticData', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::LIST, :element => {:type => ::Thrift::Types::STRING}}},
  COUNTERS => {:type => ::Thrift::Types::STRUCT, :name => 'counters', :class => Hadoop::API::Jobtracker::ThriftGroupList},
  MOSTRECENTSTATE => {:type => ::Thrift::Types::STRING, :name => 'mostRecentState'},
  RUNNINGATTEMPTS => {:type => ::Thrift::Types::LIST, :name => 'runningAttempts', :element => {:type => ::Thrift::Types::STRING}},
  SUCCESSFULATTEMPT => {:type => ::Thrift::Types::STRING, :name => 'successfulAttempt'}
}

Instance Method Summary

• #struct_fields ⇒ Object
• #validate ⇒ Object

Instance Method Details

#struct_fields ⇒ Object

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

def struct_fields; FIELDS; end

#validate ⇒ Object

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

def validate
end