Package com.hmsonline.storm.cassandra.client

Examples of com.hmsonline.storm.cassandra.client.AstyanaxClient.writeTuple()

94
95
96
97
98
99
100
101
102
103
104
        Fields fields = new Fields("key1", "key2", "foo", "bar");
        Values values = new Values("key1val", "key2val", "fooval", "barval");
        Tuple tuple = new MockTuple(fields, values);

        client.writeTuple(tuple, tupleMapper);

        AstyanaxContext<Keyspace> context = newContext("localhost:9160", KEYSPACE);
        Keyspace ks = context.getEntity();

        Column<String> result = ks
View Full Code Here
145
146
147
148
149
150
151
152
153
154
155
        Values values = new Values("key1val", "key2val", "fooval", "barval");
        TridentTuple tuple = newTridentTuple(fields, values);
       
        SimpleTridentTupleMapper tupleMapper = new SimpleTridentTupleMapper(KEYSPACE, fields);
       
        client.writeTuple(tuple, tupleMapper);
       
        Map<String, String> map = client.lookup(tupleMapper, tuple);
       
        assertEquals("fooval", map.get("foo"));
       
View Full Code Here
174
175
176
177
178
179
180
181
182
183
184
        Values values = new Values("my_row", "a", "a", "aa");
        TridentTuple tuple = newTridentTuple(fields, values);
       
        CompositeColumnTridentTupleMapper tupleMapper = new CompositeColumnTridentTupleMapper(KEYSPACE);
       
        client.writeTuple(tuple, tupleMapper);
       
        tuple = newTridentTuple(fields, new Values("my_row", "b", "b", "bb"));
        client.writeTuple(tuple, tupleMapper);
       
        tuple = newTridentTuple(fields, new Values("my_row", "a", "b", "ab"));
View Full Code Here
177
178
179
180
181
182
183
184
185
186
187
        CompositeColumnTridentTupleMapper tupleMapper = new CompositeColumnTridentTupleMapper(KEYSPACE);
       
        client.writeTuple(tuple, tupleMapper);
       
        tuple = newTridentTuple(fields, new Values("my_row", "b", "b", "bb"));
        client.writeTuple(tuple, tupleMapper);
       
        tuple = newTridentTuple(fields, new Values("my_row", "a", "b", "ab"));
        client.writeTuple(tuple, tupleMapper);
       
        tuple = newTridentTuple(fields, new Values("my_row", "a", "c", "ac"));
View Full Code Here
180
181
182
183
184
185
186
187
188
189
190
       
        tuple = newTridentTuple(fields, new Values("my_row", "b", "b", "bb"));
        client.writeTuple(tuple, tupleMapper);
       
        tuple = newTridentTuple(fields, new Values("my_row", "a", "b", "ab"));
        client.writeTuple(tuple, tupleMapper);
       
        tuple = newTridentTuple(fields, new Values("my_row", "a", "c", "ac"));
        client.writeTuple(tuple, tupleMapper);
       
        tuple = newTridentTuple(fields, new Values("my_row", "a", "d", "ad"));
View Full Code Here
183
184
185
186
187
188
189
190
191
192
193
       
        tuple = newTridentTuple(fields, new Values("my_row", "a", "b", "ab"));
        client.writeTuple(tuple, tupleMapper);
       
        tuple = newTridentTuple(fields, new Values("my_row", "a", "c", "ac"));
        client.writeTuple(tuple, tupleMapper);
       
        tuple = newTridentTuple(fields, new Values("my_row", "a", "d", "ad"));
        client.writeTuple(tuple, tupleMapper);
       
        tuple = newTridentTuple(fields, new Values("my_row", "c", "c", "cc"));
View Full Code Here
186
187
188
189
190
191
192
193
194
195
196
       
        tuple = newTridentTuple(fields, new Values("my_row", "a", "c", "ac"));
        client.writeTuple(tuple, tupleMapper);
       
        tuple = newTridentTuple(fields, new Values("my_row", "a", "d", "ad"));
        client.writeTuple(tuple, tupleMapper);
       
        tuple = newTridentTuple(fields, new Values("my_row", "c", "c", "cc"));
        client.writeTuple(tuple, tupleMapper);
       
        tuple = newTridentTuple(fields, new Values("my_row", "d", "d", "dd"));
View Full Code Here
189
190
191
192
193
194
195
196
197
198
199
       
        tuple = newTridentTuple(fields, new Values("my_row", "a", "d", "ad"));
        client.writeTuple(tuple, tupleMapper);
       
        tuple = newTridentTuple(fields, new Values("my_row", "c", "c", "cc"));
        client.writeTuple(tuple, tupleMapper);
       
        tuple = newTridentTuple(fields, new Values("my_row", "d", "d", "dd"));
        client.writeTuple(tuple, tupleMapper);
       
       
View Full Code Here
192
193
194
195
196
197
198
199
200
201
202
       
        tuple = newTridentTuple(fields, new Values("my_row", "c", "c", "cc"));
        client.writeTuple(tuple, tupleMapper);
       
        tuple = newTridentTuple(fields, new Values("my_row", "d", "d", "dd"));
        client.writeTuple(tuple, tupleMapper);
       
       
        Map<SimpleComposite, String> map = client.lookup(tupleMapper, tuple, new SimpleComposite("a", "a"), new SimpleComposite("a", "c"), Equality.GREATER_THAN_EQUAL);
        dumpMap(map);
       
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.