Repository: reef Updated Branches: refs/heads/master 9c3fd46cc -> 9349e99b5
[REEF-1767] Change PipelinedBroadcastAndReduce.Run() in IMRU examples to public JIRA: [REEF-1767](https://issues.apache.org/jira/browse/REEF-1767) Pull request: This closes #1284 Project: http://git-wip-us.apache.org/repos/asf/reef/repo Commit: http://git-wip-us.apache.org/repos/asf/reef/commit/9349e99b Tree: http://git-wip-us.apache.org/repos/asf/reef/tree/9349e99b Diff: http://git-wip-us.apache.org/repos/asf/reef/diff/9349e99b Branch: refs/heads/master Commit: 9349e99b5ce9f085610a0cdb46d3f0d7028e1540 Parents: 9c3fd46 Author: Julia Wang <[email protected]> Authored: Tue Apr 4 18:39:14 2017 -0700 Committer: Sergiy Matusevych <[email protected]> Committed: Thu Apr 6 20:38:36 2017 -0700 ---------------------------------------------------------------------- .../PipelinedBroadcastReduce/PipelinedBroadcastAndReduce.cs | 2 +- .../PipelinedBroadcastAndReduceWithFaultTolerant.cs | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/reef/blob/9349e99b/lang/cs/Org.Apache.REEF.IMRU.Examples/PipelinedBroadcastReduce/PipelinedBroadcastAndReduce.cs ---------------------------------------------------------------------- diff --git a/lang/cs/Org.Apache.REEF.IMRU.Examples/PipelinedBroadcastReduce/PipelinedBroadcastAndReduce.cs b/lang/cs/Org.Apache.REEF.IMRU.Examples/PipelinedBroadcastReduce/PipelinedBroadcastAndReduce.cs index 47c01c3..f4554f5 100644 --- a/lang/cs/Org.Apache.REEF.IMRU.Examples/PipelinedBroadcastReduce/PipelinedBroadcastAndReduce.cs +++ b/lang/cs/Org.Apache.REEF.IMRU.Examples/PipelinedBroadcastReduce/PipelinedBroadcastAndReduce.cs @@ -44,7 +44,7 @@ namespace Org.Apache.REEF.IMRU.Examples.PipelinedBroadcastReduce /// <summary> /// Runs the actual broadcast and reduce job /// </summary> - internal void Run(int numberofMappers, int chunkSize, int numIterations, int dim, int mapperMemory, int updateTaskMemory) + public void Run(int numberofMappers, int chunkSize, int numIterations, int dim, int mapperMemory, int updateTaskMemory) { var results = _imruClient.Submit<int[], int[], int[], Stream>( CreateJobDefinitionBuilder(numberofMappers, chunkSize, numIterations, dim, mapperMemory, updateTaskMemory) http://git-wip-us.apache.org/repos/asf/reef/blob/9349e99b/lang/cs/Org.Apache.REEF.IMRU.Examples/PipelinedBroadcastReduce/PipelinedBroadcastAndReduceWithFaultTolerant.cs ---------------------------------------------------------------------- diff --git a/lang/cs/Org.Apache.REEF.IMRU.Examples/PipelinedBroadcastReduce/PipelinedBroadcastAndReduceWithFaultTolerant.cs b/lang/cs/Org.Apache.REEF.IMRU.Examples/PipelinedBroadcastReduce/PipelinedBroadcastAndReduceWithFaultTolerant.cs index 9ec3a69..ea8ece4 100644 --- a/lang/cs/Org.Apache.REEF.IMRU.Examples/PipelinedBroadcastReduce/PipelinedBroadcastAndReduceWithFaultTolerant.cs +++ b/lang/cs/Org.Apache.REEF.IMRU.Examples/PipelinedBroadcastReduce/PipelinedBroadcastAndReduceWithFaultTolerant.cs @@ -48,7 +48,7 @@ namespace Org.Apache.REEF.IMRU.Examples.PipelinedBroadcastReduce /// <summary> /// Runs the actual broadcast and reduce job with fault tolerance /// </summary> - internal void Run(int numberofMappers, int chunkSize, int numIterations, int dim, int mapperMemory, int updateTaskMemory, int maxRetryNumberInRecovery, int totalNumberOfForcedFailures) + public void Run(int numberofMappers, int chunkSize, int numIterations, int dim, int mapperMemory, int updateTaskMemory, int maxRetryNumberInRecovery, int totalNumberOfForcedFailures) { var results = _imruClient.Submit<int[], int[], int[], Stream>( CreateJobDefinitionBuilder(numberofMappers, chunkSize, numIterations, dim, mapperMemory, updateTaskMemory)
