Back to home page

OSCL-LXR
 
 

    

Identifier search

Type the full name of an identifier to look for (a function name, variable name, typedef, etc).
Matches are case-sensitive. Check "Definitions only" to find only definitions of the symbol (unchecked, all references).
As a convenience, extra 999 line numbers denote case-insensitive occurrences (either belonging to a case-insensitive language or differing in case).

  

Results for ssc

Definitions

Type Member of File Line
variable /examples/src/main/python/mllib/streaming_k_means_example.py 30
variable /examples/src/main/python/mllib/streaming_linear_regression_example.py 42
variable /examples/src/main/python/streaming/hdfs_wordcount.py 41
variable /examples/src/main/python/streaming/network_wordcount.py 40
variable /examples/src/main/python/streaming/network_wordjoinsentiments.py 53
variable /examples/src/main/python/streaming/queue_stream.py 33
variable /examples/src/main/python/streaming/stateful_network_wordcount.py 44
field JavaDirectKafkaStreamSuite /external/kafka-0-10/src/test/java/org/apache/spark/streaming/kafka010/JavaDirectKafkaStreamSuite.java 42
variable /external/kinesis-asl/src/main/python/examples/streaming/kinesis_wordcount_asl.py 74
field JavaStreamingLogisticRegressionSuite /mllib/src/test/java/org/apache/spark/mllib/classification/JavaStreamingLogisticRegressionSuite.java 41
field JavaStreamingKMeansSuite /mllib/src/test/java/org/apache/spark/mllib/clustering/JavaStreamingKMeansSuite.java 40
field JavaStreamingLinearRegressionSuite /mllib/src/test/java/org/apache/spark/mllib/regression/JavaStreamingLinearRegressionSuite.java 40
field JavaStatisticsSuite /mllib/src/test/java/org/apache/spark/mllib/stat/JavaStatisticsSuite.java 47
field LocalJavaStreamingContext /streaming/src/test/java/org/apache/spark/streaming/LocalJavaStreamingContext.java 27

14 declarations in 14 files.

References:

