apoc.periodic
| Qualified Name | Type | Release |
|---|---|---|
apoc.periodic.cancel(name) - cancel job with the given name |
Procedure |
APOC Core |
apoc.periodic.commit(statement,params) - runs the given statement in separate transactions until it returns 0 |
Procedure |
APOC Core |
apoc.periodic.countdown('name',statement,repeat-rate-in-seconds) creates a background job that will repeatedly execute the given Cypher statement until it returns 0. |
Procedure |
APOC Core |
apoc.periodic.iterate('statement returning items', 'statement per item', {batchSize:1000,iterateList:true,parallel:false,params:{},concurrency:50,retries:0}) YIELD batches, total - run the second statement for each item returned by the first statement. Returns number of batches and total processed rows |
Procedure |
APOC Core |
apoc.periodic.list - list all jobs |
Procedure |
APOC Core |
apoc.periodic.repeat('name',statement,repeat-rate-in-seconds, config) submit a repeatedly-called background query. The parameter 'config' is optional and can contain a 'params' entry usable in nested Cypher statement. |
Procedure |
APOC Core |
apoc.periodic.rock_n_roll('some cypher for iteration', 'some cypher as action on each iteration', 10000) YIELD batches, total - run the action statement in batches over the iterator statement’s results in a separate thread. Returns number of batches and total processed rows |
Procedure |
APOC Full |
apoc.periodic.rock_n_roll_while('some cypher for knowing when to stop', 'some cypher for iteration', 'some cypher as action on each iteration', 10000) YIELD batches, total - run the action statement in batches over the iterator statement’s results in a separate thread. Returns number of batches and total processed rows |
Procedure |
APOC Full |
apoc.periodic.submit('name',statement,params) - creates a background job which executes a Cypher statement once. The parameter 'params' is optional and can contain query parameters for the Cypher statement |
Procedure |
APOC Core |
apoc.periodic.truncate({config}) - removes all entities (and optionally indexes and constraints) from db using the apoc.periodic.iterate under the hood |
Procedure |
APOC Core |