SPARK报错……: File '

 : : failed to compile: : File '', Line 61, Column 30: Index expression of type "" cannot be widened to "int"
/* 001 */ import ;
/* 002 */ import ;
/* 003 */ import ;
/* 004 */ import ;
/* 005 */ import ;
/* 006 */ import ;
/* 007 */ import ;
/* 008 */
/* 009 */ public SpecificColumnarIterator generate(Object[] references) {
/* 010 */   return new SpecificColumnarIterator();
/* 011 */ }
/* 012 */
/* 013 */ class SpecificColumnarIterator extends {
/* 014 */
/* 015 */   private ByteOrder nativeOrder = null;
/* 016 */   private byte[][] buffers = null;
/* 017 */   private UnsafeRow unsafeRow = new UnsafeRow(5);
/* 018 */   private BufferHolder bufferHolder = new BufferHolder(unsafeRow);
/* 019 */   private UnsafeRowWriter rowWriter = new UnsafeRowWriter(bufferHolder, 5);
/* 020 */   private MutableUnsafeRow mutableRow = null;
/* 021 */
/* 022 */   private int currentRow = 0;
/* 023 */   private int numRowsInBatch = 0;
/* 024 */
/* 025 */   private input = null;
/* 026 */   private DataType[] columnTypes = null;
/* 027 */   private int[] columnIndexes = null;
/* 028 */
/* 029 */   private accessor;
/* 030 */   private accessor1;
/* 031 */   private accessor2;
/* 032 */   private accessor3;
/* 033 */   private accessor4;
/* 034 */
/* 035 */   public SpecificColumnarIterator() {
/* 036 */     = ();
/* 037 */     = new byte[5][];
/* 038 */     = new MutableUnsafeRow(rowWriter);
/* 039 */   }
/* 040 */
/* 041 */   public void initialize(Iterator input, DataType[] columnTypes, int[] columnIndexes) {
/* 042 */     = input;
/* 043 */     = columnTypes;
/* 044 */     = columnIndexes;
/* 045 */   }
/* 046 */
/* 047 */
/* 048 */
/* 049 */   public boolean hasNext() {
/* 050 */     if (currentRow < numRowsInBatch) {
/* 051 */       return true;
/* 052 */     }
/* 053 */     if (!()) {
/* 054 */       return false;
/* 055 */     }
/* 056 */
/* 057 */     batch = () ();
/* 058 */     currentRow = 0;
/* 059 */     numRowsInBatch = ();
/* 060 */     for (int i = 0; i < ; i ++) {
/* 061 */       buffers[i] = ()[columnIndexes[i]];
/* 062 */     }
/* 063 */     accessor = new ((buffers[0]).order(nativeOrder));
/* 064 */     accessor1 = new ((buffers[1]).order(nativeOrder));
/* 065 */     accessor2 = new ((buffers[2]).order(nativeOrder));
/* 066 */     accessor3 = new ((buffers[3]).order(nativeOrder));
/* 067 */     accessor4 = new ((buffers[4]).order(nativeOrder));
/* 068 */
/* 069 */     return hasNext();
/* 070 */   }
/* 071 */
/* 072 */   public InternalRow next() {
/* 073 */     currentRow += 1;
/* 074 */     ();
/* 075 */     ();
/* 076 */     (mutableRow, 0);
/* 077 */     (mutableRow, 1);
/* 078 */     (mutableRow, 2);
/* 079 */     (mutableRow, 3);
/* 080 */     (mutableRow, 4);
/* 081 */     (());
/* 082 */     return unsafeRow;
/* 083 */   }
/* 084 */ }


        at org.spark_project.$(:306)
        at org.spark_project.$(:293)
        at org.spark_project.(:116)
        at org.spark_project.(:135)
        at org.spark_project.$(:2410)
        at org.spark_project.$(:2380)
        at org.spark_project.$(:2342)
        at org.spark_project.$(:2257)
        at org.spark_project.(:4000)
        at org.spark_project.(:4004)
        at org.spark_project.$(:4874)
        at $.compile(:905)
        at $.create(:233)
        at $.create(:65)
        at (:889)
        at $$anonfun$doExecute$(:180)
        at $$anonfun$doExecute$(:135)
        at $$anonfun$mapPartitionsWithIndexInternal$1$$anonfun$apply$(:815)
        at $$anonfun$mapPartitionsWithIndexInternal$1$$anonfun$apply$(:815)
        at (:38)
        at (:323)
        at (:287)
        at (:38)
        at (:323)
        at (:287)
        at (:38)
        at (:323)
        at (:287)
        at (:96)
        at (:53)
        at (:99)
        at $(:322)
        at (:1149)
        at $(:624)