spotify / DataflowJavaSDK
File Change Frequency

File change frequency (churn) shows the distribution of file updates (days with at least one commit).

Overview
File Change Frequency Overall
  • There are 501 files with 51,322 lines of code.
    • 0 files changed more than 100 times (0 lines of code)
    • 3 files changed 51-100 times (2,586 lines of code)
    • 29 files changed 21-50 times (10,707 lines of code)
    • 207 files changed 6-20 times (23,373 lines of code)
    • 262 files changed 1-5 times (14,656 lines of code)
0% | 5% | 20% | 45% | 28%
Legend:
101+
51-100
21-50
6-20
1-5

explore: grouped by folders | grouped by update frequency | data
Contributors Count Frequency Overall
  • There are 501 files with 51,322 lines of code.
    • 0 files changed by more than 25 contributors (0 lines of code)
    • 29 files changed by 11-25 contributors (12,031 lines of code)
    • 120 files changed by 6-10 contributors (15,147 lines of code)
    • 273 files changed by 2-5 contributors (20,005 lines of code)
    • 79 files changed by 1 contributor (4,139 lines of code)
0% | 23% | 29% | 38% | 8%
Legend:
26+
11-25
6-10
2-5
1

explore: grouped by folders | grouped by contributors count | data
File Change Frequency per File Extension
java, xml, md, txt, properties, proto, sh, gitignore, avsc, json, gitattributes, yaml
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
java0% | 5% | 20% | 45% | 28%
proto0% | 0% | 88% | 0% | 11%
xml0% | 0% | 0% | 0% | 100%
File Change Frequency per Logical Decomposition
primary
primary (file change frequency)
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
sdk0% | 5% | 21% | 46% | 27%
contrib0% | 0% | 0% | 0% | 100%
maven-archetypes0% | 0% | 0% | 0% | 100%
Most Frequently Changed Files (Top 50)

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
DataflowPipelineRunner.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners
 796 60 2014-12-13 2015-10-30 65 21 davor@google.com sgmc@google.com
Combine.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms
 1076 110 2014-12-13 2015-11-04 56 15 davor@google.com tgroh@google.com
DataflowPipelineTranslator.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners
 714 44 2014-12-13 2015-11-04 53 24 vanya@google.com davor@google.com
StreamingDataflowWorker.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 862 41 2015-02-04 2015-11-05 45 16 millsd@google.com markshields@google.com
ParDo.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms
 461 45 2014-12-13 2015-09-22 43 17 davor@google.com kirpichov@google.com
BigQueryIO.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/io
 764 78 2014-12-13 2015-10-28 42 20 davor@google.com dhalperi@users.noreply.gith...
DoFnRunner.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 434 37 2014-12-13 2015-10-12 41 14 davor@google.com dhalperi@google.com
GroupAlsoByWindowsDoFn.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 74 2 2014-12-13 2015-10-09 37 9 davor@google.com bchambers@google.com
DoFn.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms
 164 17 2014-12-13 2015-09-11 37 11 davor@google.com klk@google.com
Window.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing
 271 32 2014-12-13 2015-10-21 37 12 davor@google.com dhalperi@google.com
GroupByKey.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms
 304 18 2014-12-13 2015-11-04 35 13 davor@google.com tgroh@google.com
DatastoreIO.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/io
 487 49 2014-12-13 2015-10-09 34 16 davor@google.com dhalperi@google.com
DirectPipelineRunner.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners
 564 56 2014-12-13 2015-10-21 34 10 davor@google.com tgroh@google.com
PubsubIO.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/io
 524 56 2014-12-13 2015-11-05 32 15 davor@google.com peihe@google.com
CoderRegistry.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/coders
 468 26 2014-12-13 2015-10-21 30 8 davor@google.com dhalperi@google.com
View.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms
 177 25 2014-12-13 2015-10-06 29 12 davor@google.com peihe@google.com
DataflowAssert.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/testing
 428 44 2014-12-13 2015-09-11 29 12 davor@google.com klk@google.com
DataflowWorker.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 343 17 2014-12-13 2015-10-13 27 15 davor@google.com klk@google.com
MapTaskExecutorFactory.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 401 29 2014-12-13 2015-10-22 27 13 davor@google.com robertwb@google.com
Trigger.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing
 220 21 2015-04-06 2015-10-20 26 11 bchambers@google.com bchambers@google.com
DataflowPipelineWorkerPoolOptions.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/options
 80 4 2014-12-13 2015-11-04 25 11 davor@google.com davor@google.com
GroupAlsoByWindowsParDoFn.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 222 11 2014-12-13 2015-10-16 25 8 davor@google.com robertwb@google.com
PipelineOptionsFactory.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/options
 837 42 2014-12-13 2015-08-17 24 13 davor@google.com lcwik@google.com
AfterWatermark.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing
 360 44 2015-04-06 2015-11-05 23 8 bchambers@google.com klk@google.com
FileBasedSource.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/io
 392 30 2015-03-13 2015-10-06 23 12 chamikara@google.com mattlang@google.com
WindowedValue.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 499 65 2014-12-13 2015-09-11 23 12 davor@google.com klk@google.com
ReadOperation.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker
 186 14 2014-12-13 2015-10-29 22 11 davor@google.com robertwb@google.com
Flatten.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms
 108 8 2014-12-13 2015-09-11 21 10 davor@google.com klk@google.com
Pipeline.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk
 223 22 2014-12-13 2015-09-11 21 9 davor@google.com klk@google.com
DataflowWorkerHarness.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 235 11 2014-12-13 2015-10-05 21 10 davor@google.com lcwik@google.com
proto
windmill.proto
in sdk/src/main/proto
 261 - 2015-02-03 2015-11-06 21 8 millsd@google.com aneeshnaman@google.com
TextIO.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/io
 358 52 2014-12-13 2015-11-04 21 12 vanya@google.com robertwb@google.com
Top.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms
 199 17 2014-12-13 2015-11-04 20 11 davor@google.com tgroh@google.com
Create.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms
 208 17 2014-12-13 2015-09-29 20 8 davor@google.com dhalperi@google.com
AvroIO.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/io
 315 52 2014-12-13 2015-10-21 20 12 davor@google.com dhalperi@google.com
DoFnTester.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms
 184 18 2014-12-13 2015-11-03 19 8 davor@google.com tgroh@google.com
BatchModeExecutionContext.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 70 11 2014-12-13 2015-08-28 18 7 davor@google.com klk@google.com
DataflowPipelineDebugOptions.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/options
 122 3 2014-12-13 2015-08-17 18 9 davor@google.com lcwik@google.com
StandardCoder.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/coders
 145 14 2014-12-13 2015-09-11 18 11 davor@google.com klk@google.com
CoderUtils.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 196 18 2014-12-13 2015-09-11 18 9 davor@google.com klk@google.com
GroupingShuffleReader.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 288 17 2014-12-20 2015-10-22 18 10 kirpichov@google.com robertwb@google.com
Source.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/io
 21 - 2015-01-09 2015-09-11 17 10 kirpichov@google.com klk@google.com
Reader.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker
 77 13 2014-12-20 2015-10-22 17 10 kirpichov@google.com robertwb@google.com
AfterProcessingTime.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing
 110 15 2015-04-06 2015-09-11 17 6 bchambers@google.com klk@google.com
CoGbkResult.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/join
 313 30 2014-12-13 2015-09-29 17 10 davor@google.com dhalperi@google.com
AvroCoder.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/coders
 390 33 2014-12-13 2015-10-06 17 7 davor@google.com mattlang@google.com
Count.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms
 53 7 2014-12-13 2015-09-11 16 10 davor@google.com klk@google.com
PTransform.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms
 65 12 2014-12-13 2015-09-11 16 10 davor@google.com klk@google.com
AfterPane.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing
 96 15 2015-04-06 2015-09-11 16 4 bchambers@google.com klk@google.com
SlidingWindows.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing
 109 16 2014-12-13 2015-10-26 16 10 davor@google.com klk@google.com
Files With Most Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
DataflowPipelineTranslator.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners
 714 44 2014-12-13 2015-11-04 53 24 vanya@google.com davor@google.com
DataflowPipelineRunner.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners
 796 60 2014-12-13 2015-10-30 65 21 davor@google.com sgmc@google.com
BigQueryIO.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/io
 764 78 2014-12-13 2015-10-28 42 20 davor@google.com dhalperi@users.noreply.gith...
ParDo.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms
 461 45 2014-12-13 2015-09-22 43 17 davor@google.com kirpichov@google.com
StreamingDataflowWorker.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 862 41 2015-02-04 2015-11-05 45 16 millsd@google.com markshields@google.com
DatastoreIO.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/io
 487 49 2014-12-13 2015-10-09 34 16 davor@google.com dhalperi@google.com
Combine.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms
 1076 110 2014-12-13 2015-11-04 56 15 davor@google.com tgroh@google.com
PubsubIO.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/io
 524 56 2014-12-13 2015-11-05 32 15 davor@google.com peihe@google.com
DataflowWorker.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 343 17 2014-12-13 2015-10-13 27 15 davor@google.com klk@google.com
DoFnRunner.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 434 37 2014-12-13 2015-10-12 41 14 davor@google.com dhalperi@google.com
GroupByKey.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms
 304 18 2014-12-13 2015-11-04 35 13 davor@google.com tgroh@google.com
