com.microsoft.azure.management.datalake.analytics

Interface Pipelines

public interface Pipelines

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

Method Summary

Modifier and Type	Method and Description
JobPipelineInformation	get(String accountName, UUID pipelineIdentity) Gets the Pipeline information for the specified pipeline ID.
JobPipelineInformation	get(String accountName, UUID pipelineIdentity, org.joda.time.DateTime startDateTime, org.joda.time.DateTime endDateTime) Gets the Pipeline information for the specified pipeline ID.
rx.Observable<JobPipelineInformation>	getAsync(String accountName, UUID pipelineIdentity) Gets the Pipeline information for the specified pipeline ID.
rx.Observable<JobPipelineInformation>	getAsync(String accountName, UUID pipelineIdentity, org.joda.time.DateTime startDateTime, org.joda.time.DateTime endDateTime) Gets the Pipeline information for the specified pipeline ID.
ServiceFuture<JobPipelineInformation>	getAsync(String accountName, UUID pipelineIdentity, org.joda.time.DateTime startDateTime, org.joda.time.DateTime endDateTime, ServiceCallback<JobPipelineInformation> serviceCallback) Gets the Pipeline information for the specified pipeline ID.
ServiceFuture<JobPipelineInformation>	getAsync(String accountName, UUID pipelineIdentity, ServiceCallback<JobPipelineInformation> serviceCallback) Gets the Pipeline information for the specified pipeline ID.
rx.Observable<ServiceResponse<JobPipelineInformation>>	getWithServiceResponseAsync(String accountName, UUID pipelineIdentity) Gets the Pipeline information for the specified pipeline ID.
rx.Observable<ServiceResponse<JobPipelineInformation>>	getWithServiceResponseAsync(String accountName, UUID pipelineIdentity, org.joda.time.DateTime startDateTime, org.joda.time.DateTime endDateTime) Gets the Pipeline information for the specified pipeline ID.
PagedList<JobPipelineInformation>	list(String accountName) Lists all pipelines.
PagedList<JobPipelineInformation>	list(String accountName, org.joda.time.DateTime startDateTime, org.joda.time.DateTime endDateTime) Lists all pipelines.
rx.Observable<Page<JobPipelineInformation>>	listAsync(String accountName) Lists all pipelines.
rx.Observable<Page<JobPipelineInformation>>	listAsync(String accountName, org.joda.time.DateTime startDateTime, org.joda.time.DateTime endDateTime) Lists all pipelines.
ServiceFuture<List<JobPipelineInformation>>	listAsync(String accountName, org.joda.time.DateTime startDateTime, org.joda.time.DateTime endDateTime, ListOperationCallback<JobPipelineInformation> serviceCallback) Lists all pipelines.
ServiceFuture<List<JobPipelineInformation>>	listAsync(String accountName, ListOperationCallback<JobPipelineInformation> serviceCallback) Lists all pipelines.
PagedList<JobPipelineInformation>	listNext(String nextPageLink) Lists all pipelines.
rx.Observable<Page<JobPipelineInformation>>	listNextAsync(String nextPageLink) Lists all pipelines.
ServiceFuture<List<JobPipelineInformation>>	listNextAsync(String nextPageLink, ServiceFuture<List<JobPipelineInformation>> serviceFuture, ListOperationCallback<JobPipelineInformation> serviceCallback) Lists all pipelines.
rx.Observable<ServiceResponse<Page<JobPipelineInformation>>>	listNextWithServiceResponseAsync(String nextPageLink) Lists all pipelines.
rx.Observable<ServiceResponse<Page<JobPipelineInformation>>>	listWithServiceResponseAsync(String accountName) Lists all pipelines.
rx.Observable<ServiceResponse<Page<JobPipelineInformation>>>	listWithServiceResponseAsync(String accountName, org.joda.time.DateTime startDateTime, org.joda.time.DateTime endDateTime) Lists all pipelines.

Method Detail

list

PagedList<JobPipelineInformation> list(String accountName)

Lists all pipelines.

Parameters:

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

