Versions in this module Expand all Collapse all v47 v47.1.0 Oct 21, 2020 v47.0.0 Oct 13, 2020 Changes in this version + func UserAgent() string + func Version() string + type AppState struct + State ApplicationState + type ApplicationState string + const ACCEPTED + const FAILED + const FINISHED + const FINISHING + const KILLED + const NEW + const NEWSAVING + const RUNNING + const SUBMITTED + func PossibleApplicationStateValues() []ApplicationState + type BaseClient struct + Endpoint string + UserName string + func New(endpoint string, userName string) BaseClient + func NewWithoutDefaults(endpoint string, userName string) BaseClient + type JobClient struct + func NewJobClient(endpoint string, userName string) JobClient + func (client JobClient) DeleteSparkBatch(ctx context.Context, batchID int32, requestedBy string) (result SparkJobDeletedResult, err error) + func (client JobClient) DeleteSparkBatchPreparer(ctx context.Context, batchID int32, requestedBy string) (*http.Request, error) + func (client JobClient) DeleteSparkBatchResponder(resp *http.Response) (result SparkJobDeletedResult, err error) + func (client JobClient) DeleteSparkBatchSender(req *http.Request) (*http.Response, error) + func (client JobClient) DeleteSparkSessionJob(ctx context.Context, sessionID int32, requestedBy string) (result SparkJobDeletedResult, err error) + func (client JobClient) DeleteSparkSessionJobPreparer(ctx context.Context, sessionID int32, requestedBy string) (*http.Request, error) + func (client JobClient) DeleteSparkSessionJobResponder(resp *http.Response) (result SparkJobDeletedResult, err error) + func (client JobClient) DeleteSparkSessionJobSender(req *http.Request) (*http.Response, error) + func (client JobClient) DeleteSparkStatementJob(ctx context.Context, sessionID int32, statementID int32, requestedBy string) (result SparkStatementCancellationResult, err error) + func (client JobClient) DeleteSparkStatementJobPreparer(ctx context.Context, sessionID int32, statementID int32, requestedBy string) (*http.Request, error) + func (client JobClient) DeleteSparkStatementJobResponder(resp *http.Response) (result SparkStatementCancellationResult, err error) + func (client JobClient) DeleteSparkStatementJobSender(req *http.Request) (*http.Response, error) + func (client JobClient) Get(ctx context.Context, jobID string) (result JobDetailRootJSONObject, err error) + func (client JobClient) GetAppState(ctx context.Context, appID string) (result AppState, err error) + func (client JobClient) GetAppStatePreparer(ctx context.Context, appID string) (*http.Request, error) + func (client JobClient) GetAppStateResponder(resp *http.Response) (result AppState, err error) + func (client JobClient) GetAppStateSender(req *http.Request) (*http.Response, error) + func (client JobClient) GetPreparer(ctx context.Context, jobID string) (*http.Request, error) + func (client JobClient) GetResponder(resp *http.Response) (result JobDetailRootJSONObject, err error) + func (client JobClient) GetSender(req *http.Request) (*http.Response, error) + func (client JobClient) GetSparkBatchJob(ctx context.Context, batchID int32) (result SparkBatchJob, err error) + func (client JobClient) GetSparkBatchJobPreparer(ctx context.Context, batchID int32) (*http.Request, error) + func (client JobClient) GetSparkBatchJobResponder(resp *http.Response) (result SparkBatchJob, err error) + func (client JobClient) GetSparkBatchJobSender(req *http.Request) (*http.Response, error) + func (client JobClient) GetSparkBatchLog(ctx context.Context, batchID int32, from *int32, size *int32) (result SparkJobLog, err error) + func (client JobClient) GetSparkBatchLogPreparer(ctx context.Context, batchID int32, from *int32, size *int32) (*http.Request, error) + func (client JobClient) GetSparkBatchLogResponder(resp *http.Response) (result SparkJobLog, err error) + func (client JobClient) GetSparkBatchLogSender(req *http.Request) (*http.Response, error) + func (client JobClient) GetSparkBatchState(ctx context.Context, batchID int32) (result SparkJobState, err error) + func (client JobClient) GetSparkBatchStatePreparer(ctx context.Context, batchID int32) (*http.Request, error) + func (client JobClient) GetSparkBatchStateResponder(resp *http.Response) (result SparkJobState, err error) + func (client JobClient) GetSparkBatchStateSender(req *http.Request) (*http.Response, error) + func (client JobClient) GetSparkSessionJob(ctx context.Context, sessionID int32) (result SparkSessionJob, err error) + func (client JobClient) GetSparkSessionJobPreparer(ctx context.Context, sessionID int32) (*http.Request, error) + func (client JobClient) GetSparkSessionJobResponder(resp *http.Response) (result SparkSessionJob, err error) + func (client JobClient) GetSparkSessionJobSender(req *http.Request) (*http.Response, error) + func (client JobClient) GetSparkSessionLog(ctx context.Context, sessionID int32, from *int32, size *int32) (result SparkJobLog, err error) + func (client JobClient) GetSparkSessionLogPreparer(ctx context.Context, sessionID int32, from *int32, size *int32) (*http.Request, error) + func (client JobClient) GetSparkSessionLogResponder(resp *http.Response) (result SparkJobLog, err error) + func (client JobClient) GetSparkSessionLogSender(req *http.Request) (*http.Response, error) + func (client JobClient) GetSparkSessionState(ctx context.Context, sessionID int32) (result SparkJobState, err error) + func (client JobClient) GetSparkSessionStatePreparer(ctx context.Context, sessionID int32) (*http.Request, error) + func (client JobClient) GetSparkSessionStateResponder(resp *http.Response) (result SparkJobState, err error) + func (client JobClient) GetSparkSessionStateSender(req *http.Request) (*http.Response, error) + func (client JobClient) GetSparkStatementJob(ctx context.Context, sessionID int32, statementID int32) (result SparkStatement, err error) + func (client JobClient) GetSparkStatementJobPreparer(ctx context.Context, sessionID int32, statementID int32) (*http.Request, error) + func (client JobClient) GetSparkStatementJobResponder(resp *http.Response) (result SparkStatement, err error) + func (client JobClient) GetSparkStatementJobSender(req *http.Request) (*http.Response, error) + func (client JobClient) Kill(ctx context.Context, jobID string) (result JobDetailRootJSONObject, err error) + func (client JobClient) KillPreparer(ctx context.Context, jobID string) (*http.Request, error) + func (client JobClient) KillResponder(resp *http.Response) (result JobDetailRootJSONObject, err error) + func (client JobClient) KillSender(req *http.Request) (*http.Response, error) + func (client JobClient) List(ctx context.Context) (result ListJobListJSONObject, err error) + func (client JobClient) ListAfterJobID(ctx context.Context, jobid string, numrecords *int32) (result ListJobListJSONObject, err error) + func (client JobClient) ListAfterJobIDPreparer(ctx context.Context, jobid string, numrecords *int32) (*http.Request, error) + func (client JobClient) ListAfterJobIDResponder(resp *http.Response) (result ListJobListJSONObject, err error) + func (client JobClient) ListAfterJobIDSender(req *http.Request) (*http.Response, error) + func (client JobClient) ListPreparer(ctx context.Context) (*http.Request, error) + func (client JobClient) ListResponder(resp *http.Response) (result ListJobListJSONObject, err error) + func (client JobClient) ListSender(req *http.Request) (*http.Response, error) + func (client JobClient) ListSparkBatchJob(ctx context.Context, from *int32, size *int32) (result SparkBatchJobCollection, err error) + func (client JobClient) ListSparkBatchJobPreparer(ctx context.Context, from *int32, size *int32) (*http.Request, error) + func (client JobClient) ListSparkBatchJobResponder(resp *http.Response) (result SparkBatchJobCollection, err error) + func (client JobClient) ListSparkBatchJobSender(req *http.Request) (*http.Response, error) + func (client JobClient) ListSparkSessionJob(ctx context.Context, from *int32, size *int32) (result SparkSessionCollection, err error) + func (client JobClient) ListSparkSessionJobPreparer(ctx context.Context, from *int32, size *int32) (*http.Request, error) + func (client JobClient) ListSparkSessionJobResponder(resp *http.Response) (result SparkSessionCollection, err error) + func (client JobClient) ListSparkSessionJobSender(req *http.Request) (*http.Response, error) + func (client JobClient) ListSparkStatementJob(ctx context.Context, sessionID int32) (result SparkStatementCollection, err error) + func (client JobClient) ListSparkStatementJobPreparer(ctx context.Context, sessionID int32) (*http.Request, error) + func (client JobClient) ListSparkStatementJobResponder(resp *http.Response) (result SparkStatementCollection, err error) + func (client JobClient) ListSparkStatementJobSender(req *http.Request) (*http.Response, error) + func (client JobClient) SubmitHiveJob(ctx context.Context, content io.ReadCloser) (result JobSubmissionJSONResponse, err error) + func (client JobClient) SubmitHiveJobPreparer(ctx context.Context, content io.ReadCloser) (*http.Request, error) + func (client JobClient) SubmitHiveJobResponder(resp *http.Response) (result JobSubmissionJSONResponse, err error) + func (client JobClient) SubmitHiveJobSender(req *http.Request) (*http.Response, error) + func (client JobClient) SubmitMapReduceJob(ctx context.Context, content io.ReadCloser) (result JobSubmissionJSONResponse, err error) + func (client JobClient) SubmitMapReduceJobPreparer(ctx context.Context, content io.ReadCloser) (*http.Request, error) + func (client JobClient) SubmitMapReduceJobResponder(resp *http.Response) (result JobSubmissionJSONResponse, err error) + func (client JobClient) SubmitMapReduceJobSender(req *http.Request) (*http.Response, error) + func (client JobClient) SubmitMapReduceStreamingJob(ctx context.Context, content io.ReadCloser) (result JobSubmissionJSONResponse, err error) + func (client JobClient) SubmitMapReduceStreamingJobPreparer(ctx context.Context, content io.ReadCloser) (*http.Request, error) + func (client JobClient) SubmitMapReduceStreamingJobResponder(resp *http.Response) (result JobSubmissionJSONResponse, err error) + func (client JobClient) SubmitMapReduceStreamingJobSender(req *http.Request) (*http.Response, error) + func (client JobClient) SubmitPigJob(ctx context.Context, content io.ReadCloser) (result JobSubmissionJSONResponse, err error) + func (client JobClient) SubmitPigJobPreparer(ctx context.Context, content io.ReadCloser) (*http.Request, error) + func (client JobClient) SubmitPigJobResponder(resp *http.Response) (result JobSubmissionJSONResponse, err error) + func (client JobClient) SubmitPigJobSender(req *http.Request) (*http.Response, error) + func (client JobClient) SubmitSparkBatchJob(ctx context.Context, sparkBatchJobRequest SparkBatchJobRequest, ...) (result SparkBatchJob, err error) + func (client JobClient) SubmitSparkBatchJobPreparer(ctx context.Context, sparkBatchJobRequest SparkBatchJobRequest, ...) (*http.Request, error) + func (client JobClient) SubmitSparkBatchJobResponder(resp *http.Response) (result SparkBatchJob, err error) + func (client JobClient) SubmitSparkBatchJobSender(req *http.Request) (*http.Response, error) + func (client JobClient) SubmitSparkSessionJob(ctx context.Context, sparkSessionJobRequest SparkSessionJobRequest, ...) (result SparkSessionJob, err error) + func (client JobClient) SubmitSparkSessionJobPreparer(ctx context.Context, sparkSessionJobRequest SparkSessionJobRequest, ...) (*http.Request, error) + func (client JobClient) SubmitSparkSessionJobResponder(resp *http.Response) (result SparkSessionJob, err error) + func (client JobClient) SubmitSparkSessionJobSender(req *http.Request) (*http.Response, error) + func (client JobClient) SubmitSparkStatementJob(ctx context.Context, sessionID int32, ...) (result SparkStatement, err error) + func (client JobClient) SubmitSparkStatementJobPreparer(ctx context.Context, sessionID int32, ...) (*http.Request, error) + func (client JobClient) SubmitSparkStatementJobResponder(resp *http.Response) (result SparkStatement, err error) + func (client JobClient) SubmitSparkStatementJobSender(req *http.Request) (*http.Response, error) + func (client JobClient) SubmitSqoopJob(ctx context.Context, content io.ReadCloser) (result JobSubmissionJSONResponse, err error) + func (client JobClient) SubmitSqoopJobPreparer(ctx context.Context, content io.ReadCloser) (*http.Request, error) + func (client JobClient) SubmitSqoopJobResponder(resp *http.Response) (result JobSubmissionJSONResponse, err error) + func (client JobClient) SubmitSqoopJobSender(req *http.Request) (*http.Response, error) + type JobDetailRootJSONObject struct + Callback interface{} + Completed *string + ExitValue *int32 + ID *string + Msg interface{} + ParentID *string + PercentComplete *string + Profile *Profile + Status *Status + User *string + Userargs *Userargs + type JobID struct + ID *int64 + JtIdentifier *string + type JobListJSONObject struct + Detail *JobDetailRootJSONObject + ID *string + type JobOperationsErrorResponse struct + Error *string + type JobSubmissionJSONResponse struct + ID *string + type ListJobListJSONObject struct + Value *[]JobListJSONObject + type Profile struct + JobFile *string + JobID *string + JobName *string + QueueName *string + URL *string + User *string + type SessionJobKind string + const Pyspark + const SQL + const Spark + const Sparkr + func PossibleSessionJobKindValues() []SessionJobKind + type SparkBatchJob struct + AppID *string + AppInfo map[string]*string + ID *int32 + LogLines *[]string + State *string + func (sbj SparkBatchJob) MarshalJSON() ([]byte, error) + type SparkBatchJobCollection struct + From *int32 + Sessions *[]SparkBatchJob + Total *int32 + type SparkBatchJobRequest struct + Archives *[]string + Arguments *[]string + ClassName *string + Configuration map[string]*string + DriverCores *int32 + DriverMemory *string + ExecutorCores *int32 + ExecutorCount *int32 + ExecutorMemory *string + File *string + Files *[]string + Jars *[]string + Name *string + ProxyUser *string + PythonFiles *[]string + Queue *string + func (sbjr SparkBatchJobRequest) MarshalJSON() ([]byte, error) + type SparkJobDeletedResult struct + DeletedMessage *string + type SparkJobLog struct + From *int32 + ID *int32 + LogLines *[]string + Size *int32 + Total *int64 + type SparkJobState struct + ID *int32 + State *string + type SparkSessionCollection struct + From *int32 + Sessions *[]SparkSessionJob + Total *int32 + type SparkSessionJob struct + AppID *string + AppInfo map[string]*string + ID *int32 + Kind *string + LogLines *[]string + Owner *string + ProxyUser *string + State *string + func (ssj SparkSessionJob) MarshalJSON() ([]byte, error) + type SparkSessionJobRequest struct + Archives *[]string + Configuration map[string]*string + DriverCores *int32 + DriverMemory *string + ExecutorCores *int32 + ExecutorCount *int32 + ExecutorMemory *string + Files *[]string + HeartbeatTimeoutInSecond *int32 + Jars *[]string + Kind SessionJobKind + Name *string + ProxyUser *string + PythonFiles *[]string + Queue *string + func (ssjr SparkSessionJobRequest) MarshalJSON() ([]byte, error) + type SparkStatement struct + Code *string + ID *int32 + Output *SparkStatementOutput + Progress *float64 + State *string + type SparkStatementCancellationResult struct + CancelMessage *string + type SparkStatementCollection struct + Statements *[]SparkStatement + type SparkStatementOutput struct + Data interface{} + ExecutionCount *int32 + Status *string + type SparkStatementRequest struct + Code *string + Kind *string + type Status struct + CleanupProgress *float64 + FailureInfo *string + FinishTime *int64 + HistoryFile *string + JobACLs interface{} + JobComplete *bool + JobFile *string + JobID *string + JobName *string + JobPriority *string + MapProgress *float64 + NeededMem *int64 + NumReservedSlots *int32 + NumUsedSlots *int32 + Priority *string + Queue *string + ReduceProgress *float64 + ReservedMem *int64 + Retired *bool + RunState *int32 + SchedulingInfo *string + SetupProgress *float64 + StartTime *int64 + State *string + TrackingURL *string + Uber *bool + UsedMem *int64 + Username *string + type Userargs struct + Arg *[]string + Callback interface{} + Define *[]string + Enablelog *string + Execute *string + File interface{} + Files interface{} + Jar *string + Statusdir interface{} + func (u Userargs) MarshalJSON() ([]byte, error) Other modules containing this package gopkg.in/azure/azure-sdk-for-go.v23 gopkg.in/azure/azure-sdk-for-go.v24 gopkg.in/azure/azure-sdk-for-go.v25 gopkg.in/azure/azure-sdk-for-go.v26 gopkg.in/azure/azure-sdk-for-go.v27 gopkg.in/azure/azure-sdk-for-go.v28 gopkg.in/azure/azure-sdk-for-go.v29 gopkg.in/azure/azure-sdk-for-go.v30 gopkg.in/azure/azure-sdk-for-go.v31 gopkg.in/azure/azure-sdk-for-go.v32 gopkg.in/azure/azure-sdk-for-go.v33 gopkg.in/azure/azure-sdk-for-go.v34 gopkg.in/azure/azure-sdk-for-go.v35 gopkg.in/azure/azure-sdk-for-go.v36 gopkg.in/azure/azure-sdk-for-go.v37 gopkg.in/azure/azure-sdk-for-go.v38 gopkg.in/azure/azure-sdk-for-go.v39 gopkg.in/azure/azure-sdk-for-go.v40 gopkg.in/azure/azure-sdk-for-go.v41 gopkg.in/azure/azure-sdk-for-go.v42 gopkg.in/azure/azure-sdk-for-go.v43 gopkg.in/azure/azure-sdk-for-go.v44 gopkg.in/azure/azure-sdk-for-go.v45 gopkg.in/azure/azure-sdk-for-go.v46 gopkg.in/azure/azure-sdk-for-go.v48 gopkg.in/azure/azure-sdk-for-go.v49