public class IncrementalRowsWithNormalization extends IncrementalRows
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.Modifier and Type | Field and Description |
---|---|
protected BeeLine |
beeLine |
normalizingWidths, rs
Modifier and Type | Method and Description |
---|---|
boolean |
hasNext() |
Object |
next() |
void |
remove() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
forEachRemaining
protected final BeeLine beeLine
public boolean hasNext()
hasNext
in interface Iterator
hasNext
in class IncrementalRows
public Object next()
next
in interface Iterator
next
in class IncrementalRows
Copyright © 2022 The Apache Software Foundation. All rights reserved.