Update LICENSE header across all files
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/d59c8012 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/d59c8012 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/d59c8012 Branch: refs/heads/master Commit: d59c80121dd0362040e1269f4ad4a58390557500 Parents: c6aac3b Author: Davor Bonaci <[email protected]> Authored: Wed Mar 30 14:59:35 2016 -0700 Committer: Dan Halperin <[email protected]> Committed: Wed Mar 30 16:34:14 2016 -0700 ---------------------------------------------------------------------- contrib/hadoop/pom.xml | 31 ++++++++++---------- .../contrib/hadoop/HadoopFileSource.java | 23 ++++++++------- .../dataflow/contrib/hadoop/WritableCoder.java | 23 ++++++++------- .../contrib/hadoop/HadoopFileSourceTest.java | 23 ++++++++------- .../contrib/hadoop/WritableCoderTest.java | 23 ++++++++------- .../dataflow/contrib/joinlibrary/Join.java | 23 ++++++++------- .../contrib/joinlibrary/InnerJoinTest.java | 23 ++++++++------- .../contrib/joinlibrary/OuterLeftJoinTest.java | 23 ++++++++------- .../contrib/joinlibrary/OuterRightJoinTest.java | 23 ++++++++------- .../dataflow/examples/DebuggingWordCount.java | 23 ++++++++------- .../dataflow/examples/MinimalWordCount.java | 23 ++++++++------- .../dataflow/examples/WindowedWordCount.java | 23 ++++++++------- .../cloud/dataflow/examples/WordCount.java | 23 ++++++++------- .../examples/common/DataflowExampleOptions.java | 23 ++++++++------- .../examples/common/DataflowExampleUtils.java | 23 ++++++++------- .../common/ExampleBigQueryTableOptions.java | 23 ++++++++------- ...xamplePubsubTopicAndSubscriptionOptions.java | 23 ++++++++------- .../common/ExamplePubsubTopicOptions.java | 23 ++++++++------- .../examples/common/PubsubFileInjector.java | 23 ++++++++------- .../examples/complete/AutoComplete.java | 23 ++++++++------- .../examples/complete/StreamingWordExtract.java | 23 ++++++++------- .../cloud/dataflow/examples/complete/TfIdf.java | 23 ++++++++------- .../examples/complete/TopWikipediaSessions.java | 23 ++++++++------- .../examples/complete/TrafficMaxLaneFlow.java | 23 ++++++++------- .../examples/complete/TrafficRoutes.java | 23 ++++++++------- .../examples/cookbook/BigQueryTornadoes.java | 23 ++++++++------- .../cookbook/CombinePerKeyExamples.java | 23 ++++++++------- .../examples/cookbook/DatastoreWordCount.java | 23 ++++++++------- .../examples/cookbook/DeDupExample.java | 23 ++++++++------- .../examples/cookbook/FilterExamples.java | 23 ++++++++------- .../examples/cookbook/JoinExamples.java | 23 ++++++++------- .../examples/cookbook/MaxPerKeyExamples.java | 23 ++++++++------- .../examples/cookbook/TriggerExample.java | 23 ++++++++------- .../examples/DebuggingWordCountTest.java | 23 ++++++++------- .../cloud/dataflow/examples/WordCountTest.java | 23 ++++++++------- .../examples/complete/AutoCompleteTest.java | 23 ++++++++------- .../dataflow/examples/complete/TfIdfTest.java | 23 ++++++++------- .../complete/TopWikipediaSessionsTest.java | 23 ++++++++------- .../cookbook/BigQueryTornadoesTest.java | 23 ++++++++------- .../cookbook/CombinePerKeyExamplesTest.java | 23 ++++++++------- .../examples/cookbook/DeDupExampleTest.java | 23 ++++++++------- .../examples/cookbook/FilterExamplesTest.java | 23 ++++++++------- .../examples/cookbook/JoinExamplesTest.java | 23 ++++++++------- .../cookbook/MaxPerKeyExamplesTest.java | 23 ++++++++------- .../examples/cookbook/TriggerExampleTest.java | 23 ++++++++------- .../examples/MinimalWordCountJava8.java | 23 ++++++++------- .../examples/complete/game/GameStats.java | 23 ++++++++------- .../examples/complete/game/HourlyTeamScore.java | 23 ++++++++------- .../examples/complete/game/LeaderBoard.java | 23 ++++++++------- .../examples/complete/game/UserScore.java | 23 ++++++++------- .../complete/game/injector/Injector.java | 23 ++++++++------- .../complete/game/injector/InjectorUtils.java | 23 ++++++++------- .../injector/RetryHttpInitializerWrapper.java | 23 ++++++++------- .../complete/game/utils/WriteToBigQuery.java | 23 ++++++++------- .../game/utils/WriteWindowedToBigQuery.java | 23 ++++++++------- .../examples/MinimalWordCountJava8Test.java | 23 ++++++++------- .../examples/complete/game/GameStatsTest.java | 23 ++++++++------- .../complete/game/HourlyTeamScoreTest.java | 23 ++++++++------- .../examples/complete/game/UserScoreTest.java | 23 ++++++++------- .../beam/runners/flink/examples/TFIDF.java | 23 ++++++++------- .../flink/examples/streaming/AutoComplete.java | 23 ++++++++------- .../flink/examples/streaming/JoinExamples.java | 23 ++++++++------- .../flink/translation/functions/UnionCoder.java | 23 ++++++++------- sdks/java/checkstyle.xml | 31 ++++++++++---------- .../com/google/cloud/dataflow/sdk/Pipeline.java | 23 ++++++++------- .../cloud/dataflow/sdk/PipelineResult.java | 23 ++++++++------- .../dataflow/sdk/annotations/Experimental.java | 23 ++++++++------- .../dataflow/sdk/annotations/package-info.java | 23 ++++++++------- .../cloud/dataflow/sdk/coders/AtomicCoder.java | 23 ++++++++------- .../cloud/dataflow/sdk/coders/AvroCoder.java | 23 ++++++++------- .../sdk/coders/BigEndianIntegerCoder.java | 23 ++++++++------- .../dataflow/sdk/coders/BigEndianLongCoder.java | 23 ++++++++------- .../dataflow/sdk/coders/ByteArrayCoder.java | 23 ++++++++------- .../cloud/dataflow/sdk/coders/ByteCoder.java | 23 ++++++++------- .../dataflow/sdk/coders/ByteStringCoder.java | 23 ++++++++------- .../sdk/coders/CannotProvideCoderException.java | 23 ++++++++------- .../google/cloud/dataflow/sdk/coders/Coder.java | 23 ++++++++------- .../dataflow/sdk/coders/CoderException.java | 23 ++++++++------- .../dataflow/sdk/coders/CoderFactories.java | 23 ++++++++------- .../cloud/dataflow/sdk/coders/CoderFactory.java | 23 ++++++++------- .../dataflow/sdk/coders/CoderProvider.java | 23 ++++++++------- .../dataflow/sdk/coders/CoderProviders.java | 23 ++++++++------- .../dataflow/sdk/coders/CoderRegistry.java | 23 ++++++++------- .../dataflow/sdk/coders/CollectionCoder.java | 23 ++++++++------- .../cloud/dataflow/sdk/coders/CustomCoder.java | 23 ++++++++------- .../cloud/dataflow/sdk/coders/DefaultCoder.java | 23 ++++++++------- .../dataflow/sdk/coders/DelegateCoder.java | 23 ++++++++------- .../sdk/coders/DeterministicStandardCoder.java | 23 ++++++++------- .../cloud/dataflow/sdk/coders/DoubleCoder.java | 23 ++++++++------- .../dataflow/sdk/coders/DurationCoder.java | 23 ++++++++------- .../cloud/dataflow/sdk/coders/EntityCoder.java | 23 ++++++++------- .../cloud/dataflow/sdk/coders/InstantCoder.java | 23 ++++++++------- .../dataflow/sdk/coders/IterableCoder.java | 23 ++++++++------- .../dataflow/sdk/coders/IterableLikeCoder.java | 23 ++++++++------- .../cloud/dataflow/sdk/coders/JAXBCoder.java | 23 ++++++++------- .../cloud/dataflow/sdk/coders/KvCoder.java | 23 ++++++++------- .../cloud/dataflow/sdk/coders/KvCoderBase.java | 23 ++++++++------- .../cloud/dataflow/sdk/coders/ListCoder.java | 23 ++++++++------- .../cloud/dataflow/sdk/coders/MapCoder.java | 23 ++++++++------- .../cloud/dataflow/sdk/coders/MapCoderBase.java | 23 ++++++++------- .../dataflow/sdk/coders/NullableCoder.java | 23 ++++++++------- .../cloud/dataflow/sdk/coders/Proto2Coder.java | 22 +++++++------- .../dataflow/sdk/coders/SerializableCoder.java | 23 ++++++++------- .../cloud/dataflow/sdk/coders/SetCoder.java | 23 ++++++++------- .../dataflow/sdk/coders/StandardCoder.java | 23 ++++++++------- .../sdk/coders/StringDelegateCoder.java | 23 ++++++++------- .../dataflow/sdk/coders/StringUtf8Coder.java | 23 ++++++++------- .../sdk/coders/StructuralByteArray.java | 22 +++++++------- .../dataflow/sdk/coders/TableRowJsonCoder.java | 23 ++++++++------- .../sdk/coders/TextualIntegerCoder.java | 23 ++++++++------- .../cloud/dataflow/sdk/coders/VarIntCoder.java | 23 ++++++++------- .../cloud/dataflow/sdk/coders/VarLongCoder.java | 23 ++++++++------- .../cloud/dataflow/sdk/coders/VoidCoder.java | 23 ++++++++------- .../cloud/dataflow/sdk/coders/package-info.java | 23 ++++++++------- .../sdk/coders/protobuf/ProtoCoder.java | 22 +++++++------- .../sdk/coders/protobuf/ProtobufUtil.java | 23 ++++++++------- .../sdk/coders/protobuf/package-info.java | 23 ++++++++------- .../google/cloud/dataflow/sdk/io/AvroIO.java | 23 ++++++++------- .../cloud/dataflow/sdk/io/AvroSource.java | 23 ++++++++------- .../cloud/dataflow/sdk/io/BigQueryIO.java | 23 ++++++++------- .../cloud/dataflow/sdk/io/BlockBasedSource.java | 23 ++++++++------- .../sdk/io/BoundedReadFromUnboundedSource.java | 23 ++++++++------- .../cloud/dataflow/sdk/io/BoundedSource.java | 23 ++++++++------- .../cloud/dataflow/sdk/io/CompressedSource.java | 23 ++++++++------- .../cloud/dataflow/sdk/io/CountingInput.java | 23 ++++++++------- .../cloud/dataflow/sdk/io/CountingSource.java | 23 ++++++++------- .../cloud/dataflow/sdk/io/DatastoreIO.java | 23 ++++++++------- .../cloud/dataflow/sdk/io/FileBasedSink.java | 23 ++++++++------- .../cloud/dataflow/sdk/io/FileBasedSource.java | 23 ++++++++------- .../dataflow/sdk/io/OffsetBasedSource.java | 23 ++++++++------- .../google/cloud/dataflow/sdk/io/PubsubIO.java | 23 ++++++++------- .../com/google/cloud/dataflow/sdk/io/Read.java | 23 ++++++++------- .../dataflow/sdk/io/ShardNameTemplate.java | 23 ++++++++------- .../com/google/cloud/dataflow/sdk/io/Sink.java | 27 +++++++++-------- .../google/cloud/dataflow/sdk/io/Source.java | 23 ++++++++------- .../google/cloud/dataflow/sdk/io/TextIO.java | 23 ++++++++------- .../cloud/dataflow/sdk/io/UnboundedSource.java | 23 ++++++++------- .../com/google/cloud/dataflow/sdk/io/Write.java | 23 ++++++++------- .../google/cloud/dataflow/sdk/io/XmlSink.java | 23 ++++++++------- .../google/cloud/dataflow/sdk/io/XmlSource.java | 23 ++++++++------- .../dataflow/sdk/io/bigtable/BigtableIO.java | 23 ++++++++------- .../sdk/io/bigtable/BigtableService.java | 22 +++++++------- .../sdk/io/bigtable/BigtableServiceImpl.java | 22 +++++++------- .../dataflow/sdk/io/bigtable/package-info.java | 23 ++++++++------- .../cloud/dataflow/sdk/io/package-info.java | 23 ++++++++------- .../cloud/dataflow/sdk/io/range/ByteKey.java | 23 ++++++++------- .../dataflow/sdk/io/range/ByteKeyRange.java | 23 ++++++++------- .../sdk/io/range/ByteKeyRangeTracker.java | 23 ++++++++------- .../sdk/io/range/OffsetRangeTracker.java | 27 +++++++++-------- .../dataflow/sdk/io/range/RangeTracker.java | 27 +++++++++-------- .../dataflow/sdk/io/range/package-info.java | 23 ++++++++------- .../sdk/options/ApplicationNameOptions.java | 23 ++++++++------- .../dataflow/sdk/options/BigQueryOptions.java | 23 ++++++++------- .../BlockingDataflowPipelineOptions.java | 23 ++++++++------- .../sdk/options/CloudDebuggerOptions.java | 23 ++++++++------- .../options/DataflowPipelineDebugOptions.java | 23 ++++++++------- .../sdk/options/DataflowPipelineOptions.java | 23 ++++++++------- .../DataflowPipelineWorkerPoolOptions.java | 23 ++++++++------- .../sdk/options/DataflowProfilingOptions.java | 22 +++++++------- .../options/DataflowWorkerHarnessOptions.java | 23 ++++++++------- .../options/DataflowWorkerLoggingOptions.java | 22 +++++++------- .../cloud/dataflow/sdk/options/Default.java | 23 ++++++++------- .../sdk/options/DefaultValueFactory.java | 23 ++++++++------- .../cloud/dataflow/sdk/options/Description.java | 23 ++++++++------- .../sdk/options/DirectPipelineOptions.java | 23 ++++++++------- .../cloud/dataflow/sdk/options/GcpOptions.java | 23 ++++++++------- .../cloud/dataflow/sdk/options/GcsOptions.java | 23 ++++++++------- .../sdk/options/GoogleApiDebugOptions.java | 23 ++++++++------- .../cloud/dataflow/sdk/options/Hidden.java | 23 ++++++++------- .../dataflow/sdk/options/PipelineOptions.java | 23 ++++++++------- .../sdk/options/PipelineOptionsFactory.java | 23 ++++++++------- .../sdk/options/PipelineOptionsRegistrar.java | 23 ++++++++------- .../sdk/options/PipelineOptionsValidator.java | 23 ++++++++------- .../sdk/options/ProxyInvocationHandler.java | 23 ++++++++------- .../dataflow/sdk/options/StreamingOptions.java | 23 ++++++++------- .../cloud/dataflow/sdk/options/Validation.java | 23 ++++++++------- .../dataflow/sdk/options/package-info.java | 23 ++++++++------- .../google/cloud/dataflow/sdk/package-info.java | 23 ++++++++------- .../runners/AggregatorPipelineExtractor.java | 23 ++++++++------- .../runners/AggregatorRetrievalException.java | 23 ++++++++------- .../dataflow/sdk/runners/AggregatorValues.java | 23 ++++++++------- .../runners/BlockingDataflowPipelineRunner.java | 23 ++++++++------- .../DataflowJobAlreadyExistsException.java | 23 ++++++++------- .../DataflowJobAlreadyUpdatedException.java | 23 ++++++++------- .../runners/DataflowJobCancelledException.java | 23 ++++++++------- .../sdk/runners/DataflowJobException.java | 23 ++++++++------- .../runners/DataflowJobExecutionException.java | 23 ++++++++------- .../runners/DataflowJobUpdatedException.java | 23 ++++++++------- .../dataflow/sdk/runners/DataflowPipeline.java | 23 ++++++++------- .../sdk/runners/DataflowPipelineJob.java | 22 +++++++------- .../sdk/runners/DataflowPipelineRegistrar.java | 23 ++++++++------- .../sdk/runners/DataflowPipelineRunner.java | 23 ++++++++------- .../runners/DataflowPipelineRunnerHooks.java | 23 ++++++++------- .../sdk/runners/DataflowPipelineTranslator.java | 23 ++++++++------- .../sdk/runners/DataflowServiceException.java | 23 ++++++++------- .../dataflow/sdk/runners/DirectPipeline.java | 23 ++++++++------- .../sdk/runners/DirectPipelineRegistrar.java | 23 ++++++++------- .../sdk/runners/DirectPipelineRunner.java | 23 ++++++++------- .../dataflow/sdk/runners/PipelineRunner.java | 23 ++++++++------- .../sdk/runners/PipelineRunnerRegistrar.java | 23 ++++++++------- .../sdk/runners/RecordingPipelineVisitor.java | 23 ++++++++------- .../sdk/runners/TransformHierarchy.java | 23 ++++++++------- .../dataflow/sdk/runners/TransformTreeNode.java | 23 ++++++++------- .../sdk/runners/dataflow/AssignWindows.java | 22 +++++++------- .../runners/dataflow/BigQueryIOTranslator.java | 23 ++++++++------- .../sdk/runners/dataflow/CustomSources.java | 23 ++++++++------- .../dataflow/DataflowAggregatorTransforms.java | 23 ++++++++------- .../dataflow/DataflowMetricUpdateExtractor.java | 23 ++++++++------- .../runners/dataflow/PubsubIOTranslator.java | 23 ++++++++------- .../sdk/runners/dataflow/ReadTranslator.java | 23 ++++++++------- .../sdk/runners/dataflow/package-info.java | 23 ++++++++------- .../inprocess/AbstractModelEnforcement.java | 22 +++++++------- .../inprocess/BoundedReadEvaluatorFactory.java | 22 +++++++------- .../CachedThreadPoolExecutorServiceFactory.java | 22 +++++++------- .../dataflow/sdk/runners/inprocess/Clock.java | 22 +++++++------- .../runners/inprocess/CompletionCallback.java | 22 +++++++------- .../ConsumerTrackingPipelineVisitor.java | 22 +++++++------- .../inprocess/EmptyTransformEvaluator.java | 22 +++++++------- .../EncodabilityEnforcementFactory.java | 22 +++++++------- .../sdk/runners/inprocess/EvaluatorKey.java | 22 +++++++------- .../inprocess/ExecutorServiceFactory.java | 22 +++++++------- .../ExecutorServiceParallelExecutor.java | 22 +++++++------- .../inprocess/FlattenEvaluatorFactory.java | 22 +++++++------- .../runners/inprocess/ForwardingPTransform.java | 22 +++++++------- .../inprocess/GroupByKeyEvaluatorFactory.java | 22 +++++++------- .../ImmutabilityEnforcementFactory.java | 22 +++++++------- .../inprocess/InMemoryWatermarkManager.java | 22 +++++++------- .../sdk/runners/inprocess/InProcessBundle.java | 22 +++++++------- .../inprocess/InProcessBundleOutputManager.java | 22 +++++++------- .../sdk/runners/inprocess/InProcessCreate.java | 22 +++++++------- .../inprocess/InProcessEvaluationContext.java | 22 +++++++------- .../inprocess/InProcessExecutionContext.java | 22 +++++++------- .../runners/inprocess/InProcessExecutor.java | 22 +++++++------- .../inprocess/InProcessPipelineOptions.java | 22 +++++++------- .../inprocess/InProcessPipelineRunner.java | 22 +++++++------- .../inprocess/InProcessSideInputContainer.java | 22 +++++++------- .../inprocess/InProcessTimerInternals.java | 22 +++++++------- .../inprocess/InProcessTransformResult.java | 22 +++++++------- .../inprocess/KeyedPValueTrackingVisitor.java | 22 +++++++------- .../sdk/runners/inprocess/ModelEnforcement.java | 22 +++++++------- .../inprocess/ModelEnforcementFactory.java | 22 +++++++------- .../sdk/runners/inprocess/NanosOffsetClock.java | 22 +++++++------- .../inprocess/ParDoInProcessEvaluator.java | 22 +++++++------- .../inprocess/ParDoMultiEvaluatorFactory.java | 22 +++++++------- .../inprocess/ParDoSingleEvaluatorFactory.java | 22 +++++++------- .../sdk/runners/inprocess/StepAndKey.java | 22 +++++++------- .../runners/inprocess/StepTransformResult.java | 22 +++++++------- .../runners/inprocess/TransformEvaluator.java | 22 +++++++------- .../inprocess/TransformEvaluatorFactory.java | 22 +++++++------- .../inprocess/TransformEvaluatorRegistry.java | 22 +++++++------- .../runners/inprocess/TransformExecutor.java | 22 +++++++------- .../inprocess/TransformExecutorService.java | 22 +++++++------- .../inprocess/TransformExecutorServices.java | 22 +++++++------- .../UnboundedReadEvaluatorFactory.java | 22 +++++++------- .../runners/inprocess/ViewEvaluatorFactory.java | 22 +++++++------- .../inprocess/WatermarkCallbackExecutor.java | 22 +++++++------- .../dataflow/sdk/runners/package-info.java | 23 ++++++++------- .../dataflow/sdk/runners/worker/IsmFormat.java | 22 +++++++------- .../sdk/runners/worker/package-info.java | 23 ++++++++------- .../dataflow/sdk/testing/CoderProperties.java | 23 ++++++++------- .../dataflow/sdk/testing/DataflowAssert.java | 23 ++++++++------- .../dataflow/sdk/testing/RunnableOnService.java | 23 ++++++++------- .../sdk/testing/SerializableMatcher.java | 23 ++++++++------- .../sdk/testing/SerializableMatchers.java | 23 ++++++++------- .../dataflow/sdk/testing/SourceTestUtils.java | 23 ++++++++------- .../testing/TestDataflowPipelineOptions.java | 23 ++++++++------- .../sdk/testing/TestDataflowPipelineRunner.java | 23 ++++++++------- .../dataflow/sdk/testing/TestPipeline.java | 23 ++++++++------- .../dataflow/sdk/testing/WindowFnTestUtils.java | 23 ++++++++------- .../dataflow/sdk/testing/package-info.java | 23 ++++++++------- .../dataflow/sdk/transforms/Aggregator.java | 27 +++++++++-------- .../sdk/transforms/AggregatorRetriever.java | 23 ++++++++------- .../sdk/transforms/AppliedPTransform.java | 23 ++++++++------- .../sdk/transforms/ApproximateQuantiles.java | 23 ++++++++------- .../sdk/transforms/ApproximateUnique.java | 23 ++++++++------- .../cloud/dataflow/sdk/transforms/Combine.java | 22 +++++++------- .../dataflow/sdk/transforms/CombineFnBase.java | 22 +++++++------- .../dataflow/sdk/transforms/CombineFns.java | 22 +++++++------- .../sdk/transforms/CombineWithContext.java | 22 +++++++------- .../cloud/dataflow/sdk/transforms/Count.java | 23 ++++++++------- .../cloud/dataflow/sdk/transforms/Create.java | 23 ++++++++------- .../cloud/dataflow/sdk/transforms/DoFn.java | 23 ++++++++------- .../dataflow/sdk/transforms/DoFnReflector.java | 23 ++++++++------- .../dataflow/sdk/transforms/DoFnTester.java | 23 ++++++++------- .../sdk/transforms/DoFnWithContext.java | 23 ++++++++------- .../cloud/dataflow/sdk/transforms/Filter.java | 23 ++++++++------- .../sdk/transforms/FlatMapElements.java | 23 ++++++++------- .../cloud/dataflow/sdk/transforms/Flatten.java | 23 ++++++++------- .../dataflow/sdk/transforms/GroupByKey.java | 23 ++++++++------- .../transforms/IntraBundleParallelization.java | 23 ++++++++------- .../cloud/dataflow/sdk/transforms/Keys.java | 23 ++++++++------- .../cloud/dataflow/sdk/transforms/KvSwap.java | 23 ++++++++------- .../dataflow/sdk/transforms/MapElements.java | 23 ++++++++------- .../cloud/dataflow/sdk/transforms/Max.java | 23 ++++++++------- .../cloud/dataflow/sdk/transforms/Mean.java | 23 ++++++++------- .../cloud/dataflow/sdk/transforms/Min.java | 23 ++++++++------- .../dataflow/sdk/transforms/PTransform.java | 23 ++++++++------- .../cloud/dataflow/sdk/transforms/ParDo.java | 23 ++++++++------- .../dataflow/sdk/transforms/Partition.java | 23 ++++++++------- .../sdk/transforms/RemoveDuplicates.java | 23 ++++++++------- .../cloud/dataflow/sdk/transforms/Sample.java | 23 ++++++++------- .../sdk/transforms/SerializableComparator.java | 23 ++++++++------- .../sdk/transforms/SerializableFunction.java | 23 ++++++++------- .../dataflow/sdk/transforms/SimpleFunction.java | 23 ++++++++------- .../cloud/dataflow/sdk/transforms/Sum.java | 23 ++++++++------- .../cloud/dataflow/sdk/transforms/Top.java | 23 ++++++++------- .../cloud/dataflow/sdk/transforms/Values.java | 23 ++++++++------- .../cloud/dataflow/sdk/transforms/View.java | 23 ++++++++------- .../cloud/dataflow/sdk/transforms/WithKeys.java | 23 ++++++++------- .../dataflow/sdk/transforms/WithTimestamps.java | 23 ++++++++------- .../cloud/dataflow/sdk/transforms/Write.java | 23 ++++++++------- .../sdk/transforms/display/DisplayData.java | 23 ++++++++------- .../sdk/transforms/display/HasDisplayData.java | 23 ++++++++------- .../sdk/transforms/join/CoGbkResult.java | 23 ++++++++------- .../sdk/transforms/join/CoGbkResultSchema.java | 23 ++++++++------- .../sdk/transforms/join/CoGroupByKey.java | 23 ++++++++------- .../transforms/join/KeyedPCollectionTuple.java | 23 ++++++++------- .../sdk/transforms/join/RawUnionValue.java | 23 ++++++++------- .../sdk/transforms/join/UnionCoder.java | 23 ++++++++------- .../sdk/transforms/join/package-info.java | 23 ++++++++------- .../dataflow/sdk/transforms/package-info.java | 23 ++++++++------- .../sdk/transforms/windowing/AfterAll.java | 23 ++++++++------- .../windowing/AfterDelayFromFirstElement.java | 23 ++++++++------- .../sdk/transforms/windowing/AfterEach.java | 23 ++++++++------- .../sdk/transforms/windowing/AfterFirst.java | 23 ++++++++------- .../sdk/transforms/windowing/AfterPane.java | 23 ++++++++------- .../windowing/AfterProcessingTime.java | 23 ++++++++------- .../AfterSynchronizedProcessingTime.java | 22 +++++++------- .../transforms/windowing/AfterWatermark.java | 23 ++++++++------- .../sdk/transforms/windowing/BoundedWindow.java | 23 ++++++++------- .../transforms/windowing/CalendarWindows.java | 23 ++++++++------- .../transforms/windowing/DefaultTrigger.java | 23 ++++++++------- .../sdk/transforms/windowing/FixedWindows.java | 23 ++++++++------- .../sdk/transforms/windowing/GlobalWindow.java | 23 ++++++++------- .../sdk/transforms/windowing/GlobalWindows.java | 23 ++++++++------- .../transforms/windowing/IntervalWindow.java | 23 ++++++++------- .../transforms/windowing/InvalidWindows.java | 23 ++++++++------- .../MergeOverlappingIntervalWindows.java | 23 ++++++++------- .../windowing/NonMergingWindowFn.java | 23 ++++++++------- .../transforms/windowing/OrFinallyTrigger.java | 22 +++++++------- .../sdk/transforms/windowing/OutputTimeFn.java | 23 ++++++++------- .../sdk/transforms/windowing/OutputTimeFns.java | 23 ++++++++------- .../sdk/transforms/windowing/PaneInfo.java | 23 ++++++++------- .../windowing/PartitioningWindowFn.java | 23 ++++++++------- .../sdk/transforms/windowing/Repeatedly.java | 23 ++++++++------- .../sdk/transforms/windowing/Sessions.java | 23 ++++++++------- .../transforms/windowing/SlidingWindows.java | 23 ++++++++------- .../sdk/transforms/windowing/Trigger.java | 23 ++++++++------- .../transforms/windowing/TriggerBuilder.java | 22 +++++++------- .../sdk/transforms/windowing/Window.java | 23 ++++++++------- .../sdk/transforms/windowing/WindowFn.java | 23 ++++++++------- .../sdk/transforms/windowing/package-info.java | 23 ++++++++------- .../dataflow/sdk/util/ActiveWindowSet.java | 22 +++++++------- .../cloud/dataflow/sdk/util/ApiSurface.java | 23 ++++++++------- .../dataflow/sdk/util/AppEngineEnvironment.java | 23 ++++++++------- .../dataflow/sdk/util/AppliedCombineFn.java | 22 +++++++------- .../dataflow/sdk/util/AssignWindowsDoFn.java | 23 ++++++++------- ...AttemptAndTimeBoundedExponentialBackOff.java | 23 ++++++++------- .../util/AttemptBoundedExponentialBackOff.java | 23 ++++++++------- .../cloud/dataflow/sdk/util/AvroUtils.java | 23 ++++++++------- .../dataflow/sdk/util/BaseExecutionContext.java | 23 ++++++++------- .../dataflow/sdk/util/BatchTimerInternals.java | 23 ++++++++------- .../sdk/util/BigQueryTableInserter.java | 23 ++++++++------- .../sdk/util/BigQueryTableRowIterator.java | 23 ++++++++------- .../cloud/dataflow/sdk/util/BitSetCoder.java | 22 +++++++------- .../BufferedElementCountingOutputStream.java | 23 ++++++++------- .../cloud/dataflow/sdk/util/CloudKnownType.java | 23 ++++++++------- .../cloud/dataflow/sdk/util/CloudObject.java | 23 ++++++++------- .../cloud/dataflow/sdk/util/CoderUtils.java | 23 ++++++++------- .../sdk/util/CombineContextFactory.java | 22 +++++++------- .../cloud/dataflow/sdk/util/CombineFnUtil.java | 22 +++++++------- .../dataflow/sdk/util/CounterAggregator.java | 27 +++++++++-------- .../dataflow/sdk/util/CredentialFactory.java | 23 ++++++++------- .../cloud/dataflow/sdk/util/Credentials.java | 23 ++++++++------- .../sdk/util/DataflowPathValidator.java | 23 ++++++++------- .../dataflow/sdk/util/DataflowReleaseInfo.java | 23 ++++++++------- .../sdk/util/DirectModeExecutionContext.java | 23 ++++++++------- .../sdk/util/DirectSideInputReader.java | 23 ++++++++------- .../cloud/dataflow/sdk/util/DoFnInfo.java | 23 ++++++++------- .../cloud/dataflow/sdk/util/DoFnRunner.java | 22 +++++++------- .../cloud/dataflow/sdk/util/DoFnRunnerBase.java | 23 ++++++++------- .../cloud/dataflow/sdk/util/DoFnRunners.java | 22 +++++++------- .../dataflow/sdk/util/ExecutableTrigger.java | 23 ++++++++------- .../dataflow/sdk/util/ExecutionContext.java | 23 ++++++++------- .../sdk/util/ExposedByteArrayInputStream.java | 23 ++++++++------- .../sdk/util/ExposedByteArrayOutputStream.java | 23 ++++++++------- .../dataflow/sdk/util/FileIOChannelFactory.java | 23 ++++++++------- .../dataflow/sdk/util/FinishedTriggers.java | 22 +++++++------- .../sdk/util/FinishedTriggersBitSet.java | 23 ++++++++------- .../dataflow/sdk/util/FinishedTriggersSet.java | 23 ++++++++------- .../dataflow/sdk/util/GcpCredentialFactory.java | 23 ++++++++------- .../dataflow/sdk/util/GcsIOChannelFactory.java | 23 ++++++++------- .../cloud/dataflow/sdk/util/GcsStager.java | 23 ++++++++------- .../google/cloud/dataflow/sdk/util/GcsUtil.java | 27 +++++++++-------- .../util/GroupAlsoByWindowViaWindowSetDoFn.java | 22 +++++++------- .../sdk/util/GroupAlsoByWindowsDoFn.java | 23 ++++++++------- .../GroupAlsoByWindowsViaOutputBufferDoFn.java | 23 ++++++++------- .../dataflow/sdk/util/IOChannelFactory.java | 23 ++++++++------- .../cloud/dataflow/sdk/util/IOChannelUtils.java | 23 ++++++++------- .../sdk/util/IllegalMutationException.java | 23 ++++++++------- .../dataflow/sdk/util/InstanceBuilder.java | 23 ++++++++------- .../util/IntervalBoundedExponentialBackOff.java | 23 ++++++++------- .../cloud/dataflow/sdk/util/KeyedWorkItem.java | 22 +++++++------- .../dataflow/sdk/util/KeyedWorkItemCoder.java | 22 +++++++------- .../cloud/dataflow/sdk/util/KeyedWorkItems.java | 22 +++++++------- .../sdk/util/LateDataDroppingDoFnRunner.java | 22 +++++++------- .../dataflow/sdk/util/MapAggregatorValues.java | 23 ++++++++------- .../sdk/util/MergingActiveWindowSet.java | 22 +++++++------- .../cloud/dataflow/sdk/util/MimeTypes.java | 23 ++++++++------- .../cloud/dataflow/sdk/util/MonitoringUtil.java | 22 +++++++------- .../dataflow/sdk/util/MutationDetector.java | 23 ++++++++------- .../dataflow/sdk/util/MutationDetectors.java | 23 ++++++++------- .../cloud/dataflow/sdk/util/NonEmptyPanes.java | 22 +++++++------- .../sdk/util/NonMergingActiveWindowSet.java | 22 +++++++------- .../sdk/util/NoopCredentialFactory.java | 23 ++++++++------- .../dataflow/sdk/util/NoopPathValidator.java | 23 ++++++++------- .../dataflow/sdk/util/NullSideInputReader.java | 23 ++++++++------- .../dataflow/sdk/util/OutputReference.java | 23 ++++++++------- .../sdk/util/PCollectionViewWindow.java | 23 ++++++++------- .../dataflow/sdk/util/PCollectionViews.java | 23 ++++++++------- .../google/cloud/dataflow/sdk/util/PTuple.java | 23 ++++++++------- .../cloud/dataflow/sdk/util/PackageUtil.java | 23 ++++++++------- .../dataflow/sdk/util/PaneInfoTracker.java | 22 +++++++------- .../cloud/dataflow/sdk/util/PathValidator.java | 23 ++++++++------- .../sdk/util/PerKeyCombineFnRunner.java | 22 +++++++------- .../sdk/util/PerKeyCombineFnRunners.java | 22 +++++++------- .../cloud/dataflow/sdk/util/PropertyNames.java | 23 ++++++++------- .../dataflow/sdk/util/RandomAccessData.java | 22 +++++++------- .../cloud/dataflow/sdk/util/ReduceFn.java | 22 +++++++------- .../sdk/util/ReduceFnContextFactory.java | 22 +++++++------- .../cloud/dataflow/sdk/util/ReduceFnRunner.java | 22 +++++++------- .../sdk/util/ReifyTimestampAndWindowsDoFn.java | 27 +++++++++-------- .../cloud/dataflow/sdk/util/Reshuffle.java | 22 +++++++------- .../dataflow/sdk/util/ReshuffleTrigger.java | 22 +++++++------- .../sdk/util/RetryHttpRequestInitializer.java | 23 ++++++++------- .../dataflow/sdk/util/SerializableUtils.java | 23 ++++++++------- .../cloud/dataflow/sdk/util/Serializer.java | 23 ++++++++------- .../sdk/util/ShardingWritableByteChannel.java | 23 ++++++++------- .../dataflow/sdk/util/SideInputReader.java | 23 ++++++++------- .../dataflow/sdk/util/SimpleDoFnRunner.java | 22 +++++++------- .../google/cloud/dataflow/sdk/util/Stager.java | 23 ++++++++------- .../cloud/dataflow/sdk/util/StreamUtils.java | 23 ++++++++------- .../cloud/dataflow/sdk/util/StringUtils.java | 23 ++++++++------- .../google/cloud/dataflow/sdk/util/Structs.java | 23 ++++++++------- .../dataflow/sdk/util/SystemDoFnInternal.java | 22 +++++++------- .../cloud/dataflow/sdk/util/SystemReduceFn.java | 22 +++++++------- .../cloud/dataflow/sdk/util/TestCredential.java | 23 ++++++++------- .../cloud/dataflow/sdk/util/TimeDomain.java | 22 +++++++------- .../cloud/dataflow/sdk/util/TimeUtil.java | 22 +++++++------- .../cloud/dataflow/sdk/util/TimerInternals.java | 23 ++++++++------- .../google/cloud/dataflow/sdk/util/Timers.java | 23 ++++++++------- .../cloud/dataflow/sdk/util/Transport.java | 27 +++++++++-------- .../sdk/util/TriggerContextFactory.java | 22 +++++++------- .../cloud/dataflow/sdk/util/TriggerRunner.java | 22 +++++++------- .../dataflow/sdk/util/UnownedInputStream.java | 23 ++++++++------- .../dataflow/sdk/util/UnownedOutputStream.java | 23 ++++++++------- .../sdk/util/UploadIdResponseInterceptor.java | 23 ++++++++------- .../dataflow/sdk/util/UserCodeException.java | 23 ++++++++------- .../dataflow/sdk/util/ValueWithRecordId.java | 27 +++++++++-------- .../google/cloud/dataflow/sdk/util/Values.java | 23 ++++++++------- .../google/cloud/dataflow/sdk/util/VarInt.java | 23 ++++++++------- .../cloud/dataflow/sdk/util/WatermarkHold.java | 22 +++++++------- .../cloud/dataflow/sdk/util/Weighted.java | 23 ++++++++------- .../cloud/dataflow/sdk/util/WeightedValue.java | 23 ++++++++------- .../cloud/dataflow/sdk/util/WindowTracing.java | 23 ++++++++------- .../cloud/dataflow/sdk/util/WindowedValue.java | 27 +++++++++-------- .../dataflow/sdk/util/WindowingInternals.java | 23 ++++++++------- .../dataflow/sdk/util/WindowingStrategy.java | 23 ++++++++------- .../cloud/dataflow/sdk/util/ZipFiles.java | 23 ++++++++------- .../cloud/dataflow/sdk/util/common/Counter.java | 27 +++++++++-------- .../sdk/util/common/CounterProvider.java | 23 ++++++++------- .../dataflow/sdk/util/common/CounterSet.java | 27 +++++++++-------- .../util/common/ElementByteSizeObservable.java | 23 ++++++++------- .../ElementByteSizeObservableIterable.java | 27 +++++++++-------- .../ElementByteSizeObservableIterator.java | 27 +++++++++-------- .../util/common/ElementByteSizeObserver.java | 27 +++++++++-------- .../sdk/util/common/PeekingReiterator.java | 27 +++++++++-------- .../sdk/util/common/ReflectHelpers.java | 22 +++++++------- .../dataflow/sdk/util/common/Reiterable.java | 27 +++++++++-------- .../dataflow/sdk/util/common/Reiterator.java | 27 +++++++++-------- .../dataflow/sdk/util/common/package-info.java | 23 ++++++++------- .../sdk/util/common/worker/StateSampler.java | 27 +++++++++-------- .../sdk/util/common/worker/package-info.java | 23 ++++++++------- .../cloud/dataflow/sdk/util/gcsfs/GcsPath.java | 23 ++++++++------- .../dataflow/sdk/util/gcsfs/package-info.java | 23 ++++++++------- .../cloud/dataflow/sdk/util/package-info.java | 23 ++++++++------- .../util/state/AccumulatorCombiningState.java | 22 +++++++------- .../cloud/dataflow/sdk/util/state/BagState.java | 22 +++++++------- .../dataflow/sdk/util/state/CombiningState.java | 22 +++++++------- .../CopyOnAccessInMemoryStateInternals.java | 22 +++++++------- .../sdk/util/state/InMemoryStateInternals.java | 22 +++++++------- .../sdk/util/state/MergingStateAccessor.java | 23 ++++++++------- .../dataflow/sdk/util/state/ReadableState.java | 22 +++++++------- .../cloud/dataflow/sdk/util/state/State.java | 22 +++++++------- .../dataflow/sdk/util/state/StateAccessor.java | 23 ++++++++------- .../dataflow/sdk/util/state/StateContext.java | 22 +++++++------- .../dataflow/sdk/util/state/StateContexts.java | 22 +++++++------- .../dataflow/sdk/util/state/StateInternals.java | 22 +++++++------- .../dataflow/sdk/util/state/StateMerging.java | 22 +++++++------- .../dataflow/sdk/util/state/StateNamespace.java | 22 +++++++------- .../sdk/util/state/StateNamespaceForTest.java | 22 +++++++------- .../sdk/util/state/StateNamespaces.java | 22 +++++++------- .../dataflow/sdk/util/state/StateTable.java | 22 +++++++------- .../cloud/dataflow/sdk/util/state/StateTag.java | 22 +++++++------- .../dataflow/sdk/util/state/StateTags.java | 22 +++++++------- .../dataflow/sdk/util/state/ValueState.java | 22 +++++++------- .../sdk/util/state/WatermarkHoldState.java | 22 +++++++------- .../google/cloud/dataflow/sdk/values/KV.java | 23 ++++++++------- .../cloud/dataflow/sdk/values/PBegin.java | 23 ++++++++------- .../cloud/dataflow/sdk/values/PCollection.java | 23 ++++++++------- .../dataflow/sdk/values/PCollectionList.java | 23 ++++++++------- .../dataflow/sdk/values/PCollectionTuple.java | 23 ++++++++------- .../dataflow/sdk/values/PCollectionView.java | 23 ++++++++------- .../google/cloud/dataflow/sdk/values/PDone.java | 23 ++++++++------- .../cloud/dataflow/sdk/values/PInput.java | 23 ++++++++------- .../cloud/dataflow/sdk/values/POutput.java | 23 ++++++++------- .../dataflow/sdk/values/POutputValueBase.java | 23 ++++++++------- .../cloud/dataflow/sdk/values/PValue.java | 23 ++++++++------- .../cloud/dataflow/sdk/values/PValueBase.java | 23 ++++++++------- .../dataflow/sdk/values/TimestampedValue.java | 23 ++++++++------- .../cloud/dataflow/sdk/values/TupleTag.java | 23 ++++++++------- .../cloud/dataflow/sdk/values/TupleTagList.java | 23 ++++++++------- .../dataflow/sdk/values/TypeDescriptor.java | 23 ++++++++------- .../cloud/dataflow/sdk/values/TypedPValue.java | 23 ++++++++------- .../cloud/dataflow/sdk/values/package-info.java | 23 ++++++++------- .../main/proto/proto2_coder_test_messages.proto | 22 +++++++------- .../cloud/dataflow/sdk/DataflowMatchers.java | 23 ++++++++------- .../google/cloud/dataflow/sdk/PipelineTest.java | 23 ++++++++------- .../google/cloud/dataflow/sdk/TestUtils.java | 23 ++++++++------- .../cloud/dataflow/sdk/WindowMatchers.java | 23 ++++++++------- .../dataflow/sdk/coders/AvroCoderTest.java | 23 ++++++++------- .../sdk/coders/BigEndianIntegerCoderTest.java | 23 ++++++++------- .../sdk/coders/BigEndianLongCoderTest.java | 23 ++++++++------- .../dataflow/sdk/coders/ByteArrayCoderTest.java | 23 ++++++++------- .../dataflow/sdk/coders/ByteCoderTest.java | 23 ++++++++------- .../sdk/coders/ByteStringCoderTest.java | 23 ++++++++------- .../dataflow/sdk/coders/CoderFactoriesTest.java | 23 ++++++++------- .../dataflow/sdk/coders/CoderProvidersTest.java | 23 ++++++++------- .../dataflow/sdk/coders/CoderRegistryTest.java | 23 ++++++++------- .../cloud/dataflow/sdk/coders/CoderTest.java | 22 +++++++------- .../sdk/coders/CollectionCoderTest.java | 23 ++++++++------- .../dataflow/sdk/coders/CustomCoderTest.java | 23 ++++++++------- .../dataflow/sdk/coders/DefaultCoderTest.java | 23 ++++++++------- .../dataflow/sdk/coders/DelegateCoderTest.java | 23 ++++++++------- .../dataflow/sdk/coders/DoubleCoderTest.java | 23 ++++++++------- .../dataflow/sdk/coders/DurationCoderTest.java | 23 ++++++++------- .../dataflow/sdk/coders/EntityCoderTest.java | 23 ++++++++------- .../dataflow/sdk/coders/InstantCoderTest.java | 23 ++++++++------- .../dataflow/sdk/coders/IterableCoderTest.java | 23 ++++++++------- .../dataflow/sdk/coders/JAXBCoderTest.java | 23 ++++++++------- .../cloud/dataflow/sdk/coders/KvCoderTest.java | 23 ++++++++------- .../dataflow/sdk/coders/ListCoderTest.java | 23 ++++++++------- .../cloud/dataflow/sdk/coders/MapCoderTest.java | 23 ++++++++------- .../dataflow/sdk/coders/NullableCoderTest.java | 23 ++++++++------- .../sdk/coders/PrintBase64Encodings.java | 23 ++++++++------- .../dataflow/sdk/coders/Proto2CoderTest.java | 23 ++++++++------- .../sdk/coders/SerializableCoderTest.java | 23 ++++++++------- .../cloud/dataflow/sdk/coders/SetCoderTest.java | 23 ++++++++------- .../dataflow/sdk/coders/StandardCoderTest.java | 23 ++++++++------- .../sdk/coders/StringDelegateCoderTest.java | 23 ++++++++------- .../sdk/coders/StringUtf8CoderTest.java | 23 ++++++++------- .../sdk/coders/StructuralByteArrayTest.java | 22 +++++++------- .../sdk/coders/TableRowJsonCoderTest.java | 23 ++++++++------- .../sdk/coders/TextualIntegerCoderTest.java | 23 ++++++++------- .../dataflow/sdk/coders/VarIntCoderTest.java | 23 ++++++++------- .../dataflow/sdk/coders/VarLongCoderTest.java | 23 ++++++++------- .../sdk/coders/protobuf/ProtoCoderTest.java | 23 ++++++++------- .../sdk/coders/protobuf/ProtobufUtilTest.java | 23 ++++++++------- .../sdk/io/AvroIOGeneratedClassTest.java | 23 ++++++++------- .../cloud/dataflow/sdk/io/AvroIOTest.java | 23 ++++++++------- .../cloud/dataflow/sdk/io/AvroSourceTest.java | 23 ++++++++------- .../cloud/dataflow/sdk/io/BigQueryIOTest.java | 23 ++++++++------- .../io/BoundedReadFromUnboundedSourceTest.java | 23 ++++++++------- .../dataflow/sdk/io/CompressedSourceTest.java | 23 ++++++++------- .../dataflow/sdk/io/CountingInputTest.java | 23 ++++++++------- .../dataflow/sdk/io/CountingSourceTest.java | 23 ++++++++------- .../cloud/dataflow/sdk/io/DatastoreIOTest.java | 23 ++++++++------- .../dataflow/sdk/io/FileBasedSinkTest.java | 23 ++++++++------- .../dataflow/sdk/io/FileBasedSourceTest.java | 23 ++++++++------- .../dataflow/sdk/io/OffsetBasedSourceTest.java | 23 ++++++++------- .../cloud/dataflow/sdk/io/PubsubIOTest.java | 23 ++++++++------- .../google/cloud/dataflow/sdk/io/ReadTest.java | 23 ++++++++------- .../cloud/dataflow/sdk/io/TextIOTest.java | 23 ++++++++------- .../google/cloud/dataflow/sdk/io/WriteTest.java | 23 ++++++++------- .../cloud/dataflow/sdk/io/XmlSinkTest.java | 23 ++++++++------- .../cloud/dataflow/sdk/io/XmlSourceTest.java | 23 ++++++++------- .../sdk/io/bigtable/BigtableIOTest.java | 23 ++++++++------- .../range/ByteKeyRangeEstimateFractionTest.java | 23 ++++++++------- .../range/ByteKeyRangeInterpolateKeyTest.java | 23 ++++++++------- .../dataflow/sdk/io/range/ByteKeyRangeTest.java | 23 ++++++++------- .../sdk/io/range/ByteKeyRangeTrackerTest.java | 22 +++++++------- .../dataflow/sdk/io/range/ByteKeyTest.java | 23 ++++++++------- .../sdk/io/range/OffsetRangeTrackerTest.java | 27 +++++++++-------- .../DataflowPipelineDebugOptionsTest.java | 23 ++++++++------- .../options/DataflowPipelineOptionsTest.java | 23 ++++++++------- .../options/DataflowProfilingOptionsTest.java | 22 +++++++------- .../DataflowWorkerLoggingOptionsTest.java | 22 +++++++------- .../dataflow/sdk/options/GcpOptionsTest.java | 22 +++++++------- .../sdk/options/GoogleApiDebugOptionsTest.java | 23 ++++++++------- .../sdk/options/PipelineOptionsFactoryTest.java | 23 ++++++++------- .../sdk/options/PipelineOptionsTest.java | 23 ++++++++------- .../options/PipelineOptionsValidatorTest.java | 23 ++++++++------- .../sdk/options/ProxyInvocationHandlerTest.java | 23 ++++++++------- .../AggregatorPipelineExtractorTest.java | 23 ++++++++------- .../BlockingDataflowPipelineRunnerTest.java | 23 ++++++++------- .../sdk/runners/DataflowPipelineJobTest.java | 22 +++++++------- .../runners/DataflowPipelineRegistrarTest.java | 23 ++++++++------- .../sdk/runners/DataflowPipelineRunnerTest.java | 23 ++++++++------- .../sdk/runners/DataflowPipelineTest.java | 23 ++++++++------- .../runners/DataflowPipelineTranslatorTest.java | 23 ++++++++------- .../runners/DirectPipelineRegistrarTest.java | 23 ++++++++------- .../sdk/runners/DirectPipelineRunnerTest.java | 23 ++++++++------- .../sdk/runners/DirectPipelineTest.java | 23 ++++++++------- .../sdk/runners/PipelineRunnerTest.java | 23 ++++++++------- .../dataflow/sdk/runners/TransformTreeTest.java | 23 ++++++++------- .../sdk/runners/dataflow/CustomSourcesTest.java | 23 ++++++++------- .../runners/dataflow/TestCountingSource.java | 23 ++++++++------- .../BoundedReadEvaluatorFactoryTest.java | 22 +++++++------- .../ConsumerTrackingPipelineVisitorTest.java | 22 +++++++------- .../EncodabilityEnforcementFactoryTest.java | 22 +++++++------- .../inprocess/FlattenEvaluatorFactoryTest.java | 22 +++++++------- .../inprocess/ForwardingPTransformTest.java | 22 +++++++------- .../GroupByKeyEvaluatorFactoryTest.java | 22 +++++++------- .../ImmutabilityEnforcementFactoryTest.java | 22 +++++++------- .../inprocess/InMemoryWatermarkManagerTest.java | 22 +++++++------- .../runners/inprocess/InProcessBundleTest.java | 22 +++++++------- .../runners/inprocess/InProcessCreateTest.java | 22 +++++++------- .../InProcessEvaluationContextTest.java | 22 +++++++------- .../inprocess/InProcessPipelineRunnerTest.java | 22 +++++++------- .../InProcessSideInputContainerTest.java | 22 +++++++------- .../inprocess/InProcessTimerInternalsTest.java | 22 +++++++------- .../KeyedPValueTrackingVisitorTest.java | 22 +++++++------- .../sdk/runners/inprocess/MockClock.java | 22 +++++++------- .../ParDoMultiEvaluatorFactoryTest.java | 22 +++++++------- .../ParDoSingleEvaluatorFactoryTest.java | 22 +++++++------- .../TransformExecutorServicesTest.java | 22 +++++++------- .../inprocess/TransformExecutorTest.java | 22 +++++++------- .../UnboundedReadEvaluatorFactoryTest.java | 22 +++++++------- .../inprocess/ViewEvaluatorFactoryTest.java | 22 +++++++------- .../WatermarkCallbackExecutorTest.java | 22 +++++++------- .../sdk/testing/CoderPropertiesTest.java | 23 ++++++++------- .../sdk/testing/DataflowAssertTest.java | 23 ++++++++------- .../sdk/testing/DataflowJUnitTestRunner.java | 23 ++++++++------- .../dataflow/sdk/testing/ExpectedLogs.java | 23 ++++++++------- .../dataflow/sdk/testing/ExpectedLogsTest.java | 23 ++++++++------- .../sdk/testing/FastNanoClockAndSleeper.java | 23 ++++++++------- .../testing/FastNanoClockAndSleeperTest.java | 23 ++++++++------- .../sdk/testing/PCollectionViewTesting.java | 23 ++++++++------- .../sdk/testing/ResetDateTimeProvider.java | 23 ++++++++------- .../sdk/testing/ResetDateTimeProviderTest.java | 23 ++++++++------- .../sdk/testing/RestoreSystemProperties.java | 23 ++++++++------- .../testing/RestoreSystemPropertiesTest.java | 23 ++++++++------- .../sdk/testing/SerializableMatchersTest.java | 23 ++++++++------- .../sdk/testing/SystemNanoTimeSleeper.java | 23 ++++++++------- .../sdk/testing/SystemNanoTimeSleeperTest.java | 23 ++++++++------- .../testing/TestDataflowPipelineRunnerTest.java | 23 ++++++++------- .../dataflow/sdk/testing/TestPipelineTest.java | 23 ++++++++------- .../transforms/ApproximateQuantilesTest.java | 23 ++++++++------- .../sdk/transforms/ApproximateUniqueTest.java | 23 ++++++++------- .../dataflow/sdk/transforms/CombineFnsTest.java | 22 +++++++------- .../dataflow/sdk/transforms/CombineTest.java | 23 ++++++++------- .../dataflow/sdk/transforms/CountTest.java | 23 ++++++++------- .../dataflow/sdk/transforms/CreateTest.java | 23 ++++++++------- .../sdk/transforms/DoFnContextTest.java | 23 ++++++++------- .../DoFnDelegatingAggregatorTest.java | 23 ++++++++------- .../sdk/transforms/DoFnReflectorTest.java | 23 ++++++++------- .../cloud/dataflow/sdk/transforms/DoFnTest.java | 23 ++++++++------- .../dataflow/sdk/transforms/DoFnTesterTest.java | 22 +++++++------- .../sdk/transforms/DoFnWithContextTest.java | 23 ++++++++------- .../dataflow/sdk/transforms/FilterTest.java | 23 ++++++++------- .../sdk/transforms/FlatMapElementsTest.java | 23 ++++++++------- .../dataflow/sdk/transforms/FlattenTest.java | 23 ++++++++------- .../dataflow/sdk/transforms/GroupByKeyTest.java | 23 ++++++++------- .../IntraBundleParallelizationTest.java | 23 ++++++++------- .../cloud/dataflow/sdk/transforms/KeysTest.java | 23 ++++++++------- .../dataflow/sdk/transforms/KvSwapTest.java | 23 ++++++++------- .../sdk/transforms/MapElementsTest.java | 23 ++++++++------- .../cloud/dataflow/sdk/transforms/MaxTest.java | 23 ++++++++------- .../cloud/dataflow/sdk/transforms/MeanTest.java | 23 ++++++++------- .../cloud/dataflow/sdk/transforms/MinTest.java | 23 ++++++++------- .../cloud/dataflow/sdk/transforms/NoOpDoFn.java | 23 ++++++++------- .../dataflow/sdk/transforms/PTransformTest.java | 23 ++++++++------- .../dataflow/sdk/transforms/ParDoTest.java | 23 ++++++++------- .../dataflow/sdk/transforms/PartitionTest.java | 23 ++++++++------- .../sdk/transforms/RemoveDuplicatesTest.java | 23 ++++++++------- .../dataflow/sdk/transforms/SampleTest.java | 23 ++++++++------- .../sdk/transforms/SimpleStatsFnsTest.java | 23 ++++++++------- .../cloud/dataflow/sdk/transforms/SumTest.java | 22 +++++++------- .../cloud/dataflow/sdk/transforms/TopTest.java | 23 ++++++++------- .../dataflow/sdk/transforms/ValuesTest.java | 23 ++++++++------- .../cloud/dataflow/sdk/transforms/ViewTest.java | 23 ++++++++------- .../dataflow/sdk/transforms/WithKeysTest.java | 23 ++++++++------- .../sdk/transforms/WithTimestampsTest.java | 22 +++++++------- .../transforms/display/DisplayDataMatchers.java | 23 ++++++++------- .../display/DisplayDataMatchersTest.java | 23 ++++++++------- .../sdk/transforms/display/DisplayDataTest.java | 23 ++++++++------- .../transforms/join/CoGbkResultCoderTest.java | 23 ++++++++------- .../sdk/transforms/join/CoGbkResultTest.java | 23 ++++++++------- .../sdk/transforms/join/CoGroupByKeyTest.java | 23 ++++++++------- .../sdk/transforms/join/UnionCoderTest.java | 23 ++++++++------- .../sdk/transforms/windowing/AfterAllTest.java | 23 ++++++++------- .../sdk/transforms/windowing/AfterEachTest.java | 23 ++++++++------- .../transforms/windowing/AfterFirstTest.java | 23 ++++++++------- .../sdk/transforms/windowing/AfterPaneTest.java | 23 ++++++++------- .../windowing/AfterProcessingTimeTest.java | 23 ++++++++------- .../AfterSynchronizedProcessingTimeTest.java | 22 +++++++------- .../windowing/AfterWatermarkTest.java | 23 ++++++++------- .../windowing/CalendarWindowsTest.java | 23 ++++++++------- .../windowing/DefaultTriggerTest.java | 23 ++++++++------- .../transforms/windowing/FixedWindowsTest.java | 23 ++++++++------- .../windowing/IntervalWindowTest.java | 23 ++++++++------- .../windowing/OrFinallyTriggerTest.java | 23 ++++++++------- .../sdk/transforms/windowing/PaneInfoTest.java | 22 +++++++------- .../transforms/windowing/RepeatedlyTest.java | 23 ++++++++------- .../sdk/transforms/windowing/SessionsTest.java | 23 ++++++++------- .../windowing/SlidingWindowsTest.java | 23 ++++++++------- .../sdk/transforms/windowing/TriggerTest.java | 22 +++++++------- .../sdk/transforms/windowing/WindowTest.java | 23 ++++++++------- .../sdk/transforms/windowing/WindowingTest.java | 23 ++++++++------- .../cloud/dataflow/sdk/util/ApiSurfaceTest.java | 23 ++++++++------- ...mptAndTimeBoundedExponentialBackOffTest.java | 23 ++++++++------- .../AttemptBoundedExponentialBackOffTest.java | 23 ++++++++------- .../cloud/dataflow/sdk/util/AvroUtilsTest.java | 23 ++++++++------- .../sdk/util/BatchTimerInternalsTest.java | 22 +++++++------- .../sdk/util/BigQueryTableInserterTest.java | 23 ++++++++------- .../sdk/util/BigQueryTableRowIteratorTest.java | 23 ++++++++------- .../dataflow/sdk/util/BigQueryUtilTest.java | 23 ++++++++------- ...BufferedElementCountingOutputStreamTest.java | 23 ++++++++------- .../cloud/dataflow/sdk/util/CoderUtilsTest.java | 23 ++++++++------- .../dataflow/sdk/util/CombineFnUtilTest.java | 22 +++++++------- .../sdk/util/CounterAggregatorTest.java | 27 +++++++++-------- .../sdk/util/DataflowPathValidatorTest.java | 23 ++++++++------- .../sdk/util/ExecutableTriggerTest.java | 23 ++++++++------- .../util/ExposedByteArrayInputStreamTest.java | 22 +++++++------- .../util/ExposedByteArrayOutputStreamTest.java | 22 +++++++------- .../sdk/util/FileIOChannelFactoryTest.java | 23 ++++++++------- .../sdk/util/FinishedTriggersBitSetTest.java | 23 ++++++++------- .../sdk/util/FinishedTriggersProperties.java | 23 ++++++++------- .../sdk/util/FinishedTriggersSetTest.java | 23 ++++++++------- .../sdk/util/GcsIOChannelFactoryTest.java | 23 ++++++++------- .../cloud/dataflow/sdk/util/GcsUtilTest.java | 23 ++++++++------- .../sdk/util/GroupAlsoByWindowsProperties.java | 23 ++++++++------- ...oupAlsoByWindowsViaOutputBufferDoFnTest.java | 23 ++++++++------- .../dataflow/sdk/util/IOChannelUtilsTest.java | 23 ++++++++------- .../dataflow/sdk/util/InstanceBuilderTest.java | 23 ++++++++------- .../IntervalBoundedExponentialBackOffTest.java | 23 ++++++++------- .../sdk/util/KeyedWorkItemCoderTest.java | 22 +++++++------- .../util/LateDataDroppingDoFnRunnerTest.java | 22 +++++++------- .../sdk/util/MergingActiveWindowSetTest.java | 23 ++++++++------- .../dataflow/sdk/util/MonitoringUtilTest.java | 22 +++++++------- .../sdk/util/MutationDetectorsTest.java | 23 ++++++++------- .../cloud/dataflow/sdk/util/PTupleTest.java | 23 ++++++++------- .../dataflow/sdk/util/PackageUtilTest.java | 23 ++++++++------- .../dataflow/sdk/util/RandomAccessDataTest.java | 22 +++++++------- .../dataflow/sdk/util/ReduceFnRunnerTest.java | 23 ++++++++------- .../cloud/dataflow/sdk/util/ReduceFnTester.java | 23 ++++++++------- .../cloud/dataflow/sdk/util/ReshuffleTest.java | 23 ++++++++------- .../dataflow/sdk/util/ReshuffleTriggerTest.java | 22 +++++++------- .../util/RetryHttpRequestInitializerTest.java | 23 ++++++++------- .../sdk/util/SerializableUtilsTest.java | 23 ++++++++------- .../cloud/dataflow/sdk/util/SerializerTest.java | 23 ++++++++------- .../dataflow/sdk/util/SimpleDoFnRunnerTest.java | 23 ++++++++------- .../dataflow/sdk/util/StreamUtilsTest.java | 22 +++++++------- .../dataflow/sdk/util/StringUtilsTest.java | 23 ++++++++------- .../cloud/dataflow/sdk/util/StructsTest.java | 23 ++++++++------- .../cloud/dataflow/sdk/util/TimeUtilTest.java | 23 ++++++++------- .../dataflow/sdk/util/TimerInternalsTest.java | 22 +++++++------- .../cloud/dataflow/sdk/util/TriggerTester.java | 23 ++++++++------- .../sdk/util/UnownedInputStreamTest.java | 23 ++++++++------- .../sdk/util/UnownedOutputStreamTest.java | 23 ++++++++------- .../util/UploadIdResponseInterceptorTest.java | 22 +++++++------- .../sdk/util/UserCodeExceptionTest.java | 24 +++++++-------- .../cloud/dataflow/sdk/util/VarIntTest.java | 23 ++++++++------- .../dataflow/sdk/util/WindowedValueTest.java | 23 ++++++++------- .../cloud/dataflow/sdk/util/ZipFilesTest.java | 23 ++++++++------- .../sdk/util/common/CounterSetTest.java | 27 +++++++++-------- .../dataflow/sdk/util/common/CounterTest.java | 27 +++++++++-------- .../sdk/util/common/CounterTestUtils.java | 27 +++++++++-------- .../sdk/util/common/ReflectHelpersTest.java | 22 +++++++------- .../dataflow/sdk/util/gcsfs/GcsPathTest.java | 23 ++++++++------- .../CopyOnAccessInMemoryStateInternalsTest.java | 22 +++++++------- .../util/state/InMemoryStateInternalsTest.java | 22 +++++++------- .../sdk/util/state/StateNamespacesTest.java | 22 +++++++------- .../dataflow/sdk/util/state/StateTagTest.java | 22 +++++++------- .../cloud/dataflow/sdk/values/KVTest.java | 23 ++++++++------- .../sdk/values/PCollectionListTest.java | 23 ++++++++------- .../sdk/values/PCollectionTupleTest.java | 23 ++++++++------- .../cloud/dataflow/sdk/values/PDoneTest.java | 23 ++++++++------- .../cloud/dataflow/sdk/values/TupleTagTest.java | 23 ++++++++------- .../dataflow/sdk/values/TypeDescriptorTest.java | 23 ++++++++------- .../dataflow/sdk/values/TypedPValueTest.java | 23 ++++++++------- .../PipelineOptionsFactoryJava8Test.java | 22 +++++++------- .../sdk/transforms/CombineJava8Test.java | 23 ++++++++------- .../sdk/transforms/FilterJava8Test.java | 23 ++++++++------- .../transforms/FlatMapElementsJava8Test.java | 23 ++++++++------- .../sdk/transforms/MapElementsJava8Test.java | 23 ++++++++------- .../sdk/transforms/PartitionJava8Test.java | 23 ++++++++------- .../transforms/RemoveDuplicatesJava8Test.java | 22 +++++++------- .../sdk/transforms/WithKeysJava8Test.java | 22 +++++++------- .../sdk/transforms/WithTimestampsJava8Test.java | 22 +++++++------- .../main/resources/archetype-resources/pom.xml | 31 ++++++++++---------- .../src/main/java/DebuggingWordCount.java | 23 ++++++++------- .../src/main/java/MinimalWordCount.java | 23 ++++++++------- .../src/main/java/WindowedWordCount.java | 23 ++++++++------- .../src/main/java/WordCount.java | 23 ++++++++------- .../java/common/DataflowExampleOptions.java | 23 ++++++++------- .../main/java/common/DataflowExampleUtils.java | 23 ++++++++------- .../common/ExampleBigQueryTableOptions.java | 23 ++++++++------- .../java/common/ExamplePubsubTopicOptions.java | 23 ++++++++------- .../main/java/common/PubsubFileInjector.java | 23 ++++++++------- .../src/test/java/DebuggingWordCountTest.java | 23 ++++++++------- .../src/test/java/WordCountTest.java | 23 ++++++++------- .../src/main/java/StarterPipeline.java | 23 ++++++++------- .../src/main/java/it/pkg/StarterPipeline.java | 23 ++++++++------- 814 files changed, 9852 insertions(+), 8816 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/d59c8012/contrib/hadoop/pom.xml ---------------------------------------------------------------------- diff --git a/contrib/hadoop/pom.xml b/contrib/hadoop/pom.xml index 05212e4..cf88019 100644 --- a/contrib/hadoop/pom.xml +++ b/contrib/hadoop/pom.xml @@ -1,19 +1,20 @@ <?xml version="1.0" encoding="UTF-8"?> -<!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ - ~ Copyright (C) 2015 The Google Cloud Dataflow Hadoop Library Authors - ~ - ~ Licensed under the Apache License, Version 2.0 (the "License"); you may not - ~ use this file except in compliance with the License. You may obtain a copy of - ~ the License at - ~ - ~ http://www.apache.org/licenses/LICENSE-2.0 - ~ - ~ Unless required by applicable law or agreed to in writing, software - ~ distributed under the License is distributed on an "AS IS" BASIS, WITHOUT - ~ WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the - ~ License for the specific language governing permissions and limitations under - ~ the License. - ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~--> +<!-- + Licensed to the Apache Software Foundation (ASF) under one or more + contributor license agreements. See the NOTICE file distributed with + this work for additional information regarding copyright ownership. + The ASF licenses this file to You under the Apache License, Version 2.0 + (the "License"); you may not use this file except in compliance with + the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. +--> <project xmlns="http://maven.apache.org/POM/4.0.0"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd";> http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/d59c8012/contrib/hadoop/src/main/java/com/google/cloud/dataflow/contrib/hadoop/HadoopFileSource.java ---------------------------------------------------------------------- diff --git a/contrib/hadoop/src/main/java/com/google/cloud/dataflow/contrib/hadoop/HadoopFileSource.java b/contrib/hadoop/src/main/java/com/google/cloud/dataflow/contrib/hadoop/HadoopFileSource.java index f24c3b7..c8da9d2 100644 --- a/contrib/hadoop/src/main/java/com/google/cloud/dataflow/contrib/hadoop/HadoopFileSource.java +++ b/contrib/hadoop/src/main/java/com/google/cloud/dataflow/contrib/hadoop/HadoopFileSource.java @@ -1,19 +1,20 @@ /* - * Copyright (C) 2015 The Google Cloud Dataflow Hadoop Library Authors + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at * - * Licensed under the Apache License, Version 2.0 (the "License"); you may not - * use this file except in compliance with the License. You may obtain a copy of - * the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 + * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT - * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the - * License for the specific language governing permissions and limitations under - * the License. + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. */ - package com.google.cloud.dataflow.contrib.hadoop; import com.google.cloud.dataflow.sdk.coders.Coder; http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/d59c8012/contrib/hadoop/src/main/java/com/google/cloud/dataflow/contrib/hadoop/WritableCoder.java ---------------------------------------------------------------------- diff --git a/contrib/hadoop/src/main/java/com/google/cloud/dataflow/contrib/hadoop/WritableCoder.java b/contrib/hadoop/src/main/java/com/google/cloud/dataflow/contrib/hadoop/WritableCoder.java index 5dba58d..572c24b 100644 --- a/contrib/hadoop/src/main/java/com/google/cloud/dataflow/contrib/hadoop/WritableCoder.java +++ b/contrib/hadoop/src/main/java/com/google/cloud/dataflow/contrib/hadoop/WritableCoder.java @@ -1,19 +1,20 @@ /* - * Copyright (C) 2015 The Google Cloud Dataflow Hadoop Library Authors + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at * - * Licensed under the Apache License, Version 2.0 (the "License"); you may not - * use this file except in compliance with the License. You may obtain a copy of - * the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 + * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT - * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the - * License for the specific language governing permissions and limitations under - * the License. + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. */ - package com.google.cloud.dataflow.contrib.hadoop; import com.google.cloud.dataflow.sdk.coders.Coder; http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/d59c8012/contrib/hadoop/src/test/java/com/google/cloud/dataflow/contrib/hadoop/HadoopFileSourceTest.java ---------------------------------------------------------------------- diff --git a/contrib/hadoop/src/test/java/com/google/cloud/dataflow/contrib/hadoop/HadoopFileSourceTest.java b/contrib/hadoop/src/test/java/com/google/cloud/dataflow/contrib/hadoop/HadoopFileSourceTest.java index cef3c08..4aeb0f8 100644 --- a/contrib/hadoop/src/test/java/com/google/cloud/dataflow/contrib/hadoop/HadoopFileSourceTest.java +++ b/contrib/hadoop/src/test/java/com/google/cloud/dataflow/contrib/hadoop/HadoopFileSourceTest.java @@ -1,19 +1,20 @@ /* - * Copyright (C) 2015 The Google Cloud Dataflow Hadoop Library Authors + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at * - * Licensed under the Apache License, Version 2.0 (the "License"); you may not - * use this file except in compliance with the License. You may obtain a copy of - * the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 + * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT - * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the - * License for the specific language governing permissions and limitations under - * the License. + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. */ - package com.google.cloud.dataflow.contrib.hadoop; import static com.google.cloud.dataflow.sdk.testing.SourceTestUtils.readFromSource; http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/d59c8012/contrib/hadoop/src/test/java/com/google/cloud/dataflow/contrib/hadoop/WritableCoderTest.java ---------------------------------------------------------------------- diff --git a/contrib/hadoop/src/test/java/com/google/cloud/dataflow/contrib/hadoop/WritableCoderTest.java b/contrib/hadoop/src/test/java/com/google/cloud/dataflow/contrib/hadoop/WritableCoderTest.java index 8eeb5e5..fac3fe2 100644 --- a/contrib/hadoop/src/test/java/com/google/cloud/dataflow/contrib/hadoop/WritableCoderTest.java +++ b/contrib/hadoop/src/test/java/com/google/cloud/dataflow/contrib/hadoop/WritableCoderTest.java @@ -1,19 +1,20 @@ /* - * Copyright (C) 2015 The Google Cloud Dataflow Hadoop Library Authors + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at * - * Licensed under the Apache License, Version 2.0 (the "License"); you may not - * use this file except in compliance with the License. You may obtain a copy of - * the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 + * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT - * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the - * License for the specific language governing permissions and limitations under - * the License. + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. */ - package com.google.cloud.dataflow.contrib.hadoop; import com.google.cloud.dataflow.sdk.testing.CoderProperties; http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/d59c8012/contrib/join-library/src/main/java/com/google/cloud/dataflow/contrib/joinlibrary/Join.java ---------------------------------------------------------------------- diff --git a/contrib/join-library/src/main/java/com/google/cloud/dataflow/contrib/joinlibrary/Join.java b/contrib/join-library/src/main/java/com/google/cloud/dataflow/contrib/joinlibrary/Join.java index 81d8a7f..b7f0df7 100644 --- a/contrib/join-library/src/main/java/com/google/cloud/dataflow/contrib/joinlibrary/Join.java +++ b/contrib/join-library/src/main/java/com/google/cloud/dataflow/contrib/joinlibrary/Join.java @@ -1,19 +1,20 @@ /* - * Copyright (C) 2015 The Google Cloud Dataflow join-library Authors + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at * - * Licensed under the Apache License, Version 2.0 (the "License"); you may not - * use this file except in compliance with the License. You may obtain a copy of - * the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 + * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT - * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the - * License for the specific language governing permissions and limitations under - * the License. + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. */ - package com.google.cloud.dataflow.contrib.joinlibrary; import com.google.cloud.dataflow.sdk.coders.KvCoder; http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/d59c8012/contrib/join-library/src/test/java/com/google/cloud/dataflow/contrib/joinlibrary/InnerJoinTest.java ---------------------------------------------------------------------- diff --git a/contrib/join-library/src/test/java/com/google/cloud/dataflow/contrib/joinlibrary/InnerJoinTest.java b/contrib/join-library/src/test/java/com/google/cloud/dataflow/contrib/joinlibrary/InnerJoinTest.java index 839c451..067ffb6 100644 --- a/contrib/join-library/src/test/java/com/google/cloud/dataflow/contrib/joinlibrary/InnerJoinTest.java +++ b/contrib/join-library/src/test/java/com/google/cloud/dataflow/contrib/joinlibrary/InnerJoinTest.java @@ -1,19 +1,20 @@ /* - * Copyright (C) 2015 The Google Cloud Dataflow join-library Authors + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at * - * Licensed under the Apache License, Version 2.0 (the "License"); you may not - * use this file except in compliance with the License. You may obtain a copy of - * the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 + * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT - * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the - * License for the specific language governing permissions and limitations under - * the License. + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. */ - package com.google.cloud.dataflow.contrib.joinlibrary; import com.google.cloud.dataflow.sdk.Pipeline; http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/d59c8012/contrib/join-library/src/test/java/com/google/cloud/dataflow/contrib/joinlibrary/OuterLeftJoinTest.java ---------------------------------------------------------------------- diff --git a/contrib/join-library/src/test/java/com/google/cloud/dataflow/contrib/joinlibrary/OuterLeftJoinTest.java b/contrib/join-library/src/test/java/com/google/cloud/dataflow/contrib/joinlibrary/OuterLeftJoinTest.java index 3dd6742..90e4606 100644 --- a/contrib/join-library/src/test/java/com/google/cloud/dataflow/contrib/joinlibrary/OuterLeftJoinTest.java +++ b/contrib/join-library/src/test/java/com/google/cloud/dataflow/contrib/joinlibrary/OuterLeftJoinTest.java @@ -1,19 +1,20 @@ /* - * Copyright (C) 2015 The Google Cloud Dataflow join-library Authors + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at * - * Licensed under the Apache License, Version 2.0 (the "License"); you may not - * use this file except in compliance with the License. You may obtain a copy of - * the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 + * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT - * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the - * License for the specific language governing permissions and limitations under - * the License. + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. */ - package com.google.cloud.dataflow.contrib.joinlibrary; import com.google.cloud.dataflow.sdk.Pipeline; http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/d59c8012/contrib/join-library/src/test/java/com/google/cloud/dataflow/contrib/joinlibrary/OuterRightJoinTest.java ---------------------------------------------------------------------- diff --git a/contrib/join-library/src/test/java/com/google/cloud/dataflow/contrib/joinlibrary/OuterRightJoinTest.java b/contrib/join-library/src/test/java/com/google/cloud/dataflow/contrib/joinlibrary/OuterRightJoinTest.java index 9f3b80b..fe785d7 100644 --- a/contrib/join-library/src/test/java/com/google/cloud/dataflow/contrib/joinlibrary/OuterRightJoinTest.java +++ b/contrib/join-library/src/test/java/com/google/cloud/dataflow/contrib/joinlibrary/OuterRightJoinTest.java @@ -1,19 +1,20 @@ /* - * Copyright (C) 2015 The Google Cloud Dataflow join-library Authors + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at * - * Licensed under the Apache License, Version 2.0 (the "License"); you may not - * use this file except in compliance with the License. You may obtain a copy of - * the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 + * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT - * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the - * License for the specific language governing permissions and limitations under - * the License. + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. */ - package com.google.cloud.dataflow.contrib.joinlibrary; import com.google.cloud.dataflow.sdk.Pipeline; http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/d59c8012/examples/java/src/main/java/com/google/cloud/dataflow/examples/DebuggingWordCount.java ---------------------------------------------------------------------- diff --git a/examples/java/src/main/java/com/google/cloud/dataflow/examples/DebuggingWordCount.java b/examples/java/src/main/java/com/google/cloud/dataflow/examples/DebuggingWordCount.java index 8823dbc..1f76181 100644 --- a/examples/java/src/main/java/com/google/cloud/dataflow/examples/DebuggingWordCount.java +++ b/examples/java/src/main/java/com/google/cloud/dataflow/examples/DebuggingWordCount.java @@ -1,19 +1,20 @@ /* - * Copyright (C) 2015 Google Inc. + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at * - * Licensed under the Apache License, Version 2.0 (the "License"); you may not - * use this file except in compliance with the License. You may obtain a copy of - * the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 + * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT - * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the - * License for the specific language governing permissions and limitations under - * the License. + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. */ - package com.google.cloud.dataflow.examples; import com.google.cloud.dataflow.examples.WordCount.WordCountOptions; http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/d59c8012/examples/java/src/main/java/com/google/cloud/dataflow/examples/MinimalWordCount.java ---------------------------------------------------------------------- diff --git a/examples/java/src/main/java/com/google/cloud/dataflow/examples/MinimalWordCount.java b/examples/java/src/main/java/com/google/cloud/dataflow/examples/MinimalWordCount.java index 4ed0520..f3be5a3 100644 --- a/examples/java/src/main/java/com/google/cloud/dataflow/examples/MinimalWordCount.java +++ b/examples/java/src/main/java/com/google/cloud/dataflow/examples/MinimalWordCount.java @@ -1,19 +1,20 @@ /* - * Copyright (C) 2015 Google Inc. + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at * - * Licensed under the Apache License, Version 2.0 (the "License"); you may not - * use this file except in compliance with the License. You may obtain a copy of - * the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 + * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT - * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the - * License for the specific language governing permissions and limitations under - * the License. + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. */ - package com.google.cloud.dataflow.examples; import com.google.cloud.dataflow.sdk.Pipeline; http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/d59c8012/examples/java/src/main/java/com/google/cloud/dataflow/examples/WindowedWordCount.java ---------------------------------------------------------------------- diff --git a/examples/java/src/main/java/com/google/cloud/dataflow/examples/WindowedWordCount.java b/examples/java/src/main/java/com/google/cloud/dataflow/examples/WindowedWordCount.java index 2adac55..8f49dd2 100644 --- a/examples/java/src/main/java/com/google/cloud/dataflow/examples/WindowedWordCount.java +++ b/examples/java/src/main/java/com/google/cloud/dataflow/examples/WindowedWordCount.java @@ -1,19 +1,20 @@ /* - * Copyright (C) 2015 Google Inc. + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at * - * Licensed under the Apache License, Version 2.0 (the "License"); you may not - * use this file except in compliance with the License. You may obtain a copy of - * the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 + * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT - * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the - * License for the specific language governing permissions and limitations under - * the License. + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. */ - package com.google.cloud.dataflow.examples; import com.google.api.services.bigquery.model.TableFieldSchema; http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/d59c8012/examples/java/src/main/java/com/google/cloud/dataflow/examples/WordCount.java ---------------------------------------------------------------------- diff --git a/examples/java/src/main/java/com/google/cloud/dataflow/examples/WordCount.java b/examples/java/src/main/java/com/google/cloud/dataflow/examples/WordCount.java index 1086106..ad08d13 100644 --- a/examples/java/src/main/java/com/google/cloud/dataflow/examples/WordCount.java +++ b/examples/java/src/main/java/com/google/cloud/dataflow/examples/WordCount.java @@ -1,19 +1,20 @@ /* - * Copyright (C) 2015 Google Inc. + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at * - * Licensed under the Apache License, Version 2.0 (the "License"); you may not - * use this file except in compliance with the License. You may obtain a copy of - * the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 + * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT - * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the - * License for the specific language governing permissions and limitations under - * the License. + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. */ - package com.google.cloud.dataflow.examples; import com.google.cloud.dataflow.sdk.Pipeline; http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/d59c8012/examples/java/src/main/java/com/google/cloud/dataflow/examples/common/DataflowExampleOptions.java ---------------------------------------------------------------------- diff --git a/examples/java/src/main/java/com/google/cloud/dataflow/examples/common/DataflowExampleOptions.java b/examples/java/src/main/java/com/google/cloud/dataflow/examples/common/DataflowExampleOptions.java index 606bfb4..557e903 100644 --- a/examples/java/src/main/java/com/google/cloud/dataflow/examples/common/DataflowExampleOptions.java +++ b/examples/java/src/main/java/com/google/cloud/dataflow/examples/common/DataflowExampleOptions.java @@ -1,17 +1,20 @@ /* - * Copyright (C) 2015 Google Inc. + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at * - * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except - * in compliance with the License. You may obtain a copy of the License at + * http://www.apache.org/licenses/LICENSE-2.0 * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software distributed under the License - * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express - * or implied. See the License for the specific language governing permissions and limitations under - * the License. + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. */ - package com.google.cloud.dataflow.examples.common; import com.google.cloud.dataflow.sdk.options.DataflowPipelineOptions;
