spotify / DataflowJavaSDK
File Size

The distribution of size of files (measured in lines of code).

Intro
Learn more...
File Size Overall
2% | 13% | 35% | 22% | 26%
Legend:
1001+
501-1000
201-500
101-200
1-100


explore: grouped by folders | grouped by size | sunburst | 3D view
File Size per Extension
1001+
501-1000
201-500
101-200
1-100
java2% | 13% | 35% | 22% | 26%
proto0% | 0% | 88% | 0% | 11%
xml0% | 0% | 0% | 0% | 100%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
sdk2% | 13% | 35% | 22% | 26%
contrib0% | 0% | 65% | 21% | 12%
maven-archetypes0% | 0% | 0% | 0% | 100%
Longest Files (Top 50)
File# lines# units
Combine.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms
 1076 110
StreamingDataflowWorker.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 862 41
PipelineOptionsFactory.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/options
 837 42
DataflowPipelineRunner.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners
 796 60
BigQueryIO.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/io
 764 78
SerializableMatchers.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/testing
 719 57
DataflowPipelineTranslator.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners
 714 44
Counter.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common
 705 75
DirectPipelineRunner.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners
 564 56
CustomSources.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/dataflow
 539 27
PubsubIO.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/io
 524 56
WindowedValue.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 499 65
DatastoreIO.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/io
 487 49
DoFnReflector.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms
 476 45
CoderRegistry.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/coders
 468 26
ParDo.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms
 461 45
ReduceFnRunner.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 452 25
SourceTestUtils.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/testing
 436 18
DoFnRunner.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 434 37
ApproximateQuantiles.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms
 434 30
DataflowAssert.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/testing
 428 44
WindmillStateInternals.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 415 30
PartialGroupByKeyOperation.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker
 412 35
MapTaskExecutorFactory.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 401 29
GcsPath.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/gcsfs
 400 43
StreamingModeExecutionContext.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 400 32
OrderedCode.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 397 13
FileBasedSource.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/io
 392 30
AvroCoder.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/coders
 390 33
TriggerContextFactory.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 377 42
FileBasedSink.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/io
 372 35
AvroSource.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/io
 367 34
AfterWatermark.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing
 360 44
TextIO.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/io
 358 52
DataflowWorker.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 343 17
HadoopFileSource.java
in contrib/hadoop/src/main/java/com/google/cloud/dataflow/contrib/hadoop
 341 26
WindmillStateReader.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 334 15
ApiSurface.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 333 34
ReduceFnContextFactory.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 320 45
AvroIO.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/io
 315 52
CoGbkResult.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/join
 313 30
GroupByKey.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms
 304 18
XmlSource.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/io
 299 24
Structs.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 294 28
BigQueryTableRowIterator.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 294 17
ProxyInvocationHandler.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/options
 291 15
GroupingShuffleReader.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 288 17
Window.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing
 271 32
TextReader.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 271 25
proto
windmill.proto
in sdk/src/main/proto
 261 -
Files With Most Units (Top 50)
File# lines# units
Combine.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms
 1076 110
BigQueryIO.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/io
 764 78
Counter.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common
 705 75
WindowedValue.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 499 65
DataflowPipelineRunner.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners
 796 60
SerializableMatchers.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/testing
 719 57
PubsubIO.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/io
 524 56
DirectPipelineRunner.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners
 564 56
AvroIO.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/io
 315 52
TextIO.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/io
 358 52
DatastoreIO.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/io
 487 49
ReduceFnContextFactory.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 320 45
ParDo.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms
 461 45
DoFnReflector.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms
 476 45
DataflowAssert.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/testing
 428 44
AfterWatermark.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing
 360 44
DataflowPipelineTranslator.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners
 714 44
GcsPath.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/gcsfs
 400 43
PipelineOptionsFactory.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/options
 837 42
TriggerContextFactory.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 377 42
StreamingDataflowWorker.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 862 41
DoFnRunner.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 434 37
CalendarWindows.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing
 203 36
PartialGroupByKeyOperation.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker
 412 35
FileBasedSink.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/io
 372 35
ApiSurface.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 333 34
AvroSource.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/io
 367 34
AvroCoder.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/coders
 390 33
Window.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing
 271 32
StreamingModeExecutionContext.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 400 32
StateTags.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state
 253 31
FileBasedSource.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/io
 392 30
CoGbkResult.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/join
 313 30
ApproximateQuantiles.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms
 434 30
WindmillStateInternals.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 415 30
MapTaskExecutorFactory.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 401 29
Structs.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 294 28
InMemoryStateInternals.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state
 207 27
CustomSources.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/dataflow
 539 27
HadoopFileSource.java
in contrib/hadoop/src/main/java/com/google/cloud/dataflow/contrib/hadoop
 341 26
CoderRegistry.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/coders
 468 26
ReduceFnRunner.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 452 25
IntraBundleParallelization.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms
 190 25
View.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms
 177 25
TextReader.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 271 25
XmlSource.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/io
 299 24
Pipeline.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk
 223 22
StateNamespaces.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state
 161 22
Read.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/io
 111 22
PaneInfo.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing
 198 22
Files With Long Lines (Top 1)

There is only one file with lines longer than 120 characters. In total, there is only one long line.

File# lines# units# long lines
archetype-metadata.xml
in maven-archetypes/starter/src/main/resources/META-INF/maven
 20 - 1
Correlations

File Size vs. Commits (all time): 502 points

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

File Size vs. Contributors (all time): 502 points

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

File Size vs. Commits (30 days): 0 points

No data for "commits (30d)" vs. "lines of code".

File Size vs. Contributors (30 days): 0 points

No data for "contributors (30d)" vs. "lines of code".

File Size vs. Commits (90 days): 0 points

No data for "commits (90d)" vs. "lines of code".

File Size vs. Contributors (90 days): 0 points

No data for "contributors (90d)" vs. "lines of code".