Styjun

How were concentration and extermination camp guards recruited?

Why does the Schrödinger equation work so well for the Hydrogen atom despite the relativistic boundary at the nucleus?

Who operates delivery flights for commercial airlines?

What makes linear regression with polynomial features curvy?

Do any instruments not produce overtones?

Function to extract float from different price patterns

Reading two lines in piano

What's the correct term for a waitress in the Middle Ages?

On the Twin Paradox Again

What happens to foam insulation board after you pour concrete slab?

What is the advantage of carrying a tripod and ND-filters when you could use image stacking instead?

Does the "6 seconds per round" rule apply to speaking/roleplaying during combat situations?

My coworkers think I had a long honeymoon. Actually I was diagnosed with cancer. How do I talk about it?

How is it possible that Gollum speaks Westron?

Are the AT-AT's from "Empire Strikes Back" a deliberate reference to Mecha?

Completing the square to find if quadratic form is positive definite.

What are the words for people who cause trouble believing they know better?

Why did Hela need Heimdal's sword?

Is there any word or phrase for negative bearing?

OOP demonstration in C++17 using a Pokémon

Why don't B747s start takeoffs with full throttle?

Sharing one invocation list between multiple events on the same object in C#

Can a 2nd-level sorcerer use sorcery points to create a 2nd-level spell slot?

What is the purpose of building foundations?

How to use PipelineDB to automate the updating of a Slowly Changing Dimension Table?

Changing a table into a continuous view - issue with dependent continuous viewsHow do I list all streams and continuous views in pipelinedb?Pipelinedb: How to group stream data by each N minutes in continuous viewHow to stream output from a continous view in pipelinedb?How to Update kafka extension in PipelinedbCan table be used as a stream in PipelineDBHow to Upgrade version pipelinedbHow to add a column to continuous transform in pipelinedb

.everyoneloves__top-leaderboard:empty,.everyoneloves__mid-leaderboard:empty,.everyoneloves__bot-mid-leaderboard:empty height:90px;width:728px;box-sizing:border-box;

0

Can PipelineDB be used to automate the updating of a Slowly Changing Dimension table (type 2)?

Specific example:

Say I've got a table called ProductOfferHistory, which tracks product offers for a particular product/store/daterange combination. (i.e.: price, isAvail, storeId, productId, fromDt, toDt). If a new OfferEvent comes in (productId, StoreId, price, isAvail, dt) one of 2 things should happen:

1) price/isAvail is the same as the last recorded ProductOfferHistory-record for productId/storeId. In that case: skip

2) price/isAvail is different from the last recorded ProductOfferHistory-record for productId/storeId. In that case:

• set the toDT of said last record to event.dt


• create a new record: price/isAvail/storeId/productId/fromDt = event.dt

Would it be possible using PipelineDB to have OfferEvents come in as a stream, and update the ProductOfferHistory with above described logic?

pipelinedb

share|improve this question

edited Mar 24 at 15:06

Geert-Jan

asked Mar 24 at 14:16

Geert-JanGeert-Jan

10.3k858110

add a comment | 

0

Can PipelineDB be used to automate the updating of a Slowly Changing Dimension table (type 2)?

Specific example:

Say I've got a table called ProductOfferHistory, which tracks product offers for a particular product/store/daterange combination. (i.e.: price, isAvail, storeId, productId, fromDt, toDt). If a new OfferEvent comes in (productId, StoreId, price, isAvail, dt) one of 2 things should happen:

1) price/isAvail is the same as the last recorded ProductOfferHistory-record for productId/storeId. In that case: skip

2) price/isAvail is different from the last recorded ProductOfferHistory-record for productId/storeId. In that case:

• set the toDT of said last record to event.dt


• create a new record: price/isAvail/storeId/productId/fromDt = event.dt

Would it be possible using PipelineDB to have OfferEvents come in as a stream, and update the ProductOfferHistory with above described logic?

pipelinedb

share|improve this question

edited Mar 24 at 15:06

Geert-Jan

asked Mar 24 at 14:16

Geert-JanGeert-Jan

10.3k858110

add a comment | 

Can PipelineDB be used to automate the updating of a Slowly Changing Dimension table (type 2)?

Specific example:

Say I've got a table called ProductOfferHistory, which tracks product offers for a particular product/store/daterange combination. (i.e.: price, isAvail, storeId, productId, fromDt, toDt). If a new OfferEvent comes in (productId, StoreId, price, isAvail, dt) one of 2 things should happen:

1) price/isAvail is the same as the last recorded ProductOfferHistory-record for productId/storeId. In that case: skip

2) price/isAvail is different from the last recorded ProductOfferHistory-record for productId/storeId. In that case:

• set the toDT of said last record to event.dt


• create a new record: price/isAvail/storeId/productId/fromDt = event.dt

Would it be possible using PipelineDB to have OfferEvents come in as a stream, and update the ProductOfferHistory with above described logic?

pipelinedb

share|improve this question

edited Mar 24 at 15:06

Geert-Jan

asked Mar 24 at 14:16

Geert-JanGeert-Jan

10.3k858110

share|improve this question

edited Mar 24 at 15:06

Geert-Jan

asked Mar 24 at 14:16

Geert-JanGeert-Jan

10.3k858110

share|improve this question

edited Mar 24 at 15:06

Geert-Jan

asked Mar 24 at 14:16

Geert-JanGeert-Jan

10.3k858110

asked Mar 24 at 14:16

Geert-JanGeert-Jan

10.3k858110

asked Mar 24 at 14:16

Geert-JanGeert-Jan

10.3k858110