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 start

Definitions

Type Member of File Line
method LevelDBTypeInfo.Index /common/kvstore/src/main/java/org/apache/spark/util/kvstore/LevelDBTypeInfo.java 285
method OneForOneBlockFetcher /common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/OneForOneBlockFetcher.java 181
method RetryingBlockFetcher /common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RetryingBlockFetcher.java 120
method /core/src/main/resources/org/apache/spark/ui/static/d3.min.js 4
property options /core/src/main/resources/org/apache/spark/ui/static/timeline-view.js 28
property options /core/src/main/resources/org/apache/spark/ui/static/timeline-view.js 111
property options /core/src/main/resources/org/apache/spark/ui/static/timeline-view.js 195
method InProcessAppHandle /launcher/src/main/java/org/apache/spark/launcher/InProcessAppHandle.java 63
class member DataStreamWriter /python/pyspark/sql/streaming.py 1158
class member StreamingContext /python/pyspark/streaming/context.py 175
field JavaRangeInputPartition /sql/core/src/test/java/test/org/apache/spark/sql/connector/JavaRangeInputPartition.java 23
method BreakableService /sql/hive-thriftserver/src/main/java/org/apache/hive/service/BreakableService.java 87
method FilterService /sql/hive-thriftserver/src/main/java/org/apache/hive/service/FilterService.java 43
method /sql/hive-thriftserver/src/main/java/org/apache/hive/service/Service.java 64
method AbstractService /sql/hive-thriftserver/v1.2/src/main/java/org/apache/hive/service/AbstractService.java 100
method CompositeService /sql/hive-thriftserver/v1.2/src/main/java/org/apache/hive/service/CompositeService.java 65
method ServiceOperations /sql/hive-thriftserver/v1.2/src/main/java/org/apache/hive/service/ServiceOperations.java 81
method CLIService /sql/hive-thriftserver/v1.2/src/main/java/org/apache/hive/service/cli/CLIService.java 146
method OperationManager /sql/hive-thriftserver/v1.2/src/main/java/org/apache/hive/service/cli/operation/OperationManager.java 72
method SessionManager /sql/hive-thriftserver/v1.2/src/main/java/org/apache/hive/service/cli/session/SessionManager.java 144
method ThriftCLIService /sql/hive-thriftserver/v1.2/src/main/java/org/apache/hive/service/cli/thrift/ThriftCLIService.java 175
method HiveServer2 /sql/hive-thriftserver/v1.2/src/main/java/org/apache/hive/service/server/HiveServer2.java 104
method TCLIService.AsyncProcessor.OpenSession /sql/hive-thriftserver/v2.3/src/gen/java/org/apache/hive/service/rpc/thrift/TCLIService.java 1865
method TCLIService.AsyncProcessor.CloseSession /sql/hive-thriftserver/v2.3/src/gen/java/org/apache/hive/service/rpc/thrift/TCLIService.java 1916
method TCLIService.AsyncProcessor.GetInfo /sql/hive-thriftserver/v2.3/src/gen/java/org/apache/hive/service/rpc/thrift/TCLIService.java 1967
method TCLIService.AsyncProcessor.ExecuteStatement /sql/hive-thriftserver/v2.3/src/gen/java/org/apache/hive/service/rpc/thrift/TCLIService.java 2018
method TCLIService.AsyncProcessor.GetTypeInfo /sql/hive-thriftserver/v2.3/src/gen/java/org/apache/hive/service/rpc/thrift/TCLIService.java 2069
method TCLIService.AsyncProcessor.GetCatalogs /sql/hive-thriftserver/v2.3/src/gen/java/org/apache/hive/service/rpc/thrift/TCLIService.java 2120
method TCLIService.AsyncProcessor.GetSchemas /sql/hive-thriftserver/v2.3/src/gen/java/org/apache/hive/service/rpc/thrift/TCLIService.java 2171
method TCLIService.AsyncProcessor.GetTables /sql/hive-thriftserver/v2.3/src/gen/java/org/apache/hive/service/rpc/thrift/TCLIService.java 2222
method TCLIService.AsyncProcessor.GetTableTypes /sql/hive-thriftserver/v2.3/src/gen/java/org/apache/hive/service/rpc/thrift/TCLIService.java 2273
method TCLIService.AsyncProcessor.GetColumns /sql/hive-thriftserver/v2.3/src/gen/java/org/apache/hive/service/rpc/thrift/TCLIService.java 2324
method TCLIService.AsyncProcessor.GetFunctions /sql/hive-thriftserver/v2.3/src/gen/java/org/apache/hive/service/rpc/thrift/TCLIService.java 2375
method TCLIService.AsyncProcessor.GetPrimaryKeys /sql/hive-thriftserver/v2.3/src/gen/java/org/apache/hive/service/rpc/thrift/TCLIService.java 2426
method TCLIService.AsyncProcessor.GetCrossReference /sql/hive-thriftserver/v2.3/src/gen/java/org/apache/hive/service/rpc/thrift/TCLIService.java 2477
method TCLIService.AsyncProcessor.GetOperationStatus /sql/hive-thriftserver/v2.3/src/gen/java/org/apache/hive/service/rpc/thrift/TCLIService.java 2528
method TCLIService.AsyncProcessor.CancelOperation /sql/hive-thriftserver/v2.3/src/gen/java/org/apache/hive/service/rpc/thrift/TCLIService.java 2579
method TCLIService.AsyncProcessor.CloseOperation /sql/hive-thriftserver/v2.3/src/gen/java/org/apache/hive/service/rpc/thrift/TCLIService.java 2630
method TCLIService.AsyncProcessor.GetResultSetMetadata /sql/hive-thriftserver/v2.3/src/gen/java/org/apache/hive/service/rpc/thrift/TCLIService.java 2681
method TCLIService.AsyncProcessor.FetchResults /sql/hive-thriftserver/v2.3/src/gen/java/org/apache/hive/service/rpc/thrift/TCLIService.java 2732
method TCLIService.AsyncProcessor.GetDelegationToken /sql/hive-thriftserver/v2.3/src/gen/java/org/apache/hive/service/rpc/thrift/TCLIService.java 2783
method TCLIService.AsyncProcessor.CancelDelegationToken /sql/hive-thriftserver/v2.3/src/gen/java/org/apache/hive/service/rpc/thrift/TCLIService.java 2834
method TCLIService.AsyncProcessor.RenewDelegationToken /sql/hive-thriftserver/v2.3/src/gen/java/org/apache/hive/service/rpc/thrift/TCLIService.java 2885
method AbstractService /sql/hive-thriftserver/v2.3/src/main/java/org/apache/hive/service/AbstractService.java 100
method CompositeService /sql/hive-thriftserver/v2.3/src/main/java/org/apache/hive/service/CompositeService.java 65
method ServiceOperations /sql/hive-thriftserver/v2.3/src/main/java/org/apache/hive/service/ServiceOperations.java 81
method CLIService /sql/hive-thriftserver/v2.3/src/main/java/org/apache/hive/service/cli/CLIService.java 147
method OperationManager /sql/hive-thriftserver/v2.3/src/main/java/org/apache/hive/service/cli/operation/OperationManager.java 71
method SessionManager /sql/hive-thriftserver/v2.3/src/main/java/org/apache/hive/service/cli/session/SessionManager.java 144
method ThriftCLIService /sql/hive-thriftserver/v2.3/src/main/java/org/apache/hive/service/cli/thrift/ThriftCLIService.java 176
method HiveServer2 /sql/hive-thriftserver/v2.3/src/main/java/org/apache/hive/service/server/HiveServer2.java 104

