Did I find the right examples for you? yes no

All Samples(2)  |  Call(0)  |  Derive(0)  |  Import(2)

src/s/e/seal-0.4.0-rc2/tests/seal/seqal/test_reducer.py   seal(Download)
from seal.lib.mr.test_utils import reduce_context
from seal.seqal.reducer import reducer
from seal.seqal.seqal_app import PAIR_STRING
import seal.lib.io.protobuf_mapping as proto
import seal.lib.aligner.sam_flags as sam_flags
    def test_no_emit_on_right_key(self):
        # load pair 1
        p = test_utils.pair1()
        # use the SECOND read to create the map-reduce key
        self.__ctx.add_value(test_utils.make_key(p[1]), PAIR_STRING)
        p = test_utils.pair1()
        # use the first read to create the map-reduce key
        self.__ctx.add_value(test_utils.make_key(p[1]), PAIR_STRING)
        self.__ctx.add_value(test_utils.make_key(p[1]), PAIR_STRING) # add it twice
        self.__reducer.reduce(self.__ctx)
    def test_fragment_with_duplicate_in_pair_2(self):
        # Ensure the reducer catches a fragment duplicate of pair[1].
        p = list(test_utils.pair1())
        # Insert the pair into the context
        self.__ctx.add_value(test_utils.make_key(p[1]), PAIR_STRING)

src/s/e/seal-0.4.0-rc2/tests/seal/seqal/test_mark_duplicates_emitter.py   seal(Download)
from seal.lib.mr.hadoop_event_monitor import HadoopEventMonitor
from seal.seqal.mapper import MarkDuplicatesEmitter
from seal.seqal.seqal_app import PAIR_STRING, UNMAPPED_STRING
from seal.lib.aligner.sam_mapping import SAMMapping
import test_utils # specific to seqal