In [1]:
...
In [3]:
# progressivis-snippet
from progressivis import SimpleCSVLoader, Sink

@register_snippet
def csv_as_array(input_module, input_slot, columns):
    s = scheduler = input_module.scheduler()
    with scheduler:
        csv = SimpleCSVLoader(
            "https://aviz.fr/progressivis/mnist_784.csv.bz2",
            nrows=10_000,
            as_array=lambda cols: {"array": [c for c in cols if c != "class"]},
            scheduler=s,
        )
        sink = Sink(name="sink", scheduler=s)
        sink.input.inp = csv.output.result
    return SnippetResult(output_module=csv, output_slot="result")

root¶

In [2]:
...

MNIST784¶

In [4]:
Constructor.widget('MNIST784', 0)
Out[4]:

T-SNE 2D¶

In [5]:
Constructor.widget('T-SNE 2D', 0)
Out[5]:
# Scheduler added module(s): ['data_shape_1', 'sink_2']
BEGIN ini
END ini
# Scheduler deleted module(s): {'sink_2', 'data_shape_1'}