You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by vr...@apache.org on 2015/09/24 04:37:27 UTC
[08/50] [abbrv] incubator-apex-core git commit: APEX-102 #resolve
#comment converting time-buckets and dimensions to list
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 <cs...@apache.org>
Authored: Thu Sep 10 09:48:41 2015 -0700
Committer: Chandni Singh <cs...@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) {