@abstractmethod<EOL><INDENT>def _build_this(self, builder, stage_names):<DEDENT>
raise RuntimeError("<STR_LIT>")<EOL>
This is the method that's implemented by the operators.
        :type builder: TopologyBuilder
        :param builder: The operator adds in the current streamlet as a spout/bolt