public interface MapPartitionsFunction<T,U> extends java.io.Serializable
Iterable<U>
call(java.util.Iterator<T> input)
Iterable<U> call(java.util.Iterator<T> input) throws Exception
Exception