Contents

package org.embulk.executor.mapreduce;

import java.util.List;
import java.util.Map;
import com.google.common.base.Optional;
import org.embulk.config.Config;
import org.embulk.config.ConfigInject;
import org.embulk.config.ConfigDefault;
import org.embulk.config.ConfigSource;
import org.embulk.config.Task;
import org.embulk.config.TaskSource;
import org.embulk.config.ModelManager;
import org.embulk.spi.ProcessTask;

public interface MapReduceExecutorTask
        extends Task
{
    @Config("job_name")
    @ConfigDefault("\"embulk\"")
    public String getJobName();

    @Config("config_files")
    @ConfigDefault("[]")
    public List<String> getConfigFiles();

    @Config("config")
    @ConfigDefault("{}")
    public Map<String, String> getConfig();

    @Config("libjars")
    @ConfigDefault("[]")
    public List<String> getLibjars();

    @Config("state_path")
    @ConfigDefault("\"/tmp/embulk\"")
    public String getStatePath();

    @Config("reducers")
    @ConfigDefault("null")
    public Optional<Integer> getReducers();

    @Config("partitioning")
    @ConfigDefault("null")
    public Optional<ConfigSource> getPartitioning();

    @ConfigInject
    public ModelManager getModelManager();

    public ConfigSource getExecConfig();
    public void setExecConfig(ConfigSource execConfig);

    public ProcessTask getProcessTask();
    public void setProcessTask(ProcessTask task);

    public Optional<String> getPartitioningType();
    public void setPartitioningType(Optional<String> partitioningType);

    public Optional<TaskSource> getPartitioningTask();
    public void setPartitioningTask(Optional<TaskSource> partitioningTask);
}

Version data entries

7 entries across 7 versions & 1 rubygems

Version	Path
embulk-executor-mapreduce-0.2.0	src/main/java/org/embulk/executor/mapreduce/MapReduceExecutorTask.java
embulk-executor-mapreduce-0.1.5	src/main/java/org/embulk/executor/mapreduce/MapReduceExecutorTask.java
embulk-executor-mapreduce-0.1.4	src/main/java/org/embulk/executor/mapreduce/MapReduceExecutorTask.java
embulk-executor-mapreduce-0.1.3	src/main/java/org/embulk/executor/mapreduce/MapReduceExecutorTask.java
embulk-executor-mapreduce-0.1.2	src/main/java/org/embulk/executor/mapreduce/MapReduceExecutorTask.java
embulk-executor-mapreduce-0.1.1	src/main/java/org/embulk/executor/mapreduce/MapReduceExecutorTask.java
embulk-executor-mapreduce-0.1.0	src/main/java/org/embulk/executor/mapreduce/MapReduceExecutorTask.java