public class EqualityDeleteRowReader
extends java.lang.Object
Constructor and Description |
---|
EqualityDeleteRowReader(CombinedScanTask task,
Table table,
Schema tableSchema,
Schema expectedSchema,
boolean caseSensitive) |
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() |
public EqualityDeleteRowReader(CombinedScanTask task, Table table, Schema tableSchema, Schema expectedSchema, boolean caseSensitive)
protected CloseableIterator<org.apache.spark.sql.catalyst.InternalRow> open(FileScanTask task)
public org.apache.spark.sql.connector.metric.CustomTaskMetric[] currentMetricsValues()
currentMetricsValues
in interface org.apache.spark.sql.connector.read.PartitionReader<org.apache.spark.sql.catalyst.InternalRow>
protected java.util.stream.Stream<ContentFile<?>> referencedFiles(FileScanTask task)
protected CloseableIterable<org.apache.spark.sql.catalyst.InternalRow> open(FileScanTask task, Schema readSchema, java.util.Map<java.lang.Integer,?> idToConstant)
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)
protected Schema expectedSchema()
protected boolean caseSensitive()
protected NameMapping nameMapping()
protected Table table()
protected DeleteCounter counter()
public boolean next() throws java.io.IOException
java.io.IOException
public T get()
public void close() throws java.io.IOException
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
java.io.IOException
protected InputFile getInputFile(java.lang.String location)
protected java.util.Map<java.lang.Integer,?> constantsMap(ContentScanTask<?> task, Schema readSchema)
protected static java.lang.Object convertConstant(Type type, java.lang.Object value)