com.microsoft.azure.management.datalake.analytics

Interface Jobs

public interface Jobs

An instance of this class provides access to all the operations defined in Jobs.

Method Summary

Modifier and Type	Method and Description
void	beginCancel(String accountName, UUID jobIdentity) Cancels the running job specified by the job ID.
rx.Observable<Void>	beginCancelAsync(String accountName, UUID jobIdentity) Cancels the running job specified by the job ID.
ServiceFuture<Void>	beginCancelAsync(String accountName, UUID jobIdentity, ServiceCallback<Void> serviceCallback) Cancels the running job specified by the job ID.
rx.Observable<ServiceResponse<Void>>	beginCancelWithServiceResponseAsync(String accountName, UUID jobIdentity) Cancels the running job specified by the job ID.
JobInformation	beginUpdate(String accountName, UUID jobIdentity) Updates the job information for the specified job ID.
JobInformation	beginUpdate(String accountName, UUID jobIdentity, UpdateJobParameters parameters) Updates the job information for the specified job ID.
rx.Observable<JobInformation>	beginUpdateAsync(String accountName, UUID jobIdentity) Updates the job information for the specified job ID.
ServiceFuture<JobInformation>	beginUpdateAsync(String accountName, UUID jobIdentity, ServiceCallback<JobInformation> serviceCallback) Updates the job information for the specified job ID.
rx.Observable<JobInformation>	beginUpdateAsync(String accountName, UUID jobIdentity, UpdateJobParameters parameters) Updates the job information for the specified job ID.
ServiceFuture<JobInformation>	beginUpdateAsync(String accountName, UUID jobIdentity, UpdateJobParameters parameters, ServiceCallback<JobInformation> serviceCallback) Updates the job information for the specified job ID.
rx.Observable<ServiceResponse<JobInformation>>	beginUpdateWithServiceResponseAsync(String accountName, UUID jobIdentity) Updates the job information for the specified job ID.
rx.Observable<ServiceResponse<JobInformation>>	beginUpdateWithServiceResponseAsync(String accountName, UUID jobIdentity, UpdateJobParameters parameters) Updates the job information for the specified job ID.
void	beginYield(String accountName, UUID jobIdentity) Pauses the specified job and places it back in the job queue, behind other jobs of equal or higher importance, based on priority.
rx.Observable<Void>	beginYieldAsync(String accountName, UUID jobIdentity) Pauses the specified job and places it back in the job queue, behind other jobs of equal or higher importance, based on priority.
ServiceFuture<Void>	beginYieldAsync(String accountName, UUID jobIdentity, ServiceCallback<Void> serviceCallback) Pauses the specified job and places it back in the job queue, behind other jobs of equal or higher importance, based on priority.
rx.Observable<ServiceResponse<Void>>	beginYieldWithServiceResponseAsync(String accountName, UUID jobIdentity) Pauses the specified job and places it back in the job queue, behind other jobs of equal or higher importance, based on priority.
JobInformation	build(String accountName, BuildJobParameters parameters) Builds (compiles) the specified job in the specified Data Lake Analytics account for job correctness and validation.
rx.Observable<JobInformation>	buildAsync(String accountName, BuildJobParameters parameters) Builds (compiles) the specified job in the specified Data Lake Analytics account for job correctness and validation.
ServiceFuture<JobInformation>	buildAsync(String accountName, BuildJobParameters parameters, ServiceCallback<JobInformation> serviceCallback) Builds (compiles) the specified job in the specified Data Lake Analytics account for job correctness and validation.
rx.Observable<ServiceResponse<JobInformation>>	buildWithServiceResponseAsync(String accountName, BuildJobParameters parameters) Builds (compiles) the specified job in the specified Data Lake Analytics account for job correctness and validation.
void	cancel(String accountName, UUID jobIdentity) Cancels the running job specified by the job ID.
rx.Observable<Void>	cancelAsync(String accountName, UUID jobIdentity) Cancels the running job specified by the job ID.
ServiceFuture<Void>	cancelAsync(String accountName, UUID jobIdentity, ServiceCallback<Void> serviceCallback) Cancels the running job specified by the job ID.
rx.Observable<ServiceResponse<Void>>	cancelWithServiceResponseAsync(String accountName, UUID jobIdentity) Cancels the running job specified by the job ID.
JobInformation	create(String accountName, UUID jobIdentity, CreateJobParameters parameters) Submits a job to the specified Data Lake Analytics account.
rx.Observable<JobInformation>	createAsync(String accountName, UUID jobIdentity, CreateJobParameters parameters) Submits a job to the specified Data Lake Analytics account.
ServiceFuture<JobInformation>	createAsync(String accountName, UUID jobIdentity, CreateJobParameters parameters, ServiceCallback<JobInformation> serviceCallback) Submits a job to the specified Data Lake Analytics account.
rx.Observable<ServiceResponse<JobInformation>>	createWithServiceResponseAsync(String accountName, UUID jobIdentity, CreateJobParameters parameters) Submits a job to the specified Data Lake Analytics account.
JobInformation	get(String accountName, UUID jobIdentity) Gets the job information for the specified job ID.
rx.Observable<JobInformation>	getAsync(String accountName, UUID jobIdentity) Gets the job information for the specified job ID.
ServiceFuture<JobInformation>	getAsync(String accountName, UUID jobIdentity, ServiceCallback<JobInformation> serviceCallback) Gets the job information for the specified job ID.
JobDataPath	getDebugDataPath(String accountName, UUID jobIdentity) Gets the job debug data information specified by the job ID.
rx.Observable<JobDataPath>	getDebugDataPathAsync(String accountName, UUID jobIdentity) Gets the job debug data information specified by the job ID.
ServiceFuture<JobDataPath>	getDebugDataPathAsync(String accountName, UUID jobIdentity, ServiceCallback<JobDataPath> serviceCallback) Gets the job debug data information specified by the job ID.
rx.Observable<ServiceResponse<JobDataPath>>	getDebugDataPathWithServiceResponseAsync(String accountName, UUID jobIdentity) Gets the job debug data information specified by the job ID.
JobStatistics	getStatistics(String accountName, UUID jobIdentity) Gets statistics of the specified job.
rx.Observable<JobStatistics>	getStatisticsAsync(String accountName, UUID jobIdentity) Gets statistics of the specified job.
ServiceFuture<JobStatistics>	getStatisticsAsync(String accountName, UUID jobIdentity, ServiceCallback<JobStatistics> serviceCallback) Gets statistics of the specified job.
rx.Observable<ServiceResponse<JobStatistics>>	getStatisticsWithServiceResponseAsync(String accountName, UUID jobIdentity) Gets statistics of the specified job.
rx.Observable<ServiceResponse<JobInformation>>	getWithServiceResponseAsync(String accountName, UUID jobIdentity) Gets the job information for the specified job ID.
PagedList<JobInformationBasic>	list(String accountName) Lists the jobs, if any, associated with the specified Data Lake Analytics account.
PagedList<JobInformationBasic>	list(String accountName, String filter, Integer top, Integer skip, String select, String orderby, Boolean count) Lists the jobs, if any, associated with the specified Data Lake Analytics account.
rx.Observable<Page<JobInformationBasic>>	listAsync(String accountName) Lists the jobs, if any, associated with the specified Data Lake Analytics account.
ServiceFuture<List<JobInformationBasic>>	listAsync(String accountName, ListOperationCallback<JobInformationBasic> serviceCallback) Lists the jobs, if any, associated with the specified Data Lake Analytics account.
rx.Observable<Page<JobInformationBasic>>	listAsync(String accountName, String filter, Integer top, Integer skip, String select, String orderby, Boolean count) Lists the jobs, if any, associated with the specified Data Lake Analytics account.
ServiceFuture<List<JobInformationBasic>>	listAsync(String accountName, String filter, Integer top, Integer skip, String select, String orderby, Boolean count, ListOperationCallback<JobInformationBasic> serviceCallback) Lists the jobs, if any, associated with the specified Data Lake Analytics account.
PagedList<JobInformationBasic>	listNext(String nextPageLink) Lists the jobs, if any, associated with the specified Data Lake Analytics account.
rx.Observable<Page<JobInformationBasic>>	listNextAsync(String nextPageLink) Lists the jobs, if any, associated with the specified Data Lake Analytics account.
ServiceFuture<List<JobInformationBasic>>	listNextAsync(String nextPageLink, ServiceFuture<List<JobInformationBasic>> serviceFuture, ListOperationCallback<JobInformationBasic> serviceCallback) Lists the jobs, if any, associated with the specified Data Lake Analytics account.
rx.Observable<ServiceResponse<Page<JobInformationBasic>>>	listNextWithServiceResponseAsync(String nextPageLink) Lists the jobs, if any, associated with the specified Data Lake Analytics account.
rx.Observable<ServiceResponse<Page<JobInformationBasic>>>	listWithServiceResponseAsync(String accountName) Lists the jobs, if any, associated with the specified Data Lake Analytics account.
rx.Observable<ServiceResponse<Page<JobInformationBasic>>>	listWithServiceResponseAsync(String accountName, String filter, Integer top, Integer skip, String select, String orderby, Boolean count) Lists the jobs, if any, associated with the specified Data Lake Analytics account.
JobInformation	update(String accountName, UUID jobIdentity) Updates the job information for the specified job ID.
JobInformation	update(String accountName, UUID jobIdentity, UpdateJobParameters parameters) Updates the job information for the specified job ID.
rx.Observable<JobInformation>	updateAsync(String accountName, UUID jobIdentity) Updates the job information for the specified job ID.
ServiceFuture<JobInformation>	updateAsync(String accountName, UUID jobIdentity, ServiceCallback<JobInformation> serviceCallback) Updates the job information for the specified job ID.
rx.Observable<JobInformation>	updateAsync(String accountName, UUID jobIdentity, UpdateJobParameters parameters) Updates the job information for the specified job ID.
ServiceFuture<JobInformation>	updateAsync(String accountName, UUID jobIdentity, UpdateJobParameters parameters, ServiceCallback<JobInformation> serviceCallback) Updates the job information for the specified job ID.
rx.Observable<ServiceResponse<JobInformation>>	updateWithServiceResponseAsync(String accountName, UUID jobIdentity) Updates the job information for the specified job ID.
rx.Observable<ServiceResponse<JobInformation>>	updateWithServiceResponseAsync(String accountName, UUID jobIdentity, UpdateJobParameters parameters) Updates the job information for the specified job ID.
void	yield(String accountName, UUID jobIdentity) Pauses the specified job and places it back in the job queue, behind other jobs of equal or higher importance, based on priority.
rx.Observable<Void>	yieldAsync(String accountName, UUID jobIdentity) Pauses the specified job and places it back in the job queue, behind other jobs of equal or higher importance, based on priority.
ServiceFuture<Void>	yieldAsync(String accountName, UUID jobIdentity, ServiceCallback<Void> serviceCallback) Pauses the specified job and places it back in the job queue, behind other jobs of equal or higher importance, based on priority.
rx.Observable<ServiceResponse<Void>>	yieldWithServiceResponseAsync(String accountName, UUID jobIdentity) Pauses the specified job and places it back in the job queue, behind other jobs of equal or higher importance, based on priority.

