Hi,
I have some metrics stored on a Cassandra supercolumn and the subcolumns are
the timestamps of each metric, I'm loading the metrics in pig with this line:
all_metrics = LOAD 'cassandra://keyspace/metrics' USING CassandraStorage() AS
(metric_key, metrics_bag: bag {metric: tuple(timestamp, columns: bag {record:
tuple(name:chararray, value:chararray)})});
I just want to access the timestamp subcolumn to get the most recent value
(using max), I try to use:
metric_status = FOREACH all_metrics GENERATE metric_key, metrics_bag.timestamp;
dump metric_status;
but I'm getting empty values, like this:
(key1,{(),(),()})
(key2,{(),()})
...
