(self, method)
| 67 | v.get_value('key_tbl_dir') is not None) |
| 68 | |
| 69 | def setup_method(self, method): |
| 70 | super().setup_method(method) |
| 71 | self.__cleanup() |
| 72 | self.client.execute('create database if not exists %s' % TEST_DB) |
| 73 | self.client.execute('use %s' % TEST_DB) |
| 74 | self.hdfs_client.make_dir(TMP_DIR) |
| 75 | # Few tests depend on the .Trash directory being present. In case it doesn't |
| 76 | # exist, we create a random text file and delete it so that hdfs recreates |
| 77 | # the hierarchy of trash |
| 78 | if not self.hdfs_client.exists("/user/{0}/.Trash/".format(getpass.getuser())): |
| 79 | self.hdfs_client.create_file("/test-warehouse/random", file_data="random") |
| 80 | rc, stdout, stderr = exec_process("hadoop fs -rm /test-warehouse/random") |
| 81 | assert rc == 0, 'Error re-creating trash: %s %s' % (stdout, stderr) |
| 82 | |
| 83 | def teardown_method(self, method): |
| 84 | self.__cleanup() |
nothing calls this directly
no test coverage detected