code: public static Processor<DataSinkTask> sink(DataSink dataSink, int parallelism, String description, UserConfig taskConf, ActorSystem system) {
      io.gearpump.streaming.Processor<DataSinkTask> p = DataSinkProcessor.apply(dataSink, parallelism, description, taskConf, system);
      return new Processor(p);
    }
docs: Creates a Sink Processor
  
  @param dataSink    the data sink itself
  @param parallelism the parallelism of this processor
  @param description the description for this processor
  @param taskConf    the configuration for this processor
  @param system      actor system
  @return the new created sink processor