Package 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 Description EqualityDeleteRowReader(CombinedScanTask task, Table table, Schema tableSchema, Schema expectedSchema, boolean caseSensitive)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method 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()
-
-
-
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 interfaceorg.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 interfacejava.lang.AutoCloseable
- Specified by:
close
in interfacejava.io.Closeable
- 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)
-
-