public class SparkArrayData
extends org.apache.spark.sql.catalyst.util.ArrayData
ArrayData
to wrap flink ArrayData
.Constructor and Description |
---|
SparkArrayData(org.apache.flink.table.types.logical.LogicalType elementType) |
Modifier and Type | Method and Description |
---|---|
Object[] |
array() |
org.apache.spark.sql.catalyst.util.ArrayData |
copy() |
Object |
get(int ordinal,
org.apache.spark.sql.types.DataType dataType) |
org.apache.spark.sql.catalyst.util.ArrayData |
getArray(int ordinal) |
byte[] |
getBinary(int ordinal) |
boolean |
getBoolean(int ordinal) |
byte |
getByte(int ordinal) |
org.apache.spark.sql.types.Decimal |
getDecimal(int ordinal,
int precision,
int scale) |
double |
getDouble(int ordinal) |
float |
getFloat(int ordinal) |
int |
getInt(int ordinal) |
org.apache.spark.unsafe.types.CalendarInterval |
getInterval(int ordinal) |
long |
getLong(int ordinal) |
org.apache.spark.sql.catalyst.util.MapData |
getMap(int ordinal) |
short |
getShort(int ordinal) |
org.apache.spark.sql.catalyst.InternalRow |
getStruct(int ordinal,
int numFields) |
org.apache.spark.unsafe.types.UTF8String |
getUTF8String(int ordinal) |
boolean |
isNullAt(int ordinal) |
int |
numElements() |
SparkArrayData |
replace(org.apache.flink.table.data.ArrayData array) |
void |
setNullAt(int i) |
void |
update(int i,
Object value) |
allocateArrayData, foreach, setBoolean, setByte, setDouble, setFloat, setInt, setLong, setShort, toArray, toArrayData, toBooleanArray, toByteArray, toDoubleArray, toFloatArray, toIntArray, toLongArray, toObjectArray, toSeq, toShortArray
public SparkArrayData(org.apache.flink.table.types.logical.LogicalType elementType)
public SparkArrayData replace(org.apache.flink.table.data.ArrayData array)
public int numElements()
numElements
in class org.apache.spark.sql.catalyst.util.ArrayData
public org.apache.spark.sql.catalyst.util.ArrayData copy()
copy
in class org.apache.spark.sql.catalyst.util.ArrayData
public Object[] array()
array
in class org.apache.spark.sql.catalyst.util.ArrayData
public void setNullAt(int i)
setNullAt
in class org.apache.spark.sql.catalyst.util.ArrayData
public void update(int i, Object value)
update
in class org.apache.spark.sql.catalyst.util.ArrayData
public boolean isNullAt(int ordinal)
public boolean getBoolean(int ordinal)
public byte getByte(int ordinal)
public short getShort(int ordinal)
public int getInt(int ordinal)
public long getLong(int ordinal)
public float getFloat(int ordinal)
public double getDouble(int ordinal)
public org.apache.spark.sql.types.Decimal getDecimal(int ordinal, int precision, int scale)
public org.apache.spark.unsafe.types.UTF8String getUTF8String(int ordinal)
public byte[] getBinary(int ordinal)
public org.apache.spark.unsafe.types.CalendarInterval getInterval(int ordinal)
public org.apache.spark.sql.catalyst.InternalRow getStruct(int ordinal, int numFields)
public org.apache.spark.sql.catalyst.util.ArrayData getArray(int ordinal)
public org.apache.spark.sql.catalyst.util.MapData getMap(int ordinal)
public Object get(int ordinal, org.apache.spark.sql.types.DataType dataType)
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.