What would you like to happen?
This is one of the two blockers preventing Neo4jIO from being used in the Neo4j Flex template for GCP Dataflow.
Currently, WriteUnwind is implemented as a true sink.
As such, it cannot be depended upon (via Wait.on).
Dependencies are major part of the Neo4j Template.
WriteUnwind could output write statistics it gets from the Neo4j driver's org.neo4j.driver.summary.ResultSummary class (org.neo4j.driver.summary.SummaryCounters in particular).
Issue Priority
Priority: 2 (default / most feature requests should be filed as P2)
Issue Components
What would you like to happen?
This is one of the two blockers preventing Neo4jIO from being used in the Neo4j Flex template for GCP Dataflow.
Currently,
WriteUnwindis implemented as a true sink.As such, it cannot be depended upon (via
Wait.on).Dependencies are major part of the Neo4j Template.
WriteUnwindcould output write statistics it gets from the Neo4j driver'sorg.neo4j.driver.summary.ResultSummaryclass (org.neo4j.driver.summary.SummaryCountersin particular).Issue Priority
Priority: 2 (default / most feature requests should be filed as P2)
Issue Components