Hi all, I am currently running some jobs coded in Beam in streaming mode on
Yarn session by Flink. My data sink was CSV files like the one in examples of
TfIdf. And I noticed that the output format for Beam is to produce one file for
every record, and also temp files for them. That would result
Hi there, can i please get an invite to the beam slack channel?
Thanks!
- Steve
--
Steven Anderson
Software Developer
Mobile: 650.455.6530
Email: st...@maestro.io
Website: http://www.maestro.io
Done!
On Tue, Aug 8, 2017 at 1:56 PM, Steve Anderson wrote:
> Hi there, can i please get an invite to the beam slack channel?
>
> Thanks!
> - Steve
>
> --
>
> Steven Anderson
> Software Developer
> Mobile: 650.455.6530
> Email: st...@maestro.io
> Website: http://www.maestro.io
>
--
---
J
Claire,
Interesting work.
In section 5, you talk about the Java language being difficult. Was there a
reason you didn't use Java lambdas for your work?
Thanks,
Jesse
On Tue, Aug 8, 2017 at 3:40 PM Claire Yuan wrote:
> Hi folks,
> We are a two-members team interning in Yahoo! Inc who are cu
Hi Claire,
Thank you - happy to see a paper with such a detailed description of your
experience with both usability of Beam per se and the execution on the
Flink runner!
The paper looks well-written, and, from a quick look at the code, it seems
to be using the Beam API properly without obvious opp
+Aljoscha Krettek for comments on Flink runner
+Thomas Weise likewise for Apex runner
On Tue, Aug 8, 2017 at 4:52 PM Eugene Kirpichov
wrote:
> Hi Claire,
>
> Thank you - happy to see a paper with such a detailed description of your
> experience with both usability of Beam per se and the execut