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 decode

Definitions

Type Member of File Line
method ChunkFetchFailure /common/network-common/src/main/java/org/apache/spark/network/protocol/ChunkFetchFailure.java 52
method ChunkFetchRequest /common/network-common/src/main/java/org/apache/spark/network/protocol/ChunkFetchRequest.java 48
method ChunkFetchSuccess /common/network-common/src/main/java/org/apache/spark/network/protocol/ChunkFetchSuccess.java 64
method Encoders.Strings /common/network-common/src/main/java/org/apache/spark/network/protocol/Encoders.java 39
method Encoders.ByteArrays /common/network-common/src/main/java/org/apache/spark/network/protocol/Encoders.java 58
method Encoders.StringArrays /common/network-common/src/main/java/org/apache/spark/network/protocol/Encoders.java 83
method Encoders.IntArrays /common/network-common/src/main/java/org/apache/spark/network/protocol/Encoders.java 106
method Encoders.LongArrays /common/network-common/src/main/java/org/apache/spark/network/protocol/Encoders.java 129
method Message.Type /common/network-common/src/main/java/org/apache/spark/network/protocol/Message.java 55
method MessageDecoder /common/network-common/src/main/java/org/apache/spark/network/protocol/MessageDecoder.java 43
method MessageDecoder /common/network-common/src/main/java/org/apache/spark/network/protocol/MessageDecoder.java 51
method OneWayMessage /common/network-common/src/main/java/org/apache/spark/network/protocol/OneWayMessage.java 56
method RpcFailure /common/network-common/src/main/java/org/apache/spark/network/protocol/RpcFailure.java 50
method RpcRequest /common/network-common/src/main/java/org/apache/spark/network/protocol/RpcRequest.java 61
method RpcResponse /common/network-common/src/main/java/org/apache/spark/network/protocol/RpcResponse.java 61
method StreamChunkId /common/network-common/src/main/java/org/apache/spark/network/protocol/StreamChunkId.java 48
method StreamFailure /common/network-common/src/main/java/org/apache/spark/network/protocol/StreamFailure.java 52
method StreamRequest /common/network-common/src/main/java/org/apache/spark/network/protocol/StreamRequest.java 52
method StreamResponse /common/network-common/src/main/java/org/apache/spark/network/protocol/StreamResponse.java 65
method UploadStream /common/network-common/src/main/java/org/apache/spark/network/protocol/UploadStream.java 77
method SaslEncryption.DecryptionHandler /common/network-common/src/main/java/org/apache/spark/network/sasl/SaslEncryption.java 110
method SaslMessage /common/network-common/src/main/java/org/apache/spark/network/sasl/SaslMessage.java 68
method BlocksRemoved /common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/BlocksRemoved.java 71
method ExecutorShuffleInfo /common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/ExecutorShuffleInfo.java 90
method FetchShuffleBlocks /common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/FetchShuffleBlocks.java 136
method GetLocalDirsForExecutors /common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/GetLocalDirsForExecutors.java 78
method LocalDirsForExecutors /common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/LocalDirsForExecutors.java 99
method OpenBlocks /common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/OpenBlocks.java 86
method RegisterExecutor /common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/RegisterExecutor.java 91
method RemoveBlocks /common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/RemoveBlocks.java 86
method StreamHandle /common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/StreamHandle.java 79
method UploadBlock /common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/UploadBlock.java 111
method UploadBlockStream /common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/UploadBlockStream.java 86
method RegisterDriver /common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/mesos/RegisterDriver.java 72
method ShuffleServiceHeartbeat /common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/mesos/ShuffleServiceHeartbeat.java 50
function /python/pyspark/sql/functions.py 1546
method SQLOperation /sql/hive-thriftserver/v1.2/src/main/java/org/apache/hive/service/cli/operation/SQLOperation.java 349
method SQLOperation /sql/hive-thriftserver/v2.3/src/main/java/org/apache/hive/service/cli/operation/SQLOperation.java 349

38 declarations in 33 files.

References:

