co.cask.cdap.data.stream.service.upload

Class StreamBodyConsumerFactory

java.lang.Object

co.cask.cdap.data.stream.service.upload.StreamBodyConsumerFactory

public class StreamBodyConsumerFactory
extends Object

A factory for creating BodyConsumer to support the stream batch ingest endpoint.

Constructor Summary

Constructors

Constructor and Description
StreamBodyConsumerFactory()

Method Summary

Methods

Modifier and Type	Method and Description
co.cask.http.BodyConsumer	create(org.jboss.netty.handler.codec.http.HttpRequest request, ContentWriterFactory contentWriterFactory) Creates a BodyConsumer to handle the given batch request.

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamBodyConsumerFactory

public StreamBodyConsumerFactory()

Method Detail

create

public co.cask.http.BodyConsumer create(org.jboss.netty.handler.codec.http.HttpRequest request,
                               ContentWriterFactory contentWriterFactory)
                                 throws UnsupportedOperationException

Creates a BodyConsumer to handle the given batch request.

Throws:

UnsupportedOperationException - if no BodyConsumer can supports the given request content type