com.here.platform.data.processing.driver.deltasets.ResolutionStrategy
BackwardResolution
Companion object BackwardResolution
case class BackwardResolution[K, V](references: DeltaSet[Key, Meta], referencesToSubjects: (Key, Meta) ⇒ Set[K])(implicit evidence$4: Ordering[K], evidence$5: ClassTag[K], evidence$6: ClassTag[V]) extends ResolutionStrategy[K, V] with Product with Serializable
Given a DeltaSet containing references and a function that maps each reference to a set of
subject partitions, BackwardResolution
makes the mapped references available to the resolver
when processing the subject partition, without any further network query.
- references
The DeltaSet containing the referenced partition key-meta pairs.
- referencesToSubjects
The function that maps each reference to a set of referenced partition keys.
- Alphabetic
- By Inheritance
- BackwardResolution
- Serializable
- Serializable
- Product
- Equals
- ResolutionStrategy
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Instance Constructors
-
new
BackwardResolution(references: DeltaSet[Key, Meta], referencesToSubjects: (Key, Meta) ⇒ Set[K])(implicit arg0: Ordering[K], arg1: ClassTag[K], arg2: ClassTag[V])
- references
The DeltaSet containing the referenced partition key-meta pairs.
- referencesToSubjects
The function that maps each reference to a set of referenced partition keys.
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
final
def
instantiate(context: DeltaContext, config: DeltaSetConfig, referencePartitioner: Partitioner[Key]): ResolutionStrategyInstance[K, V]
Maps a
ResolutionStrategy
to its corresponding implementation.Maps a
ResolutionStrategy
to its corresponding implementation.- context
The current
DeltaContext
.- config
The configuration of the transformation.
- referencePartitioner
Partitioner for reference DeltaSets constructed by this resolution strategy, if any. Can be ignored by the resolution strategy implementation where expensive repartitioning would be required to apply the partitioner.
- returns
A
ResolutionStrategy
instance.
- Definition Classes
- BackwardResolution → ResolutionStrategy
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- val references: DeltaSet[Key, Meta]
- val referencesToSubjects: (Key, Meta) ⇒ Set[K]
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()