Returns:

the PagedList<JobPipelineInformation> 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<JobPipelineInformation>> listAsync(String accountName,
                                                      ListOperationCallback<JobPipelineInformation> serviceCallback)

Lists all pipelines.

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<JobPipelineInformation>> listAsync(String accountName)

Lists all pipelines.

Parameters:

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

Returns:

the observable to the PagedList<JobPipelineInformation> object

Throws:

IllegalArgumentException - thrown if parameters fail the validation

listWithServiceResponseAsync

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

Lists all pipelines.

Parameters:

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

Returns:

the observable to the PagedList<JobPipelineInformation> object

Throws:

IllegalArgumentException - thrown if parameters fail the validation

list

PagedList<JobPipelineInformation> list(String accountName,
                                       org.joda.time.DateTime startDateTime,
                                       org.joda.time.DateTime endDateTime)

Lists all pipelines.

Parameters:

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

startDateTime - The start date for when to get the list of pipelines. The startDateTime and endDateTime can be no more than 30 days apart.

endDateTime - The end date for when to get the list of pipelines. The startDateTime and endDateTime can be no more than 30 days apart.

Returns:

the PagedList<JobPipelineInformation> 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<JobPipelineInformation>> listAsync(String accountName,
                                                      org.joda.time.DateTime startDateTime,
                                                      org.joda.time.DateTime endDateTime,
                                                      ListOperationCallback<JobPipelineInformation> serviceCallback)

Lists all pipelines.

Parameters:

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

startDateTime - The start date for when to get the list of pipelines. The startDateTime and endDateTime can be no more than 30 days apart.

endDateTime - The end date for when to get the list of pipelines. The startDateTime and endDateTime can be no more than 30 days apart.

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<JobPipelineInformation>> listAsync(String accountName,
                                                      org.joda.time.DateTime startDateTime,
                                                      org.joda.time.DateTime endDateTime)

Lists all pipelines.

Parameters:

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

startDateTime - The start date for when to get the list of pipelines. The startDateTime and endDateTime can be no more than 30 days apart.

endDateTime - The end date for when to get the list of pipelines. The startDateTime and endDateTime can be no more than 30 days apart.

Returns:

the observable to the PagedList<JobPipelineInformation> object

Throws:

IllegalArgumentException - thrown if parameters fail the validation

listWithServiceResponseAsync

rx.Observable<ServiceResponse<Page<JobPipelineInformation>>> listWithServiceResponseAsync(String accountName,
                                                                                          org.joda.time.DateTime startDateTime,
                                                                                          org.joda.time.DateTime endDateTime)

Lists all pipelines.

Parameters:

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

startDateTime - The start date for when to get the list of pipelines. The startDateTime and endDateTime can be no more than 30 days apart.

endDateTime - The end date for when to get the list of pipelines. The startDateTime and endDateTime can be no more than 30 days apart.

Returns:

the observable to the PagedList<JobPipelineInformation> object

Throws:

IllegalArgumentException - thrown if parameters fail the validation

get

JobPipelineInformation get(String accountName,
                           UUID pipelineIdentity)

Gets the Pipeline information for the specified pipeline ID.

Parameters:

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

pipelineIdentity - Pipeline ID.

Returns:

the JobPipelineInformation 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<JobPipelineInformation> getAsync(String accountName,
                                               UUID pipelineIdentity,
                                               ServiceCallback<JobPipelineInformation> serviceCallback)

Gets the Pipeline information for the specified pipeline ID.

Parameters:

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

pipelineIdentity - Pipeline 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<JobPipelineInformation> getAsync(String accountName,
                                               UUID pipelineIdentity)

Gets the Pipeline information for the specified pipeline ID.

Parameters:

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

pipelineIdentity - Pipeline ID.

Returns:

the observable to the JobPipelineInformation object

Throws:

IllegalArgumentException - thrown if parameters fail the validation

getWithServiceResponseAsync

rx.Observable<ServiceResponse<JobPipelineInformation>> getWithServiceResponseAsync(String accountName,
                                                                                   UUID pipelineIdentity)

