Package | Description |
---|---|
org.apache.flink.ml.common.broadcast.typeinfo |
Modifier and Type | Method and Description |
---|---|
CacheElement<T> |
CacheElementSerializer.copy(CacheElement<T> from) |
CacheElement<T> |
CacheElementSerializer.copy(CacheElement<T> from,
CacheElement<T> reuse) |
CacheElement<T> |
CacheElementSerializer.createInstance() |
CacheElement<T> |
CacheElementSerializer.deserialize(CacheElement<T> reuse,
org.apache.flink.core.memory.DataInputView source) |
CacheElement<T> |
CacheElementSerializer.deserialize(org.apache.flink.core.memory.DataInputView source) |
static <T> CacheElement<T> |
CacheElement.newRecord(T record) |
static <T> CacheElement<T> |
CacheElement.newWatermark(long watermark) |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.api.common.typeutils.TypeSerializer<CacheElement<T>> |
CacheElementTypeInfo.createSerializer(org.apache.flink.api.common.ExecutionConfig config) |
org.apache.flink.api.common.typeutils.TypeSerializer<CacheElement<T>> |
CacheElementSerializer.duplicate() |
Class<CacheElement<T>> |
CacheElementTypeInfo.getTypeClass() |
org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<CacheElement<T>> |
CacheElementSerializer.snapshotConfiguration() |
Modifier and Type | Method and Description |
---|---|
CacheElement<T> |
CacheElementSerializer.copy(CacheElement<T> from) |
CacheElement<T> |
CacheElementSerializer.copy(CacheElement<T> from,
CacheElement<T> reuse) |
CacheElement<T> |
CacheElementSerializer.copy(CacheElement<T> from,
CacheElement<T> reuse) |
CacheElement<T> |
CacheElementSerializer.deserialize(CacheElement<T> reuse,
org.apache.flink.core.memory.DataInputView source) |
void |
CacheElementSerializer.serialize(CacheElement<T> record,
org.apache.flink.core.memory.DataOutputView target) |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.