gCubeSystem
/
accounting-aggregator-se-plugin
15
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

First release 

git-svn-id: https://svn.d4science.research-infrastructures.eu/gcube/trunk/accounting/accounting-aggregator-se-plugin@130904 82a268e6-3cf1-43bd-a215-b396298e98cf
This commit is contained in:
Alessandro Pieve 2016-07-29 09:49:12 +00:00
parent 88a43cdcd1
commit e446bed8b4
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/java/org/gcube/accounting/aggregator/plugin/AccountingAggregatorPlugin.java
View File

@ -108,7 +108,7 @@ public class AccountingAggregatorPlugin extends Plugin<AccountingAggregatorPlugi
inputStartTime=(Integer)inputs.get("startTime"); inputStartTime=(Integer)inputs.get("startTime");
Boolean currentScope =false; Boolean currentScope =false;
String scope=""; String scope=null;
if (inputs.containsKey("currentScope")) if (inputs.containsKey("currentScope"))
currentScope=(Boolean)inputs.get("currentScope"); currentScope=(Boolean)inputs.get("currentScope");
@ -155,6 +155,7 @@ public class AccountingAggregatorPlugin extends Plugin<AccountingAggregatorPlugi
throw e; throw e;
} }
Cluster cluster = CouchbaseCluster.create(ENV, url); Cluster cluster = CouchbaseCluster.create(ENV, url);
//Define a type for aggregate //Define a type for aggregate

2
src/test/java/org/gcube/accounting/aggregator/plugin/Tests.java
View File

@ -35,7 +35,7 @@ public class Tests {
//specify bucket //specify bucket
inputs.put("bucket","accounting_service"); inputs.put("bucket","accounting_service");
//current scope //current scope
inputs.put("currentScope",true); inputs.put("currentScope",false);
//specify user for save to workspace //specify user for save to workspace
//specify a recovery 0 default recovery and aggregate, 1 only aggregate, 2 only recovery //specify a recovery 0 default recovery and aggregate, 1 only aggregate, 2 only recovery