Did I find the right examples for you? yes no

All Samples(8)  |  Call(4)  |  Derive(0)  |  Import(4)

src/s/e/seal-0.4.0-rc2/tests/seal/seqal/test_mark_duplicates_emitter.py   seal(Download)
import re
import unittest
from seal.lib.mr.test_utils import map_context, SavingLogger
 
import seal.lib.io.protobuf_mapping as proto
    def setUp(self):
        self.ctx = map_context(None, None)
        self.count_group = "Test"
        self.logger = SavingLogger()
        self.monitor = HadoopEventMonitor(self.count_group, self.logger, self.ctx)

src/s/e/seal-0.4.0-rc2/tests/seal/lib/mr/test_hadoop_event_monitor.py   seal(Download)
 
from seal.lib.mr.hadoop_event_monitor import *
from seal.lib.mr.test_utils import map_context, SavingLogger
 
class TestHadoopEventMonitor(unittest.TestCase):
 
    def setUp(self):
        self.map_ctx = map_context(None, None)
        self.logger = SavingLogger()

src/s/e/seal-0.4.0-rc2/tests/seal/lib/mr/test_filter_link.py   seal(Download)
from seal.lib.aligner.mapping import SimpleMapping
from seal.lib.standard_monitor import StandardMonitor
from seal.lib.mr.test_utils import SavingLogger
 
class TestFilterLink(unittest.TestCase):
    def setUp(self):
        self.monitor = StandardMonitor(SavingLogger())
        self.filter = FilterLink(self.monitor)
        self.receiver = self.filter.set_next(type(self).Receiver())
        # create two mappings, m1, m2.  We put them in self.pair

src/s/e/seal-0.4.0-rc2/tests/seal/lib/mr/test_emit_sam_link.py   seal(Download)
from seal.lib.mr.hit_processor_chain_link import HitProcessorChainLink
from seal.lib.mr.hadoop_event_monitor import HadoopEventMonitor
from seal.lib.mr.test_utils import map_context, SavingLogger
from seal.lib.aligner.mapping import *
 
class TestEmitSamLink(unittest.TestCase):
    def setUp(self):
        self.map_ctx = map_context(None, None)
        self.count_group = "Test"
        self.logger = SavingLogger()