Open rtarway opened 8 months ago
//TODO : Filter transactions to calculate availability, rest should be written to bigquery only for analytical purposes
https://github.com/rtarway/ecommerce-streamlytics-clickstream2/blob/adb8ef0b6f40ce283eb3d93766ae1d7fd1526981/src/main/java/com/beamlytics/inventory/pipelines/RetailDataProcessingPipeline.java#L122
https://github.com/rtarway/ecommerce-streamlytics-clickstream2/blob/adb8ef0b6f40ce283eb3d93766ae1d7fd1526981/src/main/java/com/beamlytics/inventory/pipelines/RetailDataProcessingPipeline.java#L122