@InterfaceAudience.Private public class ProtobufStreamingOutput extends Object implements org.apache.hbase.thirdparty.javax.ws.rs.core.StreamingOutput
Modifier and Type | Field and Description |
---|---|
private String |
contentType |
private int |
fetchSize |
private int |
limit |
private static org.slf4j.Logger |
LOG |
private ResultScanner |
resultScanner |
Modifier | Constructor and Description |
---|---|
protected |
ProtobufStreamingOutput(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.slf4j.Logger LOG
private String contentType
private ResultScanner resultScanner
private int limit
private int fetchSize
protected ProtobufStreamingOutput(ResultScanner scanner, String type, int limit, int fetchSize)
public void write(OutputStream outStream) throws IOException, org.apache.hbase.thirdparty.javax.ws.rs.WebApplicationException
write
in interface org.apache.hbase.thirdparty.javax.ws.rs.core.StreamingOutput
IOException
org.apache.hbase.thirdparty.javax.ws.rs.WebApplicationException
private void writeToStream(CellSetModel model, String contentType, OutputStream outStream) throws IOException
IOException
private CellSetModel createModelFromResults(Result[] results)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.