io.druid.indexing.common.task

Class HadoopTask

java.lang.Object

io.druid.indexing.common.task.AbstractTask

io.druid.indexing.common.task.HadoopTask

All Implemented Interfaces:

Task

Direct Known Subclasses:

HadoopConverterTask.ConverterSubTask, HadoopIndexTask

public abstract class HadoopTask
extends AbstractTask

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	HadoopTask(String id, String dataSource, List<String> hadoopDependencyCoordinates)

Method Summary

Methods

Modifier and Type	Method and Description
protected ClassLoader	buildClassLoader(TaskToolbox toolbox)
List<String>	getHadoopDependencyCoordinates()
static <InputType,OutputType> OutputType	invokeForeignLoader(String clazzName, InputType input, ClassLoader loader) This method tries to isolate class loading during a Function call

Methods inherited from class io.druid.indexing.common.task.AbstractTask

equals, getClasspathPrefix, getDataSource, getGroupId, getId, getNodeType, getQueryRunner, getTaskLocks, getTaskResource, hashCode, joinId, makeId, success, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface io.druid.indexing.common.task.Task

getType, isReady, run

Constructor Detail

HadoopTask

protected HadoopTask(String id,
          String dataSource,
          List<String> hadoopDependencyCoordinates)

Method Detail

getHadoopDependencyCoordinates

public List<String> getHadoopDependencyCoordinates()

buildClassLoader

protected ClassLoader buildClassLoader(TaskToolbox toolbox)
                                throws Exception

Throws:

Exception

invokeForeignLoader

public static <InputType,OutputType> OutputType invokeForeignLoader(String clazzName,
                                                    InputType input,
                                                    ClassLoader loader)

This method tries to isolate class loading during a Function call

Type Parameters:

InputType - The input type of the method.

OutputType - The output type of the method. The result of runTask must be castable to this type.

Parameters:

clazzName - The Class which has a static method called `runTask`

input - The input for `runTask`, must have `input.getClass()` be the class of the input for runTask

loader - The loader to use as the context class loader during invocation

Returns:

The result of the method invocation