An Apache Airflow provider for Qubole.
Modules are Python callables available from this provider package.
Hook for Qubole communication
Qubole check hook
Execute tasks (commands) on QDS (https://qubole.com).
Performs checks against Qubole Commands. QuboleCheckOperator expects a command that will be executed on QDS. By default, each value on first row of th…
Performs a simple value check using Qubole command. By default, each value on the first row of this Qubole command is compared with a pre-defined valu…
Wait for a file or folder to be present in cloud storage and check for its presence via QDS APIs
Wait for a Hive partition to show up in QHS (Qubole Hive Service) and check for its presence via QDS APIs
Base class for all Qubole Sensors
This is a Mixin for Qubole related check operators