This is an automated email from the ASF dual-hosted git repository. bertty pushed a commit to branch WAYANG-34 in repository https://gitbox.apache.org/repos/asf/incubator-wayang.git
commit b6ca4a45d698e84fe31e09d258f744f5f55aae8b Author: Bertty Contreras-Rojas <[email protected]> AuthorDate: Mon Sep 27 19:59:19 2021 +0200 [WAYANG-34] Correction compilation scala-11 and scala-13 Signed-off-by: bertty <[email protected]> Signed-off-by: bertty <[email protected]> --- .../main/scala/org/apache/wayang/apps/tpch/TpcH.scala | 16 ++++++++++++---- 1 file changed, 12 insertions(+), 4 deletions(-) diff --git a/wayang-benchmark/code/main/scala/org/apache/wayang/apps/tpch/TpcH.scala b/wayang-benchmark/code/main/scala/org/apache/wayang/apps/tpch/TpcH.scala index 60e35a7..c28952f 100644 --- a/wayang-benchmark/code/main/scala/org/apache/wayang/apps/tpch/TpcH.scala +++ b/wayang-benchmark/code/main/scala/org/apache/wayang/apps/tpch/TpcH.scala @@ -20,17 +20,15 @@ package org.apache.wayang.apps.tpch import org.apache.wayang.apps.tpch.queries.{Query1, Query3Database, Query3File, Query3Hybrid} import org.apache.wayang.apps.util.{Parameters, ProfileDBHelper, StdOut} -import org.apache.wayang.apps.tpch.queries.Query1 -import org.apache.wayang.apps.util.ProfileDBHelper import org.apache.wayang.commons.util.profiledb.model.Experiment import org.apache.wayang.core.api.Configuration +import org.apache.wayang.core.platform.Platform import org.apache.wayang.jdbc.platform.JdbcPlatformTemplate import org.apache.wayang.postgres.Postgres import org.apache.wayang.postgres.operators.PostgresTableSource import org.apache.wayang.sqlite3.Sqlite3 import org.apache.wayang.sqlite3.operators.Sqlite3TableSource -import scala.collection.JavaConversions._ /** * This app adapts some TPC-H queries. @@ -50,7 +48,17 @@ object TpcH { val jdbcPlatform = { val jdbcPlatforms = plugins - .flatMap(_.getRequiredPlatforms) + .flatMap( + plugin => { + val list = plugin.getRequiredPlatforms + var array: List[Platform] = List[Platform]() + val iterator = list.iterator() + while(iterator.hasNext){ + array :+= iterator.next() + } + array + } + ) .filter(_.isInstanceOf[JdbcPlatformTemplate]) .distinct if (jdbcPlatforms.size == 1) jdbcPlatforms.head.asInstanceOf[JdbcPlatformTemplate]
