co.cask.cdap.data2.dataset2.lib.cube

Class DefaultCube

java.lang.Object

co.cask.cdap.data2.dataset2.lib.cube.DefaultCube

All Implemented Interfaces:

co.cask.cdap.api.data.batch.BatchWritable<Object,co.cask.cdap.api.dataset.lib.cube.CubeFact>, co.cask.cdap.api.dataset.Dataset, co.cask.cdap.api.dataset.lib.cube.Cube, Closeable, AutoCloseable

public class DefaultCube
extends Object
implements co.cask.cdap.api.dataset.lib.cube.Cube

Default implementation of Cube.

Field Summary

Fields inherited from interface co.cask.cdap.api.dataset.lib.cube.Cube

PROPERTY_RESOLUTIONS

Constructor Summary

Constructors

Constructor and Description
DefaultCube(int[] resolutions, FactTableSupplier factTableSupplier, Map<String,? extends Aggregation> aggregations)

Method Summary

Methods

Modifier and Type	Method and Description
void	add(Collection<? extends co.cask.cdap.api.dataset.lib.cube.CubeFact> facts)
void	add(co.cask.cdap.api.dataset.lib.cube.CubeFact fact)
void	close()
void	delete(co.cask.cdap.api.dataset.lib.cube.CubeDeleteQuery query)
Collection<co.cask.cdap.api.dataset.lib.cube.DimensionValue>	findDimensionValues(co.cask.cdap.api.dataset.lib.cube.CubeExploreQuery query)
Collection<String>	findMeasureNames(co.cask.cdap.api.dataset.lib.cube.CubeExploreQuery query)
Collection<co.cask.cdap.api.dataset.lib.cube.TimeSeries>	query(co.cask.cdap.api.dataset.lib.cube.CubeQuery query)
void	setMetricsCollector(MetricsCollector metrics) Sets MetricsCollector for metrics reporting.
void	write(Object ignored, co.cask.cdap.api.dataset.lib.cube.CubeFact cubeFact)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultCube

public DefaultCube(int[] resolutions,
           FactTableSupplier factTableSupplier,
           Map<String,? extends Aggregation> aggregations)

Method Detail

add

public void add(co.cask.cdap.api.dataset.lib.cube.CubeFact fact)

Specified by:

add in interface co.cask.cdap.api.dataset.lib.cube.Cube

add

public void add(Collection<? extends co.cask.cdap.api.dataset.lib.cube.CubeFact> facts)

Specified by:

add in interface co.cask.cdap.api.dataset.lib.cube.Cube

query

public Collection<co.cask.cdap.api.dataset.lib.cube.TimeSeries> query(co.cask.cdap.api.dataset.lib.cube.CubeQuery query)

Specified by:

query in interface co.cask.cdap.api.dataset.lib.cube.Cube

delete

public void delete(co.cask.cdap.api.dataset.lib.cube.CubeDeleteQuery query)

Specified by:

delete in interface co.cask.cdap.api.dataset.lib.cube.Cube

findDimensionValues

public Collection<co.cask.cdap.api.dataset.lib.cube.DimensionValue> findDimensionValues(co.cask.cdap.api.dataset.lib.cube.CubeExploreQuery query)

Specified by:

findDimensionValues in interface co.cask.cdap.api.dataset.lib.cube.Cube

findMeasureNames

public Collection<String> findMeasureNames(co.cask.cdap.api.dataset.lib.cube.CubeExploreQuery query)

Specified by:

findMeasureNames in interface co.cask.cdap.api.dataset.lib.cube.Cube

setMetricsCollector

public void setMetricsCollector(MetricsCollector metrics)

Sets MetricsCollector for metrics reporting.

Parameters:

metrics - MetricsCollector to set.

write

public void write(Object ignored,
         co.cask.cdap.api.dataset.lib.cube.CubeFact cubeFact)

Specified by:

write in interface co.cask.cdap.api.data.batch.BatchWritable<Object,co.cask.cdap.api.dataset.lib.cube.CubeFact>

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException