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 close

Definitions

Type Member of File Line
method InMemoryStore /common/kvstore/src/main/java/org/apache/spark/util/kvstore/InMemoryStore.java 110
method InMemoryStore.InMemoryIterator /common/kvstore/src/main/java/org/apache/spark/util/kvstore/InMemoryStore.java 500
method LevelDB /common/kvstore/src/main/java/org/apache/spark/util/kvstore/LevelDB.java 233
method LevelDBIterator /common/kvstore/src/main/java/org/apache/spark/util/kvstore/LevelDBIterator.java 187
method TransportContext /common/network-common/src/main/java/org/apache/spark/network/TransportContext.java 240
method TransportClient /common/network-common/src/main/java/org/apache/spark/network/client/TransportClient.java 298
method TransportClientFactory /common/network-common/src/main/java/org/apache/spark/network/client/TransportClientFactory.java 283
method AuthEngine /common/network-common/src/main/java/org/apache/spark/network/crypto/AuthEngine.java 156
method TransportCipher.EncryptionHandler /common/network-common/src/main/java/org/apache/spark/network/crypto/TransportCipher.java 134
method TransportServer /common/network-common/src/main/java/org/apache/spark/network/server/TransportServer.java 161
method ByteArrayReadableChannel /common/network-common/src/main/java/org/apache/spark/network/util/ByteArrayReadableChannel.java 54
method ByteArrayWritableChannel /common/network-common/src/main/java/org/apache/spark/network/util/ByteArrayWritableChannel.java 60
method LimitedInputStream /common/network-common/src/main/java/org/apache/spark/network/util/LimitedInputStream.java 123
method AuthIntegrationSuite.AuthTestCtx /common/network-common/src/test/java/org/apache/spark/network/crypto/AuthIntegrationSuite.java 229
method SparkSaslSuite.SaslTestCtx /common/network-common/src/test/java/org/apache/spark/network/sasl/SparkSaslSuite.java 426
method ExternalBlockHandler /common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/ExternalBlockHandler.java 207
method ExternalBlockStoreClient /common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/ExternalBlockStoreClient.java 235
method ExternalShuffleBlockResolver /common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/ExternalShuffleBlockResolver.java 346
method SimpleDownloadFile.SimpleDownloadWritableChannel /common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/SimpleDownloadFile.java 87
method KVIterator /common/unsafe/src/main/java/org/apache/spark/unsafe/KVIterator.java 30
method NioBufferedFileInputStream /core/src/main/java/org/apache/spark/io/NioBufferedFileInputStream.java 127
method ReadAheadInputStream /core/src/main/java/org/apache/spark/io/ReadAheadInputStream.java 369
method UnsafeShuffleWriter.StreamFallbackChannelWrapper /core/src/main/java/org/apache/spark/shuffle/sort/UnsafeShuffleWriter.java 527
method LocalDiskShuffleMapOutputWriter.PartitionWriterStream /core/src/main/java/org/apache/spark/shuffle/sort/io/LocalDiskShuffleMapOutputWriter.java 239
method LocalDiskShuffleMapOutputWriter.PartitionWriterChannel /core/src/main/java/org/apache/spark/shuffle/sort/io/LocalDiskShuffleMapOutputWriter.java 271
method TimeTrackingOutputStream /core/src/main/java/org/apache/spark/storage/TimeTrackingOutputStream.java 71
method UnsafeSorterSpillReader /core/src/main/java/org/apache/spark/util/collection/unsafe/sort/UnsafeSorterSpillReader.java 141
method UnsafeSorterSpillWriter /core/src/main/java/org/apache/spark/util/collection/unsafe/sort/UnsafeSorterSpillWriter.java 147
method TestJavaSerializerImpl.SerializationStreamImpl /core/src/test/java/org/apache/spark/serializer/TestJavaSerializerImpl.java 77
method TestJavaSerializerImpl.DeserializationStreamImpl /core/src/test/java/org/apache/spark/serializer/TestJavaSerializerImpl.java 90
method Alert /docs/js/vendor/bootstrap.js 93
method n /docs/js/vendor/bootstrap.min.js 6
method SparkAvroKeyRecordWriter /external/avro/src/main/java/org/apache/spark/sql/avro/SparkAvroKeyOutputFormat.java 87
method LauncherConnection /launcher/src/main/java/org/apache/spark/launcher/LauncherConnection.java 98
method LauncherServer /launcher/src/main/java/org/apache/spark/launcher/LauncherServer.java 157
method LauncherServer.ServerConnection /launcher/src/main/java/org/apache/spark/launcher/LauncherServer.java 349
method ChildProcAppHandleSuite.LogAppender /launcher/src/test/java/org/apache/spark/launcher/ChildProcAppHandleSuite.java 254
method LauncherServerSuite /launcher/src/test/java/org/apache/spark/launcher/LauncherServerSuite.java 216
class member ChunkedStream /python/pyspark/serializers.py 656
class member StreamingTests.test_streaming_foreach_with_basic_open_process_close.ForeachWriter /python/pyspark/sql/tests/test_streaming.py 374
class member StreamingTests.test_streaming_foreach_with_open_returning_false.ForeachWriter /python/pyspark/sql/tests/test_streaming.py 400
class member StreamingTests.test_streaming_foreach_without_open_method.ForeachWriter /python/pyspark/sql/tests/test_streaming.py 420
class member StreamingTests.test_streaming_foreach_with_process_throwing_error.ForeachWriter /python/pyspark/sql/tests/test_streaming.py 465
variable StreamingTests.test_streaming_foreach_with_invalid_writers.WriterWithNonCallableClose /python/pyspark/sql/tests/test_streaming.py 526
class member ByteArrayOutput /python/pyspark/testing/utils.py 142
method MesosExternalBlockStoreClient /resource-managers/mesos/src/main/java/org/apache/spark/network/shuffle/mesos/MesosExternalBlockStoreClient.java 105
method RowBasedKeyValueBatch /sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/RowBasedKeyValueBatch.java 120
method UDFXPathUtil.ReusableStringReader /sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/xml/UDFXPathUtil.java 216
method ArrowColumnVector /sql/catalyst/src/main/java/org/apache/spark/sql/vectorized/ArrowColumnVector.java 49
method ArrowColumnVector.ArrowVectorAccessor /sql/catalyst/src/main/java/org/apache/spark/sql/vectorized/ArrowColumnVector.java 196
method ColumnVector /sql/catalyst/src/main/java/org/apache/spark/sql/vectorized/ColumnVector.java 65
method ColumnarBatch /sql/catalyst/src/main/java/org/apache/spark/sql/vectorized/ColumnarBatch.java 46
method UnsafeKVExternalSorter.KVSorterIterator /sql/core/src/main/java/org/apache/spark/sql/execution/UnsafeKVExternalSorter.java 326
method OrcColumnarBatchReader /sql/core/src/main/java/org/apache/spark/sql/execution/datasources/orc/OrcColumnarBatchReader.java 103
method SpecificParquetRecordReaderBase /sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/SpecificParquetRecordReaderBase.java 240
method VectorizedParquetRecordReader /sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedParquetRecordReader.java 159
method OffHeapColumnVector /sql/core/src/main/java/org/apache/spark/sql/execution/vectorized/OffHeapColumnVector.java 88
method OnHeapColumnVector /sql/core/src/main/java/org/apache/spark/sql/execution/vectorized/OnHeapColumnVector.java 84
method WritableColumnVector /sql/core/src/main/java/org/apache/spark/sql/execution/vectorized/WritableColumnVector.java 69
method NonClosableMutableURLClassLoader /sql/core/src/main/java/org/apache/spark/sql/internal/NonClosableMutableURLClassLoader.java 38
method OrcColumnVector /sql/core/v1.2/src/main/java/org/apache/spark/sql/execution/datasources/orc/OrcColumnVector.java 87
method OrcColumnVector /sql/core/v2.3/src/main/java/org/apache/spark/sql/execution/datasources/orc/OrcColumnVector.java 87
method HiveCommandOperation /sql/hive-thriftserver/v1.2/src/main/java/org/apache/hive/service/cli/operation/HiveCommandOperation.java 134
method MetadataOperation /sql/hive-thriftserver/v1.2/src/main/java/org/apache/hive/service/cli/operation/MetadataOperation.java 56
method Operation /sql/hive-thriftserver/v1.2/src/main/java/org/apache/hive/service/cli/operation/Operation.java 283
method SQLOperation /sql/hive-thriftserver/v1.2/src/main/java/org/apache/hive/service/cli/operation/SQLOperation.java 302
method /sql/hive-thriftserver/v1.2/src/main/java/org/apache/hive/service/cli/session/HiveSession.java 132
method HiveSessionImpl /sql/hive-thriftserver/v1.2/src/main/java/org/apache/hive/service/cli/session/HiveSessionImpl.java 634
method HiveSessionImplwithUGI /sql/hive-thriftserver/v1.2/src/main/java/org/apache/hive/service/cli/session/HiveSessionImplwithUGI.java 103
method HiveCommandOperation /sql/hive-thriftserver/v2.3/src/main/java/org/apache/hive/service/cli/operation/HiveCommandOperation.java 134
method MetadataOperation /sql/hive-thriftserver/v2.3/src/main/java/org/apache/hive/service/cli/operation/MetadataOperation.java 56
method Operation /sql/hive-thriftserver/v2.3/src/main/java/org/apache/hive/service/cli/operation/Operation.java 301
method SQLOperation /sql/hive-thriftserver/v2.3/src/main/java/org/apache/hive/service/cli/operation/SQLOperation.java 302
method /sql/hive-thriftserver/v2.3/src/main/java/org/apache/hive/service/cli/session/HiveSession.java 180
method HiveSessionImpl /sql/hive-thriftserver/v2.3/src/main/java/org/apache/hive/service/cli/session/HiveSessionImpl.java 648
method HiveSessionImplwithUGI /sql/hive-thriftserver/v2.3/src/main/java/org/apache/hive/service/cli/session/HiveSessionImplwithUGI.java 103
method SparkOrcNewRecordReader /sql/hive/src/main/java/org/apache/hadoop/hive/ql/io/orc/SparkOrcNewRecordReader.java 56
method WriteAheadLog /streaming/src/main/java/org/apache/spark/streaming/util/WriteAheadLog.java 61
method JavaWriteAheadLogSuite /streaming/src/test/java/org/apache/spark/streaming/JavaWriteAheadLogSuite.java 97

