JobOperationsExtensions Class

Definition

public static class JobOperationsExtensions
type JobOperationsExtensions = class
Public Module JobOperationsExtensions
Inheritance
JobOperationsExtensions

Methods

DeleteSparkBatchJob(IJobOperations, Int32, String)
DeleteSparkBatchJobAsync(IJobOperations, Int32, String, CancellationToken)
DeleteSparkSessionJob(IJobOperations, Int32, String)
DeleteSparkSessionJobAsync(IJobOperations, Int32, String, CancellationToken)
DeleteSparkStatementJob(IJobOperations, Int32, Int32, String)
DeleteSparkStatementJobAsync(IJobOperations, Int32, Int32, String, CancellationToken)
Get(IJobOperations, String)
GetAppState(IJobOperations, String)
GetAppStateAsync(IJobOperations, String, CancellationToken)
GetAsync(IJobOperations, String, CancellationToken)
GetJobErrorLogs(IJobOperations, String, IStorageAccess)
GetJobErrorLogsAsync(IJobOperations, String, IStorageAccess)
GetJobOutput(IJobOperations, String, IStorageAccess)
GetJobOutputAsync(IJobOperations, String, IStorageAccess)
GetSparkBatchJob(IJobOperations, Int32)
GetSparkBatchJobAsync(IJobOperations, Int32, CancellationToken)
GetSparkBatchLog(IJobOperations, Int32, Nullable<Int32>, Nullable<Int32>)
GetSparkBatchLogAsync(IJobOperations, Int32, Nullable<Int32>, Nullable<Int32>, CancellationToken)
GetSparkBatchState(IJobOperations, Int32)
GetSparkBatchStateAsync(IJobOperations, Int32, CancellationToken)
GetSparkSessionJob(IJobOperations, Int32)
GetSparkSessionJobAsync(IJobOperations, Int32, CancellationToken)
GetSparkSessionLog(IJobOperations, Int32, Nullable<Int32>, Nullable<Int32>)
GetSparkSessionLogAsync(IJobOperations, Int32, Nullable<Int32>, Nullable<Int32>, CancellationToken)
GetSparkSessionState(IJobOperations, Int32)
GetSparkSessionStateAsync(IJobOperations, Int32, CancellationToken)
GetSparkStatementJob(IJobOperations, Int32, Int32)
GetSparkStatementJobAsync(IJobOperations, Int32, Int32, CancellationToken)
Kill(IJobOperations, String)
KillAsync(IJobOperations, String, CancellationToken)
List(IJobOperations)
ListAfterJobId(IJobOperations, String, Nullable<Int32>)
ListAfterJobIdAsync(IJobOperations, String, Nullable<Int32>, CancellationToken)
ListAsync(IJobOperations, CancellationToken)
ListSparkBatchJob(IJobOperations, Nullable<Int32>, Nullable<Int32>)
ListSparkBatchJobAsync(IJobOperations, Nullable<Int32>, Nullable<Int32>, CancellationToken)
ListSparkSessionJob(IJobOperations, Nullable<Int32>, Nullable<Int32>)
ListSparkSessionJobAsync(IJobOperations, Nullable<Int32>, Nullable<Int32>, CancellationToken)
ListSparkStatementJob(IJobOperations, Int32)
ListSparkStatementJobAsync(IJobOperations, Int32, CancellationToken)
SubmitHiveJob(IJobOperations, HiveJobSubmissionParameters)
SubmitHiveJob(IJobOperations, Stream)
SubmitHiveJobAsync(IJobOperations, HiveJobSubmissionParameters, CancellationToken)
SubmitHiveJobAsync(IJobOperations, Stream, CancellationToken)
SubmitMapReduceJob(IJobOperations, MapReduceJobSubmissionParameters)
SubmitMapReduceJob(IJobOperations, Stream)
SubmitMapReduceJobAsync(IJobOperations, MapReduceJobSubmissionParameters, CancellationToken)
SubmitMapReduceJobAsync(IJobOperations, Stream, CancellationToken)
SubmitMapReduceStreamingJob(IJobOperations, MapReduceStreamingJobSubmissionParameters)
SubmitMapReduceStreamingJob(IJobOperations, Stream)
SubmitMapReduceStreamingJobAsync(IJobOperations, MapReduceStreamingJobSubmissionParameters, CancellationToken)
SubmitMapReduceStreamingJobAsync(IJobOperations, Stream, CancellationToken)
SubmitPigJob(IJobOperations, PigJobSubmissionParameters)
SubmitPigJob(IJobOperations, Stream)
SubmitPigJobAsync(IJobOperations, PigJobSubmissionParameters, CancellationToken)
SubmitPigJobAsync(IJobOperations, Stream, CancellationToken)
SubmitSparkBatchJob(IJobOperations, SparkBatchJobRequest, String)
SubmitSparkBatchJobAsync(IJobOperations, SparkBatchJobRequest, String, CancellationToken)
SubmitSparkSessionJob(IJobOperations, SparkSessionJobRequest, String)
SubmitSparkSessionJobAsync(IJobOperations, SparkSessionJobRequest, String, CancellationToken)
SubmitSparkStatementJob(IJobOperations, Int32, SparkStatementRequest, String)
SubmitSparkStatementJobAsync(IJobOperations, Int32, SparkStatementRequest, String, CancellationToken)
SubmitSqoopJob(IJobOperations, SqoopJobSubmissionParameters)
SubmitSqoopJob(IJobOperations, Stream)
SubmitSqoopJobAsync(IJobOperations, SqoopJobSubmissionParameters, CancellationToken)
SubmitSqoopJobAsync(IJobOperations, Stream, CancellationToken)
WaitForJobCompletion(IJobOperations, String, Nullable<TimeSpan>, Nullable<TimeSpan>)
WaitForJobCompletionAsync(IJobOperations, String, Nullable<TimeSpan>, Nullable<TimeSpan>)

Applies to