请问flink hudi connector 在编写create table语句的时候，怎么指定使用

Flink HDU的create table语句中可以使用payload类型关键字来指定输入流的payload类型。例如：

sql Copy code CREATE TABLE input_table ( id INT, name STRING, payload_type TINYINT ) WITH ( 'connector.type' = 'hive', 'connector.version' = '1.0', 'connector.properties.path' = '/path/to/hive/conf', 'format.type' = 'json', 'format.derive-schema' = 'true', 'format.payload.type' = 'INT', 'format.payload.format' = 'json' ); 在上面的语句中，我们指定了输入流的payload类型为INT，并且使用了hive connector。 需要注意的是，由于不同的payload类型可能需要不同的输入格式，因此在指定payload类型时最好同时指定相应的输入格式。