Method Detail

list

PagedList<JobInformationBasic> list(String accountName)

Lists the jobs, if any, associated with the specified Data Lake Analytics account. The response includes a link to the next page of results, if any.

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

Returns:

the PagedList<JobInformationBasic> object if successful.

Throws:

IllegalArgumentException - thrown if parameters fail the validation

CloudException - thrown if the request is rejected by server

RuntimeException - all other wrapped checked exceptions if the request fails to be sent

listAsync

ServiceFuture<List<JobInformationBasic>> listAsync(String accountName,
                                                   ListOperationCallback<JobInformationBasic> serviceCallback)

Lists the jobs, if any, associated with the specified Data Lake Analytics account. The response includes a link to the next page of results, if any.

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

serviceCallback - the async ServiceCallback to handle successful and failed responses.

Returns:

the ServiceFuture object

Throws:

IllegalArgumentException - thrown if parameters fail the validation

listAsync

rx.Observable<Page<JobInformationBasic>> listAsync(String accountName)

Lists the jobs, if any, associated with the specified Data Lake Analytics account. The response includes a link to the next page of results, if any.

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

Returns:

the observable to the PagedList<JobInformationBasic> object

Throws:

IllegalArgumentException - thrown if parameters fail the validation

listWithServiceResponseAsync

