View all vega-dataflow analysis

How to use the vega-dataflow.Dataflow function in vega-dataflow

To help you get started, we’ve selected a few vega-dataflow examples, based on popular ways it is used in public projects.

Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.

microsoft / chart-parts / packages / util / transform / src / facade / dataset.ts View on Github

function createTransformPipeline(
	transforms: DatasetTransform[],
	ds: DatasetManager,
): Pipeline {
	const df = new Dataflow()
	const entry = df.add(collect)
	let latest = entry

	transforms.forEach(t => {
		latest = t.build(df, latest, ds)
		latest = df.add(collect, { pulse: latest })
	})

	return {
		dataflow: df,
		start: entry,
		end: latest,
	}
}