: enable timestamp as partition, currently the schema defines it as long but it is not encoded as logical type of timestamp, rather string.

rtarway / ecommerce-streamlytics-clickstream2

0 stars 1 forks source link

: enable timestamp as partition, currently the schema defines it as long but it is not encoded as logical type of timestamp, rather string. #2

Open rtarway opened 8 months ago

rtarway commented 8 months ago

                            //TODO : enable timestamp as partition, currently the schema defines it as long but it is not encoded as logical type of timestamp, rather string.

https://github.com/rtarway/ecommerce-streamlytics-clickstream2/blob/9ed133eee01e91e8a614599e13fcf9fde7857b37/src/main/java/com/beamlytics/inventory/businesslogic/core/transforms/clickstream/ClickstreamProcessing.java#L133