[
https://issues.apache.org/jira/browse/FLINK-1907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14543869#comment-14543869
]
ASF GitHub Bot commented on FLINK-1907:
---------------------------------------
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/672#discussion_r30331377
--- Diff:
flink-staging/flink-scala-shell/src/main/scala/org.apache.flink/api/scala/FlinkILoop.scala
---
@@ -0,0 +1,199 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.flink.api.scala
+
+import java.io.{BufferedReader, File, FileOutputStream}
+
+import scala.tools.nsc.Settings
+import scala.tools.nsc.interpreter._
+
+import org.apache.flink.api.java.ScalaShellRemoteEnvironment
+import org.apache.flink.util.AbstractID
+
+/**
+ * Created by Nikolaas Steenbergen on 16-4-15.
+ */
+class FlinkILoop(val host: String,
+ val port: Int,
+ in0: Option[BufferedReader],
+ out0: JPrintWriter)
+ extends ILoop(in0, out0) {
+
+ def this(host:String, port:Int, in0: BufferedReader, out: JPrintWriter){
+ this(host:String, port:Int, Some(in0), out)
+ }
+
+ def this(host:String, port:Int){
+ this(host:String,port: Int,None, new JPrintWriter(Console.out, true))
+ }
+ // remote environment
+ private val remoteEnv: ScalaShellRemoteEnvironment = {
+ val remoteEnv = new ScalaShellRemoteEnvironment(host, port, this)
+ remoteEnv
+ }
+
+ // local environment
+ val scalaEnv: ExecutionEnvironment = {
+ val scalaEnv = new ExecutionEnvironment(remoteEnv)
+ scalaEnv
+ }
+
+
+ /**
+ * we override the process (initialization) method to
+ * insert Flink related stuff for not using a file for input.
+ */
+
+ /** Create a new interpreter. */
+ override def createInterpreter() {
+ if (addedClasspath != "")
+ {
+ settings.classpath append addedClasspath
+ }
+ intp = new ILoopInterpreter
+ intp.quietRun("import org.apache.flink.api.scala._")
+ intp.quietRun("import org.apache.flink.api.common.functions._")
+ intp.bind("env", this.scalaEnv)
+ }
+
+
+
+ /**
+ * creates a temporary directory to store compiled console files
+ */
+ private val tmpDirBase: File = {
+ // get unique temporary folder:
+ val abstractID: String = new AbstractID().toString
+ val tmpDir: File = new File(
+ System.getProperty("java.io.tmpdir"),
+ "scala_shell_tmp-" + abstractID)
+ if (!tmpDir.exists) {
+ tmpDir.mkdir
+ }
+ tmpDir
+ }
+
+ // scala_shell commands
+ private val tmpDirShell: File = {
+ new File(tmpDirBase, "scala_shell_commands")
+ }
+
+ // scala shell jar file name
+ private val tmpJarShell: File = {
+ new File(tmpDirBase, "scala_shell_commands.jar")
+ }
+
+
+ /**
+ * writes contents of the compiled lines that have been executed in the
shell into a
+ * "physical directory": creates a unique temporary directory
+ */
+ def writeFilesToDisk(): Unit = {
+ val vd = intp.virtualDirectory
+
+ var vdIt = vd.iterator
+
+ for (fi <- vdIt) {
+ if (fi.isDirectory) {
+
+ var fiIt = fi.iterator
+
+ for (f <- fiIt) {
+
+ // directory for compiled line
+ val lineDir = new File(tmpDirShell.getAbsolutePath, fi.name)
+ lineDir.mkdirs()
+
+ // compiled classes for commands from shell
+ val writeFile = new File(lineDir.getAbsolutePath, f.name)
+ val outputStream = new FileOutputStream(writeFile)
+ val inputStream = f.input
+
+ // copy file contents
+ org.apache.commons.io.IOUtils.copy(inputStream, outputStream)
+
+ inputStream.close()
+ outputStream.close()
+ }
+ }
+ }
+ }
+
+ /**
+ * CUSTOM START METHODS OVERRIDE:
+ */
+ override def prompt = "Scala-Flink> "
+
+ /**
+ * custom welcome message
+ */
+ override def printWelcome() {
+ echo(
+ """
+ $$$$$$$$$$
+ $$8888888888$$
+$$$$888888888888$$
+ $$88888888888$$
+ $$88888888888$$
+ $$8888888888$$
+ $$8888888888$$ $$ $$
+ $$8888888888$$ $$$$$$
+ $$88888888$$$$ $$8888$$
+ $$8888888$$$$ $$88888888
+ $$888888888j$$ $$88888( € )88
+ $$8888888o$$$$ s$$888888888888
+ $$8888888h$$$$ s$$$$88$$88888888(®)
+ $$8888888a$$ s$$888888$$888888 s//$
+ $$88888n$$$$ $$$$8888888888$$88 $$$$
+ $$8888n$$ $$8888888888888888$$$$$?? $$s
+ $$88888a$$88888888$$$$888888888888$$
+ $$888888$$888888888888$$$$
+ $$88888$$888888888888888$$
+ $$$$8888$$88888888888888$$
+ $$$$8888888888888888$$
+ $$888888888888$$
+ $$$$8888888$$
+ $$$$ $$$$$$$$$$$$$$
--- End diff --
How did you generate this ASCII art?
> Scala Interactive Shell
> -----------------------
>
> Key: FLINK-1907
> URL: https://issues.apache.org/jira/browse/FLINK-1907
> Project: Flink
> Issue Type: New Feature
> Components: Scala API
> Reporter: Nikolaas Steenbergen
> Assignee: Nikolaas Steenbergen
> Priority: Minor
>
> Build an interactive Shell for the Scala api.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
