Contents

module SparkToolkit
  module YARN
    Client = Java::OrgApacheHadoopYarnClientApiImpl::YarnClientImpl
    class Client
      alias_method :initalise, :initialize
      def initialize(conf=nil)
        initalise
        @conf = conf
        init conf if conf
      end

      def get_applications
        getApplications.to_a
      end
      # get_application_report(app_id)

      def get_containers(app_id)
        getContainers(app_id).to_a
      end
      # get_container_report(container_id)

      def get_application_attempts(app_id)
        getApplicationAttempts(app_id).to_a
      end
      # get_attempt_report(app_id)

      def get_node_reports
        getNodeReports.to_a
      end

      # Available devs are:
      # - :all
      # - :stdout
      # - :stderr
      def get_application_logs(appid, dev=:all)
        @conf ||= SparkToolkit::Conf::Configuration.new
        @log_accssor ||= SparkToolkit::YARN::LogAccessor.new(@conf)
        @log_accssor.get_logs(appid, dev)
      end

      # kill_application(app_id)
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

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