Class LiveVideoAnalyticsClient

java.lang.Object
com.google.cloud.visionai.v1.LiveVideoAnalyticsClient
All Implemented Interfaces:
BackgroundResource, AutoCloseable

@Generated("by gapic-generator-java") public class LiveVideoAnalyticsClient extends Object implements BackgroundResource
Service Description: Service describing handlers for resources. The service enables clients to run Live Video Analytics (LVA) on the streaming inputs.

This class provides the ability to make remote calls to the backing service through method calls that map to API methods. Sample code to get started:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
   LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
   List<OperatorQuery> queries = new ArrayList<>();
   ResolveOperatorInfoResponse response =
       liveVideoAnalyticsClient.resolveOperatorInfo(parent, queries);
 }
 

Note: close() needs to be called on the LiveVideoAnalyticsClient object to clean up resources such as threads. In the example above, try-with-resources is used, which automatically calls close().

Methods
Method Description Method Variants

ListPublicOperators

ListPublicOperators returns all the operators in public registry.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • listPublicOperators(ListPublicOperatorsRequest request)

"Flattened" method variants have converted the fields of the request object into function parameters to enable multiple ways to call the same method.

  • listPublicOperators(LocationName parent)

  • listPublicOperators(String parent)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • listPublicOperatorsPagedCallable()

  • listPublicOperatorsCallable()

ResolveOperatorInfo

ResolveOperatorInfo returns the operator information based on the request.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • resolveOperatorInfo(ResolveOperatorInfoRequest request)

"Flattened" method variants have converted the fields of the request object into function parameters to enable multiple ways to call the same method.

  • resolveOperatorInfo(LocationName parent, List<OperatorQuery> queries)

  • resolveOperatorInfo(String parent, List<OperatorQuery> queries)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • resolveOperatorInfoCallable()

ListOperators

Lists Operators in a given project and location.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • listOperators(ListOperatorsRequest request)

"Flattened" method variants have converted the fields of the request object into function parameters to enable multiple ways to call the same method.

  • listOperators(LocationName parent)

  • listOperators(String parent)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • listOperatorsPagedCallable()

  • listOperatorsCallable()

GetOperator

Gets details of a single Operator.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • getOperator(GetOperatorRequest request)

"Flattened" method variants have converted the fields of the request object into function parameters to enable multiple ways to call the same method.

  • getOperator(OperatorName name)

  • getOperator(String name)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • getOperatorCallable()

CreateOperator

Creates a new Operator in a given project and location.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • createOperatorAsync(CreateOperatorRequest request)

Methods that return long-running operations have "Async" method variants that return `OperationFuture`, which is used to track polling of the service.

  • createOperatorAsync(LocationName parent, Operator operator, String operatorId)

  • createOperatorAsync(String parent, Operator operator, String operatorId)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • createOperatorOperationCallable()

  • createOperatorCallable()

UpdateOperator

Updates the parameters of a single Operator.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • updateOperatorAsync(UpdateOperatorRequest request)

Methods that return long-running operations have "Async" method variants that return `OperationFuture`, which is used to track polling of the service.

  • updateOperatorAsync(Operator operator, FieldMask updateMask)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • updateOperatorOperationCallable()

  • updateOperatorCallable()

DeleteOperator

Deletes a single Operator.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • deleteOperatorAsync(DeleteOperatorRequest request)

Methods that return long-running operations have "Async" method variants that return `OperationFuture`, which is used to track polling of the service.

  • deleteOperatorAsync(OperatorName name)

  • deleteOperatorAsync(String name)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • deleteOperatorOperationCallable()

  • deleteOperatorCallable()

ListAnalyses

Lists Analyses in a given project and location.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • listAnalyses(ListAnalysesRequest request)

"Flattened" method variants have converted the fields of the request object into function parameters to enable multiple ways to call the same method.

  • listAnalyses(ClusterName parent)

  • listAnalyses(String parent)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • listAnalysesPagedCallable()

  • listAnalysesCallable()

GetAnalysis

Gets details of a single Analysis.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • getAnalysis(GetAnalysisRequest request)

"Flattened" method variants have converted the fields of the request object into function parameters to enable multiple ways to call the same method.

  • getAnalysis(AnalysisName name)

  • getAnalysis(String name)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • getAnalysisCallable()

CreateAnalysis

Creates a new Analysis in a given project and location.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • createAnalysisAsync(CreateAnalysisRequest request)

Methods that return long-running operations have "Async" method variants that return `OperationFuture`, which is used to track polling of the service.

  • createAnalysisAsync(ClusterName parent, Analysis analysis, String analysisId)

  • createAnalysisAsync(String parent, Analysis analysis, String analysisId)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • createAnalysisOperationCallable()

  • createAnalysisCallable()

UpdateAnalysis

Updates the parameters of a single Analysis.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • updateAnalysisAsync(UpdateAnalysisRequest request)

Methods that return long-running operations have "Async" method variants that return `OperationFuture`, which is used to track polling of the service.

  • updateAnalysisAsync(Analysis analysis, FieldMask updateMask)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • updateAnalysisOperationCallable()

  • updateAnalysisCallable()

DeleteAnalysis

Deletes a single Analysis.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • deleteAnalysisAsync(DeleteAnalysisRequest request)

Methods that return long-running operations have "Async" method variants that return `OperationFuture`, which is used to track polling of the service.

  • deleteAnalysisAsync(AnalysisName name)

  • deleteAnalysisAsync(String name)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • deleteAnalysisOperationCallable()

  • deleteAnalysisCallable()

ListProcesses

Lists Processes in a given project and location.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • listProcesses(ListProcessesRequest request)

"Flattened" method variants have converted the fields of the request object into function parameters to enable multiple ways to call the same method.

  • listProcesses(ClusterName parent)

  • listProcesses(String parent)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • listProcessesPagedCallable()

  • listProcessesCallable()

GetProcess

Gets details of a single Process.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • getProcess(GetProcessRequest request)

"Flattened" method variants have converted the fields of the request object into function parameters to enable multiple ways to call the same method.

  • getProcess(ProcessName name)

  • getProcess(String name)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • getProcessCallable()

CreateProcess

Creates a new Process in a given project and location.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • createProcessAsync(CreateProcessRequest request)

Methods that return long-running operations have "Async" method variants that return `OperationFuture`, which is used to track polling of the service.

  • createProcessAsync(ClusterName parent, Process process, String processId)

  • createProcessAsync(String parent, Process process, String processId)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • createProcessOperationCallable()

  • createProcessCallable()

UpdateProcess

Updates the parameters of a single Process.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • updateProcessAsync(UpdateProcessRequest request)

Methods that return long-running operations have "Async" method variants that return `OperationFuture`, which is used to track polling of the service.

  • updateProcessAsync(Process process, FieldMask updateMask)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • updateProcessOperationCallable()

  • updateProcessCallable()

DeleteProcess

Deletes a single Process.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • deleteProcessAsync(DeleteProcessRequest request)

Methods that return long-running operations have "Async" method variants that return `OperationFuture`, which is used to track polling of the service.

  • deleteProcessAsync(ProcessName name)

  • deleteProcessAsync(String name)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • deleteProcessOperationCallable()

  • deleteProcessCallable()

BatchRunProcess

Run all of the processes to "completion". Max time for each process is the LRO time limit.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • batchRunProcessAsync(ClusterName parent, List<CreateProcessRequest> requests)

  • batchRunProcessAsync(String parent, List<CreateProcessRequest> requests)

  • batchRunProcessAsync(BatchRunProcessRequest request)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • batchRunProcessOperationCallable()

  • batchRunProcessCallable()

ListLocations

Lists information about the supported locations for this service.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • listLocations(ListLocationsRequest request)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • listLocationsPagedCallable()

  • listLocationsCallable()

GetLocation

Gets information about a location.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • getLocation(GetLocationRequest request)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • getLocationCallable()

See the individual methods for example code.

Many parameters require resource names to be formatted in a particular way. To assist with these names, this class includes a format method for each type of name, and additionally a parse method to extract the individual identifiers contained within names that are returned.

