import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.Path; public class HadoopJob { @InterfaceAudience.Private @InterfaceStability.Evolving private Configuration conf; public HadoopJob(Configuration conf) { this.conf = conf; } @InterfaceAudience.Public @InterfaceStability.Stable public void runJob(Path inputPath, Path outputPath) { } }


上一篇:
下一篇:
切换中文