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)