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 streamId

Definitions

Type Member of File Line
field StreamInterceptor /common/network-common/src/main/java/org/apache/spark/network/client/StreamInterceptor.java 36
field StreamChunkId /common/network-common/src/main/java/org/apache/spark/network/protocol/StreamChunkId.java 30
field StreamFailure /common/network-common/src/main/java/org/apache/spark/network/protocol/StreamFailure.java 30
field StreamRequest /common/network-common/src/main/java/org/apache/spark/network/protocol/StreamRequest.java 33
field StreamResponse /common/network-common/src/main/java/org/apache/spark/network/protocol/StreamResponse.java 36
field RpcIntegrationSuite.RpcStreamCallback /common/network-common/src/test/java/org/apache/spark/network/RpcIntegrationSuite.java 237
field RpcIntegrationSuite.VerifyingStreamCallback /common/network-common/src/test/java/org/apache/spark/network/RpcIntegrationSuite.java 428
field StreamSuite.StreamTask /common/network-common/src/test/java/org/apache/spark/network/StreamSuite.java 177
field StreamHandle /common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/StreamHandle.java 34

9 declarations in 8 files.

References:

File Line
/common/network-common/src/main/java/org/apache/spark/network/client/StreamCallback.java 33 36 39
/common/network-common/src/main/java/org/apache/spark/network/client/StreamInterceptor.java 36 43 47 47 56 62 79 84 89
/common/network-common/src/main/java/org/apache/spark/network/client/TransportClient.java 134 141 160 161 164 168 175 176
/common/network-common/src/main/java/org/apache/spark/network/client/TransportResponseHandler.java 93 95 216 228 242
/common/network-common/src/main/java/org/apache/spark/network/protocol/StreamChunkId.java 30 33 34 34 44 50 52 57 64 64 72
/common/network-common/src/main/java/org/apache/spark/network/protocol/StreamFailure.java 30 33 34 34 43 48 53 55 60 67 67 75
/common/network-common/src/main/java/org/apache/spark/network/protocol/StreamRequest.java 33 35 36 36 44 49 53 54 59 66 66 74
/common/network-common/src/main/java/org/apache/spark/network/protocol/StreamResponse.java 36 39 41 41 50 56 62 66 68 73 80 80 88
/common/network-common/src/main/java/org/apache/spark/network/server/ChunkFetchRequestHandler.java 100 101 113 115
/common/network-common/src/main/java/org/apache/spark/network/server/OneForOneStreamManager.java 77 78 90 91 103 104 113 115 152 154 160 167 168 176 177 181 182 189 190
/common/network-common/src/main/java/org/apache/spark/network/server/StreamManager.java 47 59 74 86 91 96 101
/common/network-common/src/main/java/org/apache/spark/network/server/TransportRequestHandler.java 124 136 139 140 145 146 147 152 153 204 205 209 211 217 222 224
/common/network-common/src/test/java/org/apache/spark/network/ChunkFetchIntegrationSuite.java 96 97
/common/network-common/src/test/java/org/apache/spark/network/ChunkFetchRequestHandlerSuite.java 68 73 80 90 99 106
/common/network-common/src/test/java/org/apache/spark/network/RequestTimeoutIntegrationSuite.java 69 191
/common/network-common/src/test/java/org/apache/spark/network/RpcIntegrationSuite.java 108 113 117 128 132 137 237 241 242 242 249 428 433 434 441 441 446 450 463 464 468 469 473 474 479
/common/network-common/src/test/java/org/apache/spark/network/StreamSuite.java 74 79 80 177 181 183 183 195 216 220 271 278 287
/common/network-common/src/test/java/org/apache/spark/network/StreamTestHelper.java 86 87 91
/common/network-common/src/test/java/org/apache/spark/network/TransportRequestHandlerSuite.java 63 71 78 88 92 95 104
/common/network-common/src/test/java/org/apache/spark/network/server/OneForOneStreamManagerSuite.java 43 44 68 70 71 72
/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/ExternalBlockHandler.java 100 112 119 125 130
/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/OneForOneBlockFetcher.java 193 196 237 244 252
/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/StreamHandle.java 34 37 38 38 47 53 62 62 75 80 82
/common/network-shuffle/src/test/java/org/apache/spark/network/shuffle/AppIsolationSuite.java 147 147 172
/common/network-shuffle/src/test/java/org/apache/spark/network/shuffle/OneForOneBlockFetcherSuite.java 237 239
/python/pyspark/streaming/tests/test_listener.py 70 71 98 99 126 127
/streaming/src/test/java/org/apache/spark/streaming/JavaStreamingListenerAPISuite.java 33 46 59

218 references in 27 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!