IGNITE-6723: Fix to ScalarCreditRiskExample: changed type from scala sequence to scala Array for member of serialized closure. This closes #2919.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/b51df62b Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/b51df62b Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/b51df62b Branch: refs/heads/ignite-5937 Commit: b51df62bc0d32372fb465179a98c61ff26514fc9 Parents: 5b3ad97 Author: tledkov-gridgain <[email protected]> Authored: Tue Oct 24 17:42:00 2017 +0300 Committer: devozerov <[email protected]> Committed: Tue Oct 24 17:42:00 2017 +0300 ---------------------------------------------------------------------- .../apache/ignite/scalar/examples/ScalarCreditRiskExample.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/b51df62b/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCreditRiskExample.scala ---------------------------------------------------------------------- diff --git a/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCreditRiskExample.scala b/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCreditRiskExample.scala index 1b0d767..e3ba001 100644 --- a/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCreditRiskExample.scala +++ b/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCreditRiskExample.scala @@ -68,7 +68,7 @@ object ScalarCreditRiskExample { // aware if method was executed just locally or on the 100s of cluster nodes. // Credit risk crdRisk is the minimal amount that creditor has to have // available to cover possible defaults. - val crdRisk = ignite$ @< (closures(ignite$.cluster().nodes().size(), portfolio, horizon, iter, percentile), + val crdRisk = ignite$ @< (closures(ignite$.cluster().nodes().size(), portfolio.toArray, horizon, iter, percentile), (s: Seq[Double]) => s.sum / s.size, null) println("Credit risk [crdRisk=" + crdRisk + ", duration=" + @@ -86,7 +86,7 @@ object ScalarCreditRiskExample { * @param percentile Percentile. * @return Collection of closures. */ - private def closures(clusterSize: Int, portfolio: Seq[Credit], horizon: Int, iter: Int, + private def closures(clusterSize: Int, portfolio: Array[Credit], horizon: Int, iter: Int, percentile: Double): Seq[() => Double] = { val iterPerNode: Int = math.round(iter / clusterSize.asInstanceOf[Float]) val lastNodeIter: Int = iter - (clusterSize - 1) * iterPerNode
