:mod:`airflow.contrib.hooks.spark_jdbc_script` ============================================== .. py:module:: airflow.contrib.hooks.spark_jdbc_script Module Contents --------------- .. function:: set_common_options(spark_source, url='localhost:5432', jdbc_table='default.default', user='root', password='root', driver='driver') .. function:: spark_write_to_jdbc(spark, url, user, password, metastore_table, jdbc_table, driver, truncate, save_mode, batch_size, num_partitions, create_table_column_types) .. function:: spark_read_from_jdbc(spark, url, user, password, metastore_table, jdbc_table, driver, save_mode, save_format, fetch_size, num_partitions, partition_column, lower_bound, upper_bound) .. data:: parser