MapTaskExecutorFactory.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 401 29 2014-12-13 2015-10-22 27 13 davor@google.com robertwb@google.com
PipelineOptionsFactory.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/options
 837 42 2014-12-13 2015-08-17 24 13 davor@google.com lcwik@google.com
Window.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing
 271 32 2014-12-13 2015-10-21 37 12 davor@google.com dhalperi@google.com
DataflowAssert.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/testing
 428 44 2014-12-13 2015-09-11 29 12 davor@google.com klk@google.com
View.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms
 177 25 2014-12-13 2015-10-06 29 12 davor@google.com peihe@google.com
WindowedValue.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 499 65 2014-12-13 2015-09-11 23 12 davor@google.com klk@google.com
FileBasedSource.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/io
 392 30 2015-03-13 2015-10-06 23 12 chamikara@google.com mattlang@google.com
TextIO.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/io
 358 52 2014-12-13 2015-11-04 21 12 vanya@google.com robertwb@google.com
AvroIO.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/io
 315 52 2014-12-13 2015-10-21 20 12 davor@google.com dhalperi@google.com
DoFn.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms
 164 17 2014-12-13 2015-09-11 37 11 davor@google.com klk@google.com
Trigger.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing
 220 21 2015-04-06 2015-10-20 26 11 bchambers@google.com bchambers@google.com
DataflowPipelineWorkerPoolOptions.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/options
 80 4 2014-12-13 2015-11-04 25 11 davor@google.com davor@google.com
ReadOperation.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker
 186 14 2014-12-13 2015-10-29 22 11 davor@google.com robertwb@google.com
Top.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms
 199 17 2014-12-13 2015-11-04 20 11 davor@google.com tgroh@google.com
StandardCoder.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/coders
 145 14 2014-12-13 2015-09-11 18 11 davor@google.com klk@google.com
DataflowPipelineJob.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners
 223 14 2014-12-13 2015-08-30 13 11 davor@google.com tgroh@google.com
ShuffleSink.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 214 6 2014-12-13 2015-09-29 12 11 davor@google.com dhalperi@google.com
MonitoringUtil.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 157 8 2014-12-13 2015-07-22 9 11 davor@google.com klk@google.com
DirectPipelineRunner.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners
 564 56 2014-12-13 2015-10-21 34 10 davor@google.com tgroh@google.com
Flatten.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms
 108 8 2014-12-13 2015-09-11 21 10 davor@google.com klk@google.com
DataflowWorkerHarness.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 235 11 2014-12-13 2015-10-05 21 10 davor@google.com lcwik@google.com
GroupingShuffleReader.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 288 17 2014-12-20 2015-10-22 18 10 kirpichov@google.com robertwb@google.com
Reader.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker
 77 13 2014-12-20 2015-10-22 17 10 kirpichov@google.com robertwb@google.com
Source.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/io
 21 - 2015-01-09 2015-09-11 17 10 kirpichov@google.com klk@google.com
CoGbkResult.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/join
 313 30 2014-12-13 2015-09-29 17 10 davor@google.com dhalperi@google.com
PTransform.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms
 65 12 2014-12-13 2015-09-11 16 10 davor@google.com klk@google.com
Count.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms
 53 7 2014-12-13 2015-09-11 16 10 davor@google.com klk@google.com
SlidingWindows.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing
 109 16 2014-12-13 2015-10-26 16 10 davor@google.com klk@google.com
DataflowPipelineOptions.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/options
 59 1 2014-12-13 2015-10-09 14 10 davor@google.com bchambers@google.com
WindowFn.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing
 30 2 2015-01-24 2015-10-01 14 10 robertwb@google.com hokira@google.com
PropertyNames.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 78 - 2014-12-13 2015-07-13 13 10 vanya@google.com klk@google.com
GroupAlsoByWindowsDoFn.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 74 2 2014-12-13 2015-10-09 37 9 davor@google.com bchambers@google.com
Pipeline.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk
 223 22 2014-12-13 2015-09-11 21 9 davor@google.com klk@google.com
DataflowPipelineDebugOptions.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/options
 122 3 2014-12-13 2015-08-17 18 9 davor@google.com lcwik@google.com
CoderUtils.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 196 18 2014-12-13 2015-09-11 18 9 davor@google.com klk@google.com
GcsUtil.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 250 14 2014-12-13 2015-10-09 15 9 davor@google.com dhalperi@google.com
ReaderFactory.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 98 1 2014-12-20 2015-10-05 15 9 kirpichov@google.com kirpichov@google.com
Sessions.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing
 55 11 2014-12-13 2015-10-26 14 9 davor@google.com klk@google.com
NormalParDoFn.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 129 4 2014-12-13 2015-08-18 14 9 davor@google.com millsd@google.com
Files With Least Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
SourceTestUtils.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/testing
 436 18 2015-08-25 2015-08-25 1 1 kirpichov@google.com kirpichov@google.com
TriggerContextFactory.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 377 42 2015-07-17 2015-10-20 4 1 bchambers@google.com bchambers@google.com
ReduceFnContextFactory.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 320 45 2015-07-17 2015-07-21 2 1 bchambers@google.com bchambers@google.com
InMemoryStateInternals.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state
 207 27 2015-07-10 2015-08-09 4 1 bchambers@google.com bchambers@google.com
MemoryMonitor.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 199 13 2015-11-05 2015-11-05 1 1 markshields@google.com markshields@google.com
KeyedWorkItem.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 176 17 2015-09-24 2015-09-24 1 1 bchambers@google.com bchambers@google.com
ZipFiles.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 166 11 2015-08-29 2015-08-29 1 1 dhalperi@google.com dhalperi@google.com
StateNamespaces.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state
 161 22 2015-07-10 2015-07-23 4 1 bchambers@google.com bchambers@google.com
Write.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/io
 106 5 2015-10-09 2015-10-09 1 1 dhalperi@google.com dhalperi@google.com
CoderProviders.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/coders
 93 9 2015-08-26 2015-09-17 2 1 klk@google.com klk@google.com
DataflowSideInputReader.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 83 8 2015-06-25 2015-10-13 2 1 klk@google.com klk@google.com
MergedCombiningValue.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state
 82 7 2015-07-10 2015-07-29 3 1 bchambers@google.com bchambers@google.com
JulLoggerPrintStreamAdapterFactory.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/logging
 82 6 2015-08-14 2015-08-14 1 1 lcwik@google.com lcwik@google.com
MutationDetectors.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 75 10 2015-08-05 2015-08-05 1 1 klk@google.com klk@google.com
UserCodeTimeTracker.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 75 7 2015-09-11 2015-09-18 2 1 zhouyunqing@google.com zhouyunqing@google.com
BatchTimerInternals.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 67 10 2015-07-21 2015-08-06 3 1 bchambers@google.com bchambers@google.com
MergedWatermarkStateInternal.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state
 67 5 2015-07-17 2015-07-17 1 1 bchambers@google.com bchambers@google.com
DataflowMetricUpdateExtractor.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/dataflow
 67 4 2015-05-27 2015-05-27 1 1 tgroh@google.com tgroh@google.com
ExposedByteArrayOutputStream.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 61 5 2015-04-30 2015-04-30 1 1 zhouyunqing@google.com zhouyunqing@google.com
MergingStateInternals.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state
 61 4 2015-07-10 2015-07-17 2 1 bchambers@google.com bchambers@google.com
MergedBag.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state
 59 5 2015-07-10 2015-07-17 3 1 bchambers@google.com bchambers@google.com
AggregatorPipelineExtractor.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners
 57 7 2015-05-21 2015-05-21 1 1 tgroh@google.com tgroh@google.com
NonEmptyPanes.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 56 8 2015-08-09 2015-08-09 1 1 bchambers@google.com bchambers@google.com
DataflowOutputCounter.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 55 7 2015-07-21 2015-07-21 1 1 peihe@google.com peihe@google.com
DefaultParDoFnFactory.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 54 2 2015-10-13 2015-10-13 1 1 klk@google.com klk@google.com
CachingSideInputReader.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 53 5 2015-06-25 2015-10-13 2 1 klk@google.com klk@google.com
DirectSideInputReader.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 43 5 2015-06-25 2015-06-25 1 1 klk@google.com klk@google.com
DataflowAggregatorTransforms.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/dataflow
 43 4 2015-05-27 2015-05-27 1 1 tgroh@google.com tgroh@google.com
MapElements.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms
 40 4 2015-09-21 2015-10-07 2 1 klk@google.com klk@google.com
DataflowWorkerLoggingMDC.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/logging
 38 10 2015-07-10 2015-07-10 1 1 colinreid@google.com colinreid@google.com
NonMergingActiveWindowSet.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 37 8 2015-06-23 2015-10-09 3 1 bchambers@google.com bchambers@google.com
proto
 35 - 2015-02-06 2015-02-06 1 1 davor@google.com davor@google.com
