IJobOperations Interface

Definition

public interface IJobOperations
type IJobOperations = interface
Public Interface IJobOperations

Methods

GetJobAsync(String, CancellationToken)
GetJobErrorLogsAsync(String, IStorageAccess, CancellationToken)
GetJobOutputAsync(String, IStorageAccess, CancellationToken)
KillJobAsync(String, CancellationToken)
ListJobsAfterJobIdAsync(String, Int32, CancellationToken)
ListJobsAsync(CancellationToken)
SubmitHiveJobAsync(HiveJobSubmissionParameters)
SubmitHiveJobAsync(JobSubmissionParameters, CancellationToken)
SubmitMapReduceJobAsync(JobSubmissionParameters, CancellationToken)
SubmitMapReduceJobAsync(MapReduceJobSubmissionParameters)
SubmitMapReduceStreamingJobAsync(JobSubmissionParameters, CancellationToken)
SubmitMapReduceStreamingJobAsync(MapReduceStreamingJobSubmissionParameters)
SubmitPigJobAsync(JobSubmissionParameters, CancellationToken)
SubmitPigJobAsync(PigJobSubmissionParameters)
SubmitSqoopJobAsync(JobSubmissionParameters, CancellationToken)
SubmitSqoopJobAsync(SqoopJobSubmissionParameters)
WaitForJobCompletionAsync(String, Nullable<TimeSpan>, Nullable<TimeSpan>)

Extension Methods

GetJob(IJobOperations, String)
GetJobAsync(IJobOperations, String)
GetJobErrorLogs(IJobOperations, String, IStorageAccess)
GetJobErrorLogsAsync(IJobOperations, String, IStorageAccess)
GetJobOutput(IJobOperations, String, IStorageAccess)
GetJobOutputAsync(IJobOperations, String, IStorageAccess)
KillJob(IJobOperations, String)
KillJobAsync(IJobOperations, String)
ListJobs(IJobOperations)
ListJobsAfterJobId(IJobOperations, String, Int32)
ListJobsAfterJobIdAsync(IJobOperations, String, Int32)
ListJobsAsync(IJobOperations)
SubmitHiveJob(IJobOperations, HiveJobSubmissionParameters)
SubmitHiveJob(IJobOperations, JobSubmissionParameters)
SubmitHiveJobAsync(IJobOperations, HiveJobSubmissionParameters)
SubmitHiveJobAsync(IJobOperations, JobSubmissionParameters)
SubmitMapReduceJob(IJobOperations, JobSubmissionParameters)
SubmitMapReduceJob(IJobOperations, MapReduceJobSubmissionParameters)
SubmitMapReduceJobAsync(IJobOperations, JobSubmissionParameters)
SubmitMapReduceJobAsync(IJobOperations, MapReduceJobSubmissionParameters)
SubmitMapReduceStreamingJob(IJobOperations, JobSubmissionParameters)
SubmitMapReduceStreamingJob(IJobOperations, MapReduceStreamingJobSubmissionParameters)
SubmitMapReduceStreamingJobAsync(IJobOperations, JobSubmissionParameters)
SubmitMapReduceStreamingJobAsync(IJobOperations, MapReduceStreamingJobSubmissionParameters)
SubmitPigJob(IJobOperations, JobSubmissionParameters)
SubmitPigJob(IJobOperations, PigJobSubmissionParameters)
SubmitPigJobAsync(IJobOperations, JobSubmissionParameters)
SubmitPigJobAsync(IJobOperations, PigJobSubmissionParameters)
SubmitSqoopJob(IJobOperations, JobSubmissionParameters)
SubmitSqoopJob(IJobOperations, SqoopJobSubmissionParameters)
SubmitSqoopJobAsync(IJobOperations, JobSubmissionParameters)
SubmitSqoopJobAsync(IJobOperations, SqoopJobSubmissionParameters)
WaitForJobCompletion(IJobOperations, String, Nullable<TimeSpan>, Nullable<TimeSpan>)
WaitForJobCompletionAsync(IJobOperations, String, Nullable<TimeSpan>, Nullable<TimeSpan>)

Applies to