apex-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vro...@apache.org
Subject [08/50] [abbrv] incubator-apex-core git commit: APEX-102 #resolve #comment converting time-buckets and dimensions to list
Date Thu, 24 Sep 2015 02:37:27 GMT
APEX-102 #resolve #comment converting time-buckets and dimensions to list


Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/commit/b57972bd
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/tree/b57972bd
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/diff/b57972bd

Branch: refs/heads/feature-module
Commit: b57972bd336f8db6f41c72d2c8c7c95ff5ca934b
Parents: 7888aa2
Author: Chandni Singh <csingh@apache.org>
Authored: Thu Sep 10 09:48:41 2015 -0700
Committer: Chandni Singh <csingh@apache.org>
Committed: Thu Sep 10 09:48:41 2015 -0700

----------------------------------------------------------------------
 .../java/com/datatorrent/stram/appdata/AppDataPushAgent.java     | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/b57972bd/engine/src/main/java/com/datatorrent/stram/appdata/AppDataPushAgent.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/com/datatorrent/stram/appdata/AppDataPushAgent.java b/engine/src/main/java/com/datatorrent/stram/appdata/AppDataPushAgent.java
index 3ddb313..52ce622 100644
--- a/engine/src/main/java/com/datatorrent/stram/appdata/AppDataPushAgent.java
+++ b/engine/src/main/java/com/datatorrent/stram/appdata/AppDataPushAgent.java
@@ -261,14 +261,14 @@ public class AppDataPushAgent extends AbstractService
         valueSchema.put("type", type == null ? metricValue.getClass().getCanonicalName()
: type);
         String[] dimensionAggregators = metricAggregatorMeta.getDimensionAggregatorsFor(metricName);
         if (dimensionAggregators != null) {
-          valueSchema.put("dimensionAggregators", dimensionAggregators);
+          valueSchema.put("dimensionAggregators", Arrays.asList(dimensionAggregators));
         }
         valueSchemas.put(valueSchema);
       }
       result.put("values", valueSchemas);
       String[] timeBuckets = metricAggregatorMeta.getTimeBuckets();
       if (timeBuckets != null) {
-        result.put("timeBuckets", timeBuckets);
+        result.put("timeBuckets", Arrays.asList(timeBuckets));
       }
 
     } catch (JSONException ex) {


Mime
View raw message