Package me.prettyprint.hector.api.beans

Examples of me.prettyprint.hector.api.beans.DynamicComposite.addComponent()

231
232
233
234
235
236
237
238
239
240
241
    }

    private DynamicComposite entryKey(K itemKey) {
        DynamicComposite entryKey = new DynamicComposite();
        entryKey.addComponent(itemKey, keySerializer);
        entryKey.addComponent(indexName, STRING_SERIALIZER);
        return entryKey;
    }

    private List<HColumn<Long, DynamicComposite>> getEntries(DynamicComposite entryKey) {
        final SliceQuery<DynamicComposite, Long, DynamicComposite> entryQuery = HFactory.createSliceQuery(keyspace, DYNAMIC_COMPOSITE_SERIALIZER, LONG_SERIALIZER, DYNAMIC_COMPOSITE_SERIALIZER);
View Full Code Here
59
60
61
62
63
64
65
66
67
    }

    @Override
    public ColumnValueDefinition<?> toColumnDefinition() {
        final DynamicComposite dynamicComposite = new DynamicComposite();
        dynamicComposite.addComponent(value, CassidyUtils.inferSerializer(value));
        return new ColumnValueDefinition<>(dynamicComposite, DynamicCompositeSerializer.get());
    }
}
View Full Code Here
166
167
168
169
170
171
172
173
174
175
176
                value = NULL_VALUE;
                serializer = (Serializer<Object>)NULL_VALUE_SERIALIZER;
            }
            final String comparator = serializer.getComparatorType().getTypeName();
            start.addComponent(value, serializer, comparator, AbstractComposite.ComponentEquality.EQUAL);
            end.addComponent(value, serializer, comparator, i == values.length - 1 ? AbstractComposite.ComponentEquality.GREATER_THAN_EQUAL : AbstractComposite.ComponentEquality.EQUAL);
        }
        LOGGER.debug("Searching for '{}' index columns with names between {} and {}...", indexName, start, end);
        final SliceQuery<String, DynamicComposite, K> query = HFactory.createSliceQuery(keyspace, StringSerializer.get(), DynamicCompositeSerializer.get(), keySerializer);
        query.setKey(indexName);
        query.setColumnFamily(indexColumnFamily);
View Full Code Here
221
222
223
224
225
226
227
228
229
230
231
    private void insertIndexColumn(K itemKey, long timestamp, List<IndexValue<?>> indexValues, Mutator<String> indexMutator) {
        LOGGER.debug("Indexing key {} with values {}...", itemKey, indexValues);
        DynamicComposite indexColumnName = new DynamicComposite();
        IndexValue.addAll(indexValues, indexColumnName);
        indexColumnName.addComponent(itemKey, keySerializer);
        indexColumnName.addComponent(timestamp, LONG_SERIALIZER);
        LOGGER.debug("Creating '{}' index column with name {} and value {}...", indexName, indexColumnName, itemKey);
        final HColumn<DynamicComposite, K> indexColumn = HFactory.createColumn(indexColumnName, itemKey, DYNAMIC_COMPOSITE_SERIALIZER, keySerializer);
        indexMutator.addInsertion(indexName, indexColumnFamily, indexColumn);
    }
View Full Code Here
222
223
224
225
226
227
228
229
230
231
232
    private void insertIndexColumn(K itemKey, long timestamp, List<IndexValue<?>> indexValues, Mutator<String> indexMutator) {
        LOGGER.debug("Indexing key {} with values {}...", itemKey, indexValues);
        DynamicComposite indexColumnName = new DynamicComposite();
        IndexValue.addAll(indexValues, indexColumnName);
        indexColumnName.addComponent(itemKey, keySerializer);
        indexColumnName.addComponent(timestamp, LONG_SERIALIZER);
        LOGGER.debug("Creating '{}' index column with name {} and value {}...", indexName, indexColumnName, itemKey);
        final HColumn<DynamicComposite, K> indexColumn = HFactory.createColumn(indexColumnName, itemKey, DYNAMIC_COMPOSITE_SERIALIZER, keySerializer);
        indexMutator.addInsertion(indexName, indexColumnFamily, indexColumn);
    }
View Full Code Here
236
237
238
239
240
241
242
243
244
245
246
        for (HColumn<Long, DynamicComposite> entry : entries) {
            final Long entryTimestamp = entry.getName();

            DynamicComposite indexColumnName = new DynamicComposite();
            appendComponents(entry.getValue(), indexColumnName);
            indexColumnName.addComponent(key, keySerializer);
            indexColumnName.addComponent(entryTimestamp, LONG_SERIALIZER);

            indexMutator.addDeletion(indexName, indexColumnFamily, indexColumnName, DYNAMIC_COMPOSITE_SERIALIZER);
            entryMutator.addDeletion(entryKey, entryColumnFamily, entryTimestamp, LONG_SERIALIZER);
        }
View Full Code Here
237
238
239
240
241
242
243
244
245
246
247
            final Long entryTimestamp = entry.getName();

            DynamicComposite indexColumnName = new DynamicComposite();
            appendComponents(entry.getValue(), indexColumnName);
            indexColumnName.addComponent(key, keySerializer);
            indexColumnName.addComponent(entryTimestamp, LONG_SERIALIZER);

            indexMutator.addDeletion(indexName, indexColumnFamily, indexColumnName, DYNAMIC_COMPOSITE_SERIALIZER);
            entryMutator.addDeletion(entryKey, entryColumnFamily, entryTimestamp, LONG_SERIALIZER);
        }
    }
View Full Code Here
246
247
248
249
250
251
252
253
254
255
256
        }
    }

    private DynamicComposite entryKey(K itemKey) {
        DynamicComposite entryKey = new DynamicComposite();
        entryKey.addComponent(itemKey, keySerializer);
        entryKey.addComponent(indexName, STRING_SERIALIZER);
        return entryKey;
    }

    private List<HColumn<Long, DynamicComposite>> getEntries(DynamicComposite entryKey) {
View Full Code Here
247
248
249
250
251
252
253
254
255
256
257
    }

    private DynamicComposite entryKey(K itemKey) {
        DynamicComposite entryKey = new DynamicComposite();
        entryKey.addComponent(itemKey, keySerializer);
        entryKey.addComponent(indexName, STRING_SERIALIZER);
        return entryKey;
    }

    private List<HColumn<Long, DynamicComposite>> getEntries(DynamicComposite entryKey) {
        final SliceQuery<DynamicComposite, Long, DynamicComposite> entryQuery = HFactory.createSliceQuery(keyspace, DYNAMIC_COMPOSITE_SERIALIZER, LONG_SERIALIZER, DYNAMIC_COMPOSITE_SERIALIZER);
View Full Code Here
117
118
119
120
121
122
123
124
125
126
127
   
   
    DynamicComposite endRange = new DynamicComposite();   
    //endRange.add(0, "225" + Character.MAX_VALUE);
    endRange.add(0, "Austin");
    endRange.addComponent(new Long(5830), LongSerializer.get(), "LongType", AbstractComposite.ComponentEquality.GREATER_THAN_EQUAL);
   
    sliceQuery.setRange(startRange, endRange, false, 10);

    QueryResult<ColumnSlice<DynamicComposite, String>> result = sliceQuery.execute();
    return result;
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.