More info for running examples from Scala.

h2o-scala/README.rst

@@ -71,6 +71,14 @@ You can start REPL via ``sbt``:
 
   sbt run
 
+Launch Examples
+-----------
+Shalala provides a convenient way to run examples via ``sbt``:
+
+::
+
+  sbt runExamples
+
 
 Key points of implementation
 ----------------------------

h2o-scala/src/main/scala/water/api/dsl/MRLegos.scala

@@ -0,0 +1,8 @@
+package water.api.dsl
+
+/**
+ * Created by michal on 3/19/14.
+ */
+class MRLegos {
+
+}

h2o-scala/src/main/scala/water/api/dsl/SMRTask.scala

@@ -0,0 +1,35 @@
+package water.api.dsl
+
+import water.fvec.Chunk
+import water.MRTask2
+
+abstract class SMRTask[T] extends MRTask2[T] {
+  def iterator(chunks:Array[Chunk]) : Iterator[Row] = new RowIterator(chunks)
+
+  private class RowIterator (private val chunks:Array[Chunk]) extends Iterator[Row] {
+    private var rowNum: Int = -1
+    private val row = new CRow
+    def next()  : Row = {
+      rowNum += 1
+      return if (rowNum < chunks(0)._len) row else null
+    }
+    def hasNext() : Boolean = rowNum+1 < chunks(0)._len
+
+    /** Array of chunks encapsulation */
+    class CRow extends Row {
+      override def d(ncol: Int): scala.Double = chunks(ncol).at0 (rowNum)
+      override def l(ncol: Int): scala.Long   = chunks(ncol).at80(rowNum)
+      override def ncols(): Int = chunks.length
+    }
+  }
+
+  /** Row accessor. */
+  trait Row {
+    def d(ncol:Int):scala.Double
+    def l(ncol:Int):scala.Long
+    def ncols() : Int
+  }
+}
+
+
+