Examples of addEntityColumn()

Examples of com.alibaba.wasp.plan.action.GetAction.addEntityColumn()

96
97
98
99
100
101
102
103
104
105
106
    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);
    Assert.assertTrue(model == action.getReaderMode());
    Assert.assertTrue(tableName.equals(action.getFTableName()));
View Full Code Here

Examples of com.alibaba.wasp.plan.action.GetAction.addEntityColumn()

97
98
99
100
101
102
103
104
105
106
107
    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);
    Assert.assertTrue(model == action.getReaderMode());
    Assert.assertTrue(tableName.equals(action.getFTableName()));
    Assert.assertTrue(primary.equals(Bytes.toString(action.getCombinedPrimaryKey())));
View Full Code Here

Examples of com.alibaba.wasp.plan.action.InsertAction.addEntityColumn()

56
57
58
59
60
61
62
63
64
65
66
    String primary = "1234";
    String familyName = "info";
    String columnName = "col";
    String value = "8899";
    InsertAction action = new InsertAction(tableName, Bytes.toBytes(primary));
    action.addEntityColumn(tableName, familyName, columnName, DataType.STRING,
        Bytes.toBytes(value));
    MessageProto message = ProtobufUtil.convertInsertAction(action);
    action = (InsertAction) ProtobufUtil.convertWriteAction(message);
    Assert.assertTrue(tableName.equals(action.getFTableName()));
    Assert.assertTrue(primary.equals(Bytes.toString(action.getCombinedPrimaryKey())));
View Full Code Here

Examples of com.alibaba.wasp.plan.action.ScanAction.addEntityColumn()

122
123
124
125
126
127
128
129
130
131
132
    byte[] endKey = "111".getBytes();
    int limit = 100;
    int batch = 20;
    ScanAction action = new ScanAction(readerMode, indexTableName, entityTableName,
        startKey, endKey);
    action.addEntityColumn("test", "f", "c", DataType.STRING, Bytes.toBytes(""));
    action.addEntityColumn("test", "f", "c", DataType.STRING, Bytes.toBytes(""));
    action.setBatch(batch);
    action.setLimit(limit);
    ScanActionProto proto = ProtobufUtil.convertScanAction(action);
    action = (ScanAction) ProtobufUtil.convertScanAction(proto);
View Full Code Here

Examples of com.alibaba.wasp.plan.action.ScanAction.addEntityColumn()

123
124
125
126
127
128
129
130
131
132
133
    int limit = 100;
    int batch = 20;
    ScanAction action = new ScanAction(readerMode, indexTableName, entityTableName,
        startKey, endKey);
    action.addEntityColumn("test", "f", "c", DataType.STRING, Bytes.toBytes(""));
    action.addEntityColumn("test", "f", "c", DataType.STRING, Bytes.toBytes(""));
    action.setBatch(batch);
    action.setLimit(limit);
    ScanActionProto proto = ProtobufUtil.convertScanAction(action);
    action = (ScanAction) ProtobufUtil.convertScanAction(proto);
    Assert.assertTrue(readerMode == action.getReaderMode());
View Full Code Here

Examples of com.alibaba.wasp.plan.action.UpdateAction.addEntityColumn()

76
77
78
79
80
81
82
83
84
85
86
    String primary = "1234";
    String familyName = "info";
    String columnName = "col";
    String value = "8899";
    UpdateAction action = new UpdateAction(tableName, Bytes.toBytes(primary));
    action.addEntityColumn(tableName, familyName, columnName, DataType.STRING,
        Bytes.toBytes(value));
    MessageProto message = ProtobufUtil.convertUpdateAction(action);
    action = (UpdateAction) ProtobufUtil.convertWriteAction(message);
    Assert.assertTrue(tableName.equals(action.getFTableName()));
    Assert.assertTrue(primary.equals(Bytes.toString(action.getCombinedPrimaryKey())));
View Full Code Here

Examples of com.alibaba.wasp.plan.action.UpdateAction.addEntityColumn()

289
290
291
292
293
294
295
296
297
298
299
      // Check the input is the same as DataType
      checkType(field, updateItem.getValue());
      byte[] value = convert(field, updateItem.getValue());
      String familyName = metaEventOperation.getColumnFamily(fTableName,
          columnName);
      action.addEntityColumn(fTableName, familyName, columnName,
          field.getType(), value);
    }
    if (context.isGenWholePlan()) {
      Condition entityGroupKeyCondition = ParserUtils.getCondition(table
          .getEntityGroupKey().getName(), conditions);
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.