PCollectionViewWindow.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 34 6 2015-06-25 2015-06-25 1 1 klk@google.com klk@google.com
ReshuffleTrigger.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 31 5 2015-10-01 2015-10-01 1 1 bchambers@google.com bchambers@google.com
NullSideInputReader.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 30 6 2015-06-25 2015-06-25 1 1 klk@google.com klk@google.com
DataflowPipelineRegistrar.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners
 28 1 2014-12-17 2015-02-28 2 1 lcwik@google.com lcwik@google.com
UploadIdResponseInterceptor.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 27 1 2015-07-26 2015-07-26 1 1 laraschmidt@google.com laraschmidt@google.com
StateNamespaceForTest.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state
 26 4 2015-07-10 2015-07-10 1 1 bchambers@google.com bchambers@google.com
StreamingGroupAlsoByWindowsReshuffleDoFn.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 25 2 2015-10-01 2015-10-01 1 1 bchambers@google.com bchambers@google.com
AbstractBoundedReaderIterator.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker
 23 2 2015-07-02 2015-07-02 1 1 kirpichov@google.com kirpichov@google.com
DirectPipelineRegistrar.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners
 23 1 2014-12-17 2015-02-28 2 1 lcwik@google.com lcwik@google.com
IllegalMutationException.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 22 4 2015-08-05 2015-09-11 2 1 klk@google.com klk@google.com
MapAggregatorValues.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 21 3 2015-08-30 2015-08-30 1 1 tgroh@google.com tgroh@google.com
archetype-metadata.xml
in maven-archetypes/starter/src/main/resources/META-INF/maven
 20 - 2015-08-26 2015-08-26 1 1 bchambers@google.com bchambers@google.com
SizedWeigher.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 20 3 2015-06-25 2015-10-13 2 1 klk@google.com klk@google.com
DataflowProfilingOptions.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/options
 19 - 2015-10-09 2015-10-09 1 1 bchambers@google.com bchambers@google.com
Sized.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 18 4 2015-06-25 2015-10-13 2 1 klk@google.com klk@google.com
DataflowJobUpdatedException.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners
 16 3 2015-07-22 2015-09-11 2 1 klk@google.com klk@google.com
AggregatorValues.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners
 15 2 2015-05-27 2015-05-27 1 1 tgroh@google.com tgroh@google.com
DataflowJobException.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners
 13 1 2015-07-22 2015-09-11 2 1 klk@google.com klk@google.com
Correlations

File Size vs. Number of Changes: 502 points

