You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2017/10/25 09:41:20 UTC
[46/50] [abbrv] ignite git commit: IGNITE-6723: Fix to
ScalarCreditRiskExample: changed type from scala sequence to scala Array for
member of serialized closure. This closes #2919.
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-3478
Commit: b51df62bc0d32372fb465179a98c61ff26514fc9
Parents: 5b3ad97
Author: tledkov-gridgain <tl...@gridgain.com>
Authored: Tue Oct 24 17:42:00 2017 +0300
Committer: devozerov <vo...@gridgain.com>
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