spark_csv_to_avro.py

DevOps-Python-tools



	.buildkite
	.circleci
	.github
	.semaphore
	ambari_blueprints
	bash-tools @ df5a509b
	cloudformation
	crunch_accounting_csv_statement_converter_scripts
	gcp_cloud_function_ifconfig
	gcp_cloud_function_proxy
	gcp_cloud_function_sql_export
	lib
	pylib @ 548ebc65
	setup
	sql @ ad25bcb2
	templates @ b81a01bc
	tests
	.appveyor.yml
	.checkov.yaml
	.cirrus.yml
	.coafile
	.concourse.yml
	.drone.yml
	.editorconfig
	.flake8
	.gitallowed
	.gitignore
	.gitlab-ci.yml
	.gitmodules
	.gocd.yml
	.ipython-notebook-pyspark.00-pyspark-setup.py
	.ipython-notebook-pyspark.ipython_notebook_config.py.j2
	.pylintrc
	.pyup.yml
	.sonarcloud.properties
	.teamcity.vcs.json
	.teamcity.vcs.oauth.json
	.teamcity.vcs.ssh.json
	.travis.yml
	.werckerignore
	.yamllint
	ambari_ams_metrics.sh
	ambari_blueprints.py
	ambari_cancel_all_requests.sh
	ambari_trigger_service_checks.py
	anonymize_custom.conf
	anonymize_ignore.conf
	anonymize_parallel.sh
	anonymize.py
	aws_s3_presign.py
	aws_users_access_key_age.py
	aws_users_last_used.py
	aws_users_pw_last_used.py
	aws_users_unused_access_keys.py
	azure-pipelines.yml
	bitbucket-pipelines.yml
	boot
	buddy.yml
	buildspec.yml
	center.py
	cloudbuild.yaml
	cloudera_navigator_tables_used_postgres.py
	cloudera_navigator_tables_used.py
	codefresh.yml
	codeship.yml
	crunch_accounting_csv_statement_converter.py
	docker_pull_all_images_all_tags.sh
	docker_pull_all_images.sh
	docker_pull_all_tags.sh
	docker_registry_show_tags.py
	dockerfiles_check_git_branches.py
	dockerfiles_check_git_tags.py
	dockerhub_search.py
	dockerhub_show_tags.py
	find_active_apache_drill.py
	find_active_apache_drill2.py
	find_active_cassandra.py
	find_active_elasticsearch.py
	find_active_hadoop_namenode.py
	find_active_hadoop_yarn_resource_manager.py
	find_active_hadoop2_namenode.py
	find_active_hbase_master.py
	find_active_hbase_stargate.py
	find_active_hbase_thrift.py
	find_active_impala_catalog.py
	find_active_impala_statestore.py
	find_active_impala.py
	find_active_kubernetes_api.py
	find_active_oozie.py
	find_active_presto_coordinator.py
	find_active_server.py
	find_active_solrcloud.py
	find_duplicate_files.py
	find_missing_files_in_sequence.py
	gcp_service_account_credential_keys.py
	getent.py
	git_check_branches_upstream.py
	hbase_compact_tables.py
	hbase_flush_tables.py
	hbase_generate_data.py
	hbase_region_requests.py
	hbase_regions_by_memstore_size.py
	hbase_regions_by_size.py
	hbase_regions_least_used.py
	hbase_regionserver_requests.py
	hbase_scan_table_column_names.sh
	hbase_show_table_region_ranges.py
	hbase_table_region_row_distribution.py
	hbase_table_regions_by_regionserver.sh
	hbase_table_regionserver_distribution.sh
	hbase_table_row_key_distribution.py
	hbase_uncompacted_regions.sh
	hdfs_files_native_checksums.jy
	hdfs_files_stats.jy
	hdfs_find_replication_factor_1.py
	hdfs_time_block_reads.jy
	headtail.py
	hexanonymize.py
	hive_compute_table_stats.py
	hive_foreach_table.py
	hive_schemas_csv.py
	hive_tables_column_counts.py
	hive_tables_list.py
	hive_tables_locations.py
	hive_tables_metadata.py
	hive_tables_null_columns.py
	hive_tables_null_rows.py
	hive_tables_row_column_counts.py
	hive_tables_row_counts_any_nulls.py
	hive_tables_row_counts.py
	impala_compute_table_stats.py
	impala_foreach_table.py
	impala_schemas_csv.py
	impala_tables_column_counts.py
	impala_tables_list.py
	impala_tables_locations.py
	impala_tables_metadata.py
	impala_tables_null_columns.py
	impala_tables_null_rows.py
	impala_tables_row_column_counts.py
	impala_tables_row_counts_any_nulls.py
	impala_tables_row_counts.py
	ipython_notebook_pyspark.py
	Jenkinsfile
	json_docs_to_bulk_multiline.py
	json_to_xml.py
	json_to_yaml.py
	jython_autoinstall.exp
	jython_install.sh
	LICENSE
	Makefile
	opentsdb_import_metric_distribution.py
	opentsdb_list_metrics_hbase.sh
	opentsdb_list_metrics.sh
	pig_udfs.jy
	pig-text-to-elasticsearch.pig
	pig-text-to-solr.pig
	python_find_library_path.py
	pythonpath.py
	quay_show_tags.py
	README.md
	requirements.txt
	selenium_hub_browser_test.py
	serf_event_handler.py
	shippable.yml
	sonar-project.properties
	spark_avro_to_parquet.py
	spark_csv_to_avro.py
	spark_csv_to_parquet.py
	spark_json_to_avro.py
	spark_json_to_parquet.py
	spark_parquet_to_avro.py
	strip_ansi_escape_codes.py
	timeout.py
	travis_debug_session.py
	travis_last_log.py
	urldecode.py
	urlencode.py
	validate_avro.py
	validate_cson.py
	validate_csv.py
	validate_ini.py
	validate_ini2.py
	validate_json.py
	validate_ldap_ldif.py
	validate_multimedia.py
	validate_parquet.py
	validate_properties.py
	validate_toml.py
	validate_xml.py
	validate_yaml.py
	welcome.py
	wercker.yml
	xml_to_json.py
	xml_to_yaml.py
	yaml_to_json.py

Contents

History

Compare

Blame