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 flatMap

Definitions

Type Member of File Line
method Java8RDDAPISuite /core/src/test/java/test/org/apache/spark/Java8RDDAPISuite.java 183
method JavaAPISuite /core/src/test/java/test/org/apache/spark/JavaAPISuite.java 767
class member RDD /python/pyspark/rdd.py 400
class member DStream /python/pyspark/streaming/dstream.py 88

4 declarations in 4 files.

References:

File Line
/core/src/test/java/test/org/apache/spark/Java8RDDAPISuite.java 183 186
/core/src/test/java/test/org/apache/spark/JavaAPISuite.java 767 770
/examples/src/main/java/org/apache/spark/examples/JavaWordCount.java 47
/examples/src/main/java/org/apache/spark/examples/sql/streaming/JavaStructuredKafkaWordCount.java 80
/examples/src/main/java/org/apache/spark/examples/sql/streaming/JavaStructuredKerberizedKafkaWordCount.java 117
/examples/src/main/java/org/apache/spark/examples/sql/streaming/JavaStructuredNetworkWordCount.java 63
/examples/src/main/java/org/apache/spark/examples/sql/streaming/JavaStructuredNetworkWordCountWindowed.java 87
/examples/src/main/java/org/apache/spark/examples/sql/streaming/JavaStructuredSessionization.java 85
/examples/src/main/java/org/apache/spark/examples/streaming/JavaCustomReceiver.java 73
/examples/src/main/java/org/apache/spark/examples/streaming/JavaDirectKafkaWordCount.java 89
/examples/src/main/java/org/apache/spark/examples/streaming/JavaDirectKerberizedKafkaWordCount.java 131
/examples/src/main/java/org/apache/spark/examples/streaming/JavaNetworkWordCount.java 65
/examples/src/main/java/org/apache/spark/examples/streaming/JavaRecoverableNetworkWordCount.java 131
/examples/src/main/java/org/apache/spark/examples/streaming/JavaSqlNetworkWordCount.java 67
/examples/src/main/java/org/apache/spark/examples/streaming/JavaStatefulNetworkWordCount.java 74
/examples/src/main/python/mllib/multi_label_metrics_example.py 45
/examples/src/main/python/pagerank.py 78
/examples/src/main/python/sort.py 36
/examples/src/main/python/streaming/hdfs_wordcount.py 44
/examples/src/main/python/streaming/network_wordcount.py 43
/examples/src/main/python/streaming/network_wordjoinsentiments.py 62
/examples/src/main/python/streaming/recoverable_network_wordcount.py 73
/examples/src/main/python/streaming/sql_network_wordcount.py 59
/examples/src/main/python/streaming/stateful_network_wordcount.py 54
/examples/src/main/python/wordcount.py 37
/external/kinesis-asl/src/main/java/org/apache/spark/examples/streaming/JavaKinesisWordCountASL.java 164
/external/kinesis-asl/src/main/python/examples/streaming/kinesis_wordcount_asl.py 78
/python/pyspark/rdd.py 400 2055
/python/pyspark/streaming/dstream.py 88 199
/python/pyspark/streaming/tests/test_dstream.py 51
/python/pyspark/tests/test_context.py 42 57 76
/python/pyspark/tests/test_rdd.py 482 483 749
/sql/core/src/test/java/test/org/apache/spark/sql/JavaDatasetSuite.java 131
/streaming/src/test/java/test/org/apache/spark/streaming/Java8APISuite.java 362
/streaming/src/test/java/test/org/apache/spark/streaming/JavaAPISuite.java 611

43 references in 35 files.