2017-06-20_v1.0.0.py 文件源码

def _execute(self, sources, alignment_stream, interval):
        if alignment_stream is None:
            raise ToolExecutionError("Alignment stream expected")

        for ti, _ in alignment_stream.window(interval, force_calculation=True):
            yield StreamInstance(ti, random.gammavariate(alpha=self.alpha, beta=self.beta))