Package org.apache.hadoop.yarn.server.timelineservice.storage.common

Class OfflineAggregationInfo

java.lang.Object

org.apache.hadoop.yarn.server.timelineservice.storage.common.OfflineAggregationInfo

public final class OfflineAggregationInfo
extends Object

Class to carry the offline aggregation information for storage level implementations. There are currently two predefined aggregation info instances that represent flow and user level offline aggregations. Depend on its implementation, a storage class may use an OfflineAggregationInfo object to decide behaviors dynamically.

Field Summary

Fields

Modifier and Type	Field	Description
static final OfflineAggregationInfo	FLOW_AGGREGATION
static final String	FLOW_AGGREGATION_TABLE_NAME	Default flow level aggregation table name.
static final OfflineAggregationInfo	USER_AGGREGATION
static final String	USER_AGGREGATION_TABLE_NAME	Default user level aggregation table name.

Method Summary

Modifier and Type	Method	Description
String[]	getPrimaryKeyList()
String	getTableName()
int	setStringsForPrimaryKey(PreparedStatement ps, TimelineCollectorContext context, String[] extraInfo, int startPos)

Methods inherited from class java.lang.Object

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

Field Details

FLOW_AGGREGATION_TABLE_NAME

@VisibleForTesting
public static final String FLOW_AGGREGATION_TABLE_NAME

Default flow level aggregation table name.

See Also:

• Constant Field Values

USER_AGGREGATION_TABLE_NAME

public static final String USER_AGGREGATION_TABLE_NAME

Default user level aggregation table name.

See Also:

• Constant Field Values

FLOW_AGGREGATION

public static final OfflineAggregationInfo FLOW_AGGREGATION

USER_AGGREGATION

public static final OfflineAggregationInfo USER_AGGREGATION

Method Details

getTableName

public String getTableName()

getPrimaryKeyList

public String[] getPrimaryKeyList()

setStringsForPrimaryKey

public int setStringsForPrimaryKey(PreparedStatement ps,
 TimelineCollectorContext context,
 String[] extraInfo,
 int startPos)
                            throws SQLException

Throws:

SQLException