Sha256: 1426407ff3b3a8b7235886e5aa92424f553dfa48740f575f58560ea61735d5f8

Contents?: true

Size: 386 Bytes

Versions: 3

Compression:

Stored size: 386 Bytes

Contents

module SparkToolkit
  module YARN
    ID = Java::OrgApacheHadoopYarnApiRecordsImplPb::ApplicationIdPBImpl
    class ID
      java_import org.apache.hadoop.yarn.api.records.ApplicationId
      def self.new_instance(ts, id)
        ApplicationId.new_instance(ts.to_i, id.to_i)
      end

      def get_timestamp
        getClusterTimestamp
      end

      # def get_id
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version Path
spark_toolkit-0.1.2-java lib/spark_toolkit/hadoop/yarn/id.rb
spark_toolkit-0.1.1-java lib/spark_toolkit/hadoop/yarn/id.rb
spark_toolkit-0.1.0-java lib/spark_toolkit/hadoop/yarn/id.rb