contrib/hadoop/src/main/java/com/google/cloud/dataflow/contrib/hadoop/HadoopFileSource.java x: 341 lines of code y: 3 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/GroupingShuffleReader.java x: 288 lines of code y: 18 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/GroupingShuffleEntryIterator.java x: 145 lines of code y: 6 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/SideInputUtils.java x: 142 lines of code y: 8 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/OrFinallyTrigger.java x: 52 lines of code y: 5 # changes sdk/src/main/proto/windmill.proto x: 261 lines of code y: 21 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/AfterWatermark.java x: 360 lines of code y: 23 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/io/PubsubIO.java x: 524 lines of code y: 32 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/MetricTrackingWindmillServerStub.java x: 40 lines of code y: 2 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/StreamingDataflowWorker.java x: 862 lines of code y: 45 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/MemoryMonitor.java x: 199 lines of code y: 1 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Combine.java x: 1076 lines of code y: 56 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/GroupByKey.java x: 304 lines of code y: 35 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Top.java x: 199 lines of code y: 20 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/options/DataflowPipelineWorkerPoolOptions.java x: 80 lines of code y: 25 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowPipelineTranslator.java x: 714 lines of code y: 53 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/io/TextIO.java x: 358 lines of code y: 21 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/DoFnTester.java x: 184 lines of code y: 19 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowPipelineJob.java x: 223 lines of code y: 13 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DirectPipelineRunner.java x: 564 lines of code y: 34 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/MapAggregatorValues.java x: 21 lines of code y: 1 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ApiSurface.java x: 333 lines of code y: 5 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowPipelineRunner.java x: 796 lines of code y: 65 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/ReadOperation.java x: 186 lines of code y: 22 # changes contrib/hadoop/src/main/java/com/google/cloud/dataflow/contrib/hadoop/WritableCoder.java x: 64 lines of code y: 2 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/io/BoundedReadFromUnboundedSource.java x: 194 lines of code y: 6 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/FileBasedReader.java x: 225 lines of code y: 11 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/TextReader.java x: 271 lines of code y: 6 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Sum.java x: 69 lines of code y: 10 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/FixedWindows.java x: 56 lines of code y: 12 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/Sessions.java x: 55 lines of code y: 14 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/SlidingWindows.java x: 109 lines of code y: 16 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/Reshuffle.java x: 86 lines of code y: 5 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/WindowingStrategy.java x: 149 lines of code y: 12 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/ReflectHelpers.java x: 148 lines of code y: 5 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/dataflow/CustomSources.java x: 539 lines of code y: 2 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ByteArrayShufflePosition.java x: 69 lines of code y: 7 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/InMemoryReader.java x: 110 lines of code y: 8 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/MapTaskExecutorFactory.java x: 401 lines of code y: 27 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/Reader.java x: 77 lines of code y: 17 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/options/DirectPipelineOptions.java x: 33 lines of code y: 5 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/CoderRegistry.java x: 468 lines of code y: 30 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/io/AvroIO.java x: 315 lines of code y: 20 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/io/BigQueryIO.java x: 764 lines of code y: 42 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/Window.java x: 271 lines of code y: 37 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ActiveWindowSet.java x: 17 lines of code y: 4 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/StringUtf8Coder.java x: 92 lines of code y: 13 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/Trigger.java x: 220 lines of code y: 26 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ExecutableTrigger.java x: 135 lines of code y: 6 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/TriggerContextFactory.java x: 377 lines of code y: 4 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/GroupAlsoByWindowsParDoFn.java x: 222 lines of code y: 25 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/WindmillStateInternals.java x: 415 lines of code y: 3 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/PartialGroupByKeyOperation.java x: 412 lines of code y: 12 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/PCollectionViews.java x: 252 lines of code y: 8 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/CachingSideInputReader.java x: 53 lines of code y: 2 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/DataflowExecutionContext.java x: 11 lines of code y: 3 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/DataflowSideInputReader.java x: 83 lines of code y: 2 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/DataflowWorker.java x: 343 lines of code y: 27 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/DefaultParDoFnFactory.java x: 54 lines of code y: 1 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ParDoFnFactory.java x: 23 lines of code y: 8 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/SizedWeigher.java x: 20 lines of code y: 2 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/SideInputReader.java x: 10 lines of code y: 2 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/Sized.java x: 18 lines of code y: 2 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/SizedSideInputReader.java x: 12 lines of code y: 2 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/logging/DataflowWorkerLoggingHandler.java x: 162 lines of code y: 3 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/logging/DataflowWorkerLoggingInitializer.java x: 88 lines of code y: 12 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/StateSampler.java x: 175 lines of code y: 11 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/DoFnRunner.java x: 434 lines of code y: 41 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/options/GcsOptions.java x: 56 lines of code y: 7 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/GcsUtil.java x: 250 lines of code y: 15 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/StreamingGroupAlsoByWindowsDoFn.java x: 70 lines of code y: 5 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/GroupAlsoByWindowsDoFn.java x: 74 lines of code y: 37 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/MergingActiveWindowSet.java x: 130 lines of code y: 5 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/NonMergingActiveWindowSet.java x: 37 lines of code y: 3 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ReduceFnRunner.java x: 452 lines of code y: 13 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/TriggerRunner.java x: 115 lines of code y: 7 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/options/DataflowPipelineOptions.java x: 59 lines of code y: 14 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/options/DataflowProfilingOptions.java x: 19 lines of code y: 1 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AvroByteReader.java x: 59 lines of code y: 5 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/io/DatastoreIO.java x: 487 lines of code y: 34 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/io/Sink.java x: 27 lines of code y: 8 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/io/Write.java x: 106 lines of code y: 1 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/io/XmlSink.java x: 108 lines of code y: 6 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Write.java x: 4 lines of code y: 14 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ParDoFnBase.java x: 161 lines of code y: 9 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/ParDoOperation.java x: 49 lines of code y: 4 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/options/CloudDebuggerOptions.java x: 10 lines of code y: 9 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/BigQueryReader.java x: 86 lines of code y: 10 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/BigQueryTableRowIterator.java x: 294 lines of code y: 10 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/FlatMapElements.java x: 59 lines of code y: 3 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/values/PCollectionTuple.java x: 114 lines of code y: 14 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/BigQueryReaderFactory.java x: 48 lines of code y: 5 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/BigQueryTableInserter.java x: 240 lines of code y: 11 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/values/TypedPValue.java x: 95 lines of code y: 9 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/View.java x: 177 lines of code y: 29 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/AvroCoder.java x: 390 lines of code y: 17 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/io/AvroSource.java x: 367 lines of code y: 6 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/io/FileBasedSource.java x: 392 lines of code y: 23 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AvroReader.java x: 122 lines of code y: 7 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AvroReaderFactory.java x: 44 lines of code y: 5 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/io/Read.java x: 111 lines of code y: 11 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/dataflow/ReadTranslator.java x: 10 lines of code y: 4 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ReaderFactory.java x: 98 lines of code y: 15 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/SourceOperationExecutor.java x: 52 lines of code y: 8 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/SourceTranslationUtils.java x: 101 lines of code y: 8 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/StreamingModeExecutionContext.java x: 400 lines of code y: 7 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/DataflowWorkerHarness.java x: 235 lines of code y: 21 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/TriggerBuilder.java x: 4 lines of code y: 1 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/WindowFn.java x: 30 lines of code y: 14 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/StateTags.java x: 253 lines of code y: 8 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/StreamingGroupAlsoByWindowsReshuffleDoFn.java x: 25 lines of code y: 1 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ReshuffleTrigger.java x: 31 lines of code y: 1 # changes maven-archetypes/starter/src/main/resources/archetype-resources/src/main/java/StarterPipeline.java x: 29 lines of code y: 3 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/CollectionCoder.java x: 31 lines of code y: 9 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/IterableCoder.java x: 38 lines of code y: 9 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/ListCoder.java x: 34 lines of code y: 10 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/MapCoder.java x: 101 lines of code y: 13 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/SetCoder.java x: 37 lines of code y: 12 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/io/XmlSource.java x: 299 lines of code y: 11 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/dataflow/AvroIOTranslator.java x: 77 lines of code y: 8 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/dataflow/TextIOTranslator.java x: 80 lines of code y: 10 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ConcatReader.java x: 176 lines of code y: 7 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/PartitioningShuffleReader.java x: 77 lines of code y: 6 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ShuffleSink.java x: 214 lines of code y: 12 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/UngroupedShuffleReader.java x: 55 lines of code y: 5 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Create.java x: 208 lines of code y: 20 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/IntraBundleParallelization.java x: 190 lines of code y: 12 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/join/CoGbkResult.java x: 313 lines of code y: 17 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/Credentials.java x: 103 lines of code y: 11 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/DataflowPathValidator.java x: 59 lines of code y: 7 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/InstanceBuilder.java x: 125 lines of code y: 7 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/SerializableUtils.java x: 93 lines of code y: 6 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/gcsfs/GcsPath.java x: 400 lines of code y: 8 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/DoFnReflector.java x: 476 lines of code y: 6 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/DoFnWithContext.java x: 84 lines of code y: 9 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/KeyedWorkItem.java x: 176 lines of code y: 1 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/WindmillSink.java x: 138 lines of code y: 8 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/WindowingWindmillReader.java x: 84 lines of code y: 11 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/TimerOrElement.java x: 22 lines of code y: 10 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ConcatReaderFactory.java x: 107 lines of code y: 3 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/GroupingShuffleReaderFactory.java x: 46 lines of code y: 4 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/InMemoryReaderFactory.java x: 31 lines of code y: 3 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/PartitioningShuffleReaderFactory.java x: 43 lines of code y: 3 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/TextReaderFactory.java x: 44 lines of code y: 4 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/UngroupedShuffleReaderFactory.java x: 35 lines of code y: 3 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/UngroupedWindmillReader.java x: 99 lines of code y: 6 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/CloudSourceUtils.java x: 34 lines of code y: 6 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/ParDo.java x: 461 lines of code y: 43 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/UserCodeTimeTracker.java x: 75 lines of code y: 2 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/MapTaskExecutor.java x: 72 lines of code y: 12 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/Operation.java x: 77 lines of code y: 10 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/ReceivingOperation.java x: 26 lines of code y: 5 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/Sink.java x: 17 lines of code y: 8 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/WriteOperation.java x: 70 lines of code y: 7 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/RetryHttpRequestInitializer.java x: 124 lines of code y: 9 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/Transport.java x: 108 lines of code y: 11 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/UploadIdResponseInterceptor.java x: 27 lines of code y: 1 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/SimpleFunction.java x: 11 lines of code y: 1 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/CoderProviders.java x: 93 lines of code y: 2 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/SerializableCoder.java x: 105 lines of code y: 15 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Partition.java x: 71 lines of code y: 9 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Filter.java x: 88 lines of code y: 8 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/testing/DataflowAssert.java x: 428 lines of code y: 29 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/testing/SerializableMatchers.java x: 719 lines of code y: 2 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/testing/SerializableMatcher.java x: 5 lines of code y: 2 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/StreamingSideInputDoFnRunner.java x: 222 lines of code y: 2 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/Pipeline.java x: 223 lines of code y: 21 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/AtomicCoder.java x: 13 lines of code y: 10 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/BigEndianIntegerCoder.java x: 50 lines of code y: 8 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/ByteArrayCoder.java x: 79 lines of code y: 12 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/CannotProvideCoderException.java x: 42 lines of code y: 3 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/Coder.java x: 77 lines of code y: 12 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/CoderException.java x: 13 lines of code y: 5 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/CustomCoder.java x: 61 lines of code y: 10 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/DelegateCoder.java x: 78 lines of code y: 13 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/DeterministicStandardCoder.java x: 6 lines of code y: 2 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/DoubleCoder.java x: 55 lines of code y: 10 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/DurationCoder.java x: 49 lines of code y: 3 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/EntityCoder.java x: 44 lines of code y: 9 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/InstantCoder.java x: 56 lines of code y: 11 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/IterableLikeCoder.java x: 154 lines of code y: 15 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/JAXBCoder.java x: 75 lines of code y: 4 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/KvCoderBase.java x: 15 lines of code y: 6 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/MapCoderBase.java x: 15 lines of code y: 5 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/NullableCoder.java x: 97 lines of code y: 2 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/Proto2Coder.java x: 179 lines of code y: 12 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/StandardCoder.java x: 145 lines of code y: 18 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/StringDelegateCoder.java x: 36 lines of code y: 8 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/TableRowJsonCoder.java x: 41 lines of code y: 9 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/TextualIntegerCoder.java x: 41 lines of code y: 10 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/VarIntCoder.java x: 50 lines of code y: 10 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/VarLongCoder.java x: 51 lines of code y: 9 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/VoidCoder.java x: 32 lines of code y: 9 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/io/BlockBasedSource.java x: 89 lines of code y: 4 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/io/BoundedSource.java x: 30 lines of code y: 13 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/io/CompressedSource.java x: 134 lines of code y: 4 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/io/FileBasedSink.java x: 372 lines of code y: 6 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/io/OffsetBasedSource.java x: 135 lines of code y: 3 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/io/Source.java x: 21 lines of code y: 17 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/io/UnboundedSource.java x: 50 lines of code y: 7 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/options/DataflowWorkerLoggingOptions.java x: 61 lines of code y: 9 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/options/GoogleApiDebugOptions.java x: 40 lines of code y: 8 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowJobCancelledException.java x: 9 lines of code y: 2 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowJobUpdatedException.java x: 16 lines of code y: 2 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/CombineValuesFn.java x: 188 lines of code y: 14 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/SinkFactory.java x: 55 lines of code y: 9 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/ApproximateQuantiles.java x: 434 lines of code y: 15 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/ApproximateUnique.java x: 188 lines of code y: 7 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Count.java x: 53 lines of code y: 16 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/DoFn.java x: 164 lines of code y: 37 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Flatten.java x: 108 lines of code y: 21 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Keys.java x: 21 lines of code y: 6 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/KvSwap.java x: 22 lines of code y: 7 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Max.java x: 104 lines of code y: 13 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Mean.java x: 102 lines of code y: 15 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Min.java x: 104 lines of code y: 14 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/PTransform.java x: 65 lines of code y: 16 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/RemoveDuplicates.java x: 52 lines of code y: 7 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Sample.java x: 118 lines of code y: 11 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/join/CoGbkResultSchema.java x: 74 lines of code y: 8 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/join/CoGroupByKey.java x: 101 lines of code y: 9 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/join/UnionCoder.java x: 93 lines of code y: 7 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/AfterAll.java x: 67 lines of code y: 12 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/AfterEach.java x: 81 lines of code y: 14 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/AfterFirst.java x: 66 lines of code y: 11 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/AfterPane.java x: 96 lines of code y: 16 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/AfterProcessingTime.java x: 110 lines of code y: 17 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/AfterSynchronizedProcessingTime.java x: 94 lines of code y: 8 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/CalendarWindows.java x: 203 lines of code y: 10 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/DefaultTrigger.java x: 44 lines of code y: 12 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/GlobalWindow.java x: 26 lines of code y: 12 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/IntervalWindow.java x: 107 lines of code y: 8 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/InvalidWindows.java x: 44 lines of code y: 6 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/NonMergingWindowFn.java x: 10 lines of code y: 6 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/PaneInfo.java x: 198 lines of code y: 8 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/PartitioningWindowFn.java x: 28 lines of code y: 8 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/Repeatedly.java x: 46 lines of code y: 10 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/TimeTrigger.java x: 81 lines of code y: 13 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/AppliedCombineFn.java x: 44 lines of code y: 2 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/AssignWindowsDoFn.java x: 36 lines of code y: 11 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/BitSetCoder.java x: 32 lines of code y: 2 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/BoundedQueueExecutor.java x: 41 lines of code y: 6 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/CoderUtils.java x: 196 lines of code y: 18 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/GroupAlsoByWindowsAndCombineDoFn.java x: 122 lines of code y: 6 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/GroupAlsoByWindowsViaIteratorsDoFn.java x: 172 lines of code y: 8 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/IllegalMutationException.java x: 22 lines of code y: 2 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ReduceFn.java x: 57 lines of code y: 7 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ReifyTimestampAndWindowsDoFn.java x: 21 lines of code y: 7 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/Structs.java x: 294 lines of code y: 5 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/UserCodeException.java x: 41 lines of code y: 4 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ValueWithRecordId.java x: 110 lines of code y: 4 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/WatermarkHold.java x: 60 lines of code y: 9 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/WindowedValue.java x: 499 lines of code y: 23 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/Counter.java x: 705 lines of code y: 12 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/values/KV.java x: 75 lines of code y: 12 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/values/TimestampedValue.java x: 97 lines of code y: 12 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/values/TupleTag.java x: 84 lines of code y: 10 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/values/TypeDescriptor.java x: 114 lines of code y: 6 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/StateFetcher.java x: 163 lines of code y: 2 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/WindmillStateReader.java x: 334 lines of code y: 2 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/PackageUtil.java x: 196 lines of code y: 15 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ZipFiles.java x: 166 lines of code y: 1 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/PubsubSink.java x: 87 lines of code y: 7 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/BatchModeExecutionContext.java x: 70 lines of code y: 18 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/GroupingShuffleRangeTracker.java x: 120 lines of code y: 3 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/ElementByteSizeObserver.java x: 39 lines of code y: 3 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/OutputObjectAndByteCounter.java x: 100 lines of code y: 2 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/testing/SourceTestUtils.java x: 436 lines of code y: 1 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/WorkExecutor.java x: 41 lines of code y: 8 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/AttemptAndTimeBoundedExponentialBackOff.java x: 88 lines of code y: 3 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/ParDoFn.java x: 6 lines of code y: 5 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AssignWindowsParDoFn.java x: 95 lines of code y: 11 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/NormalParDoFn.java x: 129 lines of code y: 14 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ReifyTimestampAndWindowsParDoFn.java x: 80 lines of code y: 6 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/BaseExecutionContext.java x: 74 lines of code y: 3 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/CoderFactories.java x: 145 lines of code y: 4 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/DefaultCoder.java x: 13 lines of code y: 4 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/package-info.java x: 1 lines of code y: 4 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/io/ShardNameTemplate.java x: 5 lines of code y: 4 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/io/range/OffsetRangeTracker.java x: 120 lines of code y: 2 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/options/DataflowPipelineDebugOptions.java x: 122 lines of code y: 18 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/options/DataflowWorkerHarnessOptions.java x: 16 lines of code y: 6 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/options/Default.java x: 67 lines of code y: 5 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/options/GcpOptions.java x: 143 lines of code y: 14 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/options/PipelineOptions.java x: 41 lines of code y: 13 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/options/PipelineOptionsFactory.java x: 837 lines of code y: 24 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/options/PipelineOptionsValidator.java x: 61 lines of code y: 7 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/options/ProxyInvocationHandler.java x: 291 lines of code y: 14 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/package-info.java x: 1 lines of code y: 5 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/BlockingDataflowPipelineRunner.java x: 108 lines of code y: 15 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowPipeline.java x: 24 lines of code y: 5 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/TransformTreeNode.java x: 127 lines of code y: 7 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ApplianceShuffleReader.java x: 23 lines of code y: 5 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/LazyMultiReaderIterator.java x: 46 lines of code y: 5 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/OrderedCode.java x: 397 lines of code y: 5 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/TextSink.java x: 206 lines of code y: 5 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/testing/CoderProperties.java x: 229 lines of code y: 7 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/testing/TestPipeline.java x: 95 lines of code y: 12 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/testing/WindowFnTestUtils.java x: 159 lines of code y: 6 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Aggregator.java x: 7 lines of code y: 8 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/package-info.java x: 1 lines of code y: 6 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/BoundedWindow.java x: 10 lines of code y: 5 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/AppEngineEnvironment.java x: 24 lines of code y: 4 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/AttemptBoundedExponentialBackOff.java x: 38 lines of code y: 5 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/CloudObject.java x: 77 lines of code y: 4 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/CounterAggregator.java x: 53 lines of code y: 3 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/IOChannelFactory.java x: 14 lines of code y: 8 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/IOChannelUtils.java x: 91 lines of code y: 8 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/IntervalBoundedExponentialBackOff.java x: 38 lines of code y: 2 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/Serializer.java x: 65 lines of code y: 6 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ShardingWritableByteChannel.java x: 52 lines of code y: 4 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/TimeUtil.java x: 99 lines of code y: 3 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/TimerInternals.java x: 62 lines of code y: 2 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/VarInt.java x: 61 lines of code y: 4 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/CounterSet.java x: 67 lines of code y: 4 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/TaggedReiteratorList.java x: 116 lines of code y: 5 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/StateInternals.java x: 7 lines of code y: 3 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/StateNamespace.java x: 4 lines of code y: 3 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/StateTag.java x: 21 lines of code y: 3 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/values/PBegin.java x: 35 lines of code y: 7 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/values/PCollection.java x: 78 lines of code y: 15 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/values/PCollectionList.java x: 103 lines of code y: 7 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/values/PInput.java x: 8 lines of code y: 5 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/values/POutputValueBase.java x: 29 lines of code y: 6 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/io/range/package-info.java x: 1 lines of code y: 1 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/logging/JulLoggerPrintStreamAdapterFactory.java x: 82 lines of code y: 1 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/NonEmptyPanes.java x: 56 lines of code y: 1 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/InMemoryStateInternals.java x: 207 lines of code y: 4 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AvroSinkFactory.java x: 32 lines of code y: 6 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/BatchTimerInternals.java x: 67 lines of code y: 3 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/FileIOChannelFactory.java x: 84 lines of code y: 8 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/MutationDetectors.java x: 75 lines of code y: 1 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/dataflow/BigQueryIOTranslator.java x: 80 lines of code y: 8 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/annotations/Experimental.java x: 26 lines of code y: 3 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/testing/TestDataflowPipelineRunner.java x: 172 lines of code y: 12 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/MergedCombiningValue.java x: 82 lines of code y: 3 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/PathValidator.java x: 6 lines of code y: 4 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/PipelineResult.java x: 30 lines of code y: 5 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/MonitoringUtil.java x: 157 lines of code y: 9 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/OutputReceiver.java x: 36 lines of code y: 4 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ReduceFnContextFactory.java x: 320 lines of code y: 2 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/TimeDomain.java x: 6 lines of code y: 1 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/WindowingInternals.java x: 22 lines of code y: 11 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/MergedWatermarkStateInternal.java x: 67 lines of code y: 1 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/StateNamespaces.java x: 161 lines of code y: 4 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/values/PCollectionView.java x: 11 lines of code y: 12 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ChunkingShuffleEntryWriter.java x: 48 lines of code y: 4 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/BagState.java x: 3 lines of code y: 1 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/ValueState.java x: 8 lines of code y: 1 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/logging/DataflowWorkerLoggingMDC.java x: 38 lines of code y: 1 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ShuffleSinkFactory.java x: 34 lines of code y: 3 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/TextSinkFactory.java x: 32 lines of code y: 3 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ExposedByteArrayInputStream.java x: 25 lines of code y: 2 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/AbstractBoundedReaderIterator.java x: 23 lines of code y: 1 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/GcsStager.java x: 28 lines of code y: 4 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/DirectSideInputReader.java x: 43 lines of code y: 1 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/PCollectionViewWindow.java x: 34 lines of code y: 1 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/dataflow/PubsubIOTranslator.java x: 72 lines of code y: 11 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/AppliedPTransform.java x: 62 lines of code y: 5 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/WorkProgressUpdater.java x: 110 lines of code y: 10 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/join/KeyedPCollectionTuple.java x: 141 lines of code y: 8 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/AggregatorValues.java x: 15 lines of code y: 1 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/AggregatorPipelineExtractor.java x: 57 lines of code y: 1 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/NoopPathValidator.java x: 22 lines of code y: 3 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/GcsIOChannelFactory.java x: 53 lines of code y: 4 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ExposedByteArrayOutputStream.java x: 61 lines of code y: 1 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/StreamUtils.java x: 36 lines of code y: 2 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/values/PDone.java x: 16 lines of code y: 3 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/testing/RunnableOnService.java x: 2 lines of code y: 3 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/io/XMLSource.java x: 299 lines of code y: 3 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/options/BlockingDataflowPipelineOptions.java x: 19 lines of code y: 4 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/CachingShuffleBatchReader.java x: 117 lines of code y: 3 # changes contrib/join-library/src/main/java/com/google/cloud/dataflow/contrib/joinlibrary/Join.java x: 112 lines of code y: 3 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ReaderUtils.java x: 18 lines of code y: 3 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AvroSink.java x: 90 lines of code y: 3 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowPipelineRegistrar.java x: 28 lines of code y: 2 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/dataflow/package-info.java x: 1 lines of code y: 3 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AvroByteSink.java x: 46 lines of code y: 3 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/CopyableSeekableByteChannel.java x: 149 lines of code y: 2 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ShuffleReader.java x: 14 lines of code y: 2 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/MergeOverlappingIntervalWindows.java x: 55 lines of code y: 3 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/CloudKnownType.java x: 107 lines of code y: 2 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/CloudMetricUtils.java x: 41 lines of code y: 2 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/DataflowReleaseInfo.java x: 48 lines of code y: 2 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/TestCredential.java x: 25 lines of code y: 3 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/Values.java x: 60 lines of code y: 2 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/PeekingReiterator.java x: 55 lines of code y: 4 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/package-info.java x: 1 lines of code y: 2 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/BatchingShuffleEntryReader.java x: 86 lines of code y: 3 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/ShufflePosition.java x: 3 lines of code y: 2 # changes sdk/src/main/proto/proto2_coder_test_messages.proto x: 35 lines of code y: 1 # changes
65.0
# changes
  min: 1.0
  average: 7.75
  25th percentile: 3.0
  median: 5.0
  75th percentile: 10.0
  max: 65.0
