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 partitionId

Definitions

Type Member of File Line
field LocalDiskShuffleMapOutputWriter.LocalDiskShufflePartitionWriter /core/src/main/java/org/apache/spark/shuffle/sort/io/LocalDiskShuffleMapOutputWriter.java 158
field LocalDiskShuffleMapOutputWriter.PartitionWriterStream /core/src/main/java/org/apache/spark/shuffle/sort/io/LocalDiskShuffleMapOutputWriter.java 212
field LocalDiskShuffleMapOutputWriter.PartitionWriterChannel /core/src/main/java/org/apache/spark/shuffle/sort/io/LocalDiskShuffleMapOutputWriter.java 254
class member TaskContext /python/pyspark/taskcontext.py 75

4 declarations in 2 files.

References:

File Line
/core/src/main/java/org/apache/spark/shuffle/sort/PackedRecordPointer.java 77 78 83
/core/src/main/java/org/apache/spark/shuffle/sort/ShuffleExternalSorter.java 394 418
/core/src/main/java/org/apache/spark/shuffle/sort/ShuffleInMemorySorter.java 146 150
/core/src/main/java/org/apache/spark/shuffle/sort/UnsafeShuffleWriter.java 239 249
/core/src/main/java/org/apache/spark/shuffle/sort/io/LocalDiskShuffleMapOutputWriter.java 158 162 163 163 175 189 212 216 217 217 241 254 256 257 257 272 273
/core/src/test/java/org/apache/spark/shuffle/sort/ShuffleInMemorySorterSuite.java 107 108 108 109 110
/core/src/test/java/org/apache/spark/util/collection/unsafe/sort/UnsafeInMemorySorterSuite.java 129 130
/core/src/test/java/test/org/apache/spark/JavaTaskContextCompileCheck.java 42 65
/python/pyspark/sql/tests/test_pandas_udf_scalar.py 827
/python/pyspark/sql/tests/test_streaming.py 276 279 367 368
/python/pyspark/taskcontext.py 36 75 79
/python/pyspark/tests/test_taskcontext.py 64 65 82 150 181 183 206 258 260
/python/pyspark/worker.py 517
/sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/DataWriterFactory.java 57
/sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/streaming/StreamingDataWriterFactory.java 61
/sql/core/src/test/java/test/org/apache/spark/sql/streaming/JavaDataStreamReaderWriterSuite.java 77

56 references in 16 files.