flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "老男孩" <mac...@qq.com>
Subject Flink 查询hive表 初始化 Savepoint
Date Wed, 06 May 2020 08:44:07 GMT
我使用的是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);
Mime
  • Unnamed multipart/alternative (inline, 8-Bit, 0 bytes)
View raw message