co.cask.cdap.data.stream.service

Class StreamHandler

java.lang.Object

co.cask.http.AbstractHttpHandler

co.cask.cdap.data.stream.service.StreamHandler

All Implemented Interfaces:

co.cask.http.HttpHandler

public final class StreamHandler
extends co.cask.http.AbstractHttpHandler

The HttpHandler for handling REST call to V3 stream APIs.

Constructor Summary

Constructors

Constructor and Description
StreamHandler(CConfiguration cConf, StreamCoordinatorClient streamCoordinatorClient, StreamAdmin streamAdmin, StreamFileWriterFactory writerFactory, MetricsCollectionService metricsCollectionService, StreamWriterSizeCollector sizeCollector, AbstractNamespaceClient namespaceClient)

Method Summary

Methods

Modifier and Type	Method and Description
void	asyncEnqueue(org.jboss.netty.handler.codec.http.HttpRequest request, co.cask.http.HttpResponder responder, String namespaceId, String stream)
co.cask.http.BodyConsumer	batch(org.jboss.netty.handler.codec.http.HttpRequest request, co.cask.http.HttpResponder responder, String namespaceId, String stream)
void	create(org.jboss.netty.handler.codec.http.HttpRequest request, co.cask.http.HttpResponder responder, String namespaceId, String stream)
void	delete(org.jboss.netty.handler.codec.http.HttpRequest request, co.cask.http.HttpResponder responder, String namespaceId, String stream)
void	destroy(co.cask.http.HandlerContext context)
void	enqueue(org.jboss.netty.handler.codec.http.HttpRequest request, co.cask.http.HttpResponder responder, String namespaceId, String stream)
void	getInfo(org.jboss.netty.handler.codec.http.HttpRequest request, co.cask.http.HttpResponder responder, String namespaceId, String stream)
void	init(co.cask.http.HandlerContext context)
void	setConfig(org.jboss.netty.handler.codec.http.HttpRequest request, co.cask.http.HttpResponder responder, String namespaceId, String stream)
void	truncate(org.jboss.netty.handler.codec.http.HttpRequest request, co.cask.http.HttpResponder responder, String namespaceId, String stream)

Methods inherited from class co.cask.http.AbstractHttpHandler

sendInternalRequest

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamHandler

@Inject
public StreamHandler(CConfiguration cConf,
                    StreamCoordinatorClient streamCoordinatorClient,
                    StreamAdmin streamAdmin,
                    StreamFileWriterFactory writerFactory,
                    MetricsCollectionService metricsCollectionService,
                    StreamWriterSizeCollector sizeCollector,
                    AbstractNamespaceClient namespaceClient)

Method Detail

init

public void init(co.cask.http.HandlerContext context)

Specified by:

init in interface co.cask.http.HttpHandler

Overrides:

init in class co.cask.http.AbstractHttpHandler

destroy

public void destroy(co.cask.http.HandlerContext context)

Specified by:

destroy in interface co.cask.http.HttpHandler

Overrides:

destroy in class co.cask.http.AbstractHttpHandler

getInfo

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

Throws:

Exception

create

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

Throws:

Exception

enqueue

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

Throws:

Exception

asyncEnqueue

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

Throws:

Exception

batch

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

Throws:

Exception

truncate

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

Throws:

Exception

delete

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

Throws:

Exception

setConfig

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

Throws:

Exception