Every operation.
All 67 steps declared across 17 packages. Filter by kind or package, or search by name.
67 results
- /dev/nullbase/nulDummy output stream, just like /dev/null.
- Append metadatardf/metadata.js/appendFetches, updates and appends a metadata resource
- Append RDF/JS Quads (Graph Store)graph-store/postAppends RDF/JS Quads to the given named graph using the SPARQL Graph Store Protocol.
- Apply N3 Rulesn3/applyRulesApplies N3 rules to datasets in barnard59 pipelines
- Batchbase/batchGroups incoming items into arrays of the given size.
- build Cube Shapecube/buildCubeShapeBuilds a Cube Shape based on Cube Observation datasets
- Carml transformcarml/transformTransforms an XML stream based on a given Carml mapping.
- Combinebase/combineCombines multiple streams to a single stream connecting them in the given order.
- Combine RDF stream to datasetrdf/getDatasetThe entire RDF stream is combined into a single dataset
- Concatbase/concatConcatenates the content of the given streams to a single stream.
- Concat (Object)base/concat/objectConcatenates the content of the given streams to a single stream.
- Fetch CSVWcsvw/fetchLoads a CSVW file from the local filesystem or the web depending on the given argument
- Filterbase/filterForwards incoming chunks if they pass the filter function.
- Flattenbase/flattenSeparates incoming arrays into their elements and emits each element as a single chunk.
- For Eachbase/forEachCalls a sub pipeline for each incoming chunk.
- Get S3 objects3/getObjectGet an object from a S3 bucket.
- Get S3 object as streams3/getObject/streamGet an object from a S3 bucket as a Readable stream.
- Globbase/globMatch files using the given pattern and emits each filename as a single chunk.
- HTTP GET requesthttp/getMakes a HTTP GET request and returns the body of the response as stream.
- HTTP POST requesthttp/postMakes a HTTP POST request, sends the written data as request body and returns the body of the response as stream.
- Limitbase/limitLimits the amount of forwarded chunks and discards any chunks after reaching the limit.
- List files (FTP)ftp/listLists all files in the given FTP folder.
- Mapbase/mapConverts each chunk using the given function.
- Map (RDF/JS Quad)rdf/mapMatchCalls a map function only for quads matching the given triple pattern.
- Move file (FTP)ftp/moveMoves the given file at the end of the stream processing and forwards any incoming data.
- Offsetbase/offsetDiscards all chunks before the given offset.
- Opens an RDF from web or local filerdf/openWeb resource requires content-type header. Will try n-triples as fallback. Local paths will be relative to the current working directory
- Parse CSV on the Webformats/csvw/parseParses the given CSV stream using the given metadata.
- Parse JSONbase/json/parseConverts each chunk to an object by calling JSON.parse().
- Parse JSON-LDformats/jsonld/parseParses the given JSON-LD stream.
- Parse JSON-LD (Object)formats/jsonld/parse/objectParses the given JSON-LD stream.
- Parse N3formats/n3/parseParses the given N3 stream.
- Parse RDF filerdf/fs.js/parseOpens and parses an RDF file, choosing the correct parser based on the extension
- Parse RDF/XMLformats/rdf-xml/parseParses the given RDF/XML stream.
- Parse XSLX files based on the CSV on the Web standardformats/xlsx/parseParses the given XLSX stream using the given metadata.
- Put an object to S3s3/putObjectPut an object to a S3 bucket.
- Put file (FTP)ftp/writeUploads the stream to FTP.
- Read filecore/fs/createReadStreamReads a file from the local file system.
- Read file (FTP)ftp/readReads the given file.
- Read RDF/JS Quads (Graph Store)graph-store/getReads RDF/JS Quads from the given named graph using the SPARQL Graph Store Protocol.
- Serialize JSONbase/json/stringifyConverts each chunk to a JSON string by calling JSON.stringify().
- Serialize JSON-LDformats/jsonld/serializeSerializes the given RDF/JS Quads to JSON-LD.
- Serialize N-Triplesformats/ntriples/serializeSerializes the given RDF/JS Quads to N-Triples.
- Set Graphrdf/setGraphSets the graph of all quads to the given fixed value.
- Shellshell/shellRuns the given command in a shell and forwards stdin and stdout.
- Shell (after)shell/afterRuns the given command in a shell after all chunks have been processed.
- Shell (before)shell/beforeRuns the given command in a shell before any chunk has been processed.
- SPARQL Constructsparql/constructRuns the given CONSTRUCT query against the given endpoint parses the result.
- SPARQL in-memory Querysparql/in-memory/queryRuns the given query against each input chunk.
- SPARQL in-memory Updatesparql/in-memory/updateRuns the given DELETE/INSERT command against each input chunk.
- SPARQL Selectsparql/selectRuns the given SELECT query against the given endpoint parses the result into rows of RDF/JS key-value pairs.
- Splits RDF stream by RDF typerdf/splitDataset/byTypeCombines streamed quads into datasets. A new dataset is pushed when an rdf:type triple is encountered
- Splits RDF stream on graphrdf/splitDataset/byGraphCombines streamed quads into datasets. A new dataset is pushed when graph changes
- Splits RDF stream on predicaterdf/splitDataset/byPredicateCombines streamed quads into datasets. A new dataset is pushed when predicate changes
- Splits RDF stream on subjectrdf/splitDataset/bySubjectCombines streamed quads into datasets. A new dataset is pushed when subject changes
- stdinbase/stdinReads from standard input
- stdoutbase/stdoutWrites the incoming data to stdout and also forwards the data to the stream output.
- Stream valuesbase/streamValuesCreates a readable stream from the given array.
- to Cube Observationcube/toObservationConverts a set of quads to a Cube Observation
- To Stringbase/toStringConverts each chunk to a string by calling .toString().
- Transforms code:imports triples by fetching remote graphs and mergin them with the passing streamrdf/transformCodeImports
- validate rdfshacl/validateValidates a RDF graph against a set of conditions specified in a SHACL document
- validate rdfshacl/reportValidates a RDF graph against a set of conditions specified in a SHACL document, returning the validation report
- validate rdfvalidate-shacl/validateValidates a RDF graph against a set of conditions specified in a SHACL document
- Void statisticsrdf/metadata.js/voidStatsAppends void statistics, such as counts for entities and properties
- Write filecore/fs/createWriteStreamWrites a file to the local file system.
- Write RDF/JS Quads (Graph Store)graph-store/putWrites RDF/JS Quads to the given named graph using the SPARQL Graph Store Protocol.