:mod:`airflow.operators.pig_operator` ===================================== .. py:module:: airflow.operators.pig_operator Module Contents --------------- .. py:class:: PigOperator(pig, pig_cli_conn_id='pig_cli_default', pigparams_jinja_translate=False, *args, **kwargs) Bases::class:`airflow.models.BaseOperator` Executes pig script. :param pig: the pig latin script to be executed. (templated) :type pig: str :param pig_cli_conn_id: reference to the Hive database :type pig_cli_conn_id: str :param pigparams_jinja_translate: when True, pig params-type templating ${var} gets translated into jinja-type templating {{ var }}. Note that you may want to use this along with the ``DAG(user_defined_macros=myargs)`` parameter. View the DAG object documentation for more details. :type pigparams_jinja_translate: bool .. attribute:: template_fields :annotation: = ['pig'] .. attribute:: template_ext :annotation: = ['.pig', '.piglatin'] .. attribute:: ui_color :annotation: = #f0e4ec .. method:: get_hook(self) .. method:: prepare_template(self) .. method:: execute(self, context) .. method:: on_kill(self)