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 process

Definitions

Type Member of File Line
function /examples/src/main/python/streaming/sql_network_wordcount.py 62
variable /python/pyspark/shuffle.py 37
class member StreamingTests.test_streaming_foreach_with_basic_open_process_close.ForeachWriter /python/pyspark/sql/tests/test_streaming.py 371
class member StreamingTests.test_streaming_foreach_with_open_returning_false.ForeachWriter /python/pyspark/sql/tests/test_streaming.py 397
class member StreamingTests.test_streaming_foreach_without_open_method.ForeachWriter /python/pyspark/sql/tests/test_streaming.py 417
class member StreamingTests.test_streaming_foreach_without_close_method.ForeachWriter /python/pyspark/sql/tests/test_streaming.py 436
class member StreamingTests.test_streaming_foreach_without_open_and_close_methods.ForeachWriter /python/pyspark/sql/tests/test_streaming.py 448
class member StreamingTests.test_streaming_foreach_with_process_throwing_error.ForeachWriter /python/pyspark/sql/tests/test_streaming.py 462
variable StreamingTests.test_streaming_foreach_with_invalid_writers.WriterWithNonCallableProcess /python/pyspark/sql/tests/test_streaming.py 497
class member StreamingTests.test_streaming_foreach_with_invalid_writers.WriterWithNoParamProcess /python/pyspark/sql/tests/test_streaming.py 503
class member StreamingTests.test_streaming_foreach_with_invalid_writers.WithProcess /python/pyspark/sql/tests/test_streaming.py 510
function /python/pyspark/streaming/tests/test_dstream.py 515
function /python/pyspark/worker.py 593
method TSetIpAddressProcessor /sql/hive-thriftserver/v1.2/src/main/java/org/apache/hive/service/auth/TSetIpAddressProcessor.java 49
method TSetIpAddressProcessor /sql/hive-thriftserver/v2.3/src/main/java/org/apache/hive/service/auth/TSetIpAddressProcessor.java 49

15 declarations in 7 files.

References:

File Line
/common/network-common/src/main/java/org/apache/spark/network/util/JavaUtils.java 151 159 161 165 166
/dev/create-release/do-release-docker.sh 49
/docs/js/vendor/bootstrap.js 1369 1369 1373 1379 1410 1711 1713 1716
/docs/js/vendor/bootstrap.min.js 6 6 6 6 6 6
/examples/src/main/python/streaming/sql_network_wordcount.py 62 83
/python/docs/Makefile 72 77
/python/pyspark/shuffle.py 37 41 42 42 43 44 45 47
/python/pyspark/sql/streaming.py 1106
/python/pyspark/sql/tests/test_streaming.py 371 397 417 436 448 462 497 503 510
/python/pyspark/streaming/tests/test_dstream.py 515 518
/python/pyspark/worker.py 593 603 605
/sql/core/src/test/java/test/org/apache/spark/sql/streaming/JavaDataStreamReaderWriterSuite.java 82
/sql/hive-thriftserver/v1.2/src/main/java/org/apache/hive/service/auth/TSetIpAddressProcessor.java 49 53
/sql/hive-thriftserver/v2.3/src/main/java/org/apache/hive/service/auth/TSetIpAddressProcessor.java 49 53

52 references in 14 files.