@Generated(value="proto") public static final class ClientProtos.ScanResponse extends com.google.protobuf.GeneratedMessage implements ClientProtos.ScanResponseOrBuilder
hbase.pb.ScanResponse
The scan response. If there are no more results, more_results will be false. If it is not specified, it means there are more.
Modifier and Type | Class and Description |
---|---|
static class |
ClientProtos.ScanResponse.Builder
Protobuf type
hbase.pb.ScanResponse |
com.google.protobuf.GeneratedMessage.BuilderParent, com.google.protobuf.GeneratedMessage.ExtendableBuilder<MessageType extends com.google.protobuf.GeneratedMessage.ExtendableMessage,BuilderType extends com.google.protobuf.GeneratedMessage.ExtendableBuilder>, com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageType extends com.google.protobuf.GeneratedMessage.ExtendableMessage>, com.google.protobuf.GeneratedMessage.ExtendableMessageOrBuilder<MessageType extends com.google.protobuf.GeneratedMessage.ExtendableMessage>, com.google.protobuf.GeneratedMessage.FieldAccessorTable, com.google.protobuf.GeneratedMessage.GeneratedExtension<ContainingType extends com.google.protobuf.Message,Type>
Modifier and Type | Field and Description |
---|---|
static int |
CELLS_PER_RESULT_FIELD_NUMBER |
static int |
CURSOR_FIELD_NUMBER |
static int |
HEARTBEAT_MESSAGE_FIELD_NUMBER |
static int |
MORE_RESULTS_FIELD_NUMBER |
static int |
MORE_RESULTS_IN_REGION_FIELD_NUMBER |
static int |
MVCC_READ_POINT_FIELD_NUMBER |
static com.google.protobuf.Parser<ClientProtos.ScanResponse> |
PARSER |
static int |
PARTIAL_FLAG_PER_RESULT_FIELD_NUMBER |
static int |
RESULTS_FIELD_NUMBER |
static int |
SCAN_METRICS_FIELD_NUMBER |
static int |
SCANNER_ID_FIELD_NUMBER |
static int |
STALE_FIELD_NUMBER |
static int |
TTL_FIELD_NUMBER |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object obj) |
int |
getCellsPerResult(int index)
repeated uint32 cells_per_result = 1; |
int |
getCellsPerResultCount()
repeated uint32 cells_per_result = 1; |
List<Integer> |
getCellsPerResultList()
repeated uint32 cells_per_result = 1; |
ClientProtos.Cursor |
getCursor()
optional .hbase.pb.Cursor cursor = 12; |
ClientProtos.CursorOrBuilder |
getCursorOrBuilder()
optional .hbase.pb.Cursor cursor = 12; |
static ClientProtos.ScanResponse |
getDefaultInstance() |
ClientProtos.ScanResponse |
getDefaultInstanceForType() |
static com.google.protobuf.Descriptors.Descriptor |
getDescriptor() |
boolean |
getHeartbeatMessage()
optional bool heartbeat_message = 9; |
boolean |
getMoreResults()
optional bool more_results = 3; |
boolean |
getMoreResultsInRegion()
optional bool more_results_in_region = 8; |
long |
getMvccReadPoint()
optional uint64 mvcc_read_point = 11 [default = 0]; |
com.google.protobuf.Parser<ClientProtos.ScanResponse> |
getParserForType() |
boolean |
getPartialFlagPerResult(int index)
repeated bool partial_flag_per_result = 7; |
int |
getPartialFlagPerResultCount()
repeated bool partial_flag_per_result = 7; |
List<Boolean> |
getPartialFlagPerResultList()
repeated bool partial_flag_per_result = 7; |
ClientProtos.Result |
getResults(int index)
repeated .hbase.pb.Result results = 5; |
int |
getResultsCount()
repeated .hbase.pb.Result results = 5; |
List<ClientProtos.Result> |
getResultsList()
repeated .hbase.pb.Result results = 5; |
ClientProtos.ResultOrBuilder |
getResultsOrBuilder(int index)
repeated .hbase.pb.Result results = 5; |
List<? extends ClientProtos.ResultOrBuilder> |
getResultsOrBuilderList()
repeated .hbase.pb.Result results = 5; |
MapReduceProtos.ScanMetrics |
getScanMetrics()
optional .hbase.pb.ScanMetrics scan_metrics = 10; |
MapReduceProtos.ScanMetricsOrBuilder |
getScanMetricsOrBuilder()
optional .hbase.pb.ScanMetrics scan_metrics = 10; |
long |
getScannerId()
optional uint64 scanner_id = 2; |
int |
getSerializedSize() |
boolean |
getStale()
optional bool stale = 6; |
int |
getTtl()
optional uint32 ttl = 4; |
com.google.protobuf.UnknownFieldSet |
getUnknownFields() |
boolean |
hasCursor()
optional .hbase.pb.Cursor cursor = 12; |
int |
hashCode() |
boolean |
hasHeartbeatMessage()
optional bool heartbeat_message = 9; |
boolean |
hasMoreResults()
optional bool more_results = 3; |
boolean |
hasMoreResultsInRegion()
optional bool more_results_in_region = 8; |
boolean |
hasMvccReadPoint()
optional uint64 mvcc_read_point = 11 [default = 0]; |
boolean |
hasScanMetrics()
optional .hbase.pb.ScanMetrics scan_metrics = 10; |
boolean |
hasScannerId()
optional uint64 scanner_id = 2; |
boolean |
hasStale()
optional bool stale = 6; |
boolean |
hasTtl()
optional uint32 ttl = 4; |
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable |
internalGetFieldAccessorTable() |
boolean |
isInitialized() |
static ClientProtos.ScanResponse.Builder |
newBuilder() |
static ClientProtos.ScanResponse.Builder |
newBuilder(ClientProtos.ScanResponse prototype) |
ClientProtos.ScanResponse.Builder |
newBuilderForType() |
protected ClientProtos.ScanResponse.Builder |
newBuilderForType(com.google.protobuf.GeneratedMessage.BuilderParent parent) |
static ClientProtos.ScanResponse |
parseDelimitedFrom(InputStream input) |
static ClientProtos.ScanResponse |
parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static ClientProtos.ScanResponse |
parseFrom(byte[] data) |
static ClientProtos.ScanResponse |
parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static ClientProtos.ScanResponse |
parseFrom(com.google.protobuf.ByteString data) |
static ClientProtos.ScanResponse |
parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static ClientProtos.ScanResponse |
parseFrom(com.google.protobuf.CodedInputStream input) |
static ClientProtos.ScanResponse |
parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static ClientProtos.ScanResponse |
parseFrom(InputStream input) |
static ClientProtos.ScanResponse |
parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
ClientProtos.ScanResponse.Builder |
toBuilder() |
protected Object |
writeReplace() |
void |
writeTo(com.google.protobuf.CodedOutputStream output) |
getAllFields, getDescriptorForType, getField, getRepeatedField, getRepeatedFieldCount, hasField, makeExtensionsImmutable, newFileScopedGeneratedExtension, newMessageScopedGeneratedExtension, parseUnknownField
findInitializationErrors, getInitializationErrorString, hashBoolean, hashEnum, hashEnumList, hashFields, hashLong, toString
toByteArray, toByteString, writeDelimitedTo, writeTo
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
public static com.google.protobuf.Parser<ClientProtos.ScanResponse> PARSER
public static final int CELLS_PER_RESULT_FIELD_NUMBER
public static final int SCANNER_ID_FIELD_NUMBER
public static final int MORE_RESULTS_FIELD_NUMBER
public static final int TTL_FIELD_NUMBER
public static final int RESULTS_FIELD_NUMBER
public static final int STALE_FIELD_NUMBER
public static final int PARTIAL_FLAG_PER_RESULT_FIELD_NUMBER
public static final int MORE_RESULTS_IN_REGION_FIELD_NUMBER
public static final int HEARTBEAT_MESSAGE_FIELD_NUMBER
public static final int SCAN_METRICS_FIELD_NUMBER
public static final int MVCC_READ_POINT_FIELD_NUMBER
public static final int CURSOR_FIELD_NUMBER
public static ClientProtos.ScanResponse getDefaultInstance()
public ClientProtos.ScanResponse getDefaultInstanceForType()
getDefaultInstanceForType
in interface com.google.protobuf.MessageLiteOrBuilder
getDefaultInstanceForType
in interface com.google.protobuf.MessageOrBuilder
public final com.google.protobuf.UnknownFieldSet getUnknownFields()
getUnknownFields
in interface com.google.protobuf.MessageOrBuilder
getUnknownFields
in class com.google.protobuf.GeneratedMessage
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable internalGetFieldAccessorTable()
internalGetFieldAccessorTable
in class com.google.protobuf.GeneratedMessage
public com.google.protobuf.Parser<ClientProtos.ScanResponse> getParserForType()
getParserForType
in interface com.google.protobuf.Message
getParserForType
in interface com.google.protobuf.MessageLite
getParserForType
in class com.google.protobuf.GeneratedMessage
public List<Integer> getCellsPerResultList()
repeated uint32 cells_per_result = 1;
This field is filled in if we are doing cellblocks. A cellblock is made up of all Cells serialized out as one cellblock BUT responses from a server have their Cells grouped by Result. So we can reconstitute the Results on the client-side, this field is a list of counts of Cells in each Result that makes up the response. For example, if this field has 3, 3, 3 in it, then we know that on the client, we are to make three Results each of three Cells each.
getCellsPerResultList
in interface ClientProtos.ScanResponseOrBuilder
public int getCellsPerResultCount()
repeated uint32 cells_per_result = 1;
This field is filled in if we are doing cellblocks. A cellblock is made up of all Cells serialized out as one cellblock BUT responses from a server have their Cells grouped by Result. So we can reconstitute the Results on the client-side, this field is a list of counts of Cells in each Result that makes up the response. For example, if this field has 3, 3, 3 in it, then we know that on the client, we are to make three Results each of three Cells each.
getCellsPerResultCount
in interface ClientProtos.ScanResponseOrBuilder
public int getCellsPerResult(int index)
repeated uint32 cells_per_result = 1;
This field is filled in if we are doing cellblocks. A cellblock is made up of all Cells serialized out as one cellblock BUT responses from a server have their Cells grouped by Result. So we can reconstitute the Results on the client-side, this field is a list of counts of Cells in each Result that makes up the response. For example, if this field has 3, 3, 3 in it, then we know that on the client, we are to make three Results each of three Cells each.
getCellsPerResult
in interface ClientProtos.ScanResponseOrBuilder
public boolean hasScannerId()
optional uint64 scanner_id = 2;
hasScannerId
in interface ClientProtos.ScanResponseOrBuilder
public long getScannerId()
optional uint64 scanner_id = 2;
getScannerId
in interface ClientProtos.ScanResponseOrBuilder
public boolean hasMoreResults()
optional bool more_results = 3;
hasMoreResults
in interface ClientProtos.ScanResponseOrBuilder
public boolean getMoreResults()
optional bool more_results = 3;
getMoreResults
in interface ClientProtos.ScanResponseOrBuilder
public boolean hasTtl()
optional uint32 ttl = 4;
hasTtl
in interface ClientProtos.ScanResponseOrBuilder
public int getTtl()
optional uint32 ttl = 4;
getTtl
in interface ClientProtos.ScanResponseOrBuilder
public List<ClientProtos.Result> getResultsList()
repeated .hbase.pb.Result results = 5;
If cells are not carried in an accompanying cellblock, then they are pb'd here. This field is mutually exclusive with cells_per_result (since the Cells will be inside the pb'd Result)
getResultsList
in interface ClientProtos.ScanResponseOrBuilder
public List<? extends ClientProtos.ResultOrBuilder> getResultsOrBuilderList()
repeated .hbase.pb.Result results = 5;
If cells are not carried in an accompanying cellblock, then they are pb'd here. This field is mutually exclusive with cells_per_result (since the Cells will be inside the pb'd Result)
getResultsOrBuilderList
in interface ClientProtos.ScanResponseOrBuilder
public int getResultsCount()
repeated .hbase.pb.Result results = 5;
If cells are not carried in an accompanying cellblock, then they are pb'd here. This field is mutually exclusive with cells_per_result (since the Cells will be inside the pb'd Result)
getResultsCount
in interface ClientProtos.ScanResponseOrBuilder
public ClientProtos.Result getResults(int index)
repeated .hbase.pb.Result results = 5;
If cells are not carried in an accompanying cellblock, then they are pb'd here. This field is mutually exclusive with cells_per_result (since the Cells will be inside the pb'd Result)
getResults
in interface ClientProtos.ScanResponseOrBuilder
public ClientProtos.ResultOrBuilder getResultsOrBuilder(int index)
repeated .hbase.pb.Result results = 5;
If cells are not carried in an accompanying cellblock, then they are pb'd here. This field is mutually exclusive with cells_per_result (since the Cells will be inside the pb'd Result)
getResultsOrBuilder
in interface ClientProtos.ScanResponseOrBuilder
public boolean hasStale()
optional bool stale = 6;
hasStale
in interface ClientProtos.ScanResponseOrBuilder
public boolean getStale()
optional bool stale = 6;
getStale
in interface ClientProtos.ScanResponseOrBuilder
public List<Boolean> getPartialFlagPerResultList()
repeated bool partial_flag_per_result = 7;
This field is filled in if we are doing cellblocks. In the event that a row could not fit all of its cells into a single RPC chunk, the results will be returned as partials, and reconstructed into a complete result on the client side. This field is a list of flags indicating whether or not the result that the cells belong to is a partial result. For example, if this field has false, false, true in it, then we know that on the client side, we need to make another RPC request since the last result was only a partial.
getPartialFlagPerResultList
in interface ClientProtos.ScanResponseOrBuilder
public int getPartialFlagPerResultCount()
repeated bool partial_flag_per_result = 7;
This field is filled in if we are doing cellblocks. In the event that a row could not fit all of its cells into a single RPC chunk, the results will be returned as partials, and reconstructed into a complete result on the client side. This field is a list of flags indicating whether or not the result that the cells belong to is a partial result. For example, if this field has false, false, true in it, then we know that on the client side, we need to make another RPC request since the last result was only a partial.
getPartialFlagPerResultCount
in interface ClientProtos.ScanResponseOrBuilder
public boolean getPartialFlagPerResult(int index)
repeated bool partial_flag_per_result = 7;
This field is filled in if we are doing cellblocks. In the event that a row could not fit all of its cells into a single RPC chunk, the results will be returned as partials, and reconstructed into a complete result on the client side. This field is a list of flags indicating whether or not the result that the cells belong to is a partial result. For example, if this field has false, false, true in it, then we know that on the client side, we need to make another RPC request since the last result was only a partial.
getPartialFlagPerResult
in interface ClientProtos.ScanResponseOrBuilder
public boolean hasMoreResultsInRegion()
optional bool more_results_in_region = 8;
A server may choose to limit the number of results returned to the client for reasons such as the size in bytes or quantity of results accumulated. This field will true when more results exist in the current region.
hasMoreResultsInRegion
in interface ClientProtos.ScanResponseOrBuilder
public boolean getMoreResultsInRegion()
optional bool more_results_in_region = 8;
A server may choose to limit the number of results returned to the client for reasons such as the size in bytes or quantity of results accumulated. This field will true when more results exist in the current region.
getMoreResultsInRegion
in interface ClientProtos.ScanResponseOrBuilder
public boolean hasHeartbeatMessage()
optional bool heartbeat_message = 9;
This field is filled in if the server is sending back a heartbeat message. Heartbeat messages are sent back to the client to prevent the scanner from timing out. Seeing a heartbeat message communicates to the Client that the server would have continued to scan had the time limit not been reached.
hasHeartbeatMessage
in interface ClientProtos.ScanResponseOrBuilder
public boolean getHeartbeatMessage()
optional bool heartbeat_message = 9;
This field is filled in if the server is sending back a heartbeat message. Heartbeat messages are sent back to the client to prevent the scanner from timing out. Seeing a heartbeat message communicates to the Client that the server would have continued to scan had the time limit not been reached.
getHeartbeatMessage
in interface ClientProtos.ScanResponseOrBuilder
public boolean hasScanMetrics()
optional .hbase.pb.ScanMetrics scan_metrics = 10;
This field is filled in if the client has requested that scan metrics be tracked. The metrics tracked here are sent back to the client to be tracked together with the existing client side metrics.
hasScanMetrics
in interface ClientProtos.ScanResponseOrBuilder
public MapReduceProtos.ScanMetrics getScanMetrics()
optional .hbase.pb.ScanMetrics scan_metrics = 10;
This field is filled in if the client has requested that scan metrics be tracked. The metrics tracked here are sent back to the client to be tracked together with the existing client side metrics.
getScanMetrics
in interface ClientProtos.ScanResponseOrBuilder
public MapReduceProtos.ScanMetricsOrBuilder getScanMetricsOrBuilder()
optional .hbase.pb.ScanMetrics scan_metrics = 10;
This field is filled in if the client has requested that scan metrics be tracked. The metrics tracked here are sent back to the client to be tracked together with the existing client side metrics.
getScanMetricsOrBuilder
in interface ClientProtos.ScanResponseOrBuilder
public boolean hasMvccReadPoint()
optional uint64 mvcc_read_point = 11 [default = 0];
The mvcc read point which is used to open the scanner at server side. Client can make use of this mvcc_read_point when restarting a scanner to get a consistent view of a row.
hasMvccReadPoint
in interface ClientProtos.ScanResponseOrBuilder
public long getMvccReadPoint()
optional uint64 mvcc_read_point = 11 [default = 0];
The mvcc read point which is used to open the scanner at server side. Client can make use of this mvcc_read_point when restarting a scanner to get a consistent view of a row.
getMvccReadPoint
in interface ClientProtos.ScanResponseOrBuilder
public boolean hasCursor()
optional .hbase.pb.Cursor cursor = 12;
If the Scan need cursor, return the row key we are scanning in heartbeat message. If the Scan doesn't need a cursor, don't set this field to reduce network IO.
hasCursor
in interface ClientProtos.ScanResponseOrBuilder
public ClientProtos.Cursor getCursor()
optional .hbase.pb.Cursor cursor = 12;
If the Scan need cursor, return the row key we are scanning in heartbeat message. If the Scan doesn't need a cursor, don't set this field to reduce network IO.
getCursor
in interface ClientProtos.ScanResponseOrBuilder
public ClientProtos.CursorOrBuilder getCursorOrBuilder()
optional .hbase.pb.Cursor cursor = 12;
If the Scan need cursor, return the row key we are scanning in heartbeat message. If the Scan doesn't need a cursor, don't set this field to reduce network IO.
getCursorOrBuilder
in interface ClientProtos.ScanResponseOrBuilder
public final boolean isInitialized()
isInitialized
in interface com.google.protobuf.MessageLiteOrBuilder
isInitialized
in class com.google.protobuf.GeneratedMessage
public void writeTo(com.google.protobuf.CodedOutputStream output) throws IOException
writeTo
in interface com.google.protobuf.MessageLite
writeTo
in class com.google.protobuf.AbstractMessage
IOException
public int getSerializedSize()
getSerializedSize
in interface com.google.protobuf.MessageLite
getSerializedSize
in class com.google.protobuf.AbstractMessage
protected Object writeReplace() throws ObjectStreamException
writeReplace
in class com.google.protobuf.GeneratedMessage
ObjectStreamException
public boolean equals(Object obj)
equals
in interface com.google.protobuf.Message
equals
in class com.google.protobuf.AbstractMessage
public int hashCode()
hashCode
in interface com.google.protobuf.Message
hashCode
in class com.google.protobuf.AbstractMessage
public static ClientProtos.ScanResponse parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static ClientProtos.ScanResponse parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static ClientProtos.ScanResponse parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static ClientProtos.ScanResponse parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static ClientProtos.ScanResponse parseFrom(InputStream input) throws IOException
IOException
public static ClientProtos.ScanResponse parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
IOException
public static ClientProtos.ScanResponse parseDelimitedFrom(InputStream input) throws IOException
IOException
public static ClientProtos.ScanResponse parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
IOException
public static ClientProtos.ScanResponse parseFrom(com.google.protobuf.CodedInputStream input) throws IOException
IOException
public static ClientProtos.ScanResponse parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
IOException
public static ClientProtos.ScanResponse.Builder newBuilder()
public ClientProtos.ScanResponse.Builder newBuilderForType()
newBuilderForType
in interface com.google.protobuf.Message
newBuilderForType
in interface com.google.protobuf.MessageLite
public static ClientProtos.ScanResponse.Builder newBuilder(ClientProtos.ScanResponse prototype)
public ClientProtos.ScanResponse.Builder toBuilder()
toBuilder
in interface com.google.protobuf.Message
toBuilder
in interface com.google.protobuf.MessageLite
protected ClientProtos.ScanResponse.Builder newBuilderForType(com.google.protobuf.GeneratedMessage.BuilderParent parent)
newBuilderForType
in class com.google.protobuf.GeneratedMessage
Copyright © 2007–2019 Cloudera. All rights reserved.