flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From fhue...@apache.org
Subject [6/6] flink git commit: [FLINK-2774] [scala shell] Extended default imports for ScalaShell
Date Thu, 15 Oct 2015 13:07:25 GMT
[FLINK-2774] [scala shell] Extended default imports for ScalaShell

This closes #1247

-- PRs closed due to inactivity
This closes #1077


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c82ebbfc
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c82ebbfc
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/c82ebbfc

Branch: refs/heads/master
Commit: c82ebbfce0b11a4b4de3126fb02ccfdad80e0837
Parents: fbc18b9
Author: Chiwan Park <chiwanpark@apache.org>
Authored: Fri Oct 9 17:30:50 2015 +0200
Committer: Fabian Hueske <fhueske@apache.org>
Committed: Thu Oct 15 11:34:01 2015 +0200

----------------------------------------------------------------------
 .../org/apache/flink/api/scala/FlinkILoop.scala     | 16 +++++++++++++++-
 1 file changed, 15 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/c82ebbfc/flink-staging/flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkILoop.scala
----------------------------------------------------------------------
diff --git a/flink-staging/flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkILoop.scala
b/flink-staging/flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkILoop.scala
index f13288b..9fb45a8 100644
--- a/flink-staging/flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkILoop.scala
+++ b/flink-staging/flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkILoop.scala
@@ -96,8 +96,22 @@ class FlinkILoop(
   }
 
   private val packageImports = Seq[String](
+    "org.apache.flink.core.fs._",
+    "org.apache.flink.core.fs.local._",
+    "org.apache.flink.api.common.io._",
+    "org.apache.flink.api.common.aggregators._",
+    "org.apache.flink.api.common.accumulators._",
+    "org.apache.flink.api.common.distributions._",
+    "org.apache.flink.api.common.operators._",
+    "org.apache.flink.api.common.operators.base.JoinOperatorBase.JoinHint",
+    "org.apache.flink.api.common.functions._",
+    "org.apache.flink.api.java.io._",
+    "org.apache.flink.api.java.aggregation._",
+    "org.apache.flink.api.java.functions._",
+    "org.apache.flink.api.java.operators._",
+    "org.apache.flink.api.java.sampling._",
     "org.apache.flink.api.scala._",
-    "org.apache.flink.api.common.functions._"
+    "org.apache.flink.api.scala.utils._"
   )
 
   override def createInterpreter(): Unit = {


Mime
View raw message