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;

import javax.validation.constraints.Min;

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("exclude_jars")
    @ConfigDefault("[]")
    public List<String> getExcludeJars();

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

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

    @Config("retry_tasks")
    @ConfigDefault("false")
    public boolean getRetryTasks();

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

    @Config("local_mode_input_tasks")
    @ConfigDefault("0")
    @Min(0)
    public Integer getLocalModeInputTasks();

    @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

2 entries across 2 versions & 1 rubygems

Version	Path
embulk-executor-mapreduce-0.3.0	src/main/java/org/embulk/executor/mapreduce/MapReduceExecutorTask.java
embulk-executor-mapreduce-0.2.8	src/main/java/org/embulk/executor/mapreduce/MapReduceExecutorTask.java