Skip to content

Instantly share code, notes, and snippets.

@jamestung1990

jamestung1990/RemoteIteratorWrapper.scala

Forked from timvw/RemoteIteratorWrapper.scala
Created April 24, 2017 03:04
Show Gist options

  • Select an option

    Learn more about clone URLs
  • Save jamestung1990/ed75b9887898fe936c0a202c1f23b71d to your computer and use it in GitHub Desktop.

Select an option

Learn more about clone URLs
Save jamestung1990/ed75b9887898fe936c0a202c1f23b71d to your computer and use it in GitHub Desktop.
Download ZIP
scala wrapper for hadoop remote iterator
Raw
RemoteIteratorWrapper.scala
case class RemoteIteratorWrapper[T](underlying: org.apache.hadoop.fs.RemoteIterator[T]) extends scala.collection.AbstractIterator[T] with scala.collection.Iterator[T] {
def hasNext = underlying.hasNext
def next() = underlying.next()
}
object Conversions {
implicit def remoteIterator2ScalaIterator[T](underlying: org.apache.hadoop.fs.RemoteIterator[T]) : scala.collection.Iterator[T] = RemoteIteratorWrapper[T](underlying)
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment