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

Interface ColumnPrefix<T extends BaseTable<T>>

All Known Implementing Classes:
ApplicationColumnPrefix, AppToFlowColumnPrefix, EntityColumnPrefix, FlowActivityColumnPrefix, FlowRunColumnPrefix, SubApplicationColumnPrefix
public interface ColumnPrefix<T extends BaseTable<T>>
Used to represent a partially qualified column, where the actual column name will be composed of a prefix and the remainder of the column qualifier. The prefix can be null, in which case the column qualifier will be completely determined when the values are stored.

  • Method Details

    • getColumnPrefixBytes

      byte[] getColumnPrefixBytes(String qualifierPrefix)
      Parameters:
      qualifierPrefix - Column qualifier or prefix of qualifier.
      Returns:
      a byte array encoding column prefix and qualifier/prefix passed.

    • getColumnPrefixBytes

      byte[] getColumnPrefixBytes(byte[] qualifierPrefix)
      Parameters:
      qualifierPrefix - Column qualifier or prefix of qualifier.
      Returns:
      a byte array encoding column prefix and qualifier/prefix passed.

    • getColumnPrefixInBytes

      byte[] getColumnPrefixInBytes()
      Get the column prefix in bytes.
      Returns:
      column prefix in bytes

    • getColumnFamilyBytes

      byte[] getColumnFamilyBytes()
      Returns column family name(as bytes) associated with this column prefix.
      Returns:
      a byte array encoding column family for this prefix.

    • getValueConverter

      ValueConverter getValueConverter()
      Returns value converter implementation associated with this column prefix.
      Returns:
      a ValueConverter implementation.

    • getCombinedAttrsWithAggr

      Attribute[] getCombinedAttrsWithAggr(Attribute... attributes)
      Return attributed combined with aggregations, if any.
      Returns:
      an array of Attributes

    • supplementCellTimeStamp

      boolean supplementCellTimeStamp()
      Return true if the cell timestamp needs to be supplemented.
      Returns:
      true if the cell timestamp needs to be supplemented