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 stream

Definitions

Type Member of File Line
method TransportClient /common/network-common/src/main/java/org/apache/spark/network/client/TransportClient.java 160
function /core/src/main/resources/org/apache/spark/ui/static/d3.min.js 4
method ta.geo.clipExtent.n /core/src/main/resources/org/apache/spark/ui/static/d3.min.js 4

3 declarations in 2 files.

References:

File Line
/common/kvstore/src/main/java/org/apache/spark/util/kvstore/InMemoryStore.java 375 375 379 379 384 384 388 388 392 392 395 422
/common/kvstore/src/main/java/org/apache/spark/util/kvstore/KVTypeInfo.java 104
/common/kvstore/src/test/java/org/apache/spark/util/kvstore/LevelDBSuite.java 272
/common/network-common/src/main/java/org/apache/spark/network/client/TransportClient.java 160
/common/network-common/src/test/java/org/apache/spark/network/RpcIntegrationSuite.java 214 215 216 217 217 219 325 326 328
/common/network-common/src/test/java/org/apache/spark/network/StreamSuite.java 220
/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/ExternalShuffleBlockResolver.java 376
/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/OneForOneBlockFetcher.java 193
/common/network-shuffle/src/test/java/org/apache/spark/network/shuffle/AppIsolationSuite.java 146 147
/common/network-shuffle/src/test/java/org/apache/spark/network/shuffle/ExternalBlockHandlerSuite.java 176 178 180
/core/src/main/java/org/apache/spark/shuffle/sort/UnsafeShuffleWriter.java 416 417
/core/src/main/resources/org/apache/spark/ui/static/d3.min.js 2 2
/launcher/src/main/java/org/apache/spark/launcher/FilteredObjectInputStream.java 45
/launcher/src/test/java/org/apache/spark/launcher/LauncherServerSuite.java 276 277
/python/pyspark/profiler.py 163
/python/pyspark/serializers.py 89 95 101 107 140 142 144 147 151 157 159 161 163 164 169 222 223 225 226 228 229 251 252 267 276 277 301 302 303 308 309 328 329 330 342 343 555 556 561 564 567 577 578 584 585 592 593 599 600 603 604 610 611 612
/python/pyspark/sql/pandas/serializers.py 51 52 54 60 64 66 71 84 90 96 98 195 201 203 207 239 251 255 263 272 275 276
/python/pyspark/streaming/kinesis.py 96 97
/python/pyspark/streaming/tests/test_context.py 33 34
/python/pyspark/streaming/tests/test_dstream.py 80 88 97
/python/pyspark/streaming/tests/test_kinesis.py 48 60
/python/pyspark/testing/streamingutils.py 153 155 157
/python/pyspark/util.py 68 70
/python/run-tests.py 239
/sql/catalyst/src/main/java/org/apache/spark/sql/connector/expressions/Expressions.java 88
/sql/core/src/test/java/test/org/apache/spark/sql/JavaDataFrameSuite.java 520 522
/sql/core/src/test/java/test/org/apache/spark/sql/JavaHigherOrderFunctionsSuite.java 67
/sql/core/src/test/java/test/org/apache/spark/sql/connector/JavaAdvancedDataSourceV2.java 63 72 136
/streaming/src/test/java/test/org/apache/spark/streaming/Java8APISuite.java 64 65 82 83 100 101 126 127 147 148 168 169 182 189 190 191 192 361 362 404 405 445 447 493 495 519 521 545 547 577 579 606 608 630 632 655 657 679 681 712 714 751 753 781 783 805 807 839 841
/streaming/src/test/java/test/org/apache/spark/streaming/JavaAPISuite.java 83 84 105 106 123 124 145 146 170 171 189 190 203 206 223 226 247 248 266 267 307 308 340 343 348 383 384 402 403 417 424 426 428 430 609 611 627 628 630 636 679 680 751 753 803 805 831 833 858 860 892 894 921 923 958 960 983 985 1014 1015 1042 1044 1083 1085 1108 1110 1148 1150 1181 1183 1214 1217 1255 1257 1286 1288 1313 1315 1349 1351 1528 1529

269 references in 30 files.