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 <
[email protected]> 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" <[email protected]> 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.PropertiesConfigFactory
> >--config-path=file://$PWD/conf/wikipedia-parser.properties.local
> >
> >- Shekar
>
>
