Flink 查询hive表 初始化 Savepoint

[王良]

我使用的是flink 1.10 ，想通过查询hive表的数据初始化Savepoint，现在遇到的问题是无法将Table转成DataSet

EnvironmentSettings settings = 
EnvironmentSettings.newInstance().useBlinkPlanner().inBatchMode().build();
TableEnvironment tableEnv = TableEnvironment.create(settings);
Table table = tableEnv.sqlQuery("select * from test001");

BootstrapTransformation<CurrencyRate> broadcastTransformation = 
OperatorTransformation
        .bootstrapWith(currencyDataSet)
        .transform(new CurrencyBootstrapFunction());

Savepoint
        .create(backend, 128)
        .withOperator(ACCOUNT_UID, transformation)
        .withOperator(CURRENCY_UID, broadcastTransformation)
        .write(savepointPath);