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

Test to illustrate https://github.com/twitter/summingbird/issues/671 #672

Open
pankajroark wants to merge 7 commits into
base: develop
Choose a base branch
from
Open

Test to illustrate https://github.com/twitter/summingbird/issues/671 #672

Changes from 1 commit
Commits
Show all changes
7 commits
Select commit Hold shift + click to select a range
4a602fd
Test to illustrate https://github.com/twitter/summingbird/issues/671
pankajroark Jun 29, 2016
86c24c3
Add back sparseEquiv import.
pankajroark Jun 29, 2016
54ef23b
Try to create scalding platform tests for the same issue.
pankajroark Jun 30, 2016
5ab3053
Add tests for named options for scalding platform.
pankajroark Jul 2, 2016
2cada35
Fix scalding named option test.
pankajroark Jul 2, 2016
7422550
More scalding platform named option tests.
pankajroark Jul 2, 2016
b502b7b
Fix https://github.com/twitter/summingbird/issues/671
pankajroark Jul 2, 2016
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
Next Next commit
Add back sparseEquiv import.
  • Loading branch information
@pankajroark
pankajroark committed Jun 29, 2016
commit 86c24c38dc85adab2a8786bbf38befce7c6dc212
6 changes: 4 additions & 2 deletions summingbird-storm-test/src/test/scala/com/twitter/summingbird/storm/TopologyTests.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -16,9 +16,10 @@

package com.twitter.summingbird.storm

import java.util.{Map => JMap}
import java.util.{ Map => JMap }

import backtype.storm.generated.StormTopology
import com.twitter.algebird.MapAlgebra
import com.twitter.summingbird._
import com.twitter.summingbird.batch.Batcher
import com.twitter.summingbird.online.option._
Expand All @@ -27,13 +28,14 @@ import org.scalacheck._
import org.scalatest.WordSpec

import scala.collection.JavaConversions._
import scala.collection.mutable.{HashMap => MutableHashMap, Map => MutableMap}
import scala.collection.mutable.{ HashMap => MutableHashMap, Map => MutableMap }

/**
* Tests for Summingbird's Storm planner.
*/

class TopologyTests extends WordSpec {
import MapAlgebra.sparseEquiv

// This is dangerous, obviously. The Storm platform graphs tested
// here use the UnitBatcher, so the actual time extraction isn't
Expand Down