[beam] branch master updated (b0899a4 -> 0fe57b1)

[ib...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

ibzib pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


    from b0899a4  Fix BoundedQueueExecutor and StreamingDataflowWorker to actually limit memory from windmill (#16901)
     add 0fe57b1  [BEAM-1857] Add Neo4jIO (#15916)

No new revisions were added by this update.

Summary of changes:
 build.gradle.kts                                   |    1 +
 {.test-infra => sdks/java/io/neo4j}/OWNERS         |    3 +-
 .../io/{contextualtextio => neo4j}/build.gradle    |   22 +-
 .../java/org/apache/beam/sdk/io/neo4j/Neo4jIO.java | 1221 ++++++++++++++++++++
 .../apache/beam/sdk/io/neo4j}/package-info.java    |    4 +-
 .../org/apache/beam/sdk/io/neo4j/Neo4jIOIT.java    |  275 +++++
 .../org/apache/beam/sdk/io/neo4j/Neo4jIOTest.java  |  117 ++
 .../apache/beam/sdk/io/neo4j/Neo4jTestUtil.java    |   70 ++
 settings.gradle.kts                                |    1 +
 9 files changed, 1699 insertions(+), 15 deletions(-)
 copy {.test-infra => sdks/java/io/neo4j}/OWNERS (83%)
 copy sdks/java/io/{contextualtextio => neo4j}/build.gradle (63%)
 create mode 100644 sdks/java/io/neo4j/src/main/java/org/apache/beam/sdk/io/neo4j/Neo4jIO.java
 copy sdks/java/io/{amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis => neo4j/src/main/java/org/apache/beam/sdk/io/neo4j}/package-info.java (90%)
 create mode 100644 sdks/java/io/neo4j/src/test/java/org/apache/beam/sdk/io/neo4j/Neo4jIOIT.java
 create mode 100644 sdks/java/io/neo4j/src/test/java/org/apache/beam/sdk/io/neo4j/Neo4jIOTest.java
 create mode 100644 sdks/java/io/neo4j/src/test/java/org/apache/beam/sdk/io/neo4j/Neo4jTestUtil.java