

def test_create_partitioned_separate_schema(self):
    schema = ibis.schema([('day', 'int8'), ('value', 'double')])
    part_schema = ibis.schema([('year', 'int32'), ('month', 'string')])
    name = _tmp_name()
    self.con.create_table(name, schema=schema, partition=part_schema)
    self.temp_tables.append(name)
    ex_schema = ibis.schema([('day', 'int8'), ('value', 'double'), ('year', 'int32'), ('month', 'string')])
    table_schema = self.con.get_schema(name)
    assert_equal(table_schema, ex_schema)
    partition_schema = self.con.table(name).partition_schema()
    assert_equal(partition_schema, part_schema)

dataset/ETHPy150Open cloudera/ibis/ibis/impala/tests/test_partition.py TestPartitioning.test_create_partitioned_separate_schema/original