StreamRefResolver

All Superinterfaces:: Extension

public interface StreamRefResolver extends Extension

The stream ref resolver provides a way to serialize and deserialize streamrefs in user serializers.

Not for user extension

Method Summary

Modifier and Type

Method

Description

<T> SinkRef<T>

resolveSinkRef(String serializedSinkRef)

Deserialize an SinkRef in the toSerializationFormat(org.apache.pekko.stream.SourceRef<T>).

<T> SourceRef<T>

resolveSourceRef(String serializedSourceRef)

Deserialize an SourceRef in the toSerializationFormat(org.apache.pekko.stream.SourceRef<T>).

<T> String

toSerializationFormat(SinkRef<T> ref)

Generate full String representation of the SinkRef.

<T> String

toSerializationFormat(SourceRef<T> ref)

Generate full String representation of the SourceRef.

Method Details
- toSerializationFormat
  
  <T> String toSerializationFormat(SourceRef<T> ref)
  
  Generate full String representation of the SourceRef. This representation should be used as serialized representation.
- toSerializationFormat
  
  <T> String toSerializationFormat(SinkRef<T> ref)
  
  Generate full String representation of the SinkRef. This representation should be used as serialized representation.
- resolveSourceRef
  
  <T> SourceRef<T> resolveSourceRef(String serializedSourceRef)
  
  Deserialize an SourceRef in the toSerializationFormat(org.apache.pekko.stream.SourceRef<T>).
- resolveSinkRef
  
  <T> SinkRef<T> resolveSinkRef(String serializedSinkRef)
  
  Deserialize an SinkRef in the toSerializationFormat(org.apache.pekko.stream.SourceRef<T>).