service

Documentation

Index

• Constants
• type FlinkExecutor
  • func NewFlinkExecutor(ctx context.Context, db *gorm.DB, engineClient utils.ClusterManagerClient, ...) *FlinkExecutor
  • func (exec *FlinkExecutor) CancelJob(ctx context.Context, flinkId string, spaceId string, clusterId string) error
  • func (exec *FlinkExecutor) GetJobInfo(ctx context.Context, flinkId string, spaceId string, clusterId string) (*flink.Job, error)
  • func (exec *FlinkExecutor) InitJob(ctx context.Context, req *pbrequest.InitFlinkJob) (string, string, error)
  • func (exec *FlinkExecutor) Release(ctx context.Context, instanceId string, noteId string) error
  • func (exec *FlinkExecutor) SubmitJob(ctx context.Context, instanceId string, noteId string, paragraphId string, ...) (*zeppelin.ParagraphResult, error)
  • func (exec *FlinkExecutor) ValidateCode(ctx context.Context, jobCode *pbrequest.ValidateFlinkJob) (bool, string, error)
• type JobManagerService
  • func NewJobManagerService(ctx context.Context, db *gorm.DB, uClient utils.UdfClient, ...) *JobManagerService
  • func (jm *JobManagerService) CancelFlinkJob(ctx context.Context, flinkId string, spaceId string, clusterId string) error
  • func (jm *JobManagerService) FreeFlinkJob(ctx context.Context, instanceId string, noteId string) error
  • func (jm *JobManagerService) GetFlinkJob(ctx context.Context, flinkId string, spaceId string, clusterId string) (*pbresponse.GetFlinkJob, error)
  • func (jm *JobManagerService) InitFlinkJob(ctx context.Context, req *pbrequest.InitFlinkJob) (*pbresponse.InitFlinkJob, error)
  • func (jm *JobManagerService) SubmitFlinkJob(ctx context.Context, req *pbrequest.SubmitFlinkJob) (*pbresponse.SubmitFlinkJob, error)
  • func (jm *JobManagerService) ValidateFlinkCode(ctx context.Context, jobCode *pbrequest.ValidateFlinkJob) (*pbresponse.ValidateFlinkJob, error)
• type Udf

Constants

const (
	FLINK      = "flink"
	SHELL      = "sh"
	Quote      = "$qc$"
	UDFQuote   = Quote + "_udf_name_" + Quote
	JobManager = "job_manager"
)

Types

type FlinkExecutor

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

func NewFlinkExecutor

func NewFlinkExecutor(ctx context.Context, db *gorm.DB, engineClient utils.ClusterManagerClient, udfClient utils.UdfClient, resourceClient utils.ResourceClient,
	flinkClient *flink.Client, zeppelinClient *zeppelin.Client) *FlinkExecutor

func (*FlinkExecutor) CancelJob

func (exec *FlinkExecutor) CancelJob(ctx context.Context, flinkId string, spaceId string, clusterId string) error

func (*FlinkExecutor) GetJobInfo

func (exec *FlinkExecutor) GetJobInfo(ctx context.Context, flinkId string, spaceId string, clusterId string) (*flink.Job, error)

func (*FlinkExecutor) InitJob

func (exec *FlinkExecutor) InitJob(ctx context.Context, req *pbrequest.InitFlinkJob) (string, string, error)

func (*FlinkExecutor) Release

func (exec *FlinkExecutor) Release(ctx context.Context, instanceId string, noteId string) error

func (*FlinkExecutor) SubmitJob

func (exec *FlinkExecutor) SubmitJob(ctx context.Context, instanceId string, noteId string, paragraphId string, jobType pbmodel.StreamJob_Type) (*zeppelin.ParagraphResult, error)

func (*FlinkExecutor) ValidateCode

func (exec *FlinkExecutor) ValidateCode(ctx context.Context, jobCode *pbrequest.ValidateFlinkJob) (bool, string, error)

type JobManagerService

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

func NewJobManagerService

func NewJobManagerService(ctx context.Context, db *gorm.DB, uClient utils.UdfClient, eClient utils.ClusterManagerClient,
	rClient utils.ResourceClient, fClient *flink.Client,
	zClient *zeppelin.Client, etcdClient *getcd.Client) *JobManagerService

func (*JobManagerService) CancelFlinkJob

func (jm *JobManagerService) CancelFlinkJob(ctx context.Context, flinkId string, spaceId string, clusterId string) error

func (*JobManagerService) FreeFlinkJob

func (jm *JobManagerService) FreeFlinkJob(ctx context.Context, instanceId string, noteId string) error

func (*JobManagerService) GetFlinkJob

func (jm *JobManagerService) GetFlinkJob(ctx context.Context, flinkId string, spaceId string, clusterId string) (*pbresponse.GetFlinkJob, error)

func (*JobManagerService) InitFlinkJob

func (jm *JobManagerService) InitFlinkJob(ctx context.Context, req *pbrequest.InitFlinkJob) (*pbresponse.InitFlinkJob, error)

func (*JobManagerService) SubmitFlinkJob

func (jm *JobManagerService) SubmitFlinkJob(ctx context.Context, req *pbrequest.SubmitFlinkJob) (*pbresponse.SubmitFlinkJob, error)

func (*JobManagerService) ValidateFlinkCode

func (jm *JobManagerService) ValidateFlinkCode(ctx context.Context, jobCode *pbrequest.ValidateFlinkJob) (*pbresponse.ValidateFlinkJob, error)

type Udf

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