SQL to File streaming with NIO

FileStreaming.java

/**
 *
 * Statefull File Streaming class that write files with java.nio.
 *
 */
class FileStreaming(filename: String) {

  val output = new java.io.File(ApplicationConf.outputDir, filename)
  output.createNewFile()

  val channel = new RandomAccessFile(output, "rw").getChannel
  val buffer = ByteBuffer.allocate(1024)

  var count = 0

  def stream(rs: WrappedResultSet) {
    buffer.clear
    val data = Metadata(rs).data.map(t => t._2).mkString("", "|", "\n").getBytes
    (0 to data.length - 1).foreach(i => buffer put data(i))
    buffer.flip
    channel.write(buffer)
    count += 1
  }

  def close() = channel.close()
}