rx.Observable<ServiceResponse<Page<JobInformationBasic>>> listWithServiceResponseAsync(String accountName)

Lists the jobs, if any, associated with the specified Data Lake Analytics account. The response includes a link to the next page of results, if any.

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

Returns:

the observable to the PagedList<JobInformationBasic> object

Throws:

IllegalArgumentException - thrown if parameters fail the validation

list

PagedList<JobInformationBasic> list(String accountName,
                                    String filter,
                                    Integer top,
                                    Integer skip,
                                    String select,
                                    String orderby,
                                    Boolean count)

Lists the jobs, if any, associated with the specified Data Lake Analytics account. The response includes a link to the next page of results, if any.

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

filter - OData filter. Optional.

top - The number of items to return. Optional.

skip - The number of items to skip over before returning elements. Optional.

select - OData Select statement. Limits the properties on each entry to just those requested, e.g. Categories?$select=CategoryName,Description. Optional.

orderby - OrderBy clause. One or more comma-separated expressions with an optional "asc" (the default) or "desc" depending on the order you'd like the values sorted, e.g. Categories?$orderby=CategoryName desc. Optional.

count - The Boolean value of true or false to request a count of the matching resources included with the resources in the response, e.g. Categories?$count=true. Optional.

Returns:

the PagedList<JobInformationBasic> object if successful.

Throws:

IllegalArgumentException - thrown if parameters fail the validation

CloudException - thrown if the request is rejected by server

RuntimeException - all other wrapped checked exceptions if the request fails to be sent

listAsync

ServiceFuture<List<JobInformationBasic>> listAsync(String accountName,
                                                   String filter,
                                                   Integer top,
                                                   Integer skip,
                                                   String select,
                                                   String orderby,
                                                   Boolean count,
                                                   ListOperationCallback<JobInformationBasic> serviceCallback)

Lists the jobs, if any, associated with the specified Data Lake Analytics account. The response includes a link to the next page of results, if any.

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

filter - OData filter. Optional.

top - The number of items to return. Optional.

skip - The number of items to skip over before returning elements. Optional.

select - OData Select statement. Limits the properties on each entry to just those requested, e.g. Categories?$select=CategoryName,Description. Optional.

orderby - OrderBy clause. One or more comma-separated expressions with an optional "asc" (the default) or "desc" depending on the order you'd like the values sorted, e.g. Categories?$orderby=CategoryName desc. Optional.

count - The Boolean value of true or false to request a count of the matching resources included with the resources in the response, e.g. Categories?$count=true. Optional.

serviceCallback - the async ServiceCallback to handle successful and failed responses.

Returns:

the ServiceFuture object

Throws:

IllegalArgumentException - thrown if parameters fail the validation

listAsync

rx.Observable<Page<JobInformationBasic>> listAsync(String accountName,
                                                   String filter,
                                                   Integer top,
                                                   Integer skip,
                                                   String select,
                                                   String orderby,
                                                   Boolean count)

Lists the jobs, if any, associated with the specified Data Lake Analytics account. The response includes a link to the next page of results, if any.

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

filter - OData filter. Optional.

top - The number of items to return. Optional.

skip - The number of items to skip over before returning elements. Optional.

select - OData Select statement. Limits the properties on each entry to just those requested, e.g. Categories?$select=CategoryName,Description. Optional.

orderby - OrderBy clause. One or more comma-separated expressions with an optional "asc" (the default) or "desc" depending on the order you'd like the values sorted, e.g. Categories?$orderby=CategoryName desc. Optional.

count - The Boolean value of true or false to request a count of the matching resources included with the resources in the response, e.g. Categories?$count=true. Optional.

Returns:

the observable to the PagedList<JobInformationBasic> object

Throws:

IllegalArgumentException - thrown if parameters fail the validation

listWithServiceResponseAsync

rx.Observable<ServiceResponse<Page<JobInformationBasic>>> listWithServiceResponseAsync(String accountName,
                                                                                       String filter,
                                                                                       Integer top,
                                                                                       Integer skip,
                                                                                       String select,
                                                                                       String orderby,
                                                                                       Boolean count)

