public class AccountingPersistenceQueryCouchBase extends Object implements org.gcube.accounting.analytics.persistence.AccountingPersistenceBackendQuery
Modifier and Type | Field and Description |
---|---|
static String |
BUCKET_JOB_NAME_PROPERTY_KEY |
static String |
BUCKET_PORTLET_NAME_PROPERTY_KEY |
static String |
BUCKET_SERVICE_NAME_PROPERTY_KEY |
static String |
BUCKET_STORAGE_NAME_PROPERTY_KEY |
static String |
BUCKET_TASK_NAME_PROPERTY_KEY |
protected com.couchbase.client.java.Bucket |
bucketJob |
protected String |
bucketNameJob |
protected String |
bucketNamePortlet |
protected String |
bucketNameService |
protected String |
bucketNameStorage |
protected String |
bucketNameTask |
protected com.couchbase.client.java.Bucket |
bucketPortlet |
protected com.couchbase.client.java.Bucket |
bucketService |
protected com.couchbase.client.java.Bucket |
bucketStorage |
protected com.couchbase.client.java.Bucket |
bucketTask |
protected com.couchbase.client.java.Cluster |
cluster |
protected static com.couchbase.client.java.env.CouchbaseEnvironment |
ENV |
static long |
ENV_TIME_OUT |
protected static String |
KEYS_SEPARATOR
Used in the name of map reduce to separate keys used as filter
|
protected static String |
MAP_REDUCE__DESIGN |
protected static String |
MAP_REDUCE_ALL |
static String |
PASSWORD_PROPERTY_KEY |
static String |
URL_PROPERTY_KEY |
Constructor and Description |
---|
AccountingPersistenceQueryCouchBase() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
protected Calendar |
getCalendar(org.json.JSONObject obj,
org.gcube.accounting.analytics.TemporalConstraint.AggregationMode aggregationMode) |
protected Calendar |
getCalendarFromArray(com.couchbase.client.java.document.json.JsonArray array) |
protected String |
getDesignDocId(Class<? extends org.gcube.documentstore.records.AggregatedRecord<?,?>> recordClass) |
SortedSet<org.gcube.accounting.analytics.NumberedFilter> |
getFilterValues(Class<? extends org.gcube.documentstore.records.AggregatedRecord<?,?>> clz,
org.gcube.accounting.analytics.TemporalConstraint temporalConstraint,
List<org.gcube.accounting.analytics.Filter> filters,
String key) |
static String |
getMapReduceFunctionName(Collection<String> collection) |
SortedSet<org.gcube.accounting.analytics.NumberedFilter> |
getNextPossibleValues(Class<? extends org.gcube.documentstore.records.AggregatedRecord<?,?>> clz,
org.gcube.accounting.analytics.TemporalConstraint temporalConstraint,
List<org.gcube.accounting.analytics.Filter> filters,
String key,
String orderingProperty) |
protected String |
getQualifiedProperty(String property) |
protected com.couchbase.client.java.document.json.JsonArray |
getRangeKey(long time,
org.gcube.accounting.analytics.TemporalConstraint.AggregationMode aggregationMode,
boolean wildCard,
boolean endKey) |
protected String |
getSpecializedProperty(Class<? extends org.gcube.documentstore.records.AggregatedRecord<?,?>> clz,
String property) |
SortedMap<Calendar,org.gcube.accounting.analytics.Info> |
getTimeSeries(Class<? extends org.gcube.documentstore.records.AggregatedRecord<?,?>> clz,
org.gcube.accounting.analytics.TemporalConstraint temporalConstraint,
List<org.gcube.accounting.analytics.Filter> filters) |
SortedMap<org.gcube.accounting.analytics.NumberedFilter,SortedMap<Calendar,org.gcube.accounting.analytics.Info>> |
getTopValues(Class<? extends org.gcube.documentstore.records.AggregatedRecord<?,?>> clz,
org.gcube.accounting.analytics.TemporalConstraint temporalConstraint,
List<org.gcube.accounting.analytics.Filter> filters,
String topKey,
String orderingProperty) |
org.json.JSONObject |
getUsageValue(Class<? extends org.gcube.documentstore.records.AggregatedRecord<?,?>> clz,
org.gcube.accounting.analytics.TemporalConstraint temporalConstraint,
org.gcube.accounting.analytics.Filter applicant) |
protected SortedMap<Calendar,org.gcube.accounting.analytics.Info> |
mapReduceQuery(Class<? extends org.gcube.documentstore.records.AggregatedRecord<?,?>> clz,
org.gcube.accounting.analytics.TemporalConstraint temporalConstraint,
List<org.gcube.accounting.analytics.Filter> filters) |
void |
prepareConnection(org.gcube.accounting.analytics.persistence.AccountingPersistenceBackendQueryConfiguration configuration) |
protected Map<Calendar,org.gcube.accounting.analytics.Info> |
selectQuery(Class<? extends org.gcube.documentstore.records.AggregatedRecord<?,?>> clz,
org.gcube.accounting.analytics.TemporalConstraint temporalConstraint,
List<org.gcube.accounting.analytics.Filter> filters) |
public static final String URL_PROPERTY_KEY
public static final String PASSWORD_PROPERTY_KEY
public static final String BUCKET_STORAGE_NAME_PROPERTY_KEY
public static final String BUCKET_SERVICE_NAME_PROPERTY_KEY
public static final String BUCKET_PORTLET_NAME_PROPERTY_KEY
public static final String BUCKET_JOB_NAME_PROPERTY_KEY
public static final String BUCKET_TASK_NAME_PROPERTY_KEY
public static final long ENV_TIME_OUT
protected static final com.couchbase.client.java.env.CouchbaseEnvironment ENV
protected com.couchbase.client.java.Cluster cluster
protected com.couchbase.client.java.Bucket bucketStorage
protected String bucketNameStorage
protected com.couchbase.client.java.Bucket bucketService
protected String bucketNameService
protected com.couchbase.client.java.Bucket bucketPortlet
protected String bucketNamePortlet
protected com.couchbase.client.java.Bucket bucketJob
protected String bucketNameJob
protected com.couchbase.client.java.Bucket bucketTask
protected String bucketNameTask
protected static final String MAP_REDUCE__DESIGN
protected static final String MAP_REDUCE_ALL
protected static final String KEYS_SEPARATOR
public void prepareConnection(org.gcube.accounting.analytics.persistence.AccountingPersistenceBackendQueryConfiguration configuration) throws Exception
prepareConnection
in interface org.gcube.accounting.analytics.persistence.AccountingPersistenceBackendQuery
Exception
public void close() throws Exception
close
in interface org.gcube.accounting.analytics.persistence.AccountingPersistenceBackendQuery
Exception
protected Calendar getCalendar(org.json.JSONObject obj, org.gcube.accounting.analytics.TemporalConstraint.AggregationMode aggregationMode) throws NumberFormatException, org.json.JSONException
NumberFormatException
org.json.JSONException
protected Map<Calendar,org.gcube.accounting.analytics.Info> selectQuery(Class<? extends org.gcube.documentstore.records.AggregatedRecord<?,?>> clz, org.gcube.accounting.analytics.TemporalConstraint temporalConstraint, List<org.gcube.accounting.analytics.Filter> filters) throws Exception
Exception
protected Calendar getCalendarFromArray(com.couchbase.client.java.document.json.JsonArray array) throws org.json.JSONException
org.json.JSONException
protected com.couchbase.client.java.document.json.JsonArray getRangeKey(long time, org.gcube.accounting.analytics.TemporalConstraint.AggregationMode aggregationMode, boolean wildCard, boolean endKey) throws org.json.JSONException
org.json.JSONException
protected String getDesignDocId(Class<? extends org.gcube.documentstore.records.AggregatedRecord<?,?>> recordClass) throws InstantiationException, IllegalAccessException
public static String getMapReduceFunctionName(Collection<String> collection)
protected SortedMap<Calendar,org.gcube.accounting.analytics.Info> mapReduceQuery(Class<? extends org.gcube.documentstore.records.AggregatedRecord<?,?>> clz, org.gcube.accounting.analytics.TemporalConstraint temporalConstraint, List<org.gcube.accounting.analytics.Filter> filters) throws Exception
Exception
public SortedMap<Calendar,org.gcube.accounting.analytics.Info> getTimeSeries(Class<? extends org.gcube.documentstore.records.AggregatedRecord<?,?>> clz, org.gcube.accounting.analytics.TemporalConstraint temporalConstraint, List<org.gcube.accounting.analytics.Filter> filters) throws Exception
getTimeSeries
in interface org.gcube.accounting.analytics.persistence.AccountingPersistenceBackendQuery
Exception
public SortedMap<org.gcube.accounting.analytics.NumberedFilter,SortedMap<Calendar,org.gcube.accounting.analytics.Info>> getTopValues(Class<? extends org.gcube.documentstore.records.AggregatedRecord<?,?>> clz, org.gcube.accounting.analytics.TemporalConstraint temporalConstraint, List<org.gcube.accounting.analytics.Filter> filters, String topKey, String orderingProperty) throws Exception
getTopValues
in interface org.gcube.accounting.analytics.persistence.AccountingPersistenceBackendQuery
Exception
protected String getSpecializedProperty(Class<? extends org.gcube.documentstore.records.AggregatedRecord<?,?>> clz, String property)
public SortedSet<org.gcube.accounting.analytics.NumberedFilter> getNextPossibleValues(Class<? extends org.gcube.documentstore.records.AggregatedRecord<?,?>> clz, org.gcube.accounting.analytics.TemporalConstraint temporalConstraint, List<org.gcube.accounting.analytics.Filter> filters, String key, String orderingProperty) throws Exception
getNextPossibleValues
in interface org.gcube.accounting.analytics.persistence.AccountingPersistenceBackendQuery
Exception
public SortedSet<org.gcube.accounting.analytics.NumberedFilter> getFilterValues(Class<? extends org.gcube.documentstore.records.AggregatedRecord<?,?>> clz, org.gcube.accounting.analytics.TemporalConstraint temporalConstraint, List<org.gcube.accounting.analytics.Filter> filters, String key) throws Exception
getFilterValues
in interface org.gcube.accounting.analytics.persistence.AccountingPersistenceBackendQuery
Exception
public org.json.JSONObject getUsageValue(Class<? extends org.gcube.documentstore.records.AggregatedRecord<?,?>> clz, org.gcube.accounting.analytics.TemporalConstraint temporalConstraint, org.gcube.accounting.analytics.Filter applicant) throws Exception
getUsageValue
in interface org.gcube.accounting.analytics.persistence.AccountingPersistenceBackendQuery
Exception
Copyright © 2016. All Rights Reserved.