Package 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	Description
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<com.lancedb.lance.ipc.ColumnOrdering>> topNSortOrders, Optional<org.apache.spark.sql.connector.expressions.aggregate.Aggregation> pushedAggregation, String scanId)
LanceInputPartition(org.apache.spark.sql.types.StructType schema, int partitionId, LanceSplit lanceSplit, LanceConfig config, Optional<String> whereCondition, String scanId)

Method Summary

Modifier and Type	Method	Description
LanceConfig	getConfig()
LanceSplit	getLanceSplit()
Optional<Integer>	getLimit()
Optional<Integer>	getOffset()
int	getPartitionId()
Optional<org.apache.spark.sql.connector.expressions.aggregate.Aggregation>	getPushedAggregation()
String	getScanId()
org.apache.spark.sql.types.StructType	getSchema()
Optional<List<com.lancedb.lance.ipc.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 Details

LanceInputPartition

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

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<com.lancedb.lance.ipc.ColumnOrdering>> topNSortOrders,
 Optional<org.apache.spark.sql.connector.expressions.aggregate.Aggregation> pushedAggregation,
 String scanId)

Method Details

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<com.lancedb.lance.ipc.ColumnOrdering>> getTopNSortOrders()

getPushedAggregation

public Optional<org.apache.spark.sql.connector.expressions.aggregate.Aggregation> getPushedAggregation()

getScanId

public String getScanId()