co.cask.cdap.data2.datafabric.dataset.service.executor

Class DatasetOpExecutorService

java.lang.Object

com.google.common.util.concurrent.AbstractIdleService

co.cask.cdap.data2.datafabric.dataset.service.executor.DatasetOpExecutorService

All Implemented Interfaces:

com.google.common.util.concurrent.Service

public class DatasetOpExecutorService
extends com.google.common.util.concurrent.AbstractIdleService

Provides various REST endpoints to execute user code via DatasetAdminOpHTTPHandler.

Nested Class Summary

Nested classes/interfaces inherited from interface com.google.common.util.concurrent.Service

com.google.common.util.concurrent.Service.Listener, com.google.common.util.concurrent.Service.State

Constructor Summary

Constructors

Constructor and Description
DatasetOpExecutorService(CConfiguration cConf, DiscoveryService discoveryService, MetricsCollectionService metricsCollectionService, Set<co.cask.http.HttpHandler> handlers)

Method Summary

Methods

Modifier and Type	Method and Description
co.cask.http.NettyHttpService	getHttpService()
protected void	shutDown()
protected void	startUp()
String	toString()

Methods inherited from class com.google.common.util.concurrent.AbstractIdleService

addListener, executor, isRunning, start, startAndWait, state, stop, stopAndWait

Methods inherited from class java.lang.Object

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

Constructor Detail

DatasetOpExecutorService

@Inject
public DatasetOpExecutorService(CConfiguration cConf,
                               DiscoveryService discoveryService,
                               MetricsCollectionService metricsCollectionService,
                               Set<co.cask.http.HttpHandler> handlers)

Method Detail

startUp

protected void startUp()
                throws Exception

Specified by:

startUp in class com.google.common.util.concurrent.AbstractIdleService

Throws:

Exception

shutDown

protected void shutDown()
                 throws Exception

Specified by:

shutDown in class com.google.common.util.concurrent.AbstractIdleService

Throws:

Exception

toString

public String toString()

Overrides:

toString in class com.google.common.util.concurrent.AbstractIdleService

getHttpService

public co.cask.http.NettyHttpService getHttpService()