2727import scala .collection .mutable .ArraySeq ;
2828
2929import org .apache .spark .sql .catalyst .InternalRow ;
30- import org .apache .spark .sql .BaseMutableRow ;
3130import org .apache .spark .sql .types .DataType ;
3231import org .apache .spark .sql .types .StructType ;
3332import org .apache .spark .unsafe .types .UTF8String ;
5251 *
5352 * Instances of `UnsafeRow` act as pointers to row data stored in this format.
5453 */
55- public final class UnsafeRow extends BaseMutableRow {
54+ public final class UnsafeRow extends MutableRow {
5655
5756 private Object baseObject ;
5857 private long baseOffset ;
@@ -176,56 +175,56 @@ public void update(int ordinal, Object value) {
176175 }
177176
178177 @ Override
179- public void setInt (int ordinal , int value ) {
178+ public void setBoolean (int ordinal , boolean value ) {
180179 assertIndexIsValid (ordinal );
181180 setNotNullAt (ordinal );
182- PlatformDependent .UNSAFE .putInt (baseObject , getFieldOffset (ordinal ), value );
181+ PlatformDependent .UNSAFE .putBoolean (baseObject , getFieldOffset (ordinal ), value );
183182 }
184183
185184 @ Override
186- public void setLong (int ordinal , long value ) {
185+ public void setByte (int ordinal , byte value ) {
187186 assertIndexIsValid (ordinal );
188187 setNotNullAt (ordinal );
189- PlatformDependent .UNSAFE .putLong (baseObject , getFieldOffset (ordinal ), value );
188+ PlatformDependent .UNSAFE .putByte (baseObject , getFieldOffset (ordinal ), value );
190189 }
191190
192191 @ Override
193- public void setDouble (int ordinal , double value ) {
192+ public void setShort (int ordinal , short value ) {
194193 assertIndexIsValid (ordinal );
195194 setNotNullAt (ordinal );
196- PlatformDependent .UNSAFE .putDouble (baseObject , getFieldOffset (ordinal ), value );
195+ PlatformDependent .UNSAFE .putShort (baseObject , getFieldOffset (ordinal ), value );
197196 }
198197
199198 @ Override
200- public void setBoolean (int ordinal , boolean value ) {
199+ public void setInt (int ordinal , int value ) {
201200 assertIndexIsValid (ordinal );
202201 setNotNullAt (ordinal );
203- PlatformDependent .UNSAFE .putBoolean (baseObject , getFieldOffset (ordinal ), value );
202+ PlatformDependent .UNSAFE .putInt (baseObject , getFieldOffset (ordinal ), value );
204203 }
205204
206205 @ Override
207- public void setShort (int ordinal , short value ) {
206+ public void setLong (int ordinal , long value ) {
208207 assertIndexIsValid (ordinal );
209208 setNotNullAt (ordinal );
210- PlatformDependent .UNSAFE .putShort (baseObject , getFieldOffset (ordinal ), value );
209+ PlatformDependent .UNSAFE .putLong (baseObject , getFieldOffset (ordinal ), value );
211210 }
212211
213212 @ Override
214- public void setByte (int ordinal , byte value ) {
213+ public void setFloat (int ordinal , float value ) {
215214 assertIndexIsValid (ordinal );
216215 setNotNullAt (ordinal );
217- PlatformDependent .UNSAFE .putByte (baseObject , getFieldOffset (ordinal ), value );
216+ PlatformDependent .UNSAFE .putFloat (baseObject , getFieldOffset (ordinal ), value );
218217 }
219218
220219 @ Override
221- public void setFloat (int ordinal , float value ) {
220+ public void setDouble (int ordinal , double value ) {
222221 assertIndexIsValid (ordinal );
223222 setNotNullAt (ordinal );
224- PlatformDependent .UNSAFE .putFloat (baseObject , getFieldOffset (ordinal ), value );
223+ PlatformDependent .UNSAFE .putDouble (baseObject , getFieldOffset (ordinal ), value );
225224 }
226225
227226 @ Override
228- public int size () {
227+ public int length () {
229228 return numFields ;
230229 }
231230
@@ -235,7 +234,7 @@ public StructType schema() {
235234 }
236235
237236 @ Override
238- public Object get (int i ) {
237+ public Object apply (int i ) {
239238 assertIndexIsValid (i );
240239 assert (schema != null ) : "Schema must be defined when calling generic get() method" ;
241240 final DataType dataType = schema .fields ()[i ].dataType ();
0 commit comments