Skip to content
This repository was archived by the owner on May 8, 2026. It is now read-only.

Commit 65f3dbf

Browse files
committed
Address review comments
Change-Id: Ie24e59a43eeca52075465f930d269de7482aaadc
1 parent 51bce3f commit 65f3dbf

2 files changed

Lines changed: 4 additions & 1 deletion

File tree

google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/internal/AbstractProtoStructReader.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -357,7 +357,8 @@ Object decodeValue(Value value, SqlType<?> type) {
357357
return ProtoStruct.create(schema, value.getArrayValue());
358358
case PROTO:
359359
try {
360-
return ((SqlType.Proto<?>) type).getParserForType().parseFrom(value.getBytesValue());
360+
SqlType.Proto protoType = (SqlType.Proto) type;
361+
return protoType.getParserForType().parseFrom(value.getBytesValue());
361362
} catch (InvalidProtocolBufferException e) {
362363
throw new IllegalStateException("Unable to parse value to proto " + type, e);
363364
}

google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/models/sql/SqlType.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -143,6 +143,7 @@ interface Field extends ColumnMetadata {
143143
*
144144
* @param <T> Java type of the protobuf message
145145
*/
146+
@BetaApi("This feature is currently experimental and can change in the future")
146147
interface Proto<T extends AbstractMessage> extends SqlType<T> {
147148

148149
/**
@@ -158,6 +159,7 @@ interface Proto<T extends AbstractMessage> extends SqlType<T> {
158159
*
159160
* @param <T> Java type of the protobuf enum
160161
*/
162+
@BetaApi("This feature is currently experimental and can change in the future")
161163
interface Enum<T extends ProtocolMessageEnum> extends SqlType<T> {
162164

163165
/**

0 commit comments

Comments
 (0)