This class can be customized by passing in a custom instance of LiveVideoAnalyticsSettings to create(). For example:

To customize credentials:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 LiveVideoAnalyticsSettings liveVideoAnalyticsSettings =
     LiveVideoAnalyticsSettings.newBuilder()
         .setCredentialsProvider(FixedCredentialsProvider.create(myCredentials))
         .build();
 LiveVideoAnalyticsClient liveVideoAnalyticsClient =
     LiveVideoAnalyticsClient.create(liveVideoAnalyticsSettings);
 

To customize the endpoint:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 LiveVideoAnalyticsSettings liveVideoAnalyticsSettings =
     LiveVideoAnalyticsSettings.newBuilder().setEndpoint(myEndpoint).build();
 LiveVideoAnalyticsClient liveVideoAnalyticsClient =
     LiveVideoAnalyticsClient.create(liveVideoAnalyticsSettings);
 

To use REST (HTTP1.1/JSON) transport (instead of gRPC) for sending and receiving requests over the wire:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 LiveVideoAnalyticsSettings liveVideoAnalyticsSettings =
     LiveVideoAnalyticsSettings.newHttpJsonBuilder().build();
 LiveVideoAnalyticsClient liveVideoAnalyticsClient =
     LiveVideoAnalyticsClient.create(liveVideoAnalyticsSettings);
 

