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

Class CubeDataset

java.lang.Object

co.cask.cdap.api.dataset.lib.AbstractDataset

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

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, co.cask.cdap.api.dataset.metrics.MeteredDataset, co.cask.tephra.TransactionAware, Closeable, AutoCloseable

public class CubeDataset
extends co.cask.cdap.api.dataset.lib.AbstractDataset
implements co.cask.cdap.api.dataset.lib.cube.Cube

Implementation of Cube as a Dataset on top of Tables.

Field Summary

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

PROPERTY_RESOLUTIONS

Constructor Summary

Constructors

Constructor and Description
CubeDataset(String name, MetricsTable entityTable, Map<Integer,co.cask.cdap.api.dataset.table.Table> resolutionTables, 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	write(Object ignored, co.cask.cdap.api.dataset.lib.cube.CubeFact cubeFact)

Methods inherited from class co.cask.cdap.api.dataset.lib.AbstractDataset

commitTx, getName, getTransactionAwareName, getTxChanges, postTxCommit, rollbackTx, setMetricsCollector, startTx, toString, updateTx

Methods inherited from class java.lang.Object

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

Constructor Detail

CubeDataset

public CubeDataset(String name,
           MetricsTable entityTable,
           Map<Integer,co.cask.cdap.api.dataset.table.Table> resolutionTables,
           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

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

Overrides:

close in class co.cask.cdap.api.dataset.lib.AbstractDataset

Throws:

IOException