com.lancedb.lance.spark.internal

Class LanceFragmentColumnarBatchScanner

java.lang.Object

com.lancedb.lance.spark.internal.LanceFragmentColumnarBatchScanner

All Implemented Interfaces:

AutoCloseable

public class LanceFragmentColumnarBatchScanner
extends Object
implements AutoCloseable

Constructor Summary

Constructors

Constructor and Description
LanceFragmentColumnarBatchScanner(LanceFragmentScanner fragmentScanner, org.apache.arrow.vector.ipc.ArrowReader arrowReader)

Method Summary

Modifier and Type	Method and Description
void	close()
static LanceFragmentColumnarBatchScanner	create(int fragmentId, LanceInputPartition inputPartition)
org.apache.spark.sql.vectorized.ColumnarBatch	getCurrentBatch()
boolean	loadNextBatch()

Methods inherited from class java.lang.Object

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

Constructor Detail

LanceFragmentColumnarBatchScanner

public LanceFragmentColumnarBatchScanner(LanceFragmentScanner fragmentScanner,
                                         org.apache.arrow.vector.ipc.ArrowReader arrowReader)

Method Detail

create

public static LanceFragmentColumnarBatchScanner create(int fragmentId,
                                                       LanceInputPartition inputPartition)

loadNextBatch

public boolean loadNextBatch()
                      throws IOException

Throws:

IOException

getCurrentBatch

public org.apache.spark.sql.vectorized.ColumnarBatch getCurrentBatch()

Returns:

the current batch, the caller responsible for closing the batch

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Throws:

IOException