Package | Description |
---|---|
org.apache.flink.table.dataformat | |
org.apache.flink.table.runtime.typeutils | |
org.apache.flink.table.runtime.typeutils.serializers.python |
Modifier and Type | Class and Description |
---|---|
class |
BinaryMap
[4 byte(keyArray size in bytes)] + [Key BinaryArray] + [Value BinaryArray].
|
class |
GenericMap
A GenericMap is a map where all the keys have the same type, and all the values have the same type.
|
Modifier and Type | Method and Description |
---|---|
BaseMap |
TypeGetterSetters.getMap(int ordinal)
Get map value, internal format is BaseMap.
|
BaseMap |
BinaryRow.getMap(int pos) |
BaseMap |
NestedRow.getMap(int pos) |
BaseMap |
BinaryArray.getMap(int pos) |
BaseMap |
UpdatableRow.getMap(int ordinal) |
BaseMap |
JoinedRow.getMap(int i) |
BaseMap |
ObjectArrayRow.getMap(int ordinal) |
BaseMap |
ColumnarRow.getMap(int ordinal) |
BaseMap |
GenericArray.getMap(int pos) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractBinaryWriter.writeMap(int pos,
BaseMap input,
BaseMapSerializer serializer) |
void |
BinaryWriter.writeMap(int pos,
BaseMap value,
BaseMapSerializer serializer) |
Modifier and Type | Method and Description |
---|---|
BaseMap |
BaseMapSerializer.copy(BaseMap from)
NOTE: Map should be a HashMap, when we insert the key/value pairs of the TreeMap into
a HashMap, problems maybe occur.
|
BaseMap |
BaseMapSerializer.copy(BaseMap from,
BaseMap reuse) |
BaseMap |
BaseMapSerializer.createInstance() |
BaseMap |
BaseMapSerializer.deserialize(BaseMap reuse,
DataInputView source) |
BaseMap |
BaseMapSerializer.deserialize(DataInputView source) |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<BaseMap> |
BaseMapSerializer.duplicate() |
TypeSerializerSchemaCompatibility<BaseMap> |
BaseMapSerializer.BaseMapSerializerSnapshot.resolveSchemaCompatibility(TypeSerializer<BaseMap> newSerializer) |
TypeSerializer<BaseMap> |
BaseMapSerializer.BaseMapSerializerSnapshot.restoreSerializer() |
TypeSerializerSnapshot<BaseMap> |
BaseMapSerializer.snapshotConfiguration() |
Modifier and Type | Method and Description |
---|---|
BaseMap |
BaseMapSerializer.copy(BaseMap from)
NOTE: Map should be a HashMap, when we insert the key/value pairs of the TreeMap into
a HashMap, problems maybe occur.
|
BaseMap |
BaseMapSerializer.copy(BaseMap from,
BaseMap reuse) |
BaseMap |
BaseMapSerializer.deserialize(BaseMap reuse,
DataInputView source) |
void |
BaseMapSerializer.serialize(BaseMap record,
DataOutputView target) |
BinaryMap |
BaseMapSerializer.toBinaryMap(BaseMap from) |
Modifier and Type | Method and Description |
---|---|
TypeSerializerSchemaCompatibility<BaseMap> |
BaseMapSerializer.BaseMapSerializerSnapshot.resolveSchemaCompatibility(TypeSerializer<BaseMap> newSerializer) |
Modifier and Type | Method and Description |
---|---|
BaseMap |
BaseMapSerializer.deserialize(BaseMap reuse,
DataInputView source) |
BaseMap |
BaseMapSerializer.deserialize(DataInputView source) |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<BaseMap> |
BaseMapSerializer.duplicate() |
TypeSerializerSchemaCompatibility<BaseMap> |
BaseMapSerializer.BaseMapSerializerSnapshot.resolveSchemaCompatibility(TypeSerializer<BaseMap> newSerializer) |
TypeSerializer<BaseMap> |
BaseMapSerializer.BaseMapSerializerSnapshot.restoreSerializer() |
TypeSerializerSnapshot<BaseMap> |
BaseMapSerializer.snapshotConfiguration() |
Modifier and Type | Method and Description |
---|---|
BaseMap |
BaseMapSerializer.deserialize(BaseMap reuse,
DataInputView source) |
void |
BaseMapSerializer.serialize(BaseMap map,
DataOutputView target) |
Modifier and Type | Method and Description |
---|---|
TypeSerializerSchemaCompatibility<BaseMap> |
BaseMapSerializer.BaseMapSerializerSnapshot.resolveSchemaCompatibility(TypeSerializer<BaseMap> newSerializer) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.