Flink jdbcinputformat是不能填参数设置分区的么？

你可以通过 setSql() 方法为 JdbcInputFormat 设置 SQL 语句，并通过 setSqlParameters() 方法设置 SQL 参数。

然后，你可以通过 setStartPartitionIndex() 和 setEndPartitionIndex() 方法设置分区的起始索引和结束索引。

以下是一个简单的例子：

```import org.apache.flink.api.common.serialization.SimpleStringEncoder;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.table.api.Table;
import org.apache.flink.table.api.bridge.java.StreamTableEnvironment;
import org.apache.flink.types.Row;

public class JdbcInputFormatExample {

public static void main(String[] args) throws Exception {
    StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
    StreamTableEnvironment tEnv = StreamTableEnvironment.create(env);

    // 创建一个 JDBC 连接
    String connectionUrl = "jdbc:mysql://localhost:3306/test?useSSL=false";
    String username = "root";
    String password = "password";
    Connection connection = DriverManager.getConnection(connectionUrl, username, password);

    // 创建一个 SQL 语句
    String sql = "SELECT * FROM user";

    // 设置 SQL 参数
    Map<String, Object> parameters = new HashMap<>();
    parameters.put("id", 1);

    // 创建一个 JDBCInputFormat
    JdbcInputFormat jdbcInputFormat = new JdbcInputFormat(connection, sql);

    // 设置分区
    jdbcInputFormat.setStartPartitionIndex(0);
    jdbcInputFormat.setEndPartitionIndex(1);

    // 读取数据
    DataStream<Row> dataStream = env.createInput(jdbcInputFormat, new SimpleStringEncoder());

    // 打印数据
    dataStream.print();

    // 启动 Flink 流式处理程序
    env.execute();
}

}

```