File Line
/common/network-common/src/main/java/org/apache/spark/network/crypto/ClientChallenge.java 92 93 95 97 98
/common/network-common/src/main/java/org/apache/spark/network/crypto/ServerResponse.java 79 80 81 82
/common/network-common/src/main/java/org/apache/spark/network/protocol/ChunkFetchFailure.java 52 53 54
/common/network-common/src/main/java/org/apache/spark/network/protocol/ChunkFetchRequest.java 48 49
/common/network-common/src/main/java/org/apache/spark/network/protocol/ChunkFetchSuccess.java 64 65
/common/network-common/src/main/java/org/apache/spark/network/protocol/Encoders.java 39 58 83 87 106 129
/common/network-common/src/main/java/org/apache/spark/network/protocol/Message.java 55
/common/network-common/src/main/java/org/apache/spark/network/protocol/MessageDecoder.java 43 44 45 51 54 57 60 63 66 69 72 75 78 81 84
/common/network-common/src/main/java/org/apache/spark/network/protocol/OneWayMessage.java 56
/common/network-common/src/main/java/org/apache/spark/network/protocol/RpcFailure.java 50 52
/common/network-common/src/main/java/org/apache/spark/network/protocol/RpcRequest.java 61
/common/network-common/src/main/java/org/apache/spark/network/protocol/RpcResponse.java 61
/common/network-common/src/main/java/org/apache/spark/network/protocol/StreamChunkId.java 48
/common/network-common/src/main/java/org/apache/spark/network/protocol/StreamFailure.java 52 53 54
/common/network-common/src/main/java/org/apache/spark/network/protocol/StreamRequest.java 52 53
/common/network-common/src/main/java/org/apache/spark/network/protocol/StreamResponse.java 65 66
/common/network-common/src/main/java/org/apache/spark/network/protocol/UploadStream.java 77
/common/network-common/src/main/java/org/apache/spark/network/sasl/SaslEncryption.java 110
/common/network-common/src/main/java/org/apache/spark/network/sasl/SaslMessage.java 68 74
/common/network-common/src/main/java/org/apache/spark/network/sasl/SaslRpcHandler.java 80
/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/BlockTransferMessage.java 69 70 71 72 73 74 75 76 77 78 79 80
/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/BlocksRemoved.java 71
/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/ExecutorShuffleInfo.java 90 91 93
/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/FetchShuffleBlocks.java 136 137 138 140 144
/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/GetLocalDirsForExecutors.java 78 79 80
/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/LocalDirsForExecutors.java 99 100 101 102
/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/OpenBlocks.java 86 87 88 89
/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/RegisterExecutor.java 91 92 93 94
/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/RemoveBlocks.java 86 87 88 89
/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/StreamHandle.java 79
/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/UploadBlock.java 111 112 113 114 115 116
/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/UploadBlockStream.java 86 87 88
/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/mesos/RegisterDriver.java 72 73
/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/mesos/ShuffleServiceHeartbeat.java 50 51
/common/unsafe/src/test/java/org/apache/spark/unsafe/types/UTF8StringSuite.java 566
/dev/github_jira_sync.py 71
/dev/merge_spark_pr.py 100 102
/dev/run-tests.py 273
/dev/sparktestsupport/shellutils.py 56
/python/pyspark/accumulators.py 256
/python/pyspark/rdd.py 845
/python/pyspark/serializers.py 562
/python/pyspark/sql/functions.py 1546 1552
/python/pyspark/sql/types.py 727
/python/pyspark/streaming/kinesis.py 31
/python/pyspark/tests/test_appsubmit.py 105 121 140 160 178 197 217
/python/pyspark/tests/test_rdd.py 102 112
/python/pyspark/worker.py 617
/python/run-tests.py 121 138
/sql/hive-thriftserver/v1.2/src/main/java/org/apache/hive/service/cli/operation/SQLOperation.java 335 349
/sql/hive-thriftserver/v2.3/src/main/java/org/apache/hive/service/cli/operation/SQLOperation.java 335 349

139 references in 51 files.