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