public final class SparseVectorSerializer extends org.apache.flink.api.common.typeutils.base.TypeSerializerSingleton<SparseVector>
SparseVector
.Modifier and Type | Class and Description |
---|---|
static class |
SparseVectorSerializer.SparseVectorSerializerSnapshot
Serializer configuration snapshot for compatibility and format evolution.
|
Modifier and Type | Field and Description |
---|---|
static SparseVectorSerializer |
INSTANCE |
Constructor and Description |
---|
SparseVectorSerializer() |
Modifier and Type | Method and Description |
---|---|
void |
copy(org.apache.flink.core.memory.DataInputView source,
org.apache.flink.core.memory.DataOutputView target) |
SparseVector |
copy(SparseVector from) |
SparseVector |
copy(SparseVector from,
SparseVector reuse) |
SparseVector |
createInstance() |
SparseVector |
deserialize(org.apache.flink.core.memory.DataInputView source) |
SparseVector |
deserialize(SparseVector reuse,
org.apache.flink.core.memory.DataInputView source) |
int |
getLength() |
boolean |
isImmutableType() |
void |
serialize(SparseVector vector,
org.apache.flink.core.memory.DataOutputView target) |
org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<SparseVector> |
snapshotConfiguration() |
public static final SparseVectorSerializer INSTANCE
public boolean isImmutableType()
isImmutableType
in class org.apache.flink.api.common.typeutils.TypeSerializer<SparseVector>
public SparseVector createInstance()
createInstance
in class org.apache.flink.api.common.typeutils.TypeSerializer<SparseVector>
public SparseVector copy(SparseVector from)
copy
in class org.apache.flink.api.common.typeutils.TypeSerializer<SparseVector>
public SparseVector copy(SparseVector from, SparseVector reuse)
copy
in class org.apache.flink.api.common.typeutils.TypeSerializer<SparseVector>
public int getLength()
getLength
in class org.apache.flink.api.common.typeutils.TypeSerializer<SparseVector>
public void serialize(SparseVector vector, org.apache.flink.core.memory.DataOutputView target) throws IOException
serialize
in class org.apache.flink.api.common.typeutils.TypeSerializer<SparseVector>
IOException
public SparseVector deserialize(org.apache.flink.core.memory.DataInputView source) throws IOException
deserialize
in class org.apache.flink.api.common.typeutils.TypeSerializer<SparseVector>
IOException
public SparseVector deserialize(SparseVector reuse, org.apache.flink.core.memory.DataInputView source) throws IOException
deserialize
in class org.apache.flink.api.common.typeutils.TypeSerializer<SparseVector>
IOException
public void copy(org.apache.flink.core.memory.DataInputView source, org.apache.flink.core.memory.DataOutputView target) throws IOException
copy
in class org.apache.flink.api.common.typeutils.TypeSerializer<SparseVector>
IOException
public org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<SparseVector> snapshotConfiguration()
snapshotConfiguration
in class org.apache.flink.api.common.typeutils.TypeSerializer<SparseVector>
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.