如何使用BigQueryCreateEmptyTableOperator创建包含"Clustered by“列的表？

from airflow.contrib.operators.bigquery_operator import BigQueryCreateEmptyTableOperator
from airflow import DAG
from datetime import datetime

dag = DAG(
    'create_bigquery_table',
    description='Create a BigQuery table with "Clustered by" column',
    schedule_interval=None,
    start_date=datetime(2022, 1, 1),
    catchup=False
)

create_table_task = BigQueryCreateEmptyTableOperator(
    task_id='create_table',
    dataset_id='your_dataset_id',
    table_id='your_table_id',
    schema_fields=[
        {'name': 'column1', 'type': 'STRING'},
        {'name': 'column2', 'type': 'INTEGER'},
        {'name': 'column3', 'type': 'FLOAT'}
    ],
    time_partitioning=None,
    cluster_fields=['column1'],
    dag=dag
)

create_table_task