trait StreamRefResolver extends Extension

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

Not for user extension

Annotations
@DoNotInherit()
Source
StreamRefs.scala
Linear Supertypes
Extension, AnyRef, Any
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. StreamRefResolver
  2. Extension
  3. AnyRef
  4. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Abstract Value Members

  1. abstract def resolveSinkRef[T](serializedSinkRef: String): SinkRef[T]

    Deserialize an SinkRef in the #toSerializationFormat.

  2. abstract def resolveSourceRef[T](serializedSourceRef: String): SourceRef[T]

    Deserialize an SourceRef in the #toSerializationFormat.

  3. abstract def toSerializationFormat[T](ref: SinkRef[T]): String

    Generate full String representation of the SinkRef.

    Generate full String representation of the SinkRef. This representation should be used as serialized representation.

  4. abstract def toSerializationFormat[T](ref: SourceRef[T]): String

    Generate full String representation of the SourceRef.

    Generate full String representation of the SourceRef. This representation should be used as serialized representation.