Cassandra river for Elastic search.
This river was a proof of concept for integration of cassandra with elasticsearch, its a 2 day hacked up solution.
##Setup
Build: mvn clean package
Install:
./bin/plugin -url file:elasticsearch-river-cassandra/target/releases/elasticsearch-river-cassandra-1.0.0-SNAPSHOT.zip -install river-cassandra
Remove:
./bin/plugin -remove river-cassandra
##Init
curl -XPUT 'localhost:9200/_river/prodinfo/_meta' -d '{
"type" : "cassandra",
"cassandra" : {
"cluster_name" : "test-cluster",
"keyspace" : "catalogks",
"column_family" : "info",
"batch_size" : 1000,
"hosts" : "host1:9161,host2:9161",
"username" : "username",
"password" : "password"
},
"index" : {
"index" : "prodinfo",
"type" : "product"
}
}'
##Query
- localhost:9200/info/_search
- localhost:9200/info/_count
##References
- http://jfarrell.github.com/
- Setup elasticsearch-head and bigdesk to monitor ES
##Improvements