You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by ti...@apache.org on 2016/04/15 03:53:20 UTC

[3/3] incubator-apex-malhar git commit: Merge branch 'APEXMALHAR-2055'

Merge branch 'APEXMALHAR-2055'


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

Branch: refs/heads/master
Commit: 8b2e6a2973f23f4cdcb90f00fb81bc4dd78651bd
Parents: f1d7067 5bd1a99
Author: Timothy Farkas <ti...@datatorrent.com>
Authored: Thu Apr 14 18:52:37 2016 -0700
Committer: Timothy Farkas <ti...@datatorrent.com>
Committed: Thu Apr 14 18:52:37 2016 -0700

----------------------------------------------------------------------
 .gitignore                                      |    3 +-
 .../lib/appdata/gpo/SerdeMapPrimitive.java      |   98 ++
 .../schemas/DimensionalConfigurationSchema.java | 1021 +++++++++++++++---
 .../lib/appdata/schemas/DimensionalSchema.java  |   45 +-
 .../aggregator/AbstractCompositeAggregator.java |  166 +++
 .../AbstractCompositeAggregatorFactory.java     |   49 +
 .../aggregator/AbstractTopBottomAggregator.java |  306 ++++++
 .../dimensions/aggregator/AggregatorBottom.java |   28 +
 .../aggregator/AggregatorRegistry.java          |   87 +-
 .../dimensions/aggregator/AggregatorTop.java    |   28 +
 .../aggregator/AggregatorTopBottomType.java     |   26 +
 .../dimensions/aggregator/AggregatorUtils.java  |   20 +
 .../aggregator/CompositeAggregator.java         |   61 ++
 .../aggregator/CompositeAggregatorFactory.java  |   57 +
 .../DefaultCompositeAggregatorFactory.java      |   64 ++
 .../aggregator/TopBottomAggregatorFactory.java  |   96 ++
 .../lib/io/fs/FileSplitterBaseTest.java         |    2 +-
 .../com/datatorrent/lib/util/TestUtils.java     |    5 +
 18 files changed, 1987 insertions(+), 175 deletions(-)
----------------------------------------------------------------------