Hi Max, yes, we changed the Scala API a bit and synced its features with the Java API. There are several example programs written in the new Scala API under ./flink-examples/flink-scala-examples that show you how to use the API. I think also the Scala API documentation was updated. Not sure if the changes are already reflected on the website, but you can build the docs locally from the sources with ./docs/build-docs.sh (or similar).
Best, Fabian 2014-09-26 10:20 GMT+02:00 Maximilian Alber <[email protected]>: > Hi Flinkers, > > I tried to migrate to 0.7 for new features aka Broadcast Variables in > Scala. Unfortunately the code structure seemed to have changed: > > [INFO] Compiling 2 source files to > /media/alber_disk/alber/Arbeit/Uni/Kurse/MA/repo/flink/bump_boost/target/classes > at 1411719085848 > [ERROR] > /media/alber_disk/alber/Arbeit/Uni/Kurse/MA/repo/flink/bump_boost/src/main/scala/bumpboost/BumpBoost.scala:7: > error: object TextFile is not a member of package org.apache.flink.api.scala > [ERROR] import org.apache.flink.api.scala.TextFile > [ERROR] ^ > [ERROR] > /media/alber_disk/alber/Arbeit/Uni/Kurse/MA/repo/flink/bump_boost/src/main/scala/bumpboost/BumpBoost.scala:8: > error: object ScalaPlan is not a member of package > org.apache.flink.api.scala > [ERROR] import org.apache.flink.api.scala.ScalaPlan > [ERROR] ^ > [ERROR] > /media/alber_disk/alber/Arbeit/Uni/Kurse/MA/repo/flink/bump_boost/src/main/scala/bumpboost/BumpBoost.scala:13: > error: object functions is not a member of package > org.apache.flink.api.scala > [ERROR] import org.apache.flink.api.scala.functions.MapFunction > > > Thus I tried to examine the new quickstart code on > https://flink.incubator.apache.org/docs/0.7-incubating/scala_api_quickstart.html > > Unfortunately the quickstart script still creates a project for 0.6 and > using Maven results in an error too: > > [INFO] --- maven-archetype-plugin:2.2:generate (default-cli) @ > standalone-pom --- > [INFO] Generating project in Interactive mode > [INFO] Archetype repository missing. Using the one from > [org.apache.flink:flink-quickstart-scala:0.6.1-incubating] found in catalog > remote > Downloading: > http://repo.maven.apache.org/maven2/org/apache/flink/flink-quickstart-scala/0.7-incubating/flink-quickstart-scala-0.7-incubating.jar > [INFO] > ------------------------------------------------------------------------ > [INFO] BUILD FAILURE > [INFO] > ------------------------------------------------------------------------ > [INFO] Total time: 18.857s > [INFO] Finished at: Fri Sep 26 10:17:49 CEST 2014 > [INFO] Final Memory: 12M/104M > [INFO] > ------------------------------------------------------------------------ > [ERROR] Failed to execute goal > org.apache.maven.plugins:maven-archetype-plugin:2.2:generate (default-cli) > on project standalone-pom: The desired archetype does not exist > (org.apache.flink:flink-quickstart-scala:0.7-incubating) -> [Help 1] > > > Is there some explanation how to move code from 0.6 to 0.7? Or an example > which creates a Plan? > > Thanks! > Cheers, > Max > > >
