Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( JobGVK = k8s.SparkAppGVK KubeSparkFwVersion = client.KubeFrameworkVersion(JobGVK) )
Functions ¶
func New ¶
func New(kubeClient framework.RuntimeClientInterface) framework.JobInterface
Types ¶
type KubeSparkJob ¶
type KubeSparkJob struct {
kuberuntime.KubeBaseJob
}
KubeSparkJob is a struct that contains client to operate spark application on cluster
func (*KubeSparkJob) AddEventListener ¶
func (sj *KubeSparkJob) AddEventListener(ctx context.Context, listenerType string, jobQueue workqueue.RateLimitingInterface, listener interface{}) error
func (*KubeSparkJob) JobStatus ¶
func (sj *KubeSparkJob) JobStatus(obj interface{}) (api.StatusInfo, error)
JobStatus get the statusInfo of spark application, including origin status, pf status and message
Source Files
Click to show internal directories.
Click to hide internal directories.