Added apoc.load.directory.async.* procedures
#1843
Merged
Conversation
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
…e/false) yield url
…e/false) yield url
…e/false) yield url
…e/false) yield url
fbiville
approved these changes
Apr 2, 2021
| @@ -0,0 +1,5 @@ | |||
| ¦xref::overview/apoc.load.directory.async/apoc.load.directory.async.remove.adoc[apoc.load.directory.async.remove icon:book[]] + | |||
|
|
|||
| `apoc.load.directory.async.remove(name) YIELD name, status, pattern, cypher, urlDir, config, error` - Remove a folder listener by name and return remaining listener | |||
There was a problem hiding this comment.
Suggested change
| `apoc.load.directory.async.remove(name) YIELD name, status, pattern, cypher, urlDir, config, error` - Remove a folder listener by name and return remaining listener | |
| `apoc.load.directory.async.remove(name) YIELD name, status, pattern, cypher, urlDir, config, error` - Remove a folder listener by name and return remaining listeners, if any |
| @@ -0,0 +1,254 @@ | |||
| The first parameter is the name of our custom watch listener. | |||
| If I call a procedure with the same name as an existing one, this will be overwritten. | |||
There was a problem hiding this comment.
Suggested change
| If I call a procedure with the same name as an existing one, this will be overwritten. | |
| If we use an already existing listener name, that listener will be overwritten. |
using we like the in the rest of the document
There was a problem hiding this comment.
applies to the other documentation pages below
|
|
||
| We can use as query parameter, another load procedure, like `apoc.load.csv` or `apoc.load.json`. | ||
|
|
||
| Here is two examples. |
There was a problem hiding this comment.
Suggested change
| Here is two examples. | |
| Here are two examples. |
There was a problem hiding this comment.
applies to the other documentation pages below
|
|
||
| === Examples of interoperability with other procedures | ||
|
|
||
| We can use as query parameter, another load procedure, like `apoc.load.csv` or `apoc.load.json`. |
There was a problem hiding this comment.
Suggested change
| We can use as query parameter, another load procedure, like `apoc.load.csv` or `apoc.load.json`. | |
| We can use another load procedure as query parameter, like `apoc.load.csv` or `apoc.load.json`. |
There was a problem hiding this comment.
applies to the other documentation pages below
|
|
||
| === Error handling | ||
|
|
||
| When for some reason, the listener fails, its `status` field change from `RUNNING` to `ERROR`, and the associated error is put |
There was a problem hiding this comment.
Suggested change
| When for some reason, the listener fails, its `status` field change from `RUNNING` to `ERROR`, and the associated error is put | |
| When for some reason, the listener fails, its `status` field change from `RUNNING` to `ERROR`, and the associated error is output. |
There was a problem hiding this comment.
applies to the other documentation pages below
| === Error handling | ||
|
|
||
| When for some reason, the listener fails, its `status` field change from `RUNNING` to `ERROR`, and the associated error is put | ||
| so if we execute `call apoc.load.directory.async.list`, we obtain, for example: |
There was a problem hiding this comment.
Suggested change
| so if we execute `call apoc.load.directory.async.list`, we obtain, for example: | |
| If we execute `call apoc.load.directory.async.list`, we obtain, for example: |
There was a problem hiding this comment.
applies to the other documentation pages below
| @@ -0,0 +1,9 @@ | |||
| The procedure support the following config parameters: | |||
There was a problem hiding this comment.
Suggested change
| The procedure support the following config parameters: | |
| The procedure supports the following config parameters: |
| Future removed = storage.remove(loadDirectoryItem); | ||
| if (removed == null) { | ||
| String name = loadDirectoryItem.getName(); | ||
| throw new RuntimeException("Listener with name: " + name + " doesn't exists"); |
There was a problem hiding this comment.
Suggested change
| throw new RuntimeException("Listener with name: " + name + " doesn't exists"); | |
| throw new RuntimeException("Listener with name: " + name + " doesn't exist"); |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Based on #1639 (comment)
apoc.load.directory.add(name, cypher, pattern, urlDir, configMap)apoc.load.directory.remove(name)apoc.load.directory.list()andapoc.load.directory.removeAll()apoc.load.csv('filename with spaces.csv')liketestWithSpacesInFileNameinLoadCsvTest.java