0 1076.0
lines of code
min: 1.0 | average: 102.83 | 25th percentile: 21.0 | median: 55.5 | 75th percentile: 112.5 | max: 1076.0

Number of Contributors vs. Number of Changes: 502 points

contrib/hadoop/src/main/java/com/google/cloud/dataflow/contrib/hadoop/HadoopFileSource.java x: 3 # contributors y: 3 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/GroupingShuffleReader.java x: 10 # contributors y: 18 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/GroupingShuffleEntryIterator.java x: 6 # contributors y: 6 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/SideInputUtils.java x: 6 # contributors y: 8 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/OrFinallyTrigger.java x: 3 # contributors y: 5 # changes sdk/src/main/proto/windmill.proto x: 8 # contributors y: 21 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/AfterWatermark.java x: 8 # contributors y: 23 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/io/PubsubIO.java x: 15 # contributors y: 32 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/MetricTrackingWindmillServerStub.java x: 2 # contributors y: 2 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/StreamingDataflowWorker.java x: 16 # contributors y: 45 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/MemoryMonitor.java x: 1 # contributors y: 1 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Combine.java x: 15 # contributors y: 56 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/GroupByKey.java x: 13 # contributors y: 35 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Top.java x: 11 # contributors y: 20 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/options/DataflowPipelineWorkerPoolOptions.java x: 11 # contributors y: 25 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowPipelineTranslator.java x: 24 # contributors y: 53 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/io/TextIO.java x: 12 # contributors y: 21 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/DoFnTester.java x: 8 # contributors y: 19 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowPipelineJob.java x: 11 # contributors y: 13 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DirectPipelineRunner.java x: 10 # contributors y: 34 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowPipelineRunner.java x: 21 # contributors y: 65 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/ReadOperation.java x: 11 # contributors y: 22 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/io/BoundedReadFromUnboundedSource.java x: 5 # contributors y: 6 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/FileBasedReader.java x: 7 # contributors y: 11 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Sum.java x: 8 # contributors y: 10 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/FixedWindows.java x: 8 # contributors y: 12 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/Sessions.java x: 9 # contributors y: 14 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/SlidingWindows.java x: 10 # contributors y: 16 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/WindowingStrategy.java x: 3 # contributors y: 12 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ByteArrayShufflePosition.java x: 7 # contributors y: 7 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/InMemoryReader.java x: 5 # contributors y: 8 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/MapTaskExecutorFactory.java x: 13 # contributors y: 27 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/Reader.java x: 10 # contributors y: 17 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/options/DirectPipelineOptions.java x: 5 # contributors y: 5 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/CoderRegistry.java x: 8 # contributors y: 30 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/io/AvroIO.java x: 12 # contributors y: 20 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/io/BigQueryIO.java x: 20 # contributors y: 42 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/Window.java x: 12 # contributors y: 37 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ActiveWindowSet.java x: 2 # contributors y: 4 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/StringUtf8Coder.java x: 7 # contributors y: 13 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/Trigger.java x: 11 # contributors y: 26 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ExecutableTrigger.java x: 2 # contributors y: 6 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/TriggerContextFactory.java x: 1 # contributors y: 4 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/GroupAlsoByWindowsParDoFn.java x: 8 # contributors y: 25 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/PartialGroupByKeyOperation.java x: 9 # contributors y: 12 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/CachingSideInputReader.java x: 1 # contributors y: 2 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/DataflowExecutionContext.java x: 1 # contributors y: 3 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/DataflowWorker.java x: 15 # contributors y: 27 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/logging/DataflowWorkerLoggingInitializer.java x: 6 # contributors y: 12 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/StateSampler.java x: 6 # contributors y: 11 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/DoFnRunner.java x: 14 # contributors y: 41 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/options/GcsOptions.java x: 6 # contributors y: 7 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/GcsUtil.java x: 9 # contributors y: 15 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/StreamingGroupAlsoByWindowsDoFn.java x: 2 # contributors y: 5 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/GroupAlsoByWindowsDoFn.java x: 9 # contributors y: 37 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ReduceFnRunner.java x: 4 # contributors y: 13 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/TriggerRunner.java x: 2 # contributors y: 7 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/options/DataflowPipelineOptions.java x: 10 # contributors y: 14 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/io/DatastoreIO.java x: 16 # contributors y: 34 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/io/Sink.java x: 4 # contributors y: 8 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/io/XmlSink.java x: 4 # contributors y: 6 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Write.java x: 7 # contributors y: 14 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ParDoFnBase.java x: 4 # contributors y: 9 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/ParDoOperation.java x: 4 # contributors y: 4 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/options/CloudDebuggerOptions.java x: 6 # contributors y: 9 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/BigQueryReader.java x: 6 # contributors y: 10 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/BigQueryTableRowIterator.java x: 5 # contributors y: 10 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/FlatMapElements.java x: 2 # contributors y: 3 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/BigQueryTableInserter.java x: 8 # contributors y: 11 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/values/TypedPValue.java x: 5 # contributors y: 9 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/View.java x: 12 # contributors y: 29 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/AvroCoder.java x: 7 # contributors y: 17 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/io/FileBasedSource.java x: 12 # contributors y: 23 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AvroReader.java x: 5 # contributors y: 7 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/io/Read.java x: 5 # contributors y: 11 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/SourceTranslationUtils.java x: 3 # contributors y: 8 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/DataflowWorkerHarness.java x: 10 # contributors y: 21 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/MapCoder.java x: 6 # contributors y: 13 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/dataflow/AvroIOTranslator.java x: 7 # contributors y: 8 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/dataflow/TextIOTranslator.java x: 9 # contributors y: 10 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ShuffleSink.java x: 11 # contributors y: 12 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/UngroupedShuffleReader.java x: 4 # contributors y: 5 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Create.java x: 8 # contributors y: 20 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/IntraBundleParallelization.java x: 7 # contributors y: 12 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/DataflowPathValidator.java x: 4 # contributors y: 7 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/gcsfs/GcsPath.java x: 8 # contributors y: 8 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/ParDo.java x: 17 # contributors y: 43 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/RetryHttpRequestInitializer.java x: 8 # contributors y: 9 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/Transport.java x: 9 # contributors y: 11 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/SerializableCoder.java x: 5 # contributors y: 15 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/Pipeline.java x: 9 # contributors y: 21 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/DelegateCoder.java x: 5 # contributors y: 13 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/IterableLikeCoder.java x: 8 # contributors y: 15 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/StandardCoder.java x: 11 # contributors y: 18 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/io/BlockBasedSource.java x: 3 # contributors y: 4 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/CombineValuesFn.java x: 8 # contributors y: 14 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/SinkFactory.java x: 7 # contributors y: 9 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/ApproximateQuantiles.java x: 7 # contributors y: 15 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/DoFn.java x: 11 # contributors y: 37 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Max.java x: 8 # contributors y: 13 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/AfterAll.java x: 4 # contributors y: 12 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/AfterEach.java x: 5 # contributors y: 14 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/AfterFirst.java x: 4 # contributors y: 11 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/AfterPane.java x: 4 # contributors y: 16 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/AfterProcessingTime.java x: 6 # contributors y: 17 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/AfterSynchronizedProcessingTime.java x: 2 # contributors y: 8 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/Repeatedly.java x: 3 # contributors y: 10 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/CoderUtils.java x: 9 # contributors y: 18 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/SystemReduceFn.java x: 2 # contributors y: 9 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/WatermarkHold.java x: 3 # contributors y: 9 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/values/TypeDescriptor.java x: 3 # contributors y: 6 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/BatchModeExecutionContext.java x: 7 # contributors y: 18 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/DataflowWorkProgressUpdater.java x: 7 # contributors y: 10 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/options/PipelineOptionsFactory.java x: 13 # contributors y: 24 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/testing/CoderProperties.java x: 3 # contributors y: 7 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/MonitoringUtil.java x: 11 # contributors y: 9 # changes sdk/src/main/java/com/google/cloud/dataflow/sdk/util/PropertyNames.java x: 10 # contributors y: 13 # changes
65.0
# changes
  min: 1.0
  average: 7.75
  25th percentile: 3.0
  median: 5.0
  75th percentile: 10.0
  max: 65.0
