> On Dec. 11, 2014, 1:39 a.m., Chris Mattmann wrote: > > trunk/resource/src/main/java/org/apache/oodt/cas/resource/spark/StreamingInstance.java, > > line 1 > > <https://reviews.apache.org/r/28917/diff/1/?file=788649#file788649line1> > > > > batchmgr pkg
Put in structs like SparkInstance. This is where it belongs, as it is a struct. > On Dec. 11, 2014, 1:39 a.m., Chris Mattmann wrote: > > trunk/resource/src/main/java/org/apache/oodt/cas/resource/spark/examples/PalindromeUtils.java, > > line 1 > > <https://reviews.apache.org/r/28917/diff/1/?file=788651#file788651line1> > > > > o.a.oodt.cas.resource.util Placed in Examples, as it is shared-code for the examples. It is only intended to support examples. If the class needs to be renamed, that can be done. - Michael ----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/28917/#review64662 ----------------------------------------------------------- On Dec. 17, 2014, 7:13 p.m., Michael Starch wrote: > > ----------------------------------------------------------- > This is an automatically generated e-mail. To reply, visit: > https://reviews.apache.org/r/28917/ > ----------------------------------------------------------- > > (Updated Dec. 17, 2014, 7:13 p.m.) > > > Review request for oodt and Chris Mattmann. > > > Repository: oodt > > > Description > ------- > > This change allows Spark jobs to be run in the resource manager. It > integrates with a generic Spark daemon, so spark can be run locally, as a > test spark cluster, and in mesos (not affiliated with the resouce manager > mesos integration). > > This is a solution to: https://issues.apache.org/jira/browse/OODT-780 > > > Diffs > ----- > > trunk/core/pom.xml 1644527 > trunk/resource/pom.xml 1644527 > > trunk/resource/src/main/java/org/apache/oodt/cas/resource/examples/NoSparkFilePalindromeExample.java > PRE-CREATION > > trunk/resource/src/main/java/org/apache/oodt/cas/resource/examples/PalindromeUtils.java > PRE-CREATION > > trunk/resource/src/main/java/org/apache/oodt/cas/resource/examples/SparkFilePalindromeExample.java > PRE-CREATION > > trunk/resource/src/main/java/org/apache/oodt/cas/resource/examples/StreamingPalindromeExample.java > PRE-CREATION > > trunk/resource/src/main/java/org/apache/oodt/cas/resource/scheduler/SparkScheduler.java > PRE-CREATION > > trunk/resource/src/main/java/org/apache/oodt/cas/resource/scheduler/SparkSchedulerFactory.java > PRE-CREATION > > trunk/resource/src/main/java/org/apache/oodt/cas/resource/structs/SparkInstance.java > PRE-CREATION > > trunk/resource/src/main/java/org/apache/oodt/cas/resource/structs/StreamingInstance.java > PRE-CREATION > trunk/resource/src/main/resources/examples/jobs/exPalindrome.xml > PRE-CREATION > trunk/resource/src/main/resources/examples/jobs/exSparkJob.xml PRE-CREATION > trunk/resource/src/main/resources/examples/jobs/exSparkPalindrome.xml > PRE-CREATION > trunk/resource/src/main/resources/examples/jobs/exStreamingPalindrome.xml > PRE-CREATION > trunk/resource/src/main/resources/resource.properties 1644527 > > trunk/resource/src/main/scala/org/apache/oodt/cas/resource/examples/ScalaHelloWorld.scala > PRE-CREATION > > Diff: https://reviews.apache.org/r/28917/diff/ > > > Testing > ------- > > Demonstration created, demonstration jobs run and benchmarks taken. > > > Thanks, > > Michael Starch > >
