Path	Lines of Code
airflow/tests/dags/test_submit_pyspark_dataproc_template.py	18
airflow/tests/dags/test_submit_spark_dataproc_template.py	18
airflow/tests/test_integrity.py	11
airflow/tests/test_util/helper_functions.py	6
java/src/test/java/com/google/cloud/dataproc/templates/bigquery/BigQueryToGCSTest.java	46
java/src/test/java/com/google/cloud/dataproc/templates/config/GeneralTemplateConfigTest.java	103
java/src/test/java/com/google/cloud/dataproc/templates/config/InputConfigTest.java	17
java/src/test/java/com/google/cloud/dataproc/templates/config/OutputConfigTest.java	42
java/src/test/java/com/google/cloud/dataproc/templates/config/QueryConfigTest.java	16
java/src/test/java/com/google/cloud/dataproc/templates/databases/CassandraToBQTest.java	52
java/src/test/java/com/google/cloud/dataproc/templates/databases/CassandraToGCSTest.java	61
java/src/test/java/com/google/cloud/dataproc/templates/databases/MongoToBQTest.java	57
java/src/test/java/com/google/cloud/dataproc/templates/databases/MongoToGCSTest.java	68
java/src/test/java/com/google/cloud/dataproc/templates/databases/SpannerToGCSTest.java	63
java/src/test/java/com/google/cloud/dataproc/templates/dataplex/DataplexGCSToBQTest.java	58
java/src/test/java/com/google/cloud/dataproc/templates/gcs/GCSToSpannerTest.java	83
java/src/test/java/com/google/cloud/dataproc/templates/gcs/GCStoBigTableTest.java	58
java/src/test/java/com/google/cloud/dataproc/templates/gcs/GCStoBigqueryTest.java	59
java/src/test/java/com/google/cloud/dataproc/templates/gcs/GCStoGCSTest.java	65
java/src/test/java/com/google/cloud/dataproc/templates/gcs/GCStoJDBCTest.java	50
java/src/test/java/com/google/cloud/dataproc/templates/gcs/GCStoMongoTest.java	56
java/src/test/java/com/google/cloud/dataproc/templates/gcs/TextToBigqueryTest.java	67
java/src/test/java/com/google/cloud/dataproc/templates/general/GeneralTemplateTest.java	111
java/src/test/java/com/google/cloud/dataproc/templates/hbase/HbaseToGCSTest.java	55
java/src/test/java/com/google/cloud/dataproc/templates/hive/HiveToBigQueryTest.java	59
java/src/test/java/com/google/cloud/dataproc/templates/hive/HiveToGCSTest.java	59
java/src/test/java/com/google/cloud/dataproc/templates/jdbc/JDBCToGCSTest.java	58
java/src/test/java/com/google/cloud/dataproc/templates/jdbc/JDBCToJDBCTest.java	58
java/src/test/java/com/google/cloud/dataproc/templates/kafka/KafkaReaderTest.java	93
java/src/test/java/com/google/cloud/dataproc/templates/kafka/KafkaToBQDstreamTest.java	56
java/src/test/java/com/google/cloud/dataproc/templates/kafka/KafkaToBQTest.java	53
java/src/test/java/com/google/cloud/dataproc/templates/kafka/KafkaToGCSDstreamTest.java	58
java/src/test/java/com/google/cloud/dataproc/templates/kafka/KafkaToGCSTest.java	61
java/src/test/java/com/google/cloud/dataproc/templates/main/DataProcTemplateTest.java	81
java/src/test/java/com/google/cloud/dataproc/templates/main/GCSToBigTableHFileTest.java	45
java/src/test/java/com/google/cloud/dataproc/templates/pubsub/PubSubToBQTest.java	49
java/src/test/java/com/google/cloud/dataproc/templates/pubsub/PubSubToBigTableTest.java	56
java/src/test/java/com/google/cloud/dataproc/templates/pubsub/PubSubToGCSTest.java	47
java/src/test/java/com/google/cloud/dataproc/templates/pubsublite/PubSubLiteToBigTableTest.java	64
java/src/test/java/com/google/cloud/dataproc/templates/redshift/RedshiftToGCSTest.java	62
java/src/test/java/com/google/cloud/dataproc/templates/s3/S3ToBigQueryTest.java	68
java/src/test/java/com/google/cloud/dataproc/templates/snowflake/SnowflakeToGCSTest.java	49
java/src/test/java/com/google/cloud/dataproc/templates/util/PropertyUtilTest.java	42
notebooks/test/util/test_jdbc_input_manager.py	194
notebooks/test/util/test_notebook_functions.py	75
python/test/__init__.py	1
python/test/azure/__init__.py	1
python/test/azure/test_azure_blob_storage_to_bigquery.py	52
python/test/bigquery/__init__.py	1
python/test/bigquery/test_bigquery_to_gcs.py	124
python/test/bigquery/test_bigquery_to_memorystore.py	97
python/test/cassandra/__init__.py	1
python/test/cassandra/test_cassandra_to_bq.py	23
python/test/cassandra/test_cassandra_to_gcs.py	23
python/test/elasticsearch/__init__.py	1
python/test/elasticsearch/test_elasticsearch_to_bigtable.py	46
python/test/elasticsearch/test_elasticsearch_to_bq.py	59
python/test/elasticsearch/test_elasticsearch_to_gcs.py	130
python/test/gcs/__init__.py	1
python/test/gcs/test_gcs_to_bigquery.py	184
python/test/gcs/test_gcs_to_bigtable.py	18
python/test/gcs/test_gcs_to_gcs.py	186
python/test/gcs/test_gcs_to_jdbc.py	170
python/test/gcs/test_gcs_to_mongo.py	186
python/test/gcs/test_text_to_bigquery.py	160
python/test/hbase/__init__.py	1
python/test/hbase/test_hbase_to_gcs.py	41
python/test/hive/__init__.py	1
python/test/hive/test_hive_to_bigquery.py	90
python/test/hive/test_hive_to_gcs.py	94
python/test/hive/util/__init__.py	1
python/test/hive/util/test_hive_ddl_extractor.py	26
python/test/jdbc/__init__.py	1
python/test/jdbc/test_jdbc_to_bigquery.py	168
python/test/jdbc/test_jdbc_to_gcs.py	248
python/test/jdbc/test_jdbc_to_jdbc.py	185
python/test/mongo/__init__.py	1
python/test/mongo/test_mongo_to_bq.py	22
python/test/mongo/test_mongo_to_gcs.py	168
python/test/pubsublite/__init__.py	1
python/test/pubsublite/test_pubsublite_to_bigtable.py	147
python/test/pubsublite/test_pubsublite_to_gcs.py	57
python/test/redshift/__init__.py	1
python/test/redshift/test_redshift_to_gcs.py	181
python/test/s3/__init__.py	1
python/test/s3/test_s3_to_bigquery.py	267
python/test/snowflake/test_snowflake_to_gcs.py	256
python/test/util/__init__.py	1
python/test/util/test_argument_parsing.py	97
python/test/util/test_elasticsearch_transformations.py	200