Class: Storm::ExecutorStats

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

Constant Summary collapse

EMITTED = 
1
TRANSFERRED = 
2
SPECIFIC = 
3
FIELDS = 
{
  EMITTED => {:type => ::Thrift::Types::MAP, :name => 'emitted', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::MAP, :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::I64}}},
  TRANSFERRED => {:type => ::Thrift::Types::MAP, :name => 'transferred', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::MAP, :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::I64}}},
  SPECIFIC => {:type => ::Thrift::Types::STRUCT, :name => 'specific', :class => ExecutorSpecificStats}
}

Instance Method Summary collapse

Instance Method Details

#struct_fields ⇒ Object 



626
 
# File 'lib/storm/thrift/storm_types.rb', line 626

def struct_fields; FIELDS; end

#validate ⇒ Object

Raises:

  • (::Thrift::ProtocolException) 


628
629
630
631
632
 
# File 'lib/storm/thrift/storm_types.rb', line 628

def validate
  raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field emitted is unset!') unless @emitted
  raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field transferred is unset!') unless @transferred
  raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field specific is unset!') unless @specific
end