:mod:`airflow.hooks.pig_hook`
=============================

.. py:module:: airflow.hooks.pig_hook







Module Contents
---------------






.. py:class:: PigCliHook(pig_cli_conn_id='pig_cli_default')

   Bases::class:`airflow.hooks.base_hook.BaseHook`

   

   Simple wrapper around the pig CLI.

   Note that you can also set default pig CLI properties using the
   ``pig_properties`` to be used in your connection as in
   ``{"pig_properties": "-Dpig.tmpfilecompression=true"}``


   

   

   

   .. method:: run_cli(self, pig, verbose=True)

      
      Run an pig script using the pig cli

      >>> ph = PigCliHook()
      >>> result = ph.run_cli("ls /;")
      >>> ("hdfs://" in result)
      True

      



   

   .. method:: kill(self)