executor

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

type JobdeveloperExecutor struct {
	FlinkHome        string
	HadoopConf       string
	FlinkExecuteJars string
	// contains filtered or unexported fields
}

type OperatorRelation struct {
	OperatorType    flinkpb.FlinkOperator_Type   `json:"nodetype"`
	AllowUpstream   []flinkpb.FlinkOperator_Type `json:"allowupstream"`
	AllowDownStream []flinkpb.FlinkOperator_Type `json:"allowdownstream"`
}

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

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

type SqlStack struct {
	TableId   []string
	UDFID     []string
	NodeCount int
	Standard  bool
	Sql       string
	Table     string
	Distinct  string
	Column    []flinkpb.ColumnAs
	TableAs   string
	Other     string
}

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