runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/MemoryMonitor.java sdks/java/harness/src/main/java/org/apache/beam/fn/harness/status/MemoryMonitor.java runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/common/worker/GroupingTables.java sdks/java/harness/src/main/java/org/apache/beam/fn/harness/PrecombineGroupingTable.java runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/OrderedCode.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/OrderedCode.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/wire/ByteStringCoder.java sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ByteStringCoder.java runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/PartialGroupByKeyParDoFns.java sdks/java/harness/src/main/java/org/apache/beam/fn/harness/PrecombineGroupingTable.java runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/TriggerStateMachine.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/Trigger.java runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/status/ThreadzServlet.java sdks/java/harness/src/main/java/org/apache/beam/fn/harness/status/BeamFnStatusClient.java runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/DataflowTransport.java sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/Transport.java runners/google-cloud-dataflow-java/worker/windmill/src/main/proto/windmill_service.proto sdks/go/pkg/beam/core/runtime/graphx/v1/v1.proto runners/google-cloud-dataflow-java/worker/windmill/src/main/proto/pubsub.proto sdks/go/pkg/beam/core/runtime/graphx/v1/v1.proto runners/google-cloud-dataflow-java/worker/windmill/src/main/proto/windmill.proto sdks/go/pkg/beam/core/runtime/graphx/v1/v1.proto runners/google-cloud-dataflow-java/worker/windmill/src/main/proto/pubsub.proto sdks/go/pkg/beam/core/runtime/harness/session.proto runners/google-cloud-dataflow-java/worker/windmill/src/main/proto/pubsub.proto sdks/go/pkg/beam/io/pubsubio/v1/v1.proto runners/google-cloud-dataflow-java/worker/windmill/src/main/proto/windmill.proto sdks/go/pkg/beam/core/runtime/harness/session.proto runners/google-cloud-dataflow-java/worker/windmill/src/main/proto/windmill.proto sdks/go/pkg/beam/io/pubsubio/v1/v1.proto runners/google-cloud-dataflow-java/worker/windmill/src/main/proto/windmill_service.proto sdks/go/pkg/beam/io/pubsubio/v1/v1.proto runners/google-cloud-dataflow-java/worker/windmill/src/main/proto/windmill_service.proto sdks/go/pkg/beam/core/runtime/harness/session.proto runners/core-java/src/main/java/org/apache/beam/runners/core/SimpleDoFnRunner.java sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FnApiDoFnRunner.java runners/core-java/src/main/java/org/apache/beam/runners/core/SimpleDoFnRunner.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/DoFnTester.java runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/common/worker/GroupingShuffleRangeTracker.java sdks/java/core/src/main/java/org/apache/beam/sdk/io/range/OffsetRangeTracker.java runners/core-java/src/main/java/org/apache/beam/runners/core/OutputAndTimeBoundedSplittableProcessElementInvoker.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/DoFnTester.java runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/DirectStreamObserver.java sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/stream/DirectStreamObserver.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/GrpcFnServer.java sdks/java/expansion-service/src/main/java/org/apache/beam/sdk/expansion/service/ExpansionServer.java runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/common/worker/GroupingShuffleRangeTracker.java sdks/java/core/src/main/java/org/apache/beam/sdk/io/range/ByteKeyRangeTracker.java runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterWatermarkStateMachine.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterWatermark.java runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamEnumerableConverter.java runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DeltaCounterCell.java sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/DelegatingCounter.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/RunnerPCollectionView.java sdks/java/core/src/main/java/org/apache/beam/sdk/values/PCollectionViews.java runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowWorkerLoggingOptions.java sdks/java/core/src/main/java/org/apache/beam/sdk/options/SdkHarnessOptions.java runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WindowingWindmillReader.java sdks/java/core/src/main/java/org/apache/beam/sdk/io/Read.java runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/fn/stream/ServerStreamObserverFactory.java sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/stream/OutboundObserverFactory.java runners/core-java/src/main/java/org/apache/beam/runners/core/OutputAndTimeBoundedSplittableProcessElementInvoker.java sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FnApiDoFnRunner.java runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterPaneStateMachine.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterPane.java runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/IsmReaderImpl.java sdks/java/core/src/main/java/org/apache/beam/sdk/io/Read.java runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/GroupIntoBatchesOverride.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/GroupIntoBatches.java runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/CounterCell.java sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/DelegatingCounter.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/BasicSqsClientProvider.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Done.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/Query5.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/WinningBids.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/AuctionBid.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/core/src/main/java/org/apache/beam/sdk/testing/PAssert.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/BasicSqsClientProvider.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/WinningBids.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/CombineFns.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/sources/generator/Generator.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Event.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/BasicSqsClientProvider.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/BasicSqsClientProvider.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/MutationGroup.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Event.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/coders/RowCoder.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/StartingPoint.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/Schema.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Done.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/FhirSearchParameter.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/WinningBids.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/dynamodb/BasicDynamoDbClientProvider.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/StartingPoint.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/ByteBuddyUtils.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/example/model/Customer.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/gcsfs/GcsPath.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sns/BasicSnsAsyncClientProvider.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/io/hbase/src/main/java/org/apache/beam/sdk/io/hbase/HBaseIO.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/WinningBids.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/BasicSqsClientProvider.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/io/range/OffsetRange.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/SellerPrice.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/WinningBids.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/IdNameReserve.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/join/RawUnionValue.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/SqsCheckpointMark.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/SellerPrice.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/coders/RowCoder.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/SchemaCoder.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiFlushAndFinalizeDoFn.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/example/model/Order.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/EnumerationType.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/sqs/SqsCheckpointMark.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/AuctionBid.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/CombineFns.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/AuctionBid.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/CombineFns.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/FromRowUsingCreator.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ApproximateUnique.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/Schema.java runners/flink/src/main/java/org/apache/beam/runners/flink/PipelineTranslationModeOptimizer.java sdks/java/core/src/main/java/org/apache/beam/sdk/Pipeline.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/BasicSqsClientProvider.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/ByteBuddyUtils.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/example/model/Order.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/OneOfType.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/EnumerationType.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Event.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/StartingPoint.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/gcsfs/GcsPath.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Done.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoDomain.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/CategoryPrice.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/join/RawUnionValue.java runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/internal/IsmFormat.java sdks/java/core/src/main/java/org/apache/beam/sdk/coders/VarIntCoder.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Event.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/EnumerationType.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/sources/generator/Generator.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/SellerPrice.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Watch.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/example/model/Order.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiFlushAndFinalizeDoFn.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileIO.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/CombineFns.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/gcsfs/GcsPath.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/wire/ByteStringCoder.java sdks/java/core/src/main/java/org/apache/beam/sdk/coders/ByteCoder.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/SqsCheckpointMark.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubClient.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Done.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sns/BasicSnsAsyncClientProvider.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubClient.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/io/hbase/src/main/java/org/apache/beam/sdk/io/hbase/HBaseIO.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/sqs/SqsCheckpointMark.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/core/src/main/java/org/apache/beam/sdk/coders/RowCoder.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ApproximateUnique.java runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/internal/IsmFormat.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/GlobalWindow.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/MutationGroup.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileIO.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/FromRowUsingCreator.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/testing/SuccessOrFailure.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/Schema.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/core/src/main/java/org/apache/beam/sdk/testing/PAssert.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/AuctionBid.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/WinningBids.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/gcsfs/GcsPath.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/WinningBids.java runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/internal/IsmFormat.java sdks/java/core/src/main/java/org/apache/beam/sdk/coders/StringUtf8Coder.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileIO.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/IdNameReserve.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/AuctionBid.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/StartingPoint.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileIO.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/sqs/SqsCheckpointMark.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/io/hbase/src/main/java/org/apache/beam/sdk/io/hbase/HBaseIO.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/sources/generator/Generator.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/io/hbase/src/main/java/org/apache/beam/sdk/io/hbase/HBaseIO.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/example/model/Order.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoDomain.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/sources/generator/Generator.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SplittableParDoNaiveBounded.java sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FnApiDoFnRunner.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sns/BasicSnsClientProvider.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/io/jms/src/main/java/org/apache/beam/sdk/io/jms/JmsCheckpointMark.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/GetterBasedSchemaProvider.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/CachingFactory.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/SqsCheckpointMark.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/OneOfType.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/BidsPerSession.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/SchemaCoder.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/sqs/SqsCheckpointMark.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/CachingFactory.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/example/model/Customer.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/gcsfs/GcsPath.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/FhirSearchParameter.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sns/BasicSnsClientProvider.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/SchemaCoder.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/AuctionBid.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/SchemaCoder.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryInsertError.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/StartingPoint.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubClient.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiFlushAndFinalizeDoFn.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/FhirSearchParameter.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/Query5.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/CategoryPrice.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoDomain.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/Query5.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/StartingPoint.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/SellerPrice.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/testing/PAssert.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/io/jms/src/main/java/org/apache/beam/sdk/io/jms/JmsCheckpointMark.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/EnumerationType.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/ByteBuddyUtils.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/gcsfs/GcsPath.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/GetterBasedSchemaProvider.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Watch.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryInsertError.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/ByteBuddyUtils.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Auction.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/dynamodb/BasicDynamoDbClientProvider.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubClient.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/BidsPerSession.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/GetterBasedSchemaProvider.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Watch.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/StartingPoint.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/StartingPoint.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/io/hbase/src/main/java/org/apache/beam/sdk/io/hbase/HBaseIO.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryInsertError.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Event.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/example/model/Order.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/CachingFactory.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/BidsPerSession.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Person.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ApproximateUnique.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/FhirSearchParameter.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/SqsCheckpointMark.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/example/model/Order.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileIO.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryInsertError.java runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingSideInputFetcher.java sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoCoder.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/gcsfs/GcsPath.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/sources/generator/Generator.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/ByteBuddyUtils.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/OneOfType.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/example/model/Customer.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/core/src/main/java/org/apache/beam/sdk/io/range/OffsetRange.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/CategoryPrice.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/core/src/main/java/org/apache/beam/sdk/util/SerializableThrowable.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/Schema.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/FromRowUsingCreator.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/ByteBuddyUtils.java runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/RandomAccessData.java sdks/java/core/src/main/java/org/apache/beam/sdk/coders/ByteCoder.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/join/RawUnionValue.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/io/hbase/src/main/java/org/apache/beam/sdk/io/hbase/HBaseIO.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Person.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ApproximateUnique.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/Schema.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Watch.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/CombineFns.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/join/RawUnionValue.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/GetterBasedSchemaProvider.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/MutationGroup.java runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/internal/IsmFormat.java sdks/java/core/src/main/java/org/apache/beam/sdk/coders/ByteCoder.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/CategoryPrice.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/example/model/Order.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sns/BasicSnsClientProvider.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/SellerPrice.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiFlushAndFinalizeDoFn.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/dynamodb/BasicDynamoDbClientProvider.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/BasicSqsClientProvider.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileIO.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryInsertError.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/SqsCheckpointMark.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/SqsCheckpointMark.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ApproximateUnique.java runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/internal/IsmFormat.java sdks/java/core/src/main/java/org/apache/beam/sdk/coders/BigEndianLongCoder.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/core/src/main/java/org/apache/beam/sdk/testing/SuccessOrFailure.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/io/hbase/src/main/java/org/apache/beam/sdk/io/hbase/HBaseIO.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/gcsfs/GcsPath.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sns/BasicSnsAsyncClientProvider.java runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/internal/IsmFormat.java sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ByteStringCoder.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubClient.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/StartingPoint.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/FromRowUsingCreator.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubClient.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sns/BasicSnsClientProvider.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/io/range/OffsetRange.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/ByteBuddyUtils.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Person.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileIO.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Auction.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/sources/generator/Generator.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/io/hbase/src/main/java/org/apache/beam/sdk/io/hbase/HBaseIO.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/core/src/main/java/org/apache/beam/sdk/io/range/OffsetRange.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/core/src/main/java/org/apache/beam/sdk/testing/SuccessOrFailure.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/CategoryPrice.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/join/RawUnionValue.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/StartingPoint.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/FhirSearchParameter.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/gcsfs/GcsPath.java runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterFirstStateMachine.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterFirst.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/StartingPoint.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/sources/generator/Generator.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Auction.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/CombineFns.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/testing/SuccessOrFailure.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/StartingPoint.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/MutationGroup.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoDomain.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/core/src/main/java/org/apache/beam/sdk/io/range/OffsetRange.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/BasicSqsClientProvider.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/EnumerationType.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/util/SerializableThrowable.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/StartingPoint.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/SchemaCoder.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/Query5.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/SellerPrice.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/SellerPrice.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/BidsPerSession.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/CachingFactory.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/sqs/SqsCheckpointMark.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/dynamodb/BasicDynamoDbClientProvider.java runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/RandomAccessData.java sdks/java/core/src/main/java/org/apache/beam/sdk/coders/VarLongCoder.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubClient.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/testing/SuccessOrFailure.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/StartingPoint.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/example/model/Customer.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/core/src/main/java/org/apache/beam/sdk/testing/SuccessOrFailure.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/WinningBids.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/dynamodb/BasicDynamoDbClientProvider.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/CategoryPrice.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/io/jms/src/main/java/org/apache/beam/sdk/io/jms/JmsCheckpointMark.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/FhirSearchParameter.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoDomain.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/Query5.java runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/internal/IsmFormat.java sdks/java/core/src/main/java/org/apache/beam/sdk/coders/VarLongCoder.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/Schema.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/io/hbase/src/main/java/org/apache/beam/sdk/io/hbase/HBaseIO.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/AuctionBid.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/CachingFactory.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubClient.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiFlushAndFinalizeDoFn.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/SchemaCoder.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/join/RawUnionValue.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/AuctionBid.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/io/range/OffsetRange.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/ByteBuddyUtils.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubClient.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/core/src/main/java/org/apache/beam/sdk/util/SerializableThrowable.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/wire/ByteStringCoder.java sdks/java/core/src/main/java/org/apache/beam/sdk/coders/VarLongCoder.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/OneOfType.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubClient.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/gcsfs/GcsPath.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/SchemaCoder.java runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/RandomAccessData.java sdks/java/core/src/main/java/org/apache/beam/sdk/coders/BigEndianLongCoder.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/CategoryPrice.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/io/jms/src/main/java/org/apache/beam/sdk/io/jms/JmsCheckpointMark.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/example/model/Order.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/dynamodb/BasicDynamoDbClientProvider.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryInsertError.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Person.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/sqs/SqsCheckpointMark.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/BidsPerSession.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/FromRowUsingCreator.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/gcsfs/GcsPath.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/io/hbase/src/main/java/org/apache/beam/sdk/io/hbase/HBaseIO.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryInsertError.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/core/src/main/java/org/apache/beam/sdk/io/range/OffsetRange.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/example/model/Customer.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryInsertError.java runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/RandomAccessData.java sdks/java/core/src/main/java/org/apache/beam/sdk/coders/InstantCoder.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/MutationGroup.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/GetterBasedSchemaProvider.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/OneOfType.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/core/src/main/java/org/apache/beam/sdk/util/SerializableThrowable.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Watch.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/dynamodb/BasicDynamoDbClientProvider.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/dynamodb/BasicDynamoDbClientProvider.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/OneOfType.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/SellerPrice.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/SchemaCoder.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/core/src/main/java/org/apache/beam/sdk/testing/PAssert.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sns/BasicSnsClientProvider.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/io/jms/src/main/java/org/apache/beam/sdk/io/jms/JmsCheckpointMark.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/example/model/Order.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/util/SerializableThrowable.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/core/src/main/java/org/apache/beam/sdk/testing/SuccessOrFailure.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/dynamodb/BasicDynamoDbClientProvider.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/Query5.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/FnApiStateAccessor.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/join/RawUnionValue.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/FromRowUsingCreator.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/ByteBuddyUtils.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/ByteBuddyUtils.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubClient.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sns/BasicSnsClientProvider.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/io/hbase/src/main/java/org/apache/beam/sdk/io/hbase/HBaseIO.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryInsertError.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Person.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/io/hbase/src/main/java/org/apache/beam/sdk/io/hbase/HBaseIO.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/WinningBids.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/Schema.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/testing/PAssert.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileIO.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Watch.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/CachingFactory.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/BidsPerSession.java runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/ReshuffleOverrideFactory.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Reshuffle.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubClient.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/StartingPoint.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Auction.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sns/BasicSnsClientProvider.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/FromRowUsingCreator.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/wire/ByteStringCoder.java sdks/java/core/src/main/java/org/apache/beam/sdk/coders/BigEndianShortCoder.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubClient.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/example/model/Customer.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/core/src/main/java/org/apache/beam/sdk/coders/RowCoder.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/CombineFns.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/Query5.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/gcsfs/GcsPath.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Done.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/join/RawUnionValue.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/BasicSqsClientProvider.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/gcsfs/GcsPath.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sns/BasicSnsClientProvider.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Done.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ApproximateUnique.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/StartingPoint.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/IdNameReserve.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/SqsCheckpointMark.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/sqs/SqsCheckpointMark.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoDomain.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/CombineFns.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/IdNameReserve.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/Schema.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/SellerPrice.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/ByteBuddyUtils.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Auction.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/dynamodb/BasicDynamoDbClientProvider.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sns/BasicSnsAsyncClientProvider.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/core/src/main/java/org/apache/beam/sdk/util/SerializableThrowable.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/EnumerationType.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryInsertError.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Auction.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileIO.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryInsertError.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/FhirSearchParameter.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/MutationGroup.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/join/RawUnionValue.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/join/RawUnionValue.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/CategoryPrice.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ApproximateUnique.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sns/BasicSnsAsyncClientProvider.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiFlushAndFinalizeDoFn.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/example/model/Customer.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/io/hbase/src/main/java/org/apache/beam/sdk/io/hbase/HBaseIO.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/Schema.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/ByteBuddyUtils.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/io/range/OffsetRange.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/sqs/SqsCheckpointMark.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/MutationGroup.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/core/src/main/java/org/apache/beam/sdk/io/range/OffsetRange.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/core/src/main/java/org/apache/beam/sdk/coders/RowCoder.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/FromRowUsingCreator.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Person.java runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/RandomAccessData.java sdks/java/core/src/main/java/org/apache/beam/sdk/coders/BigEndianShortCoder.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoDomain.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sns/BasicSnsAsyncClientProvider.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/StartingPoint.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/SchemaCoder.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/core/src/main/java/org/apache/beam/sdk/testing/SuccessOrFailure.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/SchemaCoder.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/EnumerationType.java runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterAllStateMachine.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterAll.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoDomain.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/core/src/main/java/org/apache/beam/sdk/io/range/OffsetRange.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/core/src/main/java/org/apache/beam/sdk/testing/PAssert.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/example/model/Customer.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sns/BasicSnsAsyncClientProvider.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ApproximateUnique.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/CategoryPrice.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/io/jms/src/main/java/org/apache/beam/sdk/io/jms/JmsCheckpointMark.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/dynamodb/BasicDynamoDbClientProvider.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/StartingPoint.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/CachingFactory.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/StartingPoint.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Event.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sns/BasicSnsClientProvider.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryInsertError.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sns/BasicSnsAsyncClientProvider.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/SqsCheckpointMark.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Person.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/FhirSearchParameter.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Event.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/BidsPerSession.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/BasicSqsClientProvider.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/CachingFactory.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sns/BasicSnsClientProvider.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/Query5.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Event.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/OneOfType.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/EnumerationType.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sns/BasicSnsClientProvider.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/core/src/main/java/org/apache/beam/sdk/coders/RowCoder.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/dynamodb/BasicDynamoDbClientProvider.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/core/src/main/java/org/apache/beam/sdk/coders/RowCoder.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/core/src/main/java/org/apache/beam/sdk/io/range/OffsetRange.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/FhirSearchParameter.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/CombineFns.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/SqsCheckpointMark.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/WinningBids.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/io/jms/src/main/java/org/apache/beam/sdk/io/jms/JmsCheckpointMark.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubClient.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileIO.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/core/src/main/java/org/apache/beam/sdk/util/SerializableThrowable.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/BidsPerSession.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Person.java runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/internal/IsmFormat.java sdks/java/core/src/main/java/org/apache/beam/sdk/coders/BigEndianIntegerCoder.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/IdNameReserve.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/ByteBuddyUtils.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ApproximateUnique.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/CachingFactory.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/CategoryPrice.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/io/hbase/src/main/java/org/apache/beam/sdk/io/hbase/HBaseIO.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/gcsfs/GcsPath.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/CategoryPrice.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/GetterBasedSchemaProvider.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/BasicSqsClientProvider.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Person.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sns/BasicSnsAsyncClientProvider.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/CategoryPrice.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/EnumerationType.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/sqs/SqsCheckpointMark.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/FhirSearchParameter.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/testing/SuccessOrFailure.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/core/src/main/java/org/apache/beam/sdk/testing/SuccessOrFailure.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/GetterBasedSchemaProvider.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/BidsPerSession.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ApproximateUnique.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/FromRowUsingCreator.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Event.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/OneOfType.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/join/RawUnionValue.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/SellerPrice.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/join/RawUnionValue.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/IdNameReserve.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/core/src/main/java/org/apache/beam/sdk/util/SerializableThrowable.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/BidsPerSession.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/FromRowUsingCreator.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/BasicSqsClientProvider.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/WinningBids.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/FhirSearchParameter.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/IdNameReserve.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoDomain.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/CategoryPrice.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/WinningBids.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/SellerPrice.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/AuctionBid.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/StartingPoint.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/EnumerationType.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/core/src/main/java/org/apache/beam/sdk/testing/PAssert.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/example/model/Customer.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/example/model/Order.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sns/BasicSnsClientProvider.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/SqsCheckpointMark.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/AuctionBid.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/SchemaCoder.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/StartingPoint.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/SellerPrice.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ApproximateUnique.java runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/RandomAccessData.java sdks/java/core/src/main/java/org/apache/beam/sdk/coders/VarIntCoder.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/StartingPoint.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/sqs/SqsCheckpointMark.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/io/hbase/src/main/java/org/apache/beam/sdk/io/hbase/HBaseIO.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/MutationGroup.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/io/hbase/src/main/java/org/apache/beam/sdk/io/hbase/HBaseIO.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiFlushAndFinalizeDoFn.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/StartingPoint.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sns/BasicSnsClientProvider.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/io/hbase/src/main/java/org/apache/beam/sdk/io/hbase/HBaseIO.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/FromRowUsingCreator.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/AuctionBid.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/StartingPoint.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/StartingPoint.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/core/src/main/java/org/apache/beam/sdk/testing/SuccessOrFailure.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Event.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiFlushAndFinalizeDoFn.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/example/model/Order.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Auction.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/sources/generator/Generator.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Person.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/io/jms/src/main/java/org/apache/beam/sdk/io/jms/JmsCheckpointMark.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/core/src/main/java/org/apache/beam/sdk/coders/RowCoder.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/MutationGroup.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiFlushAndFinalizeDoFn.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sns/BasicSnsAsyncClientProvider.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/BasicSqsClientProvider.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/example/model/Customer.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/dynamodb/BasicDynamoDbClientProvider.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/example/model/Order.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Done.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiFlushAndFinalizeDoFn.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileIO.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/BidsPerSession.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/IdNameReserve.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/example/model/Order.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/StartingPoint.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubClient.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/coders/RowCoder.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/sqs/SqsCheckpointMark.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/core/src/main/java/org/apache/beam/sdk/testing/PAssert.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/BidsPerSession.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/sources/generator/Generator.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/IdNameReserve.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Auction.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/BidsPerSession.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/example/model/Customer.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/Schema.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/io/jms/src/main/java/org/apache/beam/sdk/io/jms/JmsCheckpointMark.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/gcsfs/GcsPath.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Auction.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/FhirSearchParameter.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/SchemaCoder.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/sqs/SqsCheckpointMark.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/core/src/main/java/org/apache/beam/sdk/io/range/OffsetRange.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/bigquery/BeamSqlUnparseContext.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/core/src/main/java/org/apache/beam/sdk/testing/SuccessOrFailure.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Auction.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/core/src/main/java/org/apache/beam/sdk/util/SerializableThrowable.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/WinningBids.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Watch.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/WinningBids.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/BasicSqsClientProvider.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubClient.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/Query5.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sns/BasicSnsAsyncClientProvider.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/CombineFns.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/BidsPerSession.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiFlushAndFinalizeDoFn.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sns/BasicSnsClientProvider.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/example/model/Order.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Person.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/Schema.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryInsertError.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/CachingFactory.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/IdNameReserve.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/OneOfType.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoDomain.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/EnumerationType.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/core/src/main/java/org/apache/beam/sdk/testing/PAssert.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/gcsfs/GcsPath.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Done.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/CombineFns.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/core/src/main/java/org/apache/beam/sdk/util/SerializableThrowable.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/dynamodb/BasicDynamoDbClientProvider.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/Schema.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/OneOfType.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/GetterBasedSchemaProvider.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sns/BasicSnsAsyncClientProvider.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Auction.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/join/RawUnionValue.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Watch.java runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/internal/IsmFormat.java sdks/java/core/src/main/java/org/apache/beam/sdk/coders/BigEndianShortCoder.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/EnumerationType.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/core/src/main/java/org/apache/beam/sdk/testing/PAssert.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/io/jms/src/main/java/org/apache/beam/sdk/io/jms/JmsCheckpointMark.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/StartingPoint.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/GetterBasedSchemaProvider.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sns/BasicSnsClientProvider.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileIO.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Event.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/StartingPoint.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/core/src/main/java/org/apache/beam/sdk/io/range/OffsetRange.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/io/jms/src/main/java/org/apache/beam/sdk/io/jms/JmsCheckpointMark.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/SqsCheckpointMark.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/StartingPoint.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/core/src/main/java/org/apache/beam/sdk/util/SerializableThrowable.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiFlushAndFinalizeDoFn.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ApproximateUnique.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Done.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryInsertError.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/sources/generator/Generator.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/example/model/Customer.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/gcsfs/GcsPath.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubClient.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/Query5.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/io/jms/src/main/java/org/apache/beam/sdk/io/jms/JmsCheckpointMark.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/util/SerializableThrowable.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/CachingFactory.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/example/model/Customer.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Event.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/CombineFns.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/core/src/main/java/org/apache/beam/sdk/io/range/OffsetRange.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/AuctionBid.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/Query5.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/coders/RowCoder.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/core/src/main/java/org/apache/beam/sdk/testing/SuccessOrFailure.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/wire/ByteStringCoder.java sdks/java/core/src/main/java/org/apache/beam/sdk/coders/StringUtf8Coder.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Person.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/Schema.java runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/IsmSideInputReader.java sdks/java/core/src/main/java/org/apache/beam/sdk/values/PCollectionViews.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/SchemaCoder.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/SqsCheckpointMark.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/SqsCheckpointMark.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/CachingFactory.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/FhirSearchParameter.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/GetterBasedSchemaProvider.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/Schema.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/BidsPerSession.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/CombineFns.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/CombineFns.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Watch.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/Schema.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/GetterBasedSchemaProvider.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Auction.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Event.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/SchemaCoder.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ApproximateUnique.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/core/src/main/java/org/apache/beam/sdk/util/SerializableThrowable.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Person.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/CachingFactory.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/AuctionBid.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/dynamodb/BasicDynamoDbClientProvider.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/WinningBids.java runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterEachStateMachine.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterEach.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/SellerPrice.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/Query5.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/sqs/SqsCheckpointMark.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/CombineFns.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Watch.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiFlushAndFinalizeDoFn.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/core/src/main/java/org/apache/beam/sdk/coders/RowCoder.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiFlushAndFinalizeDoFn.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Watch.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/IdNameReserve.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/StartingPoint.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/WinningBids.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/sqs/SqsCheckpointMark.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/AuctionBid.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Person.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Watch.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoDomain.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/ByteBuddyUtils.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Event.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/BasicSqsClientProvider.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/BidsPerSession.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/OneOfType.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Done.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/sources/generator/Generator.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/OneOfType.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Auction.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/wire/ByteStringCoder.java sdks/java/core/src/main/java/org/apache/beam/sdk/coders/InstantCoder.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/GetterBasedSchemaProvider.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/CombineFns.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/example/model/Customer.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ApproximateUnique.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/core/src/main/java/org/apache/beam/sdk/coders/RowCoder.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/FnApiStateAccessor.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sns/BasicSnsAsyncClientProvider.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/SellerPrice.java runners/core-java/src/main/java/org/apache/beam/runners/core/StateTags.java sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/FnApiStateAccessor.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiFlushAndFinalizeDoFn.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Watch.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/io/jms/src/main/java/org/apache/beam/sdk/io/jms/JmsCheckpointMark.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Watch.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/dynamodb/BasicDynamoDbClientProvider.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/OneOfType.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/sqs/SqsCheckpointMark.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/Schema.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/MutationGroup.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/join/RawUnionValue.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/CategoryPrice.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ApproximateUnique.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Watch.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoDomain.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/SchemaCoder.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/sources/generator/Generator.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/MutationGroup.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoDomain.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/SchemaCoder.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/FhirSearchParameter.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/FromRowUsingCreator.java runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/UngroupedShuffleReader.java sdks/java/io/cassandra/src/main/java/org/apache/beam/sdk/io/cassandra/CassandraIO.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Auction.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/sources/generator/Generator.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/FhirSearchParameter.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/OneOfType.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/GetterBasedSchemaProvider.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/SqsCheckpointMark.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/example/model/Customer.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Event.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/CategoryPrice.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/SellerPrice.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoDomain.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/BidsPerSession.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/Query5.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/IdNameReserve.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/MutationGroup.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sns/BasicSnsAsyncClientProvider.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/IdNameReserve.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/FromRowUsingCreator.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/MutationGroup.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/GetterBasedSchemaProvider.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/CachingFactory.java runners/core-java/src/main/java/org/apache/beam/runners/core/SimpleDoFnRunner.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnInvoker.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/example/model/Order.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Auction.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/CombineFns.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoDomain.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/MutationGroup.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/FhirSearchParameter.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/StartingPoint.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/wire/ByteStringCoder.java sdks/java/core/src/main/java/org/apache/beam/sdk/coders/VarIntCoder.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/io/jms/src/main/java/org/apache/beam/sdk/io/jms/JmsCheckpointMark.java runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/RandomAccessData.java sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ByteStringCoder.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiFlushAndFinalizeDoFn.java runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/internal/IsmFormat.java sdks/java/core/src/main/java/org/apache/beam/sdk/coders/InstantCoder.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sns/BasicSnsClientProvider.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/join/RawUnionValue.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/AuctionBid.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileIO.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/core/src/main/java/org/apache/beam/sdk/io/range/OffsetRange.java runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/RandomAccessData.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/GlobalWindow.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/example/model/Order.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryInsertError.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/io/jms/src/main/java/org/apache/beam/sdk/io/jms/JmsCheckpointMark.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/BasicSqsClientProvider.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/io/jms/src/main/java/org/apache/beam/sdk/io/jms/JmsCheckpointMark.java runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/RandomAccessData.java sdks/java/core/src/main/java/org/apache/beam/sdk/coders/StringUtf8Coder.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/OneOfType.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/EnumerationType.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryInsertError.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/CachingFactory.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Done.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/FromRowUsingCreator.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/EnumerationType.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/Schema.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Done.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/CategoryPrice.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/CategoryPrice.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Person.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/GetterBasedSchemaProvider.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Event.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Person.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/core/src/main/java/org/apache/beam/sdk/testing/PAssert.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/SellerPrice.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Done.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/MutationGroup.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/GetterBasedSchemaProvider.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/wire/ByteStringCoder.java sdks/java/core/src/main/java/org/apache/beam/sdk/coders/BigEndianLongCoder.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/core/src/main/java/org/apache/beam/sdk/util/SerializableThrowable.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/EnumerationType.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/ByteBuddyUtils.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/FromRowUsingCreator.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileIO.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/BasicSqsClientProvider.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/MutationGroup.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/GetterBasedSchemaProvider.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java sdks/java/core/src/main/java/org/apache/beam/sdk/coders/RowCoder.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoDomain.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/WinningBids.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/MutationGroup.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoDomain.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ApproximateUnique.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Done.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/SchemaCoder.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/FromRowUsingCreator.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/core/src/main/java/org/apache/beam/sdk/testing/PAssert.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/OneOfType.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/StartingPoint.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/core/src/main/java/org/apache/beam/sdk/testing/SuccessOrFailure.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/SqsCheckpointMark.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/core/src/main/java/org/apache/beam/sdk/util/SerializableThrowable.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/CachingFactory.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/testing/PAssert.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/core/src/main/java/org/apache/beam/sdk/coders/RowCoder.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/core/src/main/java/org/apache/beam/sdk/io/range/OffsetRange.java runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/ValueInEmptyWindows.java sdks/java/core/src/main/java/org/apache/beam/sdk/util/WindowedValue.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/io/jms/src/main/java/org/apache/beam/sdk/io/jms/JmsCheckpointMark.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/Query5.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/core/src/main/java/org/apache/beam/sdk/io/range/OffsetRange.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/core/src/main/java/org/apache/beam/sdk/testing/SuccessOrFailure.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/join/RawUnionValue.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Done.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sns/BasicSnsAsyncClientProvider.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/SqsCheckpointMark.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/ByteBuddyUtils.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sns/BasicSnsAsyncClientProvider.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/example/model/Customer.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/sqs/SqsCheckpointMark.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/OneOfType.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/CachingFactory.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/Query5.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Auction.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/core/src/main/java/org/apache/beam/sdk/testing/PAssert.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/core/src/main/java/org/apache/beam/sdk/testing/SuccessOrFailure.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Done.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/ByteBuddyUtils.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/SqsCheckpointMark.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/core/src/main/java/org/apache/beam/sdk/coders/RowCoder.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/testing/PAssert.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/wire/ByteStringCoder.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/GlobalWindow.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileIO.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Auction.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/Query5.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/StartingPoint.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/core/src/main/java/org/apache/beam/sdk/coders/RowCoder.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Done.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/IdNameReserve.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/FhirSearchParameter.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/core/src/main/java/org/apache/beam/sdk/testing/PAssert.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Event.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/SellerPrice.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/sources/generator/Generator.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/Query5.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/example/model/Customer.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiFlushAndFinalizeDoFn.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/IdNameReserve.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sns/BasicSnsClientProvider.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/core/src/main/java/org/apache/beam/sdk/util/SerializableThrowable.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileIO.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/join/RawUnionValue.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/EnumerationType.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileIO.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/IdNameReserve.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sns/BasicSnsAsyncClientProvider.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Watch.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/wire/ByteStringCoder.java sdks/java/core/src/main/java/org/apache/beam/sdk/coders/BigEndianIntegerCoder.java runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/AuctionBid.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryInsertError.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/core/src/main/java/org/apache/beam/sdk/coders/RowCoder.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/IdNameReserve.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/sources/generator/Generator.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/EnumerationType.java runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/RandomAccessData.java sdks/java/core/src/main/java/org/apache/beam/sdk/coders/BigEndianIntegerCoder.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/sqs/SqsCheckpointMark.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Watch.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/AuctionBid.java runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/fn/data/BeamFnDataGrpcService.java sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/CompletableFutureInboundDataClient.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ApproximateUnique.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/StartingPoint.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/sources/generator/Generator.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java sdks/java/core/src/main/java/org/apache/beam/sdk/util/SerializableThrowable.java runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java sdks/java/core/src/main/java/org/apache/beam/sdk/testing/SuccessOrFailure.java runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/FromRowUsingCreator.java runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java sdks/java/core/src/main/java/org/apache/beam/sdk/testing/PAssert.java runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/sources/generator/Generator.java runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/dynamodb/BasicDynamoDbClientProvider.java runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Person.java runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/example/model/Order.java