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(-)