Lists the jobs, if any, associated with the specified Data Lake Analytics account. The response includes a link to the next page of results, if any.

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

filter - OData filter. Optional.

top - The number of items to return. Optional.

skip - The number of items to skip over before returning elements. Optional.

select - OData Select statement. Limits the properties on each entry to just those requested, e.g. Categories?$select=CategoryName,Description. Optional.

orderby - OrderBy clause. One or more comma-separated expressions with an optional "asc" (the default) or "desc" depending on the order you'd like the values sorted, e.g. Categories?$orderby=CategoryName desc. Optional.

count - The Boolean value of true or false to request a count of the matching resources included with the resources in the response, e.g. Categories?$count=true. Optional.

Returns:

the observable to the PagedList<JobInformationBasic> object

Throws:

IllegalArgumentException - thrown if parameters fail the validation

create

JobInformation create(String accountName,
                      UUID jobIdentity,
                      CreateJobParameters parameters)

Submits a job to the specified Data Lake Analytics account.

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

jobIdentity - Job identifier. Uniquely identifies the job across all jobs submitted to the service.

parameters - The parameters to submit a job.

Returns:

the JobInformation object if successful.

Throws:

IllegalArgumentException - thrown if parameters fail the validation

CloudException - thrown if the request is rejected by server

RuntimeException - all other wrapped checked exceptions if the request fails to be sent

createAsync

ServiceFuture<JobInformation> createAsync(String accountName,
                                          UUID jobIdentity,
                                          CreateJobParameters parameters,
                                          ServiceCallback<JobInformation> serviceCallback)

Submits a job to the specified Data Lake Analytics account.

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

jobIdentity - Job identifier. Uniquely identifies the job across all jobs submitted to the service.

parameters - The parameters to submit a job.

serviceCallback - the async ServiceCallback to handle successful and failed responses.

Returns:

the ServiceFuture object

Throws:

IllegalArgumentException - thrown if parameters fail the validation

createAsync

rx.Observable<JobInformation> createAsync(String accountName,
                                          UUID jobIdentity,
                                          CreateJobParameters parameters)

Submits a job to the specified Data Lake Analytics account.

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

jobIdentity - Job identifier. Uniquely identifies the job across all jobs submitted to the service.

parameters - The parameters to submit a job.

Returns:

the observable to the JobInformation object

Throws:

IllegalArgumentException - thrown if parameters fail the validation

createWithServiceResponseAsync

rx.Observable<ServiceResponse<JobInformation>> createWithServiceResponseAsync(String accountName,
                                                                              UUID jobIdentity,
                                                                              CreateJobParameters parameters)

Submits a job to the specified Data Lake Analytics account.

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

jobIdentity - Job identifier. Uniquely identifies the job across all jobs submitted to the service.

parameters - The parameters to submit a job.

Returns:

the observable to the JobInformation object

Throws:

IllegalArgumentException - thrown if parameters fail the validation

get

JobInformation get(String accountName,
                   UUID jobIdentity)

Gets the job information for the specified job ID.

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

jobIdentity - JobInfo ID.

Returns:

the JobInformation object if successful.

Throws:

IllegalArgumentException - thrown if parameters fail the validation

CloudException - thrown if the request is rejected by server

RuntimeException - all other wrapped checked exceptions if the request fails to be sent

getAsync

ServiceFuture<JobInformation> getAsync(String accountName,
                                       UUID jobIdentity,
                                       ServiceCallback<JobInformation> serviceCallback)

Gets the job information for the specified job ID.

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

jobIdentity - JobInfo ID.

serviceCallback - the async ServiceCallback to handle successful and failed responses.

Returns:

the ServiceFuture object

Throws:

IllegalArgumentException - thrown if parameters fail the validation

getAsync

rx.Observable<JobInformation> getAsync(String accountName,
                                       UUID jobIdentity)

Gets the job information for the specified job ID.

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

jobIdentity - JobInfo ID.

Returns:

the observable to the JobInformation object

Throws:

IllegalArgumentException - thrown if parameters fail the validation

getWithServiceResponseAsync

rx.Observable<ServiceResponse<JobInformation>> getWithServiceResponseAsync(String accountName,
                                                                           UUID jobIdentity)

Gets the job information for the specified job ID.

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

jobIdentity - JobInfo ID.

Returns:

the observable to the JobInformation object

Throws:

IllegalArgumentException - thrown if parameters fail the validation

update

JobInformation update(String accountName,
                      UUID jobIdentity)

Updates the job information for the specified job ID. (Only for use internally with Scope job type.).

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

jobIdentity - Job identifier. Uniquely identifies the job across all jobs submitted to the service.

Returns:

the JobInformation object if successful.

Throws:

IllegalArgumentException - thrown if parameters fail the validation

CloudException - thrown if the request is rejected by server

RuntimeException - all other wrapped checked exceptions if the request fails to be sent

updateAsync

ServiceFuture<JobInformation> updateAsync(String accountName,
                                          UUID jobIdentity,
                                          ServiceCallback<JobInformation> serviceCallback)

Updates the job information for the specified job ID. (Only for use internally with Scope job type.).

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

jobIdentity - Job identifier. Uniquely identifies the job across all jobs submitted to the service.

serviceCallback - the async ServiceCallback to handle successful and failed responses.

Returns:

the ServiceFuture object

Throws:

IllegalArgumentException - thrown if parameters fail the validation

updateAsync

