Repository: incubator-apex-core Updated Branches: refs/heads/devel-3 7888aa244 -> b57972bd3
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/devel-3 Commit: b57972bd336f8db6f41c72d2c8c7c95ff5ca934b Parents: 7888aa2 Author: Chandni Singh <[email protected]> Authored: Thu Sep 10 09:48:41 2015 -0700 Committer: Chandni Singh <[email protected]> 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) {