51 declarations in 29 files.

References:

File Line
/common/kvstore/src/main/java/org/apache/spark/util/kvstore/LevelDB.java 133 168
/common/kvstore/src/main/java/org/apache/spark/util/kvstore/LevelDBIterator.java 66 86
/common/kvstore/src/main/java/org/apache/spark/util/kvstore/LevelDBTypeInfo.java 285 310 337
/common/network-common/src/main/java/org/apache/spark/network/crypto/AuthEngine.java 242 247
/common/network-common/src/main/java/org/apache/spark/network/util/JavaUtils.java 159
/common/network-common/src/test/java/org/apache/spark/network/TransportClientFactorySuite.java 108 163 164
/common/network-common/src/test/java/org/apache/spark/network/util/TransportFrameDecoderSuite.java 94 96
/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/ExternalBlockStoreClient.java 110 120
/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/OneForOneBlockFetcher.java 181
/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RetryingBlockFetcher.java 120
/common/network-shuffle/src/test/java/org/apache/spark/network/shuffle/AppIsolationSuite.java 131
/common/network-shuffle/src/test/java/org/apache/spark/network/shuffle/OneForOneBlockFetcherSuite.java 256
/common/network-shuffle/src/test/java/org/apache/spark/network/shuffle/RetryingBlockFetcherSuite.java 296
/common/unsafe/src/main/java/org/apache/spark/unsafe/types/ByteArray.java 61 64 66 68 71 73 73 74 77
/common/unsafe/src/main/java/org/apache/spark/unsafe/types/UTF8String.java 309 310 310 316 344 345 346 526 527 529 768 776 798 800 801 802 804 812 814 815 816 818 1039 1040 1050 1050 1052 1053 1055 1055
/core/src/main/java/org/apache/spark/util/collection/TimSort.java 185 186 186 187 188 194 194 195 200 223
/core/src/main/java/org/apache/spark/util/collection/unsafe/sort/RadixSort.java 154 157 157 163 163
/core/src/main/java/org/apache/spark/util/collection/unsafe/sort/UnsafeInMemorySorter.java 350 367
/core/src/main/resources/org/apache/spark/ui/static/d3.min.js 2 3
/core/src/main/resources/org/apache/spark/ui/static/dagre-d3.min.js 25 25 27 27
/core/src/main/resources/org/apache/spark/ui/static/graphlib-dot.min.js 1
/core/src/main/resources/org/apache/spark/ui/static/jquery-3.4.1.min.js 2 2 2 2 2 2 2 2 2 2 2
/core/src/main/resources/org/apache/spark/ui/static/jquery.dataTables.1.10.18.min.js 38
/core/src/main/resources/org/apache/spark/ui/static/log-view.js 131 134
/core/src/main/resources/org/apache/spark/ui/static/timeline-view.js 29 112 196
/core/src/main/resources/org/apache/spark/ui/static/vis-timeline-graph2d.min.js 52 59
/core/src/test/java/org/apache/spark/unsafe/map/AbstractBytesToBytesMapSuite.java 711
/core/src/test/java/org/apache/spark/util/collection/unsafe/sort/UnsafeExternalSorterSuite.java 555 557
/dev/create-release/release-build.sh 410
/docs/_plugins/include_example.rb 108 110 112 114
/docs/js/vendor/jquery-3.4.1.min.js 2 2 2 2 2 2 2 2 2 2 2
/examples/src/main/java/org/apache/spark/examples/mllib/JavaStreamingTestExample.java 101
/examples/src/main/java/org/apache/spark/examples/sql/streaming/JavaStructuredKafkaWordCount.java 88
/examples/src/main/java/org/apache/spark/examples/sql/streaming/JavaStructuredKerberizedKafkaWordCount.java 125
/examples/src/main/java/org/apache/spark/examples/sql/streaming/JavaStructuredNetworkWordCount.java 74
/examples/src/main/java/org/apache/spark/examples/sql/streaming/JavaStructuredNetworkWordCountWindowed.java 108
/examples/src/main/java/org/apache/spark/examples/sql/streaming/JavaStructuredSessionization.java 155
/examples/src/main/java/org/apache/spark/examples/streaming/JavaCustomReceiver.java 78 96
/examples/src/main/java/org/apache/spark/examples/streaming/JavaDirectKafkaWordCount.java 95
/examples/src/main/java/org/apache/spark/examples/streaming/JavaDirectKerberizedKafkaWordCount.java 137
/examples/src/main/java/org/apache/spark/examples/streaming/JavaNetworkWordCount.java 70
/examples/src/main/java/org/apache/spark/examples/streaming/JavaQueueStream.java 68
/examples/src/main/java/org/apache/spark/examples/streaming/JavaRecoverableNetworkWordCount.java 188
/examples/src/main/java/org/apache/spark/examples/streaming/JavaSqlNetworkWordCount.java 91
/examples/src/main/java/org/apache/spark/examples/streaming/JavaStatefulNetworkWordCount.java 92
/examples/src/main/python/mllib/streaming_k_means_example.py 62
/examples/src/main/python/mllib/streaming_linear_regression_example.py 60
/examples/src/main/python/sql/streaming/structured_kafka_wordcount.py 88
/examples/src/main/python/sql/streaming/structured_network_wordcount.py 75
/examples/src/main/python/sql/streaming/structured_network_wordcount_windowed.py 100
/examples/src/main/python/status_api_demo.py 42
/examples/src/main/python/streaming/hdfs_wordcount.py 49
/examples/src/main/python/streaming/network_wordcount.py 48
/examples/src/main/python/streaming/network_wordjoinsentiments.py 76
/examples/src/main/python/streaming/queue_stream.py 47
/examples/src/main/python/streaming/recoverable_network_wordcount.py 108
/examples/src/main/python/streaming/sql_network_wordcount.py 84
/examples/src/main/python/streaming/stateful_network_wordcount.py 60
/external/kafka-0-10/src/test/java/org/apache/spark/streaming/kafka010/JavaDirectKafkaStreamSuite.java 163
/external/kinesis-asl/src/main/java/org/apache/spark/examples/streaming/JavaKinesisWordCountASL.java 193
/external/kinesis-asl/src/main/python/examples/streaming/kinesis_wordcount_asl.py 83
/launcher/src/main/java/org/apache/spark/launcher/ChildProcAppHandle.java 89
/launcher/src/main/java/org/apache/spark/launcher/InProcessAppHandle.java 63 86
/launcher/src/main/java/org/apache/spark/launcher/InProcessLauncher.java 75
/launcher/src/main/java/org/apache/spark/launcher/LauncherServer.java 136 255
/launcher/src/main/java/org/apache/spark/launcher/OutputRedirector.java 56
/launcher/src/main/java/org/apache/spark/launcher/SparkLauncher.java 332 407
/launcher/src/test/java/org/apache/spark/launcher/LauncherServerSuite.java 258
/python/pyspark/accumulators.py 294
/python/pyspark/context.py 466 487 488 490
/python/pyspark/mllib/linalg/__init__.py 304 305 310 596 597 602
/python/pyspark/mllib/tests/test_streaming_algorithms.py 72 113 143 176 222 248 282 320 358 385 418 457
/python/pyspark/rdd.py 835
/python/pyspark/sql/column.py 348
/python/pyspark/sql/context.py 172 192
/python/pyspark/sql/functions.py 1079 1088 1092 1101 1105 1114 1118 1127 2022 2036 2808 2823 2826
/python/pyspark/sql/pandas/conversion.py 416 416 416
/python/pyspark/sql/session.py 336 360 362
/python/pyspark/sql/streaming.py 1158 1211 1213
/python/pyspark/sql/tests/test_streaming.py 88 116 153 186 207 221 252 303 314 540 558
/python/pyspark/sql/tests/test_udf.py 465 467
/python/pyspark/sql/window.py 85 131 132 136 141 190 191 195 231 250 251 254 257 276 277 280
/python/pyspark/streaming/context.py 175 179
/python/pyspark/streaming/tests/test_context.py 38 44 59 73 114 124 147 161 170
/python/pyspark/streaming/tests/test_dstream.py 90 337 359 523 557 596 614
/python/pyspark/streaming/tests/test_kinesis.py 61
/python/pyspark/testing/streamingutils.py 111 134
/python/pyspark/tests/test_context.py 227
/python/pyspark/tests/test_pin_thread.py 73 119 124
/python/pyspark/tests/test_rdd.py 428 831 836
/python/pyspark/tests/test_worker.py 60 138
/python/run-tests.py 308
/python/test_coverage/coverage_daemon.py 33
/sbin/spark-daemon.sh 199
/sbin/start-all.sh 32 35
/sbin/start-history-server.sh 49
/sbin/start-master.sh 66
/sbin/start-mesos-dispatcher.sh 51
/sbin/start-mesos-shuffle-service.sh 36
/sbin/start-slave.sh 82
/sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/streaming/ContinuousStream.java 47
/sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/streaming/MicroBatchStream.java 53
/sql/catalyst/src/main/java/org/apache/spark/sql/vectorized/ArrowColumnVector.java 387 388 463 465 465
/sql/core/src/test/java/test/org/apache/spark/sql/connector/JavaAdvancedDataSourceV2.java 156
/sql/core/src/test/java/test/org/apache/spark/sql/connector/JavaColumnarDataSourceV2.java 88
/sql/core/src/test/java/test/org/apache/spark/sql/connector/JavaRangeInputPartition.java 23 26 27 27
/sql/core/src/test/java/test/org/apache/spark/sql/connector/JavaSimpleReaderFactory.java 32
/sql/core/src/test/java/test/org/apache/spark/sql/streaming/JavaDataStreamReaderWriterSuite.java 65 87
/sql/core/v1.2/src/main/java/org/apache/spark/sql/execution/datasources/orc/OrcColumnVector.java 182 190
/sql/core/v2.3/src/main/java/org/apache/spark/sql/execution/datasources/orc/OrcColumnVector.java 182 190
/sql/hive-thriftserver/src/main/java/org/apache/hive/service/BreakableService.java 87 90
/sql/hive-thriftserver/src/main/java/org/apache/hive/service/FilterService.java 43 44
/sql/hive-thriftserver/src/main/java/org/apache/hive/service/Service.java 64
/sql/hive-thriftserver/v1.2/src/main/java/org/apache/hive/service/AbstractService.java 100
/sql/hive-thriftserver/v1.2/src/main/java/org/apache/hive/service/CompositeService.java 65 70 72
/sql/hive-thriftserver/v1.2/src/main/java/org/apache/hive/service/ServiceOperations.java 81 84 100
/sql/hive-thriftserver/v1.2/src/main/java/org/apache/hive/service/cli/CLIService.java 127 146 147
/sql/hive-thriftserver/v1.2/src/main/java/org/apache/hive/service/cli/Column.java 176 177 179 181 186 188 193 195 200 202 207 209 214 216 221 223 228 230
/sql/hive-thriftserver/v1.2/src/main/java/org/apache/hive/service/cli/operation/OperationManager.java 72 73
/sql/hive-thriftserver/v1.2/src/main/java/org/apache/hive/service/cli/session/HiveSessionImpl.java 143
/sql/hive-thriftserver/v1.2/src/main/java/org/apache/hive/service/cli/session/SessionManager.java 144 145
/sql/hive-thriftserver/v1.2/src/main/java/org/apache/hive/service/cli/thrift/ThriftCLIService.java 175 176 178
/sql/hive-thriftserver/v1.2/src/main/java/org/apache/hive/service/cli/thrift/ThriftHttpCLIService.java 145
/sql/hive-thriftserver/v1.2/src/main/java/org/apache/hive/service/server/HiveServer2.java 104 105 124
/sql/hive-thriftserver/v2.3/src/gen/java/org/apache/hive/service/rpc/thrift/TCLIService.java 1865 1916 1967 2018 2069 2120 2171 2222 2273 2324 2375 2426 2477 2528 2579 2630 2681 2732 2783 2834 2885
/sql/hive-thriftserver/v2.3/src/main/java/org/apache/hive/service/AbstractService.java 100
/sql/hive-thriftserver/v2.3/src/main/java/org/apache/hive/service/CompositeService.java 65 70 72
/sql/hive-thriftserver/v2.3/src/main/java/org/apache/hive/service/ServiceOperations.java 81 84 100
/sql/hive-thriftserver/v2.3/src/main/java/org/apache/hive/service/cli/CLIService.java 128 147 148
/sql/hive-thriftserver/v2.3/src/main/java/org/apache/hive/service/cli/operation/OperationManager.java 71 72
/sql/hive-thriftserver/v2.3/src/main/java/org/apache/hive/service/cli/session/HiveSessionImpl.java 144
/sql/hive-thriftserver/v2.3/src/main/java/org/apache/hive/service/cli/session/SessionManager.java 144 145
/sql/hive-thriftserver/v2.3/src/main/java/org/apache/hive/service/cli/thrift/ThriftCLIService.java 176 177 179
/sql/hive-thriftserver/v2.3/src/main/java/org/apache/hive/service/cli/thrift/ThriftHttpCLIService.java 146
/sql/hive-thriftserver/v2.3/src/main/java/org/apache/hive/service/server/HiveServer2.java 104 105 124 127
/streaming/src/test/java/org/apache/spark/streaming/JavaMapWithStateSuite.java 159
/streaming/src/test/java/org/apache/spark/streaming/JavaReceiverAPISuite.java 60 74 106
/streaming/src/test/java/test/org/apache/spark/streaming/JavaAPISuite.java 86

396 references in 138 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!