Package org.apache.hadoop.hbase.rest

Class ProtobufStreamingOutput

java.lang.Object

org.apache.hadoop.hbase.rest.ProtobufStreamingOutput

All Implemented Interfaces:

org.apache.hbase.thirdparty.javax.ws.rs.core.StreamingOutput

@Private
public class ProtobufStreamingOutput
extends Object
implements org.apache.hbase.thirdparty.javax.ws.rs.core.StreamingOutput

Field Summary

Fields

Modifier and Type	Field	Description
private String	contentType
private int	fetchSize
private int	limit
private static final org.slf4j.Logger	LOG
private ResultScanner	resultScanner

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ProtobufStreamingOutput(ResultScanner scanner, String type, int limit, int fetchSize)

Method Summary

Modifier and Type	Method	Description
private CellSetModel	createModelFromResults(Result[] results)
void	write(OutputStream outStream)
private void	writeToStream(CellSetModel model, String contentType, OutputStream outStream)

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

contentType

private String contentType

resultScanner

private ResultScanner resultScanner

limit

private int limit

fetchSize

private int fetchSize

Constructor Details

ProtobufStreamingOutput

protected ProtobufStreamingOutput(ResultScanner scanner,
 String type,
 int limit,
 int fetchSize)

Method Details

write

public void write(OutputStream outStream)
           throws IOException,
org.apache.hbase.thirdparty.javax.ws.rs.WebApplicationException

Specified by:

write in interface org.apache.hbase.thirdparty.javax.ws.rs.core.StreamingOutput

Throws:

IOException

org.apache.hbase.thirdparty.javax.ws.rs.WebApplicationException

writeToStream

private void writeToStream(CellSetModel model,
 String contentType,
 OutputStream outStream)
                    throws IOException

Throws:

IOException

createModelFromResults

private CellSetModel createModelFromResults(Result[] results)