資源簡介
hcatalog is a metadata and table management system for hadoop, it's very useful
代碼片段和文件信息
/**
?*?Licensed?to?the?Apache?Software?Foundation?(ASF)?under?one
?*?or?more?contributor?license?agreements.??See?the?NOTICE?file
?*?distributed?with?this?work?for?additional?information
?*?regarding?copyright?ownership.??The?ASF?licenses?this?file
?*?to?you?under?the?Apache?License?Version?2.0?(the
?*?“License“);?you?may?not?use?this?file?except?in?compliance
?*?with?the?License.??You?may?obtain?a?copy?of?the?License?at
?*
?*?????http://www.apache.org/licenses/LICENSE-2.0
?*
?*?Unless?required?by?applicable?law?or?agreed?to?in?writing
?*?software?distributed?under?the?License?is?distributed?on?an
?*?“AS?IS“?BASIS?WITHOUT?WARRANTIES?OR?CONDITIONS?OF?ANY
?*?KIND?either?express?or?implied.??See?the?License?for?the
?*?specific?language?governing?permissions?and?limitations
?*?under?the?License.
?*/
package?org.apache.hadoop.mapred;
import?org.apache.hadoop.util.Progressable;
import?org.apache.hadoop.conf.Configuration;
import?org.apache.hcatalog.shims.HCatHadoopShims;
public?class?HCatMapRedUtil?{
????public?static?TaskAttemptContext?createTaskAttemptContext(org.apache.hadoop.mapreduce.TaskAttemptContext?context)?{
????????return??createTaskAttemptContext(new?JobConf(context.getConfiguration())
????????????????????????????????????????????????????????????org.apache.hadoop.mapred.TaskAttemptID.forName(context.getTaskAttemptID().toString())
?????????????????????????????????????????????????????????????Reporter.NULL);
????}
????public?static?org.apache.hadoop.mapreduce.TaskAttemptContext?createTaskAttemptContext(Configuration?conf?org.apache.hadoop.mapreduce.TaskAttemptID?id)?{
????????return??HCatHadoopShims.Instance.get().createTaskAttemptContext(confid);
????}
????public?static?TaskAttemptContext?createTaskAttemptContext(JobConf?conf?TaskAttemptID?id?Progressable?progressable)?{
????????return?HCatHadoopShims.Instance.get?().createTaskAttemptContext(conf?id?(Reporter)?progressable);
????}
????public?static?org.apache.hadoop.mapred.JobContext?createJobContext(org.apache.hadoop.mapreduce.JobContext?context)?{
????????return?createJobContext((JobConf)context.getConfiguration()
????????????????????????????????context.getJobID()
????????????????????????????????Reporter.NULL);
????}
????public?static?JobContext?createJobContext(JobConf?conf?org.apache.hadoop.mapreduce.JobID?id?Progressable?progressable)?{
????????return?HCatHadoopShims.Instance.get?().createJobContext(conf?id?(Reporter)?progressable);
????}
}
- 上一篇:原子物理學(第四版)
- 下一篇:商城app我的訂單列表頁面模板.zip
評論
共有 條評論