This is an automated email from the ASF dual-hosted git repository. kenn pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
commit e8df60381a39327200ae70f38b569b9126e3ae5e Merge: 574e7bfbc1d 7fb05cbb5e1 Author: Kenneth Knowles <k...@apache.org> AuthorDate: Thu Feb 1 21:39:14 2024 -0500 Merge pull request #30170: Move the code from sdks-java-fn-execution to sdks-java-core runners/core-construction-java/build.gradle | 1 - runners/core-java/build.gradle | 1 - runners/direct-java/build.gradle | 1 - runners/flink/flink_runner.gradle | 1 - runners/google-cloud-dataflow-java/worker/build.gradle | 5 ----- runners/java-fn-execution/build.gradle | 1 - runners/java-job-service/build.gradle | 1 - runners/samza/build.gradle | 1 - runners/spark/spark_runner.gradle | 1 - sdks/java/core/build.gradle | 2 ++ .../main/java/org/apache/beam/sdk/fn/CancellableQueue.java | 0 .../src/main/java/org/apache/beam/sdk/fn/IdGenerator.java | 0 .../src/main/java/org/apache/beam/sdk/fn/IdGenerators.java | 0 .../main/java/org/apache/beam/sdk/fn/JvmInitializers.java | 0 .../beam/sdk/fn/channel/AddHarnessIdInterceptor.java | 0 .../apache/beam/sdk/fn/channel/ManagedChannelFactory.java | 0 .../apache/beam/sdk/fn/channel/SocketAddressFactory.java | 0 .../java/org/apache/beam/sdk/fn/channel/package-info.java | 0 .../apache/beam/sdk/fn/data/BeamFnDataGrpcMultiplexer.java | 0 .../apache/beam/sdk/fn/data/BeamFnDataInboundObserver.java | 0 .../beam/sdk/fn/data/BeamFnDataOutboundAggregator.java | 0 .../apache/beam/sdk/fn/data/CloseableFnDataReceiver.java | 0 .../java/org/apache/beam/sdk/fn/data/DataEndpoint.java | 0 .../apache/beam/sdk/fn/data/DecodingFnDataReceiver.java | 0 .../java/org/apache/beam/sdk/fn/data/FnDataReceiver.java | 0 .../java/org/apache/beam/sdk/fn/data/LogicalEndpoint.java | 0 .../org/apache/beam/sdk/fn/data/RemoteGrpcPortRead.java | 0 .../org/apache/beam/sdk/fn/data/RemoteGrpcPortWrite.java | 0 .../java/org/apache/beam/sdk/fn/data/TimerEndpoint.java | 0 .../java/org/apache/beam/sdk/fn/data/WeightedList.java | 0 .../java/org/apache/beam/sdk/fn/data/package-info.java | 0 .../src/main/java/org/apache/beam/sdk/fn/package-info.java | 0 .../main/java/org/apache/beam/sdk/fn/server/FnService.java | 0 .../sdk/fn/server/GrpcContextHeaderAccessorProvider.java | 0 .../java/org/apache/beam/sdk/fn/server/GrpcFnServer.java | 0 .../java/org/apache/beam/sdk/fn/server/HeaderAccessor.java | 0 .../apache/beam/sdk/fn/server/InProcessServerFactory.java | 0 .../java/org/apache/beam/sdk/fn/server/ServerFactory.java | 0 .../java/org/apache/beam/sdk/fn/server/package-info.java | 0 .../beam/sdk/fn/splittabledofn/RestrictionTrackers.java | 0 .../beam/sdk/fn/splittabledofn/WatermarkEstimators.java | 0 .../apache/beam/sdk/fn/splittabledofn/package-info.java | 0 .../org/apache/beam/sdk/fn/stream/AdvancingPhaser.java | 0 .../apache/beam/sdk/fn/stream/BufferingStreamObserver.java | 0 .../java/org/apache/beam/sdk/fn/stream/DataStreams.java | 0 .../apache/beam/sdk/fn/stream/DirectStreamObserver.java | 0 .../sdk/fn/stream/ForwardingClientResponseObserver.java | 0 .../apache/beam/sdk/fn/stream/OutboundObserverFactory.java | 0 .../apache/beam/sdk/fn/stream/PrefetchableIterable.java | 0 .../apache/beam/sdk/fn/stream/PrefetchableIterables.java | 0 .../apache/beam/sdk/fn/stream/PrefetchableIterator.java | 0 .../apache/beam/sdk/fn/stream/PrefetchableIterators.java | 0 .../beam/sdk/fn/stream/SynchronizedStreamObserver.java | 0 .../java/org/apache/beam/sdk/fn/stream/package-info.java | 0 .../java/org/apache/beam/sdk/fn/test/TestExecutors.java | 0 .../main/java/org/apache/beam/sdk/fn/test/TestStreams.java | 0 .../java/org/apache/beam/sdk/fn/test/package-info.java | 0 .../apache/beam/sdk/fn/windowing/EncodedBoundedWindow.java | 0 .../org/apache/beam/sdk/fn/windowing/package-info.java | 0 .../java/org/apache/beam/sdk/fn/CancellableQueueTest.java | 0 .../test/java/org/apache/beam/sdk/fn/IdGeneratorsTest.java | 0 .../java/org/apache/beam/sdk/fn/JvmInitializersTest.java | 5 +++-- .../beam/sdk/fn/channel/ManagedChannelFactoryTest.java | 0 .../beam/sdk/fn/channel/SocketAddressFactoryTest.java | 0 .../beam/sdk/fn/data/BeamFnDataGrpcMultiplexerTest.java | 0 .../beam/sdk/fn/data/BeamFnDataInboundObserverTest.java | 14 +++++++++----- .../beam/sdk/fn/data/BeamFnDataOutboundAggregatorTest.java | 0 .../apache/beam/sdk/fn/data/RemoteGrpcPortReadTest.java | 0 .../apache/beam/sdk/fn/data/RemoteGrpcPortWriteTest.java | 0 .../sdk/fn/splittabledofn/RestrictionTrackersTest.java | 0 .../sdk/fn/splittabledofn/WatermarkEstimatorsTest.java | 0 .../org/apache/beam/sdk/fn/stream/AdvancingPhaserTest.java | 0 .../beam/sdk/fn/stream/BufferingStreamObserverTest.java | 0 .../org/apache/beam/sdk/fn/stream/DataStreamsTest.java | 0 .../beam/sdk/fn/stream/DirectStreamObserverTest.java | 0 .../fn/stream/ForwardingClientResponseObserverTest.java | 0 .../beam/sdk/fn/stream/OutboundObserverFactoryTest.java | 0 .../beam/sdk/fn/stream/PrefetchableIterablesTest.java | 0 .../beam/sdk/fn/stream/PrefetchableIteratorsTest.java | 0 .../org/apache/beam/sdk/fn/test/TestExecutorsTest.java | 0 .../java/org/apache/beam/sdk/fn/test/TestStreamsTest.java | 0 .../beam/sdk/fn/windowing/EncodedBoundedWindowTest.java | 0 sdks/java/fn-execution/build.gradle | 9 --------- sdks/java/harness/build.gradle | 1 - sdks/java/harness/jmh/build.gradle | 3 +++ .../org/apache/beam/fn/harness/BeamFnDataWriteRunner.java | 1 - sdks/java/transform-service/build.gradle | 1 - 87 files changed, 17 insertions(+), 32 deletions(-)