Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 Search Hadoop and all its subprojects:

Switch to Threaded View
Accumulo >> mail # user >> Access to connector inside a Mapper class?


Copy link to this message
-
Re: Access to connector inside a Mapper class?
Thanks Christopher and David, for the moment I am re-constructing a
Connector in the set up of the job based on the configuration parameters,
but I may also try out extending AccumuloInputFormat as it feels a little
cleaner.

Thanks!

Mike
On Sat, Jan 26, 2013 at 1:10 PM, Christopher <[EMAIL PROTECTED]> wrote:

> If you extend AccumuloInputFormat to make the required protected methods
> public, you could do:
>
> MyAccumuloInputFormat.getInstance(context).getConnector(My
> AccumuloInputFormat.getUsername(context),MyAccumuloInputFormat.getPassword(context))
> with your TaskAttemptContext in the mapper/reducer.
>
> Or, you could store your own configuration options to re-construct a Connector
> when you set up your job (you could re-use those configuration variables we
> set, but that's... relying on implementation details that may change).
>
>
>
> --
> Christopher L Tubbs II
> http://gravatar.com/ctubbsii
>
>
> On Wed, Jan 23, 2013 at 1:50 PM, Mike Hugo <[EMAIL PROTECTED]> wrote:
>
>> Is there a way to get access to the underlying connector being used by
>> the Accumulo Input Format inside the map method of a Mapper class?  In
>> certain scenarios, I need to be able to look up a value from a different
>> table while iterating over a set of keys in the mapper class.  Should I
>> just create a new connector instance?
>>
>> Mike
>>
>
>
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB