public HdfsSystemDescriptor withStagingDirectory(String stagingDirectory) {
    this.consumerStagingDirectory = Optional.ofNullable(StringUtils.stripToNull(stagingDirectory));
    return this;
  }
Staging directory for storing partition description. If not set, will use the staging directory set
by yarn job.
@param stagingDirectory staging directory for HDFS consumer inputs.
@return this system descriptor
samza-hdfs/src/main/java/org/apache/samza/system/hdfs/descriptors/HdfsSystemDescriptor.java