spotify / DataflowJavaSDK
File Age & Freshness

File age measurements show the distribution of file ages (days since the first commit) and the file freshness (days since the latest commit).

Summary
File Change History Overall
File Age Distribution Overall
Days since first update
  • There are 501 files with 51,322 lines of code in files.
    • 501 files that are 366+ days old (51,322 lines of code)
    • 0 files that are 181-365 days old (0 lines of code)
    • 0 files that are 91-180 days old (0 lines of code)
    • 0 files that are 31-90 days old (0 lines of code)
    • 0 files that are 1-30 days old (0 lines of code)
100% | 0% | 0% | 0% | 0%
Legend:
366+
181-365
91-180
31-90
1-30

explore: grouped by folders | grouped by age
File Freshness Distribution Overall
Days since last update
  • There are 501 files with 51,322 lines of code in files.
    • 501 files have been last changed 366+ days ago (51,322 lines of code)
    • 0 files have been last changed 181-365 days ago (0 lines of code)
    • 0 files have been last changed 91-180 days ago (0 lines of code)
    • 0 files have been last changed 31-90 days ago (0 lines of code)
    • 0 files have been last changed 1-30 days ago (0 lines of code)
100% | 0% | 0% | 0% | 0%
Legend:
366+
181-365
91-180
31-90
1-30

explore: grouped by folders | grouped by freshness
File Change History per File Extension
java, xml, md, txt, properties, proto, sh, gitignore, avsc, json, gitattributes, yaml
File Age Distribution per Extension
Days since first update
366+
181-365
91-180
31-90
1-30
java100% | 0% | 0% | 0% | 0%
proto100% | 0% | 0% | 0% | 0%
xml100% | 0% | 0% | 0% | 0%
File Freshness Distribution per Extension
Days since last update
366+
181-365
91-180
31-90
1-30
java100% | 0% | 0% | 0% | 0%
proto100% | 0% | 0% | 0% | 0%
xml100% | 0% | 0% | 0% | 0%
File Change History per Logical Decomposition
primary
primary (file age distribution)
Days since first update
366+
181-365
91-180
31-90
1-30
sdk100% | 0% | 0% | 0% | 0%
contrib100% | 0% | 0% | 0% | 0%
maven-archetypes100% | 0% | 0% | 0% | 0%
primary (file freshness distribution)
Days since last update
366+
181-365
91-180
31-90
1-30
sdk100% | 0% | 0% | 0% | 0%
contrib100% | 0% | 0% | 0% | 0%
maven-archetypes100% | 0% | 0% | 0% | 0%
Oldest Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
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
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
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...
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
Counter.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common
 705 75 2014-12-13 2015-09-11 12 8 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
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
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
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
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
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
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
ApproximateQuantiles.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms
 434 30 2014-12-13 2015-09-11 15 7 davor@google.com klk@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
PartialGroupByKeyOperation.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker
 412 35 2014-12-13 2015-10-16 12 9 davor@google.com robertwb@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
GcsPath.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/gcsfs
 400 43 2014-12-13 2015-09-29 8 8 davor@google.com dhalperi@google.com
OrderedCode.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 397 13 2014-12-13 2015-08-17 5 4 davor@google.com lcwik@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
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
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
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
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
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
Structs.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 294 28 2014-12-13 2015-09-11 5 4 davor@google.com klk@google.com
BigQueryTableRowIterator.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 294 17 2014-12-13 2015-10-09 10 5 davor@google.com dhalperi@google.com
ProxyInvocationHandler.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/options
 291 15 2014-12-13 2015-08-17 14 8 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
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
BigQueryTableInserter.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 240 11 2014-12-13 2015-10-08 11 8 davor@google.com dhalperi@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
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
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
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
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
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
TextSink.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 206 14 2014-12-13 2015-08-17 5 3 davor@google.com lcwik@google.com
CalendarWindows.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing
 203 36 2014-12-13 2015-09-11 10 9 davor@google.com klk@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
PackageUtil.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 196 11 2014-12-13 2015-08-29 15 7 davor@google.com dhalperi@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
ApproximateUnique.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms
 188 20 2014-12-13 2015-09-11 7 6 davor@google.com klk@google.com
CombineValuesFn.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 188 12 2014-12-13 2015-09-11 14 8 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
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
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
StateSampler.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker
 175 14 2014-12-13 2015-10-12 11 6 davor@google.com zhouyunqing@google.com
