def METHOD_NAME(client: DatabendClient):
    overwrite_stream = "overwrite_stream"
    append_stream = "append_stream"
    cursor = client.open()
    cursor.execute(f"DROP table _airbyte_raw_{overwrite_stream}")
    cursor.execute(f"DROP table _airbyte_raw_{append_stream}")