Hii Maninda, Thanks for replying. I tried creating a table which will suite my need, with different set of columns from above example.
CREATE EXTERNAL TABLE IF NOT EXISTS Chamila ( remote_ip STRING, request_date STRING,request STRING, httpCode STRING,length STRING, version STRING) STORED BY 'org.apache.hadoop.hive.cassandra.CassandraStorageHandler' WITH SERDEPROPERTIES ( "wso2.carbon.datasource.name" = "WSO2BAM_CASSANDRA_DATASOURCE" , "cassandra.cf.name" = "processed_logs" , "cassandra.columns.mapping" = ":key,remote_ip, request_date, request,httpCode,length, version" ); But I get an error saying, "Error while executing Hive script.Query returned non-zero code: 9, cause: FAILED: Execution Error, return code 1 from org.apache.hadoop.hive.ql.exec.DDLTask". How can I create a table to suite what I want. As I understood, it has no meaning to create a virtual table without linking it with Column Family. Thank you! On Fri, Dec 20, 2013 at 5:58 PM, Maninda Edirisooriya <mani...@wso2.com>wrote: > On Fri, Dec 20, 2013 at 4:54 PM, Chamila Wijayarathna <cham...@wso2.com>wrote: > >> Hello All, >> I am running BAM sample 1. >> In the analytic script which get run when I sent log line event it has >> query >> >> CREATE EXTERNAL TABLE IF NOT EXISTS ProcessedLogs ( >> logId STRING,remote_ip STRING, >> request_date STRING,request STRING, >> httpCode STRING,length STRING, >> version STRING) >> STORED BY 'org.apache.hadoop.hive.cassandra.CassandraStorageHandler' >> WITH SERDEPROPERTIES ( >> "wso2.carbon.datasource.name" = "WSO2BAM_CASSANDRA_DATASOURCE" , >> "cassandra.cf.name" = "processed_logs" , >> "cassandra.columns.mapping" = >> ":key,remote_ip, request_date, request,httpCode,length, version" ); >> >> What I understand about this query is that it creates a table and load >> data from "processed_logs" column family which is available at >> Cassandra Keyspaces / EVENT_KS. >> > In this query it created the "processed_logs" column family and creates > the Hive table (which is a virtual table), "ProcessedLogs" wrapping the > column family, "processed_logs". > >> >> I need to analyze a log file which is in a format different from >> access.log given in sample. How can I create a different column family for >> my requirement and access them in my script??? >> > The script above can be used for creating a column family. > > Read [1] for more information on writing Hive queries. > > [1] > http://docs.wso2.org/display/BAM240/Creating+Hive+Queries+to+Analyze+Data > >> >> >> Thank You! >> -- >> *Chamila Wijayarathna* >> Engineering Intern, >> WSO2 Inc. >> >> >> _______________________________________________ >> Dev mailing list >> Dev@wso2.org >> http://wso2.org/cgi-bin/mailman/listinfo/dev >> >> > -- *Chamila Wijayarathna* Engineering Intern, WSO2 Inc.
_______________________________________________ Dev mailing list Dev@wso2.org http://wso2.org/cgi-bin/mailman/listinfo/dev
