Interface Application

All Known Subinterfaces:
InternalApplication
All Known Implementing Classes:
DefaultApplication

public interface Application
Describes a group of processing units that interact together as an application.
Since:
8.0.3
Author:
itaif
  • Method Details

    • getProcessingUnits

      ProcessingUnits getProcessingUnits()
      Returns:
      the processing units associated with the application
      Since:
      8.0.3
    • getName

      String getName()
      Returns:
      the name of the application.
      Since:
      8.0.3
    • deployProcessingUnit

      ProcessingUnit deployProcessingUnit(ProcessingUnitDeploymentTopology puDeployment)
      Deploys the specified processing unit adding it to this application
    • deployProcessingUnit

      ProcessingUnit deployProcessingUnit(ProcessingUnitDeploymentTopology puDeployment, long timeout, TimeUnit timeUnit)
      Deploys the specified processing unit adding it to this application
    • undeployAndWait

      void undeployAndWait()
      Undeploys all Processing Units that are part of the application and waits until all instances have been undeployed. In case of an Elastic processing unit, also waits for containers to shutdown. The processing units are undeployed in the reverse dependency order (if feeder depends on space, then space is undeployed and only then space is undeployed)

      The undeployment process will wait indefinitely and return when all processing units have undeployed.

      Since:
      8.0.6
    • undeployAndWait

      boolean undeployAndWait(long timeout, TimeUnit timeUnit)
      Undeploys all Processing Units that are part of the application and waits until all instances have been undeployed. In case of an Elastic processing unit, also waits for containers to shutdown. The processing units are undeployed in the reverse dependency order (if feeder depends on space, then space is undeployed and only then space is undeployed)

      The undeployment process waits for the specified timeout and return when all processing units of the application has been undeployed or timeout expired. * @return true if all processing units have undeployed, false if undeployment process is incomplete and the timeout expired.

      Since:
      8.0.6
    • setStatisticsHistorySize

      @Deprecated void setStatisticsHistorySize(int historySize)
      Deprecated.
      Deprecation since 10.1.1 - apply using getProcessingUnits(). Processing Unit instance service statistics history size; Default StatisticsMonitor.DEFAULT_HISTORY_SIZE.
      Parameters:
      historySize - the amount of statistics objects to keep.