This closes #2891: Vital moves of user-facing stuff out of util Update Dataflow worker to 20170504-2 Move some PCollectionView bits out of util Move ValueWithRecordId to sdk.values, annotated Move Reshuffle and ReshuffleTrigger out of util Move SideInputReader to runners/core-java Move PathValidator adjacent to other filesystem bits Move WindowingStrategy from util to values Mark TimeDomain experimental alongside Timers; improve javadoc Move user-facing timer-related classes out of util Add @Internal and @Experimental to state package Move Java sdk.util.state to sdk.state
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3042d761 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3042d761 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/3042d761 Branch: refs/heads/master Commit: 3042d761a223029a5be2b5ccab257396c71b07e6 Parents: 2f4dd8d 02e80a7 Author: Kenneth Knowles <k...@google.com> Authored: Thu May 4 17:02:18 2017 -0700 Committer: Kenneth Knowles <k...@google.com> Committed: Thu May 4 17:02:18 2017 -0700 ---------------------------------------------------------------------- .../apache/beam/runners/apex/ApexRunner.java | 2 +- .../beam/runners/apex/ApexRunnerRegistrar.java | 1 - .../beam/runners/apex/ApexRunnerResult.java | 2 - .../beam/runners/apex/ApexYarnLauncher.java | 2 - .../translation/ReadUnboundedTranslator.java | 1 - .../apex/translation/TransformTranslator.java | 1 - .../operators/ApexGroupByKeyOperator.java | 6 +- .../operators/ApexParDoOperator.java | 6 +- .../ApexReadUnboundedInputOperator.java | 2 - .../operators/ApexTimerInternals.java | 2 +- .../translation/utils/ApexStateInternals.java | 20 +- .../utils/CoderAdapterStreamCodec.java | 2 - .../translation/utils/StateInternalsProxy.java | 4 +- .../utils/ValueAndCoderKryoSerializable.java | 2 - .../apex/translation/utils/ValuesSource.java | 2 - .../beam/runners/apex/ApexYarnLauncherTest.java | 2 - .../apex/examples/UnboundedTextSource.java | 2 - .../runners/apex/examples/WordCountTest.java | 2 - .../translation/ApexGroupByKeyOperatorTest.java | 4 +- .../apex/translation/ParDoTranslatorTest.java | 2 +- .../operators/ApexTimerInternalsTest.java | 2 +- .../utils/ApexStateInternalsTest.java | 12 +- .../translation/utils/CollectionSource.java | 2 - .../runners/core/construction/PCollections.java | 2 +- .../core/construction/PrimitiveCreate.java | 2 +- .../core/construction/SdkComponents.java | 2 +- .../runners/core/construction/Triggers.java | 4 +- .../core/construction/WindowingStrategies.java | 4 +- .../core/construction/PCollectionsTest.java | 2 +- .../construction/PTransformMatchersTest.java | 18 +- .../construction/ReplacementOutputsTest.java | 2 +- .../core/construction/SdkComponentsTest.java | 4 +- .../construction/WindowingStrategiesTest.java | 4 +- .../apache/beam/runners/core/DoFnAdapters.java | 4 +- .../apache/beam/runners/core/DoFnRunner.java | 2 +- .../apache/beam/runners/core/DoFnRunners.java | 4 +- .../runners/core/GlobalCombineFnRunner.java | 1 - .../runners/core/GlobalCombineFnRunners.java | 41 +- .../GroupAlsoByWindowViaOutputBufferDoFn.java | 2 +- .../core/GroupAlsoByWindowViaWindowSetDoFn.java | 2 +- .../GroupAlsoByWindowViaWindowSetNewDoFn.java | 3 +- .../core/GroupByKeyViaGroupByKeyOnly.java | 2 +- .../runners/core/InMemoryStateInternals.java | 22 +- .../runners/core/InMemoryTimerInternals.java | 2 +- .../core/LateDataDroppingDoFnRunner.java | 4 +- .../apache/beam/runners/core/LateDataUtils.java | 2 +- .../runners/core/MergingActiveWindowSet.java | 2 +- .../beam/runners/core/MergingStateAccessor.java | 2 +- .../apache/beam/runners/core/NonEmptyPanes.java | 8 +- .../beam/runners/core/NullSideInputReader.java | 61 ++ ...eBoundedSplittableProcessElementInvoker.java | 5 +- .../beam/runners/core/PaneInfoTracker.java | 4 +- .../beam/runners/core/ProcessFnRunner.java | 3 +- .../core/PushbackSideInputDoFnRunner.java | 2 +- .../core/ReadyCheckingSideInputReader.java | 34 + .../org/apache/beam/runners/core/ReduceFn.java | 6 +- .../runners/core/ReduceFnContextFactory.java | 13 +- .../beam/runners/core/ReduceFnRunner.java | 7 +- .../beam/runners/core/SideInputHandler.java | 5 +- .../beam/runners/core/SideInputReader.java | 47 ++ .../beam/runners/core/SimpleDoFnRunner.java | 13 +- .../beam/runners/core/SimpleOldDoFnRunner.java | 5 +- .../core/SimplePushbackSideInputDoFnRunner.java | 3 +- .../beam/runners/core/SplittableParDo.java | 8 +- .../apache/beam/runners/core/StateAccessor.java | 2 +- .../beam/runners/core/StateInternals.java | 4 +- .../apache/beam/runners/core/StateMerging.java | 14 +- .../apache/beam/runners/core/StateTable.java | 4 +- .../org/apache/beam/runners/core/StateTag.java | 16 +- .../org/apache/beam/runners/core/StateTags.java | 20 +- .../beam/runners/core/StatefulDoFnRunner.java | 8 +- .../beam/runners/core/SystemReduceFn.java | 8 +- .../core/TestInMemoryStateInternals.java | 4 +- .../beam/runners/core/TimerInternals.java | 2 +- .../core/UnsupportedSideInputReader.java | 1 - .../apache/beam/runners/core/WatermarkHold.java | 6 +- .../core/WindowingInternalsAdapters.java | 1 - .../AfterDelayFromFirstElementStateMachine.java | 6 +- .../core/triggers/AfterPaneStateMachine.java | 2 +- .../AfterProcessingTimeStateMachine.java | 2 +- ...rSynchronizedProcessingTimeStateMachine.java | 2 +- .../triggers/AfterWatermarkStateMachine.java | 2 +- .../triggers/DefaultTriggerStateMachine.java | 2 +- .../triggers/ReshuffleTriggerStateMachine.java | 2 +- .../core/triggers/TriggerStateMachine.java | 2 +- .../TriggerStateMachineContextFactory.java | 6 +- .../triggers/TriggerStateMachineRunner.java | 4 +- ...roupAlsoByWindowViaOutputBufferDoFnTest.java | 2 +- .../core/GroupAlsoByWindowsProperties.java | 2 +- .../core/InMemoryStateInternalsTest.java | 16 +- .../core/InMemoryTimerInternalsTest.java | 2 +- .../runners/core/KeyedWorkItemCoderTest.java | 2 +- .../core/LateDataDroppingDoFnRunnerTest.java | 2 +- ...ndedSplittableProcessElementInvokerTest.java | 1 - .../beam/runners/core/ReduceFnRunnerTest.java | 7 +- .../beam/runners/core/ReduceFnTester.java | 8 +- .../beam/runners/core/SideInputHandlerTest.java | 2 +- .../beam/runners/core/SimpleDoFnRunnerTest.java | 11 +- .../SimplePushbackSideInputDoFnRunnerTest.java | 3 +- .../beam/runners/core/SplittableParDoTest.java | 3 +- .../runners/core/StatefulDoFnRunnerTest.java | 9 +- .../beam/runners/core/TimerInternalsTest.java | 2 +- .../triggers/TriggerStateMachineTester.java | 6 +- .../core/triggers/TriggerStateMachinesTest.java | 2 +- .../CopyOnAccessInMemoryStateInternals.java | 18 +- .../beam/runners/direct/DirectGroupByKey.java | 2 +- .../runners/direct/DirectTimerInternals.java | 2 +- .../beam/runners/direct/EvaluationContext.java | 6 +- .../GroupAlsoByWindowEvaluatorFactory.java | 2 +- .../runners/direct/PCollectionViewWindow.java | 67 ++ .../beam/runners/direct/ParDoEvaluator.java | 4 +- .../direct/ParDoMultiOverrideFactory.java | 2 +- .../beam/runners/direct/SideInputContainer.java | 7 +- ...littableProcessElementsEvaluatorFactory.java | 4 +- .../direct/StatefulParDoEvaluatorFactory.java | 4 +- .../direct/TestStreamEvaluatorFactory.java | 2 +- .../direct/WatermarkCallbackExecutor.java | 2 +- .../beam/runners/direct/WatermarkManager.java | 2 +- .../runners/direct/CommittedResultTest.java | 2 +- .../CopyOnAccessInMemoryStateInternalsTest.java | 14 +- .../direct/DirectTimerInternalsTest.java | 2 +- ...leManagerRemovingTransformEvaluatorTest.java | 2 +- .../runners/direct/EvaluationContextTest.java | 8 +- .../direct/KeyedPValueTrackingVisitorTest.java | 2 +- .../beam/runners/direct/ParDoEvaluatorTest.java | 2 +- .../runners/direct/SideInputContainerTest.java | 8 +- .../StatefulParDoEvaluatorFactoryTest.java | 10 +- .../direct/ViewEvaluatorFactoryTest.java | 2 +- .../runners/direct/ViewOverrideFactoryTest.java | 4 +- .../direct/WatermarkCallbackExecutorTest.java | 2 +- .../runners/direct/WatermarkManagerTest.java | 2 +- .../direct/WriteWithShardingFactoryTest.java | 4 +- .../flink/FlinkBatchTransformTranslators.java | 4 +- .../flink/FlinkBatchTranslationContext.java | 2 +- .../flink/FlinkDetachedRunnerResult.java | 1 - .../FlinkStreamingTransformTranslators.java | 4 +- .../flink/FlinkStreamingViewOverrides.java | 2 +- .../metrics/DoFnRunnerWithMetricsUpdate.java | 2 +- .../functions/AbstractFlinkCombineRunner.java | 4 +- .../functions/FlinkDoFnFunction.java | 2 +- .../FlinkMergingNonShuffleReduceFunction.java | 2 +- .../functions/FlinkPartialReduceFunction.java | 2 +- .../functions/FlinkReduceFunction.java | 2 +- .../functions/FlinkSideInputReader.java | 4 +- .../functions/FlinkStatefulDoFnFunction.java | 2 +- .../functions/HashingFlinkCombineRunner.java | 4 +- .../functions/SortingFlinkCombineRunner.java | 4 +- .../types/EncodedValueSerializer.java | 2 - .../wrappers/streaming/DoFnOperator.java | 10 +- .../streaming/SplittableDoFnOperator.java | 2 +- .../wrappers/streaming/WindowDoFnOperator.java | 2 +- .../state/FlinkBroadcastStateInternals.java | 20 +- .../state/FlinkKeyGroupStateInternals.java | 20 +- .../state/FlinkSplitStateInternals.java | 20 +- .../streaming/state/FlinkStateInternals.java | 20 +- .../beam/runners/flink/PipelineOptionsTest.java | 2 +- .../flink/streaming/DoFnOperatorTest.java | 16 +- .../FlinkBroadcastStateInternalsTest.java | 10 +- .../FlinkKeyGroupStateInternalsTest.java | 4 +- .../streaming/FlinkSplitStateInternalsTest.java | 4 +- .../streaming/FlinkStateInternalsTest.java | 12 +- runners/google-cloud-dataflow-java/pom.xml | 2 +- .../beam/runners/dataflow/AssignWindows.java | 2 +- .../dataflow/BatchStatefulParDoOverrides.java | 2 +- .../runners/dataflow/BatchViewOverrides.java | 4 +- .../dataflow/DataflowPipelineTranslator.java | 2 +- .../beam/runners/dataflow/DataflowRunner.java | 8 +- .../dataflow/ReshuffleOverrideFactory.java | 6 +- .../beam/runners/dataflow/util/DoFnInfo.java | 2 +- .../BatchStatefulParDoOverridesTest.java | 6 +- .../DataflowPipelineTranslatorTest.java | 8 +- .../runners/dataflow/DataflowRunnerTest.java | 2 +- .../transforms/DataflowGroupByKeyTest.java | 2 +- .../dataflow/transforms/DataflowViewTest.java | 2 +- .../beam/runners/spark/SparkRunnerDebugger.java | 1 - .../beam/runners/spark/TestSparkRunner.java | 2 +- .../spark/aggregators/NamedAggregators.java | 2 - .../beam/runners/spark/coders/CoderHelpers.java | 1 - .../spark/coders/StatelessJavaSerializer.java | 1 - .../beam/runners/spark/io/CreateStream.java | 2 +- .../runners/spark/io/SparkUnboundedSource.java | 1 - .../runners/spark/metrics/AggregatorMetric.java | 1 - .../spark/metrics/SparkBeamMetricSource.java | 1 - .../SparkGroupAlsoByWindowViaWindowSet.java | 2 +- .../spark/stateful/SparkStateInternals.java | 20 +- .../spark/stateful/SparkTimerInternals.java | 2 +- .../spark/stateful/StateSpecFunctions.java | 1 - .../translation/DoFnRunnerWithMetrics.java | 2 +- .../translation/GroupCombineFunctions.java | 5 +- .../spark/translation/MultiDoFnFunction.java | 2 +- .../translation/SparkAbstractCombineFn.java | 4 +- .../spark/translation/SparkGlobalCombineFn.java | 2 +- ...SparkGroupAlsoByWindowViaOutputBufferFn.java | 2 +- .../spark/translation/SparkKeyedCombineFn.java | 2 +- .../translation/StorageLevelPTransform.java | 2 +- .../spark/translation/TransformTranslator.java | 4 +- .../spark/translation/TranslationUtils.java | 3 +- .../streaming/StreamingTransformTranslator.java | 4 +- .../spark/util/GlobalWatermarkHolder.java | 1 - .../util/SinglePrimitiveOutputPTransform.java | 2 +- .../spark/util/SparkSideInputReader.java | 4 +- .../src/main/resources/beam/findbugs-filter.xml | 2 +- .../sdk/io/BoundedReadFromUnboundedSource.java | 2 +- .../org/apache/beam/sdk/io/FileSystems.java | 1 - .../main/java/org/apache/beam/sdk/io/Read.java | 2 +- .../beam/sdk/io/fs/NoopPathValidator.java | 52 ++ .../apache/beam/sdk/io/fs/PathValidator.java | 58 ++ .../apache/beam/sdk/options/ValueProviders.java | 1 - .../org/apache/beam/sdk/state/BagState.java | 32 + .../apache/beam/sdk/state/CombiningState.java | 56 ++ .../apache/beam/sdk/state/GroupingState.java | 45 ++ .../org/apache/beam/sdk/state/MapState.java | 82 +++ .../apache/beam/sdk/state/ReadableState.java | 51 ++ .../apache/beam/sdk/state/ReadableStates.java | 44 ++ .../org/apache/beam/sdk/state/SetState.java | 49 ++ .../java/org/apache/beam/sdk/state/State.java | 36 ++ .../org/apache/beam/sdk/state/StateBinder.java | 71 ++ .../org/apache/beam/sdk/state/StateContext.java | 46 ++ .../apache/beam/sdk/state/StateContexts.java | 54 ++ .../org/apache/beam/sdk/state/StateSpec.java | 63 ++ .../org/apache/beam/sdk/state/StateSpecs.java | 643 +++++++++++++++++++ .../org/apache/beam/sdk/state/TimeDomain.java | 45 ++ .../java/org/apache/beam/sdk/state/Timer.java | 78 +++ .../org/apache/beam/sdk/state/TimerSpec.java | 30 + .../org/apache/beam/sdk/state/TimerSpecs.java | 41 ++ .../java/org/apache/beam/sdk/state/Timers.java | 58 ++ .../org/apache/beam/sdk/state/ValueState.java | 37 ++ .../beam/sdk/state/WatermarkHoldState.java | 41 ++ .../org/apache/beam/sdk/state/package-info.java | 22 + .../org/apache/beam/sdk/testing/PAssert.java | 2 +- .../beam/sdk/testing/TestPipelineOptions.java | 2 - .../org/apache/beam/sdk/testing/TestStream.java | 2 +- .../apache/beam/sdk/testing/UsesMapState.java | 2 +- .../apache/beam/sdk/testing/UsesSetState.java | 2 +- .../org/apache/beam/sdk/transforms/Combine.java | 4 +- .../org/apache/beam/sdk/transforms/DoFn.java | 10 +- .../apache/beam/sdk/transforms/DoFnTester.java | 4 +- .../org/apache/beam/sdk/transforms/Flatten.java | 2 +- .../apache/beam/sdk/transforms/GroupByKey.java | 2 +- .../beam/sdk/transforms/GroupIntoBatches.java | 18 +- .../org/apache/beam/sdk/transforms/ParDo.java | 2 +- .../org/apache/beam/sdk/transforms/Regex.java | 1 - .../beam/sdk/transforms/ReifyTimestamps.java | 73 +++ .../apache/beam/sdk/transforms/Reshuffle.java | 92 +++ .../org/apache/beam/sdk/transforms/View.java | 2 +- .../reflect/ByteBuddyDoFnInvokerFactory.java | 2 +- .../sdk/transforms/reflect/DoFnInvoker.java | 4 +- .../sdk/transforms/reflect/DoFnSignature.java | 8 +- .../sdk/transforms/reflect/DoFnSignatures.java | 8 +- .../transforms/windowing/AfterWatermark.java | 2 +- .../transforms/windowing/ReshuffleTrigger.java | 58 ++ .../beam/sdk/transforms/windowing/Window.java | 4 +- .../apache/beam/sdk/util/AppliedCombineFn.java | 1 + .../org/apache/beam/sdk/util/ClassPath.java | 1 + .../beam/sdk/util/CombineContextFactory.java | 27 +- .../org/apache/beam/sdk/util/CombineFnUtil.java | 2 +- .../apache/beam/sdk/util/IdentityWindowFn.java | 1 + .../apache/beam/sdk/util/NoopPathValidator.java | 4 +- .../beam/sdk/util/NullSideInputReader.java | 61 -- .../beam/sdk/util/PCollectionViewWindow.java | 67 -- .../apache/beam/sdk/util/PCollectionViews.java | 496 -------------- .../org/apache/beam/sdk/util/PathValidator.java | 55 -- .../sdk/util/ReadyCheckingSideInputReader.java | 34 - .../apache/beam/sdk/util/ReifyTimestamps.java | 76 --- .../org/apache/beam/sdk/util/Reshuffle.java | 88 --- .../apache/beam/sdk/util/ReshuffleTrigger.java | 52 -- .../apache/beam/sdk/util/SideInputReader.java | 47 -- .../org/apache/beam/sdk/util/TimeDomain.java | 43 -- .../java/org/apache/beam/sdk/util/Timer.java | 78 --- .../org/apache/beam/sdk/util/TimerSpec.java | 30 - .../org/apache/beam/sdk/util/TimerSpecs.java | 41 -- .../java/org/apache/beam/sdk/util/Timers.java | 58 -- .../apache/beam/sdk/util/ValueWithRecordId.java | 134 ---- .../apache/beam/sdk/util/WindowingStrategy.java | 283 -------- .../apache/beam/sdk/util/state/BagState.java | 28 - .../beam/sdk/util/state/CombiningState.java | 53 -- .../beam/sdk/util/state/GroupingState.java | 42 -- .../apache/beam/sdk/util/state/MapState.java | 79 --- .../beam/sdk/util/state/ReadableState.java | 51 -- .../beam/sdk/util/state/ReadableStates.java | 45 -- .../apache/beam/sdk/util/state/SetState.java | 45 -- .../org/apache/beam/sdk/util/state/State.java | 32 - .../apache/beam/sdk/util/state/StateBinder.java | 66 -- .../beam/sdk/util/state/StateContext.java | 43 -- .../beam/sdk/util/state/StateContexts.java | 51 -- .../apache/beam/sdk/util/state/StateSpec.java | 53 -- .../apache/beam/sdk/util/state/StateSpecs.java | 629 ------------------ .../apache/beam/sdk/util/state/ValueState.java | 37 -- .../beam/sdk/util/state/WatermarkHoldState.java | 42 -- .../beam/sdk/util/state/package-info.java | 22 - .../org/apache/beam/sdk/values/PCollection.java | 1 - .../beam/sdk/values/PCollectionTuple.java | 1 - .../apache/beam/sdk/values/PCollectionView.java | 1 - .../beam/sdk/values/PCollectionViews.java | 495 ++++++++++++++ .../beam/sdk/values/ValueWithRecordId.java | 138 ++++ .../beam/sdk/values/WindowingStrategy.java | 283 ++++++++ .../sdk/io/DrunkWritableByteChannelFactory.java | 1 - .../org/apache/beam/sdk/io/TFRecordIOTest.java | 2 - .../apache/beam/sdk/metrics/GaugeCellTest.java | 1 + .../beam/sdk/options/PipelineOptionsTest.java | 1 - .../sdk/runners/TransformHierarchyTest.java | 2 +- .../beam/sdk/runners/TransformTreeTest.java | 2 +- .../sdk/testing/PCollectionViewTesting.java | 2 +- .../beam/sdk/transforms/DoFnTesterTest.java | 4 +- .../beam/sdk/transforms/GroupByKeyTest.java | 3 +- .../apache/beam/sdk/transforms/ParDoTest.java | 22 +- .../apache/beam/sdk/transforms/RegexTest.java | 2 - .../sdk/transforms/ReifyTimestampsTest.java | 104 +++ .../beam/sdk/transforms/ReshuffleTest.java | 266 ++++++++ .../apache/beam/sdk/transforms/ViewTest.java | 2 +- .../transforms/reflect/DoFnInvokersTest.java | 14 +- .../transforms/reflect/DoFnSignaturesTest.java | 16 +- .../transforms/reflect/OnTimerInvokersTest.java | 6 +- .../testhelper/DoFnInvokersTestHelper.java | 6 +- .../windowing/ReshuffleTriggerTest.java | 42 ++ .../sdk/transforms/windowing/WindowTest.java | 4 +- .../apache/beam/sdk/util/CombineFnUtilTest.java | 2 +- .../beam/sdk/util/ReifyTimestampsTest.java | 109 ---- .../org/apache/beam/sdk/util/ReshuffleTest.java | 270 -------- .../beam/sdk/util/ReshuffleTriggerTest.java | 44 -- .../beam/sdk/util/ValueWithRecordIdTest.java | 34 - .../beam/sdk/values/PCollectionTupleTest.java | 1 - .../beam/sdk/values/ValueWithRecordIdTest.java | 34 + .../sdk/extensions/gcp/options/GcpOptions.java | 2 +- .../sdk/extensions/gcp/options/GcsOptions.java | 2 +- .../apache/beam/sdk/util/GcsPathValidator.java | 1 + .../extensions/protobuf/ByteStringCoder.java | 1 - .../extensions/sorter/ExternalSorterTest.java | 1 - .../harness/control/ProcessBundleHandler.java | 4 +- .../control/ProcessBundleHandlerTest.java | 2 +- .../apache/beam/sdk/io/common/HashingFn.java | 2 - .../beam/sdk/io/gcp/bigquery/BatchLoads.java | 2 +- .../sdk/io/gcp/bigquery/BigQueryHelpers.java | 2 - .../io/gcp/bigquery/BigQueryQuerySource.java | 1 - .../sdk/io/gcp/bigquery/CalculateSchemas.java | 1 - .../beam/sdk/io/gcp/bigquery/CreateTables.java | 1 - .../io/gcp/bigquery/StreamingWriteTables.java | 2 +- .../sdk/io/gcp/bigquery/TableDestination.java | 1 - .../sdk/io/gcp/bigquery/WritePartition.java | 1 - .../beam/sdk/io/gcp/bigquery/WriteRename.java | 1 - .../beam/sdk/io/gcp/bigquery/WriteTables.java | 1 - .../sdk/io/gcp/bigquery/BigQueryIOTest.java | 4 +- .../io/gcp/bigquery/FakeBigQueryServices.java | 2 - .../sdk/io/gcp/bigquery/FakeJobService.java | 3 - .../sdk/io/gcp/bigquery/TableContainer.java | 1 - .../ConfigurableEmployeeInputFormat.java | 1 - .../hadoop/inputformat/EmployeeInputFormat.java | 1 - .../ReuseObjectsEmployeeInputFormat.java | 1 - .../hadoop/inputformat/TestEmployeeDataSet.java | 2 - .../inputformat/HIFIOWithElasticTest.java | 1 - .../HIFIOWithEmbeddedCassandraTest.java | 2 - .../integration/tests/HIFIOCassandraIT.java | 2 - .../integration/tests/HIFIOElasticIT.java | 1 - .../org/apache/beam/sdk/io/jdbc/JdbcIO.java | 2 - .../org/apache/beam/sdk/io/jdbc/JdbcIOIT.java | 1 - .../org/apache/beam/sdk/io/jms/JmsRecord.java | 1 - .../beam/sdk/io/kafka/KafkaCheckpointMark.java | 2 - .../apache/beam/sdk/io/kafka/KafkaRecord.java | 1 - .../CoderBasedKafkaDeserializer.java | 1 - .../CoderBasedKafkaSerializer.java | 1 - .../serialization/InstantDeserializer.java | 1 - .../kafka/serialization/InstantSerializer.java | 1 - .../beam/sdk/io/mongodb/MongoDbGridFSIO.java | 3 - .../sdk/io/mongodb/MongoDBGridFSIOTest.java | 3 - .../beam/sdk/io/mongodb/MongoDbIOTest.java | 4 - .../org/apache/beam/sdk/io/mqtt/MqttIO.java | 3 - 366 files changed, 4082 insertions(+), 4094 deletions(-) ----------------------------------------------------------------------