Hi Tushar, This is a great project to add to dtBackyard at: https://sites.google.com/a/datatorrent.com/dtbackyard/project-ownership
Ram On Mon, Sep 28, 2015 at 7:29 AM, Tushar Gosavi <[email protected]> wrote: > Hi All, > > I am trying to see how we can write a Streaming Application using Scala > language, > as Scala targets JVM and has good interoperability with Java. > > I am able to port simple pi demo in Scala along with the operators. Please > take > a look at PR#40 (https://github.com/apache/incubator-apex-malhar/pull/40) > for this work, and provide feedback. > > Created following operators in Scala > - RandomItemGenerator : Generate random points in 2d space. > - PiCalculator : Calculates value of pi > - ConsoleOutOperator : Write value of tuple on stdout, I could not use > the Java operator available in Malhar, because scala does more strong type > checking. (I need to look into this more) > > And use these operators to write a simple streaming application. > > The following functionality is working > - Scala Operators recovers correctly from the crash. > - Scala supports generating setters/getters using @BeanProperty annotation, > and these > properties become accessible through config file and we can set them > dynamically through dtcli. > - get-operator-properties is working. > > > Thanks, > -Tushar. >
