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 collect

Definitions

Type Member of File Line
method DBIteratorSuite /common/kvstore/src/test/java/org/apache/spark/util/kvstore/DBIteratorSuite.java 497
function /python/pyspark/mllib/tests/test_streaming_algorithms.py 167
class member RDD /python/pyspark/rdd.py 881
class member DataFrame /python/pyspark/sql/dataframe.py 589

4 declarations in 4 files.

References:

File Line
/common/kvstore/src/main/java/org/apache/spark/util/kvstore/InMemoryStore.java 424
/common/kvstore/src/test/java/org/apache/spark/util/kvstore/DBIteratorSuite.java 456 497
/common/kvstore/src/test/java/org/apache/spark/util/kvstore/LevelDBSuite.java 274
/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/ExternalShuffleBlockResolver.java 385
/common/network-shuffle/src/test/java/org/apache/spark/network/shuffle/CleanupNonShuffleServiceServedFilesSuite.java 211
/core/src/test/java/org/apache/spark/util/SerializableConfigurationSuite.java 52
/core/src/test/java/test/org/apache/spark/Java8RDDAPISuite.java 109 174 177 179 226 229 243 264 295 301 317 348
/core/src/test/java/test/org/apache/spark/JavaAPISuite.java 164 203 210 243 269 276 315 324 401 428 459 478 759 761 763 809 812 825 839 863 872 927 947 965 985 1003 1027 1052 1075 1095 1106 1122 1141 1162 1181 1187 1200 1214 1257 1309 1323 1394
/examples/src/main/java/org/apache/spark/examples/JavaLogQuery.java 115
/examples/src/main/java/org/apache/spark/examples/JavaPageRank.java 115
/examples/src/main/java/org/apache/spark/examples/JavaWordCount.java 53
/examples/src/main/java/org/apache/spark/examples/mllib/JavaAssociationRulesExample.java 50
/examples/src/main/java/org/apache/spark/examples/mllib/JavaBinaryClassificationMetricsExample.java 65 69 73 76 80 87
/examples/src/main/java/org/apache/spark/examples/mllib/JavaPCAExample.java 64
/examples/src/main/java/org/apache/spark/examples/mllib/JavaPowerIterationClusteringExample.java 54
/examples/src/main/java/org/apache/spark/examples/mllib/JavaPrefixSpanExample.java 50
/examples/src/main/java/org/apache/spark/examples/mllib/JavaSVDExample.java 64
/examples/src/main/java/org/apache/spark/examples/mllib/JavaSimpleFPGrowth.java 49 55
/examples/src/main/java/org/apache/spark/examples/mllib/JavaStratifiedSamplingExample.java 60 61 65 66
/examples/src/main/java/org/apache/spark/examples/sql/JavaSparkSQLExample.java 233
/examples/src/main/java/org/apache/spark/examples/streaming/JavaRecoverableNetworkWordCount.java 150
/examples/src/main/python/als.py 92 100
/examples/src/main/python/avro_inputformat.py 77 87
/examples/src/main/python/kmeans.py 77
/examples/src/main/python/ml/cross_validator.py 95
/examples/src/main/python/ml/estimator_transformer_param_example.py 86
/examples/src/main/python/ml/pipeline_example.py 64
/examples/src/main/python/ml/word2vec_example.py 44
/examples/src/main/python/mllib/elementwise_product_example.py 44
/examples/src/main/python/mllib/fpgrowth_example.py 30
/examples/src/main/python/mllib/multi_class_metrics_example.py 57
/examples/src/main/python/mllib/multi_label_metrics_example.py 45
/examples/src/main/python/mllib/normalizer_example.py 45 49
/examples/src/main/python/mllib/pca_rowmatrix_example.py 42
/examples/src/main/python/mllib/standard_scaler_example.py 46 50
/examples/src/main/python/mllib/stratified_sampling_example.py 35
/examples/src/main/python/mllib/svd_example.py 42
/examples/src/main/python/mllib/tf_idf_example.py 50 54
/examples/src/main/python/pagerank.py 85
/examples/src/main/python/parquet_inputformat.py 65
/examples/src/main/python/sort.py 41
/examples/src/main/python/sql/basic.py 160
/examples/src/main/python/sql/hive.py 72
/examples/src/main/python/status_api_demo.py 53
/examples/src/main/python/streaming/recoverable_network_wordcount.py 90
/examples/src/main/python/wordcount.py 40
/external/kafka-0-10/src/test/java/org/apache/spark/streaming/kafka010/JavaDirectKafkaStreamSuite.java 159
/launcher/src/test/java/org/apache/spark/launcher/ChildProcAppHandleSuite.java 124 140 159 160
/mllib/src/test/java/org/apache/spark/ml/feature/JavaPCASuite.java 92
/mllib/src/test/java/org/apache/spark/ml/feature/JavaStopWordsRemoverSuite.java 53
/mllib/src/test/java/org/apache/spark/ml/regression/JavaLinearRegressionSuite.java 54
/mllib/src/test/java/org/apache/spark/mllib/feature/JavaTfIdfSuite.java 42 45 62 65
/mllib/src/test/java/org/apache/spark/mllib/fpm/JavaFPGrowthSuite.java 51 88
/mllib/src/test/java/org/apache/spark/mllib/fpm/JavaPrefixSpanSuite.java 47 79
/mllib/src/test/java/org/apache/spark/mllib/recommendation/JavaALSSuite.java 50
/mllib/src/test/java/org/apache/spark/mllib/regression/JavaIsotonicRegressionSuite.java 67
/python/pyspark/daemon.py 197
/python/pyspark/ml/tests/test_algorithms.py 157
/python/pyspark/ml/tests/test_base.py 48
/python/pyspark/ml/tests/test_feature.py 126 142 151 168 182 209 224 231 248 255 269
/python/pyspark/ml/tests/test_linalg.py 338 369
/python/pyspark/ml/tests/test_param.py 341
/python/pyspark/ml/tests/test_persistence.py 70 124
/python/pyspark/mllib/tests/test_algorithms.py 91 290 291
/python/pyspark/mllib/tests/test_linalg.py 429 478
/python/pyspark/mllib/tests/test_streaming_algorithms.py 138 167 168 174 281 310 416 449
/python/pyspark/mllib/tests/test_util.py 62 84
/python/pyspark/rdd.py 566 577 585 745 881 930 1003 1038 1673 2259 2374
/python/pyspark/shuffle.py 336 381 600 765
/python/pyspark/sql/dataframe.py 589 639
/python/pyspark/sql/pandas/conversion.py 138
/python/pyspark/sql/tests/test_arrow.py 229 229 237 238 244 245 316 317 359
/python/pyspark/sql/tests/test_column.py 98 99 100 139 141 143 145
/python/pyspark/sql/tests/test_context.py 79 80 81 82 83 83 91 92 93 94 95 95 104 105 106 107 108 108 127 149 167 176 186 196 199 202 205 224
/python/pyspark/sql/tests/test_dataframe.py 54 350 415 420 425 429 433 438 443 450 453 471 786 793 798 862
/python/pyspark/sql/tests/test_datasources.py 34 46 54 54 61 68 76 76 86 98 141
/python/pyspark/sql/tests/test_functions.py 38 43 47 50 53 56 63 78 98 118 120 122 124 126 128 130 132 134 136 138 143 146 152 153 156 157 182 191 204 233 270 273 276 279 285 289 303 304 310
/python/pyspark/sql/tests/test_group.py 27 28
/python/pyspark/sql/tests/test_pandas_cogrouped_map.py 142
/python/pyspark/sql/tests/test_pandas_grouped_map.py 459 461 472 501 512 542 585
/python/pyspark/sql/tests/test_pandas_map.py 67 68 81 82 91 116 117
/python/pyspark/sql/tests/test_pandas_udf.py 160 169 178 186 195 215 220 236 240
/python/pyspark/sql/tests/test_pandas_udf_grouped_agg.py 441 447 453 463 476 509
/python/pyspark/sql/tests/test_pandas_udf_scalar.py 106 114 140 140 151 166 176 176 185 185 194 194 203 203 212 212 221 221 230 230 239 239 248 248 262 262 286 286 295 295 304 304 313 313 333 335 339 344 364 415 415 429 438 450 465 479 479 501 504 523 538 538 545 545 561 578 578 628 677 700 723 752 756 762 793 795 818 818 819 819 833 834 848 873 898 898 954 955 956 957 958 976 987 988 989 990 991 1029 1030 1072 1091 1122 1122 1127 1127
/python/pyspark/sql/tests/test_readwriter.py 34 34 38 38 42 42 48 48 54 54 68 68 72 72 76 76 84 84 90 90 115 120 125 130 136 142
/python/pyspark/sql/tests/test_serde.py 127 133
/python/pyspark/sql/tests/test_session.py 44 85
/python/pyspark/sql/tests/test_streaming.py 336 536
/python/pyspark/sql/tests/test_types.py 41 41 87 97 187 192 210 301 308 315 324 327 329 421 734
/python/pyspark/sql/tests/test_udf.py 48 62 66 72 80 87 94 110 119 121 123 151 153 157 159 161 172 174 177 185 193 205 207 219 229 242 255 259 270 278 280 290 299 307 317 326 340 347 348 356 357 537 567 567 572 572 601 611 618
/python/pyspark/sql/tests/test_utils.py 44 46
/python/pyspark/streaming/tests/test_context.py 34 40 51 58 72 86
/python/pyspark/streaming/tests/test_dstream.py 98 384 575
/python/pyspark/streaming/tests/test_kinesis.py 57
/python/pyspark/testing/streamingutils.py 115 125 157
/python/pyspark/tests/test_broadcast.py 42 94 98
/python/pyspark/tests/test_conf.py 31
/python/pyspark/tests/test_context.py 48 51 69 82 86 157
/python/pyspark/tests/test_join.py 32 39 46 53
/python/pyspark/tests/test_pin_thread.py 106
/python/pyspark/tests/test_rdd.py 119 128 134 143 148 153 161 165 175 250 251 304 305 326 335 336 344 377 388 449 452 603 611 618 621 628 647 649 650 655 659 660 662 663 665 666 668 669 675 677 708 709 717 718 719 723 724 730 742 743 749
/python/pyspark/tests/test_rddbarrier.py 38
/python/pyspark/tests/test_readwrite.py 46 52 58 69 80 86 92 105 116 124 136 144 153 163 172 215 229 239 257 262 267 274 279 284 293 311 327 345 361 382 401 435 448 454 460 469 479
/python/pyspark/tests/test_serializers.py 154
/python/pyspark/tests/test_shuffle.py 169
/python/pyspark/tests/test_taskcontext.py 64 65 75 88 111 113 134 154 168 188 191 209 212 229 242 253 267 275 282
/python/pyspark/tests/test_worker.py 173 174 193
/resource-managers/kubernetes/integration-tests/tests/pyfiles.py 42
/resource-managers/kubernetes/integration-tests/tests/worker_memory_check.py 43
/sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/IdentifierImpl.java 59
/sql/core/src/test/java/test/org/apache/spark/sql/JavaApplySchemaSuite.java 139
/sql/core/src/test/java/test/org/apache/spark/sql/JavaBeanDeserializationSuite.java 187
/sql/core/src/test/java/test/org/apache/spark/sql/JavaColumnExpressionSuite.java 62 63 66 67 70 71
/sql/core/src/test/java/test/org/apache/spark/sql/JavaDatasetSuite.java 763 883
/sql/core/src/test/java/test/org/apache/spark/sql/JavaHigherOrderFunctionsSuite.java 69
/streaming/src/test/java/org/apache/spark/streaming/JavaMapWithStateSuite.java 153 157

675 references in 116 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!