Commits

Commit history

1. Commits on Oct 17, 2017

   • This closes #3982

     aaltay

     committed
     0f7736dView commit details

     Copy full SHA for 0f7736d

     Browse repository at this point

   • Wordcount on fnapi pipeline and IT test.

     aaltay

     committed
     3050bccView commit details

     Copy full SHA for 3050bcc

     Browse repository at this point

   • This closes #4005: Add missing license header in ProducerSpEL.java.

     kennknowles

     committed
     020ef14View commit details

     Copy full SHA for 020ef14

     Browse repository at this point

   • Add missing license header in ProducerSpEL.java.

     

     Raghu Angadi

     committed
     249da9bView commit details

     Copy full SHA for 249da9b

     Browse repository at this point

   • This closes #4003: [BEAM-3049] Relocate everything shaded by Java SDK harness

     kennknowles

     committed
     0f9f47dView commit details

     Copy full SHA for 0f9f47d

     Browse repository at this point

   • This closes #3612

     

     Reuven Lax

     committed
     0d2a39bView commit details

     Copy full SHA for 0d2a39b

     Browse repository at this point

   • update JavaDoc for withEOS().

     

     Raghu Angadi

     committed
     686b22fView commit details

     Copy full SHA for 686b22f

     Browse repository at this point

   • update JavaDoc for withEOS().

     

     Raghu Angadi

     committed
     0d5a3e2View commit details

     Copy full SHA for 0d5a3e2

     Browse repository at this point

   • Add runner check. Add withReadCommit() to reader.

     

     Raghu Angadi

     committed
     5e280faView commit details

     Copy full SHA for 5e280fa

     Browse repository at this point

   • Support version 0.11 through ProducerSpEL (reflection).

     Show description for 265e7c7
     

     Raghu Angadi

     committed
     265e7c7View commit details

     Copy full SHA for 265e7c7

     Browse repository at this point

   • Improve how we use MockProducer in tests.

     Show description for 3bd4085
     

     Raghu Angadi

     committed
     3bd4085View commit details

     Copy full SHA for 3bd4085

     Browse repository at this point

   • assign a random shard id once in setup(), rather than each time in processElement().

     

     Raghu Angadi

     committed
     236484bView commit details

     Copy full SHA for 236484b

     Browse repository at this point

   • Close producers after one minute of inactivity.

     Show description for f4f6105
     

     Raghu Angadi

     committed
     f4f6105View commit details

     Copy full SHA for f4f6105

     Browse repository at this point

   • Input PCollection has the coder for elements. No need to ask for them explicitly.

     

     Raghu Angadi

     committed
     5767156View commit details

     Copy full SHA for 5767156

     Browse repository at this point

   • Add basic metrics.

     

     Raghu Angadi

     committed
     99f5541View commit details

     Copy full SHA for 99f5541

     Browse repository at this point

   • 1) Add a note about metadata expiration.

     Show description for d9c95f0
     

     Raghu Angadi

     committed
     d9c95f0View commit details

     Copy full SHA for d9c95f0

     Browse repository at this point

   • Disable other sink tests. Need to fix how tests use global MOCK_PRODUCER. A few more other minor changes.

     

     Raghu Angadi

     committed
     6bf618dView commit details

     Copy full SHA for 6bf618d

     Browse repository at this point

   • Kafka exactly-once sink.

     Show description for d745cc9
     

     Raghu Angadi

     committed
     d745cc9View commit details

     Copy full SHA for d745cc9

     Browse repository at this point

   • [BEAM-1017] This closes #1687

     jbonofre

     committed
     9524cbdView commit details

     Copy full SHA for 9524cbd

     Browse repository at this point

   • [BEAM-1017] Add RedisIO

     jbonofre

     committed
     0d8ab6cView commit details

     Copy full SHA for 0d8ab6c

     Browse repository at this point

   • This closes #3989

     tgroh

     committed
     4b502bfView commit details

     Copy full SHA for 4b502bf

     Browse repository at this point

   • Remove "beta" from the Cancel Command Prefix

     tgroh

     committed
     2af8b07View commit details

     Copy full SHA for 2af8b07

     Browse repository at this point

   • Relocate everything shaded by Java SDK harness

     kennknowles

     committed
     0089093View commit details

     Copy full SHA for 0089093

     Browse repository at this point

   • This closes #3861

     tgroh

     committed
     52ad6f1View commit details

     Copy full SHA for 52ad6f1

     Browse repository at this point

   • [BEAM-409] Avoiding integer division in ceil

     Show description for 2f0a53d
     

     youngoli

     authored and

     tgroh

     committed
     2f0a53dView commit details

     Copy full SHA for 2f0a53d

     Browse repository at this point

   • [BEAM-3063] Improve VoidCoder structural value to use a single shared instance.

     Show description for 8ff9c00
     lukecwik

     committed
     8ff9c00View commit details

     Copy full SHA for 8ff9c00

     Browse repository at this point

   • [BEAM-3063] Improve VoidCoder structural value to use a single shared instance.

     lukecwik

     committed
     380e995View commit details

     Copy full SHA for 380e995

     Browse repository at this point
2. Commits on Oct 16, 2017

   • [BEAM-1487, BEAM-3016] Address termination correctness issues in BufferingStreamObserver & BeamFnLoggingClient

     Show description for 3633c40
     lukecwik

     committed
     3633c40View commit details

     Copy full SHA for 3633c40

     Browse repository at this point

   • [BEAM-1487, BEAM-3016] Address termination correctness issues in BufferingStreamObserver & BeamFnLoggingClient

     Show description for 6cdea08
     lukecwik

     committed
     6cdea08View commit details

     Copy full SHA for 6cdea08

     Browse repository at this point

   • This closes #3981: [BEAM-2878] Use bintray as default for container images

     Show description for c8f3a91
     kennknowles

     committed
     c8f3a91View commit details

     Copy full SHA for c8f3a91

     Browse repository at this point

   • This closes #4001: [BEAM-3052] Set end-of-window timer in AfterWatermarkStateMachine

     Show description for 52863ef
     kennknowles

     committed
     52863efView commit details

     Copy full SHA for 52863ef

     Browse repository at this point

   • Do not set EOW timer in TriggerStateMachineTester

     kennknowles

     committed
     3d36f63View commit details

     Copy full SHA for 3d36f63

     Browse repository at this point

   • Set end-of-window timer in AfterWatermarkStateMachine

     kennknowles

     committed
     45c65c5View commit details

     Copy full SHA for 45c65c5

     Browse repository at this point

   • Allow checking timers set in TriggerStateMachineTester

     kennknowles

     committed
     64fb19dView commit details

     Copy full SHA for 64fb19d

     Browse repository at this point

   • This closes #3995: Add custom gcs temp location support to BigQueryIO

     jkff

     committed
     a5cbd76View commit details

     Copy full SHA for a5cbd76

     Browse repository at this point