You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@iceberg.apache.org by GitBox <gi...@apache.org> on 2021/07/24 10:10:52 UTC
[GitHub] [iceberg] rlcyf opened a new issue #2861: how to work in Flink Scala Api?
rlcyf opened a new issue #2861:
URL: https://github.com/apache/iceberg/issues/2861
```
org.apache.flink.streaming.api.scala.DataStream
org.apache.flink.streaming.api.datastream.DataStream
```
```
val stream:org.apache.flink.streaming.api.datastream.DataStream[RowData] = FlinkSource.forRowData()
.env(env.getJavaEnv)
.tableLoader(tableLoader)
.streaming(true)
.build()
// working
val result = new org.apache.flink.streaming.api.scala.DataStream[RowData](stream)
resilt.print()
```
### Is it possible to provide scala converters？ like asScalaSream?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscribe@iceberg.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@iceberg.apache.org
For additional commands, e-mail: issues-help@iceberg.apache.org
[GitHub] [iceberg] hililiwei commented on issue #2861: how to work in Flink Scala Api?
Posted by GitBox <gi...@apache.org>.
hililiwei commented on issue #2861:
URL: https://github.com/apache/iceberg/issues/2861#issuecomment-897579847
I think we can convert it to a scala stream by adding a decorator in the org.apache.iceberg.flink package, using the implicit conversion of scala. I can try to do it.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscribe@iceberg.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@iceberg.apache.org
For additional commands, e-mail: issues-help@iceberg.apache.org