com.lancedb.lance.spark.read

Class LanceInputPartition

java.lang.Object

com.lancedb.lance.spark.read.LanceInputPartition

All Implemented Interfaces:

Serializable, org.apache.spark.sql.connector.read.InputPartition

public class LanceInputPartition
extends Object
implements org.apache.spark.sql.connector.read.InputPartition

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
LanceInputPartition(org.apache.spark.sql.types.StructType schema, int partitionId, LanceSplit lanceSplit, LanceConfig config, Optional<String> whereCondition)
LanceInputPartition(org.apache.spark.sql.types.StructType schema, int partitionId, LanceSplit lanceSplit, LanceConfig config, Optional<String> whereCondition, Optional<Integer> limit, Optional<Integer> offset)
LanceInputPartition(org.apache.spark.sql.types.StructType schema, int partitionId, LanceSplit lanceSplit, LanceConfig config, Optional<String> whereCondition, Optional<Integer> limit, Optional<Integer> offset, Optional<List<ColumnOrdering>> topNSortOrders)

Method Summary

Modifier and Type	Method and Description
LanceConfig	getConfig()
LanceSplit	getLanceSplit()
Optional<Integer>	getLimit()
Optional<Integer>	getOffset()
int	getPartitionId()
org.apache.spark.sql.types.StructType	getSchema()
Optional<List<ColumnOrdering>>	getTopNSortOrders()
Optional<String>	getWhereCondition()

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.InputPartition

preferredLocations

Constructor Detail

LanceInputPartition

public LanceInputPartition(org.apache.spark.sql.types.StructType schema,
                           int partitionId,
                           LanceSplit lanceSplit,
                           LanceConfig config,
                           Optional<String> whereCondition)

LanceInputPartition

public LanceInputPartition(org.apache.spark.sql.types.StructType schema,
                           int partitionId,
                           LanceSplit lanceSplit,
                           LanceConfig config,
                           Optional<String> whereCondition,
                           Optional<Integer> limit,
                           Optional<Integer> offset)

LanceInputPartition

public LanceInputPartition(org.apache.spark.sql.types.StructType schema,
                           int partitionId,
                           LanceSplit lanceSplit,
                           LanceConfig config,
                           Optional<String> whereCondition,
                           Optional<Integer> limit,
                           Optional<Integer> offset,
                           Optional<List<ColumnOrdering>> topNSortOrders)

Method Detail

getSchema

public org.apache.spark.sql.types.StructType getSchema()

getPartitionId

public int getPartitionId()

getLanceSplit

public LanceSplit getLanceSplit()

getConfig

public LanceConfig getConfig()

getWhereCondition

public Optional<String> getWhereCondition()

getLimit

public Optional<Integer> getLimit()

getOffset

public Optional<Integer> getOffset()

getTopNSortOrders

public Optional<List<ColumnOrdering>> getTopNSortOrders()