beam.git
9 hours ago  Exprosed[BEAM-3502] Remove usage of proto.Builder.clone() in... master
10 hours ago  Robert BradshawMerge pull request #4450 [BEAM-3490] Wrap DistributionD...
11 hours ago  Thomas GrohMerge pull request #4427
12 hours ago  Robert Bradshaw[BEAM-3490] Wrap DistributionData in a DistributionResu... 4450/head
13 hours ago  Thomas GrohMerge pull request #4421
13 hours ago  Ilya FigotinUse platformThreadFactory for default thread pool.
16 hours ago  Kenn KnowlesMerge pull request #4219: [BEAM-413] Created local...
16 hours ago  Kenn KnowlesMerge pull request #4263: [BEAM-3351] Fix Javadoc forma...
17 hours ago  Ahmet AltayMerge pull request #4077 from holdenk/BEAM-3142-fix...
17 hours ago  Bill NeubauerUpdate generated version of Fn API code.
19 hours ago  Jean-Baptiste... Merge pull request #4446 from iemejia/BEAM-3275-kafka1
21 hours ago  Ismaël Mejía[BEAM-3275] Update KafkaIO to support Kafka version... 4446/head
27 hours ago  Kenn KnowlesMerge pull request #4428: Add unshaded configurations...
27 hours ago  Kenn KnowlesMerge pull request #4351: [BEAM-3182][Nexmark][SQL...
33 hours ago  Łukasz Gajowy[BEAM-3496] Add missing dependencies in hadoopInputForm...
33 hours ago  Robert BradshawMerge pull request #4423 [BEAM-3486] Fixing Work Progre...
35 hours ago  Thomas GrohMerge pull request #4435
35 hours ago  Kenn KnowlesMerge pull request #4398: [ BEAM-3464] Fix NexmarkLaunc...
37 hours ago  Thomas GrohAdd a more complete FnHarness#main method
37 hours ago  Pablo[BEAM-2732] Starting refactor of state tracking in...
37 hours ago  Thomas GrohGive UnknownPTransformRunnerFactory a real name 4435/head
38 hours ago  Luke Cwik[BEAM-2863] Migrate away from deprecated methods.
39 hours ago  Kenn KnowlesMerge pull request #4384: [BEAM-2795] Use portable...
39 hours ago  Kenn KnowlesMerge pull request #4420: [BEAM-3461] Drop redundant... samza-runner
40 hours ago  Łukasz Gajowy[BEAM-3217] add HadoopInputFormatIO integration test...
41 hours ago  Robert BradshawMerge pull request #4438 from robertwb/source-counters
41 hours ago  Robert BradshawMerge pull request #4431 from robertwb/reshuffle
41 hours ago  Luke Cwik[BEAM-2863] Fix translation of side inputs due to missi...
41 hours ago  Thomas GrohMerge pull request #4429
2 days ago  Łukasz Gajowy[BEAM-3456] Enable jenkins and large scale scenario...
2 days ago  Robert Bradshawlint 4431/head
2 days ago  Eugene KirpichovMerge pull request #4432 from jkff/rm-max-bundle-size
2 days ago  Robert BradshawEnable counters from sources on workers. 4438/head
2 days ago  Eugene KirpichovRemoves maxBundleSize option accidentally introduced... 4432/head
2 days ago  Robert BradshawFix reshuffle test on non-direct runners.
2 days ago  Thomas GrohMerge pull request #4386
2 days ago  Ben SidhomUse portable constructs in Flink streaming translator 4384/head
2 days ago  Ben SidhomIdentify unconsumed reads by URN
2 days ago  Thomas GrohRevert "Temporarily disable permared Dataflow integrati... 4429/head
2 days ago  Thomas GrohUpdate Dataflow Container Version
2 days ago  Eugene KirpichovMerge pull request #4312 from rniemo-g/multiple-row...
2 days ago  Kenneth KnowlesAdd unshaded configurations in the default profile 4428/head
2 days ago  Anton Kedin[Nexmark][SQL] Implement sql query 2 4351/head
2 days ago  Thomas GrohAdd InboundDataClient 4427/head
2 days ago  Thomas GrohAdd joda-time dependency to java/fn-execution 4386/head
2 days ago  Thomas GrohAdd wire_coder_id to RemoteGrpcPort
3 days ago  Thomas GrohMerge pull request #4224 4226/head
3 days ago  Kenn KnowlesMerge pull request #4129: [BEAM-3182][Nexmark][SQL...
3 days ago  Kenn KnowlesMerge pull request #4356: [BEAM-2963] Pass portable...
3 days ago  Kenneth KnowlesCorrect getAdditionalInputs for Dataflow single-output... 4356/head
3 days ago  Kenneth KnowlesPass portable transform IDs in Dataflow runner
3 days ago  Kenneth KnowlesMore logging and error checking in ProcessBundleHandler
3 days ago  Kenneth KnowlesFix coders in Java SDK harness
3 days ago  Kenneth KnowlesMake default ParDo output tag explicit
3 days ago  Kenneth KnowlesClarify names and visibility of ParDoTranslation helpers
3 days ago  Kenneth KnowlesMove DoFnSignature helpers to DoFnSignatures and rename
3 days ago  Kenneth KnowlesMove DoFnAndMainOutput to top level
3 days ago  Ankur GoenkaFixing Work Progress reporting 4423/head
3 days ago  Luke Cwik[BEAM-3461] Drop redundant beam-YYY-parent and use... 4420/head
3 days ago  Robert BradshawMerge pull request #4408 from youngoli/beam3126
3 days ago  Thomas GrohImplement a GRPC Provision Service 4421/head
3 days ago  Ryan NiemocienskiMerge branch 'master' of https://github.com/apache... 4312/head
3 days ago  Chamikara JayalathMerge pull request #4413 from DariuszAniszewski/use...
3 days ago  Ryan NiemocienskiUse multiple key ranges in BigtableServiceImpl
3 days ago  Ryan NiemocienskiAdd tests for supporting multiple key ranges.
3 days ago  Ryan NiemocienskiUpdate BigTableSource to use multiple key ranges
3 days ago  Eugene KirpichovMerge pull request #4185 from rmannibucau/fb/BEAM-3243_...
3 days ago  Daniel Oliveira[BEAM-3126] Fixes for flatten runner.
3 days ago  Daniel Oliveira[BEAM-3125] Fixing little nitpicks and typos.
3 days ago  Daniel Oliveira[BEAM-3125] Creating flatten runner
3 days ago  Daniel Oliveira[BEAM-3125] Creating flatten runner, unfinished.
3 days ago  Thomas GrohUpdate GRPC Multiplexer and Associated to Java8 4224/head
3 days ago  Ismaël MejíaMerge pull request #4379 from jbonofre/BEAM-3438
3 days ago  Jean-Baptiste... [BEAM-3438] Disable it on Kinesis 4379/head
4 days ago  Thomas WeiseMerge pull request #4402: [BEAM-3240] Fix quickstart...
4 days ago  Ismaël MejíaMerge pull request #4415 from RyanSkraba/BEAM-3454...
4 days ago  Dariusz Aniszewskiuse VirtualEnv for PerfKit jobs 4413/head
4 days ago  Ryan Skraba[BEAM-3454] Use multiple stopping conditions on JmsIO... 4415/head
4 days ago  Ismaël MejíaMerge pull request #4414 from iemejia/master
4 days ago  Ismaël MejíaAdd missing protobuf-java dependency on runners/java... 4414/head
5 days ago  Romain Manni... adressing comments 4185/head
6 days ago  Ismaël MejíaMerge pull request #4400 from iemejia/java8-update
6 days ago  Kenn KnowlesMerge pull request #4409: [BEAM-3397] Temporarily disab...
6 days ago  Kenn KnowlesMerge pull request #4411: Fix unused dependency error...
6 days ago  Ismaël MejíaFix unused dependency error on Flink runner 4411/head
6 days ago  Ismaël MejíaMerge pull request #4410 from lukecwik/mqtt
7 days ago  Jean-Baptiste... Merge pull request #4235 from rmannibucau/fb/BEAM-682_f...
7 days ago  Luke Cwik[BEAM-3478] Fix checkstyle issue in runners/flink 4410/head
7 days ago  Lukasz Cwik[BEAM-3336] Fix thread safety issues of MqttIOTest...
7 days ago  Lukasz Cwik[BEAM-3436] Fix RetryHttpRequestInitializerTest to...
7 days ago  Kenn KnowlesMerge pull request #4343: [BEAM-2795] Use portable...
7 days ago  Kenneth KnowlesTemporarily disable permared Dataflow integration tests 4409/head
7 days ago  Thomas GrohMerge pull request #4405
7 days ago  Daniel Oliveira[BEAM-3126] Creating flatten operation for bundle proce... 4408/head
7 days ago  Chamikara JayalathMerge pull request #4390 from chamikaramj/bq_read_non_e...
7 days ago  Luke Cwik[BEAM-2863] Add the ability to length prefix unknown...
7 days ago  Ben SidhomUse portable constructs in Flink batch translator 4343/head
7 days ago  Ben SidhomExpose side inputs in CombineTranslation and refactor...
7 days ago  Kenn KnowlesMerge pull request #4341: [BEAM-3354] Fixed a bug that...
7 days ago  Thomas GrohEnable Java8 for fn execution modules
next