public class ProtobufStreamingUtil extends Object implements javax.ws.rs.core.StreamingOutput
| Modifier and Type | Field and Description |
|---|---|
private String |
contentType |
private int |
fetchSize |
private int |
limit |
private static org.apache.commons.logging.Log |
LOG |
private ResultScanner |
resultScanner |
| Modifier | Constructor and Description |
|---|---|
protected |
ProtobufStreamingUtil(ResultScanner scanner,
String type,
int limit,
int fetchSize) |
| Modifier and Type | Method and Description |
|---|---|
private CellSetModel |
createModelFromResults(Result[] results) |
void |
write(OutputStream outStream) |
private void |
writeToStream(CellSetModel model,
String contentType,
OutputStream outStream) |
private static final org.apache.commons.logging.Log LOG
private String contentType
private ResultScanner resultScanner
private int limit
private int fetchSize
protected ProtobufStreamingUtil(ResultScanner scanner, String type, int limit, int fetchSize)
public void write(OutputStream outStream) throws IOException, javax.ws.rs.WebApplicationException
write in interface javax.ws.rs.core.StreamingOutputIOExceptionjavax.ws.rs.WebApplicationExceptionprivate void writeToStream(CellSetModel model, String contentType, OutputStream outStream) throws IOException
IOExceptionprivate CellSetModel createModelFromResults(Result[] results)
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.