Package org.apache.hadoop.yarn.server.api

Interface ContainerLogAggregationPolicy

@Public @Unstable public interface ContainerLogAggregationPolicy
This API is used by NodeManager to decide if a given container's logs should be aggregated at run time.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    parseParameters(String parameters)
    The method used by the NodeManager log aggregation service to initial the policy object with parameters specified by the application or the cluster-wide setting.
    boolean
    shouldDoLogAggregation(ContainerLogContext logContext)
    The method used by the NodeManager log aggregation service to ask the policy object if a given container's logs should be aggregated.

  • Method Details

    • parseParameters

      void parseParameters(String parameters)

      The method used by the NodeManager log aggregation service to initial the policy object with parameters specified by the application or the cluster-wide setting.

      Parameters:
      parameters - parameters with scheme defined by the policy class.

    • shouldDoLogAggregation

      boolean shouldDoLogAggregation(ContainerLogContext logContext)

      The method used by the NodeManager log aggregation service to ask the policy object if a given container's logs should be aggregated.

      Parameters:
      logContext - ContainerLogContext
      Returns:
      Whether or not the container's logs should be aggregated.