Skip to content

Commit dfe9531

Browse files
committed
fix merge error
1 parent 1763082 commit dfe9531

File tree

1 file changed

+17
-0
lines changed

1 file changed

+17
-0
lines changed

src/main/java/com/alipay/oceanbase/rpc/stream/ObTableClientQueryStreamResult.java

Lines changed: 17 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -34,8 +34,10 @@
3434
import java.util.concurrent.atomic.AtomicReference;
3535

3636
public class ObTableClientQueryStreamResult extends AbstractQueryStreamResult {
37+
3738
private static final Logger logger = TableClientLoggerFactory
3839
.getLogger(ObTableClientQueryStreamResult.class);
40+
protected ObTableClient client;
3941

4042
protected ObTableQueryResult referToNewPartition(ObPair<Long, ObTableParam> partIdWithObTable)
4143
throws Exception {
@@ -82,4 +84,19 @@ protected Map<Long, ObPair<Long, ObTableParam>> refreshPartition(ObTableQuery ta
8284
throws Exception {
8385
return buildPartitions(client, tableQuery, tableName);
8486
}
87+
88+
/**
89+
* Get client.
90+
* @return client
91+
*/
92+
public ObTableClient getClient() {
93+
return client;
94+
}
95+
96+
/*
97+
* Set client.
98+
*/
99+
public void setClient(ObTableClient client) {
100+
this.client = client;
101+
}
85102
}

0 commit comments

Comments
 (0)