Skip to content

Commit bc2b5e8

Browse files
committed
Refine sample code of ots writer.
1 parent 8d746ba commit bc2b5e8

File tree

1 file changed

+7
-7
lines changed

1 file changed

+7
-7
lines changed

src/test/java/examples/OTSWriterSample.java

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ public static void main(String args[]) {
3939

4040
scanTable(client, tableName);
4141

42-
deleteTable(client, tableName);
42+
//deleteTable(client, tableName);
4343

4444
} catch (ServiceException e) {
4545
System.err.println("操作失败,详情:" + e.getMessage());
@@ -61,12 +61,12 @@ public static void main(String args[]) {
6161
private static void scanTable(OTSClient client, String tableName) {
6262
RangeIteratorParameter param = new RangeIteratorParameter(tableName);
6363
RowPrimaryKey startKey = new RowPrimaryKey();
64-
startKey.addPrimaryKeyColumn("uid", PrimaryKeyValue.INF_MIN);
65-
startKey.addPrimaryKeyColumn("gid", PrimaryKeyValue.INF_MIN);
64+
startKey.addPrimaryKeyColumn(COLUMN_GID_NAME, PrimaryKeyValue.INF_MIN);
65+
startKey.addPrimaryKeyColumn(COLUMN_UID_NAME, PrimaryKeyValue.INF_MIN);
6666

6767
RowPrimaryKey endKey = new RowPrimaryKey();
68-
endKey.addPrimaryKeyColumn("uid", PrimaryKeyValue.INF_MAX);
69-
endKey.addPrimaryKeyColumn("gid", PrimaryKeyValue.INF_MAX);
68+
endKey.addPrimaryKeyColumn(COLUMN_GID_NAME, PrimaryKeyValue.INF_MAX);
69+
endKey.addPrimaryKeyColumn(COLUMN_UID_NAME, PrimaryKeyValue.INF_MAX);
7070

7171
param.setInclusiveStartPrimaryKey(startKey);
7272
param.setExclusiveEndPrimaryKey(endKey);
@@ -183,8 +183,8 @@ public void run() {
183183
int start = id * rowsCount;
184184
for (int i = 0; i < rowsCount; i++) {
185185
RowPrimaryKey primaryKey = new RowPrimaryKey();
186-
primaryKey.addPrimaryKeyColumn("gid", PrimaryKeyValue.fromLong(start + i));
187-
primaryKey.addPrimaryKeyColumn("uid", PrimaryKeyValue.fromLong(start + i));
186+
primaryKey.addPrimaryKeyColumn(COLUMN_GID_NAME, PrimaryKeyValue.fromLong(start + i));
187+
primaryKey.addPrimaryKeyColumn(COLUMN_UID_NAME, PrimaryKeyValue.fromLong(start + i));
188188

189189
RowPutChange rowChange = new RowPutChange(tableName);
190190
rowChange.setPrimaryKey(primaryKey);

0 commit comments

Comments
 (0)