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
