org.apache.hadoop.yarn.server.api

Interface ContainerLogAggregationPolicy

@InterfaceAudience.Public
 @InterfaceStability.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 and 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 Detail

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.