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

Class FlowActivityRowKeyPrefix

java.lang.Object

org.apache.hadoop.yarn.server.timelineservice.storage.flow.FlowActivityRowKey

org.apache.hadoop.yarn.server.timelineservice.storage.flow.FlowActivityRowKeyPrefix

All Implemented Interfaces:

RowKeyPrefix<FlowActivityRowKey>

public class FlowActivityRowKeyPrefix
extends FlowActivityRowKey
implements RowKeyPrefix<FlowActivityRowKey>

A prefix partial rowkey for flow activities.

Constructor Summary

Constructors

Constructor	Description
FlowActivityRowKeyPrefix(String clusterId)	Constructs a row key prefix for the flow activity table as follows: clusterId!.
FlowActivityRowKeyPrefix(String clusterId, Long dayTs)	Constructs a row key prefix for the flow activity table as follows: clusterId!dayTimestamp!.

Method Summary

Modifier and Type	Method	Description
byte[]	getRowKeyPrefix()	Create a row key prefix, meaning a partial rowkey that can be used in range scans.

Methods inherited from class org.apache.hadoop.yarn.server.timelineservice.storage.flow.FlowActivityRowKey

getClusterId, getDayTimestamp, getFlowName, getRowKey, getRowKeyAsString, getUserId, parseRowKey, parseRowKeyFromString

Methods inherited from class java.lang.Object

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

Constructor Details

FlowActivityRowKeyPrefix

public FlowActivityRowKeyPrefix(String clusterId,
 Long dayTs)

Constructs a row key prefix for the flow activity table as follows: clusterId!dayTimestamp!.

Parameters:

clusterId - Cluster Id.

dayTs - Start of the day timestamp.

FlowActivityRowKeyPrefix

public FlowActivityRowKeyPrefix(String clusterId)

Constructs a row key prefix for the flow activity table as follows: clusterId!.

Parameters:

clusterId - identifying the cluster

Method Details

getRowKeyPrefix

public byte[] getRowKeyPrefix()

Description copied from interface: RowKeyPrefix

Create a row key prefix, meaning a partial rowkey that can be used in range scans. Which fields are included in the prefix will depend on the constructor of the specific instance that was used. Output depends on which constructor was used.

Specified by:

getRowKeyPrefix in interface RowKeyPrefix<FlowActivityRowKey>

Returns:

a prefix of the following form fist!second!...!last!