diff options
| author | GuoQiang Li <witgo@qq.com> | 2014-09-04 10:28:23 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@apache.org> | 2014-09-04 10:28:23 -0700 |
| commit | 905861906e250a0d6e6c91d9b8fd1aaa366781d3 (patch) | |
| tree | 9fc9af42af5125b147c89573c97c7848a3da3f8b /external/flume | |
| parent | 00362dac976cd05b06638deb11d990d612429e0b (diff) | |
| download | spark-905861906e250a0d6e6c91d9b8fd1aaa366781d3.tar.gz spark-905861906e250a0d6e6c91d9b8fd1aaa366781d3.tar.bz2 spark-905861906e250a0d6e6c91d9b8fd1aaa366781d3.zip | |
[Minor]Remove extra semicolon in FlumeStreamSuite.scala
Author: GuoQiang Li <witgo@qq.com>
Closes #2265 from witgo/FlumeStreamSuite and squashes the following commits:
6c99e6e [GuoQiang Li] Remove extra semicolon in FlumeStreamSuite.scala
Diffstat (limited to 'external/flume')
| -rw-r--r-- | external/flume/src/test/scala/org/apache/spark/streaming/flume/FlumeStreamSuite.scala | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/external/flume/src/test/scala/org/apache/spark/streaming/flume/FlumeStreamSuite.scala b/external/flume/src/test/scala/org/apache/spark/streaming/flume/FlumeStreamSuite.scala index 73dffef953..6ee7ac974b 100644 --- a/external/flume/src/test/scala/org/apache/spark/streaming/flume/FlumeStreamSuite.scala +++ b/external/flume/src/test/scala/org/apache/spark/streaming/flume/FlumeStreamSuite.scala @@ -109,11 +109,11 @@ class FlumeStreamSuite extends TestSuiteBase { } class CompressionChannelFactory(compressionLevel: Int) extends NioClientSocketChannelFactory { - override def newChannel(pipeline:ChannelPipeline) : SocketChannel = { - var encoder : ZlibEncoder = new ZlibEncoder(compressionLevel); - pipeline.addFirst("deflater", encoder); - pipeline.addFirst("inflater", new ZlibDecoder()); - super.newChannel(pipeline); + override def newChannel(pipeline: ChannelPipeline): SocketChannel = { + val encoder = new ZlibEncoder(compressionLevel) + pipeline.addFirst("deflater", encoder) + pipeline.addFirst("inflater", new ZlibDecoder()) + super.newChannel(pipeline) } } } |