WorkflowNode

class nvtabular.workflow.node.WorkflowNode(selector=None)[source]

A WorkflowNode is a group of columns that you want to apply the same transformations to. WorkflowNode’s can be transformed by shifting operators on to them, which returns a new WorkflowNode with the transformations applied. This lets you define a graph of operations that makes up your workflow

Parameters: selector (ColumnSelector) – Defines which columns to select from the input Dataset using column names and tags.

__rshift__(operator)[source]

Transforms this WorkflowNode by applying an Operator

Parameters: operators (Operator or callable) –
Returns
Return type: WorkflowNode

__add__(other)[source]

Adds columns from this WorkflowNode with another to return a new WorkflowNode

Parameters: other (WorkflowNode or str or list of str) –
Returns
Return type: WorkflowNode

__radd__(other)

Adds columns from this WorkflowNode with another to return a new WorkflowNode

Parameters: other (WorkflowNode or str or list of str) –
Returns
Return type: WorkflowNode

__sub__(other)[source]

Removes columns from this WorkflowNode with another to return a new WorkflowNode

Parameters: other (WorkflowNode or str or list of str) – Columns to remove
Returns
Return type: WorkflowNode

__getitem__(columns)[source]

Selects certain columns from this WorkflowNode, and returns a new Columngroup with only those columns

Parameters: columns (str or list of str) – Columns to select
Returns
Return type: WorkflowNode

__weakref__: list of weak references to the object (if defined)

nvtabular.workflow.node._to_graphviz(workflow_node)[source]: Converts a WorkflowNode to a GraphViz DiGraph object useful for display in notebooks