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 20:19:33 GMT
Hey Shekar,

You should be calling config.get("system.xyz").

Cheers,
Chris

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

>Just to clarify, this is defined in wikipedia-parser.properties
>
>On Fri, Nov 21, 2014 at 11:12 AM, Shekar Tippur <ctippur@gmail.com> wrote:
>
>> Here is the portion of the config ..
>>
>> # Normally, we'd set this much higher, but we want things to look snappy
>> in the demo.
>>
>> systems.kafka.producer.batch.num.messages=1
>>
>> systems.kafka.streams.metrics.samza.msg.serde=metrics
>>
>> system.xyz=hello
>>
>> On Fri, Nov 21, 2014 at 11:03 AM, Chris Riccomini <
>> criccomini@linkedin.com.invalid> wrote:
>>
>>> 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.PropertiesConfigFa
>>>>>>cto
>>> >>>ry
>>> >> >--config-path=file://$PWD/conf/wikipedia-parser.properties.local
>>> >> >
>>> >> >- Shekar
>>> >>
>>> >>
>>>
>>>
>>


Mime
View raw message