notebook.community

Edit and run



In [1]:

    
util.Properties.versionNumberString









    Out[1]:





2.10.5



In [2]:

    
sc.getConf.toDebugString









    Out[2]:





spark.app.id=local-1467190644259
spark.app.name=IBM Spark Kernel
spark.driver.host=10.33.251.147
spark.driver.memory=12g
spark.driver.port=60347
spark.executor.id=driver
spark.externalBlockStore.folderName=spark-10224872-7778-45fb-b66b-b02b946e27ad
spark.jars=file:/usr/local/share/jupyter/kernels/apache_toree_scala/lib/toree-assembly-0.1.0.dev8-incubating-SNAPSHOT.jar
spark.master=local[*]
spark.repl.class.uri=http://10.33.251.147:60315
spark.submit.deployMode=client



In [3]:

    
%AddDeps io.reactivex rxscala_2.10 0.26.1 --transitive --trace --verbose









    



Marking io.reactivex:rxscala_2.10:0.26.1 for download
Preparing to fetch from:
-> file:/var/folders/3k/y0wr1h7906980nx45skhhfcw0000gn/T/toree_add_deps3130004117137842159/
-> https://repo1.maven.org/maven2
=> 1 (): Downloading https://repo1.maven.org/maven2/io/reactivex/rxscala_2.10/0.26.1/rxscala_2.10-0.26.1.pom.sha1
=> 1 (): Downloading https://repo1.maven.org/maven2/io/reactivex/rxscala_2.10/0.26.1/rxscala_2.10-0.26.1.pom
===> 1 (rxscala_2.10-0.26.1.pom): Is 3091 total bytes
===> 1 (rxscala_2.10-0.26.1.pom.sha1): Is 40 total bytes
===> 1 (rxscala_2.10-0.26.1.pom.sha1): Downloaded 40 bytes (100.00%)
===> 1 (rxscala_2.10-0.26.1.pom): Downloaded 2107 bytes (68.17%)
===> 1 (rxscala_2.10-0.26.1.pom): Downloaded 3091 bytes (100.00%)
=> 1 (rxscala_2.10-0.26.1.pom.sha1): Finished downloading
=> 1 (rxscala_2.10-0.26.1.pom): Finished downloading
=> 2 (): Downloading https://repo1.maven.org/maven2/io/reactivex/rxjava/1.1.1/rxjava-1.1.1.pom
=> 3 (): Downloading https://repo1.maven.org/maven2/io/reactivex/rxjava/1.1.1/rxjava-1.1.1.pom.sha1
===> 2 (rxjava-1.1.1.pom): Is 2411 total bytes
===> 2 (rxjava-1.1.1.pom): Downloaded 2103 bytes (87.23%)
===> 2 (rxjava-1.1.1.pom): Downloaded 2411 bytes (100.00%)
=> 2 (rxjava-1.1.1.pom): Finished downloading
===> 3 (rxjava-1.1.1.pom.sha1): Is 40 total bytes
===> 3 (rxjava-1.1.1.pom.sha1): Downloaded 40 bytes (100.00%)
=> 3 (rxjava-1.1.1.pom.sha1): Finished downloading
=> 1 (): Downloading https://repo1.maven.org/maven2/io/reactivex/rxscala_2.10/0.26.1/rxscala_2.10-0.26.1.jar
=> 2 (): Downloading https://repo1.maven.org/maven2/io/reactivex/rxscala_2.10/0.26.1/rxscala_2.10-0.26.1.jar.sha1
=> 1 (): Downloading https://repo1.maven.org/maven2/io/reactivex/rxjava/1.1.1/rxjava-1.1.1.jar
=> 2 (): Downloading https://repo1.maven.org/maven2/io/reactivex/rxjava/1.1.1/rxjava-1.1.1.jar.sha1
===> 2 (rxscala_2.10-0.26.1.jar.sha1): Is 40 total bytes
===> 1 (rxscala_2.10-0.26.1.jar): Is 393627 total bytes
===> 2 (rxscala_2.10-0.26.1.jar.sha1): Downloaded 40 bytes (100.00%)
===> 1 (rxscala_2.10-0.26.1.jar): Downloaded 2089 bytes (0.53%)
=> 2 (rxscala_2.10-0.26.1.jar.sha1): Finished downloading
===> 1 (rxscala_2.10-0.26.1.jar): Downloaded 4848 bytes (1.23%)
===> 1 (rxscala_2.10-0.26.1.jar): Downloaded 7607 bytes (1.93%)
===> 1 (rxscala_2.10-0.26.1.jar): Downloaded 10366 bytes (2.63%)
===> 1 (rxscala_2.10-0.26.1.jar): Downloaded 13125 bytes (3.33%)
===> 1 (rxscala_2.10-0.26.1.jar): Downloaded 15714 bytes (3.99%)
===> 1 (rxscala_2.10-0.26.1.jar): Downloaded 18473 bytes (4.69%)
===> 1 (rxscala_2.10-0.26.1.jar): Downloaded 21232 bytes (5.39%)
===> 1 (rxscala_2.10-0.26.1.jar): Downloaded 23991 bytes (6.09%)
===> 1 (rxscala_2.10-0.26.1.jar): Downloaded 26750 bytes (6.80%)
===> 1 (rxscala_2.10-0.26.1.jar): Downloaded 29509 bytes (7.50%)
===> 1 (rxscala_2.10-0.26.1.jar): Downloaded 32098 bytes (8.15%)
===> 1 (rxscala_2.10-0.26.1.jar): Downloaded 48482 bytes (12.32%)
===> 1 (rxjava-1.1.1.jar): Is 1001969 total bytes
===> 1 (rxscala_2.10-0.26.1.jar): Downloaded 64866 bytes (16.48%)
===> 1 (rxjava-1.1.1.jar): Downloaded 2084 bytes (0.21%)
===> 1 (rxscala_2.10-0.26.1.jar): Downloaded 81250 bytes (20.64%)
===> 1 (rxjava-1.1.1.jar): Downloaded 4843 bytes (0.48%)
===> 1 (rxjava-1.1.1.jar): Downloaded 7602 bytes (0.76%)
===> 1 (rxjava-1.1.1.jar): Downloaded 10361 bytes (1.03%)
===> 1 (rxscala_2.10-0.26.1.jar): Downloaded 97634 bytes (24.80%)
===> 1 (rxjava-1.1.1.jar): Downloaded 13120 bytes (1.31%)
===> 1 (rxjava-1.1.1.jar): Downloaded 15709 bytes (1.57%)
===> 1 (rxjava-1.1.1.jar): Downloaded 18468 bytes (1.84%)
===> 1 (rxjava-1.1.1.jar): Downloaded 21227 bytes (2.12%)
===> 1 (rxjava-1.1.1.jar): Downloaded 23986 bytes (2.39%)
===> 1 (rxjava-1.1.1.jar): Downloaded 26745 bytes (2.67%)
===> 1 (rxscala_2.10-0.26.1.jar): Downloaded 114018 bytes (28.97%)
===> 1 (rxjava-1.1.1.jar): Downloaded 29504 bytes (2.94%)
===> 1 (rxjava-1.1.1.jar): Downloaded 32093 bytes (3.20%)
===> 1 (rxjava-1.1.1.jar): Downloaded 48477 bytes (4.84%)
===> 1 (rxscala_2.10-0.26.1.jar): Downloaded 130402 bytes (33.13%)
===> 1 (rxjava-1.1.1.jar): Downloaded 64861 bytes (6.47%)
===> 1 (rxjava-1.1.1.jar): Downloaded 81245 bytes (8.11%)
===> 1 (rxscala_2.10-0.26.1.jar): Downloaded 146786 bytes (37.29%)
===> 2 (rxjava-1.1.1.jar.sha1): Is 40 total bytes
===> 1 (rxjava-1.1.1.jar): Downloaded 97629 bytes (9.74%)
===> 2 (rxjava-1.1.1.jar.sha1): Downloaded 40 bytes (100.00%)
===> 1 (rxscala_2.10-0.26.1.jar): Downloaded 163170 bytes (41.45%)
===> 1 (rxjava-1.1.1.jar): Downloaded 114013 bytes (11.38%)
=> 2 (rxjava-1.1.1.jar.sha1): Finished downloading
===> 1 (rxscala_2.10-0.26.1.jar): Downloaded 179554 bytes (45.62%)
===> 1 (rxjava-1.1.1.jar): Downloaded 130397 bytes (13.01%)
===> 1 (rxjava-1.1.1.jar): Downloaded 146781 bytes (14.65%)
===> 1 (rxscala_2.10-0.26.1.jar): Downloaded 195938 bytes (49.78%)
===> 1 (rxjava-1.1.1.jar): Downloaded 163165 bytes (16.28%)
===> 1 (rxscala_2.10-0.26.1.jar): Downloaded 212322 bytes (53.94%)
===> 1 (rxscala_2.10-0.26.1.jar): Downloaded 228706 bytes (58.10%)
===> 1 (rxjava-1.1.1.jar): Downloaded 179549 bytes (17.92%)
===> 1 (rxscala_2.10-0.26.1.jar): Downloaded 245090 bytes (62.26%)
===> 1 (rxjava-1.1.1.jar): Downloaded 195933 bytes (19.55%)
===> 1 (rxscala_2.10-0.26.1.jar): Downloaded 261474 bytes (66.43%)
===> 1 (rxjava-1.1.1.jar): Downloaded 212317 bytes (21.19%)
===> 1 (rxscala_2.10-0.26.1.jar): Downloaded 277858 bytes (70.59%)
===> 1 (rxjava-1.1.1.jar): Downloaded 228701 bytes (22.83%)
===> 1 (rxjava-1.1.1.jar): Downloaded 245085 bytes (24.46%)
===> 1 (rxscala_2.10-0.26.1.jar): Downloaded 294242 bytes (74.75%)
===> 1 (rxjava-1.1.1.jar): Downloaded 261469 bytes (26.10%)
===> 1 (rxscala_2.10-0.26.1.jar): Downloaded 310626 bytes (78.91%)
===> 1 (rxjava-1.1.1.jar): Downloaded 277853 bytes (27.73%)
===> 1 (rxscala_2.10-0.26.1.jar): Downloaded 327010 bytes (83.08%)
===> 1 (rxjava-1.1.1.jar): Downloaded 294237 bytes (29.37%)
===> 1 (rxscala_2.10-0.26.1.jar): Downloaded 343394 bytes (87.24%)
===> 1 (rxjava-1.1.1.jar): Downloaded 310621 bytes (31.00%)
===> 1 (rxscala_2.10-0.26.1.jar): Downloaded 359778 bytes (91.40%)
===> 1 (rxscala_2.10-0.26.1.jar): Downloaded 376162 bytes (95.56%)
===> 1 (rxjava-1.1.1.jar): Downloaded 327005 bytes (32.64%)
===> 1 (rxscala_2.10-0.26.1.jar): Downloaded 392546 bytes (99.73%)
===> 1 (rxjava-1.1.1.jar): Downloaded 343389 bytes (34.27%)
===> 1 (rxscala_2.10-0.26.1.jar): Downloaded 393627 bytes (100.00%)
===> 1 (rxjava-1.1.1.jar): Downloaded 359773 bytes (35.91%)
=> 1 (rxscala_2.10-0.26.1.jar): Finished downloading
===> 1 (rxjava-1.1.1.jar): Downloaded 376157 bytes (37.54%)
===> 1 (rxjava-1.1.1.jar): Downloaded 392541 bytes (39.18%)
===> 1 (rxjava-1.1.1.jar): Downloaded 408925 bytes (40.81%)
===> 1 (rxjava-1.1.1.jar): Downloaded 425309 bytes (42.45%)
===> 1 (rxjava-1.1.1.jar): Downloaded 441693 bytes (44.08%)
===> 1 (rxjava-1.1.1.jar): Downloaded 458077 bytes (45.72%)
===> 1 (rxjava-1.1.1.jar): Downloaded 474461 bytes (47.35%)
===> 1 (rxjava-1.1.1.jar): Downloaded 490845 bytes (48.99%)
===> 1 (rxjava-1.1.1.jar): Downloaded 507229 bytes (50.62%)
===> 1 (rxjava-1.1.1.jar): Downloaded 523613 bytes (52.26%)
===> 1 (rxjava-1.1.1.jar): Downloaded 539997 bytes (53.89%)
===> 1 (rxjava-1.1.1.jar): Downloaded 556381 bytes (55.53%)
===> 1 (rxjava-1.1.1.jar): Downloaded 572765 bytes (57.16%)
===> 1 (rxjava-1.1.1.jar): Downloaded 589149 bytes (58.80%)
===> 1 (rxjava-1.1.1.jar): Downloaded 605533 bytes (60.43%)
===> 1 (rxjava-1.1.1.jar): Downloaded 621917 bytes (62.07%)
===> 1 (rxjava-1.1.1.jar): Downloaded 638301 bytes (63.70%)
===> 1 (rxjava-1.1.1.jar): Downloaded 654685 bytes (65.34%)
===> 1 (rxjava-1.1.1.jar): Downloaded 671069 bytes (66.98%)
===> 1 (rxjava-1.1.1.jar): Downloaded 687453 bytes (68.61%)
===> 1 (rxjava-1.1.1.jar): Downloaded 703837 bytes (70.25%)
===> 1 (rxjava-1.1.1.jar): Downloaded 720221 bytes (71.88%)
===> 1 (rxjava-1.1.1.jar): Downloaded 736605 bytes (73.52%)
===> 1 (rxjava-1.1.1.jar): Downloaded 752989 bytes (75.15%)
===> 1 (rxjava-1.1.1.jar): Downloaded 769373 bytes (76.79%)
===> 1 (rxjava-1.1.1.jar): Downloaded 785757 bytes (78.42%)
===> 1 (rxjava-1.1.1.jar): Downloaded 802141 bytes (80.06%)
===> 1 (rxjava-1.1.1.jar): Downloaded 818525 bytes (81.69%)
===> 1 (rxjava-1.1.1.jar): Downloaded 834909 bytes (83.33%)
===> 1 (rxjava-1.1.1.jar): Downloaded 851293 bytes (84.96%)
===> 1 (rxjava-1.1.1.jar): Downloaded 867677 bytes (86.60%)
===> 1 (rxjava-1.1.1.jar): Downloaded 884061 bytes (88.23%)
===> 1 (rxjava-1.1.1.jar): Downloaded 900445 bytes (89.87%)
===> 1 (rxjava-1.1.1.jar): Downloaded 916829 bytes (91.50%)
===> 1 (rxjava-1.1.1.jar): Downloaded 933213 bytes (93.14%)
===> 1 (rxjava-1.1.1.jar): Downloaded 949597 bytes (94.77%)
===> 1 (rxjava-1.1.1.jar): Downloaded 965981 bytes (96.41%)
===> 1 (rxjava-1.1.1.jar): Downloaded 982365 bytes (98.04%)
===> 1 (rxjava-1.1.1.jar): Downloaded 998749 bytes (99.68%)
===> 1 (rxjava-1.1.1.jar): Downloaded 1001969 bytes (100.00%)
=> 1 (rxjava-1.1.1.jar): Finished downloading
-> New file at /var/folders/3k/y0wr1h7906980nx45skhhfcw0000gn/T/toree_add_deps3130004117137842159/https/repo1.maven.org/maven2/io/reactivex/rxscala_2.10/0.26.1/rxscala_2.10-0.26.1.jar
-> New file at /var/folders/3k/y0wr1h7906980nx45skhhfcw0000gn/T/toree_add_deps3130004117137842159/https/repo1.maven.org/maven2/io/reactivex/rxjava/1.1.1/rxjava-1.1.1.jar



In [4]:

    
import rx.lang.scala._
import rx.lang.scala.Observable



In [5]:

    
Observable.from(List(1, 2, 3)).toBlocking.subscribe(onNext = (i) => print(i))



In [ ]: