ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Fix imports order

Browse source
This commit is contained in:
Binh Nguyen 2013-12-07 11:06:18 -08:00
parent 9115a5de62
commit 786f393a98
3 changed files with 2 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
core/src/main/java/org/apache/spark/network/netty/FileClientChannelInitializer.java
View file

@ -21,7 +21,6 @@ import io.netty.channel.ChannelInitializer;
import io.netty.channel.socket.SocketChannel; import io.netty.channel.socket.SocketChannel;
import io.netty.handler.codec.string.StringEncoder; import io.netty.handler.codec.string.StringEncoder;
class FileClientChannelInitializer extends ChannelInitializer<SocketChannel> { class FileClientChannelInitializer extends ChannelInitializer<SocketChannel> {
private final FileClientHandler fhandler; private final FileClientHandler fhandler;

5
core/src/main/java/org/apache/spark/network/netty/FileServer.java
View file

@ -17,6 +17,8 @@
package org.apache.spark.network.netty; package org.apache.spark.network.netty;
import java.net.InetSocketAddress;
import io.netty.bootstrap.ServerBootstrap; import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelFuture; import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelOption; import io.netty.channel.ChannelOption;
@ -26,9 +28,6 @@ import io.netty.channel.socket.oio.OioServerSocketChannel;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import java.net.InetSocketAddress;
/** /**
* Server that accept the path of a file an echo back its content. * Server that accept the path of a file an echo back its content.
*/ */

1
core/src/main/java/org/apache/spark/network/netty/FileServerChannelInitializer.java
View file

@ -23,7 +23,6 @@ import io.netty.handler.codec.DelimiterBasedFrameDecoder;
import io.netty.handler.codec.Delimiters; import io.netty.handler.codec.Delimiters;
import io.netty.handler.codec.string.StringDecoder; import io.netty.handler.codec.string.StringDecoder;
class FileServerChannelInitializer extends ChannelInitializer<SocketChannel> { class FileServerChannelInitializer extends ChannelInitializer<SocketChannel> {
PathResolver pResolver; PathResolver pResolver;