rx.Observable<JobInformation> updateAsync(String accountName,
                                          UUID jobIdentity)

Updates the job information for the specified job ID. (Only for use internally with Scope job type.).

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

jobIdentity - Job identifier. Uniquely identifies the job across all jobs submitted to the service.

Returns:

the observable to the JobInformation object

Throws:

IllegalArgumentException - thrown if parameters fail the validation

updateWithServiceResponseAsync

rx.Observable<ServiceResponse<JobInformation>> updateWithServiceResponseAsync(String accountName,
                                                                              UUID jobIdentity)

Updates the job information for the specified job ID. (Only for use internally with Scope job type.).

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

jobIdentity - Job identifier. Uniquely identifies the job across all jobs submitted to the service.

Returns:

the observable to the JobInformation object

Throws:

IllegalArgumentException - thrown if parameters fail the validation

update

JobInformation update(String accountName,
                      UUID jobIdentity,
                      UpdateJobParameters parameters)

Updates the job information for the specified job ID. (Only for use internally with Scope job type.).

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

jobIdentity - Job identifier. Uniquely identifies the job across all jobs submitted to the service.

parameters - The parameters to update a job.

Returns:

the JobInformation object if successful.

Throws:

IllegalArgumentException - thrown if parameters fail the validation

CloudException - thrown if the request is rejected by server

RuntimeException - all other wrapped checked exceptions if the request fails to be sent

updateAsync

ServiceFuture<JobInformation> updateAsync(String accountName,
                                          UUID jobIdentity,
                                          UpdateJobParameters parameters,
                                          ServiceCallback<JobInformation> serviceCallback)

Updates the job information for the specified job ID. (Only for use internally with Scope job type.).

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

jobIdentity - Job identifier. Uniquely identifies the job across all jobs submitted to the service.

parameters - The parameters to update a job.

serviceCallback - the async ServiceCallback to handle successful and failed responses.

Returns:

the ServiceFuture object

Throws:

IllegalArgumentException - thrown if parameters fail the validation

updateAsync

rx.Observable<JobInformation> updateAsync(String accountName,
                                          UUID jobIdentity,
                                          UpdateJobParameters parameters)

Updates the job information for the specified job ID. (Only for use internally with Scope job type.).

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

jobIdentity - Job identifier. Uniquely identifies the job across all jobs submitted to the service.

parameters - The parameters to update a job.

Returns:

the observable to the JobInformation object

Throws:

IllegalArgumentException - thrown if parameters fail the validation

updateWithServiceResponseAsync

rx.Observable<ServiceResponse<JobInformation>> updateWithServiceResponseAsync(String accountName,
                                                                              UUID jobIdentity,
                                                                              UpdateJobParameters parameters)

Updates the job information for the specified job ID. (Only for use internally with Scope job type.).

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

jobIdentity - Job identifier. Uniquely identifies the job across all jobs submitted to the service.

parameters - The parameters to update a job.

Returns:

the observable to the JobInformation object

Throws:

IllegalArgumentException - thrown if parameters fail the validation

beginUpdate

JobInformation beginUpdate(String accountName,
                           UUID jobIdentity)

Updates the job information for the specified job ID. (Only for use internally with Scope job type.).

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

jobIdentity - Job identifier. Uniquely identifies the job across all jobs submitted to the service.

Returns:

the JobInformation object if successful.

Throws:

IllegalArgumentException - thrown if parameters fail the validation

CloudException - thrown if the request is rejected by server

RuntimeException - all other wrapped checked exceptions if the request fails to be sent

beginUpdateAsync

ServiceFuture<JobInformation> beginUpdateAsync(String accountName,
                                               UUID jobIdentity,
                                               ServiceCallback<JobInformation> serviceCallback)

Updates the job information for the specified job ID. (Only for use internally with Scope job type.).

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

jobIdentity - Job identifier. Uniquely identifies the job across all jobs submitted to the service.

serviceCallback - the async ServiceCallback to handle successful and failed responses.

Returns:

the ServiceFuture object

Throws:

IllegalArgumentException - thrown if parameters fail the validation

beginUpdateAsync

rx.Observable<JobInformation> beginUpdateAsync(String accountName,
                                               UUID jobIdentity)

Updates the job information for the specified job ID. (Only for use internally with Scope job type.).

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

jobIdentity - Job identifier. Uniquely identifies the job across all jobs submitted to the service.

Returns:

the observable to the JobInformation object

Throws:

IllegalArgumentException - thrown if parameters fail the validation

beginUpdateWithServiceResponseAsync

rx.Observable<ServiceResponse<JobInformation>> beginUpdateWithServiceResponseAsync(String accountName,
                                                                                   UUID jobIdentity)

Updates the job information for the specified job ID. (Only for use internally with Scope job type.).

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

jobIdentity - Job identifier. Uniquely identifies the job across all jobs submitted to the service.

Returns:

the observable to the JobInformation object

Throws:

IllegalArgumentException - thrown if parameters fail the validation

beginUpdate

JobInformation beginUpdate(String accountName,
                           UUID jobIdentity,
                           UpdateJobParameters parameters)

Updates the job information for the specified job ID. (Only for use internally with Scope job type.).

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

jobIdentity - Job identifier. Uniquely identifies the job across all jobs submitted to the service.

parameters - The parameters to update a job.

Returns:

the JobInformation object if successful.

Throws:

IllegalArgumentException - thrown if parameters fail the validation

CloudException - thrown if the request is rejected by server

RuntimeException - all other wrapped checked exceptions if the request fails to be sent

