[AIRFLOW-6644][AIP-21] Move service classes to providers package (#7265)

* [AIP-21] Move contrib.hooks.cloudant_hook providers.cloudant.hooks.cloudant

* [AIP-21] Move contrib.hooks.databricks_hook providers.databricks.hooks.databricks

* [AIP-21] Move contrib.hooks.datadog_hook providers.datadog.hooks.datadog

* [AIP-21] Move contrib.hooks.dingding_hook providers.dingding.hooks.dingding

* [AIP-21] Move contrib.hooks.discord_webhook_hook providers.ddiscord.hooks.discord_webhook

* [AIP-21] Move contrib.hooks.gdrive_hook providers.google.suite.hooks.drive

* [AIP-21] Move contrib.hooks.jenkins_hook providers.jenking.hooks.jenkins

* [AIP-21] Move contrib.hooks.opsgenie_alert_hook providers.opsgenie.hooks.opsgenie_alert

* [AIP-21] Move contrib.hooks.pagerduty_hook providers.pagerduty.hooks.pagerduty

* [AIP-21] Move contrib.hooks.qubole_check_hook providers.qubole.hooks.qubole_check

* [AIP-21] Move contrib.hooks.qubole_hook providers.qubole.hooks.qubole

* [AIP-21] Move contrib.hooks.salesforce_hook providers.salesforce.hooks.salesforce

* [AIP-21] Move contrib.hooks.segment_hook providers.segment.hooks.segment

* [AIP-21] Move contrib.hooks.snowflake_hook providers.snowflake.hooks.snowflake

* [AIP-21] Move contrib.hooks.vertica_hook providers.vertica.hooks.vertica

* [AIP-21] Move gcp.hooks.gsheets providers.google.suite.hooks.sheets

* [AIP-21] Move hooks.slack_hook providers.slack.hooks.slack

* [AIP-21] Move hooks.zendesk_hook providers.zendesk.hooks.zendesk

* [AIP-21] Move contrib.operators.databricks_operator providers.databricks.operators.databricks

* [AIP-21] Move contrib.operators.dingding_operator providers.dindding.operators.dingding

* [AIP-21] Move contrib.operators.discord_webhook_operator providers.discord.operators.discord_webhook

* [AIP-21] Move contrib.operators.jenkins_job_trigger_operator providers.jenking.operators.jenkins_job_trigger

* [AIP-21] Move contrib.operators.opsgenie_alert_operator providers.opsgenie.operators.opsgenie_alert

* [AIP-21] Move contrib.operators.qubole_check_operator providers.qubole.operators.qubole_check

* [AIP-21] Move contrib.operators.qubole_operator providers.qubole.operators.qubole

* [AIP-21] Move contrib.operators.segment_track_event_operator providers.segment.operators.segment_track_event

* [AIP-21] Move contrib.operators.slack_webhook_operator providers.slack.operators.slack_webhook

* [AIP-21] Move contrib.operators.vertica_operator providers.vertica.operators.vertica

* [AIP-21] Move contrib.sensors.datadog_sensor providers.datadog.sensors.datadog

* [AIP-21] Move contrib.sensors.qubole_sensor providers.qubole.sensors.qubole

* [AIP-21] Move operators.slack_operator providers.slack.operators.slack

* Update docs

airflow/contrib/example_dags/example_databricks_operator.py

@@ -33,7 +33,7 @@
 """
 
 from airflow import DAG
-from airflow.contrib.operators.databricks_operator import DatabricksSubmitRunOperator
+from airflow.providers.databricks.operators.databricks import DatabricksSubmitRunOperator
 from airflow.utils.dates import days_ago
 
 default_args = {

airflow/contrib/example_dags/example_dingding_operator.py

@@ -22,7 +22,7 @@
 from datetime import timedelta
 
 from airflow import DAG
-from airflow.contrib.operators.dingding_operator import DingdingOperator
+from airflow.providers.dindding.operators.dingding import DingdingOperator
 from airflow.utils.dates import days_ago
 
 args = {

airflow/contrib/example_dags/example_qubole_operator.py

@@ -32,9 +32,9 @@
 import random
 
 from airflow import DAG
-from airflow.contrib.operators.qubole_operator import QuboleOperator
 from airflow.operators.dummy_operator import DummyOperator
 from airflow.operators.python import BranchPythonOperator, PythonOperator
+from airflow.providers.qubole.operators.qubole import QuboleOperator
 from airflow.utils.dates import days_ago
 
 default_args = {

airflow/contrib/example_dags/example_qubole_sensor.py

@@ -29,7 +29,7 @@
 """
 
 from airflow import DAG
-from airflow.contrib.sensors.qubole_sensor import QuboleFileSensor, QubolePartitionSensor
+from airflow.providers.qubole.sensors.qubole import QuboleFileSensor, QubolePartitionSensor
 from airflow.utils import dates
 
 default_args = {

airflow/contrib/hooks/cloudant_hook.py

@@ -16,49 +16,14 @@
 # KIND, either express or implied.  See the License for the
 # specific language governing permissions and limitations
 # under the License.
-"""Hook for Cloudant"""
-from cloudant import cloudant
+"""This module is deprecated. Please use `airflow.providers.cloudant.hooks.cloudant`."""
 
-from airflow.exceptions import AirflowException
-from airflow.hooks.base_hook import BaseHook
+import warnings
 
+# pylint: disable=unused-import
+from airflow.providers.cloudant.hooks.cloudant import CloudantHook  # noqa
 
-class CloudantHook(BaseHook):
-    """
-    Interact with Cloudant. This class is a thin wrapper around the cloudant python library.
-
-    .. seealso:: the latest documentation `here <https://python-cloudant.readthedocs.io/en/latest/>`_.
-
-    :param cloudant_conn_id: The connection id to authenticate and get a session object from cloudant.
-    :type cloudant_conn_id: str
-    """
-
-    def __init__(self, cloudant_conn_id='cloudant_default'):
-        self.cloudant_conn_id = cloudant_conn_id
-
-    def get_conn(self):
-        """
-        Opens a connection to the cloudant service and closes it automatically if used as context manager.
-
-        .. note::
-            In the connection form:
-            - 'host' equals the 'Account' (optional)
-            - 'login' equals the 'Username (or API Key)' (required)
-            - 'password' equals the 'Password' (required)
-
-        :return: an authorized cloudant session context manager object.
-        :rtype: cloudant
-        """
-        conn = self.get_connection(self.cloudant_conn_id)
-
-        self._validate_connection(conn)
-
-        cloudant_session = cloudant(user=conn.login, passwd=conn.password, account=conn.host)
-
-        return cloudant_session
-
-    def _validate_connection(self, conn):
-        for conn_param in ['login', 'password']:
-            if not getattr(conn, conn_param):
-                raise AirflowException('missing connection parameter {conn_param}'.format(
-                    conn_param=conn_param))
+warnings.warn(
+    "This module is deprecated. Please use `airflow.providers.cloudant.hooks.cloudant`.",
+    DeprecationWarning, stacklevel=2
+)