Re: Flink 查询hive表 初始化 Savepoint

Wed, 06 May 2020 04:45:43 -0700 

Hi，

Blink planner是不支持Table API跟DataSet API互转的。
Blink planner是批流统一的架构，不是基于DataSet API实现的批。

王良 <[email protected]> 于2020年5月6日周三 下午4:41写道：

> 我使用的是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);
>
>

-- 

Benchao Li
School of Electronics Engineering and Computer Science, Peking University
Tel:+86-15650713730
Email: [email protected]; [email protected]

回复