File tree Expand file tree Collapse file tree 2 files changed +4
-6
lines changed
java/org/apache/spark/examples/streaming
scala/org/apache/spark/examples/streaming Expand file tree Collapse file tree 2 files changed +4
-6
lines changed Original file line number Diff line number Diff line change 1515 * limitations under the License.
1616 */
1717
18- package org .apache .spark .streaming . examples ;
18+ package org .apache .spark .examples . streaming ;
1919
2020import com .google .common .collect .Lists ;
2121
4848 * To run this on your local machine, you need to first run a Netcat server
4949 * `$ nc -lk 9999`
5050 * and then run the example
51- * `$ ./run org.apache.spark.streaming. examples.JavaCustomReceiver local[2] localhost 9999`
51+ * `$ ./run org.apache.spark.examples.streaming .JavaCustomReceiver local[2] localhost 9999`
5252 */
5353
5454public class JavaCustomReceiver extends Receiver <String > {
@@ -149,5 +149,3 @@ private void receive() {
149149 }
150150 }
151151}
152-
153-
Original file line number Diff line number Diff line change 1515 * limitations under the License.
1616 */
1717
18- package org .apache .spark .streaming . examples
18+ package org .apache .spark .examples . streaming
1919
2020import java .io .{InputStreamReader , BufferedReader , InputStream }
2121import java .net .Socket
@@ -37,7 +37,7 @@ import org.apache.spark.streaming.receiver.Receiver
3737 * To run this on your local machine, you need to first run a Netcat server
3838 * `$ nc -lk 9999`
3939 * and then run the example
40- * `$ ./run org.apache.spark.streaming. examples.CustomReceiver local[2] localhost 9999`
40+ * `$ ./run org.apache.spark.examples.streaming .CustomReceiver local[2] localhost 9999`
4141 */
4242object CustomReceiver {
4343 def main (args : Array [String ]) {
You can’t perform that action at this time.
0 commit comments