I am using hadoop2.2.0,cassandra2.0.6,pig0.12 and spark1.0.1. I am reading data from cassandra using pig using CassandraStorage handler and did analytic operations. I know spark accept hadoop input format (pig) data.So I want to pass read data by pig query to spark. How can I do that any suggesstions?.