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

Class FactTable

java.lang.Object

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

All Implemented Interfaces:

Closeable, AutoCloseable

public final class FactTable
extends Object
implements Closeable

Table for storing Facts. Thread safe as long as the passed into the constructor datasets are thread safe (usually is not the case).

Constructor Summary

Constructors

Constructor and Description
FactTable(MetricsTable timeSeriesTable, EntityTable entityTable, int resolution, int rollTime) Creates an instance of FactTable.

Method Summary

Methods

Modifier and Type	Method and Description
void	add(List<Fact> facts)
void	close()
void	delete(FactScan scan) Delete entries in fact table.
Set<String>	findMeasureNames(List<String> allDimensionNames, Map<String,String> dimensionSlice, long startTs, long endTs) Finds all measure names of the facts that match given DimensionValues and time range.
Set<co.cask.cdap.api.dataset.lib.cube.DimensionValue>	findSingleDimensionValue(List<String> allDimensionNames, Map<String,String> dimensionSlice, long startTs, long endTs) Searches for first non-null valued dimensions in records that contain given list of dimensions and match given dimension values in given time range.
static byte[][]	getSplits(int aggGroupsCount)
FactScanner	scan(FactScan scan)
void	setMetricsCollector(MetricsCollector metrics)

Methods inherited from class java.lang.Object

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

Constructor Detail

FactTable

public FactTable(MetricsTable timeSeriesTable,
         EntityTable entityTable,
         int resolution,
         int rollTime)

Creates an instance of FactTable.

Parameters:

timeSeriesTable - A table for storing facts information.

entityTable - The table for storing dimension encoding mappings.

resolution - Resolution in seconds

rollTime - Number of resolution for writing to a new row with a new timebase. Meaning the differences between timebase of two consecutive rows divided by resolution seconds. It essentially defines how many columns per row in the table. This value should be < 65535.

Method Detail

setMetricsCollector

public void setMetricsCollector(MetricsCollector metrics)

add

public void add(List<Fact> facts)

scan

public FactScanner scan(FactScan scan)

delete

public void delete(FactScan scan)

Delete entries in fact table.

Parameters:

scan - specifies deletion criteria

findSingleDimensionValue

public Set<co.cask.cdap.api.dataset.lib.cube.DimensionValue> findSingleDimensionValue(List<String> allDimensionNames,
                                                                             Map<String,String> dimensionSlice,
                                                                             long startTs,
                                                                             long endTs)

Searches for first non-null valued dimensions in records that contain given list of dimensions and match given dimension values in given time range. Returned dimension values are those that are not defined in given dimension values.

Parameters:

allDimensionNames - list of all dimension names to be present in the record

dimensionSlice - dimension values to filter by, null means any non-null value.

startTs - start of the time range, in seconds

endTs - end of the time range, in seconds

Returns:

Set of DimensionValues

findMeasureNames

public Set<String> findMeasureNames(List<String> allDimensionNames,
                           Map<String,String> dimensionSlice,
                           long startTs,
                           long endTs)

Finds all measure names of the facts that match given DimensionValues and time range.

Parameters:

allDimensionNames - list of all dimension names to be present in the fact record

dimensionSlice - dimension values to filter by, null means any non-null value.

startTs - start timestamp, in sec

endTs - end timestamp, in sec

Returns:

Set of measure names

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

getSplits

public static byte[][] getSplits(int aggGroupsCount)