FileStream¶
<auto-generated stub>
Static methods¶
def apply(x: Rep[String]): Rep[FileStream]
Infix methods¶
def foreach(y: (Rep[String]) => Rep[Unit]): Rep[Unit]
def groupRowsBy(outTable: Rep[String], delim: Rep[String] = unit("\s+"), trim: Rep[Boolean] = true, appendToHash: Rep[Boolean] = false)(keyFunc: (Rep[DenseVector[String]]) => Rep[String], valFunc: (Rep[DenseVector[String]]) => Rep[DenseVector[Double]]): Rep[HashStream[DenseMatrix[Double]]]
def map(outFile: Rep[String], preserveOrder: Rep[Boolean] = false, chunkSize: Rep[Long] = filestream_getchunkbytesize())(func: (Rep[String]) => Rep[String]): Rep[FileStream]
def mapRows(outFile: Rep[String], inDelim: Rep[String] = unit("\s+"), outDelim: Rep[String] = unit(" "), trim: Rep[Boolean] = true)(func: (Rep[DenseVector[String]]) => Rep[DenseVector[R]])(implicit ev0: Stringable[R]): Rep[FileStream]
def path(): Rep[String]
def processFileChunks(readFunc: (Rep[String],Rep[String]) => Rep[R], processFunc: (Rep[ForgeArray[R]]) => Rep[Unit], chunkSize: Rep[Long] = filestream_getchunkbytesize()): Rep[Unit]
def reduce(zero: Rep[T])(func: (Rep[String]) => Rep[T])(rfunc: (Rep[T],Rep[T]) => Rep[T]): Rep[T]