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

Class DatasetInstanceHandler

java.lang.Object

co.cask.http.AbstractHttpHandler

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

All Implemented Interfaces:

co.cask.http.HttpHandler

public class DatasetInstanceHandler
extends co.cask.http.AbstractHttpHandler

Handles dataset instance management calls.

Constructor Summary

Constructors

Constructor and Description
DatasetInstanceHandler(DatasetInstanceService instanceService)

Method Summary

Methods

Modifier and Type	Method and Description
void	create(org.jboss.netty.handler.codec.http.HttpRequest request, co.cask.http.HttpResponder responder, String namespaceId, String name) Creates a new dataset instance.
void	drop(org.jboss.netty.handler.codec.http.HttpRequest request, co.cask.http.HttpResponder responder, String namespaceId, String name) Deletes a dataset instance, which also deletes the data owned by it.
void	executeAdmin(org.jboss.netty.handler.codec.http.HttpRequest request, co.cask.http.HttpResponder responder, String namespaceId, String name, String method) Executes an admin operation on a dataset instance.
void	executeDataOp(org.jboss.netty.handler.codec.http.HttpRequest request, co.cask.http.HttpResponder responder, String namespaceId, String name, String method) Executes a data operation on a dataset instance.
void	get(org.jboss.netty.handler.codec.http.HttpRequest request, co.cask.http.HttpResponder responder, String namespaceId, String name, List<String> owners) Gets the DatasetMeta for a dataset instance.
void	list(org.jboss.netty.handler.codec.http.HttpRequest request, co.cask.http.HttpResponder responder, String namespaceId)
void	update(org.jboss.netty.handler.codec.http.HttpRequest request, co.cask.http.HttpResponder responder, String namespaceId, String name) Updates an existing dataset specification properties.

Methods inherited from class co.cask.http.AbstractHttpHandler

destroy, init, sendInternalRequest

Methods inherited from class java.lang.Object

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

Constructor Detail

DatasetInstanceHandler

@Inject
public DatasetInstanceHandler(DatasetInstanceService instanceService)

Method Detail

list

public void list(org.jboss.netty.handler.codec.http.HttpRequest request,
        co.cask.http.HttpResponder responder,
        String namespaceId)
          throws Exception

Throws:

Exception

get

public void get(org.jboss.netty.handler.codec.http.HttpRequest request,
       co.cask.http.HttpResponder responder,
       String namespaceId,
       String name,
       List<String> owners)
         throws Exception

Gets the DatasetMeta for a dataset instance.

Parameters:

namespaceId - namespace of the dataset instance

name - name of the dataset instance

owners - a list of owners of the dataset instance, in the form @{code ::} (e.g. "program::namespace:default/application:PurchaseHistory/program:flow:PurchaseFlow")

Throws:

Exception - if the dataset instance was not found

create

public void create(org.jboss.netty.handler.codec.http.HttpRequest request,
          co.cask.http.HttpResponder responder,
          String namespaceId,
          String name)
            throws Exception

Creates a new dataset instance.

Parameters:

namespaceId - namespace of the new dataset instance

name - name of the new dataset instance

Throws:

Exception

update

public void update(org.jboss.netty.handler.codec.http.HttpRequest request,
          co.cask.http.HttpResponder responder,
          String namespaceId,
          String name)
            throws Exception

Updates an existing dataset specification properties.

Parameters:

namespaceId - namespace of the dataset instance

name - name of the dataset instance

Throws:

Exception

drop

public void drop(org.jboss.netty.handler.codec.http.HttpRequest request,
        co.cask.http.HttpResponder responder,
        String namespaceId,
        String name)
          throws Exception

Deletes a dataset instance, which also deletes the data owned by it.

Parameters:

namespaceId - namespace of the dataset instance

name - name of the dataset instance

Throws:

Exception

executeAdmin

public void executeAdmin(org.jboss.netty.handler.codec.http.HttpRequest request,
                co.cask.http.HttpResponder responder,
                String namespaceId,
                String name,
                String method)
                  throws Exception

Executes an admin operation on a dataset instance.

Parameters:

namespaceId - namespace of the dataset instance

name - name of the dataset instance

method - the admin operation to execute (e.g. "exists", "truncate", "upgrade")

Throws:

Exception

executeDataOp

public void executeDataOp(org.jboss.netty.handler.codec.http.HttpRequest request,
                 co.cask.http.HttpResponder responder,
                 String namespaceId,
                 String name,
                 String method)

Executes a data operation on a dataset instance. Not yet implemented.

Parameters:

namespaceId - namespace of the dataset instance

name - name of the dataset instance

method - the data operation to execute