This is an automated email from the ASF dual-hosted git repository.
anandinguva pushed a change to branch hf_inference_api_
in repository https://gitbox.apache.org/repos/asf/beam.git
from 13f018e890a Pass env variable to the right environment
add 6243894e76c WIP
add f5d1ec59078 fix test
add 3172736aaa3 Update Python Dependencies (#30140)
add dde81384ef2 Fix clean up stale container workflow (#30132)
add c9135e00041 Add info on getting started contributing (#30143)
add b72eacfba37 make getProcessingDistributionsForWorkId threadsafe
(#29979)
add c1c81b36187 Respect gcloud active configuration, if any, rather than
always using "default."
add ee4f8cb33f9 Merge pull request #30134 Respect gcloud active
configuration.
add 847a8f4486e [YAML] Improve docs on create.
add 8521d2768e0 [YAML] Better document naming parameter.
add ba29583d46c [YAML] Move pipeline running instructions to the top.
add e70a28acbd4 [YAML] Link to additonal resources.
add b85e1ebaea3 Some clarification on the mapping docs.
add 09aacf1003c Another note useful for trying things out.
add 799c1041473 Avoid SQL keywords for SQL table names.
add afd8b79e8e0 Clarification on aggregating transform based on user
feedback.
add 88bf2fc94fe Update sdks/python/apache_beam/yaml/yaml_provider.py
add b835111d66f Make note about requiring Graphviz for rendering pipelines.
add 3970b618371 Merge branch 'master' into yaml-create-doc
add b5dc54da26f Also mention JavaScript.
add e199e42a341 Fix whitespace in create suggestion.
add ce28c33940c Merge pull request #30007 [YAML] Several improvements to
the documentation.
add f9029616a91 Update environments.md (#30149)
add 097e6e27bfe Bump actions/cache from 3 to 4 (#30033)
add f9c9788815e Update 02_io_pubsub.md (#29986)
add 5a9a27cbafa Volatile heartbeat (#30148)
add b9fd39cb16b Fix Dataproc cleanup race condition (#30154)
add 22fefebacab BigQuery: Decouple clustering from time partitioning when
writing (#30094)
add 415b1658f50 Merge pull request #30137: Fix a misspelling in zetasql
overview page
add 1df9d6bba91 Bumping timeout for beam_PostCommit_Java_DataflowV2
(#30160)
add 4c5ee349f9b [sdks-java-core] Test for Reiterator outside loop in
CoGbkResult
add 36cab4ffe76 Merge pull request #30163: [sdks-java-core] Test for
Reiterator outside loop in CoGbkResult
add 41dee464db4 Make ReadFromBigQueryRequest id more randomized (#30156)
add 81513f10d60 Bump github.com/aws/aws-sdk-go-v2/credentials in /sdks
(#30162)
add 89d1c06e1ea Fix Fhir IO Search IT (#30158)
add a221f98a5f4 fix: fix error handling in segment reader and add an
integration test (#30147)
add ddb93272ab6 Fix git trusted directory errors in website build. (#30171)
add 30917ff7b3e Don't use '-' as a delimiter in BigQuerySinkMetrics
(#30118)
add fb0762352c2 Periodically send perWorkerMetrics on the WorkerMessages
API (#30135)
add 4f09e62f520 Improve varint encoding throughput with unrolled loop
(#29689)
add 5188e37ed44 Bump github.com/opencontainers/runc from 1.1.5 to 1.1.12
in /sdks (#30175)
add 96cf695a101 Fix JdbcIO PreCommit mysql breaking change (#30179)
add 824e06cd967 Allow stale_bq_datasets_cleaner.sh to run to completion,
even when there are failures to grab a dataset (#30153)
add 1d9f6044c76 Remove constraint introduced in #30059 (#30186)
add bdbbef9b54d [YAML] - PubSubLite proto (#30129)
add 1a5466b7df7 Support dict as the input of delete_batch (#30188)
add 574e7bfbc1d Fix script typos for validating docker licenses. (#30176)
add 7fb05cbb5e1 Move the code from sdks-java-fn-execution to sdks-java-core
add e8df60381a3 Merge pull request #30170: Move the code from
sdks-java-fn-execution to sdks-java-core
add 124880bc8ce Fix typo affecting
DataflowPipelineDebugOptions.setStreamingSideInputCacheExpirationMillis (#30195)
add 1f69271044d [Dataflow Streaming] Add a option to use multiple commit
threads (#30194)
add 1183b5d5274 Knowledge lookup prompts: (#29747)
add 801682930e2 Bump google.golang.org/protobuf from 1.31.0 to 1.32.0 in
/sdks (#29913)
add 30a778b9cbe Bump github.com/containerd/containerd from 1.7.7 to 1.7.11
in /sdks (#29823)
add f03b115830b Remove extraneous mocking that was causing NPEs in
DataflowWorkUnitClientTest
add 00f07864784 Remove sdks/java/fn-execution
add 8ec51f181a0 Merge pull request #30193: Remove sdks/java/fn-execution
add 9f8dda274dc Split standalone transform service application from
launcher jar (#30190)
add f2056e72dea Fix stale dataflow prebuilt image cleaner (#30168)
add 34bbbda9f98 Try a different approach for cibuildwheel flake. (#30204)
add 1a1ff756f86 Bump golang.org/x/sync from 0.5.0 to 0.6.0 in /sdks
(#30209)
add c1b3a27ee0c Bump github.com/nats-io/nats-server/v2 from 2.10.7 to
2.10.10 in /sdks (#30210)
add a47b1faa527 [Prism] Implement jobservices.Server Cancel (#30178)
add 7f91baadcf2 Upgrade website node to LTS (#30213)
add d5aa44c9ba9 Handle a user whose account was deleted. (#30192)
add a341eb69abe Added default watermark generation interval (apache#30141)
add cd5f2711c83 Merge pull request #30141: Adding a default watermark emit
interval for FlinkUnboundedSourceReader
add b0f2eebb024 When failing work items during commit, make sure to call
completeWork… (#30215)
add 23dcb7ec1d5 Revert "When failing work items during commit, make sure
to call completeWork…" (#30228)
add 5494f114382 [Dataflow Streaming] Invalidate caches and remove work on
failure before commit (#30229)
add 27f1c0774fd Bump github.com/tetratelabs/wazero from 1.5.0 to 1.6.0 in
/sdks (#30222)
add 7a59dc6a63e Merge remote-tracking branch 'origin/master' into
hf_inference_api_
No new revisions were added by this update.
Summary of changes:
...w.json => beam_PostCommit_Java_DataflowV2.json} | 0
.github/workflows/README.md | 1 +
.github/workflows/beam_CancelStaleDataflowJobs.yml | 2 +
.../workflows/beam_CleanUpDataprocResources.yml | 2 +-
.github/workflows/beam_CleanUpGCPResources.yml | 2 +
.../workflows/beam_CleanUpPrebuiltSDKImages.yml | 8 +-
.../workflows/beam_PostCommit_Java_DataflowV2.yml | 4 +-
.github/workflows/playground_frontend_test.yml | 2 +-
.github/workflows/tour_of_beam_frontend_test.yml | 2 +-
.test-infra/dataproc/cleanup.sh | 4 +-
.test-infra/metrics/sync/github/sync_workflows.py | 12 +-
.test-infra/tools/stale_bq_datasets_cleaner.sh | 34 ++-
.../tools/stale_dataflow_prebuilt_image_cleaner.sh | 103 ++++---
CHANGES.md | 3 +-
build.gradle.kts | 2 +-
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 6 +-
contributor-docs/release-guide.md | 6 +-
learning/prompts/README.md | 76 ++++++
learning/prompts/code-explanation/01_io_kafka.md | 65 +++++
.../02_io_pubsub.md | 8 +-
.../prompts/code-explanation/03_io_bigquery.md | 39 +++
.../prompts/code-explanation/04_io_bigtable.md | 44 +++
learning/prompts/code-explanation/05_io_spanner.md | 96 +++++++
.../prompts/code-explanation/06_io_tfrecord.md | 63 +++++
learning/prompts/code-explanation/07_io_json.md | 50 ++++
learning/prompts/code-explanation/08_io_csv.md | 44 +++
learning/prompts/code-explanation/09_io_avro.md | 41 +++
learning/prompts/code-explanation/10_io_parquet.md | 39 +++
learning/prompts/code-explanation/11_io_jdbc.md | 105 +++++++
learning/prompts/code-generation/01_io_kafka.md | 46 ++++
learning/prompts/code-generation/03_io_bigquery.md | 54 ++++
learning/prompts/code-generation/04_io_bigtable.md | 66 +++++
learning/prompts/code-generation/05_io_spanner.md | 63 +++++
learning/prompts/code-generation/06_io_tfrecord.md | 60 ++++
learning/prompts/code-generation/07_io_json.md | 48 ++++
learning/prompts/code-generation/08_io_csv.md | 47 ++++
learning/prompts/code-generation/09_io_avro.md | 42 +++
learning/prompts/code-generation/10_io_parquet.md | 39 +++
learning/prompts/code-generation/11_io_jdbc.md | 75 +++++
.../prompts/documentation-lookup/18_io_kafka.md | 27 ++
.../prompts/documentation-lookup/21_io_bigtable.md | 28 ++
.../prompts/documentation-lookup/22_io_spanner.md | 31 +++
learning/prompts/documentation-lookup/23_io_gcs.md | 23 ++
.../prompts/documentation-lookup/24_io_json.md | 32 +++
learning/prompts/documentation-lookup/25_io_csv.md | 32 +++
.../prompts/documentation-lookup/26_io_avro.md | 31 +++
.../prompts/documentation-lookup/27_io_parquet.md | 31 +++
.../prompts/documentation-lookup/28_io_jdbc.md | 52 ++++
runners/core-construction-java/build.gradle | 1 -
runners/core-java/build.gradle | 1 -
runners/direct-java/build.gradle | 3 -
runners/flink/flink_runner.gradle | 1 -
.../unbounded/FlinkUnboundedSourceReader.java | 36 ++-
.../options/DataflowPipelineDebugOptions.java | 8 +-
.../google-cloud-dataflow-java/worker/build.gradle | 5 -
.../worker/DataflowExecutionStateSampler.java | 9 +-
.../dataflow/worker/DataflowWorkUnitClient.java | 24 +-
.../MetricsToPerStepNamespaceMetricsConverter.java | 27 +-
.../dataflow/worker/StreamingDataflowWorker.java | 104 +++++--
.../worker/StreamingStepMetricsContainer.java | 8 +-
.../runners/dataflow/worker/WorkUnitClient.java | 17 +-
.../dataflow/worker/streaming/ActiveWorkState.java | 17 +-
.../dataflow/worker/streaming/StageInfo.java | 9 +
.../runners/dataflow/worker/streaming/Work.java | 2 +-
.../worker/DataflowWorkUnitClientTest.java | 132 ++++++---
...ricsToPerStepNamespaceMetricsConverterTest.java | 16 +-
.../worker/StreamingDataflowWorkerTest.java | 46 +++-
.../worker/StreamingStepMetricsContainerTest.java | 4 +-
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 -
scripts/ci/pr-bot/updateReviewers.ts | 1 +
sdks/go.mod | 44 +--
sdks/go.sum | 120 ++++----
sdks/go/pkg/beam/runners/prism/internal/execute.go | 8 +
.../beam/runners/prism/internal/jobservices/job.go | 10 +
.../prism/internal/jobservices/management.go | 30 ++
.../prism/internal/jobservices/management_test.go | 34 +++
.../prism/internal/jobservices/server_test.go | 61 +++++
sdks/java/core/build.gradle | 2 +
.../apache/beam/sdk/jmh/util/VarIntBenchmark.java | 303 +++++++++++++++++++++
.../org/apache/beam/sdk/fn/CancellableQueue.java | 0
.../java/org/apache/beam/sdk/fn/IdGenerator.java | 0
.../java/org/apache/beam/sdk/fn/IdGenerators.java | 0
.../org/apache/beam/sdk/fn/JvmInitializers.java | 0
.../sdk/fn/channel/AddHarnessIdInterceptor.java | 0
.../beam/sdk/fn/channel/ManagedChannelFactory.java | 0
.../beam/sdk/fn/channel/SocketAddressFactory.java | 0
.../apache/beam/sdk/fn/channel/package-info.java | 0
.../sdk/fn/data/BeamFnDataGrpcMultiplexer.java | 0
.../sdk/fn/data/BeamFnDataInboundObserver.java | 0
.../sdk/fn/data/BeamFnDataOutboundAggregator.java | 0
.../beam/sdk/fn/data/CloseableFnDataReceiver.java | 0
.../org/apache/beam/sdk/fn/data/DataEndpoint.java | 0
.../beam/sdk/fn/data/DecodingFnDataReceiver.java | 0
.../apache/beam/sdk/fn/data/FnDataReceiver.java | 0
.../apache/beam/sdk/fn/data/LogicalEndpoint.java | 0
.../beam/sdk/fn/data/RemoteGrpcPortRead.java | 0
.../beam/sdk/fn/data/RemoteGrpcPortWrite.java | 0
.../org/apache/beam/sdk/fn/data/TimerEndpoint.java | 0
.../org/apache/beam/sdk/fn/data/WeightedList.java | 0
.../org/apache/beam/sdk/fn/data/package-info.java | 0
.../java/org/apache/beam/sdk/fn/package-info.java | 0
.../org/apache/beam/sdk/fn/server/FnService.java | 0
.../server/GrpcContextHeaderAccessorProvider.java | 0
.../apache/beam/sdk/fn/server/GrpcFnServer.java | 0
.../apache/beam/sdk/fn/server/HeaderAccessor.java | 0
.../beam/sdk/fn/server/InProcessServerFactory.java | 0
.../apache/beam/sdk/fn/server/ServerFactory.java | 0
.../apache/beam/sdk/fn/server/package-info.java | 0
.../sdk/fn/splittabledofn/RestrictionTrackers.java | 0
.../sdk/fn/splittabledofn/WatermarkEstimators.java | 0
.../beam/sdk/fn/splittabledofn/package-info.java | 0
.../apache/beam/sdk/fn/stream/AdvancingPhaser.java | 0
.../sdk/fn/stream/BufferingStreamObserver.java | 0
.../org/apache/beam/sdk/fn/stream/DataStreams.java | 0
.../beam/sdk/fn/stream/DirectStreamObserver.java | 0
.../stream/ForwardingClientResponseObserver.java | 0
.../sdk/fn/stream/OutboundObserverFactory.java | 0
.../beam/sdk/fn/stream/PrefetchableIterable.java | 0
.../beam/sdk/fn/stream/PrefetchableIterables.java | 0
.../beam/sdk/fn/stream/PrefetchableIterator.java | 0
.../beam/sdk/fn/stream/PrefetchableIterators.java | 0
.../sdk/fn/stream/SynchronizedStreamObserver.java | 0
.../apache/beam/sdk/fn/stream/package-info.java | 0
.../org/apache/beam/sdk/fn/test/TestExecutors.java | 0
.../org/apache/beam/sdk/fn/test/TestStreams.java | 0
.../org/apache/beam/sdk/fn/test/package-info.java | 0
.../sdk/fn/windowing/EncodedBoundedWindow.java | 0
.../apache/beam/sdk/fn/windowing/package-info.java | 0
.../beam/sdk/transforms/join/CoGbkResult.java | 3 +-
.../main/java/org/apache/beam/sdk/util/VarInt.java | 62 ++++-
.../apache/beam/sdk/fn/CancellableQueueTest.java | 0
.../org/apache/beam/sdk/fn/IdGeneratorsTest.java | 0
.../apache/beam/sdk/fn/JvmInitializersTest.java | 5 +-
.../sdk/fn/channel/ManagedChannelFactoryTest.java | 0
.../sdk/fn/channel/SocketAddressFactoryTest.java | 0
.../sdk/fn/data/BeamFnDataGrpcMultiplexerTest.java | 0
.../sdk/fn/data/BeamFnDataInboundObserverTest.java | 14 +-
.../fn/data/BeamFnDataOutboundAggregatorTest.java | 0
.../beam/sdk/fn/data/RemoteGrpcPortReadTest.java | 0
.../beam/sdk/fn/data/RemoteGrpcPortWriteTest.java | 0
.../fn/splittabledofn/RestrictionTrackersTest.java | 0
.../fn/splittabledofn/WatermarkEstimatorsTest.java | 0
.../beam/sdk/fn/stream/AdvancingPhaserTest.java | 0
.../sdk/fn/stream/BufferingStreamObserverTest.java | 0
.../apache/beam/sdk/fn/stream/DataStreamsTest.java | 0
.../sdk/fn/stream/DirectStreamObserverTest.java | 0
.../ForwardingClientResponseObserverTest.java | 0
.../sdk/fn/stream/OutboundObserverFactoryTest.java | 0
.../sdk/fn/stream/PrefetchableIterablesTest.java | 0
.../sdk/fn/stream/PrefetchableIteratorsTest.java | 0
.../apache/beam/sdk/fn/test/TestExecutorsTest.java | 0
.../apache/beam/sdk/fn/test/TestStreamsTest.java | 0
.../sdk/fn/windowing/EncodedBoundedWindowTest.java | 0
sdks/java/expansion-service/build.gradle | 2 -
.../sdk/extensions/gcp/options/GcpOptions.java | 14 +-
sdks/java/extensions/protobuf/build.gradle | 1 +
.../sdk/extensions/protobuf/ProtoByteUtils.java | 79 +++++-
.../extensions/protobuf/ProtoByteUtilsTest.java | 72 +++++
sdks/java/extensions/python/build.gradle | 2 +-
sdks/java/fn-execution/build.gradle | 43 ---
sdks/java/harness/build.gradle | 6 +-
sdks/java/harness/jmh/build.gradle | 3 +
.../beam/fn/harness/BeamFnDataWriteRunner.java | 1 -
.../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 10 +-
.../sdk/io/gcp/bigquery/BigQuerySinkMetrics.java | 37 +--
.../sdk/io/gcp/bigquery/CreateTableHelpers.java | 10 +-
.../gcp/bigquery/DynamicDestinationsHelpers.java | 42 +--
.../io/gcp/bigquery/UpdateSchemaDestination.java | 9 +-
...ueryStorageWriteApiSchemaTransformProvider.java | 7 -
.../sdk/io/gcp/bigtable/BigtableServiceImpl.java | 20 +-
.../PubsubLiteReadSchemaTransformProvider.java | 84 ++++--
.../PubsubLiteWriteSchemaTransformProvider.java | 51 +++-
.../sdk/io/gcp/bigquery/BigQueryIOWriteTest.java | 38 +--
.../io/gcp/bigquery/BigQuerySinkMetricsTest.java | 59 ++--
.../beam/sdk/io/gcp/bigtable/BigtableReadIT.java | 93 ++++++-
.../beam/sdk/io/gcp/healthcare/FhirIOSearchIT.java | 9 +-
.../gcp/pubsublite/internal/PubsubLiteDlqTest.java | 89 ++++++
.../internal/PubsubLiteWriteDlqTest.java | 31 +++
.../beam/sdk/io/jdbc/JdbcIOAutoPartitioningIT.java | 5 +-
.../{launcher => app}/build.gradle | 45 +--
sdks/java/transform-service/build.gradle | 1 -
sdks/java/transform-service/launcher/build.gradle | 23 +-
sdks/python/apache_beam/io/gcp/bigquery.py | 6 +-
sdks/python/apache_beam/io/gcp/gcsio.py | 4 +-
.../ml/transforms/embeddings/huggingface_test.py | 1 +
.../utils/transform_service_launcher.py | 2 +-
sdks/python/apache_beam/yaml/README.md | 122 ++++++---
sdks/python/apache_beam/yaml/readme_test.py | 7 +-
sdks/python/apache_beam/yaml/standard_io.yaml | 8 +
sdks/python/apache_beam/yaml/yaml_mapping.md | 8 +-
sdks/python/apache_beam/yaml/yaml_provider.py | 31 ++-
sdks/python/build.gradle | 37 ++-
.../container/py310/base_image_requirements.txt | 4 +-
.../container/py311/base_image_requirements.txt | 4 +-
.../container/py38/base_image_requirements.txt | 4 +-
.../container/py39/base_image_requirements.txt | 4 +-
sdks/python/test-suites/tox/common.gradle | 4 +-
settings.gradle.kts | 2 +-
website/Dockerfile | 9 +-
website/www/site/content/en/contribute/_index.md | 2 +
.../en/documentation/dsls/sql/zetasql/overview.md | 4 +-
.../content/en/documentation/programming-guide.md | 4 +-
.../en/documentation/runtime/environments.md | 2 +-
206 files changed, 3367 insertions(+), 649 deletions(-)
rename .github/trigger_files/{beam_PostCommit_Python_Xlang_Gcp_Dataflow.json
=> beam_PostCommit_Java_DataflowV2.json} (100%)
create mode 100644 learning/prompts/README.md
create mode 100644 learning/prompts/code-explanation/01_io_kafka.md
rename learning/prompts/{code-explaination =>
code-explanation}/02_io_pubsub.md (78%)
create mode 100644 learning/prompts/code-explanation/03_io_bigquery.md
create mode 100644 learning/prompts/code-explanation/04_io_bigtable.md
create mode 100644 learning/prompts/code-explanation/05_io_spanner.md
create mode 100644 learning/prompts/code-explanation/06_io_tfrecord.md
create mode 100644 learning/prompts/code-explanation/07_io_json.md
create mode 100644 learning/prompts/code-explanation/08_io_csv.md
create mode 100644 learning/prompts/code-explanation/09_io_avro.md
create mode 100644 learning/prompts/code-explanation/10_io_parquet.md
create mode 100644 learning/prompts/code-explanation/11_io_jdbc.md
create mode 100644 learning/prompts/code-generation/01_io_kafka.md
create mode 100644 learning/prompts/code-generation/03_io_bigquery.md
create mode 100644 learning/prompts/code-generation/04_io_bigtable.md
create mode 100644 learning/prompts/code-generation/05_io_spanner.md
create mode 100644 learning/prompts/code-generation/06_io_tfrecord.md
create mode 100644 learning/prompts/code-generation/07_io_json.md
create mode 100644 learning/prompts/code-generation/08_io_csv.md
create mode 100644 learning/prompts/code-generation/09_io_avro.md
create mode 100644 learning/prompts/code-generation/10_io_parquet.md
create mode 100644 learning/prompts/code-generation/11_io_jdbc.md
create mode 100644 learning/prompts/documentation-lookup/18_io_kafka.md
create mode 100644 learning/prompts/documentation-lookup/21_io_bigtable.md
create mode 100644 learning/prompts/documentation-lookup/22_io_spanner.md
create mode 100644 learning/prompts/documentation-lookup/23_io_gcs.md
create mode 100644 learning/prompts/documentation-lookup/24_io_json.md
create mode 100644 learning/prompts/documentation-lookup/25_io_csv.md
create mode 100644 learning/prompts/documentation-lookup/26_io_avro.md
create mode 100644 learning/prompts/documentation-lookup/27_io_parquet.md
create mode 100644 learning/prompts/documentation-lookup/28_io_jdbc.md
create mode 100644
sdks/java/core/jmh/src/main/java/org/apache/beam/sdk/jmh/util/VarIntBenchmark.java
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/CancellableQueue.java (100%)
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/IdGenerator.java (100%)
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/IdGenerators.java (100%)
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/JvmInitializers.java (100%)
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/channel/AddHarnessIdInterceptor.java
(100%)
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/channel/ManagedChannelFactory.java
(100%)
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/channel/SocketAddressFactory.java
(100%)
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/channel/package-info.java (100%)
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/data/BeamFnDataGrpcMultiplexer.java
(100%)
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/data/BeamFnDataInboundObserver.java
(100%)
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/data/BeamFnDataOutboundAggregator.java
(100%)
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/data/CloseableFnDataReceiver.java
(100%)
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/data/DataEndpoint.java (100%)
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/data/DecodingFnDataReceiver.java
(100%)
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/data/FnDataReceiver.java (100%)
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/data/LogicalEndpoint.java (100%)
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/data/RemoteGrpcPortRead.java (100%)
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/data/RemoteGrpcPortWrite.java (100%)
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/data/TimerEndpoint.java (100%)
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/data/WeightedList.java (100%)
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/data/package-info.java (100%)
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/package-info.java (100%)
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/server/FnService.java (100%)
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/server/GrpcContextHeaderAccessorProvider.java
(100%)
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/server/GrpcFnServer.java (100%)
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/server/HeaderAccessor.java (100%)
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/server/InProcessServerFactory.java
(100%)
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/server/ServerFactory.java (100%)
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/server/package-info.java (100%)
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/splittabledofn/RestrictionTrackers.java
(100%)
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/splittabledofn/WatermarkEstimators.java
(100%)
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/splittabledofn/package-info.java
(100%)
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/stream/AdvancingPhaser.java (100%)
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/stream/BufferingStreamObserver.java
(100%)
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/stream/DataStreams.java (100%)
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/stream/DirectStreamObserver.java
(100%)
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/stream/ForwardingClientResponseObserver.java
(100%)
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/stream/OutboundObserverFactory.java
(100%)
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/stream/PrefetchableIterable.java
(100%)
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/stream/PrefetchableIterables.java
(100%)
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/stream/PrefetchableIterator.java
(100%)
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/stream/PrefetchableIterators.java
(100%)
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/stream/SynchronizedStreamObserver.java
(100%)
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/stream/package-info.java (100%)
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/test/TestExecutors.java (100%)
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/test/TestStreams.java (100%)
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/test/package-info.java (100%)
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/windowing/EncodedBoundedWindow.java
(100%)
rename sdks/java/{fn-execution =>
core}/src/main/java/org/apache/beam/sdk/fn/windowing/package-info.java (100%)
rename sdks/java/{fn-execution =>
core}/src/test/java/org/apache/beam/sdk/fn/CancellableQueueTest.java (100%)
rename sdks/java/{fn-execution =>
core}/src/test/java/org/apache/beam/sdk/fn/IdGeneratorsTest.java (100%)
rename sdks/java/{fn-execution =>
core}/src/test/java/org/apache/beam/sdk/fn/JvmInitializersTest.java (95%)
rename sdks/java/{fn-execution =>
core}/src/test/java/org/apache/beam/sdk/fn/channel/ManagedChannelFactoryTest.java
(100%)
rename sdks/java/{fn-execution =>
core}/src/test/java/org/apache/beam/sdk/fn/channel/SocketAddressFactoryTest.java
(100%)
rename sdks/java/{fn-execution =>
core}/src/test/java/org/apache/beam/sdk/fn/data/BeamFnDataGrpcMultiplexerTest.java
(100%)
rename sdks/java/{fn-execution =>
core}/src/test/java/org/apache/beam/sdk/fn/data/BeamFnDataInboundObserverTest.java
(95%)
rename sdks/java/{fn-execution =>
core}/src/test/java/org/apache/beam/sdk/fn/data/BeamFnDataOutboundAggregatorTest.java
(100%)
rename sdks/java/{fn-execution =>
core}/src/test/java/org/apache/beam/sdk/fn/data/RemoteGrpcPortReadTest.java
(100%)
rename sdks/java/{fn-execution =>
core}/src/test/java/org/apache/beam/sdk/fn/data/RemoteGrpcPortWriteTest.java
(100%)
rename sdks/java/{fn-execution =>
core}/src/test/java/org/apache/beam/sdk/fn/splittabledofn/RestrictionTrackersTest.java
(100%)
rename sdks/java/{fn-execution =>
core}/src/test/java/org/apache/beam/sdk/fn/splittabledofn/WatermarkEstimatorsTest.java
(100%)
rename sdks/java/{fn-execution =>
core}/src/test/java/org/apache/beam/sdk/fn/stream/AdvancingPhaserTest.java
(100%)
rename sdks/java/{fn-execution =>
core}/src/test/java/org/apache/beam/sdk/fn/stream/BufferingStreamObserverTest.java
(100%)
rename sdks/java/{fn-execution =>
core}/src/test/java/org/apache/beam/sdk/fn/stream/DataStreamsTest.java (100%)
rename sdks/java/{fn-execution =>
core}/src/test/java/org/apache/beam/sdk/fn/stream/DirectStreamObserverTest.java
(100%)
rename sdks/java/{fn-execution =>
core}/src/test/java/org/apache/beam/sdk/fn/stream/ForwardingClientResponseObserverTest.java
(100%)
rename sdks/java/{fn-execution =>
core}/src/test/java/org/apache/beam/sdk/fn/stream/OutboundObserverFactoryTest.java
(100%)
rename sdks/java/{fn-execution =>
core}/src/test/java/org/apache/beam/sdk/fn/stream/PrefetchableIterablesTest.java
(100%)
rename sdks/java/{fn-execution =>
core}/src/test/java/org/apache/beam/sdk/fn/stream/PrefetchableIteratorsTest.java
(100%)
rename sdks/java/{fn-execution =>
core}/src/test/java/org/apache/beam/sdk/fn/test/TestExecutorsTest.java (100%)
rename sdks/java/{fn-execution =>
core}/src/test/java/org/apache/beam/sdk/fn/test/TestStreamsTest.java (100%)
rename sdks/java/{fn-execution =>
core}/src/test/java/org/apache/beam/sdk/fn/windowing/EncodedBoundedWindowTest.java
(100%)
delete mode 100644 sdks/java/fn-execution/build.gradle
copy sdks/java/transform-service/{launcher => app}/build.gradle (53%)
