Package com.alibaba.wasp

Examples of com.alibaba.wasp.ReadModel

94
95
96
97
98
99
100
101
102
103
104
  public void testGet() {
    String tableName = "test";
    String primary = "1234";
    String familyName = "info";
    String columnName = "col";
    ReadModel model = ReadModel.SNAPSHOT;
    GetAction action = new GetAction(model, tableName, Bytes.toBytes(primary));
    action.addEntityColumn(tableName, familyName, columnName, DataType.STRING, null);
    action.addEntityColumn(tableName, familyName, columnName, DataType.STRING, null);
    GetActionProto proto = ProtobufUtil.toGetActionProto(action);
    action = (GetAction) ProtobufUtil.toGetAction(proto);
View Full Code Here
113
114
115
116
117
118
119
120
121
122
123
        && action.getColumns().get(1).getColumnName().equals(columnName));
  }

  @Test
  public void testScan() {
    ReadModel readerMode = ReadModel.INCONSISTENT;
    String indexTableName = "test_index";
    String entityTableName = "test";
    byte[] startKey = "000".getBytes();
    byte[] endKey = "111".getBytes();
    int limit = 100;
View Full Code Here
TOP

Related Classes of com.alibaba.wasp.ReadModel

  • com.alibaba.wasp.protobuf.TestProtobufUtil
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.