79 declarations in 70 files.

References:

File Line
/common/kvstore/src/main/java/org/apache/spark/util/kvstore/InMemoryStore.java 110 500
/common/kvstore/src/main/java/org/apache/spark/util/kvstore/LevelDB.java 83 233 241 258
/common/kvstore/src/main/java/org/apache/spark/util/kvstore/LevelDBIterator.java 116 187 189
/common/kvstore/src/test/java/org/apache/spark/util/kvstore/LevelDBBenchmark.java 76 192
/common/kvstore/src/test/java/org/apache/spark/util/kvstore/LevelDBIteratorSuite.java 33
/common/kvstore/src/test/java/org/apache/spark/util/kvstore/LevelDBSuite.java 43 59 67
/common/network-common/src/main/java/org/apache/spark/network/TransportContext.java 240
/common/network-common/src/main/java/org/apache/spark/network/client/TransportClient.java 298 300 338
/common/network-common/src/main/java/org/apache/spark/network/client/TransportClientFactory.java 270 283
/common/network-common/src/main/java/org/apache/spark/network/crypto/AuthEngine.java 156 178
/common/network-common/src/main/java/org/apache/spark/network/crypto/AuthRpcHandler.java 103 126 131
/common/network-common/src/main/java/org/apache/spark/network/crypto/TransportCipher.java 134 137 140 205
/common/network-common/src/main/java/org/apache/spark/network/server/ChunkFetchRequestHandler.java 74 95 148
/common/network-common/src/main/java/org/apache/spark/network/server/TransportChannelHandler.java 91 171 175
/common/network-common/src/main/java/org/apache/spark/network/server/TransportRequestHandler.java 131 273
/common/network-common/src/main/java/org/apache/spark/network/server/TransportServer.java 161 164
/common/network-common/src/main/java/org/apache/spark/network/util/ByteArrayReadableChannel.java 54
/common/network-common/src/main/java/org/apache/spark/network/util/ByteArrayWritableChannel.java 60
/common/network-common/src/main/java/org/apache/spark/network/util/JavaUtils.java 53
/common/network-common/src/main/java/org/apache/spark/network/util/LimitedInputStream.java 123 125
/common/network-common/src/test/java/org/apache/spark/network/ChunkFetchIntegrationSuite.java 88 129 130 131
/common/network-common/src/test/java/org/apache/spark/network/ChunkFetchRequestHandlerSuite.java 108
/common/network-common/src/test/java/org/apache/spark/network/RequestTimeoutIntegrationSuite.java 78 81 84
/common/network-common/src/test/java/org/apache/spark/network/RpcIntegrationSuite.java 162 163 164 203 232 319
/common/network-common/src/test/java/org/apache/spark/network/StreamSuite.java 104 105 107 118 130 145 170 241 279
/common/network-common/src/test/java/org/apache/spark/network/StreamTestHelper.java 69
/common/network-common/src/test/java/org/apache/spark/network/TransportClientFactorySuite.java 123 126 154 161 172 182 224
/common/network-common/src/test/java/org/apache/spark/network/TransportRequestHandlerSuite.java 106
/common/network-common/src/test/java/org/apache/spark/network/crypto/AuthEngineSuite.java 70 71 131 158 159 204 205
/common/network-common/src/test/java/org/apache/spark/network/crypto/AuthIntegrationSuite.java 54 229 231 234 237
/common/network-common/src/test/java/org/apache/spark/network/sasl/SparkSaslSuite.java 156 295 314 334 418 426 431 434 437
/common/network-common/src/test/java/org/apache/spark/network/util/NettyMemoryMetricsSuite.java 128 170
/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/ExternalBlockHandler.java 207 208
/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/ExternalBlockStoreClient.java 179 188 216 226 235 238
/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/ExternalShuffleBlockResolver.java 346 349
/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/OneForOneBlockFetcher.java 253
/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/SimpleDownloadFile.java 87 88
/common/network-shuffle/src/test/java/org/apache/spark/network/sasl/SaslIntegrationSuite.java 80 81 87
/common/network-shuffle/src/test/java/org/apache/spark/network/shuffle/ExternalShuffleIntegrationSuite.java 139 140
/common/network-shuffle/src/test/java/org/apache/spark/network/shuffle/ExternalShuffleSecuritySuite.java 57 61
/common/network-shuffle/src/test/java/org/apache/spark/network/shuffle/TestShuffleDataContext.java 93 94 132
/common/network-yarn/src/main/java/org/apache/spark/network/yarn/YarnShuffleService.java 323 326 329 332
/common/unsafe/src/main/java/org/apache/spark/unsafe/KVIterator.java 30
/core/src/main/java/org/apache/spark/io/NioBufferedFileInputStream.java 127 128 135
/core/src/main/java/org/apache/spark/io/ReadAheadInputStream.java 208 369 396
/core/src/main/java/org/apache/spark/serializer/DummySerializerInstance.java 62 65
/core/src/main/java/org/apache/spark/shuffle/sort/BypassMergeSortShuffleWriter.java 236 239 254 257
/core/src/main/java/org/apache/spark/shuffle/sort/UnsafeShuffleWriter.java 401 407 417 463 474 527 528
/core/src/main/java/org/apache/spark/shuffle/sort/io/LocalDiskShuffleMapOutputWriter.java 129 132 135 239 271
/core/src/main/java/org/apache/spark/storage/TimeTrackingOutputStream.java 71 73
/core/src/main/java/org/apache/spark/unsafe/map/BytesToBytesMap.java 284 332 375
/core/src/main/java/org/apache/spark/util/collection/unsafe/sort/UnsafeExternalSorter.java 496
/core/src/main/java/org/apache/spark/util/collection/unsafe/sort/UnsafeSorterSpillReader.java 82 116 141 144
/core/src/main/java/org/apache/spark/util/collection/unsafe/sort/UnsafeSorterSpillWriter.java 147 149
/core/src/test/java/org/apache/spark/io/GenericFileInputStreamSuite.java 55
/core/src/test/java/org/apache/spark/serializer/TestJavaSerializerImpl.java 77 90
/dev/create-release/generate-contributors.py 267
/dev/create-release/translate-contributors.py 77 238 239 256
/dev/github_jira_sync.py 101
/docs/js/vendor/bootstrap.js 90 93 146
/docs/js/vendor/bootstrap.min.js 6 6 6
/examples/src/main/java/org/apache/spark/examples/streaming/JavaCustomReceiver.java 122 123
/external/avro/src/main/java/org/apache/spark/sql/avro/SparkAvroKeyOutputFormat.java 87 88
/launcher/src/main/java/org/apache/spark/launcher/AbstractAppHandle.java 76
/launcher/src/main/java/org/apache/spark/launcher/LauncherConnection.java 63 71 88 98 101
/launcher/src/main/java/org/apache/spark/launcher/LauncherServer.java 138 141 157 170 175 196 233 339 349 358 384
/launcher/src/test/java/org/apache/spark/launcher/BaseSuite.java 42
/launcher/src/test/java/org/apache/spark/launcher/ChildProcAppHandleSuite.java 254
/launcher/src/test/java/org/apache/spark/launcher/LauncherServerSuite.java 97 121 148 154 183 211 216 219
/python/pyspark/broadcast.py 119
/python/pyspark/cloudpickle.py 1100 1344
/python/pyspark/context.py 559 572
/python/pyspark/daemon.py 69 156 157 162 176 183 204
/python/pyspark/java_gateway.py 78 173 201
/python/pyspark/rdd.py 834
/python/pyspark/serializers.py 656 663
/python/pyspark/shuffle.py 321 484 587 744
/python/pyspark/sql/pandas/serializers.py 94
/python/pyspark/sql/streaming.py 1111
/python/pyspark/sql/tests/test_pandas_udf_scalar.py 867
/python/pyspark/sql/tests/test_streaming.py 374 400 420 465 526
/python/pyspark/taskcontext.py 142 143
/python/pyspark/testing/utils.py 142
/python/pyspark/tests/test_appsubmit.py 70
/python/pyspark/tests/test_broadcast.py 117 121
/python/pyspark/tests/test_context.py 277
/python/pyspark/tests/test_daemon.py 32 67
/python/pyspark/tests/test_rdd.py 98 108 125 184
/python/pyspark/tests/test_serializers.py 128 203
/python/pyspark/tests/test_taskcontext.py 299
/python/pyspark/tests/test_worker.py 41 104
/python/pyspark/worker.py 582 600
/python/run-tests.py 124 146
/resource-managers/mesos/src/main/java/org/apache/spark/network/shuffle/mesos/MesosExternalBlockStoreClient.java 105 107
/resource-managers/yarn/src/test/java/org/apache/hadoop/net/ServerSocketUtil.java 128
/sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/FixedLengthRowBasedKeyValueBatch.java 152
/sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/RowBasedKeyValueBatch.java 120
/sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/VariableLengthRowBasedKeyValueBatch.java 171
/sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/xml/UDFXPathUtil.java 216
/sql/catalyst/src/main/java/org/apache/spark/sql/vectorized/ArrowColumnVector.java 49 52 57 196 197
/sql/catalyst/src/main/java/org/apache/spark/sql/vectorized/ColumnVector.java 65
/sql/catalyst/src/main/java/org/apache/spark/sql/vectorized/ColumnarBatch.java 46 48
/sql/core/src/main/java/org/apache/spark/sql/execution/UnsafeFixedWidthAggregationMap.java 208
/sql/core/src/main/java/org/apache/spark/sql/execution/UnsafeKVExternalSorter.java 326
/sql/core/src/main/java/org/apache/spark/sql/execution/datasources/orc/OrcColumnarBatchReader.java 103 105 109
/sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/SpecificParquetRecordReaderBase.java 240 242
/sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedParquetRecordReader.java 159 161 164
/sql/core/src/main/java/org/apache/spark/sql/execution/vectorized/OffHeapColumnVector.java 88 89
/sql/core/src/main/java/org/apache/spark/sql/execution/vectorized/OnHeapColumnVector.java 84 85
/sql/core/src/main/java/org/apache/spark/sql/execution/vectorized/WritableColumnVector.java 69 72 78
/sql/core/src/main/java/org/apache/spark/sql/internal/NonClosableMutableURLClassLoader.java 38
/sql/core/src/test/java/test/org/apache/spark/sql/connector/JavaAdvancedDataSourceV2.java 178
/sql/core/src/test/java/test/org/apache/spark/sql/connector/JavaColumnarDataSourceV2.java 116 117
/sql/core/src/test/java/test/org/apache/spark/sql/connector/JavaPartitionAwareDataSource.java 122
/sql/core/src/test/java/test/org/apache/spark/sql/connector/JavaSimpleReaderFactory.java 46
/sql/core/src/test/java/test/org/apache/spark/sql/streaming/JavaDataStreamReaderWriterSuite.java 85
/sql/core/v1.2/src/main/java/org/apache/spark/sql/execution/datasources/orc/OrcColumnVector.java 87
/sql/core/v2.3/src/main/java/org/apache/spark/sql/execution/datasources/orc/OrcColumnVector.java 87
/sql/hive-thriftserver/src/main/java/org/apache/hive/service/auth/LdapAuthenticationProviderImpl.java 75
/sql/hive-thriftserver/v1.2/src/main/java/org/apache/hive/service/cli/CLIService.java 158
/sql/hive-thriftserver/v1.2/src/main/java/org/apache/hive/service/cli/operation/HiveCommandOperation.java 134
/sql/hive-thriftserver/v1.2/src/main/java/org/apache/hive/service/cli/operation/MetadataOperation.java 56
/sql/hive-thriftserver/v1.2/src/main/java/org/apache/hive/service/cli/operation/Operation.java 272 283
/sql/hive-thriftserver/v1.2/src/main/java/org/apache/hive/service/cli/operation/OperationManager.java 204
/sql/hive-thriftserver/v1.2/src/main/java/org/apache/hive/service/cli/operation/SQLOperation.java 285 302
/sql/hive-thriftserver/v1.2/src/main/java/org/apache/hive/service/cli/session/HiveSession.java 132
/sql/hive-thriftserver/v1.2/src/main/java/org/apache/hive/service/cli/session/HiveSessionImpl.java 634 651 660 738
/sql/hive-thriftserver/v1.2/src/main/java/org/apache/hive/service/cli/session/HiveSessionImplwithUGI.java 103 109
/sql/hive-thriftserver/v1.2/src/main/java/org/apache/hive/service/cli/session/SessionManager.java 261 280
/sql/hive-thriftserver/v2.3/src/gen/java/org/apache/hive/service/rpc/thrift/TCLIService.java 1840 1856 1891 1907 1942 1958 1993 2009 2044 2060 2095 2111 2146 2162 2197 2213 2248 2264 2299 2315 2350 2366 2401 2417 2452 2468 2503 2519 2554 2570 2605 2621 2656 2672 2707 2723 2758 2774 2809 2825 2860 2876
/sql/hive-thriftserver/v2.3/src/main/java/org/apache/hive/service/ServiceUtils.java 60
/sql/hive-thriftserver/v2.3/src/main/java/org/apache/hive/service/cli/CLIService.java 159
/sql/hive-thriftserver/v2.3/src/main/java/org/apache/hive/service/cli/operation/HiveCommandOperation.java 134
/sql/hive-thriftserver/v2.3/src/main/java/org/apache/hive/service/cli/operation/MetadataOperation.java 56
/sql/hive-thriftserver/v2.3/src/main/java/org/apache/hive/service/cli/operation/Operation.java 290 301
/sql/hive-thriftserver/v2.3/src/main/java/org/apache/hive/service/cli/operation/OperationManager.java 228
/sql/hive-thriftserver/v2.3/src/main/java/org/apache/hive/service/cli/operation/SQLOperation.java 285 302
/sql/hive-thriftserver/v2.3/src/main/java/org/apache/hive/service/cli/session/HiveSession.java 180
/sql/hive-thriftserver/v2.3/src/main/java/org/apache/hive/service/cli/session/HiveSessionImpl.java 648 665 674 752
/sql/hive-thriftserver/v2.3/src/main/java/org/apache/hive/service/cli/session/HiveSessionImplwithUGI.java 103 109
/sql/hive-thriftserver/v2.3/src/main/java/org/apache/hive/service/cli/session/SessionManager.java 261 280
/sql/hive/src/main/java/org/apache/hadoop/hive/ql/io/orc/SparkOrcNewRecordReader.java 56 57
/streaming/src/main/java/org/apache/spark/streaming/util/WriteAheadLog.java 61
/streaming/src/test/java/org/apache/spark/streaming/JavaReceiverAPISuite.java 126 127
/streaming/src/test/java/org/apache/spark/streaming/JavaWriteAheadLogSuite.java 97

387 references in 145 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!