TestDataflowPipelineRunner.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/testing
 172 6 2014-12-13 2015-07-30 12 6 davor@google.com millsd@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
Files Not Recently Changed (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
proto
 35 - 2015-02-06 2015-02-06 1 1 davor@google.com davor@google.com
package-info.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners
 1 - 2014-12-13 2015-02-28 3 2 davor@google.com lcwik@google.com
package-info.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/dataflow
 1 - 2014-12-13 2015-02-28 3 2 davor@google.com lcwik@google.com
package-info.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/join
 1 - 2014-12-13 2015-02-28 3 2 davor@google.com lcwik@google.com
package-info.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/testing
 1 - 2014-12-13 2015-02-28 3 2 davor@google.com lcwik@google.com
package-info.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 1 - 2014-12-13 2015-02-28 2 2 davor@google.com lcwik@google.com
package-info.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/gcsfs
 1 - 2014-12-13 2015-02-28 2 2 davor@google.com lcwik@google.com
package-info.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common
 1 - 2014-12-13 2015-02-28 2 2 davor@google.com lcwik@google.com
package-info.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker
 1 - 2014-12-13 2015-02-28 2 2 davor@google.com lcwik@google.com
package-info.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 3 - 2014-12-13 2015-02-28 3 2 davor@google.com lcwik@google.com
ShufflePosition.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker
 3 - 2014-12-13 2015-02-28 2 2 davor@google.com lcwik@google.com
TestDataflowPipelineOptions.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/testing
 4 - 2014-12-13 2015-02-28 2 2 davor@google.com lcwik@google.com
Receiver.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker
 4 - 2014-12-13 2015-02-28 2 2 davor@google.com lcwik@google.com
ProgressTracker.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker
 5 - 2014-12-13 2015-02-28 2 2 davor@google.com lcwik@google.com
Reiterable.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common
 5 - 2014-12-13 2015-02-28 2 2 davor@google.com lcwik@google.com
Reiterator.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common
 5 - 2014-12-13 2015-02-28 2 2 davor@google.com lcwik@google.com
MimeTypes.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 5 - 2014-12-13 2015-02-28 2 2 davor@google.com lcwik@google.com
Base64Utils.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 6 1 2014-12-13 2015-02-28 2 2 davor@google.com lcwik@google.com
Stager.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 6 - 2015-01-30 2015-02-28 2 2 relax@google.com lcwik@google.com
ShuffleWriter.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 7 - 2014-12-13 2015-02-28 2 2 davor@google.com lcwik@google.com
CredentialFactory.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 7 - 2015-01-30 2015-02-28 2 2 relax@google.com lcwik@google.com
ElementByteSizeObservable.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common
 7 - 2014-12-13 2015-02-28 2 2 davor@google.com lcwik@google.com
WindmillServerStub.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/windmill
 9 - 2015-02-04 2015-02-28 2 2 millsd@google.com lcwik@google.com
ElementByteSizeObservableIterator.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common
 10 1 2014-12-13 2015-02-28 2 2 davor@google.com lcwik@google.com
SourceOperationExecutorFactory.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 11 1 2014-12-13 2015-02-28 3 3 davor@google.com lcwik@google.com
KeyGroupedShuffleEntries.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker
 13 1 2014-12-13 2015-02-28 2 2 davor@google.com lcwik@google.com
ShuffleReader.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 14 1 2014-12-13 2015-02-28 2 2 davor@google.com lcwik@google.com
NoopCredentialFactory.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 14 2 2015-01-30 2015-02-28 2 2 relax@google.com lcwik@google.com
OutputReference.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 16 1 2014-12-13 2015-02-28 2 2 davor@google.com lcwik@google.com
ShuffleBatchReader.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker
 18 1 2014-12-13 2015-02-28 2 2 davor@google.com lcwik@google.com
ShuffleLibrary.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 19 1 2014-12-13 2015-02-28 2 2 davor@google.com lcwik@google.com
RawUnionValue.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/join
 19 4 2014-12-13 2015-02-28 4 4 davor@google.com lcwik@google.com
GcpCredentialFactory.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 19 3 2015-01-30 2015-02-28 2 2 relax@google.com lcwik@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
TestCredential.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 25 3 2014-12-13 2015-02-28 3 3 davor@google.com lcwik@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
FlattenOperation.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker
 34 4 2014-12-13 2015-02-28 3 3 davor@google.com lcwik@google.com
CloudMetricUtils.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 41 4 2014-12-13 2015-02-28 2 2 davor@google.com lcwik@google.com
AvroByteSink.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 46 6 2014-12-13 2015-02-28 3 3 davor@google.com lcwik@google.com
DataflowReleaseInfo.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 48 4 2014-12-13 2015-02-28 2 2 davor@google.com lcwik@google.com
MergeOverlappingIntervalWindows.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing
 55 7 2014-12-13 2015-02-28 3 3 davor@google.com lcwik@google.com
PeekingReiterator.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common
 55 7 2014-12-13 2015-02-28 4 4 davor@google.com lcwik@google.com
Values.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 60 6 2014-12-13 2015-02-28 2 2 davor@google.com lcwik@google.com
BatchingShuffleEntryReader.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker
 86 9 2014-12-13 2015-02-28 3 3 davor@google.com lcwik@google.com
CloudKnownType.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 107 10 2014-12-13 2015-02-28 2 2 davor@google.com lcwik@google.com
CopyableSeekableByteChannel.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 149 14 2014-12-13 2015-02-28 2 2 davor@google.com lcwik@google.com
AvroSink.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 90 8 2014-12-13 2015-03-06 3 3 davor@google.com millsd@google.com
StreamingOptions.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/options
 7 - 2014-12-13 2015-03-13 5 3 davor@google.com lcwik@google.com
Hidden.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/options
 9 - 2015-03-13 2015-03-13 1 1 lcwik@google.com lcwik@google.com
ReaderUtils.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 18 1 2014-12-20 2015-03-19 3 2 kirpichov@google.com kirpichov@google.com
Most Recently Created Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
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
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
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
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
CustomSources.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/dataflow
 539 27 2015-10-05 2015-10-22 2 2 kirpichov@google.com robertwb@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
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
TriggerBuilder.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing
 4 - 2015-10-01 2015-10-01 1 1 bchambers@google.com bchambers@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
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
FlatMapElements.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms
 59 5 2015-09-17 2015-10-08 3 2 klk@google.com dhalperi@google.com
SimpleFunction.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms
 11 2 2015-09-17 2015-09-17 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
NullableCoder.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/coders
 97 11 2015-09-04 2015-09-11 2 2 dhalperi@google.com klk@google.com
SerializableMatchers.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/testing
 719 57 2015-09-03 2015-09-11 2 2 klk@google.com klk@google.com
SerializableMatcher.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/testing
 5 - 2015-09-03 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
WindmillStateInternals.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 415 30 2015-08-29 2015-10-16 3 3 klk@google.com robertwb@google.com
StreamingModeExecutionContext.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 400 32 2015-08-29 2015-10-05 7 5 klk@google.com kirpichov@google.com
WindmillStateReader.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 334 15 2015-08-29 2015-09-09 2 2 klk@google.com millsd@google.com
StreamingSideInputDoFnRunner.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 222 6 2015-08-29 2015-09-11 2 2 klk@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
StateFetcher.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 163 11 2015-08-29 2015-09-09 2 2 klk@google.com millsd@google.com
StreamingGroupAlsoByWindowsDoFn.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 70 3 2015-08-29 2015-10-09 5 2 klk@google.com bchambers@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
StarterPipeline.java
in maven-archetypes/starter/src/main/resources/archetype-resources/src/main/java
 29 1 2015-08-26 2015-10-01 3 3 bchambers@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
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
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
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
OffsetBasedSource.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/io
 135 15 2015-08-06 2015-09-11 3 3 kirpichov@google.com klk@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
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
MutationDetector.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 4 - 2015-08-05 2015-08-05 1 1 klk@google.com klk@google.com
AppliedCombineFn.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 44 3 2015-07-30 2015-09-11 2 2 bchambers@google.com klk@google.com
DataflowJobAlreadyUpdatedException.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners
 7 1 2015-07-30 2015-09-11 2 2 lcwik@google.com klk@google.com
DataflowJobAlreadyExistsException.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners
 7 1 2015-07-30 2015-09-11 2 2 lcwik@google.com klk@google.com
package-info.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/io/range
 1 - 2015-07-27 2015-07-27 1 1 kirpichov@google.com kirpichov@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
BaseExecutionContext.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 74 10 2015-07-25 2015-08-18 3 3 klk@google.com millsd@google.com
Reshuffle.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 86 9 2015-07-24 2015-10-26 5 3 bchambers@google.com klk@google.com
BoundedReadFromUnboundedSource.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/io
 194 18 2015-07-22 2015-10-30 6 5 millsd@google.com dhalperi@users.noreply.gith...
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
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
DataflowJobExecutionException.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners
 11 - 2015-07-22 2015-09-11 2 1 klk@google.com klk@google.com
DataflowServiceException.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners
 10 - 2015-07-22 2015-09-11 2 1 klk@google.com klk@google.com
DataflowJobCancelledException.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners
 9 2 2015-07-22 2015-09-11 2 1 klk@google.com klk@google.com
ValueWithRecordId.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 110 13 2015-07-21 2015-09-11 4 2 millsd@google.com klk@google.com
OutputObjectAndByteCounter.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker
 100 12 2015-07-21 2015-08-27 2 2 peihe@google.com millsd@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
Most Recently Changed Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
HadoopFileSource.java
in contrib/hadoop/src/main/java/com/google/cloud/dataflow/contrib/hadoop
 341 26 2015-06-10 2015-11-10 3 3 tom@cloudera.com davor@google.com
SideInputUtils.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 142 13 2014-12-13 2015-11-10 8 6 davor@google.com lcwik@google.com
OrFinallyTrigger.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing
 52 2 2015-07-08 2015-11-09 5 3 bchambers@google.com millsd@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
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
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
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
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
MetricTrackingWindmillServerStub.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 40 2 2015-07-15 2015-11-05 2 2 bchambers@google.com markshields@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
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
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
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
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
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
WritableCoder.java
in contrib/hadoop/src/main/java/com/google/cloud/dataflow/contrib/hadoop
 64 7 2015-06-10 2015-11-03 2 2 tom@cloudera.com dhalperi@users.noreply.gith...
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
BoundedReadFromUnboundedSource.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/io
 194 18 2015-07-22 2015-10-30 6 5 millsd@google.com dhalperi@users.noreply.gith...
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
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...
TextReader.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 271 25 2014-12-20 2015-10-27 6 5 kirpichov@google.com robertwb@google.com
FileBasedReader.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 225 12 2014-12-20 2015-10-27 11 7 kirpichov@google.com robertwb@google.com
WindowingStrategy.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 149 19 2015-04-05 2015-10-26 12 3 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
Reshuffle.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 86 9 2015-07-24 2015-10-26 5 3 bchambers@google.com klk@google.com
Sum.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms
 69 9 2014-12-13 2015-10-26 10 8 davor@google.com tgroh@google.com
FixedWindows.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing
 56 10 2014-12-13 2015-10-26 12 8 davor@google.com klk@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
CustomSources.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/dataflow
 539 27 2015-10-05 2015-10-22 2 2 kirpichov@google.com robertwb@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
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
ReflectHelpers.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common
 148 13 2015-03-13 2015-10-22 5 3 bchambers@google.com kak@google.com
InMemoryReader.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 110 9 2014-12-20 2015-10-22 8 5 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
ByteArrayShufflePosition.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 69 9 2014-12-13 2015-10-22 7 7 davor@google.com robertwb@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
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
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
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
DirectPipelineOptions.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/options
 33 - 2014-12-13 2015-10-21 5 5 davor@google.com tgroh@google.com
ActiveWindowSet.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 17 - 2015-06-23 2015-10-21 4 2 bchambers@google.com dhalperi@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
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
ExecutableTrigger.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 135 18 2015-05-05 2015-10-20 6 2 bchambers@google.com bchambers@google.com
StringUtf8Coder.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/coders
 92 9 2014-12-13 2015-10-20 13 7 davor@google.com bchambers@google.com
WindmillStateInternals.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker
 415 30 2015-08-29 2015-10-16 3 3 klk@google.com robertwb@google.com
PartialGroupByKeyOperation.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker
 412 35 2014-12-13 2015-10-16 12 9 davor@google.com robertwb@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
PCollectionViews.java
in sdk/src/main/java/com/google/cloud/dataflow/sdk/util
 252 18 2015-06-23 2015-10-15 8 5 klk@google.com lcwik@google.com