0 24.0
# contributors
min: 1.0 | average: 4.52 | 25th percentile: 2.0 | median: 4.0 | 75th percentile: 6.0 | max: 24.0

Number of Contributors vs. File Size: 502 points

contrib/hadoop/src/main/java/com/google/cloud/dataflow/contrib/hadoop/HadoopFileSource.java x: 3 # contributors y: 341 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/GroupingShuffleReader.java x: 10 # contributors y: 288 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/GroupingShuffleEntryIterator.java x: 6 # contributors y: 145 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/SideInputUtils.java x: 6 # contributors y: 142 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/OrFinallyTrigger.java x: 3 # contributors y: 52 lines of code sdk/src/main/proto/windmill.proto x: 8 # contributors y: 261 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/AfterWatermark.java x: 8 # contributors y: 360 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/io/PubsubIO.java x: 15 # contributors y: 524 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/MetricTrackingWindmillServerStub.java x: 2 # contributors y: 40 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/StreamingDataflowWorker.java x: 16 # contributors y: 862 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/MemoryMonitor.java x: 1 # contributors y: 199 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Combine.java x: 15 # contributors y: 1076 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/GroupByKey.java x: 13 # contributors y: 304 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Top.java x: 11 # contributors y: 199 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/options/DataflowPipelineWorkerPoolOptions.java x: 11 # contributors y: 80 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowPipelineTranslator.java x: 24 # contributors y: 714 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/io/TextIO.java x: 12 # contributors y: 358 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/DoFnTester.java x: 8 # contributors y: 184 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowPipelineJob.java x: 11 # contributors y: 223 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DirectPipelineRunner.java x: 10 # contributors y: 564 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/MapAggregatorValues.java x: 1 # contributors y: 21 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ApiSurface.java x: 3 # contributors y: 333 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowPipelineRunner.java x: 21 # contributors y: 796 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/ReadOperation.java x: 11 # contributors y: 186 lines of code contrib/hadoop/src/main/java/com/google/cloud/dataflow/contrib/hadoop/WritableCoder.java x: 2 # contributors y: 64 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/io/BoundedReadFromUnboundedSource.java x: 5 # contributors y: 194 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/FileBasedReader.java x: 7 # contributors y: 225 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/TextReader.java x: 5 # contributors y: 271 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Sum.java x: 8 # contributors y: 69 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/FixedWindows.java x: 8 # contributors y: 56 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/Sessions.java x: 9 # contributors y: 55 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/SlidingWindows.java x: 10 # contributors y: 109 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/Reshuffle.java x: 3 # contributors y: 86 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/WindowingStrategy.java x: 3 # contributors y: 149 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/ReflectHelpers.java x: 3 # contributors y: 148 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/dataflow/CustomSources.java x: 2 # contributors y: 539 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ByteArrayShufflePosition.java x: 7 # contributors y: 69 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/InMemoryReader.java x: 5 # contributors y: 110 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/MapTaskExecutorFactory.java x: 13 # contributors y: 401 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/Reader.java x: 10 # contributors y: 77 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/options/DirectPipelineOptions.java x: 5 # contributors y: 33 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/CoderRegistry.java x: 8 # contributors y: 468 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/io/AvroIO.java x: 12 # contributors y: 315 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/io/BigQueryIO.java x: 20 # contributors y: 764 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/Window.java x: 12 # contributors y: 271 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ActiveWindowSet.java x: 2 # contributors y: 17 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/StringUtf8Coder.java x: 7 # contributors y: 92 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/Trigger.java x: 11 # contributors y: 220 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ExecutableTrigger.java x: 2 # contributors y: 135 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/TriggerContextFactory.java x: 1 # contributors y: 377 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/GroupAlsoByWindowsParDoFn.java x: 8 # contributors y: 222 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/WindmillStateInternals.java x: 3 # contributors y: 415 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/PartialGroupByKeyOperation.java x: 9 # contributors y: 412 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/PCollectionViews.java x: 5 # contributors y: 252 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/CachingSideInputReader.java x: 1 # contributors y: 53 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/DataflowExecutionContext.java x: 1 # contributors y: 11 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/DataflowSideInputReader.java x: 1 # contributors y: 83 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/DataflowWorker.java x: 15 # contributors y: 343 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ParDoFnFactory.java x: 6 # contributors y: 23 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/logging/DataflowWorkerLoggingHandler.java x: 3 # contributors y: 162 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/logging/DataflowWorkerLoggingInitializer.java x: 6 # contributors y: 88 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/StateSampler.java x: 6 # contributors y: 175 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/DoFnRunner.java x: 14 # contributors y: 434 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/options/GcsOptions.java x: 6 # contributors y: 56 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/GcsUtil.java x: 9 # contributors y: 250 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/StreamingGroupAlsoByWindowsDoFn.java x: 2 # contributors y: 70 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/GroupAlsoByWindowsDoFn.java x: 9 # contributors y: 74 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/MergingActiveWindowSet.java x: 2 # contributors y: 130 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/NonMergingActiveWindowSet.java x: 1 # contributors y: 37 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ReduceFnRunner.java x: 4 # contributors y: 452 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/TriggerRunner.java x: 2 # contributors y: 115 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/options/DataflowPipelineOptions.java x: 10 # contributors y: 59 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AvroByteReader.java x: 3 # contributors y: 59 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/io/DatastoreIO.java x: 16 # contributors y: 487 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/io/Sink.java x: 4 # contributors y: 27 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/io/Write.java x: 1 # contributors y: 106 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/io/XmlSink.java x: 4 # contributors y: 108 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Write.java x: 7 # contributors y: 4 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ParDoFnBase.java x: 4 # contributors y: 161 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/ParDoOperation.java x: 4 # contributors y: 49 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/options/CloudDebuggerOptions.java x: 6 # contributors y: 10 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/BigQueryTableRowIterator.java x: 5 # contributors y: 294 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/FlatMapElements.java x: 2 # contributors y: 59 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/values/PCollectionTuple.java x: 7 # contributors y: 114 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/BigQueryReaderFactory.java x: 5 # contributors y: 48 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/BigQueryTableInserter.java x: 8 # contributors y: 240 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/values/TypedPValue.java x: 5 # contributors y: 95 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/MapElements.java x: 1 # contributors y: 40 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/View.java x: 12 # contributors y: 177 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/AvroCoder.java x: 7 # contributors y: 390 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/io/AvroSource.java x: 5 # contributors y: 367 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/io/FileBasedSource.java x: 12 # contributors y: 392 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AvroReader.java x: 5 # contributors y: 122 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AvroReaderFactory.java x: 5 # contributors y: 44 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/io/Read.java x: 5 # contributors y: 111 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/dataflow/ReadTranslator.java x: 2 # contributors y: 10 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ReaderFactory.java x: 9 # contributors y: 98 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/SourceOperationExecutor.java x: 6 # contributors y: 52 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/SourceTranslationUtils.java x: 3 # contributors y: 101 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/StreamingModeExecutionContext.java x: 5 # contributors y: 400 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/DataflowWorkerHarness.java x: 10 # contributors y: 235 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/TriggerBuilder.java x: 1 # contributors y: 4 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/WindowFn.java x: 10 # contributors y: 30 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/StateTags.java x: 3 # contributors y: 253 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/StreamingGroupAlsoByWindowsReshuffleDoFn.java x: 1 # contributors y: 25 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ReshuffleTrigger.java x: 1 # contributors y: 31 lines of code maven-archetypes/starter/src/main/resources/archetype-resources/src/main/java/StarterPipeline.java x: 3 # contributors y: 29 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/IterableCoder.java x: 5 # contributors y: 38 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/KvCoder.java x: 6 # contributors y: 111 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/ListCoder.java x: 6 # contributors y: 34 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/MapCoder.java x: 6 # contributors y: 101 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/io/XmlSource.java x: 6 # contributors y: 299 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/dataflow/AvroIOTranslator.java x: 7 # contributors y: 77 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/dataflow/TextIOTranslator.java x: 9 # contributors y: 80 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/PartitioningShuffleReader.java x: 5 # contributors y: 77 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ShuffleSink.java x: 11 # contributors y: 214 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/UngroupedShuffleReader.java x: 4 # contributors y: 55 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Create.java x: 8 # contributors y: 208 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/IntraBundleParallelization.java x: 7 # contributors y: 190 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/join/CoGbkResult.java x: 10 # contributors y: 313 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/Credentials.java x: 5 # contributors y: 103 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/DataflowPathValidator.java x: 4 # contributors y: 59 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/InstanceBuilder.java x: 4 # contributors y: 125 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/SerializableUtils.java x: 4 # contributors y: 93 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/gcsfs/GcsPath.java x: 8 # contributors y: 400 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/DoFnReflector.java x: 4 # contributors y: 476 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/DoFnWithContext.java x: 5 # contributors y: 84 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/KeyedWorkItem.java x: 1 # contributors y: 176 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/WindmillSink.java x: 6 # contributors y: 138 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ConcatReaderFactory.java x: 3 # contributors y: 107 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/GroupingShuffleReaderFactory.java x: 4 # contributors y: 46 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/InMemoryReaderFactory.java x: 3 # contributors y: 31 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/PartitioningShuffleReaderFactory.java x: 3 # contributors y: 43 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/PubsubReader.java x: 5 # contributors y: 76 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/UngroupedShuffleReaderFactory.java x: 3 # contributors y: 35 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/UngroupedWindmillReader.java x: 4 # contributors y: 99 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/ParDo.java x: 17 # contributors y: 461 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/UserCodeTimeTracker.java x: 1 # contributors y: 75 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/Operation.java x: 6 # contributors y: 77 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/Sink.java x: 5 # contributors y: 17 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/WriteOperation.java x: 5 # contributors y: 70 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/RetryHttpRequestInitializer.java x: 8 # contributors y: 124 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/Transport.java x: 9 # contributors y: 108 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/UploadIdResponseInterceptor.java x: 1 # contributors y: 27 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/CoderProviders.java x: 1 # contributors y: 93 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/testing/DataflowAssert.java x: 12 # contributors y: 428 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/testing/SerializableMatchers.java x: 2 # contributors y: 719 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/testing/SerializableMatcher.java x: 1 # contributors y: 5 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/StreamingSideInputDoFnRunner.java x: 2 # contributors y: 222 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/Pipeline.java x: 9 # contributors y: 223 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/AtomicCoder.java x: 5 # contributors y: 13 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/CoderException.java x: 4 # contributors y: 13 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/CustomCoder.java x: 6 # contributors y: 61 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/DurationCoder.java x: 2 # contributors y: 49 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/EntityCoder.java x: 6 # contributors y: 44 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/IterableLikeCoder.java x: 8 # contributors y: 154 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/JAXBCoder.java x: 2 # contributors y: 75 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/NullableCoder.java x: 2 # contributors y: 97 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/Proto2Coder.java x: 9 # contributors y: 179 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/StandardCoder.java x: 11 # contributors y: 145 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/StringDelegateCoder.java x: 4 # contributors y: 36 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/TableRowJsonCoder.java x: 6 # contributors y: 41 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/VarLongCoder.java x: 5 # contributors y: 51 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/io/BlockBasedSource.java x: 3 # contributors y: 89 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/io/BoundedSource.java x: 7 # contributors y: 30 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/io/CompressedSource.java x: 4 # contributors y: 134 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/io/FileBasedSink.java x: 4 # contributors y: 372 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/io/OffsetBasedSource.java x: 3 # contributors y: 135 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/io/Source.java x: 10 # contributors y: 21 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/options/DataflowWorkerLoggingOptions.java x: 5 # contributors y: 61 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/options/GoogleApiDebugOptions.java x: 5 # contributors y: 40 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/AggregatorRetrievalException.java x: 2 # contributors y: 7 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowJobException.java x: 1 # contributors y: 13 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/CombineValuesFn.java x: 8 # contributors y: 188 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/SinkFactory.java x: 7 # contributors y: 55 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/ApproximateQuantiles.java x: 7 # contributors y: 434 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/ApproximateUnique.java x: 6 # contributors y: 188 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Count.java x: 10 # contributors y: 53 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/DoFn.java x: 11 # contributors y: 164 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/KvSwap.java x: 5 # contributors y: 22 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Max.java x: 8 # contributors y: 104 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/PTransform.java x: 10 # contributors y: 65 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Sample.java x: 6 # contributors y: 118 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/join/CoGbkResultSchema.java x: 7 # contributors y: 74 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/join/UnionCoder.java x: 5 # contributors y: 93 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/AfterAll.java x: 4 # contributors y: 67 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/AfterPane.java x: 4 # contributors y: 96 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/AfterProcessingTime.java x: 6 # contributors y: 110 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/CalendarWindows.java x: 9 # contributors y: 203 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/GlobalWindow.java x: 9 # contributors y: 26 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/PaneInfo.java x: 4 # contributors y: 198 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/PartitioningWindowFn.java x: 7 # contributors y: 28 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/TimeTrigger.java x: 6 # contributors y: 81 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/AppliedCombineFn.java x: 2 # contributors y: 44 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/AssignWindowsDoFn.java x: 7 # contributors y: 36 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/BitSetCoder.java x: 2 # contributors y: 32 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/CoderUtils.java x: 9 # contributors y: 196 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/GroupAlsoByWindowsViaIteratorsDoFn.java x: 4 # contributors y: 172 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ReifyTimestampAndWindowsDoFn.java x: 6 # contributors y: 21 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/Structs.java x: 4 # contributors y: 294 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/UserCodeException.java x: 4 # contributors y: 41 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ValueWithRecordId.java x: 2 # contributors y: 110 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/WatermarkHold.java x: 3 # contributors y: 60 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/WindowedValue.java x: 12 # contributors y: 499 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/Counter.java x: 8 # contributors y: 705 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/values/KV.java x: 6 # contributors y: 75 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/values/TimestampedValue.java x: 6 # contributors y: 97 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/values/TypeDescriptor.java x: 3 # contributors y: 114 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/StateFetcher.java x: 2 # contributors y: 163 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/WindmillStateReader.java x: 2 # contributors y: 334 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/PackageUtil.java x: 7 # contributors y: 196 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ZipFiles.java x: 1 # contributors y: 166 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/PubsubSink.java x: 5 # contributors y: 87 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/GroupingShuffleRangeTracker.java x: 3 # contributors y: 120 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/ElementByteSizeObserver.java x: 3 # contributors y: 39 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/OutputObjectAndByteCounter.java x: 2 # contributors y: 100 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/testing/SourceTestUtils.java x: 1 # contributors y: 436 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/ParDoFn.java x: 4 # contributors y: 6 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AssignWindowsParDoFn.java x: 8 # contributors y: 95 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/NormalParDoFn.java x: 9 # contributors y: 129 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ReifyTimestampAndWindowsParDoFn.java x: 4 # contributors y: 80 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/BaseExecutionContext.java x: 3 # contributors y: 74 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/DefaultCoder.java x: 3 # contributors y: 13 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/package-info.java x: 2 # contributors y: 1 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/io/ShardNameTemplate.java x: 3 # contributors y: 5 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/io/range/OffsetRangeTracker.java x: 2 # contributors y: 120 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/options/DataflowPipelineDebugOptions.java x: 9 # contributors y: 122 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/options/Default.java x: 3 # contributors y: 67 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/options/DefaultValueFactory.java x: 3 # contributors y: 4 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/options/GcpOptions.java x: 5 # contributors y: 143 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/options/PipelineOptions.java x: 8 # contributors y: 41 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/options/PipelineOptionsFactory.java x: 13 # contributors y: 837 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/options/ProxyInvocationHandler.java x: 8 # contributors y: 291 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/BlockingDataflowPipelineRunner.java x: 8 # contributors y: 108 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowPipeline.java x: 3 # contributors y: 24 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/RecordingPipelineVisitor.java x: 4 # contributors y: 24 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/TransformTreeNode.java x: 5 # contributors y: 127 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/OrderedCode.java x: 4 # contributors y: 397 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/TextSink.java x: 3 # contributors y: 206 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/testing/CoderProperties.java x: 3 # contributors y: 229 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/testing/TestPipeline.java x: 7 # contributors y: 95 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/testing/WindowFnTestUtils.java x: 4 # contributors y: 159 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Aggregator.java x: 6 # contributors y: 7 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/package-info.java x: 4 # contributors y: 1 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/BoundedWindow.java x: 4 # contributors y: 10 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/AppEngineEnvironment.java x: 2 # contributors y: 24 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/CloudObject.java x: 3 # contributors y: 77 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/IntervalBoundedExponentialBackOff.java x: 2 # contributors y: 38 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/Serializer.java x: 5 # contributors y: 65 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/TimerInternals.java x: 2 # contributors y: 62 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/TaggedReiteratorList.java x: 5 # contributors y: 116 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/values/PCollection.java x: 8 # contributors y: 78 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/values/POutput.java x: 5 # contributors y: 11 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/values/POutputValueBase.java x: 5 # contributors y: 29 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/NonEmptyPanes.java x: 1 # contributors y: 56 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/InMemoryStateInternals.java x: 1 # contributors y: 207 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AvroSinkFactory.java x: 6 # contributors y: 32 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/BatchTimerInternals.java x: 1 # contributors y: 67 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/PaneInfoTracker.java x: 2 # contributors y: 55 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/testing/TestDataflowPipelineRunner.java x: 6 # contributors y: 172 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/PipelineResult.java x: 4 # contributors y: 30 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/MonitoringUtil.java x: 11 # contributors y: 157 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ReduceFnContextFactory.java x: 1 # contributors y: 320 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/MergingStateInternals.java x: 1 # contributors y: 61 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/StateNamespaces.java x: 1 # contributors y: 161 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/values/PCollectionView.java x: 7 # contributors y: 11 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ShuffleEntryWriter.java x: 3 # contributors y: 10 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/DirectSideInputReader.java x: 1 # contributors y: 43 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/CloudCounterUtils.java x: 4 # contributors y: 74 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/Metric.java x: 3 # contributors y: 20 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/io/XMLSource.java x: 2 # contributors y: 299 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/CachingShuffleBatchReader.java x: 3 # contributors y: 117 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/CopyableSeekableByteChannel.java x: 2 # contributors y: 149 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ShuffleReader.java x: 2 # contributors y: 14 lines of code sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/join/RawUnionValue.java x: 4 # contributors y: 19 lines of code
1076.0
lines of code
  min: 1.0
  average: 102.83
  25th percentile: 21.0
  median: 55.5
  75th percentile: 112.5
  max: 1076.0
0 24.0
# contributors
min: 1.0 | average: 4.52 | 25th percentile: 2.0 | median: 4.0 | 75th percentile: 6.0 | max: 24.0