`airflow.contrib.operators.vertica_operator`¶

Module Contents¶

class airflow.contrib.operators.vertica_operator.VerticaOperator(sql, vertica_conn_id='vertica_default', *args, **kwargs)[source]¶

Bases:airflow.models.BaseOperator

Executes sql code in a specific Vertica database

Parameters

vertica_conn_id (str) – reference to a specific Vertica database
sql (Can receive a str representing a sql statement, a list of str (sql statements), or reference to a template file. Template reference are recognized by str ending in '.sql') – the sql code to be executed. (templated)

template_fields = ['sql'][source]¶

template_ext = ['.sql'][source]¶

ui_color = #b4e0ff[source]¶

execute(self, context)[source]¶