com.lancedb.lance.spark.read

Class LanceRowPartitionReader

java.lang.Object

com.lancedb.lance.spark.read.LanceRowPartitionReader

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.spark.sql.connector.read.PartitionReader<org.apache.spark.sql.catalyst.InternalRow>

public class LanceRowPartitionReader
extends Object
implements org.apache.spark.sql.connector.read.PartitionReader<org.apache.spark.sql.catalyst.InternalRow>

Constructor Summary

Constructors

Constructor and Description
LanceRowPartitionReader(LanceColumnarPartitionReader reader)

Method Summary

Modifier and Type	Method and Description
void	close()
static LanceRowPartitionReader	create(LanceInputPartition inputPartition)
org.apache.spark.sql.catalyst.InternalRow	get()
boolean	next()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.spark.sql.connector.read.PartitionReader

currentMetricsValues

Constructor Detail

LanceRowPartitionReader

public LanceRowPartitionReader(LanceColumnarPartitionReader reader)

Method Detail

create

public static LanceRowPartitionReader create(LanceInputPartition inputPartition)

next

public boolean next()
             throws IOException

Specified by:

next in interface org.apache.spark.sql.connector.read.PartitionReader<org.apache.spark.sql.catalyst.InternalRow>

Throws:

IOException

get

public org.apache.spark.sql.catalyst.InternalRow get()

Specified by:

get in interface org.apache.spark.sql.connector.read.PartitionReader<org.apache.spark.sql.catalyst.InternalRow>

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException