@property
  def fs(self):
    if self._fs is None:
      self._fs = HadoopFileSystem("localhost", 
        thrift_port=self.namenode_thrift_port,
        hdfs_port=self.namenode_port,
        hadoop_bin_path=hadoop.conf.HADOOP_BIN.get())
    return self._fs
Request comes from the controller. Returned is a request.
dataset/ETHPy150Open cloudera/hue/desktop/libs/hadoop/src/hadoop/mini_cluster.py/MiniHadoopCluster.fs--crossover with--dataset/ETHPy150Open priestc/giotto/giotto/programs/__init__.py/Program.execute_input_middleware_stream