Package org.apache.hadoop.yarn.logaggregation.filecontroller

Class LogAggregationFileControllerFactory

java.lang.Object

org.apache.hadoop.yarn.logaggregation.filecontroller.LogAggregationFileControllerFactory

@Private
@Unstable
public class LogAggregationFileControllerFactory
extends Object

Use LogAggregationFileControllerFactory to get the correct LogAggregationFileController for write and read.

Constructor Summary

Constructors

Constructor	Description
LogAggregationFileControllerFactory(org.apache.hadoop.conf.Configuration conf)	Construct the LogAggregationFileControllerFactory object.

Method Summary

Modifier and Type	Method	Description
LinkedList<LogAggregationFileController>	getConfiguredLogAggregationFileControllerList()
LogAggregationFileController	getFileControllerForRead(org.apache.hadoop.yarn.api.records.ApplicationId appId, String appOwner)	Get LogAggregationFileController to read the aggregated logs for this application.
LogAggregationFileController	getFileControllerForWrite()	Get LogAggregationFileController to write.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

LogAggregationFileControllerFactory

public LogAggregationFileControllerFactory(org.apache.hadoop.conf.Configuration conf)

Construct the LogAggregationFileControllerFactory object.

Parameters:

conf - the Configuration

Method Details

getFileControllerForWrite

public LogAggregationFileController getFileControllerForWrite()

Get LogAggregationFileController to write.

Returns:

the LogAggregationFileController instance

getFileControllerForRead

public LogAggregationFileController getFileControllerForRead(org.apache.hadoop.yarn.api.records.ApplicationId appId,
 String appOwner)
                                                      throws IOException

Get LogAggregationFileController to read the aggregated logs for this application.

Parameters:

appId - the ApplicationId

appOwner - the Application Owner

Returns:

the LogAggregationFileController instance

Throws:

IOException - if can not find any log aggregation file controller

getConfiguredLogAggregationFileControllerList

@Private
@VisibleForTesting
public LinkedList<LogAggregationFileController> getConfiguredLogAggregationFileControllerList()