org.apache.iceberg.spark.source

Class EqualityDeleteRowReader

java.lang.Object

org.apache.iceberg.spark.source.EqualityDeleteRowReader

All Implemented Interfaces:

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

public class EqualityDeleteRowReader
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
EqualityDeleteRowReader(CombinedScanTask task, Table table, Schema tableSchema, Schema expectedSchema, boolean caseSensitive)

Method Summary

Modifier and Type	Method and Description
protected boolean	caseSensitive()
void	close()
protected java.util.Map<java.lang.Integer,?>	constantsMap(ContentScanTask<?> task, Schema readSchema)
protected static java.lang.Object	convertConstant(Type type, java.lang.Object value)
protected DeleteCounter	counter()
org.apache.spark.sql.connector.metric.CustomTaskMetric[]	currentMetricsValues()
protected Schema	expectedSchema()
T	get()
protected InputFile	getInputFile(java.lang.String location)
protected NameMapping	nameMapping()
protected CloseableIterable<org.apache.spark.sql.catalyst.InternalRow>	newIterable(InputFile file, FileFormat format, long start, long length, Expression residual, Schema projection, java.util.Map<java.lang.Integer,?> idToConstant)
boolean	next()
protected CloseableIterator<org.apache.spark.sql.catalyst.InternalRow>	open(FileScanTask task)
protected CloseableIterable<org.apache.spark.sql.catalyst.InternalRow>	open(FileScanTask task, Schema readSchema, java.util.Map<java.lang.Integer,?> idToConstant)
protected java.util.stream.Stream<ContentFile<?>>	referencedFiles(FileScanTask task)
protected Table	table()

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

get, next

Methods inherited from interface java.io.Closeable

close

Constructor Detail

EqualityDeleteRowReader

public EqualityDeleteRowReader(CombinedScanTask task,
                               Table table,
                               Schema tableSchema,
                               Schema expectedSchema,
                               boolean caseSensitive)

Method Detail

open

protected CloseableIterator<org.apache.spark.sql.catalyst.InternalRow> open(FileScanTask task)

currentMetricsValues

public org.apache.spark.sql.connector.metric.CustomTaskMetric[] currentMetricsValues()

Specified by:

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

referencedFiles

protected java.util.stream.Stream<ContentFile<?>> referencedFiles(FileScanTask task)

open

protected CloseableIterable<org.apache.spark.sql.catalyst.InternalRow> open(FileScanTask task,
                                                                            Schema readSchema,
                                                                            java.util.Map<java.lang.Integer,?> idToConstant)

newIterable

protected CloseableIterable<org.apache.spark.sql.catalyst.InternalRow> newIterable(InputFile file,
                                                                                   FileFormat format,
                                                                                   long start,
                                                                                   long length,
                                                                                   Expression residual,
                                                                                   Schema projection,
                                                                                   java.util.Map<java.lang.Integer,?> idToConstant)

expectedSchema

protected Schema expectedSchema()

caseSensitive

protected boolean caseSensitive()

nameMapping

protected NameMapping nameMapping()

table

protected Table table()

counter

protected DeleteCounter counter()

next

public boolean next()
             throws java.io.IOException

Throws:

java.io.IOException

get

public T get()

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.io.IOException

getInputFile

protected InputFile getInputFile(java.lang.String location)

constantsMap

protected java.util.Map<java.lang.Integer,?> constantsMap(ContentScanTask<?> task,
                                                          Schema readSchema)

convertConstant

protected static java.lang.Object convertConstant(Type type,
                                                  java.lang.Object value)