100644 blob 934054fe64fbb946b419ee1582637fbfbed00f34	ApplianceShuffleCounters.java
100644 blob abcf3c3b990686eb72084168ea5da49d2b1544e9	ApplianceShuffleEntryReader.java
100644 blob 8703fdafbea98cc761202b008547e161f33b4ad6	ApplianceShuffleReader.java
100644 blob f043516e14b907bd2db82b3534adc4ba48ce6d48	ApplianceShuffleWriter.java
100644 blob 9fe4bd60974c76651c6f2405b4969de5e7832d2c	AssignWindowsParDoFnFactory.java
100644 blob 0492e3dc83bc573dfecbd1019f69ed88823e1664	AvroByteReader.java
100644 blob 6437223b78b88ea82e92113e8666a195fb43d30f	AvroByteReaderFactory.java
100644 blob 9e0a2e98c0a6a1596808322811439c096bf55f91	AvroByteSink.java
100644 blob 0f2b0cc5fc914ac8aa84c99424c9b6872f691301	AvroByteSinkFactory.java
100644 blob cb697c1a8c760c5c62e39d05c186e3ef03c9a87c	BatchDataflowWorker.java
100644 blob cb54c60e257b2630590326f8b346a3ff0517eef6	BatchModeExecutionContext.java
100644 blob f5e9049a392fc4905b23baff0c3a0ff5f1cb9f10	BatchModeUngroupingParDoFn.java
100644 blob 8480dccf5c8551d14bef080e0a7b0f0e01f81876	BeamFnMapTaskExecutorFactory.java
100644 blob eab920f73b9497fbc3d0307674e2dcbd30d8f491	ByteStringCoder.java
100644 blob 3a8cbc8041e35e30cc0d71f937dffee27383d649	ChunkingShuffleBatchReader.java
100644 blob f23a8e714885e956f2c374c670675fc67acefdcb	CombinePhase.java
100644 blob 319c811fb441ee40058d03f6781b3ec5f7f2fdde	CombineValuesFnFactory.java
100644 blob 0829f70a9a4a36d4a4ec056028c61d97ac0bcf76	ConcatReader.java
100644 blob d96d5b441130ed932df682a36cd439310912144e	ConcatReaderFactory.java
100644 blob 10a6bd4ff6d55419e4e9fee46e687f322f9aa76b	ContextActivationObserver.java
100644 blob b7558af0447413799f9b56af27a5fa4810a0e6d7	ContextActivationObserverRegistry.java
100644 blob 6fe4fe8def99236d56510e0c4d1272fb61858147	CounterShortIdCache.java
100644 blob 87120b5fa4786e8e9d73be3d0959a41da3c439e4	CreateIsmShardKeyAndSortKeyDoFnFactory.java
100644 blob 1900a5105ce1694bdf992ba8294af133ce658177	DataflowApiUtils.java
100644 blob 51955f065cb1c22cf9d8109d3c4b0e11eb328d88	DataflowBatchWorkerHarness.java
100644 blob 270c0a9e63c2b834d833941f2c21b9f9c6f78c62	DataflowElementExecutionTracker.java
100644 blob 1e8271d716be4f1986387d79faf5ba2f20152f45	DataflowExecutionContext.java
100644 blob 7c435472c4f62c7e654a0cfec77a37dd211dd9be	DataflowExecutionStateKey.java
100644 blob a3fb42b55c704b04d08c7a806f5807bb330d0b92	DataflowExecutionStateRegistry.java
100644 blob 96db026fbdb592db66654c30f17bd043b9659c10	DataflowMapTaskExecutor.java
100644 blob 820bfd32ac577201d2ebc05a65b6d821161ea394	DataflowMapTaskExecutorFactory.java
100644 blob 7a68e8f819992213465b205b2ece52bd0655e2fa	DataflowMetricsContainer.java
100644 blob f4137c3ec30c86d0f4efbab078ac5e881d7d5924	DataflowOperationContext.java
100644 blob ac189a1cea43a0feac87568c103ed344e616d215	DataflowOutputCounter.java
100644 blob 60caa3a2d345e522f05d43e56a82529d3ffcffc1	DataflowPortabilityPCollectionView.java
100644 blob 7d9174ca3b4b585ad135f767aeb31affc28e5559	DataflowProcessFnRunner.java
100644 blob 4462c1e065bcd3b102054d5f3e9ad2e4dbcf9ce5	DataflowRunnerHarness.java
100644 blob 72a23401ecf63cd47bd7eab245b46f48a02034e3	DataflowSideInputReadCounter.java
100644 blob 0dae356b754b6bdccd4280785ffabe3ba03a5c78	DataflowSystemMetrics.java
100644 blob a97bbec1ab79397968165d1d70a63ba2554180eb	DataflowWorkExecutor.java
100644 blob 845690dd5dc2df469f91383671485746e6faec04	DataflowWorkProgressUpdater.java
100644 blob f2daa49e7cf2af801b330d16634ebce387792757	DataflowWorkUnitClient.java
100644 blob 461b7975f6bdee724d9d1938e87670ab35d50219	DataflowWorkerHarnessHelper.java
100644 blob 9dc8b1eaf5fa0370537a9188c925c730dc22fc57	DefaultParDoFnFactory.java
100644 blob 09f42c02add19c9524daf7f5997276adb69dca87	DeltaCounterCell.java
100644 blob 6e75d4b9eb371a8070955fcc3c371159a9a60943	DeltaDistributionCell.java
100644 blob 2ba466381aa15510c68b9f94d537b8ee2021ca84	DoFnInstanceManager.java
100644 blob 175bcefd46b673e9b4c35b9e9ddfeea23561919e	DoFnInstanceManagers.java
100644 blob 93ecccafe3f4a0cca8dd3efc3c81742d68a2c00d	DoFnRunnerFactory.java
100644 blob d215799e767aa834b35834efc4acfe9f1d83b698	ExperimentContext.java
100644 blob 2ae4c4eb8bdf32433e1982f72d60987a00d6f645	FetchAndFilterStreamingSideInputsOperation.java
100644 blob 68b798ce59c1b7e8f4024209a38b4123837db15c	Filepatterns.java
100644 blob d1683d0ae66bc0eb993f3f3970a16d2fe33b798c	FnApiWindowMappingFn.java
100644 blob d55181559322e5b500ae4793b99e76c07e45bf40	ForwardingParDoFn.java
100644 blob 8c467023d63a0b3de9d1ab9d84197939cdc325e0	GroupAlsoByWindowFn.java
100644 blob 95bbcddc4cce0b4cc267a219e5c9a87638872f37	GroupAlsoByWindowFnRunner.java
100644 blob 6ae8b24f881ddd0e185b6f0d76be33b0145b58db	GroupAlsoByWindowParDoFnFactory.java
100644 blob 2d48f95196d7c9631d5c75247b447778d582da39	GroupAlsoByWindowsParDoFn.java
100644 blob ac5582b832de8ed22b8f9abe5944cae86a8d4f93	GroupingShuffleReader.java
100644 blob 3df431c2b7112982deb30ecc68ac295f3e19d41b	GroupingShuffleReaderFactory.java
100644 blob a31780bda5f740c8de62cfd759fd451f551aba47	GroupingShuffleReaderWithFaultyBytesReadCounter.java
100644 blob 00d93890d9a2c1d7e92ea3ce622065619997f20f	HotKeyLogger.java
100644 blob 77863c0a436d871de7cb8ce11b7bd4f364ef2b33	InMemoryReader.java
100644 blob 2986374f69a88cb8cafc487027851371e273a90b	InMemoryReaderFactory.java
100644 blob 7aa00a1ec83a639a9a0b732f59b46d8a6961555f	IntrinsicMapTaskExecutor.java
100644 blob ea935344976b9761c19311ee3e49977a5d5cf951	IntrinsicMapTaskExecutorFactory.java
100644 blob 25fb7141facdde26d157869f80596f498be274bb	IsmReader.java
100644 blob 61c40127545b152de137ae22c4b7f0b3ce150d02	IsmReaderFactory.java
100644 blob 379e69a1512d2416f41c971e525a8e9cd397c825	IsmReaderImpl.java
100644 blob 37fa6fc67ab4a505a850ab4b57815a92d25f6ed1	IsmSideInputReader.java
100644 blob d59526f986dbebab12122df2e107bb89b1a00b6d	IsmSink.java
100644 blob 40018de54cf280dea743ae297ab1da4675e85800	IsmSinkFactory.java
100644 blob a774ef0e91fdfb7d679661b4371a2b6354a1507c	KeyTokenInvalidException.java
100644 blob 5bd34c05b94c5a1b5cb6c71b3b74f4f2dd70ecb1	LazilyInitializedSideInputReader.java
100644 blob d2eff46ef770bfe6f43a621c54108eeee01482e3	MetricTrackingWindmillServerStub.java
100644 blob 8120788353d3e8070f877c840d4e5b43ca7f70d3	MetricsContainerRegistry.java
100644 blob 9500170f24e83948355d2c40f6a8db5e16d8462c	MetricsEnvironmentContextActivationObserverRegistration.java
100644 blob 14c9b9f89dbe071d3da2adcb7fdd63e50e3624e8	MetricsToCounterUpdateConverter.java
100644 blob aa13b3b6958db78344ac90f6c4561d12dcf84c56	NoOpSourceOperationExecutor.java
100644 blob c6c80496c101c29573e24c64dccc0c63cd79b3c9	NoopSideInputReadCounter.java
100644 blob 84036e88247af8bf9997148541e84ded1af0c967	OrderedCode.java
100644 blob 65b36bd4609cbd4bc644c9a48fdac686e1711b11	PCollectionViewWindow.java
100644 blob 8abd9989dc75eeadf24eb54940969bdb2633f617	PairWithConstantKeyDoFnFactory.java
100644 blob c76fefbdcac0adc3871e1924424e0a551fdbf8da	ParDoFnFactory.java
100644 blob cfaef527458deb542fd05a86afc3bb08ae6641f1	PartialGroupByKeyParDoFns.java
100644 blob a52315df53e942dc65ea766c0582c0dbd822aa34	PartitioningShuffleReader.java
100644 blob a5a470b4d9578598325fac609386794d13bd891c	PartitioningShuffleReaderFactory.java
100644 blob 9ee512450fedbe71bd94ad1549ce1150232361c8	PubsubReader.java
100644 blob 72e3b4c5e402bec5b0d7397b1550a177261cddfc	PubsubSink.java
100644 blob 58f3abfc66a2083f65a0aaf5b65c598785764089	ReaderCache.java
100644 blob 0ff57bd332821f5169646ae7f50eb51da033e349	ReaderFactory.java
100644 blob 9a9d6b935a2872359e1e8fee3d2bf96a46cc540d	ReaderRegistry.java
100644 blob daa3e094ee2746ab653b149252d1f3fd7272e044	ReaderUtils.java
100644 blob 8cc17818aa228797db7eef17c3aeffdb9a0866d0	ReifyTimestampAndWindowsParDoFnFactory.java
100644 blob 02c72784acfd5623070804b457e914b54a614595	RunnerHarnessCoderCloudObjectTranslatorRegistrar.java
100644 blob 0da3475c34a79e024194b5dc5e12e14f056e5d2c	SdkHarnessRegistries.java
100644 blob 401e6b95d7cf8af57c0a3d661ecc4c2e16d70f3b	SdkHarnessRegistry.java
100644 blob 361623974d2d78a990a11b0383c566d70b9008e7	ShuffleLibrary.java
100644 blob f663abad85f77c9ab352a1f884e3b9a9bb0d65b2	ShuffleReader.java
100644 blob 2d88920797f9846221308abbe9e1c0f7d3991ffe	ShuffleSink.java
100644 blob e66e52843ad9c15b1b947d65008a3634620b0490	ShuffleSinkFactory.java
100644 blob 5315575293b420b8452c1350143cb6a1bd8f83d7	ShuffleWriter.java
100644 blob 0caed4b40c5502215eb79ba5545a9f252a9d11a2	SideInputReadCounter.java
100644 blob 3d5640755a56d3c0ecfb9d5a6e126f7276f65ee6	SideInputTrackingIsmReader.java
100644 blob f69c7c50c3bdcd05dfef52339603fcb57710ea84	SimpleDoFnRunnerFactory.java
100644 blob 0d86830b2b14da0ddd7cf2f8b20c27e29833645d	SimpleParDoFn.java
100644 blob bd9b0dc258b6f49e7116d13c603f98b4a49eb5e2	SinkFactory.java
100644 blob aee28faf692a5aa08d32e667003d94a12fd66278	SinkRegistry.java
100644 blob 4005202c6632358867d58f2531fd0689544bb190	SizeReportingSinkWrapper.java
100644 blob 30cb03536316c791cac9d541aa0447f0f64df5de	SourceOperationExecutor.java
100644 blob 32c9dee5193cab7eaef8c38df4f33f82a45987b9	SourceOperationExecutorFactory.java
100644 blob af82acff56fe6047520fd42d456dce89bcbf486d	SourceTranslationUtils.java
100644 blob 66c3eb5366bbe253573e3e6014166235521329d5	SplittableProcessFnFactory.java
100644 blob aa393d2ea6af8fa93aa2c88fe85b0be815dd29c0	StateFetcher.java
100644 blob 154414fc39024975dff92c6e6dc290952831daa1	StreamingDataflowWorker.java
100644 blob be14e7cc3bcffddadf778e622d571d52390a40cd	StreamingGroupAlsoByWindowReshuffleFn.java
100644 blob dd7d04f0013d48accc004dbb52653d619a0a6ecb	StreamingGroupAlsoByWindowViaWindowSetFn.java
100644 blob dc098e7c942dc219810f58a5db5ee4daabeb3ce8	StreamingGroupAlsoByWindowsDoFns.java
100644 blob 57f4689a57619a6bbf08b0d44d5c8087337cefb0	StreamingKeyedWorkItemSideInputDoFnRunner.java
100644 blob 23c34aee771816ca6c39cfd587d159f68f88d99a	StreamingModeExecutionContext.java
100644 blob 238d6d6abd714796a9c9439ebb76bea0d5d8c5b9	StreamingPCollectionViewWriterDoFnFactory.java
100644 blob ea27305c6c4253ccd2bf02403d114f419a2b142a	StreamingPCollectionViewWriterParDoFn.java
100644 blob 7b53ee5dad2e93ac571530dfb76f99bfd5e6e5a1	StreamingSideInputDoFnRunner.java
100644 blob e87855c3ba29168492a0daeaedd380f98873a0ec	StreamingSideInputFetcher.java
100644 blob 471106466e47749d302a7cc5eeb601fd09c0edb8	StreamingStepMetricsContainer.java
100644 blob 9194f8f7b62ceba71c668e6f45d0961474f5e2c6	ToIsmRecordForMultimapDoFnFactory.java
100644 blob 50ed81b7ac78b0e1f50dfa585810a12d37e341f1	UngroupedShuffleReader.java
100644 blob f0222683d45c5dab432a2459a8b214db3013c88f	UngroupedShuffleReaderFactory.java
100644 blob 26b45e944ecd3de80aae375a85e1b84bdf6b87cb	UngroupedWindmillReader.java
100644 blob 58760ac35952ff0dbff5003db34ee5f258459401	UserParDoFnFactory.java
100644 blob 66b36342f7d667ffb0f78d268c7a0de7b4cae905	ValuesDoFnFactory.java
100644 blob d7c3847f348887bcc90a2344b24a2014acd9876a	Weighers.java
100644 blob ea5111c68f0e326f088b5d39c4c33b99e390469d	WindmillComputationKey.java
100644 blob 4524f0d82a6bb5d8d51840922e198f376f7bb14d	WindmillKeyedWorkItem.java
100644 blob 2dd70062c63463e8c317d4d87bb59a168410b945	WindmillNamespacePrefix.java
100644 blob a89696dbbcd9af0df12805d2e1b21283e4d94302	WindmillReaderIteratorBase.java
100644 blob cd4676a9156fc151afe6805b40514413b029b9ee	WindmillSink.java
100644 blob f8eff5c80dff11d378a826a043e39cf3d8ad1e39	WindmillStateCache.java
100644 blob 15d399bc16ebe455501bd289d48cd0b0811ac5c3	WindmillStateInternals.java
100644 blob 8d727da715fc1a77eb3b09ebcf99405cef778f13	WindmillStateReader.java
100644 blob 8552c27d5967e5db681a1704f85914696486b8db	WindmillTimeUtils.java
100644 blob a102e178aea57d50f5c9d7dcba4d9e0356122684	WindmillTimerInternals.java
100644 blob 13b538f978b84512c0f6ba76a2ea96d874adae8f	WindowingWindmillReader.java
100644 blob 4c37dbc548d6559831174f48a3cf928828900755	WorkItemStatusClient.java
100644 blob 12d85069c52035333cd58d5c54bacf32392da214	WorkUnitClient.java
100644 blob 36e80d00a0cd43c13eacf32e7a666d4016398354	WorkerCustomSourceOperationExecutor.java
100644 blob 4039996b73da98106b66114451d5268fe1fbc132	WorkerCustomSources.java
100644 blob 13abdebd1a8f69982d15ecc11294003d417e8030	WorkerPipelineOptionsFactory.java
100644 blob fa3910c695b91b934fa0bbd49691407cadff7a8d	WorkerUncaughtExceptionHandler.java
040000 tree e3bc2881ec646bd200916b67c20e18bfdbb2811c	apiary
040000 tree e39ef632c9661db564ff1eea71a872d835b1294d	counters
040000 tree 3e01cf4e20433a04dff53f7b5d592d629f8c74c8	fn
040000 tree c3ed7e67a0b83de8ce6dc415d65ee47f4ce668c5	graph
040000 tree 88e79d861fd0a8992e309f9b85df1eab26d297c2	logging
040000 tree befdbbb89193c9ff7c13f189c657343270ed40c0	options
040000 tree 3106c88a820e1098ab350c3769591e836a4cab68	profiler
040000 tree 3094809e8165ae4d742eed5d0c82cf288ec5074c	status
040000 tree 6dd671fc0654f6ae3bfe9064a4dea42ff82c8dea	util
040000 tree 2554cbcd7b78ade832fc04022955e07353ec7733	windmill