Package 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 Details

    • list

      com.microsoft.azure.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
      com.microsoft.azure.CloudException - thrown if the request is rejected by server
      RuntimeException - all other wrapped checked exceptions if the request fails to be sent

    • listAsync

      com.microsoft.rest.ServiceFuture<List<JobPipelineInformation>> listAsync(String accountName, com.microsoft.azure.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<com.microsoft.azure.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<com.microsoft.rest.ServiceResponse<com.microsoft.azure.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

      com.microsoft.azure.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
      com.microsoft.azure.CloudException - thrown if the request is rejected by server
      RuntimeException - all other wrapped checked exceptions if the request fails to be sent

    • listAsync

      com.microsoft.rest.ServiceFuture<List<JobPipelineInformation>> listAsync(String accountName, org.joda.time.DateTime startDateTime, org.joda.time.DateTime endDateTime, com.microsoft.azure.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<com.microsoft.azure.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<com.microsoft.rest.ServiceResponse<com.microsoft.azure.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
      com.microsoft.azure.CloudException - thrown if the request is rejected by server
      RuntimeException - all other wrapped checked exceptions if the request fails to be sent

    • getAsync

      com.microsoft.rest.ServiceFuture<JobPipelineInformation> getAsync(String accountName, UUID pipelineIdentity, com.microsoft.rest.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<com.microsoft.rest.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
      com.microsoft.azure.CloudException - thrown if the request is rejected by server
      RuntimeException - all other wrapped checked exceptions if the request fails to be sent

    • getAsync

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

      com.microsoft.azure.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
      com.microsoft.azure.CloudException - thrown if the request is rejected by server
      RuntimeException - all other wrapped checked exceptions if the request fails to be sent

    • listNextAsync

      com.microsoft.rest.ServiceFuture<List<JobPipelineInformation>> listNextAsync(String nextPageLink, com.microsoft.rest.ServiceFuture<List<JobPipelineInformation>> serviceFuture, com.microsoft.azure.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<com.microsoft.azure.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<com.microsoft.rest.ServiceResponse<com.microsoft.azure.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