| Package | Description |
|---|---|
| co.cask.cdap.data.stream.service.upload |
| Modifier and Type | Class and Description |
|---|---|
class |
BufferedContentWriterFactory
A
ContentWriterFactory that creates ContentWriter that buffer all write requests in memory
and write them out at close time. |
class |
FileContentWriterFactory
A
ContentWriterFactory that creates ContentWriter that will
write events to file directly. |
class |
LengthBasedContentWriterFactory
A
ContentWriterFactory that creates LengthBasedContentWriter that buffers write requests in memory
until a threshold and then switches to writing events to file directly. |
| Modifier and Type | Method and Description |
|---|---|
co.cask.http.BodyConsumer |
StreamBodyConsumerFactory.create(org.jboss.netty.handler.codec.http.HttpRequest request,
ContentWriterFactory contentWriterFactory)
Creates a
BodyConsumer to handle the given batch request. |
Copyright © 2016 Cask Data, Inc. Licensed under the Apache License, Version 2.0.