io.druid.indexing.common.config

Class TaskConfig

java.lang.Object

io.druid.indexing.common.config.TaskConfig

public class TaskConfig
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static List<String>	DEFAULT_DEFAULT_HADOOP_COORDINATES

Constructor Summary

Constructors

Constructor and Description
TaskConfig(String baseDir, String baseTaskDir, String hadoopWorkingPath, Integer defaultRowFlushBoundary, List<String> defaultHadoopCoordinates, boolean restoreTasksOnRestart, org.joda.time.Period gracefulShutdownTimeout, org.joda.time.Period directoryLockTimeout)

Method Summary

Modifier and Type	Method and Description
String	getBaseDir()
File	getBaseTaskDir()
List<String>	getDefaultHadoopCoordinates()
int	getDefaultRowFlushBoundary()
org.joda.time.Period	getDirectoryLockTimeout()
org.joda.time.Period	getGracefulShutdownTimeout()
String	getHadoopWorkingPath()
File	getTaskDir(String taskId)
File	getTaskLockFile(String taskId)
File	getTaskWorkDir(String taskId)
boolean	isRestoreTasksOnRestart()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

DEFAULT_DEFAULT_HADOOP_COORDINATES

public static final List<String> DEFAULT_DEFAULT_HADOOP_COORDINATES

Constructor Detail

TaskConfig

public TaskConfig(String baseDir,
                  String baseTaskDir,
                  String hadoopWorkingPath,
                  Integer defaultRowFlushBoundary,
                  List<String> defaultHadoopCoordinates,
                  boolean restoreTasksOnRestart,
                  org.joda.time.Period gracefulShutdownTimeout,
                  org.joda.time.Period directoryLockTimeout)

Method Detail

getBaseDir

public String getBaseDir()

getBaseTaskDir

public File getBaseTaskDir()

getTaskDir

public File getTaskDir(String taskId)

getTaskWorkDir

public File getTaskWorkDir(String taskId)

getTaskLockFile

public File getTaskLockFile(String taskId)

getHadoopWorkingPath

public String getHadoopWorkingPath()

getDefaultRowFlushBoundary

public int getDefaultRowFlushBoundary()

getDefaultHadoopCoordinates

public List<String> getDefaultHadoopCoordinates()

isRestoreTasksOnRestart

public boolean isRestoreTasksOnRestart()

getGracefulShutdownTimeout

public org.joda.time.Period getGracefulShutdownTimeout()

getDirectoryLockTimeout

public org.joda.time.Period getDirectoryLockTimeout()