org.apache.samza.task

Interface TaskExecutorFactory

public interface TaskExecutorFactory

Factory for creating the executor used when running tasks in multi-thread mode.

Method Summary

Modifier and Type	Method and Description
java.util.concurrent.ExecutorService	getTaskExecutor(Config config)

Method Detail

getTaskExecutor

java.util.concurrent.ExecutorService getTaskExecutor(Config config)

Parameters:

config - contains configs for the executor

Returns:

task executor