anguenot/pyspark-cassandra

WRITETIME access at cell level?

Opened this issue · 1 comments

cadupont commented

I've been trying to find a way to access WRITETIME from cassandra (field) into pyspark. Am I looking at the right place? I can't seem to find a way to do this...
Thanks

sathiyarajanm commented

@cadupont can you try the dse-driver

pip install dse-driver

and try to get the writetime by using :
print session.execute("SELECT WRITETIME (date) FROM mykeyspace.temp WHERE date = '2017-12-01' ALLOW FILTERING;")

code snippet to test with cassandra:

Example:
from dse.cluster import Cluster
cluster = Cluster(contact_points=['localhost'])
session = cluster.connect('system')
print session.execute("SELECT WRITETIME (date) FROM mykeyspace.temp WHERE date = '2017-12-01' ALLOW FILTERING;")
Row(writetime_date=1530649026473825)

@anguenot : Any plan to add the writetime functionality in the future.