(self, vector, unique_database)
| 395 | super(TestInsertFileExtension, cls).setup_class() |
| 396 | |
| 397 | def test_file_extension(self, vector, unique_database): |
| 398 | table_format = vector.get_value('table_format').file_format |
| 399 | if table_format == 'parquet': |
| 400 | file_extension = '.parq' |
| 401 | stored_as_format = 'parquet' |
| 402 | else: |
| 403 | file_extension = '.txt' |
| 404 | stored_as_format = 'textfile' |
| 405 | table_name = "{0}_table".format(table_format) |
| 406 | ctas_query = "create table {0}.{1} stored as {2} as select 1".format( |
| 407 | unique_database, table_name, stored_as_format) |
| 408 | self.execute_query_expect_success(self.client, ctas_query) |
| 409 | for path in self.filesystem_client.ls("test-warehouse/{0}.db/{1}".format( |
| 410 | unique_database, table_name)): |
| 411 | if not path.startswith('_'): assert path.endswith(file_extension) |
| 412 | |
| 413 | |
| 414 | class TestInsertHdfsWriterLimit(ImpalaTestSuite): |
nothing calls this directly
no test coverage detected