co.cask.cdap.data2.dataset2.lib.timeseries

Class FactCodec

java.lang.Object

co.cask.cdap.data2.dataset2.lib.timeseries.FactCodec

public class FactCodec
extends Object

Helper for serde of Fact into columnar format.

Constructor Summary

Constructors

Constructor and Description
FactCodec(EntityTable entityTable, int resolution, int rollTimebaseInterval)

Method Summary

Methods

Modifier and Type	Method and Description
byte[]	createColumn(long ts)
byte[]	createEndRowKey(List<co.cask.cdap.api.dataset.lib.cube.DimensionValue> dimensionValues, String measureName, long ts, boolean anyAggGroup) Builds end row key for scan operation.
byte[]	createFuzzyRowMask(List<co.cask.cdap.api.dataset.lib.cube.DimensionValue> dimensionValues, String measureName)
byte[]	createRowKey(List<co.cask.cdap.api.dataset.lib.cube.DimensionValue> dimensionValues, String measureName, long ts) Builds row key for write and get operations.
byte[]	createStartRowKey(List<co.cask.cdap.api.dataset.lib.cube.DimensionValue> dimensionValues, String measureName, long ts, boolean anyAggGroup) Builds start row key for scan operation.
List<co.cask.cdap.api.dataset.lib.cube.DimensionValue>	getDimensionValues(byte[] rowKey)
String	getMeasureName(byte[] rowKey)
byte[]	getNextRowKey(byte[] rowKey, int indexOfDimValueToChange) For the given rowKey, return next rowKey that has different dimensionValue at given position.
long	getTimestamp(byte[] rowKey, byte[] column)

Methods inherited from class java.lang.Object

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

Constructor Detail

FactCodec

public FactCodec(EntityTable entityTable,
         int resolution,
         int rollTimebaseInterval)

Method Detail

createRowKey

public byte[] createRowKey(List<co.cask.cdap.api.dataset.lib.cube.DimensionValue> dimensionValues,
                  String measureName,
                  long ts)

Builds row key for write and get operations.

Parameters:

dimensionValues - dimension values

measureName - measure name

ts - timestamp

Returns:

row key

createStartRowKey

public byte[] createStartRowKey(List<co.cask.cdap.api.dataset.lib.cube.DimensionValue> dimensionValues,
                       String measureName,
                       long ts,
                       boolean anyAggGroup)

Builds start row key for scan operation.

Parameters:

dimensionValues - dimension values

measureName - measure name

ts - timestamp

anyAggGroup - if true, then scan matches every aggregation group; if false, scan matches only aggregation group defined with list of dimension values

Returns:

row key

createEndRowKey

public byte[] createEndRowKey(List<co.cask.cdap.api.dataset.lib.cube.DimensionValue> dimensionValues,
                     String measureName,
                     long ts,
                     boolean anyAggGroup)

Builds end row key for scan operation.

Parameters:

dimensionValues - dimension values

measureName - measure name

ts - timestamp

anyAggGroup - if true, then scan matches every aggregation group; if false, scan matches only aggregation group defined with list of dimension values

Returns:

row key

getNextRowKey

public byte[] getNextRowKey(byte[] rowKey,
                   int indexOfDimValueToChange)

For the given rowKey, return next rowKey that has different dimensionValue at given position. returns null if no next row key exist

Parameters:

rowKey - given row key

indexOfDimValueToChange - position of the dimension in a given row key to change

Returns:

next row key

createFuzzyRowMask

public byte[] createFuzzyRowMask(List<co.cask.cdap.api.dataset.lib.cube.DimensionValue> dimensionValues,
                        String measureName)

createColumn

public byte[] createColumn(long ts)

getMeasureName

public String getMeasureName(byte[] rowKey)

getDimensionValues

public List<co.cask.cdap.api.dataset.lib.cube.DimensionValue> getDimensionValues(byte[] rowKey)

getTimestamp

public long getTimestamp(byte[] rowKey,
                byte[] column)