File tree Expand file tree Collapse file tree 3 files changed +21
-7
lines changed
main/scala/org/apache/spark/streaming/flume
test/java/org/apache/spark/streaming/flume Expand file tree Collapse file tree 3 files changed +21
-7
lines changed Original file line number Diff line number Diff line change @@ -28,7 +28,7 @@ import org.apache.spark.Logging
2828 * A simple object that provides the implementation of readExternal and writeExternal for both
2929 * the wrapper classes for Flume-style Events.
3030 */
31- object EventTransformer extends Logging {
31+ private [streaming] object EventTransformer extends Logging {
3232 def readExternal (in : ObjectInput ): (java.util.HashMap [CharSequence , CharSequence ],
3333 Array [Byte ]) = {
3434 val bodyLength = in.readInt()
Original file line number Diff line number Diff line change @@ -37,19 +37,17 @@ import org.apache.spark.streaming.dstream.ReceiverInputDStream
3737import org .apache .spark .streaming .receiver .Receiver
3838import org .apache .spark .streaming .flume .sink ._
3939
40-
4140/**
4241 * A [[ReceiverInputDStream ]] that can be used to read data from several Flume agents running
43- * [[org.apache.spark.flume.sink.SparkSink ]]s.
42+ * [[org.apache.spark.streaming. flume.sink.SparkSink ]]s.
4443 * @param _ssc Streaming context that will execute this input stream
4544 * @param addresses List of addresses at which SparkSinks are listening
4645 * @param maxBatchSize Maximum size of a batch
4746 * @param parallelism Number of parallel connections to open
4847 * @param storageLevel The storage level to use.
4948 * @tparam T Class type of the object of this stream
5049 */
51- private [streaming]
52- class FlumePollingInputDStream [T : ClassTag ](
50+ private [streaming] class FlumePollingInputDStream [T : ClassTag ](
5351 @ transient _ssc : StreamingContext ,
5452 val addresses : Seq [InetSocketAddress ],
5553 val maxBatchSize : Int ,
@@ -62,8 +60,7 @@ class FlumePollingInputDStream[T: ClassTag](
6260 }
6361}
6462
65- private [streaming]
66- class FlumePollingReceiver (
63+ private [streaming] class FlumePollingReceiver (
6764 addresses : Seq [InetSocketAddress ],
6865 maxBatchSize : Int ,
6966 parallelism : Int ,
Original file line number Diff line number Diff line change 1+ /*
2+ * Licensed to the Apache Software Foundation (ASF) under one or more
3+ * contributor license agreements. See the NOTICE file distributed with
4+ * this work for additional information regarding copyright ownership.
5+ * The ASF licenses this file to You under the Apache License, Version 2.0
6+ * (the "License"); you may not use this file except in compliance with
7+ * the License. You may obtain a copy of the License at
8+ *
9+ * http://www.apache.org/licenses/LICENSE-2.0
10+ *
11+ * Unless required by applicable law or agreed to in writing, software
12+ * distributed under the License is distributed on an "AS IS" BASIS,
13+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14+ * See the License for the specific language governing permissions and
15+ * limitations under the License.
16+ */
17+
118package org .apache .spark .streaming .flume ;
219
320import java .net .InetSocketAddress ;
You can’t perform that action at this time.
0 commit comments