You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@hive.apache.org by "Feng Yuan (JIRA)" <ji...@apache.org> on 2017/09/11 06:00:00 UTC
[jira] [Created] (HIVE-17498) Does hive have mr-nativetask support
refer to MAPREDUCE-2841
Feng Yuan created HIVE-17498:
--------------------------------
Summary: Does hive have mr-nativetask support refer to MAPREDUCE-2841
Key: HIVE-17498
URL: https://issues.apache.org/jira/browse/HIVE-17498
Project: Hive
Issue Type: Bug
Components: Hive
Reporter: Feng Yuan
I try to implement a HivePlatform extends org.apache.hadoop.mapred.nativetask.Platform.
{code}
//
// Source code recreated from a .class file by IntelliJ IDEA
// (powered by Fernflower decompiler)
//
package org.apache.hadoop.mapred.nativetask;
import java.io.IOException;
import java.util.HashSet;
import java.util.Set;
import org.apache.hadoop.classification.InterfaceAudience.Public;
import org.apache.hadoop.classification.InterfaceStability.Evolving;
import org.apache.hadoop.mapred.JobConf;
import org.apache.hadoop.mapred.nativetask.serde.INativeSerializer;
import org.apache.hadoop.mapred.nativetask.serde.NativeSerialization;
@Public
@Evolving
public abstract class Platform {
private final NativeSerialization serialization = NativeSerialization.getInstance();
protected Set<String> keyClassNames = new HashSet();
public Platform() {
}
public abstract void init() throws IOException;
public abstract String name();
protected void registerKey(String keyClassName, Class<?> key) throws IOException {
this.serialization.register(keyClassName, key);
this.keyClassNames.add(keyClassName);
}
protected abstract boolean support(String var1, INativeSerializer<?> var2, JobConf var3);
protected abstract boolean define(Class<?> var1);
}
{code}
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)