IJobOperations Interface

Definition

public interface IJobOperations
type IJobOperations = interface
Public Interface IJobOperations

Methods

DeleteSparkBatchJobWithHttpMessagesAsync(Int32, String, Dictionary<String,List<String>>, CancellationToken)
DeleteSparkSessionJobWithHttpMessagesAsync(Int32, String, Dictionary<String,List<String>>, CancellationToken)
DeleteSparkStatementJobWithHttpMessagesAsync(Int32, Int32, String, Dictionary<String,List<String>>, CancellationToken)
GetAppStateWithHttpMessagesAsync(String, Dictionary<String,List<String>>, CancellationToken)
GetJobErrorLogsAsync(String, IStorageAccess, CancellationToken)
GetJobOutputAsync(String, IStorageAccess, CancellationToken)
GetSparkBatchJobWithHttpMessagesAsync(Int32, Dictionary<String,List<String>>, CancellationToken)
GetSparkBatchLogWithHttpMessagesAsync(Int32, Nullable<Int32>, Nullable<Int32>, Dictionary<String,List<String>>, CancellationToken)
GetSparkBatchStateWithHttpMessagesAsync(Int32, Dictionary<String,List<String>>, CancellationToken)
GetSparkSessionJobWithHttpMessagesAsync(Int32, Dictionary<String,List<String>>, CancellationToken)
GetSparkSessionLogWithHttpMessagesAsync(Int32, Nullable<Int32>, Nullable<Int32>, Dictionary<String,List<String>>, CancellationToken)
GetSparkSessionStateWithHttpMessagesAsync(Int32, Dictionary<String,List<String>>, CancellationToken)
GetSparkStatementJobWithHttpMessagesAsync(Int32, Int32, Dictionary<String,List<String>>, CancellationToken)
GetWithHttpMessagesAsync(String, Dictionary<String,List<String>>, CancellationToken)
KillWithHttpMessagesAsync(String, Dictionary<String,List<String>>, CancellationToken)
ListAfterJobIdWithHttpMessagesAsync(String, Nullable<Int32>, Dictionary<String,List<String>>, CancellationToken)
ListSparkBatchJobWithHttpMessagesAsync(Nullable<Int32>, Nullable<Int32>, Dictionary<String,List<String>>, CancellationToken)
ListSparkSessionJobWithHttpMessagesAsync(Nullable<Int32>, Nullable<Int32>, Dictionary<String,List<String>>, CancellationToken)
ListSparkStatementJobWithHttpMessagesAsync(Int32, Dictionary<String,List<String>>, CancellationToken)
ListWithHttpMessagesAsync(Dictionary<String,List<String>>, CancellationToken)
SubmitHiveJobWithHttpMessagesAsync(HiveJobSubmissionParameters, Dictionary<String,List<String>>, CancellationToken)
SubmitHiveJobWithHttpMessagesAsync(Stream, Dictionary<String,List<String>>, CancellationToken)
SubmitMapReduceJobWithHttpMessagesAsync(MapReduceJobSubmissionParameters, Dictionary<String,List<String>>, CancellationToken)
SubmitMapReduceJobWithHttpMessagesAsync(Stream, Dictionary<String,List<String>>, CancellationToken)
SubmitMapReduceStreamingJobWithHttpMessagesAsync(MapReduceStreamingJobSubmissionParameters, Dictionary<String,List<String>>, CancellationToken)
SubmitMapReduceStreamingJobWithHttpMessagesAsync(Stream, Dictionary<String,List<String>>, CancellationToken)
SubmitPigJobWithHttpMessagesAsync(PigJobSubmissionParameters, Dictionary<String,List<String>>, CancellationToken)
SubmitPigJobWithHttpMessagesAsync(Stream, Dictionary<String,List<String>>, CancellationToken)
SubmitSparkBatchJobWithHttpMessagesAsync(SparkBatchJobRequest, String, Dictionary<String,List<String>>, CancellationToken)
SubmitSparkSessionJobWithHttpMessagesAsync(SparkSessionJobRequest, String, Dictionary<String,List<String>>, CancellationToken)
SubmitSparkStatementJobWithHttpMessagesAsync(Int32, SparkStatementRequest, String, Dictionary<String,List<String>>, CancellationToken)
SubmitSqoopJobWithHttpMessagesAsync(SqoopJobSubmissionParameters, Dictionary<String,List<String>>, CancellationToken)
SubmitSqoopJobWithHttpMessagesAsync(Stream, Dictionary<String,List<String>>, CancellationToken)
WaitForJobCompletionWithHttpMessagesAsync(String, Nullable<TimeSpan>, Nullable<TimeSpan>)

Extension 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