co.cask.cdap.examples.webanalytics

Class UniqueVisitCount

java.lang.Object

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

co.cask.cdap.examples.webanalytics.UniqueVisitCount

All Implemented Interfaces:

RecordScannable<KeyValue<String,Long>>, Dataset, MeteredDataset, Closeable, AutoCloseable, org.apache.tephra.TransactionAware

public class UniqueVisitCount
extends AbstractDataset
implements RecordScannable<KeyValue<String,Long>>

A Dataset that stores IP to total visit counts. It uses a KeyValueTable underneath to hold the data. It also implements the RecordScannable interface so that it can be queried using ad-hoc SQL.

Constructor Summary

Constructors

Constructor and Description
UniqueVisitCount(DatasetSpecification spec, KeyValueTable keyValueTable) Constructor for the Dataset.

Method Summary

Methods

Modifier and Type	Method and Description
RecordScanner<KeyValue<String,Long>>	createSplitRecordScanner(Split split)
long	getCount(String ip) Reads the visit count for a given IP.
Type	getRecordType()
List<Split>	getSplits()
void	increment(String ip, long amount) Performs increments of visit count of the given IP.

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

close, 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

Methods inherited from interface java.io.Closeable

close

Constructor Detail

UniqueVisitCount

public UniqueVisitCount(DatasetSpecification spec,
                KeyValueTable keyValueTable)

Constructor for the Dataset. Request to use a KeyValueTable.

Parameters:

spec - The specification of the Dataset instance.

keyValueTable - The underlying table

Method Detail

increment

public void increment(String ip,
             long amount)

Performs increments of visit count of the given IP.

Parameters:

ip - The IP to increment

amount - The amount to increment

getCount

public long getCount(String ip)

Reads the visit count for a given IP.

Parameters:

ip - The IP to lookup

Returns:

the number of visits

getRecordType

public Type getRecordType()

Specified by:

getRecordType in interface RecordScannable<KeyValue<String,Long>>

getSplits

public List<Split> getSplits()

Specified by:

getSplits in interface RecordScannable<KeyValue<String,Long>>

createSplitRecordScanner

public RecordScanner<KeyValue<String,Long>> createSplitRecordScanner(Split split)

Specified by:

createSplitRecordScanner in interface RecordScannable<KeyValue<String,Long>>