beginUpdateAsync

ServiceFuture<JobInformation> beginUpdateAsync(String accountName,
                                               UUID jobIdentity,
                                               UpdateJobParameters parameters,
                                               ServiceCallback<JobInformation> serviceCallback)

Updates the job information for the specified job ID. (Only for use internally with Scope job type.).

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

jobIdentity - Job identifier. Uniquely identifies the job across all jobs submitted to the service.

parameters - The parameters to update a job.

serviceCallback - the async ServiceCallback to handle successful and failed responses.

Returns:

the ServiceFuture object

Throws:

IllegalArgumentException - thrown if parameters fail the validation

beginUpdateAsync

rx.Observable<JobInformation> beginUpdateAsync(String accountName,
                                               UUID jobIdentity,
                                               UpdateJobParameters parameters)

Updates the job information for the specified job ID. (Only for use internally with Scope job type.).

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

jobIdentity - Job identifier. Uniquely identifies the job across all jobs submitted to the service.

parameters - The parameters to update a job.

Returns:

the observable to the JobInformation object

Throws:

IllegalArgumentException - thrown if parameters fail the validation

beginUpdateWithServiceResponseAsync

rx.Observable<ServiceResponse<JobInformation>> beginUpdateWithServiceResponseAsync(String accountName,
                                                                                   UUID jobIdentity,
                                                                                   UpdateJobParameters parameters)

Updates the job information for the specified job ID. (Only for use internally with Scope job type.).

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

jobIdentity - Job identifier. Uniquely identifies the job across all jobs submitted to the service.

parameters - The parameters to update a job.

Returns:

the observable to the JobInformation object

Throws:

IllegalArgumentException - thrown if parameters fail the validation

getStatistics

JobStatistics getStatistics(String accountName,
                            UUID jobIdentity)

Gets statistics of the specified job.

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

jobIdentity - Job Information ID.

Returns:

the JobStatistics object if successful.

Throws:

IllegalArgumentException - thrown if parameters fail the validation

CloudException - thrown if the request is rejected by server

RuntimeException - all other wrapped checked exceptions if the request fails to be sent

getStatisticsAsync

ServiceFuture<JobStatistics> getStatisticsAsync(String accountName,
                                                UUID jobIdentity,
                                                ServiceCallback<JobStatistics> serviceCallback)

Gets statistics of the specified job.

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

jobIdentity - Job Information ID.

serviceCallback - the async ServiceCallback to handle successful and failed responses.

Returns:

the ServiceFuture object

Throws:

IllegalArgumentException - thrown if parameters fail the validation

getStatisticsAsync

rx.Observable<JobStatistics> getStatisticsAsync(String accountName,
                                                UUID jobIdentity)

Gets statistics of the specified job.

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

jobIdentity - Job Information ID.

Returns:

the observable to the JobStatistics object

Throws:

IllegalArgumentException - thrown if parameters fail the validation

getStatisticsWithServiceResponseAsync

rx.Observable<ServiceResponse<JobStatistics>> getStatisticsWithServiceResponseAsync(String accountName,
                                                                                    UUID jobIdentity)

Gets statistics of the specified job.

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

jobIdentity - Job Information ID.

Returns:

the observable to the JobStatistics object

Throws:

IllegalArgumentException - thrown if parameters fail the validation

getDebugDataPath

JobDataPath getDebugDataPath(String accountName,
                             UUID jobIdentity)

Gets the job debug data information specified by the job ID.

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

jobIdentity - Job identifier. Uniquely identifies the job across all jobs submitted to the service.

Returns:

the JobDataPath object if successful.

Throws:

IllegalArgumentException - thrown if parameters fail the validation

CloudException - thrown if the request is rejected by server

RuntimeException - all other wrapped checked exceptions if the request fails to be sent

getDebugDataPathAsync

ServiceFuture<JobDataPath> getDebugDataPathAsync(String accountName,
                                                 UUID jobIdentity,
                                                 ServiceCallback<JobDataPath> serviceCallback)

Gets the job debug data information specified by the job ID.

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

jobIdentity - Job identifier. Uniquely identifies the job across all jobs submitted to the service.

serviceCallback - the async ServiceCallback to handle successful and failed responses.

Returns:

the ServiceFuture object

Throws:

IllegalArgumentException - thrown if parameters fail the validation

getDebugDataPathAsync

rx.Observable<JobDataPath> getDebugDataPathAsync(String accountName,
                                                 UUID jobIdentity)

Gets the job debug data information specified by the job ID.

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

jobIdentity - Job identifier. Uniquely identifies the job across all jobs submitted to the service.

Returns:

the observable to the JobDataPath object

Throws:

IllegalArgumentException - thrown if parameters fail the validation

getDebugDataPathWithServiceResponseAsync

rx.Observable<ServiceResponse<JobDataPath>> getDebugDataPathWithServiceResponseAsync(String accountName,
                                                                                     UUID jobIdentity)

Gets the job debug data information specified by the job ID.

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

jobIdentity - Job identifier. Uniquely identifies the job across all jobs submitted to the service.

Returns:

the observable to the JobDataPath object

Throws:

IllegalArgumentException - thrown if parameters fail the validation

cancel

void cancel(String accountName,
            UUID jobIdentity)

Cancels the running job specified by the job ID.

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

jobIdentity - Job identifier. Uniquely identifies the job across all jobs submitted to the service.

Throws:

IllegalArgumentException - thrown if parameters fail the validation

CloudException - thrown if the request is rejected by server

RuntimeException - all other wrapped checked exceptions if the request fails to be sent

