clear query| facets| time Search criteria: .   Results from 1 to 10 from 915 (0.0s).
Loading phrases to help you
refine your search...
Pass-through transform for accessing runner-specific functionality from Beam? - Beam - [mail # user]
...+[EMAIL PROTECTED] has been doing something very similar but using it supportnative Flink IO within Apache Beam within the company he works for. Notethat the community had a discussion about...
   Author: Lukasz Cwik , 2018-10-17, 21:44
[PROPOSAL] Move sorting to sdks-java-core - Beam - [mail # dev]
...Merging the sorter into sdks-java-core isn't needed for pipelines executedvia portability since the Runner will be able to perform PTransformreplacement and optimization based upon the URN o...
   Author: Lukasz Cwik , 2018-10-17, 21:39
[expand - 5 more] - [BEAM-5442] Store duplicate unknown (runner) options in a list argument - Beam - [mail # dev]
...On Tue, Oct 16, 2018 at 11:51 AM Robert Bradshaw wrote:> On Tue, Oct 16, 2018 at 7:03 PM Lukasz Cwik  wrote:> >> > For all unknown options, the SDK can require that all f...
   Author: Lukasz Cwik , 2018-10-17, 21:35
Java > 8 support - Beam - [mail # dev]
...When we were supporting Java 7, there were Java 8 based modules in Maven.We can follow a similar pattern where Java11 (or any other version) havetheir own projects and as the base Java versi...
   Author: Lukasz Cwik , 2018-10-17, 21:03
Python SDK worker / portable Flink runner performance improvements - Beam - [mail # dev]
...Thanks, this was useful for me since I have been away these past couple ofweeks.On Wed, Oct 17, 2018 at 8:45 AM Thomas Weise  wrote:> Hi,>> As you may have noticed, some of the...
   Author: Lukasz Cwik , 2018-10-17, 21:00
[PROPOSAL] Using Bazel and Docker for Python SDK development and tests - Beam - [mail # dev]
...Gradle works pretty well at executing separate projects in parallel. Thereare a few Java projects which contain only tests with different flags whichallow us to use the Gradle project based ...
   Author: Lukasz Cwik , 2018-10-17, 20:57
[expand - 1 more] - Renewing the Slack channel join link? - Beam - [mail # dev]
...To follow up on this, Apache Infra was able to make the slack invitelink[1] permanent via INFRA-17152[2]. If you experience issues, pleasefollow-up on the JIRA issue.One less source of toil....
   Author: Lukasz Cwik , 2018-10-17, 20:09
Is portable.DirectGroupByKey supposed to be private? - Beam - [mail # dev]
...I believe Thomas copied a large portion of the DirectRunner codebase whenhe started developing the ULR.Package public/private is an important distinction to make and we shouldattempt to mini...
   Author: Lukasz Cwik , 2018-10-17, 18:59
[expand - 1 more] - joining two streams of the same type - Beam - [mail # user]
...YesOn Tue, Oct 16, 2018 at 4:34 PM [EMAIL PROTECTED]  wrote:> Ok, thanks, but still I have to manually specify how to extract messages> of a specific stream (previously flattened)...
   Author: Lukasz Cwik , 2018-10-17, 16:22
Does anyone have a strong intelliJ setup? - Beam - [mail # dev]
...I also reached out on the Gradle forum asking about how to get Intellij touse a subprojects output jars instead of the output classes:https://discuss.gradle.org/t/how-to-get-intellij-to-use-...
   Author: Lukasz Cwik , 2018-10-16, 18:06