Hi Team ,

I want to write a custom cassandra codec and i want to use that codec in my
spark application while reading the data from cassandra table .

Basically the custom codecs are used to convert one column type to another
while reading from cassandra. for example i have a timestamp column in
cassandra table ,but i want to read it as long and save as parquet file to
HDFS , then this cutom codecs will be usefull instead of doing an
additional transformation in the spark code.

I want to know how to set/register this custom cassandra codecs in spark ?

 I had tried with solution provided in the below link but it does not work
, any ideas around this will be helpfull.

https://stackoverflow.com/questions/40363611/adding-custom-codec-to-cassandraconnector/49750791?noredirect=1#comment86515847_49750791




*Thanks & Regards*
*S.Revanth kumar reddy*
https://github.com/Re1tReddy/
http://34.230.100.5:8080/crazyusers/login

Reply via email to