cancelAsync

ServiceFuture<Void> cancelAsync(String accountName,
                                UUID jobIdentity,
                                ServiceCallback<Void> serviceCallback)

Cancels the running job specified by the job ID.

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

jobIdentity - Job identifier. Uniquely identifies the job across all jobs submitted to the service.

serviceCallback - the async ServiceCallback to handle successful and failed responses.

Returns:

the ServiceFuture object

Throws:

IllegalArgumentException - thrown if parameters fail the validation

cancelAsync

rx.Observable<Void> cancelAsync(String accountName,
                                UUID jobIdentity)

Cancels the running job specified by the job ID.

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

jobIdentity - Job identifier. Uniquely identifies the job across all jobs submitted to the service.

Returns:

the ServiceResponse object if successful.

Throws:

IllegalArgumentException - thrown if parameters fail the validation

cancelWithServiceResponseAsync

rx.Observable<ServiceResponse<Void>> cancelWithServiceResponseAsync(String accountName,
                                                                    UUID jobIdentity)

Cancels the running job specified by the job ID.

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

jobIdentity - Job identifier. Uniquely identifies the job across all jobs submitted to the service.

Returns:

the ServiceResponse object if successful.

Throws:

IllegalArgumentException - thrown if parameters fail the validation

beginCancel

void beginCancel(String accountName,
                 UUID jobIdentity)

Cancels the running job specified by the job ID.

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

jobIdentity - Job identifier. Uniquely identifies the job across all jobs submitted to the service.

Throws:

IllegalArgumentException - thrown if parameters fail the validation

CloudException - thrown if the request is rejected by server

RuntimeException - all other wrapped checked exceptions if the request fails to be sent

beginCancelAsync

ServiceFuture<Void> beginCancelAsync(String accountName,
                                     UUID jobIdentity,
                                     ServiceCallback<Void> serviceCallback)

Cancels the running job specified by the job ID.

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

jobIdentity - Job identifier. Uniquely identifies the job across all jobs submitted to the service.

serviceCallback - the async ServiceCallback to handle successful and failed responses.

Returns:

the ServiceFuture object

Throws:

IllegalArgumentException - thrown if parameters fail the validation

beginCancelAsync

rx.Observable<Void> beginCancelAsync(String accountName,
                                     UUID jobIdentity)

Cancels the running job specified by the job ID.

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

jobIdentity - Job identifier. Uniquely identifies the job across all jobs submitted to the service.

Returns:

the ServiceResponse object if successful.

Throws:

IllegalArgumentException - thrown if parameters fail the validation

beginCancelWithServiceResponseAsync

rx.Observable<ServiceResponse<Void>> beginCancelWithServiceResponseAsync(String accountName,
                                                                         UUID jobIdentity)

Cancels the running job specified by the job ID.

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

jobIdentity - Job identifier. Uniquely identifies the job across all jobs submitted to the service.

Returns:

the ServiceResponse object if successful.

Throws:

IllegalArgumentException - thrown if parameters fail the validation

yield

void yield(String accountName,
           UUID jobIdentity)

Pauses the specified job and places it back in the job queue, behind other jobs of equal or higher importance, based on priority. (Only for use internally with Scope job type.).

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

jobIdentity - Job identifier. Uniquely identifies the job across all jobs submitted to the service.

Throws:

IllegalArgumentException - thrown if parameters fail the validation

CloudException - thrown if the request is rejected by server

RuntimeException - all other wrapped checked exceptions if the request fails to be sent

yieldAsync

ServiceFuture<Void> yieldAsync(String accountName,
                               UUID jobIdentity,
                               ServiceCallback<Void> serviceCallback)

Pauses the specified job and places it back in the job queue, behind other jobs of equal or higher importance, based on priority. (Only for use internally with Scope job type.).

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

jobIdentity - Job identifier. Uniquely identifies the job across all jobs submitted to the service.

serviceCallback - the async ServiceCallback to handle successful and failed responses.

Returns:

the ServiceFuture object

Throws:

IllegalArgumentException - thrown if parameters fail the validation

yieldAsync

rx.Observable<Void> yieldAsync(String accountName,
                               UUID jobIdentity)

Pauses the specified job and places it back in the job queue, behind other jobs of equal or higher importance, based on priority. (Only for use internally with Scope job type.).

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

jobIdentity - Job identifier. Uniquely identifies the job across all jobs submitted to the service.

Returns:

the ServiceResponse object if successful.

Throws:

IllegalArgumentException - thrown if parameters fail the validation

yieldWithServiceResponseAsync

rx.Observable<ServiceResponse<Void>> yieldWithServiceResponseAsync(String accountName,
                                                                   UUID jobIdentity)

Pauses the specified job and places it back in the job queue, behind other jobs of equal or higher importance, based on priority. (Only for use internally with Scope job type.).

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

jobIdentity - Job identifier. Uniquely identifies the job across all jobs submitted to the service.

Returns:

the ServiceResponse object if successful.

Throws:

IllegalArgumentException - thrown if parameters fail the validation

beginYield

void beginYield(String accountName,
                UUID jobIdentity)

Pauses the specified job and places it back in the job queue, behind other jobs of equal or higher importance, based on priority. (Only for use internally with Scope job type.).

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

jobIdentity - Job identifier. Uniquely identifies the job across all jobs submitted to the service.

Throws:

IllegalArgumentException - thrown if parameters fail the validation

CloudException - thrown if the request is rejected by server

RuntimeException - all other wrapped checked exceptions if the request fails to be sent

