This is an automated email from the ASF dual-hosted git repository.
bhulette pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 08e0998 Merge pull request #15753 from [BEAM-13080] Add option in
Reshuffle to set num of keys generated.
add a4e1129 [BEAM-11936] Fix errorprone warnings (#15821)
No new revisions were added by this update.
Summary of changes:
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 4 -
.../apache/beam/examples/snippets/Snippets.java | 8 +-
.../apache/beam/runners/core/SimpleDoFnRunner.java | 9 +-
.../beam/runners/core/StatefulDoFnRunner.java | 5 +-
.../AfterDelayFromFirstElementStateMachine.java | 4 +-
.../runners/core/InMemoryTimerInternalsTest.java | 5 +-
.../beam/runners/core/ReduceFnRunnerTest.java | 6 +-
.../SimplePushbackSideInputDoFnRunnerTest.java | 22 ++-
.../beam/runners/core/StatefulDoFnRunnerTest.java | 76 +++++---
.../runners/direct/WatermarkCallbackExecutor.java | 4 +-
.../runners/direct/SideInputContainerTest.java | 15 +-
.../direct/StatefulParDoEvaluatorFactoryTest.java | 16 +-
.../beam/runners/direct/WatermarkManagerTest.java | 4 +-
.../runners/direct/WindowEvaluatorFactoryTest.java | 7 +-
.../streaming/ExecutableStageDoFnOperator.java | 7 +-
.../wrappers/streaming/DoFnOperatorTest.java | 29 +--
.../streaming/ExecutableStageDoFnOperatorTest.java | 10 +-
.../beam/runners/dataflow/DataflowRunner.java | 14 +-
.../runners/dataflow/worker/SimpleParDoFn.java | 10 +-
.../dataflow/worker/WindmillStateInternals.java | 2 +-
.../fn/control/ProcessRemoteBundleOperation.java | 3 +
.../dataflow/worker/GroupingShuffleReaderTest.java | 4 +-
.../worker/PartitioningShuffleReaderTest.java | 4 +-
.../runners/dataflow/worker/ShuffleSinkTest.java | 4 +-
.../worker/StreamingModeExecutionContextTest.java | 2 +-
.../worker/UngroupedShuffleReaderTest.java | 4 +-
.../dataflow/worker/UserParDoFnFactoryTest.java | 12 +-
.../worker/WindmillTimerInternalsTest.java | 13 +-
.../control/BundleCheckpointHandlers.java | 5 +-
.../fnexecution/control/RemoteExecutionTest.java | 15 +-
.../portability/JobServicePipelineResult.java | 2 +-
.../samza/adapter/UnboundedSourceSystemTest.java | 9 +-
.../beam/runners/spark/io/MicrobatchSource.java | 4 +-
.../GroupNonMergingWindowsFunctionsTest.java | 2 +-
.../spark/translation/SparkCombineFnTest.java | 18 +-
.../spark/translation/TransformTranslatorTest.java | 13 +-
.../translation/streaming/CreateStreamTest.java | 4 +-
.../beam/sdk/schemas/FieldAccessDescriptor.java | 4 +-
.../apache/beam/sdk/schemas/transforms/Cast.java | 4 +-
.../apache/beam/sdk/schemas/transforms/Join.java | 68 +++----
.../beam/sdk/schemas/utils/ByteBuddyUtils.java | 13 +-
.../sdk/schemas/utils/SelectByteBuddyHelpers.java | 10 +-
.../org/apache/beam/sdk/transforms/Combine.java | 34 ++--
.../org/apache/beam/sdk/transforms/CombineFns.java | 15 +-
.../java/org/apache/beam/sdk/transforms/Reify.java | 8 +-
.../reflect/ByteBuddyDoFnInvokerFactory.java | 12 +-
.../splittabledofn/ByteKeyRangeTracker.java | 4 +-
.../sdk/transforms/windowing/FixedWindows.java | 2 +-
.../sdk/transforms/windowing/IntervalWindow.java | 2 +-
.../org/apache/beam/sdk/util/FluentBackoff.java | 2 +-
.../apache/beam/sdk/coders/CoderRegistryTest.java | 2 +-
.../apache/beam/sdk/io/GenerateSequenceTest.java | 2 +-
.../test/java/org/apache/beam/sdk/io/ReadTest.java | 2 +-
.../beam/sdk/schemas/transforms/GroupTest.java | 10 +-
.../apache/beam/sdk/testing/TestStreamTest.java | 6 +-
.../apache/beam/sdk/transforms/LatestFnTest.java | 7 +-
.../org/apache/beam/sdk/transforms/ParDoTest.java | 38 ++--
.../beam/sdk/transforms/PeriodicImpulseTest.java | 4 +-
.../beam/sdk/transforms/PeriodicSequenceTest.java | 4 +-
.../org/apache/beam/sdk/transforms/WaitTest.java | 5 +-
.../beam/sdk/transforms/WithTimestampsTest.java | 3 +-
.../sdk/transforms/reflect/DoFnInvokersTest.java | 1 +
.../sdk/transforms/reflect/DoFnSignaturesTest.java | 2 +-
.../splittabledofn/WatermarkEstimatorsTest.java | 27 ++-
.../sdk/transforms/windowing/FixedWindowsTest.java | 3 +-
.../beam/sdk/transforms/windowing/WindowTest.java | 3 +-
.../apache/beam/sdk/util/WindowedValueTest.java | 22 ++-
.../impl/transform/BeamBuiltinAggregations.java | 42 ++--
.../server/GrpcContextHeaderAccessorProvider.java | 2 +
.../beam/sdk/fn/stream/PrefetchableIterables.java | 9 +-
.../fn/splittabledofn/WatermarkEstimatorsTest.java | 3 +-
.../apache/beam/fn/harness/FnApiDoFnRunner.java | 16 +-
.../beam/fn/harness/FnApiDoFnRunnerTest.java | 215 +++++++++++++++------
.../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 56 +++---
.../bigquery/StorageApiWriteUnshardedRecords.java | 2 +-
.../sdk/io/gcp/firestore/FirestoreV1WriteFn.java | 3 +-
.../beam/sdk/io/gcp/firestore/RpcQosImpl.java | 4 +-
.../apache/beam/sdk/io/gcp/healthcare/HL7v2IO.java | 11 +-
.../apache/beam/sdk/io/gcp/pubsub/PubsubIO.java | 28 +--
.../io/gcp/spanner/SpannerTransformRegistrar.java | 6 +-
.../sdk/io/gcp/healthcare/HL7v2IOTestUtil.java | 4 +-
.../java/org/apache/beam/sdk/io/hbase/HBaseIO.java | 4 +-
.../java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 18 +-
.../sdk/io/kafka/WatchKafkaTopicPartitionDoFn.java | 2 +-
.../io/kafka/WatchKafkaTopicPartitionDoFnTest.java | 9 +-
.../beam/sdk/loadtests/SideInputLoadTest.java | 2 +-
.../beam/sdk/nexmark/queries/WinningBids.java | 6 +-
87 files changed, 683 insertions(+), 453 deletions(-)
