spark

Documentation

Index

• Variables
• func Delete(appName string) (bool, error)
• func IsDone(sparkApp *sparkop.SparkApplication) bool
• func List(opts *metav1.ListOptions) ([]sparkop.SparkApplication, error)
• func ListByLabel(labelKey string, labelValue string) ([]sparkop.SparkApplication, error)
• func ListByLabels(labels map[string]string) ([]sparkop.SparkApplication, error)
• func SparkSpec(workloadID string, ctx *context.Context, workloadType string, ...) *sparkop.SparkApplication

Variables

var FailureCondition = "status.applicationState.state in (" + strings.Join(failureStates, ",") + ")"

var SuccessCondition = "status.applicationState.state in (" + strings.Join(successStates, ",") + ")"

Functions

func Delete

func Delete(appName string) (bool, error)

func IsDone

func IsDone(sparkApp *sparkop.SparkApplication) bool

func List

func List(opts *metav1.ListOptions) ([]sparkop.SparkApplication, error)

func ListByLabel

func ListByLabel(labelKey string, labelValue string) ([]sparkop.SparkApplication, error)

func ListByLabels

func ListByLabels(labels map[string]string) ([]sparkop.SparkApplication, error)

func SparkSpec

func SparkSpec(workloadID string, ctx *context.Context, workloadType string, sparkCompute *userconfig.SparkCompute, args ...string) *sparkop.SparkApplication