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

Class DatasetService

java.lang.Object

com.google.common.util.concurrent.AbstractExecutionThreadService

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

All Implemented Interfaces:

com.google.common.util.concurrent.Service

public class DatasetService
extends com.google.common.util.concurrent.AbstractExecutionThreadService

DatasetService implemented using the common http netty framework.

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

DatasetService(CConfiguration cConf, NamespacedLocationFactory namespacedLocationFactory, DiscoveryService discoveryService, DiscoveryServiceClient discoveryServiceClient, DatasetTypeManager typeManager, MetricsCollectionService metricsCollectionService, DatasetOpExecutor opExecutorClient, MDSDatasetsRegistry mdsDatasets, Set<DatasetMetricsReporter> metricReporters, DatasetInstanceService datasetInstanceService, StorageProviderNamespaceAdmin storageProviderNamespaceAdmin, NamespaceStore namespaceStore)

Method Summary

Methods

Modifier and Type	Method and Description
protected Executor	executor()
protected String	getServiceName()
protected void	run()
protected void	shutDown()
protected void	startUp()
String	toString()
protected void	triggerShutdown()

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

addListener, 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

DatasetService

@Inject
public DatasetService(CConfiguration cConf,
                     NamespacedLocationFactory namespacedLocationFactory,
                     DiscoveryService discoveryService,
                     DiscoveryServiceClient discoveryServiceClient,
                     DatasetTypeManager typeManager,
                     MetricsCollectionService metricsCollectionService,
                     DatasetOpExecutor opExecutorClient,
                     MDSDatasetsRegistry mdsDatasets,
                     Set<DatasetMetricsReporter> metricReporters,
                     DatasetInstanceService datasetInstanceService,
                     StorageProviderNamespaceAdmin storageProviderNamespaceAdmin,
                     NamespaceStore namespaceStore)
               throws Exception

Throws:

Exception

Method Detail

startUp

protected void startUp()
                throws Exception

Overrides:

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

Throws:

Exception

getServiceName

protected String getServiceName()

Overrides:

getServiceName in class com.google.common.util.concurrent.AbstractExecutionThreadService

run

protected void run()
            throws Exception

Specified by:

run in class com.google.common.util.concurrent.AbstractExecutionThreadService

Throws:

Exception

triggerShutdown

protected void triggerShutdown()

Overrides:

triggerShutdown in class com.google.common.util.concurrent.AbstractExecutionThreadService

shutDown

protected void shutDown()
                 throws Exception

Overrides:

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

Throws:

Exception

toString

public String toString()

Overrides:

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

executor

protected Executor executor()

Overrides:

executor in class com.google.common.util.concurrent.AbstractExecutionThreadService