Package | Description |
---|---|
org.apache.flink.cep.nfa |
Modifier and Type | Method and Description |
---|---|
SharedBuffer<K,V> |
SharedBuffer.SharedBufferSerializer.copy(SharedBuffer<K,V> from) |
SharedBuffer<K,V> |
SharedBuffer.SharedBufferSerializer.copy(SharedBuffer<K,V> from,
SharedBuffer<K,V> reuse) |
SharedBuffer<K,V> |
SharedBuffer.SharedBufferSerializer.createInstance() |
SharedBuffer<K,V> |
SharedBuffer.SharedBufferSerializer.deserialize(DataInputView source) |
SharedBuffer<K,V> |
SharedBuffer.SharedBufferSerializer.deserialize(SharedBuffer<K,V> reuse,
DataInputView source) |
Modifier and Type | Method and Description |
---|---|
CompatibilityResult<SharedBuffer<K,V>> |
SharedBuffer.SharedBufferSerializer.ensureCompatibility(TypeSerializerConfigSnapshot configSnapshot) |
Modifier and Type | Method and Description |
---|---|
SharedBuffer<K,V> |
SharedBuffer.SharedBufferSerializer.copy(SharedBuffer<K,V> from) |
SharedBuffer<K,V> |
SharedBuffer.SharedBufferSerializer.copy(SharedBuffer<K,V> from,
SharedBuffer<K,V> reuse) |
SharedBuffer<K,V> |
SharedBuffer.SharedBufferSerializer.copy(SharedBuffer<K,V> from,
SharedBuffer<K,V> reuse) |
SharedBuffer<K,V> |
SharedBuffer.SharedBufferSerializer.deserialize(SharedBuffer<K,V> reuse,
DataInputView source) |
void |
SharedBuffer.SharedBufferSerializer.serialize(SharedBuffer<K,V> record,
DataOutputView target) |
Constructor and Description |
---|
NFASerializer(TypeSerializer<T> typeSerializer,
TypeSerializer<SharedBuffer<String,T>> sharedBufferSerializer) |
NFASerializerConfigSnapshot(TypeSerializer<T> eventSerializer,
TypeSerializer<SharedBuffer<String,T>> sharedBufferSerializer) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.