You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by da...@apache.org on 2016/04/14 06:48:38 UTC
[51/74] [partial] incubator-beam git commit: Rename
com/google/cloud/dataflow->org/apache/beam
Rename com/google/cloud/dataflow->org/apache/beam
Applied this script:
mkdir -p $1/org/apache/beam;
git mv $1/com/google/cloud/dataflow/* $1/org/apache;
rmdir -p $1/com/google/cloud/dataflow;
To these directories:
- sdks/java/core/src/{main,test}
- sdks/java/java8tests/src/test
- runners/google-cloud-dataflow-java/src/{main,test}
- contrib/{join-library,hadoop}/src/{main,test}
- examples/java{,8}/src/{main,test}
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/0393a791
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/0393a791
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/0393a791
Branch: refs/heads/master
Commit: 0393a7917318baaa1e580259a74bff2c1dcbe6b8
Parents: c4cbbb1
Author: bchambers <bc...@google.com>
Authored: Wed Apr 13 14:18:40 2016 -0700
Committer: bchambers <bc...@google.com>
Committed: Wed Apr 13 17:34:42 2016 -0700
----------------------------------------------------------------------
.../contrib/hadoop/HadoopFileSource.java | 486 ---
.../dataflow/contrib/hadoop/WritableCoder.java | 111 -
.../apache/contrib/hadoop/HadoopFileSource.java | 486 +++
.../apache/contrib/hadoop/WritableCoder.java | 111 +
.../contrib/hadoop/HadoopFileSourceTest.java | 190 --
.../contrib/hadoop/WritableCoderTest.java | 37 -
.../contrib/hadoop/HadoopFileSourceTest.java | 190 ++
.../contrib/hadoop/WritableCoderTest.java | 37 +
.../dataflow/contrib/joinlibrary/Join.java | 186 --
.../org/apache/contrib/joinlibrary/Join.java | 186 ++
.../contrib/joinlibrary/InnerJoinTest.java | 143 -
.../contrib/joinlibrary/OuterLeftJoinTest.java | 153 -
.../contrib/joinlibrary/OuterRightJoinTest.java | 153 -
.../contrib/joinlibrary/InnerJoinTest.java | 143 +
.../contrib/joinlibrary/OuterLeftJoinTest.java | 153 +
.../contrib/joinlibrary/OuterRightJoinTest.java | 153 +
.../dataflow/examples/DebuggingWordCount.java | 199 --
.../dataflow/examples/MinimalWordCount.java | 118 -
.../dataflow/examples/WindowedWordCount.java | 270 --
.../cloud/dataflow/examples/WordCount.java | 207 --
.../examples/common/DataflowExampleOptions.java | 37 -
.../examples/common/DataflowExampleUtils.java | 488 ---
.../common/ExampleBigQueryTableOptions.java | 56 -
...xamplePubsubTopicAndSubscriptionOptions.java | 47 -
.../common/ExamplePubsubTopicOptions.java | 47 -
.../examples/common/PubsubFileInjector.java | 154 -
.../examples/complete/AutoComplete.java | 517 ---
.../cloud/dataflow/examples/complete/README.md | 44 -
.../examples/complete/StreamingWordExtract.java | 164 -
.../cloud/dataflow/examples/complete/TfIdf.java | 432 ---
.../examples/complete/TopWikipediaSessions.java | 224 --
.../examples/complete/TrafficMaxLaneFlow.java | 426 ---
.../examples/complete/TrafficRoutes.java | 460 ---
.../examples/cookbook/BigQueryTornadoes.java | 180 --
.../cookbook/CombinePerKeyExamples.java | 224 --
.../examples/cookbook/DatastoreWordCount.java | 270 --
.../examples/cookbook/DeDupExample.java | 101 -
.../examples/cookbook/FilterExamples.java | 267 --
.../examples/cookbook/JoinExamples.java | 186 --
.../examples/cookbook/MaxPerKeyExamples.java | 174 -
.../cloud/dataflow/examples/cookbook/README.md | 55 -
.../examples/cookbook/TriggerExample.java | 565 ----
.../beam/examples/DebuggingWordCount.java | 199 ++
.../apache/beam/examples/MinimalWordCount.java | 118 +
.../apache/beam/examples/WindowedWordCount.java | 270 ++
.../org/apache/beam/examples/WordCount.java | 207 ++
.../examples/common/DataflowExampleOptions.java | 37 +
.../examples/common/DataflowExampleUtils.java | 488 +++
.../common/ExampleBigQueryTableOptions.java | 56 +
...xamplePubsubTopicAndSubscriptionOptions.java | 47 +
.../common/ExamplePubsubTopicOptions.java | 47 +
.../examples/common/PubsubFileInjector.java | 154 +
.../beam/examples/complete/AutoComplete.java | 517 +++
.../org/apache/beam/examples/complete/README.md | 44 +
.../examples/complete/StreamingWordExtract.java | 164 +
.../apache/beam/examples/complete/TfIdf.java | 432 +++
.../examples/complete/TopWikipediaSessions.java | 224 ++
.../examples/complete/TrafficMaxLaneFlow.java | 426 +++
.../beam/examples/complete/TrafficRoutes.java | 460 +++
.../examples/cookbook/BigQueryTornadoes.java | 180 ++
.../cookbook/CombinePerKeyExamples.java | 224 ++
.../examples/cookbook/DatastoreWordCount.java | 270 ++
.../beam/examples/cookbook/DeDupExample.java | 101 +
.../beam/examples/cookbook/FilterExamples.java | 267 ++
.../beam/examples/cookbook/JoinExamples.java | 186 ++
.../examples/cookbook/MaxPerKeyExamples.java | 174 +
.../org/apache/beam/examples/cookbook/README.md | 55 +
.../beam/examples/cookbook/TriggerExample.java | 565 ++++
.../examples/DebuggingWordCountTest.java | 46 -
.../cloud/dataflow/examples/WordCountTest.java | 86 -
.../examples/complete/AutoCompleteTest.java | 182 --
.../dataflow/examples/complete/TfIdfTest.java | 68 -
.../complete/TopWikipediaSessionsTest.java | 63 -
.../cookbook/BigQueryTornadoesTest.java | 81 -
.../cookbook/CombinePerKeyExamplesTest.java | 91 -
.../examples/cookbook/DeDupExampleTest.java | 84 -
.../examples/cookbook/FilterExamplesTest.java | 86 -
.../examples/cookbook/JoinExamplesTest.java | 115 -
.../cookbook/MaxPerKeyExamplesTest.java | 86 -
.../examples/cookbook/TriggerExampleTest.java | 140 -
.../beam/examples/DebuggingWordCountTest.java | 45 +
.../org/apache/beam/examples/WordCountTest.java | 86 +
.../examples/complete/AutoCompleteTest.java | 182 ++
.../beam/examples/complete/TfIdfTest.java | 68 +
.../complete/TopWikipediaSessionsTest.java | 63 +
.../cookbook/BigQueryTornadoesTest.java | 81 +
.../cookbook/CombinePerKeyExamplesTest.java | 91 +
.../examples/cookbook/DeDupExampleTest.java | 84 +
.../examples/cookbook/FilterExamplesTest.java | 86 +
.../examples/cookbook/JoinExamplesTest.java | 115 +
.../cookbook/MaxPerKeyExamplesTest.java | 86 +
.../examples/cookbook/TriggerExampleTest.java | 138 +
.../examples/MinimalWordCountJava8.java | 69 -
.../examples/complete/game/GameStats.java | 340 --
.../examples/complete/game/HourlyTeamScore.java | 194 --
.../examples/complete/game/LeaderBoard.java | 238 --
.../dataflow/examples/complete/game/README.md | 113 -
.../examples/complete/game/UserScore.java | 240 --
.../complete/game/injector/Injector.java | 416 ---
.../complete/game/injector/InjectorUtils.java | 102 -
.../injector/RetryHttpInitializerWrapper.java | 129 -
.../complete/game/utils/WriteToBigQuery.java | 135 -
.../game/utils/WriteWindowedToBigQuery.java | 77 -
.../beam/examples/MinimalWordCountJava8.java | 69 +
.../beam/examples/complete/game/GameStats.java | 340 ++
.../examples/complete/game/HourlyTeamScore.java | 194 ++
.../examples/complete/game/LeaderBoard.java | 238 ++
.../beam/examples/complete/game/README.md | 113 +
.../beam/examples/complete/game/UserScore.java | 240 ++
.../complete/game/injector/Injector.java | 416 +++
.../complete/game/injector/InjectorUtils.java | 102 +
.../injector/RetryHttpInitializerWrapper.java | 129 +
.../complete/game/utils/WriteToBigQuery.java | 135 +
.../game/utils/WriteWindowedToBigQuery.java | 77 +
.../examples/MinimalWordCountJava8Test.java | 104 -
.../examples/complete/game/GameStatsTest.java | 77 -
.../complete/game/HourlyTeamScoreTest.java | 112 -
.../examples/complete/game/UserScoreTest.java | 155 -
.../examples/MinimalWordCountJava8Test.java | 104 +
.../examples/complete/game/GameStatsTest.java | 77 +
.../complete/game/HourlyTeamScoreTest.java | 112 +
.../examples/complete/game/UserScoreTest.java | 155 +
.../BlockingDataflowPipelineOptions.java | 50 -
.../sdk/options/CloudDebuggerOptions.java | 53 -
.../options/DataflowPipelineDebugOptions.java | 254 --
.../sdk/options/DataflowPipelineOptions.java | 115 -
.../DataflowPipelineWorkerPoolOptions.java | 258 --
.../sdk/options/DataflowProfilingOptions.java | 48 -
.../options/DataflowWorkerHarnessOptions.java | 51 -
.../options/DataflowWorkerLoggingOptions.java | 155 -
.../runners/BlockingDataflowPipelineRunner.java | 186 --
.../DataflowJobAlreadyExistsException.java | 35 -
.../DataflowJobAlreadyUpdatedException.java | 34 -
.../runners/DataflowJobCancelledException.java | 39 -
.../sdk/runners/DataflowJobException.java | 41 -
.../runners/DataflowJobExecutionException.java | 35 -
.../runners/DataflowJobUpdatedException.java | 52 -
.../dataflow/sdk/runners/DataflowPipeline.java | 60 -
.../sdk/runners/DataflowPipelineJob.java | 394 ---
.../sdk/runners/DataflowPipelineRegistrar.java | 59 -
.../sdk/runners/DataflowPipelineRunner.java | 3009 ------------------
.../runners/DataflowPipelineRunnerHooks.java | 39 -
.../sdk/runners/DataflowPipelineTranslator.java | 1100 -------
.../sdk/runners/DataflowServiceException.java | 33 -
.../sdk/runners/dataflow/AssignWindows.java | 90 -
.../runners/dataflow/BigQueryIOTranslator.java | 126 -
.../sdk/runners/dataflow/CustomSources.java | 119 -
.../dataflow/DataflowAggregatorTransforms.java | 80 -
.../dataflow/DataflowMetricUpdateExtractor.java | 111 -
.../runners/dataflow/PubsubIOTranslator.java | 108 -
.../sdk/runners/dataflow/ReadTranslator.java | 104 -
.../sdk/runners/dataflow/package-info.java | 21 -
.../testing/TestDataflowPipelineOptions.java | 27 -
.../sdk/testing/TestDataflowPipelineRunner.java | 256 --
.../sdk/util/DataflowPathValidator.java | 98 -
.../dataflow/sdk/util/DataflowTransport.java | 112 -
.../cloud/dataflow/sdk/util/GcsStager.java | 54 -
.../cloud/dataflow/sdk/util/MonitoringUtil.java | 235 --
.../cloud/dataflow/sdk/util/PackageUtil.java | 328 --
.../google/cloud/dataflow/sdk/util/Stager.java | 30 -
.../BlockingDataflowPipelineOptions.java | 50 +
.../beam/sdk/options/CloudDebuggerOptions.java | 53 +
.../options/DataflowPipelineDebugOptions.java | 254 ++
.../sdk/options/DataflowPipelineOptions.java | 115 +
.../DataflowPipelineWorkerPoolOptions.java | 258 ++
.../sdk/options/DataflowProfilingOptions.java | 48 +
.../options/DataflowWorkerHarnessOptions.java | 51 +
.../options/DataflowWorkerLoggingOptions.java | 155 +
.../runners/BlockingDataflowPipelineRunner.java | 186 ++
.../DataflowJobAlreadyExistsException.java | 35 +
.../DataflowJobAlreadyUpdatedException.java | 34 +
.../runners/DataflowJobCancelledException.java | 39 +
.../beam/sdk/runners/DataflowJobException.java | 41 +
.../runners/DataflowJobExecutionException.java | 35 +
.../runners/DataflowJobUpdatedException.java | 51 +
.../beam/sdk/runners/DataflowPipeline.java | 60 +
.../beam/sdk/runners/DataflowPipelineJob.java | 394 +++
.../sdk/runners/DataflowPipelineRegistrar.java | 59 +
.../sdk/runners/DataflowPipelineRunner.java | 3009 ++++++++++++++++++
.../runners/DataflowPipelineRunnerHooks.java | 39 +
.../sdk/runners/DataflowPipelineTranslator.java | 1100 +++++++
.../sdk/runners/DataflowServiceException.java | 33 +
.../sdk/runners/dataflow/AssignWindows.java | 89 +
.../runners/dataflow/BigQueryIOTranslator.java | 126 +
.../sdk/runners/dataflow/CustomSources.java | 119 +
.../dataflow/DataflowAggregatorTransforms.java | 80 +
.../dataflow/DataflowMetricUpdateExtractor.java | 110 +
.../runners/dataflow/PubsubIOTranslator.java | 108 +
.../sdk/runners/dataflow/ReadTranslator.java | 104 +
.../beam/sdk/runners/dataflow/package-info.java | 21 +
.../testing/TestDataflowPipelineOptions.java | 27 +
.../sdk/testing/TestDataflowPipelineRunner.java | 256 ++
.../beam/sdk/util/DataflowPathValidator.java | 98 +
.../apache/beam/sdk/util/DataflowTransport.java | 112 +
.../org/apache/beam/sdk/util/GcsStager.java | 54 +
.../apache/beam/sdk/util/MonitoringUtil.java | 235 ++
.../org/apache/beam/sdk/util/PackageUtil.java | 328 ++
.../java/org/apache/beam/sdk/util/Stager.java | 30 +
.../dataflow/sdk/io/DataflowTextIOTest.java | 118 -
.../DataflowPipelineDebugOptionsTest.java | 41 -
.../options/DataflowPipelineOptionsTest.java | 92 -
.../options/DataflowProfilingOptionsTest.java | 49 -
.../DataflowWorkerLoggingOptionsTest.java | 75 -
.../BlockingDataflowPipelineRunnerTest.java | 302 --
.../sdk/runners/DataflowPipelineJobTest.java | 605 ----
.../runners/DataflowPipelineRegistrarTest.java | 73 -
.../sdk/runners/DataflowPipelineRunnerTest.java | 1369 --------
.../sdk/runners/DataflowPipelineTest.java | 45 -
.../runners/DataflowPipelineTranslatorTest.java | 890 ------
.../sdk/runners/dataflow/CustomSourcesTest.java | 274 --
.../testing/TestDataflowPipelineRunnerTest.java | 377 ---
.../sdk/transforms/DataflowGroupByKeyTest.java | 111 -
.../sdk/transforms/DataflowViewTest.java | 206 --
.../sdk/util/DataflowPathValidatorTest.java | 93 -
.../dataflow/sdk/util/MonitoringUtilTest.java | 148 -
.../dataflow/sdk/util/PackageUtilTest.java | 483 ---
.../apache/beam/sdk/io/DataflowTextIOTest.java | 117 +
.../DataflowPipelineDebugOptionsTest.java | 41 +
.../options/DataflowPipelineOptionsTest.java | 92 +
.../options/DataflowProfilingOptionsTest.java | 49 +
.../DataflowWorkerLoggingOptionsTest.java | 75 +
.../BlockingDataflowPipelineRunnerTest.java | 302 ++
.../sdk/runners/DataflowPipelineJobTest.java | 605 ++++
.../runners/DataflowPipelineRegistrarTest.java | 73 +
.../sdk/runners/DataflowPipelineRunnerTest.java | 1369 ++++++++
.../beam/sdk/runners/DataflowPipelineTest.java | 45 +
.../runners/DataflowPipelineTranslatorTest.java | 890 ++++++
.../sdk/runners/dataflow/CustomSourcesTest.java | 274 ++
.../testing/TestDataflowPipelineRunnerTest.java | 377 +++
.../sdk/transforms/DataflowGroupByKeyTest.java | 110 +
.../beam/sdk/transforms/DataflowViewTest.java | 205 ++
.../sdk/util/DataflowPathValidatorTest.java | 92 +
.../beam/sdk/util/MonitoringUtilTest.java | 148 +
.../apache/beam/sdk/util/PackageUtilTest.java | 483 +++
.../com/google/cloud/dataflow/sdk/Pipeline.java | 503 ---
.../cloud/dataflow/sdk/PipelineResult.java | 96 -
.../cloud/dataflow/sdk/coders/AtomicCoder.java | 52 -
.../cloud/dataflow/sdk/coders/AvroCoder.java | 715 -----
.../sdk/coders/BigEndianIntegerCoder.java | 100 -
.../dataflow/sdk/coders/BigEndianLongCoder.java | 100 -
.../dataflow/sdk/coders/ByteArrayCoder.java | 139 -
.../cloud/dataflow/sdk/coders/ByteCoder.java | 112 -
.../dataflow/sdk/coders/ByteStringCoder.java | 107 -
.../sdk/coders/CannotProvideCoderException.java | 96 -
.../google/cloud/dataflow/sdk/coders/Coder.java | 299 --
.../dataflow/sdk/coders/CoderException.java | 37 -
.../dataflow/sdk/coders/CoderFactories.java | 275 --
.../cloud/dataflow/sdk/coders/CoderFactory.java | 44 -
.../dataflow/sdk/coders/CoderProvider.java | 34 -
.../dataflow/sdk/coders/CoderProviders.java | 165 -
.../dataflow/sdk/coders/CoderRegistry.java | 844 -----
.../dataflow/sdk/coders/CollectionCoder.java | 74 -
.../cloud/dataflow/sdk/coders/CustomCoder.java | 138 -
.../cloud/dataflow/sdk/coders/DefaultCoder.java | 67 -
.../dataflow/sdk/coders/DelegateCoder.java | 165 -
.../sdk/coders/DeterministicStandardCoder.java | 39 -
.../cloud/dataflow/sdk/coders/DoubleCoder.java | 114 -
.../dataflow/sdk/coders/DurationCoder.java | 98 -
.../cloud/dataflow/sdk/coders/EntityCoder.java | 87 -
.../cloud/dataflow/sdk/coders/InstantCoder.java | 114 -
.../dataflow/sdk/coders/IterableCoder.java | 79 -
.../dataflow/sdk/coders/IterableLikeCoder.java | 279 --
.../cloud/dataflow/sdk/coders/JAXBCoder.java | 170 -
.../cloud/dataflow/sdk/coders/KvCoder.java | 163 -
.../cloud/dataflow/sdk/coders/KvCoderBase.java | 62 -
.../cloud/dataflow/sdk/coders/ListCoder.java | 78 -
.../cloud/dataflow/sdk/coders/MapCoder.java | 161 -
.../cloud/dataflow/sdk/coders/MapCoderBase.java | 55 -
.../dataflow/sdk/coders/NullableCoder.java | 179 --
.../cloud/dataflow/sdk/coders/Proto2Coder.java | 363 ---
.../dataflow/sdk/coders/SerializableCoder.java | 184 --
.../cloud/dataflow/sdk/coders/SetCoder.java | 95 -
.../dataflow/sdk/coders/StandardCoder.java | 230 --
.../sdk/coders/StringDelegateCoder.java | 87 -
.../dataflow/sdk/coders/StringUtf8Coder.java | 140 -
.../sdk/coders/StructuralByteArray.java | 58 -
.../dataflow/sdk/coders/TableRowJsonCoder.java | 83 -
.../sdk/coders/TextualIntegerCoder.java | 70 -
.../cloud/dataflow/sdk/coders/VarIntCoder.java | 98 -
.../cloud/dataflow/sdk/coders/VarLongCoder.java | 97 -
.../cloud/dataflow/sdk/coders/VoidCoder.java | 77 -
.../cloud/dataflow/sdk/coders/package-info.java | 45 -
.../sdk/coders/protobuf/ProtoCoder.java | 406 ---
.../sdk/coders/protobuf/ProtobufUtil.java | 172 -
.../sdk/coders/protobuf/package-info.java | 24 -
.../google/cloud/dataflow/sdk/io/AvroIO.java | 811 -----
.../cloud/dataflow/sdk/io/AvroSource.java | 648 ----
.../cloud/dataflow/sdk/io/BigQueryIO.java | 1685 ----------
.../cloud/dataflow/sdk/io/BlockBasedSource.java | 238 --
.../sdk/io/BoundedReadFromUnboundedSource.java | 272 --
.../cloud/dataflow/sdk/io/BoundedSource.java | 278 --
.../cloud/dataflow/sdk/io/CompressedSource.java | 414 ---
.../cloud/dataflow/sdk/io/CountingInput.java | 224 --
.../cloud/dataflow/sdk/io/CountingSource.java | 481 ---
.../cloud/dataflow/sdk/io/DatastoreIO.java | 947 ------
.../cloud/dataflow/sdk/io/FileBasedSink.java | 865 -----
.../cloud/dataflow/sdk/io/FileBasedSource.java | 663 ----
.../dataflow/sdk/io/OffsetBasedSource.java | 329 --
.../cloud/dataflow/sdk/io/PubsubClient.java | 322 --
.../cloud/dataflow/sdk/io/PubsubGrpcClient.java | 401 ---
.../google/cloud/dataflow/sdk/io/PubsubIO.java | 1048 ------
.../com/google/cloud/dataflow/sdk/io/Read.java | 254 --
.../dataflow/sdk/io/ShardNameTemplate.java | 76 -
.../com/google/cloud/dataflow/sdk/io/Sink.java | 255 --
.../google/cloud/dataflow/sdk/io/Source.java | 194 --
.../google/cloud/dataflow/sdk/io/TextIO.java | 991 ------
.../cloud/dataflow/sdk/io/UnboundedSource.java | 254 --
.../com/google/cloud/dataflow/sdk/io/Write.java | 217 --
.../google/cloud/dataflow/sdk/io/XmlSink.java | 311 --
.../google/cloud/dataflow/sdk/io/XmlSource.java | 544 ----
.../dataflow/sdk/io/bigtable/BigtableIO.java | 989 ------
.../sdk/io/bigtable/BigtableService.java | 110 -
.../sdk/io/bigtable/BigtableServiceImpl.java | 243 --
.../dataflow/sdk/io/bigtable/package-info.java | 23 -
.../cloud/dataflow/sdk/io/package-info.java | 38 -
.../cloud/dataflow/sdk/io/range/ByteKey.java | 174 -
.../dataflow/sdk/io/range/ByteKeyRange.java | 377 ---
.../sdk/io/range/ByteKeyRangeTracker.java | 118 -
.../sdk/io/range/OffsetRangeTracker.java | 183 --
.../dataflow/sdk/io/range/RangeTracker.java | 221 --
.../dataflow/sdk/io/range/package-info.java | 24 -
.../sdk/options/ApplicationNameOptions.java | 34 -
.../dataflow/sdk/options/BigQueryOptions.java | 32 -
.../cloud/dataflow/sdk/options/Default.java | 154 -
.../sdk/options/DefaultValueFactory.java | 39 -
.../cloud/dataflow/sdk/options/Description.java | 36 -
.../sdk/options/DirectPipelineOptions.java | 76 -
.../cloud/dataflow/sdk/options/GcpOptions.java | 292 --
.../cloud/dataflow/sdk/options/GcsOptions.java | 114 -
.../sdk/options/GoogleApiDebugOptions.java | 88 -
.../cloud/dataflow/sdk/options/Hidden.java | 34 -
.../dataflow/sdk/options/PipelineOptions.java | 264 --
.../sdk/options/PipelineOptionsFactory.java | 1490 ---------
.../sdk/options/PipelineOptionsRegistrar.java | 37 -
.../sdk/options/PipelineOptionsValidator.java | 103 -
.../sdk/options/ProxyInvocationHandler.java | 442 ---
.../dataflow/sdk/options/PubsubOptions.java | 36 -
.../dataflow/sdk/options/StreamingOptions.java | 31 -
.../cloud/dataflow/sdk/options/Validation.java | 47 -
.../dataflow/sdk/options/package-info.java | 26 -
.../google/cloud/dataflow/sdk/package-info.java | 34 -
.../runners/AggregatorPipelineExtractor.java | 98 -
.../runners/AggregatorRetrievalException.java | 33 -
.../dataflow/sdk/runners/AggregatorValues.java | 53 -
.../dataflow/sdk/runners/DirectPipeline.java | 56 -
.../sdk/runners/DirectPipelineRegistrar.java | 54 -
.../sdk/runners/DirectPipelineRunner.java | 1320 --------
.../dataflow/sdk/runners/PipelineRunner.java | 77 -
.../sdk/runners/PipelineRunnerRegistrar.java | 41 -
.../sdk/runners/RecordingPipelineVisitor.java | 55 -
.../sdk/runners/TransformHierarchy.java | 105 -
.../dataflow/sdk/runners/TransformTreeNode.java | 253 --
.../inprocess/AbstractModelEnforcement.java | 38 -
.../inprocess/AvroIOShardedWriteFactory.java | 76 -
.../inprocess/BoundedReadEvaluatorFactory.java | 156 -
.../sdk/runners/inprocess/BundleFactory.java | 50 -
.../CachedThreadPoolExecutorServiceFactory.java | 44 -
.../dataflow/sdk/runners/inprocess/Clock.java | 31 -
.../runners/inprocess/CompletionCallback.java | 36 -
.../ConsumerTrackingPipelineVisitor.java | 175 -
.../inprocess/EmptyTransformEvaluator.java | 51 -
.../EncodabilityEnforcementFactory.java | 71 -
.../sdk/runners/inprocess/EvaluatorKey.java | 57 -
.../inprocess/ExecutorServiceFactory.java | 34 -
.../ExecutorServiceParallelExecutor.java | 478 ---
.../inprocess/FlattenEvaluatorFactory.java | 85 -
.../runners/inprocess/ForwardingPTransform.java | 56 -
.../inprocess/GroupByKeyEvaluatorFactory.java | 273 --
.../ImmutabilityCheckingBundleFactory.java | 131 -
.../ImmutabilityEnforcementFactory.java | 104 -
.../inprocess/InMemoryWatermarkManager.java | 1313 --------
.../sdk/runners/inprocess/InProcessBundle.java | 123 -
.../inprocess/InProcessBundleFactory.java | 157 -
.../inprocess/InProcessBundleOutputManager.java | 52 -
.../sdk/runners/inprocess/InProcessCreate.java | 235 --
.../inprocess/InProcessEvaluationContext.java | 411 ---
.../inprocess/InProcessExecutionContext.java | 108 -
.../runners/inprocess/InProcessExecutor.java | 48 -
.../inprocess/InProcessPipelineOptions.java | 101 -
.../inprocess/InProcessPipelineRunner.java | 366 ---
.../runners/inprocess/InProcessRegistrar.java | 54 -
.../inprocess/InProcessSideInputContainer.java | 232 --
.../inprocess/InProcessTimerInternals.java | 85 -
.../inprocess/InProcessTransformResult.java | 77 -
.../inprocess/KeyedPValueTrackingVisitor.java | 97 -
.../sdk/runners/inprocess/ModelEnforcement.java | 63 -
.../inprocess/ModelEnforcementFactory.java | 30 -
.../sdk/runners/inprocess/NanosOffsetClock.java | 60 -
.../inprocess/PTransformOverrideFactory.java | 33 -
.../inprocess/ParDoInProcessEvaluator.java | 120 -
.../inprocess/ParDoMultiEvaluatorFactory.java | 92 -
.../inprocess/ParDoSingleEvaluatorFactory.java | 89 -
.../PassthroughTransformEvaluator.java | 49 -
.../runners/inprocess/ShardControlledWrite.java | 81 -
.../sdk/runners/inprocess/StepAndKey.java | 70 -
.../runners/inprocess/StepTransformResult.java | 164 -
.../inprocess/TextIOShardedWriteFactory.java | 78 -
.../runners/inprocess/TransformEvaluator.java | 47 -
.../inprocess/TransformEvaluatorFactory.java | 44 -
.../inprocess/TransformEvaluatorRegistry.java | 76 -
.../runners/inprocess/TransformExecutor.java | 175 -
.../inprocess/TransformExecutorService.java | 36 -
.../inprocess/TransformExecutorServices.java | 155 -
.../UnboundedReadEvaluatorFactory.java | 178 --
.../runners/inprocess/ViewEvaluatorFactory.java | 145 -
.../inprocess/WatermarkCallbackExecutor.java | 145 -
.../inprocess/WindowEvaluatorFactory.java | 131 -
.../dataflow/sdk/runners/package-info.java | 34 -
.../dataflow/sdk/runners/worker/IsmFormat.java | 948 ------
.../sdk/runners/worker/package-info.java | 25 -
.../dataflow/sdk/testing/CoderProperties.java | 350 --
.../cloud/dataflow/sdk/testing/PAssert.java | 825 -----
.../dataflow/sdk/testing/RunnableOnService.java | 34 -
.../sdk/testing/SerializableMatcher.java | 37 -
.../sdk/testing/SerializableMatchers.java | 1181 -------
.../dataflow/sdk/testing/SourceTestUtils.java | 676 ----
.../dataflow/sdk/testing/TestPipeline.java | 205 --
.../dataflow/sdk/testing/WindowFnTestUtils.java | 326 --
.../dataflow/sdk/testing/package-info.java | 22 -
.../dataflow/sdk/transforms/Aggregator.java | 79 -
.../sdk/transforms/AggregatorRetriever.java | 37 -
.../sdk/transforms/AppliedPTransform.java | 101 -
.../sdk/transforms/ApproximateQuantiles.java | 767 -----
.../sdk/transforms/ApproximateUnique.java | 420 ---
.../cloud/dataflow/sdk/transforms/Combine.java | 2242 -------------
.../dataflow/sdk/transforms/CombineFnBase.java | 285 --
.../dataflow/sdk/transforms/CombineFns.java | 1010 ------
.../sdk/transforms/CombineWithContext.java | 279 --
.../cloud/dataflow/sdk/transforms/Count.java | 193 --
.../cloud/dataflow/sdk/transforms/Create.java | 427 ---
.../cloud/dataflow/sdk/transforms/DoFn.java | 564 ----
.../dataflow/sdk/transforms/DoFnReflector.java | 669 ----
.../dataflow/sdk/transforms/DoFnTester.java | 496 ---
.../sdk/transforms/DoFnWithContext.java | 417 ---
.../cloud/dataflow/sdk/transforms/Filter.java | 235 --
.../sdk/transforms/FlatMapElements.java | 146 -
.../cloud/dataflow/sdk/transforms/Flatten.java | 220 --
.../dataflow/sdk/transforms/GroupByKey.java | 276 --
.../transforms/IntraBundleParallelization.java | 348 --
.../cloud/dataflow/sdk/transforms/Keys.java | 69 -
.../cloud/dataflow/sdk/transforms/KvSwap.java | 74 -
.../dataflow/sdk/transforms/MapElements.java | 113 -
.../cloud/dataflow/sdk/transforms/Max.java | 256 --
.../cloud/dataflow/sdk/transforms/Mean.java | 203 --
.../cloud/dataflow/sdk/transforms/Min.java | 256 --
.../dataflow/sdk/transforms/PTransform.java | 325 --
.../cloud/dataflow/sdk/transforms/ParDo.java | 1323 --------
.../dataflow/sdk/transforms/Partition.java | 174 -
.../sdk/transforms/RemoveDuplicates.java | 159 -
.../cloud/dataflow/sdk/transforms/Sample.java | 247 --
.../sdk/transforms/SerializableComparator.java | 29 -
.../sdk/transforms/SerializableFunction.java | 32 -
.../dataflow/sdk/transforms/SimpleFunction.java | 55 -
.../cloud/dataflow/sdk/transforms/Sum.java | 189 --
.../cloud/dataflow/sdk/transforms/Top.java | 560 ----
.../cloud/dataflow/sdk/transforms/Values.java | 69 -
.../cloud/dataflow/sdk/transforms/View.java | 471 ---
.../cloud/dataflow/sdk/transforms/WithKeys.java | 141 -
.../dataflow/sdk/transforms/WithTimestamps.java | 130 -
.../cloud/dataflow/sdk/transforms/Write.java | 30 -
.../sdk/transforms/display/DisplayData.java | 901 ------
.../sdk/transforms/display/HasDisplayData.java | 55 -
.../sdk/transforms/join/CoGbkResult.java | 464 ---
.../sdk/transforms/join/CoGbkResultSchema.java | 135 -
.../sdk/transforms/join/CoGroupByKey.java | 212 --
.../transforms/join/KeyedPCollectionTuple.java | 248 --
.../sdk/transforms/join/RawUnionValue.java | 52 -
.../sdk/transforms/join/UnionCoder.java | 148 -
.../sdk/transforms/join/package-info.java | 22 -
.../dataflow/sdk/transforms/package-info.java | 44 -
.../sdk/transforms/windowing/AfterAll.java | 114 -
.../windowing/AfterDelayFromFirstElement.java | 323 --
.../sdk/transforms/windowing/AfterEach.java | 133 -
.../sdk/transforms/windowing/AfterFirst.java | 117 -
.../sdk/transforms/windowing/AfterPane.java | 143 -
.../windowing/AfterProcessingTime.java | 96 -
.../AfterSynchronizedProcessingTime.java | 76 -
.../transforms/windowing/AfterWatermark.java | 396 ---
.../sdk/transforms/windowing/BoundedWindow.java | 47 -
.../transforms/windowing/CalendarWindows.java | 349 --
.../transforms/windowing/DefaultTrigger.java | 94 -
.../sdk/transforms/windowing/FixedWindows.java | 117 -
.../sdk/transforms/windowing/GlobalWindow.java | 69 -
.../sdk/transforms/windowing/GlobalWindows.java | 64 -
.../transforms/windowing/IntervalWindow.java | 202 --
.../transforms/windowing/InvalidWindows.java | 88 -
.../MergeOverlappingIntervalWindows.java | 87 -
.../windowing/NonMergingWindowFn.java | 36 -
.../transforms/windowing/OrFinallyTrigger.java | 102 -
.../sdk/transforms/windowing/OutputTimeFn.java | 320 --
.../sdk/transforms/windowing/OutputTimeFns.java | 169 -
.../sdk/transforms/windowing/PaneInfo.java | 385 ---
.../windowing/PartitioningWindowFn.java | 62 -
.../sdk/transforms/windowing/Repeatedly.java | 98 -
.../sdk/transforms/windowing/Sessions.java | 113 -
.../transforms/windowing/SlidingWindows.java | 215 --
.../sdk/transforms/windowing/Trigger.java | 535 ----
.../transforms/windowing/TriggerBuilder.java | 29 -
.../sdk/transforms/windowing/Window.java | 654 ----
.../sdk/transforms/windowing/WindowFn.java | 222 --
.../sdk/transforms/windowing/package-info.java | 50 -
.../dataflow/sdk/util/ActiveWindowSet.java | 182 --
.../cloud/dataflow/sdk/util/ApiSurface.java | 643 ----
.../dataflow/sdk/util/AppEngineEnvironment.java | 62 -
.../dataflow/sdk/util/AppliedCombineFn.java | 132 -
.../cloud/dataflow/sdk/util/AssignWindows.java | 46 -
.../dataflow/sdk/util/AssignWindowsDoFn.java | 68 -
...AttemptAndTimeBoundedExponentialBackOff.java | 169 -
.../util/AttemptBoundedExponentialBackOff.java | 84 -
.../cloud/dataflow/sdk/util/AvroUtils.java | 346 --
.../dataflow/sdk/util/BaseExecutionContext.java | 156 -
.../dataflow/sdk/util/BatchTimerInternals.java | 139 -
.../dataflow/sdk/util/BigQueryServices.java | 61 -
.../dataflow/sdk/util/BigQueryServicesImpl.java | 196 --
.../sdk/util/BigQueryTableInserter.java | 459 ---
.../sdk/util/BigQueryTableRowIterator.java | 472 ---
.../cloud/dataflow/sdk/util/BitSetCoder.java | 61 -
.../BufferedElementCountingOutputStream.java | 187 --
.../cloud/dataflow/sdk/util/CloudKnownType.java | 139 -
.../cloud/dataflow/sdk/util/CloudObject.java | 185 --
.../cloud/dataflow/sdk/util/CoderUtils.java | 328 --
.../sdk/util/CombineContextFactory.java | 109 -
.../cloud/dataflow/sdk/util/CombineFnUtil.java | 205 --
.../dataflow/sdk/util/CounterAggregator.java | 97 -
.../dataflow/sdk/util/CredentialFactory.java | 30 -
.../cloud/dataflow/sdk/util/Credentials.java | 193 --
.../dataflow/sdk/util/DataflowReleaseInfo.java | 88 -
.../sdk/util/DirectModeExecutionContext.java | 131 -
.../sdk/util/DirectSideInputReader.java | 74 -
.../cloud/dataflow/sdk/util/DoFnInfo.java | 68 -
.../cloud/dataflow/sdk/util/DoFnRunner.java | 62 -
.../cloud/dataflow/sdk/util/DoFnRunnerBase.java | 559 ----
.../cloud/dataflow/sdk/util/DoFnRunners.java | 144 -
.../dataflow/sdk/util/ExecutableTrigger.java | 158 -
.../dataflow/sdk/util/ExecutionContext.java | 103 -
.../sdk/util/ExposedByteArrayInputStream.java | 52 -
.../sdk/util/ExposedByteArrayOutputStream.java | 118 -
.../dataflow/sdk/util/FileIOChannelFactory.java | 136 -
.../dataflow/sdk/util/FinishedTriggers.java | 44 -
.../sdk/util/FinishedTriggersBitSet.java | 69 -
.../dataflow/sdk/util/FinishedTriggersSet.java | 75 -
.../dataflow/sdk/util/GcpCredentialFactory.java | 46 -
.../dataflow/sdk/util/GcsIOChannelFactory.java | 87 -
.../google/cloud/dataflow/sdk/util/GcsUtil.java | 411 ---
.../util/GroupAlsoByWindowViaWindowSetDoFn.java | 106 -
.../sdk/util/GroupAlsoByWindowsDoFn.java | 59 -
.../GroupAlsoByWindowsViaOutputBufferDoFn.java | 99 -
.../sdk/util/GroupByKeyViaGroupByKeyOnly.java | 246 --
.../dataflow/sdk/util/IOChannelFactory.java | 102 -
.../cloud/dataflow/sdk/util/IOChannelUtils.java | 205 --
.../sdk/util/IllegalMutationException.java | 53 -
.../dataflow/sdk/util/InstanceBuilder.java | 270 --
.../util/IntervalBoundedExponentialBackOff.java | 94 -
.../cloud/dataflow/sdk/util/KeyedWorkItem.java | 43 -
.../dataflow/sdk/util/KeyedWorkItemCoder.java | 122 -
.../cloud/dataflow/sdk/util/KeyedWorkItems.java | 122 -
.../sdk/util/LateDataDroppingDoFnRunner.java | 146 -
.../dataflow/sdk/util/MapAggregatorValues.java | 49 -
.../sdk/util/MergingActiveWindowSet.java | 575 ----
.../cloud/dataflow/sdk/util/MimeTypes.java | 24 -
.../dataflow/sdk/util/MutationDetector.java | 32 -
.../dataflow/sdk/util/MutationDetectors.java | 182 --
.../cloud/dataflow/sdk/util/NonEmptyPanes.java | 150 -
.../sdk/util/NonMergingActiveWindowSet.java | 92 -
.../sdk/util/NoopCredentialFactory.java | 39 -
.../dataflow/sdk/util/NoopPathValidator.java | 49 -
.../dataflow/sdk/util/NullSideInputReader.java | 62 -
.../dataflow/sdk/util/OutputReference.java | 43 -
.../sdk/util/PCollectionViewWindow.java | 68 -
.../dataflow/sdk/util/PCollectionViews.java | 427 ---
.../google/cloud/dataflow/sdk/util/PTuple.java | 161 -
.../dataflow/sdk/util/PaneInfoTracker.java | 153 -
.../cloud/dataflow/sdk/util/PathValidator.java | 48 -
.../sdk/util/PerKeyCombineFnRunner.java | 149 -
.../sdk/util/PerKeyCombineFnRunners.java | 259 --
.../cloud/dataflow/sdk/util/PropertyNames.java | 108 -
.../dataflow/sdk/util/RandomAccessData.java | 354 ---
.../cloud/dataflow/sdk/util/ReduceFn.java | 130 -
.../sdk/util/ReduceFnContextFactory.java | 496 ---
.../cloud/dataflow/sdk/util/ReduceFnRunner.java | 903 ------
.../sdk/util/ReifyTimestampAndWindowsDoFn.java | 47 -
.../cloud/dataflow/sdk/util/Reshuffle.java | 147 -
.../dataflow/sdk/util/ReshuffleTrigger.java | 63 -
.../sdk/util/RetryHttpRequestInitializer.java | 251 --
.../dataflow/sdk/util/SerializableUtils.java | 160 -
.../cloud/dataflow/sdk/util/Serializer.java | 146 -
.../sdk/util/ShardingWritableByteChannel.java | 119 -
.../dataflow/sdk/util/SideInputReader.java | 49 -
.../dataflow/sdk/util/SimpleDoFnRunner.java | 57 -
.../cloud/dataflow/sdk/util/StreamUtils.java | 69 -
.../cloud/dataflow/sdk/util/StringUtils.java | 243 --
.../google/cloud/dataflow/sdk/util/Structs.java | 385 ---
.../dataflow/sdk/util/SystemDoFnInternal.java | 39 -
.../cloud/dataflow/sdk/util/SystemReduceFn.java | 135 -
.../cloud/dataflow/sdk/util/TestCredential.java | 52 -
.../cloud/dataflow/sdk/util/TimeDomain.java | 43 -
.../cloud/dataflow/sdk/util/TimeUtil.java | 166 -
.../cloud/dataflow/sdk/util/TimerInternals.java | 270 --
.../google/cloud/dataflow/sdk/util/Timers.java | 60 -
.../cloud/dataflow/sdk/util/Transport.java | 151 -
.../sdk/util/TriggerContextFactory.java | 512 ---
.../cloud/dataflow/sdk/util/TriggerRunner.java | 233 --
.../dataflow/sdk/util/UnownedInputStream.java | 77 -
.../dataflow/sdk/util/UnownedOutputStream.java | 57 -
.../sdk/util/UploadIdResponseInterceptor.java | 62 -
.../dataflow/sdk/util/UserCodeException.java | 95 -
.../dataflow/sdk/util/ValueWithRecordId.java | 155 -
.../google/cloud/dataflow/sdk/util/Values.java | 89 -
.../google/cloud/dataflow/sdk/util/VarInt.java | 116 -
.../cloud/dataflow/sdk/util/WatermarkHold.java | 476 ---
.../cloud/dataflow/sdk/util/Weighted.java | 28 -
.../cloud/dataflow/sdk/util/WeightedValue.java | 46 -
.../cloud/dataflow/sdk/util/WindowTracing.java | 37 -
.../cloud/dataflow/sdk/util/WindowedValue.java | 721 -----
.../dataflow/sdk/util/WindowingInternals.java | 83 -
.../dataflow/sdk/util/WindowingStrategy.java | 267 --
.../cloud/dataflow/sdk/util/ZipFiles.java | 295 --
.../cloud/dataflow/sdk/util/common/Counter.java | 1104 -------
.../sdk/util/common/CounterProvider.java | 27 -
.../dataflow/sdk/util/common/CounterSet.java | 178 --
.../util/common/ElementByteSizeObservable.java | 42 -
.../ElementByteSizeObservableIterable.java | 64 -
.../ElementByteSizeObservableIterator.java | 37 -
.../util/common/ElementByteSizeObserver.java | 93 -
.../sdk/util/common/PeekingReiterator.java | 99 -
.../sdk/util/common/ReflectHelpers.java | 211 --
.../dataflow/sdk/util/common/Reiterable.java | 28 -
.../dataflow/sdk/util/common/Reiterator.java | 40 -
.../dataflow/sdk/util/common/package-info.java | 19 -
.../sdk/util/common/worker/StateSampler.java | 366 ---
.../sdk/util/common/worker/package-info.java | 19 -
.../cloud/dataflow/sdk/util/gcsfs/GcsPath.java | 620 ----
.../dataflow/sdk/util/gcsfs/package-info.java | 19 -
.../cloud/dataflow/sdk/util/package-info.java | 19 -
.../util/state/AccumulatorCombiningState.java | 53 -
.../cloud/dataflow/sdk/util/state/BagState.java | 28 -
.../dataflow/sdk/util/state/CombiningState.java | 42 -
.../CopyOnAccessInMemoryStateInternals.java | 456 ---
.../sdk/util/state/InMemoryStateInternals.java | 416 ---
.../sdk/util/state/MergingStateAccessor.java | 41 -
.../dataflow/sdk/util/state/ReadableState.java | 55 -
.../cloud/dataflow/sdk/util/state/State.java | 32 -
.../dataflow/sdk/util/state/StateAccessor.java | 37 -
.../dataflow/sdk/util/state/StateContext.java | 43 -
.../dataflow/sdk/util/state/StateContexts.java | 109 -
.../dataflow/sdk/util/state/StateInternals.java | 57 -
.../dataflow/sdk/util/state/StateMerging.java | 256 --
.../dataflow/sdk/util/state/StateNamespace.java | 56 -
.../sdk/util/state/StateNamespaceForTest.java | 65 -
.../sdk/util/state/StateNamespaces.java | 279 --
.../dataflow/sdk/util/state/StateTable.java | 91 -
.../cloud/dataflow/sdk/util/state/StateTag.java | 98 -
.../dataflow/sdk/util/state/StateTags.java | 581 ----
.../dataflow/sdk/util/state/ValueState.java | 37 -
.../sdk/util/state/WatermarkHoldState.java | 44 -
.../google/cloud/dataflow/sdk/values/KV.java | 131 -
.../cloud/dataflow/sdk/values/PBegin.java | 88 -
.../cloud/dataflow/sdk/values/PCollection.java | 251 --
.../dataflow/sdk/values/PCollectionList.java | 239 --
.../dataflow/sdk/values/PCollectionTuple.java | 265 --
.../dataflow/sdk/values/PCollectionView.java | 65 -
.../google/cloud/dataflow/sdk/values/PDone.java | 48 -
.../cloud/dataflow/sdk/values/PInput.java | 57 -
.../cloud/dataflow/sdk/values/POutput.java | 77 -
.../dataflow/sdk/values/POutputValueBase.java | 103 -
.../cloud/dataflow/sdk/values/PValue.java | 39 -
.../cloud/dataflow/sdk/values/PValueBase.java | 156 -
.../dataflow/sdk/values/TimestampedValue.java | 156 -
.../cloud/dataflow/sdk/values/TupleTag.java | 197 --
.../cloud/dataflow/sdk/values/TupleTagList.java | 149 -
.../dataflow/sdk/values/TypeDescriptor.java | 352 --
.../cloud/dataflow/sdk/values/TypedPValue.java | 198 --
.../cloud/dataflow/sdk/values/package-info.java | 53 -
.../main/java/org/apache/beam/sdk/Pipeline.java | 503 +++
.../org/apache/beam/sdk/PipelineResult.java | 96 +
.../org/apache/beam/sdk/coders/AtomicCoder.java | 52 +
.../org/apache/beam/sdk/coders/AvroCoder.java | 715 +++++
.../beam/sdk/coders/BigEndianIntegerCoder.java | 100 +
.../beam/sdk/coders/BigEndianLongCoder.java | 100 +
.../apache/beam/sdk/coders/ByteArrayCoder.java | 139 +
.../org/apache/beam/sdk/coders/ByteCoder.java | 112 +
.../apache/beam/sdk/coders/ByteStringCoder.java | 107 +
.../sdk/coders/CannotProvideCoderException.java | 96 +
.../java/org/apache/beam/sdk/coders/Coder.java | 299 ++
.../apache/beam/sdk/coders/CoderException.java | 37 +
.../apache/beam/sdk/coders/CoderFactories.java | 275 ++
.../apache/beam/sdk/coders/CoderFactory.java | 44 +
.../apache/beam/sdk/coders/CoderProvider.java | 34 +
.../apache/beam/sdk/coders/CoderProviders.java | 165 +
.../apache/beam/sdk/coders/CoderRegistry.java | 844 +++++
.../apache/beam/sdk/coders/CollectionCoder.java | 74 +
.../org/apache/beam/sdk/coders/CustomCoder.java | 138 +
.../apache/beam/sdk/coders/DefaultCoder.java | 67 +
.../apache/beam/sdk/coders/DelegateCoder.java | 165 +
.../sdk/coders/DeterministicStandardCoder.java | 39 +
.../org/apache/beam/sdk/coders/DoubleCoder.java | 114 +
.../apache/beam/sdk/coders/DurationCoder.java | 98 +
.../org/apache/beam/sdk/coders/EntityCoder.java | 87 +
.../apache/beam/sdk/coders/InstantCoder.java | 114 +
.../apache/beam/sdk/coders/IterableCoder.java | 79 +
.../beam/sdk/coders/IterableLikeCoder.java | 279 ++
.../org/apache/beam/sdk/coders/JAXBCoder.java | 170 +
.../org/apache/beam/sdk/coders/KvCoder.java | 163 +
.../org/apache/beam/sdk/coders/KvCoderBase.java | 62 +
.../org/apache/beam/sdk/coders/ListCoder.java | 78 +
.../org/apache/beam/sdk/coders/MapCoder.java | 161 +
.../apache/beam/sdk/coders/MapCoderBase.java | 55 +
.../apache/beam/sdk/coders/NullableCoder.java | 179 ++
.../org/apache/beam/sdk/coders/Proto2Coder.java | 363 +++
.../beam/sdk/coders/SerializableCoder.java | 184 ++
.../org/apache/beam/sdk/coders/SetCoder.java | 95 +
.../apache/beam/sdk/coders/StandardCoder.java | 230 ++
.../beam/sdk/coders/StringDelegateCoder.java | 87 +
.../apache/beam/sdk/coders/StringUtf8Coder.java | 140 +
.../beam/sdk/coders/StructuralByteArray.java | 58 +
.../beam/sdk/coders/TableRowJsonCoder.java | 83 +
.../beam/sdk/coders/TextualIntegerCoder.java | 70 +
.../org/apache/beam/sdk/coders/VarIntCoder.java | 98 +
.../apache/beam/sdk/coders/VarLongCoder.java | 97 +
.../org/apache/beam/sdk/coders/VoidCoder.java | 77 +
.../apache/beam/sdk/coders/package-info.java | 45 +
.../beam/sdk/coders/protobuf/ProtoCoder.java | 406 +++
.../beam/sdk/coders/protobuf/ProtobufUtil.java | 172 +
.../beam/sdk/coders/protobuf/package-info.java | 24 +
.../java/org/apache/beam/sdk/io/AvroIO.java | 811 +++++
.../java/org/apache/beam/sdk/io/AvroSource.java | 648 ++++
.../java/org/apache/beam/sdk/io/BigQueryIO.java | 1685 ++++++++++
.../apache/beam/sdk/io/BlockBasedSource.java | 238 ++
.../sdk/io/BoundedReadFromUnboundedSource.java | 272 ++
.../org/apache/beam/sdk/io/BoundedSource.java | 278 ++
.../apache/beam/sdk/io/CompressedSource.java | 414 +++
.../org/apache/beam/sdk/io/CountingInput.java | 224 ++
.../org/apache/beam/sdk/io/CountingSource.java | 481 +++
.../org/apache/beam/sdk/io/DatastoreIO.java | 947 ++++++
.../org/apache/beam/sdk/io/FileBasedSink.java | 865 +++++
.../org/apache/beam/sdk/io/FileBasedSource.java | 663 ++++
.../apache/beam/sdk/io/OffsetBasedSource.java | 329 ++
.../org/apache/beam/sdk/io/PubsubClient.java | 322 ++
.../apache/beam/sdk/io/PubsubGrpcClient.java | 401 +++
.../java/org/apache/beam/sdk/io/PubsubIO.java | 1048 ++++++
.../main/java/org/apache/beam/sdk/io/Read.java | 254 ++
.../apache/beam/sdk/io/ShardNameTemplate.java | 76 +
.../main/java/org/apache/beam/sdk/io/Sink.java | 255 ++
.../java/org/apache/beam/sdk/io/Source.java | 194 ++
.../java/org/apache/beam/sdk/io/TextIO.java | 991 ++++++
.../org/apache/beam/sdk/io/UnboundedSource.java | 254 ++
.../main/java/org/apache/beam/sdk/io/Write.java | 217 ++
.../java/org/apache/beam/sdk/io/XmlSink.java | 311 ++
.../java/org/apache/beam/sdk/io/XmlSource.java | 544 ++++
.../apache/beam/sdk/io/bigtable/BigtableIO.java | 989 ++++++
.../beam/sdk/io/bigtable/BigtableService.java | 110 +
.../sdk/io/bigtable/BigtableServiceImpl.java | 243 ++
.../beam/sdk/io/bigtable/package-info.java | 23 +
.../org/apache/beam/sdk/io/package-info.java | 38 +
.../org/apache/beam/sdk/io/range/ByteKey.java | 174 +
.../apache/beam/sdk/io/range/ByteKeyRange.java | 377 +++
.../beam/sdk/io/range/ByteKeyRangeTracker.java | 118 +
.../beam/sdk/io/range/OffsetRangeTracker.java | 183 ++
.../apache/beam/sdk/io/range/RangeTracker.java | 221 ++
.../apache/beam/sdk/io/range/package-info.java | 24 +
.../sdk/options/ApplicationNameOptions.java | 34 +
.../beam/sdk/options/BigQueryOptions.java | 32 +
.../org/apache/beam/sdk/options/Default.java | 154 +
.../beam/sdk/options/DefaultValueFactory.java | 39 +
.../apache/beam/sdk/options/Description.java | 36 +
.../beam/sdk/options/DirectPipelineOptions.java | 76 +
.../org/apache/beam/sdk/options/GcpOptions.java | 292 ++
.../org/apache/beam/sdk/options/GcsOptions.java | 114 +
.../beam/sdk/options/GoogleApiDebugOptions.java | 88 +
.../org/apache/beam/sdk/options/Hidden.java | 34 +
.../beam/sdk/options/PipelineOptions.java | 264 ++
.../sdk/options/PipelineOptionsFactory.java | 1490 +++++++++
.../sdk/options/PipelineOptionsRegistrar.java | 37 +
.../sdk/options/PipelineOptionsValidator.java | 103 +
.../sdk/options/ProxyInvocationHandler.java | 442 +++
.../apache/beam/sdk/options/PubsubOptions.java | 36 +
.../beam/sdk/options/StreamingOptions.java | 31 +
.../org/apache/beam/sdk/options/Validation.java | 47 +
.../apache/beam/sdk/options/package-info.java | 26 +
.../java/org/apache/beam/sdk/package-info.java | 34 +
.../runners/AggregatorPipelineExtractor.java | 98 +
.../runners/AggregatorRetrievalException.java | 33 +
.../beam/sdk/runners/AggregatorValues.java | 52 +
.../apache/beam/sdk/runners/DirectPipeline.java | 56 +
.../sdk/runners/DirectPipelineRegistrar.java | 54 +
.../beam/sdk/runners/DirectPipelineRunner.java | 1320 ++++++++
.../apache/beam/sdk/runners/PipelineRunner.java | 77 +
.../sdk/runners/PipelineRunnerRegistrar.java | 41 +
.../sdk/runners/RecordingPipelineVisitor.java | 55 +
.../beam/sdk/runners/TransformHierarchy.java | 105 +
.../beam/sdk/runners/TransformTreeNode.java | 253 ++
.../inprocess/AbstractModelEnforcement.java | 38 +
.../inprocess/AvroIOShardedWriteFactory.java | 76 +
.../inprocess/BoundedReadEvaluatorFactory.java | 156 +
.../sdk/runners/inprocess/BundleFactory.java | 49 +
.../CachedThreadPoolExecutorServiceFactory.java | 44 +
.../beam/sdk/runners/inprocess/Clock.java | 30 +
.../runners/inprocess/CompletionCallback.java | 36 +
.../ConsumerTrackingPipelineVisitor.java | 173 +
.../inprocess/EmptyTransformEvaluator.java | 50 +
.../EncodabilityEnforcementFactory.java | 71 +
.../sdk/runners/inprocess/EvaluatorKey.java | 55 +
.../inprocess/ExecutorServiceFactory.java | 33 +
.../ExecutorServiceParallelExecutor.java | 477 +++
.../inprocess/FlattenEvaluatorFactory.java | 85 +
.../runners/inprocess/ForwardingPTransform.java | 56 +
.../inprocess/GroupByKeyEvaluatorFactory.java | 273 ++
.../ImmutabilityCheckingBundleFactory.java | 131 +
.../ImmutabilityEnforcementFactory.java | 104 +
.../inprocess/InMemoryWatermarkManager.java | 1313 ++++++++
.../sdk/runners/inprocess/InProcessBundle.java | 123 +
.../inprocess/InProcessBundleFactory.java | 156 +
.../inprocess/InProcessBundleOutputManager.java | 51 +
.../sdk/runners/inprocess/InProcessCreate.java | 235 ++
.../inprocess/InProcessEvaluationContext.java | 411 +++
.../inprocess/InProcessExecutionContext.java | 107 +
.../runners/inprocess/InProcessExecutor.java | 48 +
.../inprocess/InProcessPipelineOptions.java | 101 +
.../inprocess/InProcessPipelineRunner.java | 366 +++
.../runners/inprocess/InProcessRegistrar.java | 54 +
.../inprocess/InProcessSideInputContainer.java | 232 ++
.../inprocess/InProcessTimerInternals.java | 84 +
.../inprocess/InProcessTransformResult.java | 77 +
.../inprocess/KeyedPValueTrackingVisitor.java | 96 +
.../sdk/runners/inprocess/ModelEnforcement.java | 63 +
.../inprocess/ModelEnforcementFactory.java | 30 +
.../sdk/runners/inprocess/NanosOffsetClock.java | 59 +
.../inprocess/PTransformOverrideFactory.java | 33 +
.../inprocess/ParDoInProcessEvaluator.java | 120 +
.../inprocess/ParDoMultiEvaluatorFactory.java | 92 +
.../inprocess/ParDoSingleEvaluatorFactory.java | 89 +
.../PassthroughTransformEvaluator.java | 49 +
.../runners/inprocess/ShardControlledWrite.java | 81 +
.../beam/sdk/runners/inprocess/StepAndKey.java | 70 +
.../runners/inprocess/StepTransformResult.java | 164 +
.../inprocess/TextIOShardedWriteFactory.java | 78 +
.../runners/inprocess/TransformEvaluator.java | 46 +
.../inprocess/TransformEvaluatorFactory.java | 44 +
.../inprocess/TransformEvaluatorRegistry.java | 76 +
.../runners/inprocess/TransformExecutor.java | 175 +
.../inprocess/TransformExecutorService.java | 35 +
.../inprocess/TransformExecutorServices.java | 154 +
.../UnboundedReadEvaluatorFactory.java | 177 ++
.../runners/inprocess/ViewEvaluatorFactory.java | 145 +
.../inprocess/WatermarkCallbackExecutor.java | 145 +
.../inprocess/WindowEvaluatorFactory.java | 131 +
.../apache/beam/sdk/runners/package-info.java | 34 +
.../beam/sdk/runners/worker/IsmFormat.java | 948 ++++++
.../beam/sdk/runners/worker/package-info.java | 25 +
.../beam/sdk/testing/CoderProperties.java | 350 ++
.../org/apache/beam/sdk/testing/PAssert.java | 825 +++++
.../beam/sdk/testing/RunnableOnService.java | 34 +
.../beam/sdk/testing/SerializableMatcher.java | 36 +
.../beam/sdk/testing/SerializableMatchers.java | 1181 +++++++
.../beam/sdk/testing/SourceTestUtils.java | 676 ++++
.../apache/beam/sdk/testing/TestPipeline.java | 205 ++
.../beam/sdk/testing/WindowFnTestUtils.java | 326 ++
.../apache/beam/sdk/testing/package-info.java | 22 +
.../apache/beam/sdk/transforms/Aggregator.java | 79 +
.../sdk/transforms/AggregatorRetriever.java | 36 +
.../beam/sdk/transforms/AppliedPTransform.java | 101 +
.../sdk/transforms/ApproximateQuantiles.java | 767 +++++
.../beam/sdk/transforms/ApproximateUnique.java | 420 +++
.../org/apache/beam/sdk/transforms/Combine.java | 2242 +++++++++++++
.../beam/sdk/transforms/CombineFnBase.java | 285 ++
.../apache/beam/sdk/transforms/CombineFns.java | 1010 ++++++
.../beam/sdk/transforms/CombineWithContext.java | 279 ++
.../org/apache/beam/sdk/transforms/Count.java | 193 ++
.../org/apache/beam/sdk/transforms/Create.java | 427 +++
.../org/apache/beam/sdk/transforms/DoFn.java | 564 ++++
.../beam/sdk/transforms/DoFnReflector.java | 669 ++++
.../apache/beam/sdk/transforms/DoFnTester.java | 496 +++
.../beam/sdk/transforms/DoFnWithContext.java | 417 +++
.../org/apache/beam/sdk/transforms/Filter.java | 235 ++
.../beam/sdk/transforms/FlatMapElements.java | 146 +
.../org/apache/beam/sdk/transforms/Flatten.java | 220 ++
.../apache/beam/sdk/transforms/GroupByKey.java | 276 ++
.../transforms/IntraBundleParallelization.java | 348 ++
.../org/apache/beam/sdk/transforms/Keys.java | 69 +
.../org/apache/beam/sdk/transforms/KvSwap.java | 74 +
.../apache/beam/sdk/transforms/MapElements.java | 113 +
.../org/apache/beam/sdk/transforms/Max.java | 256 ++
.../org/apache/beam/sdk/transforms/Mean.java | 203 ++
.../org/apache/beam/sdk/transforms/Min.java | 256 ++
.../apache/beam/sdk/transforms/PTransform.java | 325 ++
.../org/apache/beam/sdk/transforms/ParDo.java | 1323 ++++++++
.../apache/beam/sdk/transforms/Partition.java | 174 +
.../beam/sdk/transforms/RemoveDuplicates.java | 159 +
.../org/apache/beam/sdk/transforms/Sample.java | 247 ++
.../sdk/transforms/SerializableComparator.java | 29 +
.../sdk/transforms/SerializableFunction.java | 32 +
.../beam/sdk/transforms/SimpleFunction.java | 55 +
.../org/apache/beam/sdk/transforms/Sum.java | 189 ++
.../org/apache/beam/sdk/transforms/Top.java | 560 ++++
.../org/apache/beam/sdk/transforms/Values.java | 69 +
.../org/apache/beam/sdk/transforms/View.java | 471 +++
.../apache/beam/sdk/transforms/WithKeys.java | 141 +
.../beam/sdk/transforms/WithTimestamps.java | 130 +
.../org/apache/beam/sdk/transforms/Write.java | 29 +
.../sdk/transforms/display/DisplayData.java | 901 ++++++
.../sdk/transforms/display/HasDisplayData.java | 55 +
.../beam/sdk/transforms/join/CoGbkResult.java | 464 +++
.../sdk/transforms/join/CoGbkResultSchema.java | 135 +
.../beam/sdk/transforms/join/CoGroupByKey.java | 212 ++
.../transforms/join/KeyedPCollectionTuple.java | 248 ++
.../beam/sdk/transforms/join/RawUnionValue.java | 51 +
.../beam/sdk/transforms/join/UnionCoder.java | 148 +
.../beam/sdk/transforms/join/package-info.java | 22 +
.../beam/sdk/transforms/package-info.java | 43 +
.../beam/sdk/transforms/windowing/AfterAll.java | 114 +
.../windowing/AfterDelayFromFirstElement.java | 323 ++
.../sdk/transforms/windowing/AfterEach.java | 133 +
.../sdk/transforms/windowing/AfterFirst.java | 117 +
.../sdk/transforms/windowing/AfterPane.java | 143 +
.../windowing/AfterProcessingTime.java | 96 +
.../AfterSynchronizedProcessingTime.java | 76 +
.../transforms/windowing/AfterWatermark.java | 396 +++
.../sdk/transforms/windowing/BoundedWindow.java | 47 +
.../transforms/windowing/CalendarWindows.java | 349 ++
.../transforms/windowing/DefaultTrigger.java | 94 +
.../sdk/transforms/windowing/FixedWindows.java | 117 +
.../sdk/transforms/windowing/GlobalWindow.java | 69 +
.../sdk/transforms/windowing/GlobalWindows.java | 64 +
.../transforms/windowing/IntervalWindow.java | 202 ++
.../transforms/windowing/InvalidWindows.java | 88 +
.../MergeOverlappingIntervalWindows.java | 87 +
.../windowing/NonMergingWindowFn.java | 36 +
.../transforms/windowing/OrFinallyTrigger.java | 102 +
.../sdk/transforms/windowing/OutputTimeFn.java | 320 ++
.../sdk/transforms/windowing/OutputTimeFns.java | 169 +
.../beam/sdk/transforms/windowing/PaneInfo.java | 385 +++
.../windowing/PartitioningWindowFn.java | 62 +
.../sdk/transforms/windowing/Repeatedly.java | 98 +
.../beam/sdk/transforms/windowing/Sessions.java | 113 +
.../transforms/windowing/SlidingWindows.java | 215 ++
.../beam/sdk/transforms/windowing/Trigger.java | 535 ++++
.../transforms/windowing/TriggerBuilder.java | 29 +
.../beam/sdk/transforms/windowing/Window.java | 654 ++++
.../beam/sdk/transforms/windowing/WindowFn.java | 222 ++
.../sdk/transforms/windowing/package-info.java | 50 +
.../apache/beam/sdk/util/ActiveWindowSet.java | 182 ++
.../org/apache/beam/sdk/util/ApiSurface.java | 643 ++++
.../beam/sdk/util/AppEngineEnvironment.java | 62 +
.../apache/beam/sdk/util/AppliedCombineFn.java | 132 +
.../org/apache/beam/sdk/util/AssignWindows.java | 46 +
.../apache/beam/sdk/util/AssignWindowsDoFn.java | 68 +
...AttemptAndTimeBoundedExponentialBackOff.java | 169 +
.../util/AttemptBoundedExponentialBackOff.java | 84 +
.../org/apache/beam/sdk/util/AvroUtils.java | 345 ++
.../beam/sdk/util/BaseExecutionContext.java | 156 +
.../beam/sdk/util/BatchTimerInternals.java | 139 +
.../apache/beam/sdk/util/BigQueryServices.java | 61 +
.../beam/sdk/util/BigQueryServicesImpl.java | 196 ++
.../beam/sdk/util/BigQueryTableInserter.java | 459 +++
.../beam/sdk/util/BigQueryTableRowIterator.java | 472 +++
.../org/apache/beam/sdk/util/BitSetCoder.java | 61 +
.../BufferedElementCountingOutputStream.java | 186 ++
.../apache/beam/sdk/util/CloudKnownType.java | 139 +
.../org/apache/beam/sdk/util/CloudObject.java | 185 ++
.../org/apache/beam/sdk/util/CoderUtils.java | 328 ++
.../beam/sdk/util/CombineContextFactory.java | 109 +
.../org/apache/beam/sdk/util/CombineFnUtil.java | 205 ++
.../apache/beam/sdk/util/CounterAggregator.java | 97 +
.../apache/beam/sdk/util/CredentialFactory.java | 30 +
.../org/apache/beam/sdk/util/Credentials.java | 193 ++
.../beam/sdk/util/DataflowReleaseInfo.java | 88 +
.../sdk/util/DirectModeExecutionContext.java | 131 +
.../beam/sdk/util/DirectSideInputReader.java | 74 +
.../java/org/apache/beam/sdk/util/DoFnInfo.java | 68 +
.../org/apache/beam/sdk/util/DoFnRunner.java | 62 +
.../apache/beam/sdk/util/DoFnRunnerBase.java | 559 ++++
.../org/apache/beam/sdk/util/DoFnRunners.java | 144 +
.../apache/beam/sdk/util/ExecutableTrigger.java | 158 +
.../apache/beam/sdk/util/ExecutionContext.java | 103 +
.../sdk/util/ExposedByteArrayInputStream.java | 52 +
.../sdk/util/ExposedByteArrayOutputStream.java | 118 +
.../beam/sdk/util/FileIOChannelFactory.java | 136 +
.../apache/beam/sdk/util/FinishedTriggers.java | 44 +
.../beam/sdk/util/FinishedTriggersBitSet.java | 67 +
.../beam/sdk/util/FinishedTriggersSet.java | 73 +
.../beam/sdk/util/GcpCredentialFactory.java | 46 +
.../beam/sdk/util/GcsIOChannelFactory.java | 87 +
.../java/org/apache/beam/sdk/util/GcsUtil.java | 411 +++
.../util/GroupAlsoByWindowViaWindowSetDoFn.java | 105 +
.../beam/sdk/util/GroupAlsoByWindowsDoFn.java | 59 +
.../GroupAlsoByWindowsViaOutputBufferDoFn.java | 99 +
.../sdk/util/GroupByKeyViaGroupByKeyOnly.java | 246 ++
.../apache/beam/sdk/util/IOChannelFactory.java | 102 +
.../apache/beam/sdk/util/IOChannelUtils.java | 205 ++
.../beam/sdk/util/IllegalMutationException.java | 53 +
.../apache/beam/sdk/util/InstanceBuilder.java | 270 ++
.../util/IntervalBoundedExponentialBackOff.java | 94 +
.../org/apache/beam/sdk/util/KeyedWorkItem.java | 43 +
.../beam/sdk/util/KeyedWorkItemCoder.java | 122 +
.../apache/beam/sdk/util/KeyedWorkItems.java | 122 +
.../sdk/util/LateDataDroppingDoFnRunner.java | 146 +
.../beam/sdk/util/MapAggregatorValues.java | 49 +
.../beam/sdk/util/MergingActiveWindowSet.java | 575 ++++
.../org/apache/beam/sdk/util/MimeTypes.java | 24 +
.../apache/beam/sdk/util/MutationDetector.java | 32 +
.../apache/beam/sdk/util/MutationDetectors.java | 181 ++
.../org/apache/beam/sdk/util/NonEmptyPanes.java | 150 +
.../sdk/util/NonMergingActiveWindowSet.java | 92 +
.../beam/sdk/util/NoopCredentialFactory.java | 39 +
.../apache/beam/sdk/util/NoopPathValidator.java | 49 +
.../beam/sdk/util/NullSideInputReader.java | 62 +
.../apache/beam/sdk/util/OutputReference.java | 43 +
.../beam/sdk/util/PCollectionViewWindow.java | 68 +
.../apache/beam/sdk/util/PCollectionViews.java | 427 +++
.../java/org/apache/beam/sdk/util/PTuple.java | 161 +
.../apache/beam/sdk/util/PaneInfoTracker.java | 153 +
.../org/apache/beam/sdk/util/PathValidator.java | 48 +
.../beam/sdk/util/PerKeyCombineFnRunner.java | 149 +
.../beam/sdk/util/PerKeyCombineFnRunners.java | 259 ++
.../org/apache/beam/sdk/util/PropertyNames.java | 108 +
.../apache/beam/sdk/util/RandomAccessData.java | 354 +++
.../java/org/apache/beam/sdk/util/ReduceFn.java | 130 +
.../beam/sdk/util/ReduceFnContextFactory.java | 496 +++
.../apache/beam/sdk/util/ReduceFnRunner.java | 903 ++++++
.../sdk/util/ReifyTimestampAndWindowsDoFn.java | 47 +
.../org/apache/beam/sdk/util/Reshuffle.java | 147 +
.../apache/beam/sdk/util/ReshuffleTrigger.java | 63 +
.../sdk/util/RetryHttpRequestInitializer.java | 251 ++
.../apache/beam/sdk/util/SerializableUtils.java | 160 +
.../org/apache/beam/sdk/util/Serializer.java | 146 +
.../sdk/util/ShardingWritableByteChannel.java | 119 +
.../apache/beam/sdk/util/SideInputReader.java | 48 +
.../apache/beam/sdk/util/SimpleDoFnRunner.java | 56 +
.../org/apache/beam/sdk/util/StreamUtils.java | 69 +
.../org/apache/beam/sdk/util/StringUtils.java | 243 ++
.../java/org/apache/beam/sdk/util/Structs.java | 385 +++
.../beam/sdk/util/SystemDoFnInternal.java | 39 +
.../apache/beam/sdk/util/SystemReduceFn.java | 135 +
.../apache/beam/sdk/util/TestCredential.java | 52 +
.../org/apache/beam/sdk/util/TimeDomain.java | 43 +
.../java/org/apache/beam/sdk/util/TimeUtil.java | 166 +
.../apache/beam/sdk/util/TimerInternals.java | 270 ++
.../java/org/apache/beam/sdk/util/Timers.java | 60 +
.../org/apache/beam/sdk/util/Transport.java | 151 +
.../beam/sdk/util/TriggerContextFactory.java | 512 +++
.../org/apache/beam/sdk/util/TriggerRunner.java | 233 ++
.../beam/sdk/util/UnownedInputStream.java | 76 +
.../beam/sdk/util/UnownedOutputStream.java | 56 +
.../sdk/util/UploadIdResponseInterceptor.java | 62 +
.../apache/beam/sdk/util/UserCodeException.java | 95 +
.../apache/beam/sdk/util/ValueWithRecordId.java | 155 +
.../java/org/apache/beam/sdk/util/Values.java | 89 +
.../java/org/apache/beam/sdk/util/VarInt.java | 116 +
.../org/apache/beam/sdk/util/WatermarkHold.java | 476 +++
.../java/org/apache/beam/sdk/util/Weighted.java | 28 +
.../org/apache/beam/sdk/util/WeightedValue.java | 46 +
.../org/apache/beam/sdk/util/WindowTracing.java | 37 +
.../org/apache/beam/sdk/util/WindowedValue.java | 721 +++++
.../beam/sdk/util/WindowingInternals.java | 83 +
.../apache/beam/sdk/util/WindowingStrategy.java | 267 ++
.../java/org/apache/beam/sdk/util/ZipFiles.java | 295 ++
.../apache/beam/sdk/util/common/Counter.java | 1104 +++++++
.../beam/sdk/util/common/CounterProvider.java | 27 +
.../apache/beam/sdk/util/common/CounterSet.java | 178 ++
.../util/common/ElementByteSizeObservable.java | 42 +
.../ElementByteSizeObservableIterable.java | 64 +
.../ElementByteSizeObservableIterator.java | 37 +
.../util/common/ElementByteSizeObserver.java | 93 +
.../beam/sdk/util/common/PeekingReiterator.java | 99 +
.../beam/sdk/util/common/ReflectHelpers.java | 211 ++
.../apache/beam/sdk/util/common/Reiterable.java | 28 +
.../apache/beam/sdk/util/common/Reiterator.java | 40 +
.../beam/sdk/util/common/package-info.java | 19 +
.../sdk/util/common/worker/StateSampler.java | 366 +++
.../sdk/util/common/worker/package-info.java | 19 +
.../org/apache/beam/sdk/util/gcsfs/GcsPath.java | 620 ++++
.../beam/sdk/util/gcsfs/package-info.java | 19 +
.../org/apache/beam/sdk/util/package-info.java | 19 +
.../util/state/AccumulatorCombiningState.java | 53 +
.../apache/beam/sdk/util/state/BagState.java | 28 +
.../beam/sdk/util/state/CombiningState.java | 42 +
.../CopyOnAccessInMemoryStateInternals.java | 456 +++
.../sdk/util/state/InMemoryStateInternals.java | 416 +++
.../sdk/util/state/MergingStateAccessor.java | 41 +
.../beam/sdk/util/state/ReadableState.java | 55 +
.../org/apache/beam/sdk/util/state/State.java | 32 +
.../beam/sdk/util/state/StateAccessor.java | 37 +
.../beam/sdk/util/state/StateContext.java | 43 +
.../beam/sdk/util/state/StateContexts.java | 109 +
.../beam/sdk/util/state/StateInternals.java | 57 +
.../beam/sdk/util/state/StateMerging.java | 256 ++
.../beam/sdk/util/state/StateNamespace.java | 56 +
.../sdk/util/state/StateNamespaceForTest.java | 65 +
.../beam/sdk/util/state/StateNamespaces.java | 279 ++
.../apache/beam/sdk/util/state/StateTable.java | 91 +
.../apache/beam/sdk/util/state/StateTag.java | 98 +
.../apache/beam/sdk/util/state/StateTags.java | 581 ++++
.../apache/beam/sdk/util/state/ValueState.java | 37 +
.../beam/sdk/util/state/WatermarkHoldState.java | 44 +
.../java/org/apache/beam/sdk/values/KV.java | 131 +
.../java/org/apache/beam/sdk/values/PBegin.java | 88 +
.../org/apache/beam/sdk/values/PCollection.java | 251 ++
.../apache/beam/sdk/values/PCollectionList.java | 239 ++
.../beam/sdk/values/PCollectionTuple.java | 265 ++
.../apache/beam/sdk/values/PCollectionView.java | 65 +
.../java/org/apache/beam/sdk/values/PDone.java | 48 +
.../java/org/apache/beam/sdk/values/PInput.java | 57 +
.../org/apache/beam/sdk/values/POutput.java | 77 +
.../beam/sdk/values/POutputValueBase.java | 103 +
.../java/org/apache/beam/sdk/values/PValue.java | 39 +
.../org/apache/beam/sdk/values/PValueBase.java | 156 +
.../beam/sdk/values/TimestampedValue.java | 156 +
.../org/apache/beam/sdk/values/TupleTag.java | 197 ++
.../apache/beam/sdk/values/TupleTagList.java | 149 +
.../apache/beam/sdk/values/TypeDescriptor.java | 352 ++
.../org/apache/beam/sdk/values/TypedPValue.java | 198 ++
.../apache/beam/sdk/values/package-info.java | 53 +
.../cloud/dataflow/sdk/DataflowMatchers.java | 66 -
.../google/cloud/dataflow/sdk/PipelineTest.java | 297 --
.../google/cloud/dataflow/sdk/TestUtils.java | 214 --
.../cloud/dataflow/sdk/WindowMatchers.java | 138 -
.../dataflow/sdk/coders/AvroCoderTest.java | 755 -----
.../sdk/coders/BigEndianIntegerCoderTest.java | 91 -
.../sdk/coders/BigEndianLongCoderTest.java | 95 -
.../dataflow/sdk/coders/ByteArrayCoderTest.java | 145 -
.../dataflow/sdk/coders/ByteCoderTest.java | 92 -
.../sdk/coders/ByteStringCoderTest.java | 122 -
.../dataflow/sdk/coders/CoderFactoriesTest.java | 101 -
.../dataflow/sdk/coders/CoderProvidersTest.java | 72 -
.../dataflow/sdk/coders/CoderRegistryTest.java | 522 ---
.../cloud/dataflow/sdk/coders/CoderTest.java | 80 -
.../sdk/coders/CollectionCoderTest.java | 94 -
.../dataflow/sdk/coders/CustomCoderTest.java | 136 -
.../dataflow/sdk/coders/DefaultCoderTest.java | 129 -
.../dataflow/sdk/coders/DelegateCoderTest.java | 142 -
.../dataflow/sdk/coders/DoubleCoderTest.java | 97 -
.../dataflow/sdk/coders/DurationCoderTest.java | 87 -
.../dataflow/sdk/coders/EntityCoderTest.java | 109 -
.../dataflow/sdk/coders/InstantCoderTest.java | 117 -
.../dataflow/sdk/coders/IterableCoderTest.java | 110 -
.../dataflow/sdk/coders/JAXBCoderTest.java | 156 -
.../cloud/dataflow/sdk/coders/KvCoderTest.java | 119 -
.../dataflow/sdk/coders/ListCoderTest.java | 135 -
.../cloud/dataflow/sdk/coders/MapCoderTest.java | 107 -
.../dataflow/sdk/coders/NullableCoderTest.java | 140 -
.../sdk/coders/PrintBase64Encodings.java | 82 -
.../dataflow/sdk/coders/Proto2CoderTest.java | 146 -
.../sdk/coders/SerializableCoderTest.java | 223 --
.../cloud/dataflow/sdk/coders/SetCoderTest.java | 87 -
.../dataflow/sdk/coders/StandardCoderTest.java | 177 --
.../sdk/coders/StringDelegateCoderTest.java | 73 -
.../sdk/coders/StringUtf8CoderTest.java | 81 -
.../sdk/coders/StructuralByteArrayTest.java | 41 -
.../sdk/coders/TableRowJsonCoderTest.java | 87 -
.../sdk/coders/TextualIntegerCoderTest.java | 91 -
.../dataflow/sdk/coders/VarIntCoderTest.java | 92 -
.../dataflow/sdk/coders/VarLongCoderTest.java | 95 -
.../sdk/coders/protobuf/ProtoCoderTest.java | 183 --
.../sdk/coders/protobuf/ProtobufUtilTest.java | 196 --
.../sdk/io/AvroIOGeneratedClassTest.java | 375 ---
.../cloud/dataflow/sdk/io/AvroIOTest.java | 259 --
.../cloud/dataflow/sdk/io/AvroSourceTest.java | 693 ----
.../cloud/dataflow/sdk/io/BigQueryIOTest.java | 606 ----
.../io/BoundedReadFromUnboundedSourceTest.java | 133 -
.../dataflow/sdk/io/CompressedSourceTest.java | 477 ---
.../dataflow/sdk/io/CountingInputTest.java | 152 -
.../dataflow/sdk/io/CountingSourceTest.java | 290 --
.../cloud/dataflow/sdk/io/DatastoreIOTest.java | 588 ----
.../dataflow/sdk/io/FileBasedSinkTest.java | 513 ---
.../dataflow/sdk/io/FileBasedSourceTest.java | 917 ------
.../dataflow/sdk/io/OffsetBasedSourceTest.java | 281 --
.../cloud/dataflow/sdk/io/PubsubIOTest.java | 234 --
.../google/cloud/dataflow/sdk/io/ReadTest.java | 145 -
.../cloud/dataflow/sdk/io/TextIOTest.java | 517 ---
.../google/cloud/dataflow/sdk/io/WriteTest.java | 344 --
.../cloud/dataflow/sdk/io/XmlSinkTest.java | 236 --
.../cloud/dataflow/sdk/io/XmlSourceTest.java | 825 -----
.../sdk/io/bigtable/BigtableIOTest.java | 689 ----
.../range/ByteKeyRangeEstimateFractionTest.java | 70 -
.../range/ByteKeyRangeInterpolateKeyTest.java | 74 -
.../dataflow/sdk/io/range/ByteKeyRangeTest.java | 397 ---
.../sdk/io/range/ByteKeyRangeTrackerTest.java | 120 -
.../dataflow/sdk/io/range/ByteKeyTest.java | 179 --
.../sdk/io/range/OffsetRangeTrackerTest.java | 187 --
.../com/google/cloud/dataflow/sdk/io/user.avsc | 10 -
.../dataflow/sdk/options/GcpOptionsTest.java | 125 -
.../sdk/options/GoogleApiDebugOptionsTest.java | 147 -
.../sdk/options/PipelineOptionsFactoryTest.java | 1150 -------
.../sdk/options/PipelineOptionsTest.java | 127 -
.../options/PipelineOptionsValidatorTest.java | 311 --
.../sdk/options/ProxyInvocationHandlerTest.java | 692 ----
.../AggregatorPipelineExtractorTest.java | 229 --
.../runners/DirectPipelineRegistrarTest.java | 70 -
.../sdk/runners/DirectPipelineRunnerTest.java | 211 --
.../sdk/runners/DirectPipelineTest.java | 35 -
.../sdk/runners/PipelineRunnerTest.java | 81 -
.../dataflow/sdk/runners/TransformTreeTest.java | 195 --
.../runners/dataflow/TestCountingSource.java | 247 --
.../AvroIOShardedWriteFactoryTest.java | 112 -
.../BoundedReadEvaluatorFactoryTest.java | 290 --
.../ConsumerTrackingPipelineVisitorTest.java | 272 --
.../EncodabilityEnforcementFactoryTest.java | 262 --
.../inprocess/FlattenEvaluatorFactoryTest.java | 141 -
.../inprocess/ForwardingPTransformTest.java | 102 -
.../GroupByKeyEvaluatorFactoryTest.java | 182 --
.../ImmutabilityCheckingBundleFactoryTest.java | 220 --
.../ImmutabilityEnforcementFactoryTest.java | 127 -
.../inprocess/InMemoryWatermarkManagerTest.java | 1124 -------
.../inprocess/InProcessBundleFactoryTest.java | 197 --
.../runners/inprocess/InProcessBundleTest.java | 145 -
.../runners/inprocess/InProcessCreateTest.java | 235 --
.../InProcessEvaluationContextTest.java | 535 ----
.../InProcessPipelineRegistrarTest.java | 73 -
.../inprocess/InProcessPipelineRunnerTest.java | 79 -
.../InProcessSideInputContainerTest.java | 372 ---
.../inprocess/InProcessTimerInternalsTest.java | 133 -
.../KeyedPValueTrackingVisitorTest.java | 191 --
.../sdk/runners/inprocess/MockClock.java | 62 -
.../ParDoMultiEvaluatorFactoryTest.java | 431 ---
.../ParDoSingleEvaluatorFactoryTest.java | 325 --
.../TextIOShardedWriteFactoryTest.java | 112 -
.../TransformExecutorServicesTest.java | 136 -
.../inprocess/TransformExecutorTest.java | 537 ----
.../UnboundedReadEvaluatorFactoryTest.java | 333 --
.../inprocess/ViewEvaluatorFactoryTest.java | 101 -
.../WatermarkCallbackExecutorTest.java | 128 -
.../inprocess/WindowEvaluatorFactoryTest.java | 221 --
.../sdk/testing/CoderPropertiesTest.java | 215 --
.../sdk/testing/DataflowJUnitTestRunner.java | 129 -
.../dataflow/sdk/testing/ExpectedLogs.java | 307 --
.../dataflow/sdk/testing/ExpectedLogsTest.java | 154 -
.../sdk/testing/FastNanoClockAndSleeper.java | 48 -
.../testing/FastNanoClockAndSleeperTest.java | 48 -
.../cloud/dataflow/sdk/testing/PAssertTest.java | 309 --
.../sdk/testing/PCollectionViewTesting.java | 296 --
.../sdk/testing/ResetDateTimeProvider.java | 42 -
.../sdk/testing/ResetDateTimeProviderTest.java | 56 -
.../sdk/testing/RestoreSystemProperties.java | 50 -
.../testing/RestoreSystemPropertiesTest.java | 51 -
.../sdk/testing/SerializableMatchersTest.java | 166 -
.../sdk/testing/SystemNanoTimeSleeper.java | 69 -
.../sdk/testing/SystemNanoTimeSleeperTest.java | 54 -
.../dataflow/sdk/testing/TestPipelineTest.java | 103 -
.../transforms/ApproximateQuantilesTest.java | 298 --
.../sdk/transforms/ApproximateUniqueTest.java | 292 --
.../dataflow/sdk/transforms/CombineFnsTest.java | 415 ---
.../dataflow/sdk/transforms/CombineTest.java | 1138 -------
.../dataflow/sdk/transforms/CountTest.java | 122 -
.../dataflow/sdk/transforms/CreateTest.java | 241 --
.../sdk/transforms/DoFnContextTest.java | 69 -
.../DoFnDelegatingAggregatorTest.java | 144 -
.../sdk/transforms/DoFnReflectorTest.java | 494 ---
.../cloud/dataflow/sdk/transforms/DoFnTest.java | 202 --
.../dataflow/sdk/transforms/DoFnTesterTest.java | 255 --
.../sdk/transforms/DoFnWithContextTest.java | 221 --
.../dataflow/sdk/transforms/FilterTest.java | 161 -
.../sdk/transforms/FlatMapElementsTest.java | 125 -
.../dataflow/sdk/transforms/FlattenTest.java | 370 ---
.../dataflow/sdk/transforms/GroupByKeyTest.java | 377 ---
.../IntraBundleParallelizationTest.java | 251 --
.../cloud/dataflow/sdk/transforms/KeysTest.java | 84 -
.../dataflow/sdk/transforms/KvSwapTest.java | 92 -
.../sdk/transforms/MapElementsTest.java | 135 -
.../cloud/dataflow/sdk/transforms/MaxTest.java | 67 -
.../cloud/dataflow/sdk/transforms/MeanTest.java | 73 -
.../cloud/dataflow/sdk/transforms/MinTest.java | 67 -
.../cloud/dataflow/sdk/transforms/NoOpDoFn.java | 144 -
.../dataflow/sdk/transforms/PTransformTest.java | 42 -
.../dataflow/sdk/transforms/ParDoTest.java | 1542 ---------
.../dataflow/sdk/transforms/PartitionTest.java | 141 -
.../sdk/transforms/RemoveDuplicatesTest.java | 132 -
.../dataflow/sdk/transforms/SampleTest.java | 261 --
.../sdk/transforms/SimpleStatsFnsTest.java | 130 -
.../cloud/dataflow/sdk/transforms/SumTest.java | 68 -
.../cloud/dataflow/sdk/transforms/TopTest.java | 260 --
.../dataflow/sdk/transforms/ValuesTest.java | 94 -
.../cloud/dataflow/sdk/transforms/ViewTest.java | 1423 ---------
.../dataflow/sdk/transforms/WithKeysTest.java | 128 -
.../sdk/transforms/WithTimestampsTest.java | 211 --
.../transforms/display/DisplayDataMatchers.java | 321 --
.../display/DisplayDataMatchersTest.java | 157 -
.../sdk/transforms/display/DisplayDataTest.java | 955 ------
.../transforms/join/CoGbkResultCoderTest.java | 86 -
.../sdk/transforms/join/CoGbkResultTest.java | 125 -
.../sdk/transforms/join/CoGroupByKeyTest.java | 508 ---
.../sdk/transforms/join/UnionCoderTest.java | 49 -
.../sdk/transforms/windowing/AfterAllTest.java | 152 -
.../sdk/transforms/windowing/AfterEachTest.java | 123 -
.../transforms/windowing/AfterFirstTest.java | 176 -
.../sdk/transforms/windowing/AfterPaneTest.java | 127 -
.../windowing/AfterProcessingTimeTest.java | 158 -
.../AfterSynchronizedProcessingTimeTest.java | 122 -
.../windowing/AfterWatermarkTest.java | 339 --
.../windowing/CalendarWindowsTest.java | 261 --
.../windowing/DefaultTriggerTest.java | 177 --
.../transforms/windowing/FixedWindowsTest.java | 125 -
.../windowing/IntervalWindowTest.java | 95 -
.../windowing/OrFinallyTriggerTest.java | 210 --
.../sdk/transforms/windowing/PaneInfoTest.java | 77 -
.../transforms/windowing/RepeatedlyTest.java | 212 --
.../sdk/transforms/windowing/SessionsTest.java | 157 -
.../windowing/SlidingWindowsTest.java | 194 --
.../sdk/transforms/windowing/TriggerTest.java | 119 -
.../sdk/transforms/windowing/WindowTest.java | 227 --
.../sdk/transforms/windowing/WindowingTest.java | 245 --
.../cloud/dataflow/sdk/util/ApiSurfaceTest.java | 188 --
...mptAndTimeBoundedExponentialBackOffTest.java | 213 --
.../AttemptBoundedExponentialBackOffTest.java | 86 -
.../cloud/dataflow/sdk/util/AvroUtilsTest.java | 226 --
.../sdk/util/BatchTimerInternalsTest.java | 118 -
.../sdk/util/BigQueryServicesImplTest.java | 262 --
.../sdk/util/BigQueryTableInserterTest.java | 304 --
.../sdk/util/BigQueryTableRowIteratorTest.java | 256 --
.../dataflow/sdk/util/BigQueryUtilTest.java | 480 ---
...BufferedElementCountingOutputStreamTest.java | 208 --
.../cloud/dataflow/sdk/util/CoderUtilsTest.java | 230 --
.../dataflow/sdk/util/CombineFnUtilTest.java | 104 -
.../sdk/util/CounterAggregatorTest.java | 254 --
.../sdk/util/ExecutableTriggerTest.java | 129 -
.../util/ExposedByteArrayInputStreamTest.java | 80 -
.../util/ExposedByteArrayOutputStreamTest.java | 247 --
.../sdk/util/FileIOChannelFactoryTest.java | 227 --
.../sdk/util/FinishedTriggersBitSetTest.java | 55 -
.../sdk/util/FinishedTriggersProperties.java | 110 -
.../sdk/util/FinishedTriggersSetTest.java | 61 -
.../sdk/util/GcsIOChannelFactoryTest.java | 44 -
.../cloud/dataflow/sdk/util/GcsUtilTest.java | 492 ---
.../sdk/util/GroupAlsoByWindowsProperties.java | 719 -----
...oupAlsoByWindowsViaOutputBufferDoFnTest.java | 112 -
.../dataflow/sdk/util/IOChannelUtilsTest.java | 95 -
.../dataflow/sdk/util/InstanceBuilderTest.java | 116 -
.../IntervalBoundedExponentialBackOffTest.java | 100 -
.../sdk/util/KeyedWorkItemCoderTest.java | 63 -
.../util/LateDataDroppingDoFnRunnerTest.java | 117 -
.../sdk/util/MergingActiveWindowSetTest.java | 174 -
.../sdk/util/MutationDetectorsTest.java | 149 -
.../cloud/dataflow/sdk/util/PTupleTest.java | 41 -
.../dataflow/sdk/util/RandomAccessDataTest.java | 207 --
.../dataflow/sdk/util/ReduceFnRunnerTest.java | 1205 -------
.../cloud/dataflow/sdk/util/ReduceFnTester.java | 779 -----
.../cloud/dataflow/sdk/util/ReshuffleTest.java | 209 --
.../dataflow/sdk/util/ReshuffleTriggerTest.java | 60 -
.../util/RetryHttpRequestInitializerTest.java | 297 --
.../sdk/util/SerializableUtilsTest.java | 166 -
.../cloud/dataflow/sdk/util/SerializerTest.java | 163 -
.../dataflow/sdk/util/SimpleDoFnRunnerTest.java | 87 -
.../dataflow/sdk/util/StreamUtilsTest.java | 73 -
.../dataflow/sdk/util/StringUtilsTest.java | 146 -
.../cloud/dataflow/sdk/util/StructsTest.java | 207 --
.../cloud/dataflow/sdk/util/TimeUtilTest.java | 74 -
.../dataflow/sdk/util/TimerInternalsTest.java | 54 -
.../cloud/dataflow/sdk/util/TriggerTester.java | 584 ----
.../sdk/util/UnownedInputStreamTest.java | 77 -
.../sdk/util/UnownedOutputStreamTest.java | 58 -
.../util/UploadIdResponseInterceptorTest.java | 101 -
.../sdk/util/UserCodeExceptionTest.java | 176 -
.../cloud/dataflow/sdk/util/VarIntTest.java | 278 --
.../dataflow/sdk/util/WindowedValueTest.java | 58 -
.../cloud/dataflow/sdk/util/ZipFilesTest.java | 312 --
.../sdk/util/common/CounterSetTest.java | 226 --
.../dataflow/sdk/util/common/CounterTest.java | 590 ----
.../sdk/util/common/CounterTestUtils.java | 57 -
.../sdk/util/common/ReflectHelpersTest.java | 128 -
.../dataflow/sdk/util/gcsfs/GcsPathTest.java | 334 --
.../CopyOnAccessInMemoryStateInternalsTest.java | 555 ----
.../util/state/InMemoryStateInternalsTest.java | 350 --
.../sdk/util/state/StateNamespacesTest.java | 131 -
.../dataflow/sdk/util/state/StateTagTest.java | 175 -
.../cloud/dataflow/sdk/values/KVTest.java | 113 -
.../sdk/values/PCollectionListTest.java | 48 -
.../sdk/values/PCollectionTupleTest.java | 94 -
.../cloud/dataflow/sdk/values/PDoneTest.java | 103 -
.../cloud/dataflow/sdk/values/TupleTagTest.java | 88 -
.../dataflow/sdk/values/TypeDescriptorTest.java | 194 --
.../dataflow/sdk/values/TypedPValueTest.java | 165 -
.../org/apache/beam/sdk/DataflowMatchers.java | 66 +
.../java/org/apache/beam/sdk/PipelineTest.java | 297 ++
.../java/org/apache/beam/sdk/TestUtils.java | 214 ++
.../org/apache/beam/sdk/WindowMatchers.java | 138 +
.../apache/beam/sdk/coders/AvroCoderTest.java | 755 +++++
.../sdk/coders/BigEndianIntegerCoderTest.java | 91 +
.../beam/sdk/coders/BigEndianLongCoderTest.java | 95 +
.../beam/sdk/coders/ByteArrayCoderTest.java | 145 +
.../apache/beam/sdk/coders/ByteCoderTest.java | 92 +
.../beam/sdk/coders/ByteStringCoderTest.java | 122 +
.../beam/sdk/coders/CoderFactoriesTest.java | 101 +
.../beam/sdk/coders/CoderProvidersTest.java | 72 +
.../beam/sdk/coders/CoderRegistryTest.java | 522 +++
.../org/apache/beam/sdk/coders/CoderTest.java | 79 +
.../beam/sdk/coders/CollectionCoderTest.java | 94 +
.../apache/beam/sdk/coders/CustomCoderTest.java | 136 +
.../beam/sdk/coders/DefaultCoderTest.java | 129 +
.../beam/sdk/coders/DelegateCoderTest.java | 142 +
.../apache/beam/sdk/coders/DoubleCoderTest.java | 97 +
.../beam/sdk/coders/DurationCoderTest.java | 87 +
.../apache/beam/sdk/coders/EntityCoderTest.java | 109 +
.../beam/sdk/coders/InstantCoderTest.java | 117 +
.../beam/sdk/coders/IterableCoderTest.java | 110 +
.../apache/beam/sdk/coders/JAXBCoderTest.java | 156 +
.../org/apache/beam/sdk/coders/KvCoderTest.java | 119 +
.../apache/beam/sdk/coders/ListCoderTest.java | 135 +
.../apache/beam/sdk/coders/MapCoderTest.java | 107 +
.../beam/sdk/coders/NullableCoderTest.java | 140 +
.../beam/sdk/coders/PrintBase64Encodings.java | 82 +
.../apache/beam/sdk/coders/Proto2CoderTest.java | 146 +
.../beam/sdk/coders/SerializableCoderTest.java | 223 ++
.../apache/beam/sdk/coders/SetCoderTest.java | 87 +
.../beam/sdk/coders/StandardCoderTest.java | 177 ++
.../sdk/coders/StringDelegateCoderTest.java | 73 +
.../beam/sdk/coders/StringUtf8CoderTest.java | 81 +
.../sdk/coders/StructuralByteArrayTest.java | 41 +
.../beam/sdk/coders/TableRowJsonCoderTest.java | 87 +
.../sdk/coders/TextualIntegerCoderTest.java | 91 +
.../apache/beam/sdk/coders/VarIntCoderTest.java | 91 +
.../beam/sdk/coders/VarLongCoderTest.java | 95 +
.../sdk/coders/protobuf/ProtoCoderTest.java | 183 ++
.../sdk/coders/protobuf/ProtobufUtilTest.java | 196 ++
.../beam/sdk/io/AvroIOGeneratedClassTest.java | 375 +++
.../java/org/apache/beam/sdk/io/AvroIOTest.java | 259 ++
.../org/apache/beam/sdk/io/AvroSourceTest.java | 693 ++++
.../org/apache/beam/sdk/io/BigQueryIOTest.java | 606 ++++
.../io/BoundedReadFromUnboundedSourceTest.java | 133 +
.../beam/sdk/io/CompressedSourceTest.java | 477 +++
.../apache/beam/sdk/io/CountingInputTest.java | 152 +
.../apache/beam/sdk/io/CountingSourceTest.java | 290 ++
.../org/apache/beam/sdk/io/DatastoreIOTest.java | 588 ++++
.../apache/beam/sdk/io/FileBasedSinkTest.java | 513 +++
.../apache/beam/sdk/io/FileBasedSourceTest.java | 917 ++++++
.../beam/sdk/io/OffsetBasedSourceTest.java | 281 ++
.../org/apache/beam/sdk/io/PubsubIOTest.java | 234 ++
.../java/org/apache/beam/sdk/io/ReadTest.java | 145 +
.../java/org/apache/beam/sdk/io/TextIOTest.java | 517 +++
.../java/org/apache/beam/sdk/io/WriteTest.java | 344 ++
.../org/apache/beam/sdk/io/XmlSinkTest.java | 236 ++
.../org/apache/beam/sdk/io/XmlSourceTest.java | 825 +++++
.../beam/sdk/io/bigtable/BigtableIOTest.java | 689 ++++
.../range/ByteKeyRangeEstimateFractionTest.java | 70 +
.../range/ByteKeyRangeInterpolateKeyTest.java | 74 +
.../beam/sdk/io/range/ByteKeyRangeTest.java | 397 +++
.../sdk/io/range/ByteKeyRangeTrackerTest.java | 120 +
.../apache/beam/sdk/io/range/ByteKeyTest.java | 179 ++
.../sdk/io/range/OffsetRangeTrackerTest.java | 187 ++
.../test/java/org/apache/beam/sdk/io/user.avsc | 10 +
.../apache/beam/sdk/options/GcpOptionsTest.java | 124 +
.../sdk/options/GoogleApiDebugOptionsTest.java | 147 +
.../sdk/options/PipelineOptionsFactoryTest.java | 1150 +++++++
.../beam/sdk/options/PipelineOptionsTest.java | 126 +
.../options/PipelineOptionsValidatorTest.java | 311 ++
.../sdk/options/ProxyInvocationHandlerTest.java | 692 ++++
.../AggregatorPipelineExtractorTest.java | 228 ++
.../runners/DirectPipelineRegistrarTest.java | 70 +
.../sdk/runners/DirectPipelineRunnerTest.java | 211 ++
.../beam/sdk/runners/DirectPipelineTest.java | 35 +
.../beam/sdk/runners/PipelineRunnerTest.java | 81 +
.../beam/sdk/runners/TransformTreeTest.java | 195 ++
.../runners/dataflow/TestCountingSource.java | 247 ++
.../AvroIOShardedWriteFactoryTest.java | 112 +
.../BoundedReadEvaluatorFactoryTest.java | 289 ++
.../ConsumerTrackingPipelineVisitorTest.java | 272 ++
.../EncodabilityEnforcementFactoryTest.java | 262 ++
.../inprocess/FlattenEvaluatorFactoryTest.java | 141 +
.../inprocess/ForwardingPTransformTest.java | 102 +
.../GroupByKeyEvaluatorFactoryTest.java | 182 ++
.../ImmutabilityCheckingBundleFactoryTest.java | 220 ++
.../ImmutabilityEnforcementFactoryTest.java | 126 +
.../inprocess/InMemoryWatermarkManagerTest.java | 1124 +++++++
.../inprocess/InProcessBundleFactoryTest.java | 197 ++
.../runners/inprocess/InProcessBundleTest.java | 144 +
.../runners/inprocess/InProcessCreateTest.java | 235 ++
.../InProcessEvaluationContextTest.java | 535 ++++
.../InProcessPipelineRegistrarTest.java | 73 +
.../inprocess/InProcessPipelineRunnerTest.java | 78 +
.../InProcessSideInputContainerTest.java | 372 +++
.../inprocess/InProcessTimerInternalsTest.java | 133 +
.../KeyedPValueTrackingVisitorTest.java | 191 ++
.../beam/sdk/runners/inprocess/MockClock.java | 62 +
.../ParDoMultiEvaluatorFactoryTest.java | 431 +++
.../ParDoSingleEvaluatorFactoryTest.java | 324 ++
.../TextIOShardedWriteFactoryTest.java | 112 +
.../TransformExecutorServicesTest.java | 136 +
.../inprocess/TransformExecutorTest.java | 537 ++++
.../UnboundedReadEvaluatorFactoryTest.java | 333 ++
.../inprocess/ViewEvaluatorFactoryTest.java | 100 +
.../WatermarkCallbackExecutorTest.java | 128 +
.../inprocess/WindowEvaluatorFactoryTest.java | 221 ++
.../beam/sdk/testing/CoderPropertiesTest.java | 215 ++
.../sdk/testing/DataflowJUnitTestRunner.java | 129 +
.../apache/beam/sdk/testing/ExpectedLogs.java | 307 ++
.../beam/sdk/testing/ExpectedLogsTest.java | 154 +
.../sdk/testing/FastNanoClockAndSleeper.java | 48 +
.../testing/FastNanoClockAndSleeperTest.java | 48 +
.../apache/beam/sdk/testing/PAssertTest.java | 309 ++
.../sdk/testing/PCollectionViewTesting.java | 296 ++
.../beam/sdk/testing/ResetDateTimeProvider.java | 42 +
.../sdk/testing/ResetDateTimeProviderTest.java | 56 +
.../sdk/testing/RestoreSystemProperties.java | 50 +
.../testing/RestoreSystemPropertiesTest.java | 51 +
.../sdk/testing/SerializableMatchersTest.java | 166 +
.../beam/sdk/testing/SystemNanoTimeSleeper.java | 69 +
.../sdk/testing/SystemNanoTimeSleeperTest.java | 54 +
.../beam/sdk/testing/TestPipelineTest.java | 103 +
.../transforms/ApproximateQuantilesTest.java | 298 ++
.../sdk/transforms/ApproximateUniqueTest.java | 292 ++
.../beam/sdk/transforms/CombineFnsTest.java | 415 +++
.../apache/beam/sdk/transforms/CombineTest.java | 1138 +++++++
.../apache/beam/sdk/transforms/CountTest.java | 122 +
.../apache/beam/sdk/transforms/CreateTest.java | 241 ++
.../beam/sdk/transforms/DoFnContextTest.java | 69 +
.../DoFnDelegatingAggregatorTest.java | 144 +
.../beam/sdk/transforms/DoFnReflectorTest.java | 494 +++
.../apache/beam/sdk/transforms/DoFnTest.java | 202 ++
.../beam/sdk/transforms/DoFnTesterTest.java | 254 ++
.../sdk/transforms/DoFnWithContextTest.java | 221 ++
.../apache/beam/sdk/transforms/FilterTest.java | 161 +
.../sdk/transforms/FlatMapElementsTest.java | 125 +
.../apache/beam/sdk/transforms/FlattenTest.java | 370 +++
.../beam/sdk/transforms/GroupByKeyTest.java | 377 +++
.../IntraBundleParallelizationTest.java | 251 ++
.../apache/beam/sdk/transforms/KeysTest.java | 84 +
.../apache/beam/sdk/transforms/KvSwapTest.java | 92 +
.../beam/sdk/transforms/MapElementsTest.java | 135 +
.../org/apache/beam/sdk/transforms/MaxTest.java | 67 +
.../apache/beam/sdk/transforms/MeanTest.java | 73 +
.../org/apache/beam/sdk/transforms/MinTest.java | 67 +
.../apache/beam/sdk/transforms/NoOpDoFn.java | 144 +
.../beam/sdk/transforms/PTransformTest.java | 42 +
.../apache/beam/sdk/transforms/ParDoTest.java | 1542 +++++++++
.../beam/sdk/transforms/PartitionTest.java | 141 +
.../sdk/transforms/RemoveDuplicatesTest.java | 132 +
.../apache/beam/sdk/transforms/SampleTest.java | 261 ++
.../beam/sdk/transforms/SimpleStatsFnsTest.java | 130 +
.../org/apache/beam/sdk/transforms/SumTest.java | 68 +
.../org/apache/beam/sdk/transforms/TopTest.java | 260 ++
.../apache/beam/sdk/transforms/ValuesTest.java | 94 +
.../apache/beam/sdk/transforms/ViewTest.java | 1423 +++++++++
.../beam/sdk/transforms/WithKeysTest.java | 128 +
.../beam/sdk/transforms/WithTimestampsTest.java | 211 ++
.../transforms/display/DisplayDataMatchers.java | 321 ++
.../display/DisplayDataMatchersTest.java | 157 +
.../sdk/transforms/display/DisplayDataTest.java | 955 ++++++
.../transforms/join/CoGbkResultCoderTest.java | 86 +
.../sdk/transforms/join/CoGbkResultTest.java | 125 +
.../sdk/transforms/join/CoGroupByKeyTest.java | 508 +++
.../sdk/transforms/join/UnionCoderTest.java | 49 +
.../sdk/transforms/windowing/AfterAllTest.java | 152 +
.../sdk/transforms/windowing/AfterEachTest.java | 123 +
.../transforms/windowing/AfterFirstTest.java | 176 +
.../sdk/transforms/windowing/AfterPaneTest.java | 127 +
.../windowing/AfterProcessingTimeTest.java | 158 +
.../AfterSynchronizedProcessingTimeTest.java | 122 +
.../windowing/AfterWatermarkTest.java | 339 ++
.../windowing/CalendarWindowsTest.java | 261 ++
.../windowing/DefaultTriggerTest.java | 177 ++
.../transforms/windowing/FixedWindowsTest.java | 125 +
.../windowing/IntervalWindowTest.java | 95 +
.../windowing/OrFinallyTriggerTest.java | 210 ++
.../sdk/transforms/windowing/PaneInfoTest.java | 77 +
.../transforms/windowing/RepeatedlyTest.java | 212 ++
.../sdk/transforms/windowing/SessionsTest.java | 157 +
.../windowing/SlidingWindowsTest.java | 194 ++
.../sdk/transforms/windowing/TriggerTest.java | 119 +
.../sdk/transforms/windowing/WindowTest.java | 227 ++
.../sdk/transforms/windowing/WindowingTest.java | 245 ++
.../apache/beam/sdk/util/ApiSurfaceTest.java | 188 ++
...mptAndTimeBoundedExponentialBackOffTest.java | 213 ++
.../AttemptBoundedExponentialBackOffTest.java | 86 +
.../org/apache/beam/sdk/util/AvroUtilsTest.java | 226 ++
.../beam/sdk/util/BatchTimerInternalsTest.java | 118 +
.../beam/sdk/util/BigQueryServicesImplTest.java | 261 ++
.../sdk/util/BigQueryTableInserterTest.java | 304 ++
.../sdk/util/BigQueryTableRowIteratorTest.java | 256 ++
.../apache/beam/sdk/util/BigQueryUtilTest.java | 480 +++
...BufferedElementCountingOutputStreamTest.java | 207 ++
.../apache/beam/sdk/util/CoderUtilsTest.java | 230 ++
.../apache/beam/sdk/util/CombineFnUtilTest.java | 104 +
.../beam/sdk/util/CounterAggregatorTest.java | 254 ++
.../beam/sdk/util/ExecutableTriggerTest.java | 129 +
.../util/ExposedByteArrayInputStreamTest.java | 80 +
.../util/ExposedByteArrayOutputStreamTest.java | 247 ++
.../beam/sdk/util/FileIOChannelFactoryTest.java | 227 ++
.../sdk/util/FinishedTriggersBitSetTest.java | 55 +
.../sdk/util/FinishedTriggersProperties.java | 110 +
.../beam/sdk/util/FinishedTriggersSetTest.java | 61 +
.../beam/sdk/util/GcsIOChannelFactoryTest.java | 44 +
.../org/apache/beam/sdk/util/GcsUtilTest.java | 492 +++
.../sdk/util/GroupAlsoByWindowsProperties.java | 719 +++++
...oupAlsoByWindowsViaOutputBufferDoFnTest.java | 112 +
.../beam/sdk/util/IOChannelUtilsTest.java | 95 +
.../beam/sdk/util/InstanceBuilderTest.java | 116 +
.../IntervalBoundedExponentialBackOffTest.java | 100 +
.../beam/sdk/util/KeyedWorkItemCoderTest.java | 63 +
.../util/LateDataDroppingDoFnRunnerTest.java | 116 +
.../sdk/util/MergingActiveWindowSetTest.java | 174 +
.../beam/sdk/util/MutationDetectorsTest.java | 148 +
.../org/apache/beam/sdk/util/PTupleTest.java | 41 +
.../beam/sdk/util/RandomAccessDataTest.java | 206 ++
.../beam/sdk/util/ReduceFnRunnerTest.java | 1205 +++++++
.../apache/beam/sdk/util/ReduceFnTester.java | 779 +++++
.../org/apache/beam/sdk/util/ReshuffleTest.java | 209 ++
.../beam/sdk/util/ReshuffleTriggerTest.java | 60 +
.../util/RetryHttpRequestInitializerTest.java | 297 ++
.../beam/sdk/util/SerializableUtilsTest.java | 166 +
.../apache/beam/sdk/util/SerializerTest.java | 163 +
.../beam/sdk/util/SimpleDoFnRunnerTest.java | 86 +
.../apache/beam/sdk/util/StreamUtilsTest.java | 73 +
.../apache/beam/sdk/util/StringUtilsTest.java | 146 +
.../org/apache/beam/sdk/util/StructsTest.java | 207 ++
.../org/apache/beam/sdk/util/TimeUtilTest.java | 74 +
.../beam/sdk/util/TimerInternalsTest.java | 53 +
.../org/apache/beam/sdk/util/TriggerTester.java | 584 ++++
.../beam/sdk/util/UnownedInputStreamTest.java | 76 +
.../beam/sdk/util/UnownedOutputStreamTest.java | 57 +
.../util/UploadIdResponseInterceptorTest.java | 101 +
.../beam/sdk/util/UserCodeExceptionTest.java | 175 +
.../org/apache/beam/sdk/util/VarIntTest.java | 278 ++
.../apache/beam/sdk/util/WindowedValueTest.java | 58 +
.../org/apache/beam/sdk/util/ZipFilesTest.java | 312 ++
.../beam/sdk/util/common/CounterSetTest.java | 226 ++
.../beam/sdk/util/common/CounterTest.java | 590 ++++
.../beam/sdk/util/common/CounterTestUtils.java | 57 +
.../sdk/util/common/ReflectHelpersTest.java | 128 +
.../apache/beam/sdk/util/gcsfs/GcsPathTest.java | 334 ++
.../CopyOnAccessInMemoryStateInternalsTest.java | 555 ++++
.../util/state/InMemoryStateInternalsTest.java | 350 ++
.../sdk/util/state/StateNamespacesTest.java | 131 +
.../beam/sdk/util/state/StateTagTest.java | 175 +
.../java/org/apache/beam/sdk/values/KVTest.java | 113 +
.../beam/sdk/values/PCollectionListTest.java | 48 +
.../beam/sdk/values/PCollectionTupleTest.java | 94 +
.../org/apache/beam/sdk/values/PDoneTest.java | 103 +
.../apache/beam/sdk/values/TupleTagTest.java | 88 +
.../beam/sdk/values/TypeDescriptorTest.java | 194 ++
.../apache/beam/sdk/values/TypedPValueTest.java | 164 +
.../PipelineOptionsFactoryJava8Test.java | 92 -
.../PipelineOptionsFactoryJava8Test.java | 92 +
.../sdk/transforms/CombineJava8Test.java | 134 -
.../sdk/transforms/FilterJava8Test.java | 119 -
.../transforms/FlatMapElementsJava8Test.java | 85 -
.../sdk/transforms/MapElementsJava8Test.java | 78 -
.../sdk/transforms/PartitionJava8Test.java | 75 -
.../transforms/RemoveDuplicatesJava8Test.java | 100 -
.../sdk/transforms/WithKeysJava8Test.java | 75 -
.../sdk/transforms/WithTimestampsJava8Test.java | 67 -
.../beam/sdk/transforms/CombineJava8Test.java | 134 +
.../beam/sdk/transforms/FilterJava8Test.java | 119 +
.../transforms/FlatMapElementsJava8Test.java | 85 +
.../sdk/transforms/MapElementsJava8Test.java | 78 +
.../beam/sdk/transforms/PartitionJava8Test.java | 75 +
.../transforms/RemoveDuplicatesJava8Test.java | 100 +
.../beam/sdk/transforms/WithKeysJava8Test.java | 75 +
.../sdk/transforms/WithTimestampsJava8Test.java | 67 +
1646 files changed, 174737 insertions(+), 174807 deletions(-)
----------------------------------------------------------------------