View all bigflow analysis

How to use the bigflow.util.hadoop_client.HadoopClient function in bigflow

To help you get started, we’ve selected a few bigflow examples, based on popular ways it is used in public projects.

Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.

baidu / bigflow / bigflow_python / python / bigflow / pipeline / pipeline_base.py View on Github

def _hadoop_client(self):
        if self._hadoop_client_instance == None:
            self._hadoop_client_instance = hadoop_client.HadoopClient(
                    self._job_config.hadoop_client_path,
                    self._job_config.hadoop_config_path)
        return self._hadoop_client_instance