-
- Downloads
Merge pull request #318 from srowen/master
Suggested small changes to Java code for slightly more standard style, encapsulation and in some cases performance Sorry if this is too abrupt or not a welcome set of changes, but thought I'd see if I could contribute a little. I'm a Java developer and just getting seriously into Spark. So I thought I'd suggest a number of small changes to the couple Java parts of the code to make it a little tighter, more standard and even a bit faster. Feel free to take all, some or none of this. Happy to explain any of it.
No related branches found
No related tags found
Showing
- core/src/main/java/org/apache/spark/network/netty/FileClient.java 3 additions, 2 deletions.../main/java/org/apache/spark/network/netty/FileClient.java
- core/src/main/java/org/apache/spark/network/netty/FileClientChannelInitializer.java 1 addition, 1 deletion...che/spark/network/netty/FileClientChannelInitializer.java
- core/src/main/java/org/apache/spark/network/netty/FileServer.java 4 additions, 4 deletions.../main/java/org/apache/spark/network/netty/FileServer.java
- core/src/main/java/org/apache/spark/network/netty/FileServerChannelInitializer.java 2 additions, 2 deletions...che/spark/network/netty/FileServerChannelInitializer.java
- core/src/main/java/org/apache/spark/network/netty/FileServerHandler.java 3 additions, 3 deletions...ava/org/apache/spark/network/netty/FileServerHandler.java
- core/src/main/java/org/apache/spark/network/netty/PathResolver.java 26 additions, 26 deletions...ain/java/org/apache/spark/network/netty/PathResolver.java
- examples/src/main/java/org/apache/spark/examples/JavaHdfsLR.java 16 additions, 13 deletions...s/src/main/java/org/apache/spark/examples/JavaHdfsLR.java
- examples/src/main/java/org/apache/spark/examples/JavaKMeans.java 15 additions, 8 deletions...s/src/main/java/org/apache/spark/examples/JavaKMeans.java
- examples/src/main/java/org/apache/spark/examples/JavaLogQuery.java 10 additions, 10 deletions...src/main/java/org/apache/spark/examples/JavaLogQuery.java
- examples/src/main/java/org/apache/spark/examples/JavaPageRank.java 7 additions, 5 deletions...src/main/java/org/apache/spark/examples/JavaPageRank.java
- examples/src/main/java/org/apache/spark/examples/JavaSparkPi.java 5 additions, 5 deletions.../src/main/java/org/apache/spark/examples/JavaSparkPi.java
- examples/src/main/java/org/apache/spark/examples/JavaTC.java 10 additions, 6 deletionsexamples/src/main/java/org/apache/spark/examples/JavaTC.java
- examples/src/main/java/org/apache/spark/examples/JavaWordCount.java 8 additions, 2 deletions...rc/main/java/org/apache/spark/examples/JavaWordCount.java
- examples/src/main/java/org/apache/spark/mllib/examples/JavaALS.java 11 additions, 7 deletions...rc/main/java/org/apache/spark/mllib/examples/JavaALS.java
- examples/src/main/java/org/apache/spark/mllib/examples/JavaKMeans.java 9 additions, 7 deletions...main/java/org/apache/spark/mllib/examples/JavaKMeans.java
- examples/src/main/java/org/apache/spark/mllib/examples/JavaLR.java 11 additions, 8 deletions...src/main/java/org/apache/spark/mllib/examples/JavaLR.java
- examples/src/main/java/org/apache/spark/streaming/examples/JavaFlumeEventCount.java 4 additions, 1 deletion.../apache/spark/streaming/examples/JavaFlumeEventCount.java
- examples/src/main/java/org/apache/spark/streaming/examples/JavaKafkaWordCount.java 11 additions, 5 deletions...g/apache/spark/streaming/examples/JavaKafkaWordCount.java
- examples/src/main/java/org/apache/spark/streaming/examples/JavaNetworkWordCount.java 11 additions, 4 deletions...apache/spark/streaming/examples/JavaNetworkWordCount.java
- examples/src/main/java/org/apache/spark/streaming/examples/JavaQueueStream.java 7 additions, 4 deletions.../org/apache/spark/streaming/examples/JavaQueueStream.java
Loading
Please register or sign in to comment