org.apache.hive.beeline

Class IncrementalRowsWithNormalization

java.lang.Object

org.apache.hive.beeline.IncrementalRows

org.apache.hive.beeline.IncrementalRowsWithNormalization

All Implemented Interfaces:

Iterator

public class IncrementalRowsWithNormalization
extends IncrementalRows

Extension of IncrementalRows which buffers "x" number of rows in memory at a time. It uses the BufferedRows class to do its buffering. The value of "x" is determined by the Beeline option --incrementalBufferRows, which defaults to BeeLineOpts.DEFAULT_INCREMENTAL_BUFFER_ROWS. Once the initial set of rows are buffered, it will allow the next() method to drain the buffer. Once the buffer is empty the next buffer will be fetched until the ResultSet is empty. The width of the rows are normalized within each buffer using the BufferedRows.normalizeWidths() method.

Field Summary

Fields

Modifier and Type	Field and Description
protected BeeLine	beeLine

Fields inherited from class org.apache.hive.beeline.IncrementalRows

normalizingWidths, rs

Method Summary

Modifier and Type	Method and Description
boolean	hasNext()
Object	next()
void	remove()

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

beeLine

protected final BeeLine beeLine

Method Detail

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator

Overrides:

hasNext in class IncrementalRows

next

public Object next()

Specified by:

next in interface Iterator

Overrides:

next in class IncrementalRows

remove

public void remove()

Specified by:

remove in interface Iterator