Package | Description |
---|---|
org.apache.flink.table.dataformat | |
org.apache.flink.table.runtime.typeutils |
Modifier and Type | Class and Description |
---|---|
class |
BinaryArray
For fields that hold fixed-length primitive types, such as long, double, or int, we store the
value directly in the field, just like the original java array.
|
class |
GenericArray
A GenericArray is an array where all the elements have the same type.
|
Modifier and Type | Method and Description |
---|---|
BaseArray |
TypeGetterSetters.getArray(int ordinal)
Get array value, internal format is BaseArray.
|
BaseArray |
BinaryRow.getArray(int pos) |
BaseArray |
NestedRow.getArray(int pos) |
BaseArray |
BinaryArray.getArray(int pos) |
BaseArray |
UpdatableRow.getArray(int ordinal) |
BaseArray |
JoinedRow.getArray(int i) |
BaseArray |
ObjectArrayRow.getArray(int ordinal) |
BaseArray |
ColumnarRow.getArray(int ordinal) |
BaseArray |
GenericArray.getArray(int pos) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractBinaryWriter.writeArray(int pos,
BaseArray input,
BaseArraySerializer serializer) |
void |
BinaryWriter.writeArray(int pos,
BaseArray value,
BaseArraySerializer serializer) |
Modifier and Type | Method and Description |
---|---|
BaseArray |
BaseArraySerializer.copy(BaseArray from) |
BaseArray |
BaseArraySerializer.copy(BaseArray from,
BaseArray reuse) |
BaseArray |
BaseArraySerializer.createInstance() |
BaseArray |
BaseArraySerializer.deserialize(BaseArray reuse,
DataInputView source) |
BaseArray |
BaseArraySerializer.deserialize(DataInputView source) |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<BaseArray> |
BaseArraySerializer.duplicate() |
TypeSerializerSchemaCompatibility<BaseArray> |
BaseArraySerializer.BaseArraySerializerSnapshot.resolveSchemaCompatibility(TypeSerializer<BaseArray> newSerializer) |
TypeSerializer<BaseArray> |
BaseArraySerializer.BaseArraySerializerSnapshot.restoreSerializer() |
TypeSerializerSnapshot<BaseArray> |
BaseArraySerializer.snapshotConfiguration() |
Modifier and Type | Method and Description |
---|---|
BaseArray |
BaseArraySerializer.copy(BaseArray from) |
BaseArray |
BaseArraySerializer.copy(BaseArray from,
BaseArray reuse) |
BaseArray |
BaseArraySerializer.deserialize(BaseArray reuse,
DataInputView source) |
void |
BaseArraySerializer.serialize(BaseArray record,
DataOutputView target) |
BinaryArray |
BaseArraySerializer.toBinaryArray(BaseArray from) |
Modifier and Type | Method and Description |
---|---|
TypeSerializerSchemaCompatibility<BaseArray> |
BaseArraySerializer.BaseArraySerializerSnapshot.resolveSchemaCompatibility(TypeSerializer<BaseArray> newSerializer) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.