File Line
/examples/src/main/java/org/apache/spark/examples/mllib/JavaStreamingTestExample.java 69 71 74 101 102
/examples/src/main/java/org/apache/spark/examples/streaming/JavaCustomReceiver.java 67 71 78 79
/examples/src/main/java/org/apache/spark/examples/streaming/JavaNetworkWordCount.java 57 63 70 71
/examples/src/main/java/org/apache/spark/examples/streaming/JavaQueueStream.java 44 57 61 68 69
/examples/src/main/java/org/apache/spark/examples/streaming/JavaRecoverableNetworkWordCount.java 125 126 130 158 186 188 189
/examples/src/main/java/org/apache/spark/examples/streaming/JavaSqlNetworkWordCount.java 59 65 91 92
/examples/src/main/java/org/apache/spark/examples/streaming/JavaStatefulNetworkWordCount.java 62 63 69 71 92 93
/examples/src/main/python/mllib/streaming_k_means_example.py 30 49 50 62 63
/examples/src/main/python/mllib/streaming_linear_regression_example.py 42 50 51 60 61
/examples/src/main/python/streaming/hdfs_wordcount.py 41 43 49 50
/examples/src/main/python/streaming/network_wordcount.py 40 42 48 49
/examples/src/main/python/streaming/network_wordjoinsentiments.py 53 57 60 76 77
/examples/src/main/python/streaming/queue_stream.py 33 39 42 47 49
/examples/src/main/python/streaming/recoverable_network_wordcount.py 68 72 98 106 108 109
/examples/src/main/python/streaming/sql_network_wordcount.py 54 58 84 85
/examples/src/main/python/streaming/stateful_network_wordcount.py 44 45 53 60 61
/external/kafka-0-10/src/test/java/org/apache/spark/streaming/kafka010/JavaDirectKafkaStreamSuite.java 42 51 56 57 58 92 125 163 171
/external/kinesis-asl/src/main/python/examples/streaming/kinesis_wordcount_asl.py 74 77 83 84
/external/kinesis-asl/src/test/java/org/apache/spark/streaming/kinesis/JavaKinesisInputDStreamBuilderSuite.java 45 62 80 97
/mllib/src/test/java/org/apache/spark/mllib/classification/JavaStreamingLogisticRegressionSuite.java 41 49 50 55 56 66 71 78
/mllib/src/test/java/org/apache/spark/mllib/clustering/JavaStreamingKMeansSuite.java 40 48 49 54 55 65 70 78
/mllib/src/test/java/org/apache/spark/mllib/regression/JavaStreamingLinearRegressionSuite.java 40 48 49 54 55 65 70 77
/mllib/src/test/java/org/apache/spark/mllib/stat/JavaStatisticsSuite.java 47 59 60 66 104 112
/python/pyspark/mllib/tests/test_streaming_algorithms.py 37 40 68 72 111 113 132 143 164 176 215 222 238 248 274 282 314 315 320 356 358 381 385 413 418 452 453 457
/python/pyspark/streaming/context.py 104 105 106 132
/python/pyspark/streaming/dstream.py 59 61 61 62 71 163 236 317 439 441 442 443 570 571 572 608 620 620 621
/python/pyspark/streaming/kinesis.py 37 79 80 83 90 92 96
/python/pyspark/streaming/tests/test_context.py 33 38 39 44 45 46 50 56 57 59 69 70 73 83 84 85 91 92 93 99 105 113 114 115 118 122 123 124 125 126 132 136 137 139 143 147 149 153 155 159 160 161 162 163 165 170 171 172 173
/python/pyspark/streaming/tests/test_dstream.py 77 78 80 90 331 337 339 352 353 359 361 372 386 460 493 498 499 512 518 519 521 523 543 544 549 554 557 561 568 574 591 594 596 600 604 606 609 612 614 619 623 627 629 632 636 640
/python/pyspark/streaming/tests/test_kinesis.py 32 36 44 49 61 77
/python/pyspark/streaming/tests/test_listener.py 48
/python/pyspark/testing/streamingutils.py 79 82 83 111 134 146 149
/streaming/src/test/java/org/apache/spark/streaming/JavaMapWithStateSuite.java 147 158 158 159 160 160 161 161
/streaming/src/test/java/org/apache/spark/streaming/JavaReceiverAPISuite.java 65 67 74 86
/streaming/src/test/java/org/apache/spark/streaming/LocalJavaStreamingContext.java 27 35 36 41 42
/streaming/src/test/java/test/org/apache/spark/streaming/Java8APISuite.java 64 67 82 85 100 109 126 129 147 151 168 172 182 187 233 237 244 260 261 268 270 315 316 318 323 332 345 361 365 404 414 445 450 494 498 520 532 546 550 578 589 607 613 631 638 656 662 680 695 713 720 752 758 782 786 806 812 840 846
/streaming/src/test/java/test/org/apache/spark/streaming/JavaAPISuite.java 75 82 83 85 86 87 88 89 105 108 123 126 145 148 170 173 189 192 204 208 224 228 247 250 266 275 307 310 340 352 360 366 373 373 383 385 402 406 417 422 475 479 488 505 506 513 515 557 558 560 565 576 592 609 613 621 622 627 638 679 688 711 712 716 751 757 804 809 832 844 859 864 893 903 922 927 959 965 984 991 1014 1017 1043 1049 1084 1090 1109 1123 1137 1149 1163 1182 1189 1215 1219 1256 1262 1287 1293 1314 1321 1350 1362 1397 1401 1408 1463 1467 1472 1494 1498 1505 1526 1528 1531 1535 1537 1540 1542 1549 1571 1573 1576 1579 1582 1585 1589 1592 1630 1635 1657 1659 1670 1681 1688

503 references in 37 files.

[ Source navigation ] [ Identifier search ] [ general search ]

This page was automatically generated by the 2.1.0 LXR engine.

The LXR team
Valid CSS 2.1! Valid HTML 4.01!