Leomrlin commented on issue #761:
URL: https://github.com/apache/geaflow/issues/761#issuecomment-4020722939

   Yes, based on your test script, the algorithm outputs results every time the 
graph changes. Since the default `windowSize` is `1` and your script does not 
override it, each vertex/edge insertion triggers the WCC computation.
   
   The relevant configuration is defined as:
   ```java
   public static final ConfigKey GEAFLOW_DSL_WINDOW_SIZE = ConfigKeys
       .key("geaflow.dsl.window.size")
       .defaultValue(1L)
       .description("Window size, -1 represents the full window.");
   ```
   
   ### Solution
   To ensure the algorithm runs **only once** after the entire graph is 
constructed, add this line to your script:
   ```sql
   SET geaflow.dsl.window.size = -1;
   ```
   
   ### Example
   ```sql
   SET geaflow.dsl.window.size = -1; -- Run WCC once after graph fully loaded
   ```
   
   ### Explanation
   - **`geaflow.dsl.window.size = 1`** (default): Executes the algorithm after 
every single mutation (vertex/edge insertion).
   - **`geaflow.dsl.window.size = -1`**: Delays execution until all mutations 
in the current batch are applied, then runs the algorithm once and outputs the 
final result.
   
   This change eliminates duplicate intermediate outputs and ensures only the 
final connected components are written to `cc_geaflow_test`.


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to