?I am working to move our code from Yarn based StreamTask to standalone
StreamApplication via LocalTaskRunner.
I'm having some trouble understanding how to create/fetch a Context for use in
the IntiableFunction.init() interface. My old code used context to get the
store for LocalCacheManager initialization so I need this context. I see no
interesting methods in StreamAplicationDescriptor.
I am launching my StreamApplication via a TaskRunner:
Where/how do i get a Samza.context.Context?
public static void main( String[] args )
{
CommandLine cmdLine = new CommandLine();
OptionSet options = cmdLine.parser().parse(args);
Config config = cmdLine.loadConfig(options);
InquirySubmissionApp app= new InquirySubmissionApp(config);
// Need to get a context here?
app.init();
LocalApplicationRunner localApplicationRunner = new
LocalApplicationRunner(app, config);
localApplicationRunner.run();
localApplicationRunner.waitForFinish();
}?
Jeremiah Adams
Software Engineer
www.helixeducation.com<http://www.helixeducation.com/>
Blog<http://www.helixeducation.com/blog/> |
Twitter<https://twitter.com/HelixEducation> |
Facebook<https://www.facebook.com/HelixEducation> |
LinkedIn<http://www.linkedin.com/company/3609946>
