samza-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Chris Riccomini <criccom...@linkedin.com.INVALID>
Subject Re: Access samza property
Date Fri, 21 Nov 2014 19:03:34 GMT
Hey Shekar,

If your config is LITERALLY defined as "system.xyz", then you want
config.get("system.xyz"). If, however, you have an actual system defined,
and are trying to get a key/value store for it, could you post your full
config?



Cheers,
Chris

On 11/21/14 10:57 AM, "Shekar Tippur" <ctippur@gmail.com> wrote:

>Chris,
>
>Thanks for responding.
>
>  public void init(Config config, TaskContext context) {
>
>    this.store = (KeyValueStore<String, Integer>) context.getStore("xyz");
>
>  }
>
>
>I defined a init() method
>
>I have a property called system.xyz=abc
>
>I get a message - key not found: system.xyz
>
>On Fri, Nov 21, 2014 at 10:30 AM, Chris Riccomini <
>criccomini@linkedin.com.invalid> wrote:
>
>> Hey Shekar,
>>
>> You should implement InitableTask. This has an init() method which
>> receives the job's config. Then you can do config.get(), as you
>>described
>> below.
>>
>> Cheers,
>> Chris
>>
>> On 11/21/14 10:24 AM, "Shekar Tippur" <ctippur@gmail.com> wrote:
>>
>> >I have a rudimentary question. How do I access the property thats
>>defined
>> >in
>> >
>> >wikipedia-parser.properties
>> >
>> >If I define a property in wikipedia-parser.properties called
>> >
>> >system.xyz=Hello
>> >
>> >
>> >I tried to
>> >
>> >import org.apache.samza.config.Config;
>> >
>> >config.get("system.xyz")
>> >
>> >I get a null pointer exception
>> >
>> >I am passing the property file as an argument
>> >
>> >deploy/samza/bin/run-job.sh
>> 
>>>--config-factory=org.apache.samza.config.factories.PropertiesConfigFacto
>>>ry
>> >--config-path=file://$PWD/conf/wikipedia-parser.properties.local
>> >
>> >- Shekar
>>
>>


Mime
View raw message