sparkoperator

Documentation

Index

• type Manager
  • func NewManager(amProtocol interfaces.ApplicationManagementProtocol, ...) *Manager
  • func (os *Manager) Name() string
  • func (os *Manager) ServiceInit() error
  • func (os *Manager) Start() error
  • func (os *Manager) Stop()

Types

type Manager

type Manager struct {
	// contains filtered or unexported fields
}

Manager implements interfaces#Recoverable, interfaces#AppManager

func NewManager

func NewManager(amProtocol interfaces.ApplicationManagementProtocol, apiProvider client.APIProvider) *Manager

func (*Manager) Name

func (os *Manager) Name() string

func (*Manager) ServiceInit

func (os *Manager) ServiceInit() error

ServiceInit implements AppManagementService interface

It watches for changes to the SparkApplications CRD objects Two event handlers are defined to react accordingly when an SparkApplication is updated or deleted. Note that there's no need for an event handler for AddFunc because when a SparkApplication object is first created, the application ID has not been generated yet. It will only be available after the driver pod starts and then the Spark K8s backend will assign a string that starts with "spark-" as the app ID

func (*Manager) Start

func (os *Manager) Start() error

func (*Manager) Stop

func (os *Manager) Stop()