co.cask.cdap.data.stream.service

Class StreamFetchHandler

java.lang.Object

co.cask.http.AbstractHttpHandler

co.cask.cdap.data.stream.service.StreamFetchHandler

All Implemented Interfaces:

co.cask.http.HttpHandler

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

A HTTP handler for handling getting stream events.

Constructor Summary

Constructors

Constructor and Description
StreamFetchHandler(CConfiguration cConf, StreamAdmin streamAdmin, StreamMetaStore streamMetaStore)

Method Summary

Methods

Modifier and Type	Method and Description
void	fetch(org.jboss.netty.handler.codec.http.HttpRequest request, co.cask.http.HttpResponder responder, String namespaceId, String stream, String start, String end, int limit) Handler for the HTTP API /streams/[stream_name]/events?start=[start_ts]&end=[end_ts]&limit=[event_limit]

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

StreamFetchHandler

@Inject
public StreamFetchHandler(CConfiguration cConf,
                         StreamAdmin streamAdmin,
                         StreamMetaStore streamMetaStore)

Method Detail

fetch

public void fetch(org.jboss.netty.handler.codec.http.HttpRequest request,
         co.cask.http.HttpResponder responder,
         String namespaceId,
         String stream,
         String start,
         String end,
         int limit)
           throws Exception

Handler for the HTTP API /streams/[stream_name]/events?start=[start_ts]&end=[end_ts]&limit=[event_limit]

Responds with:

• 404 if stream does not exist
• 204 if no event in the given start/end time range exists
• 200 if there is are one or more events

Response body is a JSON array of the StreamEvent object.

Throws:

Exception

See Also:

StreamEventTypeAdapter for the format of the StreamEvent object