Prashant, it has an INSERT query, but no SELECT query. It does not implement getNext(), so it looks like it is STORE only, not LOAD. Am I mistaken? I read the source, but it was late :)
On Sun, Apr 29, 2012 at 12:04 PM, Prashant Kommireddi <[email protected]>wrote: > Russell, > > Looking at source code for DBStorage, seems like it does exactly that. Can > you try it out? > > public DBStorage(String driver, String jdbcURL, String user, String pass, > String insertQuery, String batchSize) > > Thanks, > Prashant > > > > On Sat, Apr 28, 2012 at 12:22 AM, Russell Jurney > <[email protected]>wrote: > > > Is it possible to use DBStorage to load data from MySQL by running a > > suppled SQL query? Something like: > > > > mydata = LOAD 'jdbc://localhost/enron' USING DBStorage('SELECT > foo.value1, > > bar.value2 FROM foo JOIN bar on foo.bar_id = bar.id'); > > > > > > Even if I have to LOAD AS and specify a schema, that would be great. > > > > It is problematic that there are no docs for DBStorage. If someone clues > me > > in, I'll write it up :) > > > > -- > > Russell Jurney twitter.com/rjurney [email protected] > > datasyndrome.com > > > -- Russell Jurney twitter.com/rjurney [email protected] datasyndrome.com
