Skip to content
No description, website, or topics provided.
Java
Branch: master
Clone or download

Latest commit

Fetching latest commit…
Cannot retrieve the latest commit at this time.

Files

Permalink
Type Name Latest commit message Commit time
Failed to load latest commit information.
gradle/wrapper initial commit Sep 26, 2014
src/main/java/bulkload initial commit Sep 26, 2014
.gitignore initial commit Sep 26, 2014
LICENSE Initial commit Sep 26, 2014
README.md initial commit Sep 26, 2014
build.gradle Add explicit supercsv dependency as was removed from C* in 3.0. Feb 21, 2016
gradlew initial commit Sep 26, 2014
gradlew.bat initial commit Sep 26, 2014
schema.cql initial commit Sep 26, 2014
settings.gradle

README.md

cassandra-bulkload-example

Sample SSTable generating and bulk loading code for DataStax Using Cassandra Bulk Loader, Updated blog post. This fetches historical prices from Yahoo! Finance in CSV format, and turn them to SSTables.

Generating SSTables

Run:

$ ./gradlew run

This will generate SSTable(s) under data directory.

Bulk loading

First, create schema using schema.cql file:

$ cqlsh -f schema.cql

Then, load SSTables to Cassandra using sstableloader:

$ sstableloader -d <ip address of the node> data/quote/historical_prices

(assuming you have cqlsh and sstableloader in your $PATH)

Check loaded data

$ bin/cqlsh
Connected to Test Cluster at 127.0.0.1:9042.
[cqlsh 5.0.1 | Cassandra 2.1.0 | CQL spec 3.2.0 | Native protocol v3]
Use HELP for help.
cqlsh> USE quote ;
cqlsh:quote> SELECT * FROM historical_prices WHERE ticker = 'ORCL' LIMIT 3;

 ticker | date                     | adj_close | close | high  | low   | open  | volume
--------+--------------------------+-----------+-------+-------+-------+-------+----------
   ORCL | 2014-09-25 00:00:00-0500 |     38.76 | 38.76 | 39.35 | 38.65 | 39.35 | 13287800
   ORCL | 2014-09-24 00:00:00-0500 |     39.42 | 39.42 | 39.56 | 38.57 | 38.77 | 18906200
   ORCL | 2014-09-23 00:00:00-0500 |     38.83 | 38.83 | 39.59 | 38.80 | 39.50 | 34353300

(3 rows)

Voilà!

You can’t perform that action at this time.