Elgato_dark/zeppelin
1
0
Fork 0
mirror of https://github.com/apache/zeppelin synced 2026-05-24 09:38:26 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Cleaning up imports, comments, etc

Browse source
This commit is contained in:
Sriram Krishnan 2015-12-21 15:00:25 -08:00
parent c27ec48ff7
commit 368dc042ef
3 changed files with 15 additions and 25 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
scalding/pom.xml
View file

@ -60,16 +60,6 @@
<artifactId>commons-exec</artifactId>
<version>1.3</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
</dependency>
<dependency>
<groupId>junit</groupId>

22
scalding/src/main/java/org/apache/zeppelin/scalding/ScaldingInterpreter.java
View file

@ -17,16 +17,16 @@
package org.apache.zeppelin.scalding;
import java.io.File;
import java.util.Properties;
import java.util.List;
import java.util.Map;
import java.util.LinkedList;
import java.net.URL;
import java.net.URLClassLoader;
import java.io.ByteArrayOutputStream;
import java.io.File;
import java.io.PrintStream;
import java.io.PrintWriter;
import java.util.Properties;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;
import java.net.URL;
import java.net.URLClassLoader;
import org.apache.zeppelin.interpreter.Interpreter;
import org.apache.zeppelin.interpreter.InterpreterContext;
@ -34,11 +34,10 @@ import org.apache.zeppelin.interpreter.InterpreterResult;
import org.apache.zeppelin.interpreter.InterpreterResult.Code;
import org.apache.zeppelin.scheduler.Scheduler;
import org.apache.zeppelin.scheduler.SchedulerFactory;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
//import com.twitter.scalding.ScaldingILoop;
import scala.Console;
import scala.Some;
import scala.None;
@ -259,7 +258,9 @@ public class ScaldingInterpreter extends Interpreter {
}
@Override
public void cancel(InterpreterContext context) {}
public void cancel(InterpreterContext context) {
// not implemented
}
@Override
public FormType getFormType() {
@ -268,6 +269,7 @@ public class ScaldingInterpreter extends Interpreter {
@Override
public int getProgress(InterpreterContext context) {
// not implemented - return 0
return 0;
}

8
scalding/src/main/scala/org/apache/zeppelin/scalding/ScaldingILoop.scala
View file

@ -14,16 +14,14 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.zeppelin.scalding;
import java.io.File
import java.io.{BufferedReader, File, FileReader}
import scala.tools.nsc.interpreter.IR
import scala.tools.nsc.GenericRunnerSettings
import scala.tools.nsc.interpreter.{JPrintWriter, ILoop}
import scala.tools.nsc.interpreter.{ILoop, IR, JPrintWriter}
import java.io.{BufferedReader, FileReader}
/**
* A class providing Scalding specific commands for inclusion in the Scalding REPL.