path # lines of code # active days days since first update days since last update # commits # contributors first updated last updated first contributor last contributor contrib/join-library/src/main/java/com/google/cloud/dataflow/contrib/joinlibrary/Join.java 112 3 3603 3591 5 3 2015-03-09 2015-03-21 magru@spotify.com davor@google.com contrib/hadoop/src/main/java/com/google/cloud/dataflow/contrib/hadoop/HadoopFileSource.java 341 3 3510 3357 3 3 2015-06-10 2015-11-10 tom@cloudera.com davor@google.com contrib/hadoop/src/main/java/com/google/cloud/dataflow/contrib/hadoop/WritableCoder.java 64 2 3510 3364 2 2 2015-06-10 2015-11-03 tom@cloudera.com dhalperi@users.noreply.github.com maven-archetypes/starter/src/main/resources/META-INF/maven/archetype-metadata.xml 20 1 3433 3433 1 1 2015-08-26 2015-08-26 bchambers@google.com bchambers@google.com maven-archetypes/starter/src/main/resources/archetype-resources/src/main/java/StarterPipeline.java 29 3 3433 3397 3 3 2015-08-26 2015-10-01 bchambers@google.com tgroh@google.com sdk/src/main/proto/proto2_coder_test_messages.proto 35 1 3634 3634 1 1 2015-02-06 2015-02-06 davor@google.com davor@google.com sdk/src/main/proto/windmill.proto 261 21 3637 3361 32 8 2015-02-03 2015-11-06 millsd@google.com aneeshnaman@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/options/PipelineOptionsValidator.java 61 7 3689 3442 8 5 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/options/BlockingDataflowPipelineOptions.java 19 4 3689 3580 4 3 2014-12-13 2015-04-01 davor@google.com gildea@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/options/Default.java 67 5 3689 3442 5 3 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/options/DataflowWorkerLoggingOptions.java 61 9 3613 3417 12 5 2015-02-27 2015-09-11 lcwik@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/options/ApplicationNameOptions.java 7 5 3689 3442 5 3 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/options/GoogleApiDebugOptions.java 40 8 3656 3417 11 5 2015-01-15 2015-09-11 lcwik@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/options/DefaultValueFactory.java 4 4 3689 3442 4 3 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/options/DataflowPipelineDebugOptions.java 122 18 3689 3442 20 9 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/options/Validation.java 12 4 3689 3489 4 4 2014-12-13 2015-07-01 davor@google.com tgroh@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/options/DataflowPipelineOptions.java 59 14 3689 3389 14 10 2014-12-13 2015-10-09 davor@google.com bchambers@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/options/Description.java 10 4 3689 3580 4 3 2014-12-13 2015-04-01 davor@google.com gildea@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/options/DirectPipelineOptions.java 33 5 3689 3377 5 5 2014-12-13 2015-10-21 davor@google.com tgroh@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/options/DataflowProfilingOptions.java 19 1 3389 3389 1 1 2015-10-09 2015-10-09 bchambers@google.com bchambers@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/options/PipelineOptionsRegistrar.java 5 4 3685 3442 4 2 2014-12-17 2015-08-17 lcwik@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/options/BigQueryOptions.java 11 4 3689 3580 4 3 2014-12-13 2015-04-01 davor@google.com gildea@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/options/PipelineOptionsFactory.java 837 24 3689 3442 30 13 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/options/ProxyInvocationHandler.java 291 14 3689 3442 16 8 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/options/DataflowPipelineWorkerPoolOptions.java 80 25 3689 3363 26 11 2014-12-13 2015-11-04 davor@google.com davor@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/options/StreamingOptions.java 7 5 3689 3599 5 3 2014-12-13 2015-03-13 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/options/GcsOptions.java 56 7 3689 3389 8 6 2014-12-13 2015-10-09 davor@google.com dhalperi@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/options/CloudDebuggerOptions.java 10 9 3664 3389 9 6 2015-01-07 2015-10-09 liangzhang@google.com bchambers@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/options/DataflowWorkerHarnessOptions.java 16 6 3689 3442 6 4 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/options/PipelineOptions.java 41 13 3689 3442 14 8 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/options/GcpOptions.java 143 14 3689 3442 15 5 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/options/Hidden.java 9 1 3599 3599 1 1 2015-03-13 2015-03-13 lcwik@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/options/package-info.java 1 4 3689 3442 4 2 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/DelegateCoder.java 78 13 3673 3417 13 5 2014-12-29 2015-09-11 klk@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/AvroCoder.java 390 17 3689 3392 20 7 2014-12-13 2015-10-06 davor@google.com mattlang@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/ListCoder.java 34 10 3689 3399 10 6 2014-12-13 2015-09-29 davor@google.com dhalperi@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/StringUtf8Coder.java 92 13 3689 3378 13 7 2014-12-13 2015-10-20 davor@google.com bchambers@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/TextualIntegerCoder.java 41 10 3689 3417 10 6 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/MapCoder.java 101 13 3689 3399 13 6 2014-12-13 2015-09-29 davor@google.com dhalperi@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/CoderFactory.java 6 1 3573 3573 1 1 2015-04-08 2015-04-08 klk@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/DefaultCoder.java 13 4 3689 3442 4 3 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/KvCoder.java 111 11 3689 3399 11 6 2014-12-13 2015-09-29 davor@google.com dhalperi@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/CoderException.java 13 5 3689 3417 5 4 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/Coder.java 77 12 3689 3417 12 6 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/AtomicCoder.java 13 10 3689 3417 10 5 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/InstantCoder.java 56 11 3689 3417 11 6 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/CustomCoder.java 61 10 3689 3417 10 6 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/IterableCoder.java 38 9 3689 3399 9 5 2014-12-13 2015-09-29 davor@google.com dhalperi@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/NullableCoder.java 97 2 3424 3417 2 2 2015-09-04 2015-09-11 dhalperi@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/VarIntCoder.java 50 10 3689 3417 10 5 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/CoderRegistry.java 468 30 3689 3377 33 8 2014-12-13 2015-10-21 davor@google.com dhalperi@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/SerializableCoder.java 105 15 3689 3411 15 5 2014-12-13 2015-09-17 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/CollectionCoder.java 31 9 3689 3399 9 5 2014-12-13 2015-09-29 davor@google.com dhalperi@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/BigEndianLongCoder.java 50 8 3689 3417 8 4 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/JAXBCoder.java 75 4 3580 3417 4 2 2015-04-01 2015-09-11 chamikara@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/CannotProvideCoderException.java 42 3 3556 3417 3 2 2015-04-25 2015-09-11 klk@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/VarLongCoder.java 51 9 3689 3417 9 5 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/Proto2Coder.java 179 12 3642 3417 12 9 2015-01-29 2015-09-11 pzd@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/StringDelegateCoder.java 36 8 3673 3417 8 4 2014-12-29 2015-09-11 klk@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/DurationCoder.java 49 3 3479 3417 3 2 2015-07-11 2015-09-11 klk@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/ByteArrayCoder.java 79 12 3689 3417 13 7 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/SetCoder.java 37 12 3689 3399 12 6 2014-12-13 2015-09-29 davor@google.com dhalperi@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/CoderProvider.java 5 3 3573 3546 3 1 2015-04-08 2015-05-05 klk@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/CoderProviders.java 93 2 3433 3411 2 1 2015-08-26 2015-09-17 klk@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/IterableLikeCoder.java 154 15 3689 3417 15 8 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/EntityCoder.java 44 9 3689 3417 9 6 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/VoidCoder.java 32 9 3689 3417 9 5 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/BigEndianIntegerCoder.java 50 8 3689 3417 8 4 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/TableRowJsonCoder.java 41 9 3689 3417 9 6 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/CoderFactories.java 145 4 3560 3442 4 3 2015-04-21 2015-08-17 klk@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/MapCoderBase.java 15 5 3689 3417 5 5 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/StandardCoder.java 145 18 3689 3417 18 11 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/DeterministicStandardCoder.java 6 2 3565 3417 2 1 2015-04-16 2015-09-11 klk@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/DoubleCoder.java 55 10 3689 3417 10 6 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/package-info.java 1 4 3689 3442 4 2 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/KvCoderBase.java 15 6 3689 3417 6 5 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/Pipeline.java 223 21 3689 3417 24 9 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/GroupAlsoByWindowsAndCombineDoFn.java 122 6 3494 3417 8 5 2015-06-26 2015-09-11 peihe@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/Structs.java 294 5 3689 3417 5 4 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/PathValidator.java 6 4 3641 3463 4 2 2015-01-30 2015-07-27 relax@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/DirectModeExecutionContext.java 84 10 3689 3438 10 5 2014-12-13 2015-08-21 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/NoopCredentialFactory.java 14 2 3641 3612 2 2 2015-01-30 2015-02-28 relax@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/IOChannelUtils.java 91 8 3689 3442 9 5 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ApiSurface.java 333 5 3546 3414 6 3 2015-05-05 2015-09-14 klk@google.com bchambers@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/MonitoringUtil.java 157 9 3689 3468 11 11 2014-12-13 2015-07-22 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ExposedByteArrayOutputStream.java 61 1 3551 3551 1 1 2015-04-30 2015-04-30 zhouyunqing@google.com zhouyunqing@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/UserCodeException.java 41 4 3689 3417 4 4 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/GcpCredentialFactory.java 19 2 3641 3612 2 2 2015-01-30 2015-02-28 relax@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/DataflowPathValidator.java 59 7 3641 3399 7 4 2015-01-30 2015-09-29 relax@google.com dhalperi@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/StringUtils.java 121 6 3689 3442 7 5 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/StreamUtils.java 36 2 3551 3539 2 2 2015-04-30 2015-05-12 zhouyunqing@google.com davorbonaci@users.noreply.github.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/PCollectionViewWindow.java 34 1 3495 3495 1 1 2015-06-25 2015-06-25 klk@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/Values.java 60 2 3689 3612 2 2 2014-12-13 2015-02-28 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/MergingActiveWindowSet.java 130 5 3497 3389 5 2 2015-06-23 2015-10-09 bchambers@google.com bchambers@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/AttemptAndTimeBoundedExponentialBackOff.java 88 3 3564 3439 3 3 2015-04-17 2015-08-20 laraschmidt@google.com ccy@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/DoFnRunner.java 434 41 3689 3386 48 14 2014-12-13 2015-10-12 davor@google.com dhalperi@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ReaderUtils.java 18 3 3682 3593 3 2 2014-12-20 2015-03-19 kirpichov@google.com kirpichov@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/TimerOrElement.java 22 10 3689 3404 10 6 2014-12-13 2015-09-24 davor@google.com bchambers@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/GcsUtil.java 250 15 3689 3389 17 9 2014-12-13 2015-10-09 davor@google.com dhalperi@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/PCollectionViews.java 252 8 3497 3383 8 5 2015-06-23 2015-10-15 klk@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/BatchTimerInternals.java 67 3 3469 3453 3 1 2015-07-21 2015-08-06 bchambers@google.com bchambers@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/SizedSideInputReader.java 12 2 3495 3385 2 1 2015-06-25 2015-10-13 klk@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/IllegalMutationException.java 22 2 3454 3417 2 1 2015-08-05 2015-09-11 klk@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/MemoryMonitor.java 199 1 3362 3362 1 1 2015-11-05 2015-11-05 markshields@google.com markshields@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/InstanceBuilder.java 125 7 3689 3399 7 4 2014-12-13 2015-09-29 davor@google.com dhalperi@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ActiveWindowSet.java 17 4 3497 3377 4 2 2015-06-23 2015-10-21 bchambers@google.com dhalperi@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/MutationDetector.java 4 1 3454 3454 1 1 2015-08-05 2015-08-05 klk@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/DataflowReleaseInfo.java 48 2 3689 3612 2 2 2014-12-13 2015-02-28 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/Reshuffle.java 86 5 3466 3372 5 3 2015-07-24 2015-10-26 bchambers@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/WatermarkHold.java 60 9 3497 3417 9 3 2015-06-23 2015-09-11 bchambers@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/UploadIdResponseInterceptor.java 27 1 3464 3464 1 1 2015-07-26 2015-07-26 laraschmidt@google.com laraschmidt@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/Credentials.java 103 11 3689 3399 11 5 2014-12-13 2015-09-29 davor@google.com dhalperi@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/TimerInternals.java 62 2 3469 3442 2 2 2015-07-21 2015-08-17 bchambers@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ExposedByteArrayInputStream.java 25 2 3539 3483 2 2 2015-05-12 2015-07-07 davorbonaci@users.noreply.github.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/NonEmptyPanes.java 56 1 3450 3450 1 1 2015-08-09 2015-08-09 bchambers@google.com bchambers@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/SerializableUtils.java 93 6 3689 3399 6 4 2014-12-13 2015-09-29 davor@google.com dhalperi@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/WindowingStrategy.java 149 12 3576 3372 12 3 2015-04-05 2015-10-26 bchambers@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/AppliedCombineFn.java 44 2 3460 3417 2 2 2015-07-30 2015-09-11 bchambers@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/Stager.java 6 2 3641 3612 2 2 2015-01-30 2015-02-28 relax@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/Transport.java 108 11 3689 3454 13 9 2014-12-13 2015-08-05 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/TriggerRunner.java 115 7 3478 3389 7 2 2015-07-12 2015-10-09 bchambers@google.com bchambers@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/NullSideInputReader.java 30 1 3495 3495 1 1 2015-06-25 2015-06-25 klk@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/CloudMetricUtils.java 41 2 3689 3612 2 2 2014-12-13 2015-02-28 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/PackageUtil.java 196 15 3689 3430 15 7 2014-12-13 2015-08-29 davor@google.com dhalperi@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ExecutionContext.java 31 14 3689 3441 15 7 2014-12-13 2015-08-18 davor@google.com millsd@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/PTuple.java 48 5 3689 3442 5 4 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ReifyTimestampAndWindowsDoFn.java 21 7 3641 3417 9 6 2015-01-30 2015-09-11 peihe@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/IOChannelFactory.java 14 8 3689 3442 8 5 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/InMemoryStateInternals.java 207 4 3480 3450 5 1 2015-07-10 2015-08-09 bchambers@google.com bchambers@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/ValueState.java 8 1 3480 3480 1 1 2015-07-10 2015-07-10 bchambers@google.com bchambers@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/WatermarkStateInternal.java 6 2 3480 3442 2 2 2015-07-10 2015-08-17 bchambers@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/MergedWatermarkStateInternal.java 67 1 3473 3473 1 1 2015-07-17 2015-07-17 bchambers@google.com bchambers@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/StateTable.java 49 3 3480 3430 3 2 2015-07-10 2015-08-29 bchambers@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/CombiningValueState.java 4 1 3480 3480 1 1 2015-07-10 2015-07-10 bchambers@google.com bchambers@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/StateTag.java 21 3 3480 3442 3 2 2015-07-10 2015-08-17 bchambers@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/MergingStateInternals.java 61 2 3480 3473 2 1 2015-07-10 2015-07-17 bchambers@google.com bchambers@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/StateNamespaceForTest.java 26 1 3480 3480 1 1 2015-07-10 2015-07-10 bchambers@google.com bchambers@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/StateTags.java 253 8 3480 3397 8 3 2015-07-10 2015-10-01 bchambers@google.com bchambers@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/BagState.java 3 1 3480 3480 1 1 2015-07-10 2015-07-10 bchambers@google.com bchambers@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/StateNamespace.java 4 3 3480 3442 3 2 2015-07-10 2015-08-17 bchambers@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/StateContents.java 7 1 3480 3480 1 1 2015-07-10 2015-07-10 bchambers@google.com bchambers@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/StateInternals.java 7 3 3480 3442 3 2 2015-07-10 2015-08-17 bchambers@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/MergedCombiningValue.java 82 3 3480 3461 3 1 2015-07-10 2015-07-29 bchambers@google.com bchambers@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/StateNamespaces.java 161 4 3480 3467 4 1 2015-07-10 2015-07-23 bchambers@google.com bchambers@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/CombiningValueStateInternal.java 7 1 3480 3480 1 1 2015-07-10 2015-07-10 bchambers@google.com bchambers@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/State.java 4 1 3480 3480 1 1 2015-07-10 2015-07-10 bchambers@google.com bchambers@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/MergeableState.java 6 2 3480 3473 2 1 2015-07-10 2015-07-17 bchambers@google.com bchambers@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/MergedBag.java 59 3 3480 3473 3 1 2015-07-10 2015-07-17 bchambers@google.com bchambers@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/AppEngineEnvironment.java 24 4 3689 3442 4 2 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/TimeDomain.java 6 1 3469 3469 1 1 2015-07-21 2015-07-21 bchambers@google.com bchambers@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/NonMergingActiveWindowSet.java 37 3 3497 3389 3 1 2015-06-23 2015-10-09 bchambers@google.com bchambers@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/MimeTypes.java 5 2 3689 3612 2 2 2014-12-13 2015-02-28 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/DoFnInfo.java 36 8 3655 3417 8 6 2015-01-16 2015-09-11 millsd@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/BaseExecutionContext.java 74 3 3465 3441 3 3 2015-07-25 2015-08-18 klk@google.com millsd@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/DirectSideInputReader.java 43 1 3495 3495 1 1 2015-06-25 2015-06-25 klk@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/CloudKnownType.java 107 2 3689 3612 2 2 2014-12-13 2015-02-28 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/MapAggregatorValues.java 21 1 3429 3429 1 1 2015-08-30 2015-08-30 tgroh@google.com tgroh@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/CounterProvider.java 4 1 3557 3557 1 1 2015-04-24 2015-04-24 tgroh@google.com tgroh@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/Reiterator.java 5 2 3689 3612 2 2 2014-12-13 2015-02-28 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/ElementByteSizeObservable.java 7 2 3689 3612 2 2 2014-12-13 2015-02-28 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/PeekingReiterator.java 55 4 3689 3612 4 4 2014-12-13 2015-02-28 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/ForwardingReiterator.java 42 4 3689 3580 4 4 2014-12-13 2015-04-01 davor@google.com gildea@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/Metric.java 20 3 3689 3552 3 3 2014-12-13 2015-04-29 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/CounterSet.java 67 4 3689 3442 4 3 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/ElementByteSizeObserver.java 39 3 3689 3432 3 3 2014-12-13 2015-08-27 davor@google.com millsd@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/ElementByteSizeObservableIterable.java 22 3 3689 3550 3 3 2014-12-13 2015-05-01 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/Counter.java 705 12 3689 3417 15 8 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/TaggedReiteratorList.java 116 5 3628 3442 5 5 2015-02-12 2015-08-17 robertwb@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/Reiterable.java 5 2 3689 3612 2 2 2014-12-13 2015-02-28 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/ElementByteSizeObservableIterator.java 10 2 3689 3612 2 2 2014-12-13 2015-02-28 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/WorkExecutor.java 41 8 3689 3436 9 6 2014-12-13 2015-08-23 davor@google.com tudorm@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/FlattenOperation.java 34 3 3689 3612 3 3 2014-12-13 2015-02-28 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/StateSampler.java 175 11 3689 3386 11 6 2014-12-13 2015-10-12 davor@google.com zhouyunqing@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/WorkProgressUpdater.java 110 10 3689 3510 11 6 2014-12-13 2015-06-10 davor@google.com dhalperi@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/OutputReceiver.java 36 4 3689 3469 4 4 2014-12-13 2015-07-21 davor@google.com peihe@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/Receiver.java 4 2 3689 3612 2 2 2014-12-13 2015-02-28 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/ParDoFn.java 6 5 3689 3441 5 4 2014-12-13 2015-08-18 davor@google.com dhalperi@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/BatchingShuffleEntryReader.java 86 3 3689 3612 3 3 2014-12-13 2015-02-28 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/ShuffleEntryReader.java 10 3 3689 3580 3 3 2014-12-13 2015-04-01 davor@google.com gildea@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/ShufflePosition.java 3 2 3689 3612 2 2 2014-12-13 2015-02-28 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/Operation.java 77 10 3689 3410 10 6 2014-12-13 2015-09-18 davor@google.com zhouyunqing@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/ReceivingOperation.java 26 5 3689 3410 5 3 2014-12-13 2015-09-18 davor@google.com zhouyunqing@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/OutputObjectAndByteCounter.java 100 2 3469 3432 2 2 2015-07-21 2015-08-27 peihe@google.com millsd@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/AbstractBoundedReaderIterator.java 23 1 3488 3488 1 1 2015-07-02 2015-07-02 kirpichov@google.com kirpichov@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/Sink.java 17 8 3689 3410 8 5 2014-12-13 2015-09-18 davor@google.com zhouyunqing@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/ShuffleEntry.java 75 3 3689 3476 3 3 2014-12-13 2015-07-14 davor@google.com mariand@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/Reader.java 77 17 3682 3376 17 10 2014-12-20 2015-10-22 kirpichov@google.com robertwb@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/ShuffleBatchReader.java 18 2 3689 3612 2 2 2014-12-13 2015-02-28 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/KeyGroupedShuffleEntries.java 13 2 3689 3612 2 2 2014-12-13 2015-02-28 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/ReadOperation.java 186 22 3689 3369 24 11 2014-12-13 2015-10-29 davor@google.com robertwb@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/CachingShuffleBatchReader.java 117 3 3689 3580 3 3 2014-12-13 2015-04-01 davor@google.com gildea@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/ProgressTrackerGroup.java 28 3 3689 3580 3 3 2014-12-13 2015-04-01 davor@google.com gildea@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/ProgressTrackingReiterator.java 26 3 3689 3580 3 3 2014-12-13 2015-04-01 davor@google.com gildea@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/ParDoOperation.java 49 4 3689 3389 4 4 2014-12-13 2015-10-09 davor@google.com robertwb@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/ElementCounter.java 5 1 3469 3469 1 1 2015-07-21 2015-07-21 peihe@google.com peihe@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/ProgressTracker.java 5 2 3689 3612 2 2 2014-12-13 2015-02-28 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/MapTaskExecutor.java 72 12 3689 3410 12 8 2014-12-13 2015-09-18 davor@google.com zhouyunqing@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/WriteOperation.java 70 7 3689 3410 7 5 2014-12-13 2015-09-18 davor@google.com zhouyunqing@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/GroupingShuffleEntryIterator.java 145 6 3689 3430 6 6 2014-12-13 2015-08-29 davor@google.com malo@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/PartialGroupByKeyOperation.java 412 12 3689 3382 12 9 2014-12-13 2015-10-16 davor@google.com robertwb@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/package-info.java 1 2 3689 3612 2 2 2014-12-13 2015-02-28 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/package-info.java 1 2 3689 3612 2 2 2014-12-13 2015-02-28 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/ReflectHelpers.java 148 5 3599 3376 5 3 2015-03-13 2015-10-22 bchambers@google.com kak@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/NoopPathValidator.java 22 3 3641 3536 3 2 2015-01-30 2015-05-15 relax@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/RetryHttpRequestInitializer.java 124 9 3689 3454 10 8 2014-12-13 2015-08-05 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/gcsfs/package-info.java 1 2 3689 3612 2 2 2014-12-13 2015-02-28 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/gcsfs/GcsPath.java 400 8 3689 3399 9 8 2014-12-13 2015-09-29 davor@google.com dhalperi@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/FileIOChannelFactory.java 84 8 3689 3454 9 5 2014-12-13 2015-08-05 davor@google.com mattlang@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ValueWithRecordId.java 110 4 3469 3417 4 2 2015-07-21 2015-09-11 millsd@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/BigQueryTableRowIterator.java 294 10 3689 3389 10 5 2014-12-13 2015-10-09 davor@google.com dhalperi@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ShardingWritableByteChannel.java 52 4 3689 3442 4 3 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/TriggerContextFactory.java 377 4 3473 3378 5 1 2015-07-17 2015-10-20 bchambers@google.com bchambers@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/GroupAlsoByWindowsDoFn.java 74 37 3689 3389 44 9 2014-12-13 2015-10-09 davor@google.com bchambers@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/BigQueryTableInserter.java 240 11 3689 3390 12 8 2014-12-13 2015-10-08 davor@google.com dhalperi@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ReshuffleTrigger.java 31 1 3397 3397 1 1 2015-10-01 2015-10-01 bchambers@google.com bchambers@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/BoundedQueueExecutor.java 41 6 3636 3417 6 6 2015-02-04 2015-09-11 millsd@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ZipFiles.java 166 1 3430 3430 1 1 2015-08-29 2015-08-29 dhalperi@google.com dhalperi@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/AssignWindowsDoFn.java 36 11 3689 3417 12 7 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/TimeUtil.java 99 3 3689 3442 3 2 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ReduceFnRunner.java 452 13 3663 3389 15 4 2015-01-08 2015-10-09 bchambers@google.com bchambers@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/Sized.java 18 2 3495 3385 2 1 2015-06-25 2015-10-13 klk@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/MutationDetectors.java 75 1 3454 3454 1 1 2015-08-05 2015-08-05 klk@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/CoderUtils.java 196 18 3689 3417 18 9 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/OutputReference.java 16 2 3689 3612 2 2 2014-12-13 2015-02-28 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/CloudObject.java 77 4 3689 3442 4 3 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/WindowedValue.java 499 23 3689 3417 24 12 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ExecutableTrigger.java 135 6 3546 3378 8 2 2015-05-05 2015-10-20 bchambers@google.com bchambers@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/SystemReduceFn.java 71 9 3478 3417 9 2 2015-07-12 2015-09-11 bchambers@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/PropertyNames.java 78 13 3689 3477 14 10 2014-12-13 2015-07-13 vanya@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/SideInputReader.java 10 2 3495 3385 2 1 2015-06-25 2015-10-13 klk@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ReduceFnContextFactory.java 320 2 3473 3469 3 1 2015-07-17 2015-07-21 bchambers@google.com bchambers@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/Serializer.java 65 6 3689 3442 6 5 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ReduceFn.java 57 7 3473 3417 7 4 2015-07-17 2015-09-11 bchambers@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/Base64Utils.java 6 2 3689 3612 2 2 2014-12-13 2015-02-28 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/WindowingInternals.java 22 11 3580 3469 11 4 2015-04-01 2015-07-21 bchambers@google.com bchambers@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/GcsStager.java 28 4 3641 3490 4 3 2015-01-30 2015-06-30 relax@google.com millsd@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/BitSetCoder.java 32 2 3473 3417 2 2 2015-07-17 2015-09-11 bchambers@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/PaneInfoTracker.java 55 5 3478 3453 5 2 2015-07-12 2015-08-06 bchambers@google.com bchambers@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/BatchModeExecutionContext.java 70 18 3689 3431 18 7 2014-12-13 2015-08-28 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/CredentialFactory.java 7 2 3641 3612 2 2 2015-01-30 2015-02-28 relax@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/SystemDoFnInternal.java 11 1 3489 3489 1 1 2015-07-01 2015-07-01 bchambers@google.com bchambers@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/IntervalBoundedExponentialBackOff.java 38 2 3480 3442 2 2 2015-07-10 2015-08-17 malo@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/VarInt.java 61 4 3689 3442 4 3 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/TestCredential.java 25 3 3689 3612 3 3 2014-12-13 2015-02-28 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/CloudSourceUtils.java 34 6 3689 3406 6 5 2014-12-13 2015-09-22 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/GcsIOChannelFactory.java 53 4 3689 3544 4 3 2014-12-13 2015-05-07 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/package-info.java 1 2 3689 3612 2 2 2014-12-13 2015-02-28 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/AttemptBoundedExponentialBackOff.java 38 5 3689 3442 5 4 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/CloudCounterUtils.java 74 4 3689 3551 4 4 2014-12-13 2015-04-30 davor@google.com tgroh@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/CounterAggregator.java 53 3 3557 3442 3 3 2015-04-24 2015-08-17 tgroh@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/util/GroupAlsoByWindowsViaIteratorsDoFn.java 172 8 3584 3417 9 4 2015-03-28 2015-09-11 bchambers@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/io/Read.java 111 11 3573 3393 11 5 2015-04-08 2015-10-05 kirpichov@google.com kirpichov@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/io/AvroIO.java 315 20 3689 3377 20 12 2014-12-13 2015-10-21 davor@google.com dhalperi@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/io/XmlSource.java 299 11 3574 3399 11 6 2015-04-07 2015-09-29 chamikara@google.com dhalperi@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/io/UnboundedSource.java 50 7 3493 3417 8 4 2015-06-27 2015-09-11 millsd@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/io/AvroSource.java 367 6 3501 3392 7 5 2015-06-19 2015-10-06 mattlang@google.com mattlang@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/io/BoundedSource.java 30 13 3586 3417 13 7 2015-03-26 2015-09-11 kirpichov@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/io/XmlSink.java 108 6 3574 3389 6 4 2015-04-07 2015-10-09 chamikara@google.com dhalperi@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/io/OffsetBasedSource.java 135 3 3453 3417 3 3 2015-08-06 2015-09-11 kirpichov@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/io/Sink.java 27 8 3580 3389 9 4 2015-04-01 2015-10-09 mattlang@google.com dhalperi@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/io/DatastoreIO.java 487 34 3689 3389 42 16 2014-12-13 2015-10-09 davor@google.com dhalperi@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/io/CompressedSource.java 134 4 3519 3417 5 4 2015-06-01 2015-09-11 mattlang@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/io/ShardNameTemplate.java 5 4 3689 3442 4 3 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/io/BigQueryIO.java 764 42 3689 3370 47 20 2014-12-13 2015-10-28 davor@google.com dhalperi@users.noreply.github.com sdk/src/main/java/com/google/cloud/dataflow/sdk/io/BlockBasedSource.java 89 4 3501 3417 4 3 2015-06-19 2015-09-11 mattlang@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/io/TextIO.java 358 21 3689 3363 23 12 2014-12-13 2015-11-04 vanya@google.com robertwb@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/io/PubsubIO.java 524 32 3689 3362 35 15 2014-12-13 2015-11-05 davor@google.com peihe@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/io/Source.java 21 17 3662 3417 20 10 2015-01-09 2015-09-11 kirpichov@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/io/FileBasedSource.java 392 23 3599 3392 29 12 2015-03-13 2015-10-06 chamikara@google.com mattlang@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/io/Write.java 106 1 3389 3389 1 1 2015-10-09 2015-10-09 dhalperi@google.com dhalperi@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/io/FileBasedSink.java 372 6 3580 3417 7 4 2015-04-01 2015-09-11 mattlang@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/io/range/RangeTracker.java 8 1 3488 3488 1 1 2015-07-02 2015-07-02 kirpichov@google.com kirpichov@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/io/range/OffsetRangeTracker.java 120 2 3488 3442 2 2 2015-07-02 2015-08-17 kirpichov@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/io/range/package-info.java 1 1 3463 3463 1 1 2015-07-27 2015-07-27 kirpichov@google.com kirpichov@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/io/BoundedReadFromUnboundedSource.java 194 6 3468 3368 6 5 2015-07-22 2015-10-30 millsd@google.com dhalperi@users.noreply.github.com sdk/src/main/java/com/google/cloud/dataflow/sdk/io/package-info.java 1 4 3689 3580 4 3 2014-12-13 2015-04-01 davor@google.com gildea@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/values/TupleTagList.java 47 5 3689 3417 5 4 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/values/KV.java 75 12 3689 3417 13 6 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/values/PCollectionView.java 11 12 3689 3475 12 7 2014-12-13 2015-07-15 davor@google.com bchambers@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/values/PCollectionList.java 103 7 3689 3442 7 5 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/values/PValue.java 6 5 3689 3442 5 4 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/values/POutput.java 11 6 3689 3442 6 5 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/values/TypeDescriptor.java 114 6 3546 3417 6 3 2015-05-05 2015-09-11 klk@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/values/PBegin.java 35 7 3689 3442 7 5 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/values/TimestampedValue.java 97 12 3689 3417 12 6 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/values/PCollection.java 78 15 3689 3442 16 8 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/values/TypedPValue.java 95 9 3689 3419 10 5 2014-12-13 2015-09-09 davor@google.com dhalperi@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/values/POutputValueBase.java 29 6 3689 3442 7 5 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/values/PInput.java 8 5 3689 3442 5 4 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/values/PValueBase.java 62 7 3689 3442 7 5 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/values/TupleTag.java 84 10 3689 3417 10 6 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/values/PDone.java 16 3 3689 3556 3 3 2014-12-13 2015-04-25 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/values/package-info.java 1 4 3689 3442 4 2 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/values/PCollectionTuple.java 114 14 3689 3390 14 7 2014-12-13 2015-10-08 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/annotations/Experimental.java 26 3 3572 3456 3 3 2015-04-09 2015-08-03 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/annotations/package-info.java 1 1 3572 3572 1 1 2015-04-09 2015-04-09 davor@google.com davor@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/testing/TestDataflowPipelineOptions.java 4 2 3689 3612 2 2 2014-12-13 2015-02-28 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/testing/RunnableOnService.java 2 3 3689 3566 3 3 2014-12-13 2015-04-15 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/testing/DataflowAssert.java 428 29 3689 3417 32 12 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/testing/SerializableMatcher.java 5 2 3425 3417 2 1 2015-09-03 2015-09-11 klk@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/testing/WindowFnTestUtils.java 159 6 3647 3442 6 4 2015-01-24 2015-08-17 robertwb@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/testing/CoderProperties.java 229 7 3551 3442 7 3 2015-04-30 2015-08-17 klk@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/testing/SerializableMatchers.java 719 2 3425 3417 4 2 2015-09-03 2015-09-11 klk@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/testing/TestDataflowPipelineRunner.java 172 12 3689 3460 13 6 2014-12-13 2015-07-30 davor@google.com millsd@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/testing/TestPipeline.java 95 12 3689 3442 12 7 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/testing/package-info.java 1 3 3689 3612 3 2 2014-12-13 2015-02-28 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/testing/SourceTestUtils.java 436 1 3434 3434 1 1 2015-08-25 2015-08-25 kirpichov@google.com kirpichov@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Mean.java 102 15 3689 3417 15 8 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Values.java 21 6 3689 3417 6 5 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/IntraBundleParallelization.java 190 12 3582 3399 12 7 2015-03-30 2015-09-29 lcwik@google.com dhalperi@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/AggregatorRetriever.java 9 1 3530 3530 1 1 2015-05-21 2015-05-21 tgroh@google.com tgroh@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/join/CoGbkResult.java 313 17 3689 3399 17 10 2014-12-13 2015-09-29 davor@google.com dhalperi@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/join/KeyedPCollectionTuple.java 141 8 3689 3515 8 6 2014-12-13 2015-06-05 davor@google.com bchambers@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/join/RawUnionValue.java 19 4 3689 3612 4 4 2014-12-13 2015-02-28 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/join/UnionCoder.java 93 7 3689 3417 7 5 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/join/CoGroupByKey.java 101 9 3689 3417 9 6 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/join/CoGbkResultSchema.java 74 8 3689 3417 8 7 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/join/package-info.java 1 3 3689 3612 3 2 2014-12-13 2015-02-28 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/GroupByKey.java 304 35 3689 3363 40 13 2014-12-13 2015-11-04 davor@google.com tgroh@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Aggregator.java 7 8 3689 3442 8 6 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/DoFn.java 164 37 3689 3417 40 11 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/AppliedPTransform.java 62 5 3577 3509 5 2 2015-04-04 2015-06-11 robertwb@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/SerializableFunction.java 5 4 3689 3550 4 3 2014-12-13 2015-05-01 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Sample.java 118 11 3689 3417 11 6 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Flatten.java 108 21 3689 3417 21 10 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/PTransform.java 65 16 3689 3417 17 10 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/RemoveDuplicates.java 52 7 3689 3417 7 6 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Top.java 199 20 3689 3363 21 11 2014-12-13 2015-11-04 davor@google.com tgroh@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Keys.java 21 6 3689 3417 6 5 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Create.java 208 20 3689 3399 22 8 2014-12-13 2015-09-29 davor@google.com dhalperi@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Count.java 53 16 3689 3417 17 10 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/ParDo.java 461 43 3689 3406 46 17 2014-12-13 2015-09-22 davor@google.com kirpichov@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Sum.java 69 10 3689 3372 10 8 2014-12-13 2015-10-26 davor@google.com tgroh@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Combine.java 1076 56 3689 3363 60 15 2014-12-13 2015-11-04 davor@google.com tgroh@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/DoFnWithContext.java 84 9 3553 3404 10 5 2015-04-28 2015-09-24 bchambers@google.com millsd@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Max.java 104 13 3689 3417 13 8 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/SerializableComparator.java 5 3 3689 3566 3 3 2014-12-13 2015-04-15 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/MapElements.java 40 2 3407 3391 2 1 2015-09-21 2015-10-07 klk@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Min.java 104 14 3689 3417 14 8 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/View.java 177 29 3689 3392 31 12 2014-12-13 2015-10-06 davor@google.com peihe@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/WithKeys.java 55 9 3689 3417 9 5 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/ApproximateQuantiles.java 434 15 3689 3417 15 7 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Partition.java 71 9 3689 3412 9 5 2014-12-13 2015-09-16 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/KvSwap.java 22 7 3689 3417 7 5 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/AfterWatermark.java 360 23 3575 3362 32 8 2015-04-06 2015-11-05 bchambers@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/MergeOverlappingIntervalWindows.java 55 3 3689 3612 3 3 2014-12-13 2015-02-28 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/Window.java 271 37 3689 3377 40 12 2014-12-13 2015-10-21 davor@google.com dhalperi@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/Repeatedly.java 46 10 3575 3417 16 3 2015-04-06 2015-09-11 bchambers@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/InvalidWindows.java 44 6 3642 3417 6 6 2015-01-29 2015-09-11 wan@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/IntervalWindow.java 107 8 3689 3417 8 5 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/OrFinallyTrigger.java 52 5 3482 3358 5 3 2015-07-08 2015-11-09 bchambers@google.com millsd@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/AfterProcessingTime.java 110 17 3575 3417 25 6 2015-04-06 2015-09-11 bchambers@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/AfterFirst.java 66 11 3575 3417 15 4 2015-04-06 2015-09-11 bchambers@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/GlobalWindow.java 26 12 3689 3417 13 9 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/WindowFn.java 30 14 3647 3397 14 10 2015-01-24 2015-10-01 robertwb@google.com hokira@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/AfterSynchronizedProcessingTime.java 94 8 3490 3417 12 2 2015-06-30 2015-09-11 bchambers@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/AfterEach.java 81 14 3575 3417 20 5 2015-04-06 2015-09-11 bchambers@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/GlobalWindows.java 33 9 3642 3417 9 7 2015-01-29 2015-09-11 robertwb@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/FixedWindows.java 56 12 3689 3372 13 8 2014-12-13 2015-10-26 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/TimeTrigger.java 81 13 3575 3417 17 6 2015-04-06 2015-09-11 bchambers@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/DefaultTrigger.java 44 12 3575 3417 19 4 2015-04-06 2015-09-11 bchambers@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/TriggerBuilder.java 4 1 3397 3397 1 1 2015-10-01 2015-10-01 bchambers@google.com bchambers@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/Trigger.java 220 26 3575 3378 42 11 2015-04-06 2015-10-20 bchambers@google.com bchambers@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/AfterAll.java 67 12 3575 3417 16 4 2015-04-06 2015-09-11 bchambers@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/NonMergingWindowFn.java 10 6 3647 3417 6 6 2015-01-24 2015-09-11 robertwb@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/PaneInfo.java 198 8 3490 3417 8 4 2015-06-30 2015-09-11 robertwb@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/BoundedWindow.java 10 5 3689 3442 5 4 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/Sessions.java 55 14 3689 3372 15 9 2014-12-13 2015-10-26 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/CalendarWindows.java 203 10 3689 3417 11 9 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/PartitioningWindowFn.java 28 8 3647 3417 8 7 2015-01-24 2015-09-11 robertwb@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/package-info.java 1 5 3686 3442 5 4 2014-12-16 2015-08-17 fjp@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/SlidingWindows.java 109 16 3689 3372 17 10 2014-12-13 2015-10-26 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/AfterPane.java 96 16 3575 3417 22 4 2015-04-06 2015-09-11 bchambers@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Write.java 4 14 3580 3389 14 7 2015-04-01 2015-10-09 mattlang@google.com dhalperi@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/SimpleFunction.java 11 1 3411 3411 1 1 2015-09-17 2015-09-17 klk@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/DoFnReflector.java 476 6 3553 3404 6 4 2015-04-28 2015-09-24 bchambers@google.com millsd@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/FlatMapElements.java 59 3 3411 3390 3 2 2015-09-17 2015-10-08 klk@google.com dhalperi@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/DoFnTester.java 184 19 3689 3364 19 8 2014-12-13 2015-11-03 davor@google.com tgroh@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/package-info.java 1 6 3689 3442 6 4 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Filter.java 88 8 3644 3417 9 6 2015-01-27 2015-09-11 ananvay@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/ApproximateUnique.java 188 7 3689 3417 7 6 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/dataflow/ReadTranslator.java 10 4 3573 3393 4 2 2015-04-08 2015-10-05 kirpichov@google.com kirpichov@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/dataflow/DataflowAggregatorTransforms.java 43 1 3524 3524 1 1 2015-05-27 2015-05-27 tgroh@google.com tgroh@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/dataflow/CustomSources.java 539 2 3393 3376 2 2 2015-10-05 2015-10-22 kirpichov@google.com robertwb@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/dataflow/AvroIOTranslator.java 77 8 3689 3399 8 7 2014-12-13 2015-09-29 davor@google.com dhalperi@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/dataflow/TextIOTranslator.java 80 10 3689 3399 11 9 2014-12-13 2015-09-29 vanya@google.com dhalperi@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/dataflow/DataflowMetricUpdateExtractor.java 67 1 3524 3524 1 1 2015-05-27 2015-05-27 tgroh@google.com tgroh@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/dataflow/BigQueryIOTranslator.java 80 8 3689 3455 8 7 2014-12-13 2015-08-04 davor@google.com kirpichov@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/dataflow/PubsubIOTranslator.java 72 11 3689 3497 11 7 2014-12-13 2015-06-23 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/dataflow/package-info.java 1 3 3689 3612 3 2 2014-12-13 2015-02-28 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowJobAlreadyUpdatedException.java 7 2 3460 3417 2 2 2015-07-30 2015-09-11 lcwik@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowJobCancelledException.java 9 2 3468 3417 2 1 2015-07-22 2015-09-11 klk@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowJobExecutionException.java 11 2 3468 3417 2 1 2015-07-22 2015-09-11 klk@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/AggregatorPipelineExtractor.java 57 1 3530 3530 1 1 2015-05-21 2015-05-21 tgroh@google.com tgroh@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowPipeline.java 24 5 3689 3442 5 3 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowPipelineRegistrar.java 28 2 3685 3612 2 1 2014-12-17 2015-02-28 lcwik@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/TransformHierarchy.java 48 5 3689 3442 5 4 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowPipelineRunnerHooks.java 7 5 3689 3566 5 4 2014-12-13 2015-04-15 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/PipelineRunner.java 32 5 3689 3442 5 3 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowJobAlreadyExistsException.java 7 2 3460 3417 2 2 2015-07-30 2015-09-11 lcwik@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DirectPipelineRegistrar.java 23 2 3685 3612 2 1 2014-12-17 2015-02-28 lcwik@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/TransformTreeNode.java 127 7 3689 3442 7 5 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowPipelineJob.java 223 13 3689 3429 14 11 2014-12-13 2015-08-30 davor@google.com tgroh@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/BlockingDataflowPipelineRunner.java 108 15 3689 3442 16 8 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowPipelineRunner.java 796 65 3689 3368 76 21 2014-12-13 2015-10-30 davor@google.com sgmc@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowServiceException.java 10 2 3468 3417 2 1 2015-07-22 2015-09-11 klk@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowPipelineTranslator.java 714 53 3689 3363 63 24 2014-12-13 2015-11-04 vanya@google.com davor@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowJobException.java 13 2 3468 3417 2 1 2015-07-22 2015-09-11 klk@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DirectPipeline.java 24 4 3689 3529 4 3 2014-12-13 2015-05-22 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ParDoFnFactory.java 23 8 3689 3385 8 6 2014-12-13 2015-10-13 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ReaderFactory.java 98 15 3682 3393 15 9 2014-12-20 2015-10-05 kirpichov@google.com kirpichov@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/CombineValuesFn.java 188 14 3689 3417 16 8 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/DataflowWorkerHarness.java 235 21 3689 3393 22 10 2014-12-13 2015-10-05 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ShuffleWriter.java 7 2 3689 3612 2 2 2014-12-13 2015-02-28 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AvroSinkFactory.java 32 6 3689 3453 6 6 2014-12-13 2015-08-06 davor@google.com bchambers@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/GroupingShuffleReaderFactory.java 46 4 3682 3406 4 4 2014-12-20 2015-09-22 kirpichov@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/InMemoryReader.java 110 8 3682 3376 9 5 2014-12-20 2015-10-22 kirpichov@google.com robertwb@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ShuffleReader.java 14 2 3689 3612 2 2 2014-12-13 2015-02-28 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ParDoFnBase.java 161 9 3503 3389 9 4 2015-06-17 2015-10-09 klk@google.com robertwb@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/TextSinkFactory.java 32 3 3689 3481 3 3 2014-12-13 2015-07-09 davor@google.com mwegiel@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/DataflowWorkProgressUpdater.java 77 10 3689 3436 11 7 2014-12-13 2015-08-23 davor@google.com tudorm@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AssignWindowsParDoFn.java 95 11 3689 3441 12 8 2014-12-13 2015-08-18 davor@google.com millsd@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/StreamingDataflowWorker.java 862 45 3636 3362 50 16 2015-02-04 2015-11-05 millsd@google.com markshields@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/SideInputUtils.java 142 8 3689 3357 8 6 2014-12-13 2015-11-10 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/StreamingGroupAlsoByWindowsReshuffleDoFn.java 25 1 3397 3397 1 1 2015-10-01 2015-10-01 bchambers@google.com bchambers@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/PartitioningShuffleReader.java 77 6 3682 3399 6 5 2014-12-20 2015-09-29 kirpichov@google.com dhalperi@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ShuffleLibrary.java 19 2 3689 3612 2 2 2014-12-13 2015-02-28 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/LazyMultiReaderIterator.java 46 5 3682 3442 5 3 2014-12-20 2015-08-17 kirpichov@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ByteArrayShufflePosition.java 69 7 3689 3376 7 7 2014-12-13 2015-10-22 davor@google.com robertwb@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/PartitioningShuffleReaderFactory.java 43 3 3682 3406 3 3 2014-12-20 2015-09-22 kirpichov@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AvroSink.java 90 3 3689 3606 3 3 2014-12-13 2015-03-06 davor@google.com millsd@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/SinkFactory.java 55 9 3689 3417 9 7 2014-12-13 2015-09-11 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ChunkingShuffleEntryWriter.java 48 4 3689 3476 4 4 2014-12-13 2015-07-14 davor@google.com mariand@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ApplianceShuffleReader.java 23 5 3689 3442 5 4 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ChunkingShuffleBatchReader.java 52 5 3689 3441 5 5 2014-12-13 2015-08-18 davor@google.com dhalperi@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/GroupAlsoByWindowsParDoFn.java 222 25 3689 3382 28 8 2014-12-13 2015-10-16 davor@google.com robertwb@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/BigQueryReaderFactory.java 48 5 3682 3390 5 5 2014-12-20 2015-10-08 kirpichov@google.com dhalperi@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ShuffleSink.java 214 12 3689 3399 13 11 2014-12-13 2015-09-29 davor@google.com dhalperi@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/DataflowSideInputReader.java 83 2 3495 3385 2 1 2015-06-25 2015-10-13 klk@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/SourceTranslationUtils.java 101 8 3689 3393 8 3 2014-12-13 2015-10-05 davor@google.com kirpichov@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/windmill/WindmillServerStub.java 9 2 3636 3612 2 2 2015-02-04 2015-02-28 millsd@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/MapTaskExecutorFactory.java 401 27 3689 3376 27 13 2014-12-13 2015-10-22 davor@google.com robertwb@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/DataflowOutputCounter.java 55 1 3469 3469 1 1 2015-07-21 2015-07-21 peihe@google.com peihe@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/CopyableSeekableByteChannel.java 149 2 3689 3612 2 2 2014-12-13 2015-02-28 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ApplianceShuffleWriter.java 26 5 3689 3442 5 4 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/FileBasedReader.java 225 11 3682 3371 13 7 2014-12-20 2015-10-27 kirpichov@google.com robertwb@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AvroReaderFactory.java 44 5 3682 3392 5 5 2014-12-20 2015-10-06 kirpichov@google.com mattlang@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AvroByteSink.java 46 3 3689 3612 3 3 2014-12-13 2015-02-28 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/WindmillSink.java 138 8 3636 3404 8 6 2015-02-04 2015-09-24 millsd@google.com bchambers@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/SourceOperationExecutorFactory.java 11 3 3689 3612 3 3 2014-12-13 2015-02-28 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ShuffleEntryWriter.java 10 3 3689 3476 3 3 2014-12-13 2015-07-14 davor@google.com mariand@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/CachingSideInputReader.java 53 2 3495 3385 2 1 2015-06-25 2015-10-13 klk@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ReifyTimestampAndWindowsParDoFn.java 80 6 3641 3441 6 4 2015-01-30 2015-08-18 peihe@google.com millsd@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/SizedWeigher.java 20 2 3495 3385 2 1 2015-06-25 2015-10-13 klk@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/BigQueryReader.java 86 10 3682 3389 10 6 2014-12-20 2015-10-09 kirpichov@google.com dhalperi@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/GroupingShuffleReader.java 288 18 3682 3376 18 10 2014-12-20 2015-10-22 kirpichov@google.com robertwb@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/DataflowWorker.java 343 27 3689 3385 29 15 2014-12-13 2015-10-13 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/OrderedCode.java 397 5 3689 3442 5 4 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/TextReaderFactory.java 44 4 3682 3406 4 4 2014-12-20 2015-09-22 kirpichov@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/TextReader.java 271 6 3682 3371 6 5 2014-12-20 2015-10-27 kirpichov@google.com robertwb@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/UngroupedShuffleReaderFactory.java 35 3 3682 3406 3 3 2014-12-20 2015-09-22 kirpichov@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AvroByteReader.java 59 5 3682 3389 5 3 2014-12-20 2015-10-09 kirpichov@google.com mattlang@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AvroReader.java 122 7 3682 3392 7 5 2014-12-20 2015-10-06 kirpichov@google.com mattlang@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/WindmillStateInternals.java 415 3 3430 3382 3 3 2015-08-29 2015-10-16 klk@google.com robertwb@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/PubsubReader.java 76 6 3636 3406 6 5 2015-02-04 2015-09-22 millsd@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/StreamingModeExecutionContext.java 400 7 3430 3393 8 5 2015-08-29 2015-10-05 klk@google.com kirpichov@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/DefaultParDoFnFactory.java 54 1 3385 3385 1 1 2015-10-13 2015-10-13 klk@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/NormalParDoFn.java 129 14 3689 3441 16 9 2014-12-13 2015-08-18 davor@google.com millsd@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/KeyedWorkItem.java 176 1 3404 3404 1 1 2015-09-24 2015-09-24 bchambers@google.com bchambers@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/SourceOperationExecutor.java 52 8 3689 3393 8 6 2014-12-13 2015-10-05 davor@google.com kirpichov@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/GroupingShuffleRangeTracker.java 120 3 3488 3431 3 3 2015-07-02 2015-08-28 kirpichov@google.com dhalperi@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/TextSink.java 206 5 3689 3442 5 3 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/UngroupedShuffleReader.java 55 5 3682 3399 5 4 2014-12-20 2015-09-29 kirpichov@google.com dhalperi@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/DataflowExecutionContext.java 11 3 3495 3385 3 1 2015-06-25 2015-10-13 klk@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/WindowingWindmillReader.java 84 11 3636 3404 11 5 2015-02-04 2015-09-24 millsd@google.com bchambers@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/UngroupedWindmillReader.java 99 6 3636 3406 6 4 2015-02-04 2015-09-22 millsd@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/PubsubSink.java 87 7 3636 3430 7 5 2015-02-04 2015-08-29 millsd@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/StreamingSideInputDoFnRunner.java 222 2 3430 3417 2 2 2015-08-29 2015-09-11 klk@google.com bchambers@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/StateFetcher.java 163 2 3430 3419 2 2 2015-08-29 2015-09-09 klk@google.com millsd@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/WindmillStateReader.java 334 2 3430 3419 2 2 2015-08-29 2015-09-09 klk@google.com millsd@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/UserCodeTimeTracker.java 75 2 3417 3410 2 1 2015-09-11 2015-09-18 zhouyunqing@google.com zhouyunqing@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ShuffleSinkFactory.java 34 3 3689 3481 3 3 2014-12-13 2015-07-09 davor@google.com mwegiel@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/logging/JulLoggerPrintStreamAdapterFactory.java 82 1 3445 3445 1 1 2015-08-14 2015-08-14 lcwik@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/logging/DataflowWorkerLoggingMDC.java 38 1 3480 3480 1 1 2015-07-10 2015-07-10 colinreid@google.com colinreid@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/logging/DataflowWorkerLoggingInitializer.java 88 12 3689 3386 14 6 2014-12-13 2015-10-12 davor@google.com herohde@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/logging/DataflowWorkerLoggingHandler.java 162 3 3480 3386 3 3 2015-07-10 2015-10-12 colinreid@google.com herohde@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/StreamingGroupAlsoByWindowsDoFn.java 70 5 3430 3389 5 2 2015-08-29 2015-10-09 klk@google.com bchambers@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/InMemoryReaderFactory.java 31 3 3682 3406 3 3 2014-12-20 2015-09-22 kirpichov@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/package-info.java 3 3 3689 3612 3 2 2014-12-13 2015-02-28 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/MetricTrackingWindmillServerStub.java 40 2 3475 3362 2 2 2015-07-15 2015-11-05 bchambers@google.com markshields@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ConcatReader.java 176 7 3518 3399 7 6 2015-06-02 2015-09-29 chamikara@google.com dhalperi@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ConcatReaderFactory.java 107 3 3518 3406 3 3 2015-06-02 2015-09-22 chamikara@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/AggregatorValues.java 15 1 3524 3524 1 1 2015-05-27 2015-05-27 tgroh@google.com tgroh@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DirectPipelineRunner.java 564 34 3689 3377 35 10 2014-12-13 2015-10-21 davor@google.com tgroh@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/PipelineRunnerRegistrar.java 5 4 3685 3442 4 2 2014-12-17 2015-08-17 lcwik@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/AggregatorRetrievalException.java 7 2 3524 3417 2 2 2015-05-27 2015-09-11 tgroh@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowJobUpdatedException.java 16 2 3468 3417 2 1 2015-07-22 2015-09-11 klk@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/RecordingPipelineVisitor.java 24 5 3689 3442 5 4 2014-12-13 2015-08-17 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/package-info.java 1 3 3689 3612 3 2 2014-12-13 2015-02-28 davor@google.com lcwik@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/PipelineResult.java 30 5 3689 3468 5 4 2014-12-13 2015-07-22 davor@google.com klk@google.com sdk/src/main/java/com/google/cloud/dataflow/sdk/package-info.java 1 5 3689 3442 5 3 2014-12-13 2015-08-17 davor@google.com lcwik@google.com