def METHOD_NAME(disable_compression: bool) -> None:
    c1 = new_column("col1", "bigint")
    c2 = new_column("col2", "bigint")
    t1 = {"col1": c1}
    t2 = {"col2": c2, "col1": c1}
    def c1_doc(count: int) -> DictStrAny:
        return map(lambda x: {"col1": x}, range(0, count))
    def c2_doc(count: int) -> DictStrAny:
        return map(lambda x: {"col1": x, "col2": x*2+1}, range(0, count))
    # change schema before file first flush
    with get_insert_writer(_format="jsonl", disable_compression=disable_compression) as writer:
        writer.write_data_item(list(c1_doc(15)), t1)
        # flushed
        assert writer._file is not None
        writer.write_data_item(list(c2_doc(2)), t2)
        # no rotation
        assert len(writer._buffered_items) == 2
        # only the initial 15 items written
        assert writer._writer.items_count == 15
    # all written
    with FileStorage.open_zipsafe_ro(writer.closed_files[-1], "r", encoding="utf-8") as f:
        content = f.readlines()
    assert content[-1] == '{"col1":1,"col2":3}\n'