Skip to content

Commit

Permalink
[FLINK-2774] [scala shell] Extended default imports for ScalaShell
Browse files Browse the repository at this point in the history
This closes #1247

-- PRs closed due to inactivity
This closes #1077
  • Loading branch information
chiwanpark authored and fhueske committed Oct 15, 2015
1 parent fbc18b9 commit c82ebbf
Showing 1 changed file with 15 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -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 = {
Expand Down

0 comments on commit c82ebbf

Please sign in to comment.