code: def sink(self):
          
          op = Operator(
              _generate_uuid(),
              OpType.Sink,
              "Sink",
              num_instances=self.env.config.parallelism)
          return self.__register(op)
docs: Closes the stream with a sink operator.