Skip to content
This repository has been archived by the owner on Jan 20, 2022. It is now read-only.

IdentityKeyedProducer in ValueFlatMapToFlatMap Dag Optimizer rule #580

Merged
merged 2 commits into from
Jan 23, 2015
Merged

IdentityKeyedProducer in ValueFlatMapToFlatMap Dag Optimizer rule #580

Changes from 1 commit
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
1adb4a2
IdentityKeyedProducer in ValueFlatMappedProducer dag optimizer rule +…
Jan 14, 2015
25991f1
remove unneeded test
Jan 14, 2015
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
remove unneeded test
  • Loading branch information
Katya Gonina committed Jan 14, 2015
commit 25991f1c78e8e300aa4657740eb9966a5d3aa926
12 changes: 0 additions & 12 deletions summingbird-core/src/test/scala/com/twitter/summingbird/TestGraphs.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -338,18 +338,6 @@ object TestGraphs {
.sumByKey(storeAndService)
}

def leftJoinWithDependentStoreJobMap[P <: Platform[P], T, V1, U, K, V: Monoid](
source1: Producer[P, T],
storeAndService: P#Store[K, V] with P#Service[K, V])(simpleM1: T => (K, U))(valuesMap1: ((U, Option[V])) => V1)(valuesMap2: (V1) => V): TailProducer[P, (K, (Option[V], V))] = {

source1
.map(simpleM1)
.leftJoin(storeAndService)
.mapValues(valuesMap1)
.mapValues(valuesMap2)
.sumByKey(storeAndService)
}

def leftJoinWithDependentStoreJoinFanoutInScala[T, U, K: Ordering, V: Monoid, V1: Monoid](source: TraversableOnce[T])(simpleFM: T => TraversableOnce[(Long, (K, U))])(flatMapValuesFn: ((Long, (U, Option[V]))) => TraversableOnce[(Long, V)])(flatMapFn: ((Long, (K, (U, Option[V])))) => TraversableOnce[(Long, (K, V1))]): (Map[K, V], Map[K, V1]) = {

// zip the left and right streams
Expand Down