I have an usecase to dump the data from csv to cassandra.
My source CSV data has one date column which is in the format
eg (Sample input date):
I tried changing the date format to
yyyy-MM-dd using CSVReader (Record Reader) and CSVWriter (Record Writer) inside updateattribute processor (along with other column data manipulation activity)
Avro Schema defined inside CSVWriter: - avroschema
Output of CSVWriter:
At the final step I have PutCassandraRecord processor, where I defined CSVReader (as Record Reader) with schemaText property as avroschema
Cassandra table structure:
CREATE TABLE date_dump.forecast ( destination_name text,date date,destination int,maximum int,minimum int, PRIMARY KEY (destination_name, date) )
Could anyone help here to fix this issue, to dump the date column into cassandra table.