You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by fh...@apache.org on 2015/10/15 15:07:25 UTC
[6/6] flink git commit: [FLINK-2774] [scala shell] Extended default
imports for ScalaShell
[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 <ch...@apache.org>
Authored: Fri Oct 9 17:30:50 2015 +0200
Committer: Fabian Hueske <fh...@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 = {