Package com.alibaba.wasp.plan.action

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
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
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.