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

Interface DatasetOpExecutor

All Superinterfaces:

com.google.common.util.concurrent.Service

All Known Implementing Classes:

InMemoryDatasetOpExecutor, LocalDatasetOpExecutor, RemoteDatasetOpExecutor, YarnDatasetOpExecutor

public interface DatasetOpExecutor
extends com.google.common.util.concurrent.Service

Executes various Dataset operations.

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

Method Summary

Methods

Modifier and Type	Method and Description
co.cask.cdap.api.dataset.DatasetSpecification	create(Id.DatasetInstance datasetInstanceId, DatasetTypeMeta typeMeta, co.cask.cdap.api.dataset.DatasetProperties props) Creates a dataset.
void	drop(Id.DatasetInstance datasetInstanceId, DatasetTypeMeta typeMeta, co.cask.cdap.api.dataset.DatasetSpecification spec) Drops dataset.
boolean	exists(Id.DatasetInstance datasetInstanceId) Checks for the existence of a dataset instance
void	truncate(Id.DatasetInstance datasetInstanceId) Deletes all data of the dataset.
void	upgrade(Id.DatasetInstance datasetInstanceId) Upgrades dataset.

Methods inherited from interface com.google.common.util.concurrent.Service

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

Method Detail

exists

boolean exists(Id.DatasetInstance datasetInstanceId)
               throws Exception

Checks for the existence of a dataset instance

Parameters:

datasetInstanceId - Id.DatasetInstance of the dataset instance.

Returns:

true if dataset exists

Throws:

IOException

Exception

create

co.cask.cdap.api.dataset.DatasetSpecification create(Id.DatasetInstance datasetInstanceId,
                                                   DatasetTypeMeta typeMeta,
                                                   co.cask.cdap.api.dataset.DatasetProperties props)
                                                     throws Exception

Creates a dataset.

Parameters:

datasetInstanceId - Id.DatasetInstance of the dataset instance.

typeMeta - Data set type meta

props - Data set instance properties

Throws:

IOException

Exception

drop

void drop(Id.DatasetInstance datasetInstanceId,
        DatasetTypeMeta typeMeta,
        co.cask.cdap.api.dataset.DatasetSpecification spec)
          throws Exception

Drops dataset.

Parameters:

datasetInstanceId - Id.DatasetInstance of the dataset instance.

typeMeta - Data set type meta

spec - Data set instance spec

Throws:

IOException

Exception

truncate

void truncate(Id.DatasetInstance datasetInstanceId)
              throws Exception

Deletes all data of the dataset.

Parameters:

datasetInstanceId - Id.DatasetInstance of the dataset instance.

Throws:

IOException

Exception

upgrade

void upgrade(Id.DatasetInstance datasetInstanceId)
             throws Exception

Upgrades dataset.

Parameters:

datasetInstanceId - Id.DatasetInstance of the dataset instance.

Throws:

IOException

Exception