Merge pull request #1968 from huafengw/fix#1966 fix #1966 make Partitioner API Java compatible
Project: http://git-wip-us.apache.org/repos/asf/incubator-gearpump/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-gearpump/commit/0827adf3 Tree: http://git-wip-us.apache.org/repos/asf/incubator-gearpump/tree/0827adf3 Diff: http://git-wip-us.apache.org/repos/asf/incubator-gearpump/diff/0827adf3 Branch: refs/heads/master Commit: 0827adf3bec894e026d68f8851cb8c75dc769445 Parents: aff1fe3 25aacb2 Author: Huafeng Wang <[email protected]> Authored: Wed Feb 17 16:56:31 2016 +0800 Committer: Huafeng Wang <[email protected]> Committed: Wed Feb 17 16:56:31 2016 +0800 ---------------------------------------------------------------------- .../partitioner/BroadcastPartitioner.scala | 11 +++++++-- .../io/gearpump/partitioner/Partitioner.scala | 4 +-- .../streaming/examples/stock/QueryServer.scala | 26 ++++++++++---------- .../examples/transport/QueryServer.scala | 18 +++++++------- .../storm/partitioner/StormPartitioner.scala | 6 ++--- .../storm/topology/GearpumpTuple.scala | 2 +- .../experiments/storm/util/Grouper.scala | 25 ++++++++++--------- .../storm/util/StormOutputCollector.scala | 10 ++++---- .../partitioner/StormPartitionerSpec.scala | 6 ++--- .../storm/util/StormOutputCollectorSpec.scala | 10 ++++---- .../io/gearpump/services/MasterService.scala | 22 +++++++---------- .../streaming/appmaster/TaskManagerSpec.scala | 18 ++++---------- 12 files changed, 77 insertions(+), 81 deletions(-) ----------------------------------------------------------------------