beginYieldAsync

ServiceFuture<Void> beginYieldAsync(String accountName,
                                    UUID jobIdentity,
                                    ServiceCallback<Void> serviceCallback)

Pauses the specified job and places it back in the job queue, behind other jobs of equal or higher importance, based on priority. (Only for use internally with Scope job type.).

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

jobIdentity - Job identifier. Uniquely identifies the job across all jobs submitted to the service.

serviceCallback - the async ServiceCallback to handle successful and failed responses.

Returns:

the ServiceFuture object

Throws:

IllegalArgumentException - thrown if parameters fail the validation

beginYieldAsync

rx.Observable<Void> beginYieldAsync(String accountName,
                                    UUID jobIdentity)

Pauses the specified job and places it back in the job queue, behind other jobs of equal or higher importance, based on priority. (Only for use internally with Scope job type.).

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

jobIdentity - Job identifier. Uniquely identifies the job across all jobs submitted to the service.

Returns:

the ServiceResponse object if successful.

Throws:

IllegalArgumentException - thrown if parameters fail the validation

beginYieldWithServiceResponseAsync

rx.Observable<ServiceResponse<Void>> beginYieldWithServiceResponseAsync(String accountName,
                                                                        UUID jobIdentity)

Pauses the specified job and places it back in the job queue, behind other jobs of equal or higher importance, based on priority. (Only for use internally with Scope job type.).

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

jobIdentity - Job identifier. Uniquely identifies the job across all jobs submitted to the service.

Returns:

the ServiceResponse object if successful.

Throws:

IllegalArgumentException - thrown if parameters fail the validation

build

JobInformation build(String accountName,
                     BuildJobParameters parameters)

Builds (compiles) the specified job in the specified Data Lake Analytics account for job correctness and validation.

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

parameters - The parameters to build a job.

Returns:

the JobInformation object if successful.

Throws:

IllegalArgumentException - thrown if parameters fail the validation

CloudException - thrown if the request is rejected by server

RuntimeException - all other wrapped checked exceptions if the request fails to be sent

buildAsync

ServiceFuture<JobInformation> buildAsync(String accountName,
                                         BuildJobParameters parameters,
                                         ServiceCallback<JobInformation> serviceCallback)

Builds (compiles) the specified job in the specified Data Lake Analytics account for job correctness and validation.

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

parameters - The parameters to build a job.

serviceCallback - the async ServiceCallback to handle successful and failed responses.

Returns:

the ServiceFuture object

Throws:

IllegalArgumentException - thrown if parameters fail the validation

buildAsync

rx.Observable<JobInformation> buildAsync(String accountName,
                                         BuildJobParameters parameters)

Builds (compiles) the specified job in the specified Data Lake Analytics account for job correctness and validation.

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

parameters - The parameters to build a job.

Returns:

the observable to the JobInformation object

Throws:

IllegalArgumentException - thrown if parameters fail the validation

buildWithServiceResponseAsync

rx.Observable<ServiceResponse<JobInformation>> buildWithServiceResponseAsync(String accountName,
                                                                             BuildJobParameters parameters)

Builds (compiles) the specified job in the specified Data Lake Analytics account for job correctness and validation.

Parameters:

accountName - The Azure Data Lake Analytics account to execute job operations on.

parameters - The parameters to build a job.

Returns:

the observable to the JobInformation object

Throws:

IllegalArgumentException - thrown if parameters fail the validation

listNext

PagedList<JobInformationBasic> listNext(String nextPageLink)

Lists the jobs, if any, associated with the specified Data Lake Analytics account. The response includes a link to the next page of results, if any.

Parameters:

nextPageLink - The NextLink from the previous successful call to List operation.

Returns:

the PagedList<JobInformationBasic> object if successful.

Throws:

IllegalArgumentException - thrown if parameters fail the validation

CloudException - thrown if the request is rejected by server

RuntimeException - all other wrapped checked exceptions if the request fails to be sent

listNextAsync

ServiceFuture<List<JobInformationBasic>> listNextAsync(String nextPageLink,
                                                       ServiceFuture<List<JobInformationBasic>> serviceFuture,
                                                       ListOperationCallback<JobInformationBasic> serviceCallback)

Lists the jobs, if any, associated with the specified Data Lake Analytics account. The response includes a link to the next page of results, if any.

Parameters:

nextPageLink - The NextLink from the previous successful call to List operation.

serviceFuture - the ServiceFuture object tracking the Retrofit calls

serviceCallback - the async ServiceCallback to handle successful and failed responses.

Returns:

the ServiceFuture object

Throws:

IllegalArgumentException - thrown if parameters fail the validation

listNextAsync

rx.Observable<Page<JobInformationBasic>> listNextAsync(String nextPageLink)

Lists the jobs, if any, associated with the specified Data Lake Analytics account. The response includes a link to the next page of results, if any.

Parameters:

nextPageLink - The NextLink from the previous successful call to List operation.

Returns:

the observable to the PagedList<JobInformationBasic> object

Throws:

IllegalArgumentException - thrown if parameters fail the validation

listNextWithServiceResponseAsync

rx.Observable<ServiceResponse<Page<JobInformationBasic>>> listNextWithServiceResponseAsync(String nextPageLink)

Lists the jobs, if any, associated with the specified Data Lake Analytics account. The response includes a link to the next page of results, if any.

Parameters:

nextPageLink - The NextLink from the previous successful call to List operation.

Returns:

the observable to the PagedList<JobInformationBasic> object

Throws:

IllegalArgumentException - thrown if parameters fail the validation