Created
October 17, 2020 01:09
-
-
Save r-ryantm/808dbf970875c7ea37b17a47b766ad88 to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
/nix/store/ay5040ghqdrihwvl7ypcg817aj2hxjzn-python3.7-pyspark-3.0.1 | |
├── bin | |
│ ├── beeline | |
│ ├── beeline.cmd | |
│ ├── docker-image-tool.sh | |
│ ├── find-spark-home | |
│ ├── find-spark-home.cmd | |
│ ├── find_spark_home.py | |
│ ├── load-spark-env.cmd | |
│ ├── load-spark-env.sh | |
│ ├── pyspark | |
│ ├── pyspark2.cmd | |
│ ├── pyspark.cmd | |
│ ├── run-example | |
│ ├── run-example.cmd | |
│ ├── spark-class | |
│ ├── spark-class2.cmd | |
│ ├── spark-class.cmd | |
│ ├── sparkR | |
│ ├── sparkR2.cmd | |
│ ├── sparkR.cmd | |
│ ├── spark-shell | |
│ ├── spark-shell2.cmd | |
│ ├── spark-shell.cmd | |
│ ├── spark-sql | |
│ ├── spark-sql2.cmd | |
│ ├── spark-sql.cmd | |
│ ├── spark-submit | |
│ ├── spark-submit2.cmd | |
│ └── spark-submit.cmd | |
├── lib | |
│ └── python3.7 | |
│ └── site-packages | |
│ ├── pyspark | |
│ │ ├── accumulators.py | |
│ │ ├── bin | |
│ │ │ ├── beeline | |
│ │ │ ├── beeline.cmd | |
│ │ │ ├── docker-image-tool.sh | |
│ │ │ ├── find-spark-home | |
│ │ │ ├── find-spark-home.cmd | |
│ │ │ ├── load-spark-env.cmd | |
│ │ │ ├── load-spark-env.sh | |
│ │ │ ├── pyspark | |
│ │ │ ├── pyspark2.cmd | |
│ │ │ ├── pyspark.cmd | |
│ │ │ ├── run-example | |
│ │ │ ├── run-example.cmd | |
│ │ │ ├── spark-class | |
│ │ │ ├── spark-class2.cmd | |
│ │ │ ├── spark-class.cmd | |
│ │ │ ├── sparkR | |
│ │ │ ├── sparkR2.cmd | |
│ │ │ ├── sparkR.cmd | |
│ │ │ ├── spark-shell | |
│ │ │ ├── spark-shell2.cmd | |
│ │ │ ├── spark-shell.cmd | |
│ │ │ ├── spark-sql | |
│ │ │ ├── spark-sql2.cmd | |
│ │ │ ├── spark-sql.cmd | |
│ │ │ ├── spark-submit | |
│ │ │ ├── spark-submit2.cmd | |
│ │ │ └── spark-submit.cmd | |
│ │ ├── broadcast.py | |
│ │ ├── cloudpickle.py | |
│ │ ├── conf.py | |
│ │ ├── context.py | |
│ │ ├── daemon.py | |
│ │ ├── data | |
│ │ │ ├── graphx | |
│ │ │ │ ├── followers.txt | |
│ │ │ │ └── users.txt | |
│ │ │ ├── mllib | |
│ │ │ │ ├── als | |
│ │ │ │ │ ├── sample_movielens_ratings.txt | |
│ │ │ │ │ └── test.data | |
│ │ │ │ ├── gmm_data.txt | |
│ │ │ │ ├── images | |
│ │ │ │ │ ├── license.txt | |
│ │ │ │ │ ├── origin | |
│ │ │ │ │ │ ├── kittens | |
│ │ │ │ │ │ │ └── not-image.txt | |
│ │ │ │ │ │ └── license.txt | |
│ │ │ │ │ └── partitioned | |
│ │ │ │ │ └── cls=kittens | |
│ │ │ │ │ └── date=2018-01 | |
│ │ │ │ │ └── not-image.txt | |
│ │ │ │ ├── iris_libsvm.txt | |
│ │ │ │ ├── kmeans_data.txt | |
│ │ │ │ ├── pagerank_data.txt | |
│ │ │ │ ├── pic_data.txt | |
│ │ │ │ ├── ridge-data | |
│ │ │ │ │ └── lpsa.data | |
│ │ │ │ ├── sample_binary_classification_data.txt | |
│ │ │ │ ├── sample_fpgrowth.txt | |
│ │ │ │ ├── sample_isotonic_regression_libsvm_data.txt | |
│ │ │ │ ├── sample_kmeans_data.txt | |
│ │ │ │ ├── sample_lda_data.txt | |
│ │ │ │ ├── sample_lda_libsvm_data.txt | |
│ │ │ │ ├── sample_libsvm_data.txt | |
│ │ │ │ ├── sample_linear_regression_data.txt | |
│ │ │ │ ├── sample_movielens_data.txt | |
│ │ │ │ ├── sample_multiclass_classification_data.txt | |
│ │ │ │ ├── sample_svm_data.txt | |
│ │ │ │ └── streaming_kmeans_data_test.txt | |
│ │ │ └── streaming | |
│ │ │ └── AFINN-111.txt | |
│ │ ├── examples | |
│ │ │ └── src | |
│ │ │ └── main | |
│ │ │ └── python | |
│ │ │ ├── als.py | |
│ │ │ ├── avro_inputformat.py | |
│ │ │ ├── kmeans.py | |
│ │ │ ├── logistic_regression.py | |
│ │ │ ├── ml | |
│ │ │ │ ├── aft_survival_regression.py | |
│ │ │ │ ├── als_example.py | |
│ │ │ │ ├── binarizer_example.py | |
│ │ │ │ ├── bisecting_k_means_example.py | |
│ │ │ │ ├── bucketed_random_projection_lsh_example.py | |
│ │ │ │ ├── bucketizer_example.py | |
│ │ │ │ ├── chisq_selector_example.py | |
│ │ │ │ ├── chi_square_test_example.py | |
│ │ │ │ ├── correlation_example.py | |
│ │ │ │ ├── count_vectorizer_example.py | |
│ │ │ │ ├── cross_validator.py | |
│ │ │ │ ├── dataframe_example.py | |
│ │ │ │ ├── dct_example.py | |
│ │ │ │ ├── decision_tree_classification_example.py | |
│ │ │ │ ├── decision_tree_regression_example.py | |
│ │ │ │ ├── elementwise_product_example.py | |
│ │ │ │ ├── estimator_transformer_param_example.py | |
│ │ │ │ ├── feature_hasher_example.py | |
│ │ │ │ ├── fm_classifier_example.py | |
│ │ │ │ ├── fm_regressor_example.py | |
│ │ │ │ ├── fpgrowth_example.py | |
│ │ │ │ ├── gaussian_mixture_example.py | |
│ │ │ │ ├── generalized_linear_regression_example.py | |
│ │ │ │ ├── gradient_boosted_tree_classifier_example.py | |
│ │ │ │ ├── gradient_boosted_tree_regressor_example.py | |
│ │ │ │ ├── imputer_example.py | |
│ │ │ │ ├── index_to_string_example.py | |
│ │ │ │ ├── interaction_example.py | |
│ │ │ │ ├── isotonic_regression_example.py | |
│ │ │ │ ├── kmeans_example.py | |
│ │ │ │ ├── lda_example.py | |
│ │ │ │ ├── linear_regression_with_elastic_net.py | |
│ │ │ │ ├── linearsvc.py | |
│ │ │ │ ├── logistic_regression_summary_example.py | |
│ │ │ │ ├── logistic_regression_with_elastic_net.py | |
│ │ │ │ ├── max_abs_scaler_example.py | |
│ │ │ │ ├── min_hash_lsh_example.py | |
│ │ │ │ ├── min_max_scaler_example.py | |
│ │ │ │ ├── multiclass_logistic_regression_with_elastic_net.py | |
│ │ │ │ ├── multilayer_perceptron_classification.py | |
│ │ │ │ ├── naive_bayes_example.py | |
│ │ │ │ ├── n_gram_example.py | |
│ │ │ │ ├── normalizer_example.py | |
│ │ │ │ ├── onehot_encoder_example.py | |
│ │ │ │ ├── one_vs_rest_example.py | |
│ │ │ │ ├── pca_example.py | |
│ │ │ │ ├── pipeline_example.py | |
│ │ │ │ ├── polynomial_expansion_example.py | |
│ │ │ │ ├── power_iteration_clustering_example.py | |
│ │ │ │ ├── prefixspan_example.py | |
│ │ │ │ ├── __pycache__ | |
│ │ │ │ │ ├── aft_survival_regression.cpython-37.pyc | |
│ │ │ │ │ ├── als_example.cpython-37.pyc | |
│ │ │ │ │ ├── binarizer_example.cpython-37.pyc | |
│ │ │ │ │ ├── bisecting_k_means_example.cpython-37.pyc | |
│ │ │ │ │ ├── bucketed_random_projection_lsh_example.cpython-37.pyc | |
│ │ │ │ │ ├── bucketizer_example.cpython-37.pyc | |
│ │ │ │ │ ├── chisq_selector_example.cpython-37.pyc | |
│ │ │ │ │ ├── chi_square_test_example.cpython-37.pyc | |
│ │ │ │ │ ├── correlation_example.cpython-37.pyc | |
│ │ │ │ │ ├── count_vectorizer_example.cpython-37.pyc | |
│ │ │ │ │ ├── cross_validator.cpython-37.pyc | |
│ │ │ │ │ ├── dataframe_example.cpython-37.pyc | |
│ │ │ │ │ ├── dct_example.cpython-37.pyc | |
│ │ │ │ │ ├── decision_tree_classification_example.cpython-37.pyc | |
│ │ │ │ │ ├── decision_tree_regression_example.cpython-37.pyc | |
│ │ │ │ │ ├── elementwise_product_example.cpython-37.pyc | |
│ │ │ │ │ ├── estimator_transformer_param_example.cpython-37.pyc | |
│ │ │ │ │ ├── feature_hasher_example.cpython-37.pyc | |
│ │ │ │ │ ├── fm_classifier_example.cpython-37.pyc | |
│ │ │ │ │ ├── fm_regressor_example.cpython-37.pyc | |
│ │ │ │ │ ├── fpgrowth_example.cpython-37.pyc | |
│ │ │ │ │ ├── gaussian_mixture_example.cpython-37.pyc | |
│ │ │ │ │ ├── generalized_linear_regression_example.cpython-37.pyc | |
│ │ │ │ │ ├── gradient_boosted_tree_classifier_example.cpython-37.pyc | |
│ │ │ │ │ ├── gradient_boosted_tree_regressor_example.cpython-37.pyc | |
│ │ │ │ │ ├── imputer_example.cpython-37.pyc | |
│ │ │ │ │ ├── index_to_string_example.cpython-37.pyc | |
│ │ │ │ │ ├── interaction_example.cpython-37.pyc | |
│ │ │ │ │ ├── isotonic_regression_example.cpython-37.pyc | |
│ │ │ │ │ ├── kmeans_example.cpython-37.pyc | |
│ │ │ │ │ ├── lda_example.cpython-37.pyc | |
│ │ │ │ │ ├── linear_regression_with_elastic_net.cpython-37.pyc | |
│ │ │ │ │ ├── linearsvc.cpython-37.pyc | |
│ │ │ │ │ ├── logistic_regression_summary_example.cpython-37.pyc | |
│ │ │ │ │ ├── logistic_regression_with_elastic_net.cpython-37.pyc | |
│ │ │ │ │ ├── max_abs_scaler_example.cpython-37.pyc | |
│ │ │ │ │ ├── min_hash_lsh_example.cpython-37.pyc | |
│ │ │ │ │ ├── min_max_scaler_example.cpython-37.pyc | |
│ │ │ │ │ ├── multiclass_logistic_regression_with_elastic_net.cpython-37.pyc | |
│ │ │ │ │ ├── multilayer_perceptron_classification.cpython-37.pyc | |
│ │ │ │ │ ├── naive_bayes_example.cpython-37.pyc | |
│ │ │ │ │ ├── n_gram_example.cpython-37.pyc | |
│ │ │ │ │ ├── normalizer_example.cpython-37.pyc | |
│ │ │ │ │ ├── onehot_encoder_example.cpython-37.pyc | |
│ │ │ │ │ ├── one_vs_rest_example.cpython-37.pyc | |
│ │ │ │ │ ├── pca_example.cpython-37.pyc | |
│ │ │ │ │ ├── pipeline_example.cpython-37.pyc | |
│ │ │ │ │ ├── polynomial_expansion_example.cpython-37.pyc | |
│ │ │ │ │ ├── power_iteration_clustering_example.cpython-37.pyc | |
│ │ │ │ │ ├── prefixspan_example.cpython-37.pyc | |
│ │ │ │ │ ├── quantile_discretizer_example.cpython-37.pyc | |
│ │ │ │ │ ├── random_forest_classifier_example.cpython-37.pyc | |
│ │ │ │ │ ├── random_forest_regressor_example.cpython-37.pyc | |
│ │ │ │ │ ├── rformula_example.cpython-37.pyc | |
│ │ │ │ │ ├── robust_scaler_example.cpython-37.pyc | |
│ │ │ │ │ ├── sql_transformer.cpython-37.pyc | |
│ │ │ │ │ ├── standard_scaler_example.cpython-37.pyc | |
│ │ │ │ │ ├── stopwords_remover_example.cpython-37.pyc | |
│ │ │ │ │ ├── string_indexer_example.cpython-37.pyc | |
│ │ │ │ │ ├── summarizer_example.cpython-37.pyc | |
│ │ │ │ │ ├── tf_idf_example.cpython-37.pyc | |
│ │ │ │ │ ├── tokenizer_example.cpython-37.pyc | |
│ │ │ │ │ ├── train_validation_split.cpython-37.pyc | |
│ │ │ │ │ ├── vector_assembler_example.cpython-37.pyc | |
│ │ │ │ │ ├── vector_indexer_example.cpython-37.pyc | |
│ │ │ │ │ ├── vector_size_hint_example.cpython-37.pyc | |
│ │ │ │ │ ├── vector_slicer_example.cpython-37.pyc | |
│ │ │ │ │ └── word2vec_example.cpython-37.pyc | |
│ │ │ │ ├── quantile_discretizer_example.py | |
│ │ │ │ ├── random_forest_classifier_example.py | |
│ │ │ │ ├── random_forest_regressor_example.py | |
│ │ │ │ ├── rformula_example.py | |
│ │ │ │ ├── robust_scaler_example.py | |
│ │ │ │ ├── sql_transformer.py | |
│ │ │ │ ├── standard_scaler_example.py | |
│ │ │ │ ├── stopwords_remover_example.py | |
│ │ │ │ ├── string_indexer_example.py | |
│ │ │ │ ├── summarizer_example.py | |
│ │ │ │ ├── tf_idf_example.py | |
│ │ │ │ ├── tokenizer_example.py | |
│ │ │ │ ├── train_validation_split.py | |
│ │ │ │ ├── vector_assembler_example.py | |
│ │ │ │ ├── vector_indexer_example.py | |
│ │ │ │ ├── vector_size_hint_example.py | |
│ │ │ │ ├── vector_slicer_example.py | |
│ │ │ │ └── word2vec_example.py | |
│ │ │ ├── mllib | |
│ │ │ │ ├── binary_classification_metrics_example.py | |
│ │ │ │ ├── bisecting_k_means_example.py | |
│ │ │ │ ├── correlations_example.py | |
│ │ │ │ ├── correlations.py | |
│ │ │ │ ├── decision_tree_classification_example.py | |
│ │ │ │ ├── decision_tree_regression_example.py | |
│ │ │ │ ├── elementwise_product_example.py | |
│ │ │ │ ├── fpgrowth_example.py | |
│ │ │ │ ├── gaussian_mixture_example.py | |
│ │ │ │ ├── gaussian_mixture_model.py | |
│ │ │ │ ├── gradient_boosting_classification_example.py | |
│ │ │ │ ├── gradient_boosting_regression_example.py | |
│ │ │ │ ├── hypothesis_testing_example.py | |
│ │ │ │ ├── hypothesis_testing_kolmogorov_smirnov_test_example.py | |
│ │ │ │ ├── isotonic_regression_example.py | |
│ │ │ │ ├── kernel_density_estimation_example.py | |
│ │ │ │ ├── k_means_example.py | |
│ │ │ │ ├── kmeans.py | |
│ │ │ │ ├── latent_dirichlet_allocation_example.py | |
│ │ │ │ ├── linear_regression_with_sgd_example.py | |
│ │ │ │ ├── logistic_regression.py | |
│ │ │ │ ├── logistic_regression_with_lbfgs_example.py | |
│ │ │ │ ├── multi_class_metrics_example.py | |
│ │ │ │ ├── multi_label_metrics_example.py | |
│ │ │ │ ├── naive_bayes_example.py | |
│ │ │ │ ├── normalizer_example.py | |
│ │ │ │ ├── pca_rowmatrix_example.py | |
│ │ │ │ ├── power_iteration_clustering_example.py | |
│ │ │ │ ├── __pycache__ | |
│ │ │ │ │ ├── binary_classification_metrics_example.cpython-37.pyc | |
│ │ │ │ │ ├── bisecting_k_means_example.cpython-37.pyc | |
│ │ │ │ │ ├── correlations.cpython-37.pyc | |
│ │ │ │ │ ├── correlations_example.cpython-37.pyc | |
│ │ │ │ │ ├── decision_tree_classification_example.cpython-37.pyc | |
│ │ │ │ │ ├── decision_tree_regression_example.cpython-37.pyc | |
│ │ │ │ │ ├── elementwise_product_example.cpython-37.pyc | |
│ │ │ │ │ ├── fpgrowth_example.cpython-37.pyc | |
│ │ │ │ │ ├── gaussian_mixture_example.cpython-37.pyc | |
│ │ │ │ │ ├── gaussian_mixture_model.cpython-37.pyc | |
│ │ │ │ │ ├── gradient_boosting_classification_example.cpython-37.pyc | |
│ │ │ │ │ ├── gradient_boosting_regression_example.cpython-37.pyc | |
│ │ │ │ │ ├── hypothesis_testing_example.cpython-37.pyc | |
│ │ │ │ │ ├── hypothesis_testing_kolmogorov_smirnov_test_example.cpython-37.pyc | |
│ │ │ │ │ ├── isotonic_regression_example.cpython-37.pyc | |
│ │ │ │ │ ├── kernel_density_estimation_example.cpython-37.pyc | |
│ │ │ │ │ ├── kmeans.cpython-37.pyc | |
│ │ │ │ │ ├── k_means_example.cpython-37.pyc | |
│ │ │ │ │ ├── latent_dirichlet_allocation_example.cpython-37.pyc | |
│ │ │ │ │ ├── linear_regression_with_sgd_example.cpython-37.pyc | |
│ │ │ │ │ ├── logistic_regression.cpython-37.pyc | |
│ │ │ │ │ ├── logistic_regression_with_lbfgs_example.cpython-37.pyc | |
│ │ │ │ │ ├── multi_class_metrics_example.cpython-37.pyc | |
│ │ │ │ │ ├── multi_label_metrics_example.cpython-37.pyc | |
│ │ │ │ │ ├── naive_bayes_example.cpython-37.pyc | |
│ │ │ │ │ ├── normalizer_example.cpython-37.pyc | |
│ │ │ │ │ ├── pca_rowmatrix_example.cpython-37.pyc | |
│ │ │ │ │ ├── power_iteration_clustering_example.cpython-37.pyc | |
│ │ │ │ │ ├── random_forest_classification_example.cpython-37.pyc | |
│ │ │ │ │ ├── random_forest_regression_example.cpython-37.pyc | |
│ │ │ │ │ ├── random_rdd_generation.cpython-37.pyc | |
│ │ │ │ │ ├── ranking_metrics_example.cpython-37.pyc | |
│ │ │ │ │ ├── recommendation_example.cpython-37.pyc | |
│ │ │ │ │ ├── regression_metrics_example.cpython-37.pyc | |
│ │ │ │ │ ├── sampled_rdds.cpython-37.pyc | |
│ │ │ │ │ ├── standard_scaler_example.cpython-37.pyc | |
│ │ │ │ │ ├── stratified_sampling_example.cpython-37.pyc | |
│ │ │ │ │ ├── streaming_k_means_example.cpython-37.pyc | |
│ │ │ │ │ ├── streaming_linear_regression_example.cpython-37.pyc | |
│ │ │ │ │ ├── summary_statistics_example.cpython-37.pyc | |
│ │ │ │ │ ├── svd_example.cpython-37.pyc | |
│ │ │ │ │ ├── svm_with_sgd_example.cpython-37.pyc | |
│ │ │ │ │ ├── tf_idf_example.cpython-37.pyc | |
│ │ │ │ │ ├── word2vec.cpython-37.pyc | |
│ │ │ │ │ └── word2vec_example.cpython-37.pyc | |
│ │ │ │ ├── random_forest_classification_example.py | |
│ │ │ │ ├── random_forest_regression_example.py | |
│ │ │ │ ├── random_rdd_generation.py | |
│ │ │ │ ├── ranking_metrics_example.py | |
│ │ │ │ ├── recommendation_example.py | |
│ │ │ │ ├── regression_metrics_example.py | |
│ │ │ │ ├── sampled_rdds.py | |
│ │ │ │ ├── standard_scaler_example.py | |
│ │ │ │ ├── stratified_sampling_example.py | |
│ │ │ │ ├── streaming_k_means_example.py | |
│ │ │ │ ├── streaming_linear_regression_example.py | |
│ │ │ │ ├── summary_statistics_example.py | |
│ │ │ │ ├── svd_example.py | |
│ │ │ │ ├── svm_with_sgd_example.py | |
│ │ │ │ ├── tf_idf_example.py | |
│ │ │ │ ├── word2vec_example.py | |
│ │ │ │ └── word2vec.py | |
│ │ │ ├── pagerank.py | |
│ │ │ ├── parquet_inputformat.py | |
│ │ │ ├── pi.py | |
│ │ │ ├── __pycache__ | |
│ │ │ │ ├── als.cpython-37.pyc | |
│ │ │ │ ├── avro_inputformat.cpython-37.pyc | |
│ │ │ │ ├── kmeans.cpython-37.pyc | |
│ │ │ │ ├── logistic_regression.cpython-37.pyc | |
│ │ │ │ ├── pagerank.cpython-37.pyc | |
│ │ │ │ ├── parquet_inputformat.cpython-37.pyc | |
│ │ │ │ ├── pi.cpython-37.pyc | |
│ │ │ │ ├── sort.cpython-37.pyc | |
│ │ │ │ ├── status_api_demo.cpython-37.pyc | |
│ │ │ │ ├── transitive_closure.cpython-37.pyc | |
│ │ │ │ └── wordcount.cpython-37.pyc | |
│ │ │ ├── sort.py | |
│ │ │ ├── sql | |
│ │ │ │ ├── arrow.py | |
│ │ │ │ ├── basic.py | |
│ │ │ │ ├── datasource.py | |
│ │ │ │ ├── hive.py | |
│ │ │ │ ├── __pycache__ | |
│ │ │ │ │ ├── arrow.cpython-37.pyc | |
│ │ │ │ │ ├── basic.cpython-37.pyc | |
│ │ │ │ │ ├── datasource.cpython-37.pyc | |
│ │ │ │ │ └── hive.cpython-37.pyc | |
│ │ │ │ └── streaming | |
│ │ │ │ ├── __pycache__ | |
│ │ │ │ │ ├── structured_kafka_wordcount.cpython-37.pyc | |
│ │ │ │ │ ├── structured_network_wordcount.cpython-37.pyc | |
│ │ │ │ │ └── structured_network_wordcount_windowed.cpython-37.pyc | |
│ │ │ │ ├── structured_kafka_wordcount.py | |
│ │ │ │ ├── structured_network_wordcount.py | |
│ │ │ │ └── structured_network_wordcount_windowed.py | |
│ │ │ ├── status_api_demo.py | |
│ │ │ ├── streaming | |
│ │ │ │ ├── hdfs_wordcount.py | |
│ │ │ │ ├── network_wordcount.py | |
│ │ │ │ ├── network_wordjoinsentiments.py | |
│ │ │ │ ├── __pycache__ | |
│ │ │ │ │ ├── hdfs_wordcount.cpython-37.pyc | |
│ │ │ │ │ ├── network_wordcount.cpython-37.pyc | |
│ │ │ │ │ ├── network_wordjoinsentiments.cpython-37.pyc | |
│ │ │ │ │ ├── queue_stream.cpython-37.pyc | |
│ │ │ │ │ ├── recoverable_network_wordcount.cpython-37.pyc | |
│ │ │ │ │ ├── sql_network_wordcount.cpython-37.pyc | |
│ │ │ │ │ └── stateful_network_wordcount.cpython-37.pyc | |
│ │ │ │ ├── queue_stream.py | |
│ │ │ │ ├── recoverable_network_wordcount.py | |
│ │ │ │ ├── sql_network_wordcount.py | |
│ │ │ │ └── stateful_network_wordcount.py | |
│ │ │ ├── transitive_closure.py | |
│ │ │ └── wordcount.py | |
│ │ ├── files.py | |
│ │ ├── find_spark_home.py | |
│ │ ├── _globals.py | |
│ │ ├── heapq3.py | |
│ │ ├── __init__.py | |
│ │ ├── jars | |
│ │ │ ├── activation-1.1.1.jar | |
│ │ │ ├── aircompressor-0.10.jar | |
│ │ │ ├── algebra_2.12-2.0.0-M2.jar | |
│ │ │ ├── antlr4-runtime-4.7.1.jar | |
│ │ │ ├── antlr-runtime-3.5.2.jar | |
│ │ │ ├── aopalliance-1.0.jar | |
│ │ │ ├── aopalliance-repackaged-2.6.1.jar | |
│ │ │ ├── apacheds-i18n-2.0.0-M15.jar | |
│ │ │ ├── apacheds-kerberos-codec-2.0.0-M15.jar | |
│ │ │ ├── api-asn1-api-1.0.0-M20.jar | |
│ │ │ ├── api-util-1.0.0-M20.jar | |
│ │ │ ├── arpack_combined_all-0.1.jar | |
│ │ │ ├── arrow-format-0.15.1.jar | |
│ │ │ ├── arrow-memory-0.15.1.jar | |
│ │ │ ├── arrow-vector-0.15.1.jar | |
│ │ │ ├── audience-annotations-0.5.0.jar | |
│ │ │ ├── automaton-1.11-8.jar | |
│ │ │ ├── avro-1.8.2.jar | |
│ │ │ ├── avro-ipc-1.8.2.jar | |
│ │ │ ├── avro-mapred-1.8.2-hadoop2.jar | |
│ │ │ ├── bonecp-0.8.0.RELEASE.jar | |
│ │ │ ├── breeze_2.12-1.0.jar | |
│ │ │ ├── breeze-macros_2.12-1.0.jar | |
│ │ │ ├── cats-kernel_2.12-2.0.0-M4.jar | |
│ │ │ ├── chill_2.12-0.9.5.jar | |
│ │ │ ├── chill-java-0.9.5.jar | |
│ │ │ ├── commons-beanutils-1.9.4.jar | |
│ │ │ ├── commons-cli-1.2.jar | |
│ │ │ ├── commons-codec-1.10.jar | |
│ │ │ ├── commons-collections-3.2.2.jar | |
│ │ │ ├── commons-compiler-3.0.16.jar | |
│ │ │ ├── commons-compress-1.8.1.jar | |
│ │ │ ├── commons-configuration-1.6.jar | |
│ │ │ ├── commons-crypto-1.0.0.jar | |
│ │ │ ├── commons-dbcp-1.4.jar | |
│ │ │ ├── commons-digester-1.8.jar | |
│ │ │ ├── commons-httpclient-3.1.jar | |
│ │ │ ├── commons-io-2.4.jar | |
│ │ │ ├── commons-lang-2.6.jar | |
│ │ │ ├── commons-lang3-3.9.jar | |
│ │ │ ├── commons-logging-1.1.3.jar | |
│ │ │ ├── commons-math3-3.4.1.jar | |
│ │ │ ├── commons-net-3.1.jar | |
│ │ │ ├── commons-pool-1.5.4.jar | |
│ │ │ ├── commons-text-1.6.jar | |
│ │ │ ├── compress-lzf-1.0.3.jar | |
│ │ │ ├── core-1.1.2.jar | |
│ │ │ ├── curator-client-2.7.1.jar | |
│ │ │ ├── curator-framework-2.7.1.jar | |
│ │ │ ├── curator-recipes-2.7.1.jar | |
│ │ │ ├── datanucleus-api-jdo-4.2.4.jar | |
│ │ │ ├── datanucleus-core-4.1.17.jar | |
│ │ │ ├── datanucleus-rdbms-4.1.19.jar | |
│ │ │ ├── derby-10.12.1.1.jar | |
│ │ │ ├── dropwizard-metrics-hadoop-metrics2-reporter-0.1.2.jar | |
│ │ │ ├── flatbuffers-java-1.9.0.jar | |
│ │ │ ├── generex-1.0.2.jar | |
│ │ │ ├── gson-2.2.4.jar | |
│ │ │ ├── guava-14.0.1.jar | |
│ │ │ ├── guice-3.0.jar | |
│ │ │ ├── guice-servlet-3.0.jar | |
│ │ │ ├── hadoop-annotations-2.7.4.jar | |
│ │ │ ├── hadoop-auth-2.7.4.jar | |
│ │ │ ├── hadoop-client-2.7.4.jar | |
│ │ │ ├── hadoop-common-2.7.4.jar | |
│ │ │ ├── hadoop-hdfs-2.7.4.jar | |
│ │ │ ├── hadoop-mapreduce-client-app-2.7.4.jar | |
│ │ │ ├── hadoop-mapreduce-client-common-2.7.4.jar | |
│ │ │ ├── hadoop-mapreduce-client-core-2.7.4.jar | |
│ │ │ ├── hadoop-mapreduce-client-jobclient-2.7.4.jar | |
│ │ │ ├── hadoop-mapreduce-client-shuffle-2.7.4.jar | |
│ │ │ ├── hadoop-yarn-api-2.7.4.jar | |
│ │ │ ├── hadoop-yarn-client-2.7.4.jar | |
│ │ │ ├── hadoop-yarn-common-2.7.4.jar | |
│ │ │ ├── hadoop-yarn-server-common-2.7.4.jar | |
│ │ │ ├── hadoop-yarn-server-web-proxy-2.7.4.jar | |
│ │ │ ├── HikariCP-2.5.1.jar | |
│ │ │ ├── hive-beeline-2.3.7.jar | |
│ │ │ ├── hive-cli-2.3.7.jar | |
│ │ │ ├── hive-common-2.3.7.jar | |
│ │ │ ├── hive-exec-2.3.7-core.jar | |
│ │ │ ├── hive-jdbc-2.3.7.jar | |
│ │ │ ├── hive-llap-common-2.3.7.jar | |
│ │ │ ├── hive-metastore-2.3.7.jar | |
│ │ │ ├── hive-serde-2.3.7.jar | |
│ │ │ ├── hive-shims-0.23-2.3.7.jar | |
│ │ │ ├── hive-shims-2.3.7.jar | |
│ │ │ ├── hive-shims-common-2.3.7.jar | |
│ │ │ ├── hive-shims-scheduler-2.3.7.jar | |
│ │ │ ├── hive-storage-api-2.7.1.jar | |
│ │ │ ├── hive-vector-code-gen-2.3.7.jar | |
│ │ │ ├── hk2-api-2.6.1.jar | |
│ │ │ ├── hk2-locator-2.6.1.jar | |
│ │ │ ├── hk2-utils-2.6.1.jar | |
│ │ │ ├── htrace-core-3.1.0-incubating.jar | |
│ │ │ ├── httpclient-4.5.6.jar | |
│ │ │ ├── httpcore-4.4.12.jar | |
│ │ │ ├── istack-commons-runtime-3.0.8.jar | |
│ │ │ ├── ivy-2.4.0.jar | |
│ │ │ ├── jackson-annotations-2.10.0.jar | |
│ │ │ ├── jackson-core-2.10.0.jar | |
│ │ │ ├── jackson-core-asl-1.9.13.jar | |
│ │ │ ├── jackson-databind-2.10.0.jar | |
│ │ │ ├── jackson-dataformat-yaml-2.10.0.jar | |
│ │ │ ├── jackson-datatype-jsr310-2.10.3.jar | |
│ │ │ ├── jackson-jaxrs-1.9.13.jar | |
│ │ │ ├── jackson-mapper-asl-1.9.13.jar | |
│ │ │ ├── jackson-module-jaxb-annotations-2.10.0.jar | |
│ │ │ ├── jackson-module-paranamer-2.10.0.jar | |
│ │ │ ├── jackson-module-scala_2.12-2.10.0.jar | |
│ │ │ ├── jackson-xc-1.9.13.jar | |
│ │ │ ├── jakarta.activation-api-1.2.1.jar | |
│ │ │ ├── jakarta.annotation-api-1.3.5.jar | |
│ │ │ ├── jakarta.inject-2.6.1.jar | |
│ │ │ ├── jakarta.validation-api-2.0.2.jar | |
│ │ │ ├── jakarta.ws.rs-api-2.1.6.jar | |
│ │ │ ├── jakarta.xml.bind-api-2.3.2.jar | |
│ │ │ ├── janino-3.0.16.jar | |
│ │ │ ├── javassist-3.25.0-GA.jar | |
│ │ │ ├── javax.inject-1.jar | |
│ │ │ ├── javax.jdo-3.2.0-m3.jar | |
│ │ │ ├── javax.servlet-api-3.1.0.jar | |
│ │ │ ├── javolution-5.5.1.jar | |
│ │ │ ├── jaxb-api-2.2.2.jar | |
│ │ │ ├── jaxb-runtime-2.3.2.jar | |
│ │ │ ├── jcl-over-slf4j-1.7.30.jar | |
│ │ │ ├── jdo-api-3.0.1.jar | |
│ │ │ ├── jersey-client-2.30.jar | |
│ │ │ ├── jersey-common-2.30.jar | |
│ │ │ ├── jersey-container-servlet-2.30.jar | |
│ │ │ ├── jersey-container-servlet-core-2.30.jar | |
│ │ │ ├── jersey-hk2-2.30.jar | |
│ │ │ ├── jersey-media-jaxb-2.30.jar | |
│ │ │ ├── jersey-server-2.30.jar | |
│ │ │ ├── jetty-6.1.26.jar | |
│ │ │ ├── jetty-sslengine-6.1.26.jar | |
│ │ │ ├── jetty-util-6.1.26.jar | |
│ │ │ ├── JLargeArrays-1.5.jar | |
│ │ │ ├── jline-2.14.6.jar | |
│ │ │ ├── joda-time-2.10.5.jar | |
│ │ │ ├── jodd-core-3.5.2.jar | |
│ │ │ ├── jpam-1.1.jar | |
│ │ │ ├── json-1.8.jar | |
│ │ │ ├── json4s-ast_2.12-3.6.6.jar | |
│ │ │ ├── json4s-core_2.12-3.6.6.jar | |
│ │ │ ├── json4s-jackson_2.12-3.6.6.jar | |
│ │ │ ├── json4s-scalap_2.12-3.6.6.jar | |
│ │ │ ├── jsp-api-2.1.jar | |
│ │ │ ├── jsr305-3.0.0.jar | |
│ │ │ ├── jta-1.1.jar | |
│ │ │ ├── JTransforms-3.1.jar | |
│ │ │ ├── jul-to-slf4j-1.7.30.jar | |
│ │ │ ├── kryo-shaded-4.0.2.jar | |
│ │ │ ├── kubernetes-client-4.9.2.jar | |
│ │ │ ├── kubernetes-model-4.9.2.jar | |
│ │ │ ├── kubernetes-model-common-4.9.2.jar | |
│ │ │ ├── leveldbjni-all-1.8.jar | |
│ │ │ ├── libfb303-0.9.3.jar | |
│ │ │ ├── libthrift-0.12.0.jar | |
│ │ │ ├── log4j-1.2.17.jar | |
│ │ │ ├── logging-interceptor-3.12.6.jar | |
│ │ │ ├── lz4-java-1.7.1.jar | |
│ │ │ ├── machinist_2.12-0.6.8.jar | |
│ │ │ ├── macro-compat_2.12-1.1.1.jar | |
│ │ │ ├── mesos-1.4.0-shaded-protobuf.jar | |
│ │ │ ├── metrics-core-4.1.1.jar | |
│ │ │ ├── metrics-graphite-4.1.1.jar | |
│ │ │ ├── metrics-jmx-4.1.1.jar | |
│ │ │ ├── metrics-json-4.1.1.jar | |
│ │ │ ├── metrics-jvm-4.1.1.jar | |
│ │ │ ├── minlog-1.3.0.jar | |
│ │ │ ├── netty-all-4.1.47.Final.jar | |
│ │ │ ├── objenesis-2.5.1.jar | |
│ │ │ ├── okhttp-3.12.6.jar | |
│ │ │ ├── okio-1.15.0.jar | |
│ │ │ ├── opencsv-2.3.jar | |
│ │ │ ├── orc-core-1.5.10.jar | |
│ │ │ ├── orc-mapreduce-1.5.10.jar | |
│ │ │ ├── orc-shims-1.5.10.jar | |
│ │ │ ├── oro-2.0.8.jar | |
│ │ │ ├── osgi-resource-locator-1.0.3.jar | |
│ │ │ ├── paranamer-2.8.jar | |
│ │ │ ├── parquet-column-1.10.1.jar | |
│ │ │ ├── parquet-common-1.10.1.jar | |
│ │ │ ├── parquet-encoding-1.10.1.jar | |
│ │ │ ├── parquet-format-2.4.0.jar | |
│ │ │ ├── parquet-hadoop-1.10.1.jar | |
│ │ │ ├── parquet-jackson-1.10.1.jar | |
│ │ │ ├── protobuf-java-2.5.0.jar | |
│ │ │ ├── py4j-0.10.9.jar | |
│ │ │ ├── pyrolite-4.30.jar | |
│ │ │ ├── RoaringBitmap-0.7.45.jar | |
│ │ │ ├── scala-collection-compat_2.12-2.1.1.jar | |
│ │ │ ├── scala-compiler-2.12.10.jar | |
│ │ │ ├── scala-library-2.12.10.jar | |
│ │ │ ├── scala-parser-combinators_2.12-1.1.2.jar | |
│ │ │ ├── scala-reflect-2.12.10.jar | |
│ │ │ ├── scala-xml_2.12-1.2.0.jar | |
│ │ │ ├── shapeless_2.12-2.3.3.jar | |
│ │ │ ├── shims-0.7.45.jar | |
│ │ │ ├── slf4j-api-1.7.30.jar | |
│ │ │ ├── slf4j-log4j12-1.7.30.jar | |
│ │ │ ├── snakeyaml-1.24.jar | |
│ │ │ ├── snappy-java-1.1.7.5.jar | |
│ │ │ ├── spark-catalyst_2.12-3.0.1.jar | |
│ │ │ ├── spark-core_2.12-3.0.1.jar | |
│ │ │ ├── spark-graphx_2.12-3.0.1.jar | |
│ │ │ ├── spark-hive_2.12-3.0.1.jar | |
│ │ │ ├── spark-hive-thriftserver_2.12-3.0.1.jar | |
│ │ │ ├── spark-kubernetes_2.12-3.0.1.jar | |
│ │ │ ├── spark-kvstore_2.12-3.0.1.jar | |
│ │ │ ├── spark-launcher_2.12-3.0.1.jar | |
│ │ │ ├── spark-mesos_2.12-3.0.1.jar | |
│ │ │ ├── spark-mllib_2.12-3.0.1.jar | |
│ │ │ ├── spark-mllib-local_2.12-3.0.1.jar | |
│ │ │ ├── spark-network-common_2.12-3.0.1.jar | |
│ │ │ ├── spark-network-shuffle_2.12-3.0.1.jar | |
│ │ │ ├── spark-repl_2.12-3.0.1.jar | |
│ │ │ ├── spark-sketch_2.12-3.0.1.jar | |
│ │ │ ├── spark-sql_2.12-3.0.1.jar | |
│ │ │ ├── spark-streaming_2.12-3.0.1.jar | |
│ │ │ ├── spark-tags_2.12-3.0.1.jar | |
│ │ │ ├── spark-tags_2.12-3.0.1-tests.jar | |
│ │ │ ├── spark-unsafe_2.12-3.0.1.jar | |
│ │ │ ├── spark-yarn_2.12-3.0.1.jar | |
│ │ │ ├── spire_2.12-0.17.0-M1.jar | |
│ │ │ ├── spire-macros_2.12-0.17.0-M1.jar | |
│ │ │ ├── spire-platform_2.12-0.17.0-M1.jar | |
│ │ │ ├── spire-util_2.12-0.17.0-M1.jar | |
│ │ │ ├── ST4-4.0.4.jar | |
│ │ │ ├── stax-api-1.0.1.jar | |
│ │ │ ├── stax-api-1.0-2.jar | |
│ │ │ ├── stream-2.9.6.jar | |
│ │ │ ├── super-csv-2.2.0.jar | |
│ │ │ ├── threeten-extra-1.5.0.jar | |
│ │ │ ├── transaction-api-1.1.jar | |
│ │ │ ├── univocity-parsers-2.9.0.jar | |
│ │ │ ├── velocity-1.5.jar | |
│ │ │ ├── xbean-asm7-shaded-4.15.jar | |
│ │ │ ├── xercesImpl-2.12.0.jar | |
│ │ │ ├── xml-apis-1.4.01.jar | |
│ │ │ ├── xmlenc-0.52.jar | |
│ │ │ ├── xz-1.5.jar | |
│ │ │ ├── zjsonpatch-0.3.0.jar | |
│ │ │ ├── zookeeper-3.4.14.jar | |
│ │ │ └── zstd-jni-1.4.4-3.jar | |
│ │ ├── java_gateway.py | |
│ │ ├── join.py | |
│ │ ├── licenses | |
│ │ │ ├── LICENSE-AnchorJS.txt | |
│ │ │ ├── LICENSE-bootstrap.txt | |
│ │ │ ├── LICENSE-CC0.txt | |
│ │ │ ├── LICENSE-cloudpickle.txt | |
│ │ │ ├── LICENSE-copybutton.txt | |
│ │ │ ├── LICENSE-d3.min.js.txt | |
│ │ │ ├── LICENSE-dagre-d3.txt | |
│ │ │ ├── LICENSE-datatables.txt | |
│ │ │ ├── LICENSE-graphlib-dot.txt | |
│ │ │ ├── LICENSE-heapq.txt | |
│ │ │ ├── LICENSE-join.txt | |
│ │ │ ├── LICENSE-jquery.txt | |
│ │ │ ├── LICENSE-json-formatter.txt | |
│ │ │ ├── LICENSE-matchMedia-polyfill.txt | |
│ │ │ ├── LICENSE-modernizr.txt | |
│ │ │ ├── LICENSE-mustache.txt | |
│ │ │ ├── LICENSE-py4j.txt | |
│ │ │ ├── LICENSE-respond.txt | |
│ │ │ ├── LICENSE-sbt-launch-lib.txt | |
│ │ │ ├── LICENSE-sorttable.js.txt | |
│ │ │ └── LICENSE-vis-timeline.txt | |
│ │ ├── ml | |
│ │ │ ├── base.py | |
│ │ │ ├── classification.py | |
│ │ │ ├── clustering.py | |
│ │ │ ├── common.py | |
│ │ │ ├── evaluation.py | |
│ │ │ ├── feature.py | |
│ │ │ ├── fpm.py | |
│ │ │ ├── functions.py | |
│ │ │ ├── image.py | |
│ │ │ ├── __init__.py | |
│ │ │ ├── linalg | |
│ │ │ │ ├── __init__.py | |
│ │ │ │ └── __pycache__ | |
│ │ │ │ └── __init__.cpython-37.pyc | |
│ │ │ ├── param | |
│ │ │ │ ├── __init__.py | |
│ │ │ │ ├── __pycache__ | |
│ │ │ │ │ ├── __init__.cpython-37.pyc | |
│ │ │ │ │ ├── shared.cpython-37.pyc | |
│ │ │ │ │ └── _shared_params_code_gen.cpython-37.pyc | |
│ │ │ │ ├── _shared_params_code_gen.py | |
│ │ │ │ └── shared.py | |
│ │ │ ├── pipeline.py | |
│ │ │ ├── __pycache__ | |
│ │ │ │ ├── base.cpython-37.pyc | |
│ │ │ │ ├── classification.cpython-37.pyc | |
│ │ │ │ ├── clustering.cpython-37.pyc | |
│ │ │ │ ├── common.cpython-37.pyc | |
│ │ │ │ ├── evaluation.cpython-37.pyc | |
│ │ │ │ ├── feature.cpython-37.pyc | |
│ │ │ │ ├── fpm.cpython-37.pyc | |
│ │ │ │ ├── functions.cpython-37.pyc | |
│ │ │ │ ├── image.cpython-37.pyc | |
│ │ │ │ ├── __init__.cpython-37.pyc | |
│ │ │ │ ├── pipeline.cpython-37.pyc | |
│ │ │ │ ├── recommendation.cpython-37.pyc | |
│ │ │ │ ├── regression.cpython-37.pyc | |
│ │ │ │ ├── stat.cpython-37.pyc | |
│ │ │ │ ├── tree.cpython-37.pyc | |
│ │ │ │ ├── tuning.cpython-37.pyc | |
│ │ │ │ ├── util.cpython-37.pyc | |
│ │ │ │ └── wrapper.cpython-37.pyc | |
│ │ │ ├── recommendation.py | |
│ │ │ ├── regression.py | |
│ │ │ ├── stat.py | |
│ │ │ ├── tree.py | |
│ │ │ ├── tuning.py | |
│ │ │ ├── util.py | |
│ │ │ └── wrapper.py | |
│ │ ├── mllib | |
│ │ │ ├── classification.py | |
│ │ │ ├── clustering.py | |
│ │ │ ├── common.py | |
│ │ │ ├── evaluation.py | |
│ │ │ ├── feature.py | |
│ │ │ ├── fpm.py | |
│ │ │ ├── __init__.py | |
│ │ │ ├── linalg | |
│ │ │ │ ├── distributed.py | |
│ │ │ │ ├── __init__.py | |
│ │ │ │ └── __pycache__ | |
│ │ │ │ ├── distributed.cpython-37.pyc | |
│ │ │ │ └── __init__.cpython-37.pyc | |
│ │ │ ├── __pycache__ | |
│ │ │ │ ├── classification.cpython-37.pyc | |
│ │ │ │ ├── clustering.cpython-37.pyc | |
│ │ │ │ ├── common.cpython-37.pyc | |
│ │ │ │ ├── evaluation.cpython-37.pyc | |
│ │ │ │ ├── feature.cpython-37.pyc | |
│ │ │ │ ├── fpm.cpython-37.pyc | |
│ │ │ │ ├── __init__.cpython-37.pyc | |
│ │ │ │ ├── random.cpython-37.pyc | |
│ │ │ │ ├── recommendation.cpython-37.pyc | |
│ │ │ │ ├── regression.cpython-37.pyc | |
│ │ │ │ ├── tree.cpython-37.pyc | |
│ │ │ │ └── util.cpython-37.pyc | |
│ │ │ ├── random.py | |
│ │ │ ├── recommendation.py | |
│ │ │ ├── regression.py | |
│ │ │ ├── stat | |
│ │ │ │ ├── distribution.py | |
│ │ │ │ ├── __init__.py | |
│ │ │ │ ├── KernelDensity.py | |
│ │ │ │ ├── __pycache__ | |
│ │ │ │ │ ├── distribution.cpython-37.pyc | |
│ │ │ │ │ ├── __init__.cpython-37.pyc | |
│ │ │ │ │ ├── KernelDensity.cpython-37.pyc | |
│ │ │ │ │ ├── _statistics.cpython-37.pyc | |
│ │ │ │ │ └── test.cpython-37.pyc | |
│ │ │ │ ├── _statistics.py | |
│ │ │ │ └── test.py | |
│ │ │ ├── tree.py | |
│ │ │ └── util.py | |
│ │ ├── profiler.py | |
│ │ ├── __pycache__ | |
│ │ │ ├── accumulators.cpython-37.pyc | |
│ │ │ ├── broadcast.cpython-37.pyc | |
│ │ │ ├── cloudpickle.cpython-37.pyc | |
│ │ │ ├── conf.cpython-37.pyc | |
│ │ │ ├── context.cpython-37.pyc | |
│ │ │ ├── daemon.cpython-37.pyc | |
│ │ │ ├── files.cpython-37.pyc | |
│ │ │ ├── find_spark_home.cpython-37.pyc | |
│ │ │ ├── _globals.cpython-37.pyc | |
│ │ │ ├── heapq3.cpython-37.pyc | |
│ │ │ ├── __init__.cpython-37.pyc | |
│ │ │ ├── java_gateway.cpython-37.pyc | |
│ │ │ ├── join.cpython-37.pyc | |
│ │ │ ├── profiler.cpython-37.pyc | |
│ │ │ ├── rdd.cpython-37.pyc | |
│ │ │ ├── rddsampler.cpython-37.pyc | |
│ │ │ ├── resource.cpython-37.pyc | |
│ │ │ ├── resultiterable.cpython-37.pyc | |
│ │ │ ├── serializers.cpython-37.pyc | |
│ │ │ ├── shell.cpython-37.pyc | |
│ │ │ ├── shuffle.cpython-37.pyc | |
│ │ │ ├── statcounter.cpython-37.pyc | |
│ │ │ ├── status.cpython-37.pyc | |
│ │ │ ├── storagelevel.cpython-37.pyc | |
│ │ │ ├── taskcontext.cpython-37.pyc | |
│ │ │ ├── traceback_utils.cpython-37.pyc | |
│ │ │ ├── util.cpython-37.pyc | |
│ │ │ ├── version.cpython-37.pyc | |
│ │ │ └── worker.cpython-37.pyc | |
│ │ ├── python | |
│ │ │ ├── lib | |
│ │ │ │ ├── py4j-0.10.9-src.zip | |
│ │ │ │ └── pyspark.zip | |
│ │ │ └── pyspark | |
│ │ │ ├── __pycache__ | |
│ │ │ │ └── shell.cpython-37.pyc | |
│ │ │ └── shell.py | |
│ │ ├── rdd.py | |
│ │ ├── rddsampler.py | |
│ │ ├── resource.py | |
│ │ ├── resultiterable.py | |
│ │ ├── sbin | |
│ │ │ ├── spark-config.sh | |
│ │ │ ├── spark-daemon.sh | |
│ │ │ ├── start-history-server.sh | |
│ │ │ └── stop-history-server.sh | |
│ │ ├── serializers.py | |
│ │ ├── shell.py | |
│ │ ├── shuffle.py | |
│ │ ├── sql | |
│ │ │ ├── avro | |
│ │ │ │ ├── functions.py | |
│ │ │ │ ├── __init__.py | |
│ │ │ │ └── __pycache__ | |
│ │ │ │ ├── functions.cpython-37.pyc | |
│ │ │ │ └── __init__.cpython-37.pyc | |
│ │ │ ├── catalog.py | |
│ │ │ ├── column.py | |
│ │ │ ├── conf.py | |
│ │ │ ├── context.py | |
│ │ │ ├── dataframe.py | |
│ │ │ ├── functions.py | |
│ │ │ ├── group.py | |
│ │ │ ├── __init__.py | |
│ │ │ ├── pandas | |
│ │ │ │ ├── conversion.py | |
│ │ │ │ ├── functions.py | |
│ │ │ │ ├── group_ops.py | |
│ │ │ │ ├── __init__.py | |
│ │ │ │ ├── map_ops.py | |
│ │ │ │ ├── __pycache__ | |
│ │ │ │ │ ├── conversion.cpython-37.pyc | |
│ │ │ │ │ ├── functions.cpython-37.pyc | |
│ │ │ │ │ ├── group_ops.cpython-37.pyc | |
│ │ │ │ │ ├── __init__.cpython-37.pyc | |
│ │ │ │ │ ├── map_ops.cpython-37.pyc | |
│ │ │ │ │ ├── serializers.cpython-37.pyc | |
│ │ │ │ │ ├── typehints.cpython-37.pyc | |
│ │ │ │ │ ├── types.cpython-37.pyc | |
│ │ │ │ │ └── utils.cpython-37.pyc | |
│ │ │ │ ├── serializers.py | |
│ │ │ │ ├── typehints.py | |
│ │ │ │ ├── types.py | |
│ │ │ │ └── utils.py | |
│ │ │ ├── __pycache__ | |
│ │ │ │ ├── catalog.cpython-37.pyc | |
│ │ │ │ ├── column.cpython-37.pyc | |
│ │ │ │ ├── conf.cpython-37.pyc | |
│ │ │ │ ├── context.cpython-37.pyc | |
│ │ │ │ ├── dataframe.cpython-37.pyc | |
│ │ │ │ ├── functions.cpython-37.pyc | |
│ │ │ │ ├── group.cpython-37.pyc | |
│ │ │ │ ├── __init__.cpython-37.pyc | |
│ │ │ │ ├── readwriter.cpython-37.pyc | |
│ │ │ │ ├── session.cpython-37.pyc | |
│ │ │ │ ├── streaming.cpython-37.pyc | |
│ │ │ │ ├── types.cpython-37.pyc | |
│ │ │ │ ├── udf.cpython-37.pyc | |
│ │ │ │ ├── utils.cpython-37.pyc | |
│ │ │ │ └── window.cpython-37.pyc | |
│ │ │ ├── readwriter.py | |
│ │ │ ├── session.py | |
│ │ │ ├── streaming.py | |
│ │ │ ├── types.py | |
│ │ │ ├── udf.py | |
│ │ │ ├── utils.py | |
│ │ │ └── window.py | |
│ │ ├── statcounter.py | |
│ │ ├── status.py | |
│ │ ├── storagelevel.py | |
│ │ ├── streaming | |
│ │ │ ├── context.py | |
│ │ │ ├── dstream.py | |
│ │ │ ├── __init__.py | |
│ │ │ ├── kinesis.py | |
│ │ │ ├── listener.py | |
│ │ │ ├── __pycache__ | |
│ │ │ │ ├── context.cpython-37.pyc | |
│ │ │ │ ├── dstream.cpython-37.pyc | |
│ │ │ │ ├── __init__.cpython-37.pyc | |
│ │ │ │ ├── kinesis.cpython-37.pyc | |
│ │ │ │ ├── listener.cpython-37.pyc | |
│ │ │ │ └── util.cpython-37.pyc | |
│ │ │ └── util.py | |
│ │ ├── taskcontext.py | |
│ │ ├── traceback_utils.py | |
│ │ ├── util.py | |
│ │ ├── version.py | |
│ │ └── worker.py | |
│ └── pyspark-3.0.1.dist-info | |
│ ├── direct_url.json | |
│ ├── INSTALLER | |
│ ├── METADATA | |
│ ├── RECORD | |
│ ├── top_level.txt | |
│ └── WHEEL | |
└── nix-support | |
└── propagated-build-inputs | |
63 directories, 844 files |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment