I ended up create a utility class which combines the functionality of CQLSSTableWriter and the existing BulkLoader class which is used by the sstableloader. The code is located here:
https://github.com/paul-weiss/cassandra-examples/blob/master/src/main/java/org/apache/cassandra/tools/BulkWriterLoader.java If there is interest I could merge into the codebase, just let me know. thanks, -paul On Wed, Sep 21, 2016 at 9:37 PM, J. D. Jordan <jeremiah.jor...@gmail.com> wrote: > Yeah. I wouldn't use that class, I was just pointing it out as an example > of code doing a similar thing. > > > On Sep 21, 2016, at 8:16 PM, Paul Weiss <paulweiss....@gmail.com> wrote: > > > > Great will try out. I noticed the code is within the hadoop folder, I > am > > using local disk so hopefully it will work without hadoop. > > > > Thanks, > > -paul > > > > On Sep 21, 2016 8:56 PM, "Jeremiah D Jordan" <jeremiah.jor...@gmail.com> > > wrote: > > > >> Yes using the SSTableLoader class. You can see the CqlBulkRecordWriter > >> class for an example of writing out sstables to disk and then using the > >> SSTableLoader class to stream them to a cluster. > >> > >> -Jeremiah > >> > >>> On Sep 21, 2016, at 7:18 PM, Paul Weiss <paulweiss....@gmail.com> > wrote: > >>> > >>> Hi, > >>> > >>> Is it possible to call the sstableloader from java instead using the > >>> command line program? I have a process that uses the CQLSSTableWriter > and > >>> generates the sstable files but am looking for an end to end process > that > >>> bulk loads without any manual intervention. > >>> > >>> Ideally would like to avoid forking another process so I can properly > >> check > >>> for errors. > >>> > >>> Thanks, > >>> -paul > >> > >> >