Please refer to the GitHub repository's samples for more quickstart code snippets.

  • Constructor Details

    • LiveVideoAnalyticsClient

      protected LiveVideoAnalyticsClient(LiveVideoAnalyticsSettings settings) throws IOException
      Constructs an instance of LiveVideoAnalyticsClient, using the given settings. This is protected so that it is easy to make a subclass, but otherwise, the static factory methods should be preferred.
      Throws:
      IOException
    • LiveVideoAnalyticsClient

      protected LiveVideoAnalyticsClient(LiveVideoAnalyticsStub stub)
  • Method Details

    • create

      public static final LiveVideoAnalyticsClient create() throws IOException
      Constructs an instance of LiveVideoAnalyticsClient with default settings.
      Throws:
      IOException
    • create

      public static final LiveVideoAnalyticsClient create(LiveVideoAnalyticsSettings settings) throws IOException
      Constructs an instance of LiveVideoAnalyticsClient, using the given settings. The channels are created based on the settings passed in, or defaults for any settings that are not set.
      Throws:
      IOException
    • create

      public static final LiveVideoAnalyticsClient create(LiveVideoAnalyticsStub stub)
      Constructs an instance of LiveVideoAnalyticsClient, using the given stub for making calls. This is for advanced usage - prefer using create(LiveVideoAnalyticsSettings).
    • getSettings

      public final LiveVideoAnalyticsSettings getSettings()
    • getStub

      public LiveVideoAnalyticsStub getStub()
    • getOperationsClient

      public final OperationsClient getOperationsClient()
      Returns the OperationsClient that can be used to query the status of a long-running operation returned by another API method call.
    • getHttpJsonOperationsClient

      @BetaApi public final OperationsClient getHttpJsonOperationsClient()
      Returns the OperationsClient that can be used to query the status of a long-running operation returned by another API method call.
    • listPublicOperators

      ListPublicOperators returns all the operators in public registry.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
         for (Operator element : liveVideoAnalyticsClient.listPublicOperators(parent).iterateAll()) {
           // doThingsWith(element);
         }
       }
       
      Parameters:
      parent - Required. Parent value for ListPublicOperatorsRequest.
      Throws:
      ApiException - if the remote call fails
    • listPublicOperators

      public final LiveVideoAnalyticsClient.ListPublicOperatorsPagedResponse listPublicOperators(String parent)
      ListPublicOperators returns all the operators in public registry.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
         for (Operator element : liveVideoAnalyticsClient.listPublicOperators(parent).iterateAll()) {
           // doThingsWith(element);
         }
       }
       
      Parameters:
      parent - Required. Parent value for ListPublicOperatorsRequest.
      Throws:
      ApiException - if the remote call fails
    • listPublicOperators

      ListPublicOperators returns all the operators in public registry.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         ListPublicOperatorsRequest request =
             ListPublicOperatorsRequest.newBuilder()
                 .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
                 .setPageSize(883849137)
                 .setPageToken("pageToken873572522")
                 .setFilter("filter-1274492040")
                 .setOrderBy("orderBy-1207110587")
                 .build();
         for (Operator element : liveVideoAnalyticsClient.listPublicOperators(request).iterateAll()) {
           // doThingsWith(element);
         }
       }
       
      Parameters:
      request - The request object containing all of the parameters for the API call.
      Throws:
      ApiException - if the remote call fails
    • listPublicOperatorsPagedCallable

      ListPublicOperators returns all the operators in public registry.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         ListPublicOperatorsRequest request =
             ListPublicOperatorsRequest.newBuilder()
                 .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
                 .setPageSize(883849137)
                 .setPageToken("pageToken873572522")
                 .setFilter("filter-1274492040")
                 .setOrderBy("orderBy-1207110587")
                 .build();
         ApiFuture<Operator> future =
             liveVideoAnalyticsClient.listPublicOperatorsPagedCallable().futureCall(request);
         // Do something.
         for (Operator element : future.get().iterateAll()) {
           // doThingsWith(element);
         }
       }
       
    • listPublicOperatorsCallable

      public final UnaryCallable<ListPublicOperatorsRequest,ListPublicOperatorsResponse> listPublicOperatorsCallable()
      ListPublicOperators returns all the operators in public registry.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         ListPublicOperatorsRequest request =
             ListPublicOperatorsRequest.newBuilder()
                 .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
                 .setPageSize(883849137)
                 .setPageToken("pageToken873572522")
                 .setFilter("filter-1274492040")
                 .setOrderBy("orderBy-1207110587")
                 .build();
         while (true) {
           ListPublicOperatorsResponse response =
               liveVideoAnalyticsClient.listPublicOperatorsCallable().call(request);
           for (Operator element : response.getOperatorsList()) {
             // doThingsWith(element);
           }
           String nextPageToken = response.getNextPageToken();
           if (!Strings.isNullOrEmpty(nextPageToken)) {
             request = request.toBuilder().setPageToken(nextPageToken).build();
           } else {
             break;
           }
         }
       }
       
    • resolveOperatorInfo

      public final ResolveOperatorInfoResponse resolveOperatorInfo(LocationName parent, List<OperatorQuery> queries)
      ResolveOperatorInfo returns the operator information based on the request.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
         List<OperatorQuery> queries = new ArrayList<>();
         ResolveOperatorInfoResponse response =
             liveVideoAnalyticsClient.resolveOperatorInfo(parent, queries);
       }
       
      Parameters:
      parent - Required. Parent value for ResolveOperatorInfoRequest.
      queries - Required. The operator queries.
      Throws:
      ApiException - if the remote call fails
    • resolveOperatorInfo

      public final ResolveOperatorInfoResponse resolveOperatorInfo(String parent, List<OperatorQuery> queries)
      ResolveOperatorInfo returns the operator information based on the request.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
         List<OperatorQuery> queries = new ArrayList<>();
         ResolveOperatorInfoResponse response =
             liveVideoAnalyticsClient.resolveOperatorInfo(parent, queries);
       }
       
      Parameters:
      parent - Required. Parent value for ResolveOperatorInfoRequest.
      queries - Required. The operator queries.
      Throws:
      ApiException - if the remote call fails
    • resolveOperatorInfo

      public final ResolveOperatorInfoResponse resolveOperatorInfo(ResolveOperatorInfoRequest request)
      ResolveOperatorInfo returns the operator information based on the request.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         ResolveOperatorInfoRequest request =
             ResolveOperatorInfoRequest.newBuilder()
                 .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
                 .addAllQueries(new ArrayList<OperatorQuery>())
                 .build();
         ResolveOperatorInfoResponse response = liveVideoAnalyticsClient.resolveOperatorInfo(request);
       }
       
      Parameters:
      request - The request object containing all of the parameters for the API call.
      Throws:
      ApiException - if the remote call fails
    • resolveOperatorInfoCallable

      public final UnaryCallable<ResolveOperatorInfoRequest,ResolveOperatorInfoResponse> resolveOperatorInfoCallable()
      ResolveOperatorInfo returns the operator information based on the request.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         ResolveOperatorInfoRequest request =
             ResolveOperatorInfoRequest.newBuilder()
                 .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
                 .addAllQueries(new ArrayList<OperatorQuery>())
                 .build();
         ApiFuture<ResolveOperatorInfoResponse> future =
             liveVideoAnalyticsClient.resolveOperatorInfoCallable().futureCall(request);
         // Do something.
         ResolveOperatorInfoResponse response = future.get();
       }
       
    • listOperators

      Lists Operators in a given project and location.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
         for (Operator element : liveVideoAnalyticsClient.listOperators(parent).iterateAll()) {
           // doThingsWith(element);
         }
       }
       
      Parameters:
      parent - Required. Parent value for ListOperatorsRequest.
      Throws:
      ApiException - if the remote call fails
    • listOperators

      public final LiveVideoAnalyticsClient.ListOperatorsPagedResponse listOperators(String parent)
      Lists Operators in a given project and location.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
         for (Operator element : liveVideoAnalyticsClient.listOperators(parent).iterateAll()) {
           // doThingsWith(element);
         }
       }
       
      Parameters:
      parent - Required. Parent value for ListOperatorsRequest.
      Throws:
      ApiException - if the remote call fails
    • listOperators

      Lists Operators in a given project and location.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         ListOperatorsRequest request =
             ListOperatorsRequest.newBuilder()
                 .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
                 .setPageSize(883849137)
                 .setPageToken("pageToken873572522")
                 .setFilter("filter-1274492040")
                 .setOrderBy("orderBy-1207110587")
                 .build();
         for (Operator element : liveVideoAnalyticsClient.listOperators(request).iterateAll()) {
           // doThingsWith(element);
         }
       }
       
      Parameters:
      request - The request object containing all of the parameters for the API call.
      Throws:
      ApiException - if the remote call fails
    • listOperatorsPagedCallable

      Lists Operators in a given project and location.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         ListOperatorsRequest request =
             ListOperatorsRequest.newBuilder()
                 .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
                 .setPageSize(883849137)
                 .setPageToken("pageToken873572522")
                 .setFilter("filter-1274492040")
                 .setOrderBy("orderBy-1207110587")
                 .build();
         ApiFuture<Operator> future =
             liveVideoAnalyticsClient.listOperatorsPagedCallable().futureCall(request);
         // Do something.
         for (Operator element : future.get().iterateAll()) {
           // doThingsWith(element);
         }
       }
       
    • listOperatorsCallable

      public final UnaryCallable<ListOperatorsRequest,ListOperatorsResponse> listOperatorsCallable()
      Lists Operators in a given project and location.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         ListOperatorsRequest request =
             ListOperatorsRequest.newBuilder()
                 .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
                 .setPageSize(883849137)
                 .setPageToken("pageToken873572522")
                 .setFilter("filter-1274492040")
                 .setOrderBy("orderBy-1207110587")
                 .build();
         while (true) {
           ListOperatorsResponse response =
               liveVideoAnalyticsClient.listOperatorsCallable().call(request);
           for (Operator element : response.getOperatorsList()) {
             // doThingsWith(element);
           }
           String nextPageToken = response.getNextPageToken();
           if (!Strings.isNullOrEmpty(nextPageToken)) {
             request = request.toBuilder().setPageToken(nextPageToken).build();
           } else {
             break;
           }
         }
       }
       
    • getOperator

      public final Operator getOperator(OperatorName name)
      Gets details of a single Operator.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         OperatorName name = OperatorName.of("[PROJECT]", "[LOCATION]", "[OPERATOR]");
         Operator response = liveVideoAnalyticsClient.getOperator(name);
       }
       
      Parameters:
      name - Required. Name of the resource.
      Throws:
      ApiException - if the remote call fails
    • getOperator

      public final Operator getOperator(String name)
      Gets details of a single Operator.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         String name = OperatorName.of("[PROJECT]", "[LOCATION]", "[OPERATOR]").toString();
         Operator response = liveVideoAnalyticsClient.getOperator(name);
       }
       
      Parameters:
      name - Required. Name of the resource.
      Throws:
      ApiException - if the remote call fails
    • getOperator

      public final Operator getOperator(GetOperatorRequest request)
      Gets details of a single Operator.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         GetOperatorRequest request =
             GetOperatorRequest.newBuilder()
                 .setName(OperatorName.of("[PROJECT]", "[LOCATION]", "[OPERATOR]").toString())
                 .build();
         Operator response = liveVideoAnalyticsClient.getOperator(request);
       }
       
      Parameters:
      request - The request object containing all of the parameters for the API call.
      Throws:
      ApiException - if the remote call fails
    • getOperatorCallable

      public final UnaryCallable<GetOperatorRequest,Operator> getOperatorCallable()
      Gets details of a single Operator.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         GetOperatorRequest request =
             GetOperatorRequest.newBuilder()
                 .setName(OperatorName.of("[PROJECT]", "[LOCATION]", "[OPERATOR]").toString())
                 .build();
         ApiFuture<Operator> future =
             liveVideoAnalyticsClient.getOperatorCallable().futureCall(request);
         // Do something.
         Operator response = future.get();
       }
       
    • createOperatorAsync

      public final OperationFuture<Operator,OperationMetadata> createOperatorAsync(LocationName parent, Operator operator, String operatorId)
      Creates a new Operator in a given project and location.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
         Operator operator = Operator.newBuilder().build();
         String operatorId = "operatorId4364511";
         Operator response =
             liveVideoAnalyticsClient.createOperatorAsync(parent, operator, operatorId).get();
       }
       
      Parameters:
      parent - Required. Value for parent.
      operator - Required. The resource being created.
      operatorId - Required. Id of the requesting object.
      Throws:
      ApiException - if the remote call fails
    • createOperatorAsync

      public final OperationFuture<Operator,OperationMetadata> createOperatorAsync(String parent, Operator operator, String operatorId)
      Creates a new Operator in a given project and location.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
         Operator operator = Operator.newBuilder().build();
         String operatorId = "operatorId4364511";
         Operator response =
             liveVideoAnalyticsClient.createOperatorAsync(parent, operator, operatorId).get();
       }
       
      Parameters:
      parent - Required. Value for parent.
      operator - Required. The resource being created.
      operatorId - Required. Id of the requesting object.
      Throws:
      ApiException - if the remote call fails
    • createOperatorAsync

      public final OperationFuture<Operator,OperationMetadata> createOperatorAsync(CreateOperatorRequest request)
      Creates a new Operator in a given project and location.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         CreateOperatorRequest request =
             CreateOperatorRequest.newBuilder()
                 .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
                 .setOperatorId("operatorId4364511")
                 .setOperator(Operator.newBuilder().build())
                 .setRequestId("requestId693933066")
                 .build();
         Operator response = liveVideoAnalyticsClient.createOperatorAsync(request).get();
       }
       
      Parameters:
      request - The request object containing all of the parameters for the API call.
      Throws:
      ApiException - if the remote call fails
    • createOperatorOperationCallable

      public final OperationCallable<CreateOperatorRequest,Operator,OperationMetadata> createOperatorOperationCallable()
      Creates a new Operator in a given project and location.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         CreateOperatorRequest request =
             CreateOperatorRequest.newBuilder()
                 .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
                 .setOperatorId("operatorId4364511")
                 .setOperator(Operator.newBuilder().build())
                 .setRequestId("requestId693933066")
                 .build();
         OperationFuture<Operator, OperationMetadata> future =
             liveVideoAnalyticsClient.createOperatorOperationCallable().futureCall(request);
         // Do something.
         Operator response = future.get();
       }
       
    • createOperatorCallable

      public final UnaryCallable<CreateOperatorRequest,Operation> createOperatorCallable()
      Creates a new Operator in a given project and location.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         CreateOperatorRequest request =
             CreateOperatorRequest.newBuilder()
                 .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
                 .setOperatorId("operatorId4364511")
                 .setOperator(Operator.newBuilder().build())
                 .setRequestId("requestId693933066")
                 .build();
         ApiFuture<Operation> future =
             liveVideoAnalyticsClient.createOperatorCallable().futureCall(request);
         // Do something.
         Operation response = future.get();
       }
       
    • updateOperatorAsync

      public final OperationFuture<Operator,OperationMetadata> updateOperatorAsync(Operator operator, com.google.protobuf.FieldMask updateMask)
      Updates the parameters of a single Operator.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         Operator operator = Operator.newBuilder().build();
         FieldMask updateMask = FieldMask.newBuilder().build();
         Operator response = liveVideoAnalyticsClient.updateOperatorAsync(operator, updateMask).get();
       }
       
      Parameters:
      operator - Required. The resource being updated
      updateMask - Required. Field mask is used to specify the fields to be overwritten in the Operator resource by the update. The fields specified in the update_mask are relative to the resource, not the full request. A field will be overwritten if it is in the mask. If the user does not provide a mask then all fields will be overwritten.
      Throws:
      ApiException - if the remote call fails
    • updateOperatorAsync

      public final OperationFuture<Operator,OperationMetadata> updateOperatorAsync(UpdateOperatorRequest request)
      Updates the parameters of a single Operator.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         UpdateOperatorRequest request =
             UpdateOperatorRequest.newBuilder()
                 .setUpdateMask(FieldMask.newBuilder().build())
                 .setOperator(Operator.newBuilder().build())
                 .setRequestId("requestId693933066")
                 .build();
         Operator response = liveVideoAnalyticsClient.updateOperatorAsync(request).get();
       }
       
      Parameters:
      request - The request object containing all of the parameters for the API call.
      Throws:
      ApiException - if the remote call fails
    • updateOperatorOperationCallable

      public final OperationCallable<UpdateOperatorRequest,Operator,OperationMetadata> updateOperatorOperationCallable()
      Updates the parameters of a single Operator.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         UpdateOperatorRequest request =
             UpdateOperatorRequest.newBuilder()
                 .setUpdateMask(FieldMask.newBuilder().build())
                 .setOperator(Operator.newBuilder().build())
                 .setRequestId("requestId693933066")
                 .build();
         OperationFuture<Operator, OperationMetadata> future =
             liveVideoAnalyticsClient.updateOperatorOperationCallable().futureCall(request);
         // Do something.
         Operator response = future.get();
       }
       
    • updateOperatorCallable

      public final UnaryCallable<UpdateOperatorRequest,Operation> updateOperatorCallable()
      Updates the parameters of a single Operator.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         UpdateOperatorRequest request =
             UpdateOperatorRequest.newBuilder()
                 .setUpdateMask(FieldMask.newBuilder().build())
                 .setOperator(Operator.newBuilder().build())
                 .setRequestId("requestId693933066")
                 .build();
         ApiFuture<Operation> future =
             liveVideoAnalyticsClient.updateOperatorCallable().futureCall(request);
         // Do something.
         Operation response = future.get();
       }
       
    • deleteOperatorAsync

      public final OperationFuture<com.google.protobuf.Empty,OperationMetadata> deleteOperatorAsync(OperatorName name)
      Deletes a single Operator.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         OperatorName name = OperatorName.of("[PROJECT]", "[LOCATION]", "[OPERATOR]");
         liveVideoAnalyticsClient.deleteOperatorAsync(name).get();
       }
       
      Parameters:
      name - Required. Name of the resource
      Throws:
      ApiException - if the remote call fails
    • deleteOperatorAsync

      public final OperationFuture<com.google.protobuf.Empty,OperationMetadata> deleteOperatorAsync(String name)
      Deletes a single Operator.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         String name = OperatorName.of("[PROJECT]", "[LOCATION]", "[OPERATOR]").toString();
         liveVideoAnalyticsClient.deleteOperatorAsync(name).get();
       }
       
      Parameters:
      name - Required. Name of the resource
      Throws:
      ApiException - if the remote call fails
    • deleteOperatorAsync

      public final OperationFuture<com.google.protobuf.Empty,OperationMetadata> deleteOperatorAsync(DeleteOperatorRequest request)
      Deletes a single Operator.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         DeleteOperatorRequest request =
             DeleteOperatorRequest.newBuilder()
                 .setName(OperatorName.of("[PROJECT]", "[LOCATION]", "[OPERATOR]").toString())
                 .setRequestId("requestId693933066")
                 .build();
         liveVideoAnalyticsClient.deleteOperatorAsync(request).get();
       }
       
      Parameters:
      request - The request object containing all of the parameters for the API call.
      Throws:
      ApiException - if the remote call fails
    • deleteOperatorOperationCallable

      public final OperationCallable<DeleteOperatorRequest,com.google.protobuf.Empty,OperationMetadata> deleteOperatorOperationCallable()
      Deletes a single Operator.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         DeleteOperatorRequest request =
             DeleteOperatorRequest.newBuilder()
                 .setName(OperatorName.of("[PROJECT]", "[LOCATION]", "[OPERATOR]").toString())
                 .setRequestId("requestId693933066")
                 .build();
         OperationFuture<Empty, OperationMetadata> future =
             liveVideoAnalyticsClient.deleteOperatorOperationCallable().futureCall(request);
         // Do something.
         future.get();
       }
       
    • deleteOperatorCallable

      public final UnaryCallable<DeleteOperatorRequest,Operation> deleteOperatorCallable()
      Deletes a single Operator.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         DeleteOperatorRequest request =
             DeleteOperatorRequest.newBuilder()
                 .setName(OperatorName.of("[PROJECT]", "[LOCATION]", "[OPERATOR]").toString())
                 .setRequestId("requestId693933066")
                 .build();
         ApiFuture<Operation> future =
             liveVideoAnalyticsClient.deleteOperatorCallable().futureCall(request);
         // Do something.
         future.get();
       }
       
    • listAnalyses

      Lists Analyses in a given project and location.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         ClusterName parent = ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]");
         for (Analysis element : liveVideoAnalyticsClient.listAnalyses(parent).iterateAll()) {
           // doThingsWith(element);
         }
       }
       
      Parameters:
      parent - Required. Parent value for ListAnalysesRequest
      Throws:
      ApiException - if the remote call fails
    • listAnalyses

      public final LiveVideoAnalyticsClient.ListAnalysesPagedResponse listAnalyses(String parent)
      Lists Analyses in a given project and location.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         String parent = ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString();
         for (Analysis element : liveVideoAnalyticsClient.listAnalyses(parent).iterateAll()) {
           // doThingsWith(element);
         }
       }
       
      Parameters:
      parent - Required. Parent value for ListAnalysesRequest
      Throws:
      ApiException - if the remote call fails
    • listAnalyses

      Lists Analyses in a given project and location.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         ListAnalysesRequest request =
             ListAnalysesRequest.newBuilder()
                 .setParent(ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString())
                 .setPageSize(883849137)
                 .setPageToken("pageToken873572522")
                 .setFilter("filter-1274492040")
                 .setOrderBy("orderBy-1207110587")
                 .build();
         for (Analysis element : liveVideoAnalyticsClient.listAnalyses(request).iterateAll()) {
           // doThingsWith(element);
         }
       }
       
      Parameters:
      request - The request object containing all of the parameters for the API call.
      Throws:
      ApiException - if the remote call fails
    • listAnalysesPagedCallable

      Lists Analyses in a given project and location.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         ListAnalysesRequest request =
             ListAnalysesRequest.newBuilder()
                 .setParent(ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString())
                 .setPageSize(883849137)
                 .setPageToken("pageToken873572522")
                 .setFilter("filter-1274492040")
                 .setOrderBy("orderBy-1207110587")
                 .build();
         ApiFuture<Analysis> future =
             liveVideoAnalyticsClient.listAnalysesPagedCallable().futureCall(request);
         // Do something.
         for (Analysis element : future.get().iterateAll()) {
           // doThingsWith(element);
         }
       }
       
    • listAnalysesCallable

      public final UnaryCallable<ListAnalysesRequest,ListAnalysesResponse> listAnalysesCallable()
      Lists Analyses in a given project and location.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         ListAnalysesRequest request =
             ListAnalysesRequest.newBuilder()
                 .setParent(ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString())
                 .setPageSize(883849137)
                 .setPageToken("pageToken873572522")
                 .setFilter("filter-1274492040")
                 .setOrderBy("orderBy-1207110587")
                 .build();
         while (true) {
           ListAnalysesResponse response =
               liveVideoAnalyticsClient.listAnalysesCallable().call(request);
           for (Analysis element : response.getAnalysesList()) {
             // doThingsWith(element);
           }
           String nextPageToken = response.getNextPageToken();
           if (!Strings.isNullOrEmpty(nextPageToken)) {
             request = request.toBuilder().setPageToken(nextPageToken).build();
           } else {
             break;
           }
         }
       }
       
    • getAnalysis

      public final Analysis getAnalysis(AnalysisName name)
      Gets details of a single Analysis.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         AnalysisName name = AnalysisName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[ANALYSIS]");
         Analysis response = liveVideoAnalyticsClient.getAnalysis(name);
       }
       
      Parameters:
      name - Required. Name of the resource.
      Throws:
      ApiException - if the remote call fails
    • getAnalysis

      public final Analysis getAnalysis(String name)
      Gets details of a single Analysis.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         String name =
             AnalysisName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[ANALYSIS]").toString();
         Analysis response = liveVideoAnalyticsClient.getAnalysis(name);
       }
       
      Parameters:
      name - Required. Name of the resource.
      Throws:
      ApiException - if the remote call fails
    • getAnalysis

      public final Analysis getAnalysis(GetAnalysisRequest request)
      Gets details of a single Analysis.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         GetAnalysisRequest request =
             GetAnalysisRequest.newBuilder()
                 .setName(
                     AnalysisName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[ANALYSIS]").toString())
                 .build();
         Analysis response = liveVideoAnalyticsClient.getAnalysis(request);
       }
       
      Parameters:
      request - The request object containing all of the parameters for the API call.
      Throws:
      ApiException - if the remote call fails
    • getAnalysisCallable

      public final UnaryCallable<GetAnalysisRequest,Analysis> getAnalysisCallable()
      Gets details of a single Analysis.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         GetAnalysisRequest request =
             GetAnalysisRequest.newBuilder()
                 .setName(
                     AnalysisName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[ANALYSIS]").toString())
                 .build();
         ApiFuture<Analysis> future =
             liveVideoAnalyticsClient.getAnalysisCallable().futureCall(request);
         // Do something.
         Analysis response = future.get();
       }
       
    • createAnalysisAsync

      public final OperationFuture<Analysis,OperationMetadata> createAnalysisAsync(ClusterName parent, Analysis analysis, String analysisId)
      Creates a new Analysis in a given project and location.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         ClusterName parent = ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]");
         Analysis analysis = Analysis.newBuilder().build();
         String analysisId = "analysisId-944835305";
         Analysis response =
             liveVideoAnalyticsClient.createAnalysisAsync(parent, analysis, analysisId).get();
       }
       
      Parameters:
      parent - Required. Value for parent.
      analysis - Required. The resource being created.
      analysisId - Required. Id of the requesting object.
      Throws:
      ApiException - if the remote call fails
    • createAnalysisAsync

      public final OperationFuture<Analysis,OperationMetadata> createAnalysisAsync(String parent, Analysis analysis, String analysisId)
      Creates a new Analysis in a given project and location.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         String parent = ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString();
         Analysis analysis = Analysis.newBuilder().build();
         String analysisId = "analysisId-944835305";
         Analysis response =
             liveVideoAnalyticsClient.createAnalysisAsync(parent, analysis, analysisId).get();
       }
       
      Parameters:
      parent - Required. Value for parent.
      analysis - Required. The resource being created.
      analysisId - Required. Id of the requesting object.
      Throws:
      ApiException - if the remote call fails
    • createAnalysisAsync

      public final OperationFuture<Analysis,OperationMetadata> createAnalysisAsync(CreateAnalysisRequest request)
      Creates a new Analysis in a given project and location.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         CreateAnalysisRequest request =
             CreateAnalysisRequest.newBuilder()
                 .setParent(ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString())
                 .setAnalysisId("analysisId-944835305")
                 .setAnalysis(Analysis.newBuilder().build())
                 .setRequestId("requestId693933066")
                 .build();
         Analysis response = liveVideoAnalyticsClient.createAnalysisAsync(request).get();
       }
       
      Parameters:
      request - The request object containing all of the parameters for the API call.
      Throws:
      ApiException - if the remote call fails
    • createAnalysisOperationCallable

      public final OperationCallable<CreateAnalysisRequest,Analysis,OperationMetadata> createAnalysisOperationCallable()
      Creates a new Analysis in a given project and location.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         CreateAnalysisRequest request =
             CreateAnalysisRequest.newBuilder()
                 .setParent(ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString())
                 .setAnalysisId("analysisId-944835305")
                 .setAnalysis(Analysis.newBuilder().build())
                 .setRequestId("requestId693933066")
                 .build();
         OperationFuture<Analysis, OperationMetadata> future =
             liveVideoAnalyticsClient.createAnalysisOperationCallable().futureCall(request);
         // Do something.
         Analysis response = future.get();
       }
       
    • createAnalysisCallable

      public final UnaryCallable<CreateAnalysisRequest,Operation> createAnalysisCallable()
      Creates a new Analysis in a given project and location.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         CreateAnalysisRequest request =
             CreateAnalysisRequest.newBuilder()
                 .setParent(ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString())
                 .setAnalysisId("analysisId-944835305")
                 .setAnalysis(Analysis.newBuilder().build())
                 .setRequestId("requestId693933066")
                 .build();
         ApiFuture<Operation> future =
             liveVideoAnalyticsClient.createAnalysisCallable().futureCall(request);
         // Do something.
         Operation response = future.get();
       }
       
    • updateAnalysisAsync

      public final OperationFuture<Analysis,OperationMetadata> updateAnalysisAsync(Analysis analysis, com.google.protobuf.FieldMask updateMask)
      Updates the parameters of a single Analysis.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         Analysis analysis = Analysis.newBuilder().build();
         FieldMask updateMask = FieldMask.newBuilder().build();
         Analysis response = liveVideoAnalyticsClient.updateAnalysisAsync(analysis, updateMask).get();
       }
       
      Parameters:
      analysis - Required. The resource being updated.
      updateMask - Required. Field mask is used to specify the fields to be overwritten in the Analysis resource by the update. The fields specified in the update_mask are relative to the resource, not the full request. A field will be overwritten if it is in the mask. If the user does not provide a mask then all fields will be overwritten.
      Throws:
      ApiException - if the remote call fails
    • updateAnalysisAsync

      public final OperationFuture<Analysis,OperationMetadata> updateAnalysisAsync(UpdateAnalysisRequest request)
      Updates the parameters of a single Analysis.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         UpdateAnalysisRequest request =
             UpdateAnalysisRequest.newBuilder()
                 .setUpdateMask(FieldMask.newBuilder().build())
                 .setAnalysis(Analysis.newBuilder().build())
                 .setRequestId("requestId693933066")
                 .build();
         Analysis response = liveVideoAnalyticsClient.updateAnalysisAsync(request).get();
       }
       
      Parameters:
      request - The request object containing all of the parameters for the API call.
      Throws:
      ApiException - if the remote call fails
    • updateAnalysisOperationCallable

      public final OperationCallable<UpdateAnalysisRequest,Analysis,OperationMetadata> updateAnalysisOperationCallable()
      Updates the parameters of a single Analysis.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         UpdateAnalysisRequest request =
             UpdateAnalysisRequest.newBuilder()
                 .setUpdateMask(FieldMask.newBuilder().build())
                 .setAnalysis(Analysis.newBuilder().build())
                 .setRequestId("requestId693933066")
                 .build();
         OperationFuture<Analysis, OperationMetadata> future =
             liveVideoAnalyticsClient.updateAnalysisOperationCallable().futureCall(request);
         // Do something.
         Analysis response = future.get();
       }
       
    • updateAnalysisCallable

      public final UnaryCallable<UpdateAnalysisRequest,Operation> updateAnalysisCallable()
      Updates the parameters of a single Analysis.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         UpdateAnalysisRequest request =
             UpdateAnalysisRequest.newBuilder()
                 .setUpdateMask(FieldMask.newBuilder().build())
                 .setAnalysis(Analysis.newBuilder().build())
                 .setRequestId("requestId693933066")
                 .build();
         ApiFuture<Operation> future =
             liveVideoAnalyticsClient.updateAnalysisCallable().futureCall(request);
         // Do something.
         Operation response = future.get();
       }
       
    • deleteAnalysisAsync

      public final OperationFuture<com.google.protobuf.Empty,OperationMetadata> deleteAnalysisAsync(AnalysisName name)
      Deletes a single Analysis.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         AnalysisName name = AnalysisName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[ANALYSIS]");
         liveVideoAnalyticsClient.deleteAnalysisAsync(name).get();
       }
       
      Parameters:
      name - Required. Name of the resource.
      Throws:
      ApiException - if the remote call fails
    • deleteAnalysisAsync

      public final OperationFuture<com.google.protobuf.Empty,OperationMetadata> deleteAnalysisAsync(String name)
      Deletes a single Analysis.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         String name =
             AnalysisName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[ANALYSIS]").toString();
         liveVideoAnalyticsClient.deleteAnalysisAsync(name).get();
       }
       
      Parameters:
      name - Required. Name of the resource.
      Throws:
      ApiException - if the remote call fails
    • deleteAnalysisAsync

      public final OperationFuture<com.google.protobuf.Empty,OperationMetadata> deleteAnalysisAsync(DeleteAnalysisRequest request)
      Deletes a single Analysis.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         DeleteAnalysisRequest request =
             DeleteAnalysisRequest.newBuilder()
                 .setName(
                     AnalysisName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[ANALYSIS]").toString())
                 .setRequestId("requestId693933066")
                 .build();
         liveVideoAnalyticsClient.deleteAnalysisAsync(request).get();
       }
       
      Parameters:
      request - The request object containing all of the parameters for the API call.
      Throws:
      ApiException - if the remote call fails
    • deleteAnalysisOperationCallable

      public final OperationCallable<DeleteAnalysisRequest,com.google.protobuf.Empty,OperationMetadata> deleteAnalysisOperationCallable()
      Deletes a single Analysis.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         DeleteAnalysisRequest request =
             DeleteAnalysisRequest.newBuilder()
                 .setName(
                     AnalysisName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[ANALYSIS]").toString())
                 .setRequestId("requestId693933066")
                 .build();
         OperationFuture<Empty, OperationMetadata> future =
             liveVideoAnalyticsClient.deleteAnalysisOperationCallable().futureCall(request);
         // Do something.
         future.get();
       }
       
    • deleteAnalysisCallable

      public final UnaryCallable<DeleteAnalysisRequest,Operation> deleteAnalysisCallable()
      Deletes a single Analysis.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         DeleteAnalysisRequest request =
             DeleteAnalysisRequest.newBuilder()
                 .setName(
                     AnalysisName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[ANALYSIS]").toString())
                 .setRequestId("requestId693933066")
                 .build();
         ApiFuture<Operation> future =
             liveVideoAnalyticsClient.deleteAnalysisCallable().futureCall(request);
         // Do something.
         future.get();
       }
       
    • listProcesses

      Lists Processes in a given project and location.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         ClusterName parent = ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]");
         for (Process element : liveVideoAnalyticsClient.listProcesses(parent).iterateAll()) {
           // doThingsWith(element);
         }
       }
       
      Parameters:
      parent - Required. Parent value for ListProcessesRequest.
      Throws:
      ApiException - if the remote call fails
    • listProcesses

      public final LiveVideoAnalyticsClient.ListProcessesPagedResponse listProcesses(String parent)
      Lists Processes in a given project and location.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         String parent = ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString();
         for (Process element : liveVideoAnalyticsClient.listProcesses(parent).iterateAll()) {
           // doThingsWith(element);
         }
       }
       
      Parameters:
      parent - Required. Parent value for ListProcessesRequest.
      Throws:
      ApiException - if the remote call fails
    • listProcesses

      Lists Processes in a given project and location.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         ListProcessesRequest request =
             ListProcessesRequest.newBuilder()
                 .setParent(ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString())
                 .setPageSize(883849137)
                 .setPageToken("pageToken873572522")
                 .setFilter("filter-1274492040")
                 .setOrderBy("orderBy-1207110587")
                 .build();
         for (Process element : liveVideoAnalyticsClient.listProcesses(request).iterateAll()) {
           // doThingsWith(element);
         }
       }
       
      Parameters:
      request - The request object containing all of the parameters for the API call.
      Throws:
      ApiException - if the remote call fails
    • listProcessesPagedCallable

      Lists Processes in a given project and location.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         ListProcessesRequest request =
             ListProcessesRequest.newBuilder()
                 .setParent(ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString())
                 .setPageSize(883849137)
                 .setPageToken("pageToken873572522")
                 .setFilter("filter-1274492040")
                 .setOrderBy("orderBy-1207110587")
                 .build();
         ApiFuture<Process> future =
             liveVideoAnalyticsClient.listProcessesPagedCallable().futureCall(request);
         // Do something.
         for (Process element : future.get().iterateAll()) {
           // doThingsWith(element);
         }
       }
       
    • listProcessesCallable

      public final UnaryCallable<ListProcessesRequest,ListProcessesResponse> listProcessesCallable()
      Lists Processes in a given project and location.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         ListProcessesRequest request =
             ListProcessesRequest.newBuilder()
                 .setParent(ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString())
                 .setPageSize(883849137)
                 .setPageToken("pageToken873572522")
                 .setFilter("filter-1274492040")
                 .setOrderBy("orderBy-1207110587")
                 .build();
         while (true) {
           ListProcessesResponse response =
               liveVideoAnalyticsClient.listProcessesCallable().call(request);
           for (Process element : response.getProcessesList()) {
             // doThingsWith(element);
           }
           String nextPageToken = response.getNextPageToken();
           if (!Strings.isNullOrEmpty(nextPageToken)) {
             request = request.toBuilder().setPageToken(nextPageToken).build();
           } else {
             break;
           }
         }
       }
       
    • getProcess

      public final Process getProcess(ProcessName name)
      Gets details of a single Process.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         ProcessName name = ProcessName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[PROCESS]");
         Process response = liveVideoAnalyticsClient.getProcess(name);
       }
       
      Parameters:
      name - Required. Name of the resource.
      Throws:
      ApiException - if the remote call fails
    • getProcess

      public final Process getProcess(String name)
      Gets details of a single Process.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         String name = ProcessName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[PROCESS]").toString();
         Process response = liveVideoAnalyticsClient.getProcess(name);
       }
       
      Parameters:
      name - Required. Name of the resource.
      Throws:
      ApiException - if the remote call fails
    • getProcess

      public final Process getProcess(GetProcessRequest request)
      Gets details of a single Process.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         GetProcessRequest request =
             GetProcessRequest.newBuilder()
                 .setName(
                     ProcessName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[PROCESS]").toString())
                 .build();
         Process response = liveVideoAnalyticsClient.getProcess(request);
       }
       
      Parameters:
      request - The request object containing all of the parameters for the API call.
      Throws:
      ApiException - if the remote call fails
    • getProcessCallable

      public final UnaryCallable<GetProcessRequest,Process> getProcessCallable()
      Gets details of a single Process.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         GetProcessRequest request =
             GetProcessRequest.newBuilder()
                 .setName(
                     ProcessName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[PROCESS]").toString())
                 .build();
         ApiFuture<Process> future = liveVideoAnalyticsClient.getProcessCallable().futureCall(request);
         // Do something.
         Process response = future.get();
       }
       
    • createProcessAsync

      public final OperationFuture<Process,OperationMetadata> createProcessAsync(ClusterName parent, Process process, String processId)
      Creates a new Process in a given project and location.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         ClusterName parent = ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]");
         Process process = Process.newBuilder().build();
         String processId = "processId-1094760470";
         Process response =
             liveVideoAnalyticsClient.createProcessAsync(parent, process, processId).get();
       }
       
      Parameters:
      parent - Required. Value for parent.
      process - Required. The resource being created.
      processId - Required. Id of the requesting object.
      Throws:
      ApiException - if the remote call fails
    • createProcessAsync

      public final OperationFuture<Process,OperationMetadata> createProcessAsync(String parent, Process process, String processId)
      Creates a new Process in a given project and location.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         String parent = ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString();
         Process process = Process.newBuilder().build();
         String processId = "processId-1094760470";
         Process response =
             liveVideoAnalyticsClient.createProcessAsync(parent, process, processId).get();
       }
       
      Parameters:
      parent - Required. Value for parent.
      process - Required. The resource being created.
      processId - Required. Id of the requesting object.
      Throws:
      ApiException - if the remote call fails
    • createProcessAsync

      public final OperationFuture<Process,OperationMetadata> createProcessAsync(CreateProcessRequest request)
      Creates a new Process in a given project and location.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         CreateProcessRequest request =
             CreateProcessRequest.newBuilder()
                 .setParent(ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString())
                 .setProcessId("processId-1094760470")
                 .setProcess(Process.newBuilder().build())
                 .setRequestId("requestId693933066")
                 .build();
         Process response = liveVideoAnalyticsClient.createProcessAsync(request).get();
       }
       
      Parameters:
      request - The request object containing all of the parameters for the API call.
      Throws:
      ApiException - if the remote call fails
    • createProcessOperationCallable

      public final OperationCallable<CreateProcessRequest,Process,OperationMetadata> createProcessOperationCallable()
      Creates a new Process in a given project and location.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         CreateProcessRequest request =
             CreateProcessRequest.newBuilder()
                 .setParent(ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString())
                 .setProcessId("processId-1094760470")
                 .setProcess(Process.newBuilder().build())
                 .setRequestId("requestId693933066")
                 .build();
         OperationFuture<Process, OperationMetadata> future =
             liveVideoAnalyticsClient.createProcessOperationCallable().futureCall(request);
         // Do something.
         Process response = future.get();
       }
       
    • createProcessCallable

      public final UnaryCallable<CreateProcessRequest,Operation> createProcessCallable()
      Creates a new Process in a given project and location.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         CreateProcessRequest request =
             CreateProcessRequest.newBuilder()
                 .setParent(ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString())
                 .setProcessId("processId-1094760470")
                 .setProcess(Process.newBuilder().build())
                 .setRequestId("requestId693933066")
                 .build();
         ApiFuture<Operation> future =
             liveVideoAnalyticsClient.createProcessCallable().futureCall(request);
         // Do something.
         Operation response = future.get();
       }
       
    • updateProcessAsync

      public final OperationFuture<Process,OperationMetadata> updateProcessAsync(Process process, com.google.protobuf.FieldMask updateMask)
      Updates the parameters of a single Process.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         Process process = Process.newBuilder().build();
         FieldMask updateMask = FieldMask.newBuilder().build();
         Process response = liveVideoAnalyticsClient.updateProcessAsync(process, updateMask).get();
       }
       
      Parameters:
      process - Required. The resource being updated.
      updateMask - Required. Field mask is used to specify the fields to be overwritten in the Process resource by the update. The fields specified in the update_mask are relative to the resource, not the full request. A field will be overwritten if it is in the mask. If the user does not provide a mask then all fields will be overwritten.
      Throws:
      ApiException - if the remote call fails
    • updateProcessAsync

      public final OperationFuture<Process,OperationMetadata> updateProcessAsync(UpdateProcessRequest request)
      Updates the parameters of a single Process.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         UpdateProcessRequest request =
             UpdateProcessRequest.newBuilder()
                 .setUpdateMask(FieldMask.newBuilder().build())
                 .setProcess(Process.newBuilder().build())
                 .setRequestId("requestId693933066")
                 .build();
         Process response = liveVideoAnalyticsClient.updateProcessAsync(request).get();
       }
       
      Parameters:
      request - The request object containing all of the parameters for the API call.
      Throws:
      ApiException - if the remote call fails
    • updateProcessOperationCallable

      public final OperationCallable<UpdateProcessRequest,Process,OperationMetadata> updateProcessOperationCallable()
      Updates the parameters of a single Process.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         UpdateProcessRequest request =
             UpdateProcessRequest.newBuilder()
                 .setUpdateMask(FieldMask.newBuilder().build())
                 .setProcess(Process.newBuilder().build())
                 .setRequestId("requestId693933066")
                 .build();
         OperationFuture<Process, OperationMetadata> future =
             liveVideoAnalyticsClient.updateProcessOperationCallable().futureCall(request);
         // Do something.
         Process response = future.get();
       }
       
    • updateProcessCallable

      public final UnaryCallable<UpdateProcessRequest,Operation> updateProcessCallable()
      Updates the parameters of a single Process.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         UpdateProcessRequest request =
             UpdateProcessRequest.newBuilder()
                 .setUpdateMask(FieldMask.newBuilder().build())
                 .setProcess(Process.newBuilder().build())
                 .setRequestId("requestId693933066")
                 .build();
         ApiFuture<Operation> future =
             liveVideoAnalyticsClient.updateProcessCallable().futureCall(request);
         // Do something.
         Operation response = future.get();
       }
       
    • deleteProcessAsync

      public final OperationFuture<com.google.protobuf.Empty,OperationMetadata> deleteProcessAsync(ProcessName name)
      Deletes a single Process.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         ProcessName name = ProcessName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[PROCESS]");
         liveVideoAnalyticsClient.deleteProcessAsync(name).get();
       }
       
      Parameters:
      name - Required. Name of the resource.
      Throws:
      ApiException - if the remote call fails
    • deleteProcessAsync

      public final OperationFuture<com.google.protobuf.Empty,OperationMetadata> deleteProcessAsync(String name)
      Deletes a single Process.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         String name = ProcessName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[PROCESS]").toString();
         liveVideoAnalyticsClient.deleteProcessAsync(name).get();
       }
       
      Parameters:
      name - Required. Name of the resource.
      Throws:
      ApiException - if the remote call fails
    • deleteProcessAsync

      public final OperationFuture<com.google.protobuf.Empty,OperationMetadata> deleteProcessAsync(DeleteProcessRequest request)
      Deletes a single Process.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         DeleteProcessRequest request =
             DeleteProcessRequest.newBuilder()
                 .setName(
                     ProcessName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[PROCESS]").toString())
                 .setRequestId("requestId693933066")
                 .build();
         liveVideoAnalyticsClient.deleteProcessAsync(request).get();
       }
       
      Parameters:
      request - The request object containing all of the parameters for the API call.
      Throws:
      ApiException - if the remote call fails
    • deleteProcessOperationCallable

      public final OperationCallable<DeleteProcessRequest,com.google.protobuf.Empty,OperationMetadata> deleteProcessOperationCallable()
      Deletes a single Process.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         DeleteProcessRequest request =
             DeleteProcessRequest.newBuilder()
                 .setName(
                     ProcessName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[PROCESS]").toString())
                 .setRequestId("requestId693933066")
                 .build();
         OperationFuture<Empty, OperationMetadata> future =
             liveVideoAnalyticsClient.deleteProcessOperationCallable().futureCall(request);
         // Do something.
         future.get();
       }
       
    • deleteProcessCallable

      public final UnaryCallable<DeleteProcessRequest,Operation> deleteProcessCallable()
      Deletes a single Process.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         DeleteProcessRequest request =
             DeleteProcessRequest.newBuilder()
                 .setName(
                     ProcessName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[PROCESS]").toString())
                 .setRequestId("requestId693933066")
                 .build();
         ApiFuture<Operation> future =
             liveVideoAnalyticsClient.deleteProcessCallable().futureCall(request);
         // Do something.
         future.get();
       }
       
    • batchRunProcessAsync

      public final OperationFuture<BatchRunProcessResponse,OperationMetadata> batchRunProcessAsync(ClusterName parent, List<CreateProcessRequest> requests)
      Run all of the processes to "completion". Max time for each process is the LRO time limit.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         ClusterName parent = ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]");
         List<CreateProcessRequest> requests = new ArrayList<>();
         BatchRunProcessResponse response =
             liveVideoAnalyticsClient.batchRunProcessAsync(parent, requests).get();
       }
       
      Parameters:
      parent - Required. The parent resource shared by all processes being created.
      requests - Required. The create process requests.
      Throws:
      ApiException - if the remote call fails
    • batchRunProcessAsync

      public final OperationFuture<BatchRunProcessResponse,OperationMetadata> batchRunProcessAsync(String parent, List<CreateProcessRequest> requests)
      Run all of the processes to "completion". Max time for each process is the LRO time limit.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         String parent = ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString();
         List<CreateProcessRequest> requests = new ArrayList<>();
         BatchRunProcessResponse response =
             liveVideoAnalyticsClient.batchRunProcessAsync(parent, requests).get();
       }
       
      Parameters:
      parent - Required. The parent resource shared by all processes being created.
      requests - Required. The create process requests.
      Throws:
      ApiException - if the remote call fails
    • batchRunProcessAsync

      Run all of the processes to "completion". Max time for each process is the LRO time limit.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         BatchRunProcessRequest request =
             BatchRunProcessRequest.newBuilder()
                 .setParent(ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString())
                 .addAllRequests(new ArrayList<CreateProcessRequest>())
                 .setOptions(BatchRunProcessRequest.BatchRunProcessOptions.newBuilder().build())
                 .setBatchId("batchId-331744779")
                 .build();
         BatchRunProcessResponse response =
             liveVideoAnalyticsClient.batchRunProcessAsync(request).get();
       }
       
      Parameters:
      request - The request object containing all of the parameters for the API call.
      Throws:
      ApiException - if the remote call fails
    • batchRunProcessOperationCallable

      public final OperationCallable<BatchRunProcessRequest,BatchRunProcessResponse,OperationMetadata> batchRunProcessOperationCallable()
      Run all of the processes to "completion". Max time for each process is the LRO time limit.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         BatchRunProcessRequest request =
             BatchRunProcessRequest.newBuilder()
                 .setParent(ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString())
                 .addAllRequests(new ArrayList<CreateProcessRequest>())
                 .setOptions(BatchRunProcessRequest.BatchRunProcessOptions.newBuilder().build())
                 .setBatchId("batchId-331744779")
                 .build();
         OperationFuture<BatchRunProcessResponse, OperationMetadata> future =
             liveVideoAnalyticsClient.batchRunProcessOperationCallable().futureCall(request);
         // Do something.
         BatchRunProcessResponse response = future.get();
       }
       
    • batchRunProcessCallable

      public final UnaryCallable<BatchRunProcessRequest,Operation> batchRunProcessCallable()
      Run all of the processes to "completion". Max time for each process is the LRO time limit.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         BatchRunProcessRequest request =
             BatchRunProcessRequest.newBuilder()
                 .setParent(ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString())
                 .addAllRequests(new ArrayList<CreateProcessRequest>())
                 .setOptions(BatchRunProcessRequest.BatchRunProcessOptions.newBuilder().build())
                 .setBatchId("batchId-331744779")
                 .build();
         ApiFuture<Operation> future =
             liveVideoAnalyticsClient.batchRunProcessCallable().futureCall(request);
         // Do something.
         Operation response = future.get();
       }
       
    • listLocations

      Lists information about the supported locations for this service.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         ListLocationsRequest request =
             ListLocationsRequest.newBuilder()
                 .setName("name3373707")
                 .setFilter("filter-1274492040")
                 .setPageSize(883849137)
                 .setPageToken("pageToken873572522")
                 .build();
         for (Location element : liveVideoAnalyticsClient.listLocations(request).iterateAll()) {
           // doThingsWith(element);
         }
       }
       
      Parameters:
      request - The request object containing all of the parameters for the API call.
      Throws:
      ApiException - if the remote call fails
    • listLocationsPagedCallable

      Lists information about the supported locations for this service.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         ListLocationsRequest request =
             ListLocationsRequest.newBuilder()
                 .setName("name3373707")
                 .setFilter("filter-1274492040")
                 .setPageSize(883849137)
                 .setPageToken("pageToken873572522")
                 .build();
         ApiFuture<Location> future =
             liveVideoAnalyticsClient.listLocationsPagedCallable().futureCall(request);
         // Do something.
         for (Location element : future.get().iterateAll()) {
           // doThingsWith(element);
         }
       }
       
    • listLocationsCallable

      public final UnaryCallable<ListLocationsRequest,ListLocationsResponse> listLocationsCallable()
      Lists information about the supported locations for this service.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         ListLocationsRequest request =
             ListLocationsRequest.newBuilder()
                 .setName("name3373707")
                 .setFilter("filter-1274492040")
                 .setPageSize(883849137)
                 .setPageToken("pageToken873572522")
                 .build();
         while (true) {
           ListLocationsResponse response =
               liveVideoAnalyticsClient.listLocationsCallable().call(request);
           for (Location element : response.getLocationsList()) {
             // doThingsWith(element);
           }
           String nextPageToken = response.getNextPageToken();
           if (!Strings.isNullOrEmpty(nextPageToken)) {
             request = request.toBuilder().setPageToken(nextPageToken).build();
           } else {
             break;
           }
         }
       }
       
    • getLocation

      public final Location getLocation(GetLocationRequest request)
      Gets information about a location.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         GetLocationRequest request = GetLocationRequest.newBuilder().setName("name3373707").build();
         Location response = liveVideoAnalyticsClient.getLocation(request);
       }
       
      Parameters:
      request - The request object containing all of the parameters for the API call.
      Throws:
      ApiException - if the remote call fails
    • getLocationCallable

      public final UnaryCallable<GetLocationRequest,Location> getLocationCallable()
      Gets information about a location.

      Sample code:

      
       // This snippet has been automatically generated and should be regarded as a code template only.
       // It will require modifications to work:
       // - It may require correct/in-range values for request initialization.
       // - It may require specifying regional endpoints when creating the service client as shown in
       // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
       try (LiveVideoAnalyticsClient liveVideoAnalyticsClient = LiveVideoAnalyticsClient.create()) {
         GetLocationRequest request = GetLocationRequest.newBuilder().setName("name3373707").build();
         ApiFuture<Location> future =
             liveVideoAnalyticsClient.getLocationCallable().futureCall(request);
         // Do something.
         Location response = future.get();
       }
       
    • close

      public final void close()
      Specified by:
      close in interface AutoCloseable
    • shutdown

      public void shutdown()
      Specified by:
      shutdown in interface BackgroundResource
    • isShutdown

      public boolean isShutdown()
      Specified by:
      isShutdown in interface BackgroundResource
    • isTerminated

      public boolean isTerminated()
      Specified by:
      isTerminated in interface BackgroundResource
    • shutdownNow

      public void shutdownNow()
      Specified by:
      shutdownNow in interface BackgroundResource
    • awaitTermination

      public boolean awaitTermination(long duration, TimeUnit unit) throws InterruptedException
      Specified by:
      awaitTermination in interface BackgroundResource
      Throws:
      InterruptedException