Hi all,
I was writing a very simple transform in Kotlin as follows that takes in a
series of integers and applies a simply DoFn against them:
pipeline
.apply(Create.of(1, 2, 3))
.apply(ParDo.of(object: DoFn(){
@ProcessElement
fun
Hello Community,
We just made a new PR which contains support for writing operation into
Snowflake.
All CR are more than welcome :)
PR: https://github.com/apache/beam/pull/11794
Thanks
Hello, community,
I found information that Google is working on supporting Dataflow runner
for cross-language
(https://beam.apache.org/roadmap/connectors-multi-sdk/)
Is there any more information about the expected release of this feature?
Thanks
Sounds good! Let's try it out. I sent one post suggestion via the form,
let's see how the notification goes for people who are subscribed to the
spreadsheet.
I'll create a PR with the description of the new process next week.
On Mon, May 18, 2020 at 10:58 AM Ahmet Altay wrote:
> I think this
