org.mule.modules.sparksql.util

Class RowAsMapIterator

java.lang.Object

org.mule.modules.sparksql.util.RowAsMapIterator

All Implemented Interfaces:

Iterator<Map<String,Object>>

public class RowAsMapIterator
extends Object
implements Iterator<Map<String,Object>>

Field Summary

Fields

Modifier and Type	Field and Description
protected String[]	colNames
protected Iterator<org.apache.spark.sql.Row>	rowIterator

Constructor Summary

Constructors

Constructor and Description
RowAsMapIterator(org.apache.spark.sql.DataFrame dataFrame)

Method Summary

Modifier and Type	Method and Description
boolean	hasNext()
Map<String,Object>	next()
void	remove()
protected Map<String,Object>	toMap(org.apache.spark.sql.Row row)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.Iterator

forEachRemaining

Field Detail

rowIterator

protected final Iterator<org.apache.spark.sql.Row> rowIterator

colNames

protected final String[] colNames

Constructor Detail

RowAsMapIterator

public RowAsMapIterator(org.apache.spark.sql.DataFrame dataFrame)

Method Detail

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<Map<String,Object>>

next

public Map<String,Object> next()

Specified by:

next in interface Iterator<Map<String,Object>>

toMap

protected Map<String,Object> toMap(org.apache.spark.sql.Row row)

remove

public void remove()

Specified by:

remove in interface Iterator<Map<String,Object>>