Flink 查询hive表 初始化 Savepoint

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

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&gt; broadcastTransformation = OperatorTransformation
        .bootstrapWith(currencyDataSet)
        .transform(new CurrencyBootstrapFunction());

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