Class EqualityDeleteRowReader

  • All Implemented Interfaces:
    java.io.Closeable, java.lang.AutoCloseable

    public class EqualityDeleteRowReader
    extends java.lang.Object
    • Constructor Detail

      • EqualityDeleteRowReader

        public EqualityDeleteRowReader​(CombinedScanTask task,
                                       Table table,
                                       Schema expectedSchema,
                                       boolean caseSensitive)
    • Method Detail

      • tableSchema

        protected Schema tableSchema()
      • open

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

        protected Table table()
      • 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.lang.AutoCloseable
        Specified by:
        close in interface java.io.Closeable
        Throws:
        java.io.IOException
      • getInputFile

        protected InputFile getInputFile​(java.lang.String location)
      • constantsMap

        protected java.util.Map<java.lang.Integer,​?> constantsMap​(FileScanTask task,
                                                                        Schema readSchema)
      • convertConstant

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