Package: utilities

Utility nodes and miscellanea.

Includes a variety of nodes that do not fall into any of the other categories, such as nodes that fulfill certain special roles in data-flow pipelines, such as editing the meta-data, or maintaining real-time update rates. Noteworthy node classes: - nodes starting with With: these are context manager nodes that will evaluate the passed-in portion of graph with specific rules, such as using disk caching (WithCache), with specific options applied (WithOptions), and so forth.

Nodes in this package:

• Align Instances
  Align streams with an instance axis, so that they contain the same "instances" (i.e

• Append Synthetic Channels
  Append channels defined by a time-dependent formula to a time series.

• Approximate Chunk Rate
  Approximate a particular rate of chunks per second in the output.

• Assign Standard Channel Names
  Assigns channel names to incoming channels based on known montages of specific EEG devices, which can be selected from a list.

• Batch Successive Packets
  Concatenate multiple successive packets to maintain real-time rates.

• Block Reset
  Prevents subsequent nodes from receiving a reset signal from the preceding node.

• Concatenate Successive Packets
  Concatenate successive packets along some axis.

• Count Along Axis
  Returns the number of items contained in an axis.

• Create Datestamp
  Create a new datestamp from the current time, or a given timestamp, or constituent parts.

• Dejitter Timestamps
  De-jitter the time-stamps of the given data.

• Discard Empty Data
  Discard data that is empty.

• Discard Invalid Data Slices
  Remove slices of the incoming packets that contain invalid data.

• Discard Long Chunks
  Drop chunks whose length exceeds a threshold.

• Discard NaN Chunks
  Drop chunks that contain NaNs from the data.

• Extract Channel Names
  Extract a list of the channel names from a data stream.

• Extract Stream Property
  Extract a given property from one of the streams of an incoming data packet.

• Extract Timestamps
  Extract the timestamps of the given signal.

• Format Datestamp
  Format a datestamp into a string using either a named date form, or a custom format string using placeholders.

• Fuse Predictions and Markers
  ""Fuse a BCI's predictions and some markers together into a stream that can be evaluated by MeasureLoss.

• Get Sampling Rate
  Get the sampling rate of the given data.

• Get Source Filename
  Get the full path (filename) of the source of a packet.

• Get Stream Property
  Get (fetch) a metadata property of a given stream.

• Get Time Shifts
  Retrieve the time shifts between a chunk's time axis and another set of timestamps.

• Hold Last Packet
  Holds and passes on the most recently received packet.

• Hold Last Value
  Holds the most recently received (non-empty/zero/None) value.

• Interpolate Missing Timestamps
  Interpolate data to repair gaps and jitter in the timestamps.

• Move to Backend or Precision
  Move the data to the specified compute backend.

• One-Hot Coding
  Convert the given integer data to a one-hot coding.

• One Sample Buffer
  One sample buffer for control signals.

• Override Data Type
  Override the data precision type of the given data (i.e

• Override Sampling Rate
  Override the sampling rate in the given data's time axis.

• Override Timestamps
  Override the timestamps in the given data based on its nominal sampling rate, optionally pegged to the current "wall clock" reading.

• Parse Datestamp
  Parse a string into a datestamp according to some format.

• Parse Trigger Channel
  Extract event markers from a trigger channel.

• Pipeline Done
  Special purpose node used to force a pipeline to report that it is finished.

• Pipeline File Path
  Returns the filepath of the pipeline containing the node (if any), or an empty string if there is no associated file (e.g

• Propagate NaNs
  Propagate NaNs within a data packet following a specified rule.

• Regulate Chunk Sizes
  Fix up chunk size irregularities in streaming data using a buffer.

• Repeat Along Axis
  Repeat the data along the given axis.

• Replace Axis Values
  Replace the values in an array of an axis (i.e

• Retain Channel Metadata
  Store and recover space axis (channel) meta-data upon save/load of a model.

• Select Active Input
  Pick the value from the active input port.

• Select Instance Fields
  Select (retain) or drop fields from an instance axis.

• Set Axis Label
  Set a custom label on a given axis.

• Set Stream Properties
  Set (override or add) meta-data properties of a given stream.

• Shift Datestamp
  Shift a datestamp by some offset.

• Shift Timestamps
  Shift the timestamps in the given signal by some delta.

• Strip Metadata
  Strip all except for a desired subset of meta-data fields from the packet.

• Get Current Task Number
  Retrieve the number of this task if run as part of a parallel collection of tasks.

• With Backend or Precision
  Run the given computational graph with a specified compute backend and precision.

• With Cache
  Evaluate a computational graph with caching of the results.

• With Num Cores
  Run the given computational graph with a limit on the number of cores that can be used by the process.

• With Options
  Run the wired-in computational graph with the specified options applied to it.