Published in


Data Vault PIT Flow Manifold

Streams and Tasks (see: form a part of Snowflake’s Data Pipelines and from a Data Vault 2.0 perspective they’re a perfect fit and a templated approach to getting data staged, loaded, and tested through repeatable patterns. Here we will use another piece of Snowflake ingenuity to build a PIT Table Manifold.

This article builds on the previous three Snowflake Data Vault articles highlighting how the two are a great fit!

Snowflake includes the Multi-Table Insert (see: that allows for a single source (can be a complex join) to feed multiple target tables at the same time. It may be tempting to load Data Vault hubs, links, and satellites from a single staged file, but we have shown in the automated testing article why this is folly! Instead, we do want to use it when loading PIT tables but with a twista data driven twist! And we will show how!

Data Vault Pipeline

Let’s run through each stage of the pipeline

  1. Data is landed either as an INSERT OVERWRITE or INSERT ONLY. Without dropping the target’s contents then this is the first place we can use Snowflake’s Streams (see: to process new records only downstream.
  2. Landed content is staged with data vault metadata tags, some of these are:

a. Surrogate hash keys — for joining related data vault tables

b. Load date — the timestamp of when the data enters the data warehouse

c. Applied date — the timestamp of the landed data

d. Record source — where the data came from

e. Record hashes — a single column representing a collection of descriptive attributes

3. Autonomous loads through

a. Hub loaders — a template reused to load one or many hub tables

b. Link loaders — a template reused to load zero or many link tables

c. Sat loaders — a template reused to load zero or many satellite tables

4. Test Automation measuring the integrity of all loaded (and related) data vault artefacts from the staged content

5. Snapshot is taken of the current load dates and surrogate hash keys from the parent entity (hub or link) and adjacent satellite tables.

6. Use the AS_OF date table to control the PIT manifold to periodically populate target PIT tables at the configured frequency.

7. Information Marts that are defined once as views over a designated PIT table.

Point-in-Time table

A Point-in-Time (PIT) table is a physical collection of applicable surrogate keys and load dates for a snapshot period. It must be a table otherwise the potential benefits of EQUIJOIN are not realised. See

It improves join performance and forms the base for information mart views and easily allows you to define marts to be built for specific logarithmic time windows by a snapshot date. The traditional approach to building a PIT table makes use of an adjacent date table to define the logarithmic period and the PIT windows itself.

Configure AS_OF

AS_OF table controls the PIT snapshot in a combination of two ways

  • By Window: defining the start and end date of the AS_OF period, the window of snapshots to take. You can define a much larger than needed table but subset the window in execution.
  • By Frequency: defining at what frequency snapshot keys are to be sent to a PIT target. This is tailored by the business and is a part of the report frequency and depth. Ideally this would not have any involvement by engineering teams, only to set this up. From there the business controls the 1 and 0 switches.

The PIT Flow Manifold

Assembling the components together needs one more artefact to make the pipeline work, Multi-Table Insert syntax that uses AS_OF to complete the PIT Flow Manifold!

The components together will do the following

No flow if the configuration is set as such.

And the flow continues the next day

Information Mart Views

Now that we have built the manifold, the last part of the data vault pipeline is the information mart views. These are created only once and as the data vault is updated underneath it all, the manifold pumps the applicable keys into PITs and the view of course are immediately up to date.


Data Vault provides the proven data architecture templates that your enterprise data platform can be built on. Like agile sprint iterations and DevOps engineering these templates are repeatable, reduce the probabilities of errors and are scalable.

PIT flow manifold introduced here uses these templates together to make the management of information marts on a data vault completely data-driven! And on a platform designed to scale why not adopt a data modelling methodology that is designed to scale as well!

#snowflakedb #datavault

The views expressed in this article are that of my own, you should test implementation performance before committing to this implementation. The author provides no guarantees in this regard.




Snowflake articles from engineers using Snowflake to power their data.

Recommended from Medium

Spring Boot RESTful API Documentation With Swagger

| Engineering News-Record

My first Ruby CLI project

V-platform — AWS infrastructure platform at VTS

How To Pass Your Terraform Certified Associate Exam — First Time!

The four horsemen of a potential microservices apocalypse

Автопостинг в Одноклассниках из WordPress [Полное руководство]

| Engineering News-Record

Get the Medium app

A button that says 'Download on the App Store', and if clicked it will lead you to the iOS App store
A button that says 'Get it on, Google Play', and if clicked it will lead you to the Google Play store
Patrick Cuba

Patrick Cuba

A Data Vault 2.0 Expert, Snowflake Solution Architect

More from Medium

Data Vault Agility on Snowflake

Getting Started with Data Vault 2.0

Optimize Your Hierarchical Data with Snowflake, Part Three

Sensitive Data Classification Using Snowflake. Part-2