Gets the Pipeline information for the specified pipeline ID.

Parameters:

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

pipelineIdentity - Pipeline ID.

Returns:

the observable to the JobPipelineInformation object

Throws:

IllegalArgumentException - thrown if parameters fail the validation

get

JobPipelineInformation get(String accountName,
                           UUID pipelineIdentity,
                           org.joda.time.DateTime startDateTime,
                           org.joda.time.DateTime endDateTime)

Gets the Pipeline information for the specified pipeline ID.

Parameters:

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

pipelineIdentity - Pipeline ID.

startDateTime - The start date for when to get the pipeline and aggregate its data. The startDateTime and endDateTime can be no more than 30 days apart.

endDateTime - The end date for when to get the pipeline and aggregate its data. The startDateTime and endDateTime can be no more than 30 days apart.

Returns:

the JobPipelineInformation 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<JobPipelineInformation> getAsync(String accountName,
                                               UUID pipelineIdentity,
                                               org.joda.time.DateTime startDateTime,
                                               org.joda.time.DateTime endDateTime,
                                               ServiceCallback<JobPipelineInformation> serviceCallback)

Gets the Pipeline information for the specified pipeline ID.

Parameters:

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

pipelineIdentity - Pipeline ID.

startDateTime - The start date for when to get the pipeline and aggregate its data. The startDateTime and endDateTime can be no more than 30 days apart.

endDateTime - The end date for when to get the pipeline and aggregate its data. The startDateTime and endDateTime can be no more than 30 days apart.

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<JobPipelineInformation> getAsync(String accountName,
                                               UUID pipelineIdentity,
                                               org.joda.time.DateTime startDateTime,
                                               org.joda.time.DateTime endDateTime)

Gets the Pipeline information for the specified pipeline ID.

Parameters:

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

pipelineIdentity - Pipeline ID.

startDateTime - The start date for when to get the pipeline and aggregate its data. The startDateTime and endDateTime can be no more than 30 days apart.

endDateTime - The end date for when to get the pipeline and aggregate its data. The startDateTime and endDateTime can be no more than 30 days apart.

Returns:

the observable to the JobPipelineInformation object

Throws:

IllegalArgumentException - thrown if parameters fail the validation

getWithServiceResponseAsync

rx.Observable<ServiceResponse<JobPipelineInformation>> getWithServiceResponseAsync(String accountName,
                                                                                   UUID pipelineIdentity,
                                                                                   org.joda.time.DateTime startDateTime,
                                                                                   org.joda.time.DateTime endDateTime)

Gets the Pipeline information for the specified pipeline ID.

Parameters:

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

pipelineIdentity - Pipeline ID.

startDateTime - The start date for when to get the pipeline and aggregate its data. The startDateTime and endDateTime can be no more than 30 days apart.

endDateTime - The end date for when to get the pipeline and aggregate its data. The startDateTime and endDateTime can be no more than 30 days apart.

Returns:

the observable to the JobPipelineInformation object

Throws:

IllegalArgumentException - thrown if parameters fail the validation

listNext

PagedList<JobPipelineInformation> listNext(String nextPageLink)

Lists all pipelines.

Parameters:

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

Returns:

the PagedList<JobPipelineInformation> 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<JobPipelineInformation>> listNextAsync(String nextPageLink,
                                                          ServiceFuture<List<JobPipelineInformation>> serviceFuture,
                                                          ListOperationCallback<JobPipelineInformation> serviceCallback)

Lists all pipelines.

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<JobPipelineInformation>> listNextAsync(String nextPageLink)

Lists all pipelines.

Parameters:

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

Returns:

the observable to the PagedList<JobPipelineInformation> object

Throws:

IllegalArgumentException - thrown if parameters fail the validation

listNextWithServiceResponseAsync

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

Lists all pipelines.

Parameters:

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

Returns:

the observable to the PagedList<JobPipelineInformation> object

Throws:

IllegalArgumentException - thrown if parameters fail the validation