@@ -76,7 +76,7 @@ public void testConnectionPoolSize() throws Exception {
7676 assertEquals (TEST_CONNECTION_POOL_SIZE , obTableClient .getOdpTable ()
7777 .getObTableConnectionPoolSize ());
7878 } else {
79- ObPair <Long , ObTableParam > obPair = obTableClient .getTable ("test_varchar_table" ,
79+ ObPair <Long , ObTableParam > obPair = obTableClient .getTableBySingleRowKey ("test_varchar_table" ,
8080 new String [] { "abc" }, false , false );
8181 int poolSize = obPair .getRight ().getObTable ().getObTableConnectionPoolSize ();
8282 assertEquals (TEST_CONNECTION_POOL_SIZE , poolSize );
@@ -108,7 +108,7 @@ public void testWatermarkSetting() throws Exception {
108108 assertEquals (TEST_NETTY_WAIT_INTERVAL , obTableClient .getOdpTable ()
109109 .getNettyBlockingWaitInterval ());
110110 } else {
111- ObPair <Long , ObTableParam > obPair = obTableClient .getTable ("test_varchar_table" ,
111+ ObPair <Long , ObTableParam > obPair = obTableClient .getTableBySingleRowKey ("test_varchar_table" ,
112112 new String [] { "abc" }, false , false );
113113 int lowWatermark = obPair .getRight ().getObTable ().getNettyBufferLowWatermark ();
114114 int highWatermark = obPair .getRight ().getObTable ().getNettyBufferHighWatermark ();
@@ -130,7 +130,7 @@ public void testDefaultWatermark() throws Exception {
130130 if (obTableClient .isOdpMode ()) {
131131 // do nothing
132132 } else {
133- ObPair <Long , ObTableParam > obPair = obTableClient .getTable ("test_varchar_table" ,
133+ ObPair <Long , ObTableParam > obPair = obTableClient .getTableBySingleRowKey ("test_varchar_table" ,
134134 new String [] { "abc" }, false , false );
135135 int lowWatermark = obPair .getRight ().getObTable ().getNettyBufferLowWatermark ();
136136 int highWatermark = obPair .getRight ().getObTable ().getNettyBufferHighWatermark ();
0 commit comments