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 booleancaseSensitive()voidclose()protected java.util.Map<java.lang.Integer,?>constantsMap(ContentScanTask<?> task, Schema readSchema)protected static java.lang.ObjectconvertConstant(Type type, java.lang.Object value)protected DeleteCountercounter()org.apache.spark.sql.connector.metric.CustomTaskMetric[]currentMetricsValues()protected SchemaexpectedSchema()Tget()protected InputFilegetInputFile(java.lang.String location)protected NameMappingnameMapping()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)booleannext()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 Tabletable()
-
-
-
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:
currentMetricsValuesin 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:
closein interfacejava.lang.AutoCloseable- Specified by:
closein 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)
-
-