本文整理汇总了Java中com.google.datastore.v1.Key类的典型用法代码示例。如果您正苦于以下问题:Java Key类的具体用法?Java Key怎么用?Java Key使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
Key类属于com.google.datastore.v1包,在下文中一共展示了Key类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: processElement
import com.google.datastore.v1.Key; //导入依赖的package包/类
@ProcessElement
public void processElement(ProcessContext c) {
Entity.Builder entityBuilder = Entity.newBuilder();
Key key = makeKey(makeKey(kind, ancestorKey).build(), kind, c.element().getKey()).build();
entityBuilder.setKey(key);
List<Value> candidates = new ArrayList<>();
Map<String, Value> properties = new HashMap<>();
for (CompletionCandidate tag : c.element().getValue()) {
Entity.Builder tagEntity = Entity.newBuilder();
properties.put("tag", makeValue(tag.value).build());
properties.put("count", makeValue(tag.count).build());
candidates.add(makeValue(tagEntity).build());
}
properties.put("candidates", makeValue(candidates).build());
entityBuilder.putAllProperties(properties);
c.output(entityBuilder.build());
}
开发者ID:apache,项目名称:beam,代码行数:19,代码来源:AutoComplete.java
示例2: processElement
import com.google.datastore.v1.Key; //导入依赖的package包/类
@ProcessElement
public void processElement(ProcessContext c) throws Exception {
String entityJson = c.element();
if (getJSTransform().hasTransform()) {
entityJson = getJSTransform().invoke(entityJson);
}
Entity.Builder builder = Entity.newBuilder();
getJsonParser().merge(entityJson, builder);
Entity entity = builder.build();
// Remove old project id reference from key
Key k = entity.getKey();
builder.setKey(Key.newBuilder()
.addAllPath(k.getPathList())
.setPartitionId(PartitionId.newBuilder()
.setNamespaceId(k.getPartitionId().getNamespaceId()))
.build());
c.output(builder.build());
}
开发者ID:cobookman,项目名称:teleport,代码行数:22,代码来源:GcsToDatastore.java
示例3: processElement
import com.google.datastore.v1.Key; //导入依赖的package包/类
@Override
public void processElement(ProcessContext c) {
String[] columns = c.element().split(",");
Builder builder = Key.newBuilder();
PathElement pathElement = builder.addPathBuilder().setKind("Product").setName(columns[0]).build();
Key key = builder.setPath(0, pathElement).build();
Entity.Builder entityBuilder = Entity.newBuilder();
entityBuilder.setKey(key);
entityBuilder.getMutableProperties().put("ProductCode", makeValue(columns[0]).build());
entityBuilder.getMutableProperties().put("CategoryCode", makeValue(columns[1]).build());
entityBuilder.getMutableProperties().put("ProductName", makeValue(columns[2]).build());
entityBuilder.getMutableProperties().put("Price", makeValue(Integer.valueOf(columns[3])).build());
String imageURL = "";
if (columns.length > 4) {
imageURL = columns[4];
}
entityBuilder.getMutableProperties().put("ImageURL", makeValue(imageURL).build());
Entity entity = entityBuilder.build();
c.output(entity);
}
开发者ID:topgate,项目名称:retail-demo,代码行数:24,代码来源:StorageToDatastore.java
示例4: makeEntity
import com.google.datastore.v1.Key; //导入依赖的package包/类
/**
* Build an entity for the given ancestorKey, kind, namespace and value.
* @param largePropertySize if greater than 0, add an unindexed property of the given size.
*/
static Entity makeEntity(Long value, Key ancestorKey, String kind, @Nullable String namespace,
int largePropertySize) {
Entity.Builder entityBuilder = Entity.newBuilder();
Key.Builder keyBuilder = makeKey(ancestorKey, kind, UUID.randomUUID().toString());
// NOTE: Namespace is not inherited between keys created with DatastoreHelper.makeKey, so
// we must set the namespace on keyBuilder. TODO: Once partitionId inheritance is added,
// we can simplify this code.
if (namespace != null) {
keyBuilder.getPartitionIdBuilder().setNamespaceId(namespace);
}
entityBuilder.setKey(keyBuilder.build());
entityBuilder.putProperties("value", makeValue(value).build());
if (largePropertySize > 0) {
entityBuilder.putProperties("unindexed_value", makeValue(new String(
new char[largePropertySize]).replace("\0", "A")).setExcludeFromIndexes(true).build());
}
return entityBuilder.build();
}
开发者ID:apache,项目名称:beam,代码行数:24,代码来源:V1TestUtil.java
示例5: compare
import com.google.datastore.v1.Key; //导入依赖的package包/类
@Override
public int compare(Key thisKey, Key otherKey) {
if (!thisKey.getPartitionId().equals(otherKey.getPartitionId())) {
throw new IllegalArgumentException("Cannot compare keys with different partition ids.");
}
Iterator<PathElement> thisPath = thisKey.getPathList().iterator();
Iterator<PathElement> otherPath = otherKey.getPathList().iterator();
while (thisPath.hasNext()) {
if (!otherPath.hasNext()) {
return 1;
}
int result = comparePathElement(thisPath.next(), otherPath.next());
if (result != 0) {
return result;
}
}
return otherPath.hasNext() ? -1 : 0;
}
开发者ID:GoogleCloudPlatform,项目名称:google-cloud-datastore,代码行数:21,代码来源:DatastoreHelper.java
示例6: getSplits
import com.google.datastore.v1.Key; //导入依赖的package包/类
@Override
public List<Query> getSplits(
Query query, PartitionId partition, int numSplits, Datastore datastore)
throws DatastoreException, IllegalArgumentException {
List<Query> splits = new ArrayList<Query>(numSplits);
if (numSplits == 1) {
splits.add(query);
return splits;
}
validateQuery(query);
validateSplitSize(numSplits);
List<Key> scatterKeys = getScatterKeys(numSplits, query, partition, datastore);
Key lastKey = null;
for (Key nextKey : getSplitKey(scatterKeys, numSplits)) {
splits.add(createSplit(lastKey, nextKey, query));
lastKey = nextKey;
}
splits.add(createSplit(lastKey, null, query));
return splits;
}
开发者ID:GoogleCloudPlatform,项目名称:google-cloud-datastore,代码行数:23,代码来源:QuerySplitterImpl.java
示例7: createSplit
import com.google.datastore.v1.Key; //导入依赖的package包/类
/**
* Create a new {@link Query} given the query and range.
*
* @param lastKey the previous key. If null then assumed to be the beginning.
* @param nextKey the next key. If null then assumed to be the end.
* @param query the desired query.
*/
private Query createSplit(Key lastKey, Key nextKey, Query query) {
if (lastKey == null && nextKey == null) {
return query;
}
List<Filter> keyFilters = new ArrayList<Filter>();
if (query.hasFilter()) {
keyFilters.add(query.getFilter());
}
if (lastKey != null) {
Filter lowerBound = DatastoreHelper.makeFilter(DatastoreHelper.KEY_PROPERTY_NAME,
PropertyFilter.Operator.GREATER_THAN_OR_EQUAL,
DatastoreHelper.makeValue(lastKey)).build();
keyFilters.add(lowerBound);
}
if (nextKey != null) {
Filter upperBound = DatastoreHelper.makeFilter(DatastoreHelper.KEY_PROPERTY_NAME,
PropertyFilter.Operator.LESS_THAN,
DatastoreHelper.makeValue(nextKey)).build();
keyFilters.add(upperBound);
}
return Query.newBuilder(query).setFilter(makeAndFilter(keyFilters)).build();
}
开发者ID:GoogleCloudPlatform,项目名称:google-cloud-datastore,代码行数:30,代码来源:QuerySplitterImpl.java
示例8: getScatterKeys
import com.google.datastore.v1.Key; //导入依赖的package包/类
/**
* Gets a list of split keys given a desired number of splits.
*
* <p>This list will contain multiple split keys for each split. Only a single split key
* will be chosen as the split point, however providing multiple keys allows for more uniform
* sharding.
*
* @param numSplits the number of desired splits.
* @param query the user query.
* @param partition the partition to run the query in.
* @param datastore the datastore containing the data.
* @throws DatastoreException if there was an error when executing the datastore query.
*/
private List<Key> getScatterKeys(
int numSplits, Query query, PartitionId partition, Datastore datastore)
throws DatastoreException {
Query.Builder scatterPointQuery = createScatterQuery(query, numSplits);
List<Key> keySplits = new ArrayList<Key>();
QueryResultBatch batch;
do {
RunQueryRequest scatterRequest =
RunQueryRequest.newBuilder()
.setPartitionId(partition)
.setQuery(scatterPointQuery)
.build();
batch = datastore.runQuery(scatterRequest).getBatch();
for (EntityResult result : batch.getEntityResultsList()) {
keySplits.add(result.getEntity().getKey());
}
scatterPointQuery.setStartCursor(batch.getEndCursor());
scatterPointQuery.getLimitBuilder().setValue(
scatterPointQuery.getLimit().getValue() - batch.getEntityResultsCount());
} while (batch.getMoreResults() == MoreResultsType.NOT_FINISHED);
Collections.sort(keySplits, DatastoreHelper.getKeyComparator());
return keySplits;
}
开发者ID:GoogleCloudPlatform,项目名称:google-cloud-datastore,代码行数:39,代码来源:QuerySplitterImpl.java
示例9: testMakeKey_PartitionId
import com.google.datastore.v1.Key; //导入依赖的package包/类
@Test
public void testMakeKey_PartitionId() {
PartitionId partitionId = PartitionId.newBuilder()
.setNamespaceId("namespace-id")
.build();
Key parent = PARENT.toBuilder()
.setPartitionId(partitionId)
.build();
assertEquals(
Key.newBuilder()
.setPartitionId(partitionId)
.addPath(PARENT.getPath(0))
.addPath(Key.PathElement.newBuilder().setKind("Child"))
.build(),
makeKey(parent, "Child").build());
}
开发者ID:GoogleCloudPlatform,项目名称:google-cloud-datastore,代码行数:17,代码来源:DatastoreHelperTest.java
示例10: keyToString
import com.google.datastore.v1.Key; //导入依赖的package包/类
@Nullable
private String keyToString(Key k) {
StringBuilder sb = new StringBuilder();
List<String> paths = new ArrayList<>();
for (PathElement p : k.getPathList()) {
if (!Strings.isNullOrEmpty(p.getName())) {
paths.add(String.format("%s, \'%s\'", p.getKind(), p.getName().replace("'", "\'")));
} else {
paths.add(String.format("%s, %s", p.getKind(), Long.toString(p.getId())));
}
}
return "key(" + String.join(", ", paths) + ")";
}
开发者ID:cobookman,项目名称:teleport,代码行数:16,代码来源:EntityBQTransform.java
示例11: makeEntity
import com.google.datastore.v1.Key; //导入依赖的package包/类
public Entity makeEntity(KV<Integer, Iterable<TableRow>> content) {
Key key = Key.newBuilder()
.addPath(PathElement.newBuilder().setKind(this.kind).setId(content.getKey())).build();
String keyword = "";
List<Value> list = new ArrayList<>();
for (TableRow row : content.getValue()) {
String utterance = row.get("utterance").toString();
if (utterance == null || utterance.length() < 1) {
continue;
}
String word = row.get("keyword").toString();
if (keyword.equals(row.get("keyword")) == false) {
keyword = word;
}
if (list.size() > 1000) {
LOG.info("Truncated the text." + "keyword_id = " + content.getKey() + ", keyword = " + word);
break;
}
list.add(Value.newBuilder().setStringValue(utterance).build());
}
Entity.Builder entityBuilder = Entity.newBuilder();
entityBuilder.setKey(key);
Map<String, Value> propertyMap = new HashMap<String, Value>();
propertyMap.put("KeywordID", Value.newBuilder().setIntegerValue(content.getKey()).build());
propertyMap.put("Keyword", Value.newBuilder().setStringValue(keyword).build());
ArrayValue array = ArrayValue.newBuilder().addAllValues(list).build();
propertyMap.put("Candidates", Value.newBuilder().setArrayValue(array).build());
entityBuilder.putAllProperties(propertyMap);
return entityBuilder.build();
}
开发者ID:sinmetal,项目名称:iron-hippo,代码行数:37,代码来源:BigQueryToDatastore.java
示例12: isValidKey
import com.google.datastore.v1.Key; //导入依赖的package包/类
/**
* Returns true if a Cloud Datastore key is complete. A key is complete if its last element
* has either an id or a name.
*/
static boolean isValidKey(Key key) {
List<PathElement> elementList = key.getPathList();
if (elementList.isEmpty()) {
return false;
}
PathElement lastElement = elementList.get(elementList.size() - 1);
return (lastElement.getId() != 0 || !lastElement.getName().isEmpty());
}
开发者ID:apache,项目名称:beam,代码行数:13,代码来源:DatastoreV1.java
示例13: apply
import com.google.datastore.v1.Key; //导入依赖的package包/类
@Override
public Mutation apply(Key key) {
// Verify that the entity to delete has a complete key.
checkArgument(isValidKey(key),
"Keys to be deleted from the Cloud Datastore must be complete:\n%s", key);
return makeDelete(key).build();
}
开发者ID:apache,项目名称:beam,代码行数:9,代码来源:DatastoreV1.java
示例14: writeEntitiesToDatastore
import com.google.datastore.v1.Key; //导入依赖的package包/类
private static void writeEntitiesToDatastore(V1TestOptions options, String project,
String ancestor, long numEntities) throws Exception {
Datastore datastore = getDatastore(options, project);
// Write test entities to datastore
V1TestWriter writer = new V1TestWriter(datastore, new UpsertMutationBuilder());
Key ancestorKey = makeAncestorKey(options.getNamespace(), options.getKind(), ancestor);
for (long i = 0; i < numEntities; i++) {
Entity entity = makeEntity(i, ancestorKey, options.getKind(), options.getNamespace(), 0);
writer.write(entity);
}
writer.close();
}
开发者ID:apache,项目名称:beam,代码行数:14,代码来源:V1ReadIT.java
示例15: testDeleteKeyPrimitiveDisplayData
import com.google.datastore.v1.Key; //导入依赖的package包/类
@Test
public void testDeleteKeyPrimitiveDisplayData() {
DisplayDataEvaluator evaluator = DisplayDataEvaluator.create();
PTransform<PCollection<Key>, ?> write =
DatastoreIO.v1().deleteKey().withProjectId("myProject");
Set<DisplayData> displayData = evaluator.displayDataForPrimitiveTransforms(write);
assertThat("DatastoreIO write should include the project in its primitive display data",
displayData, hasItem(hasDisplayItem("projectId")));
assertThat("DatastoreIO write should include the deleteKeyFn in its primitive display data",
displayData, hasItem(hasDisplayItem("deleteKeyFn")));
}
开发者ID:apache,项目名称:beam,代码行数:13,代码来源:DatastoreV1Test.java
示例16: testHasNameOrId
import com.google.datastore.v1.Key; //导入依赖的package包/类
/**
* Test the detection of complete and incomplete keys.
*/
@Test
public void testHasNameOrId() {
Key key;
// Complete with name, no ancestor
key = makeKey("bird", "finch").build();
assertTrue(isValidKey(key));
// Complete with id, no ancestor
key = makeKey("bird", 123).build();
assertTrue(isValidKey(key));
// Incomplete, no ancestor
key = makeKey("bird").build();
assertFalse(isValidKey(key));
// Complete with name and ancestor
key = makeKey("bird", "owl").build();
key = makeKey(key, "bird", "horned").build();
assertTrue(isValidKey(key));
// Complete with id and ancestor
key = makeKey("bird", "owl").build();
key = makeKey(key, "bird", 123).build();
assertTrue(isValidKey(key));
// Incomplete with ancestor
key = makeKey("bird", "owl").build();
key = makeKey(key, "bird").build();
assertFalse(isValidKey(key));
key = makeKey().build();
assertFalse(isValidKey(key));
}
开发者ID:apache,项目名称:beam,代码行数:37,代码来源:DatastoreV1Test.java
示例17: testAddEntitiesWithIncompleteKeys
import com.google.datastore.v1.Key; //导入依赖的package包/类
/**
* Test that entities with incomplete keys cannot be updated.
*/
@Test
public void testAddEntitiesWithIncompleteKeys() throws Exception {
Key key = makeKey("bird").build();
Entity entity = Entity.newBuilder().setKey(key).build();
UpsertFn upsertFn = new UpsertFn();
thrown.expect(IllegalArgumentException.class);
thrown.expectMessage("Entities to be written to the Cloud Datastore must have complete keys");
upsertFn.apply(entity);
}
开发者ID:apache,项目名称:beam,代码行数:15,代码来源:DatastoreV1Test.java
示例18: testAddEntities
import com.google.datastore.v1.Key; //导入依赖的package包/类
@Test
/**
* Test that entities with valid keys are transformed to upsert mutations.
*/
public void testAddEntities() throws Exception {
Key key = makeKey("bird", "finch").build();
Entity entity = Entity.newBuilder().setKey(key).build();
UpsertFn upsertFn = new UpsertFn();
Mutation exceptedMutation = makeUpsert(entity).build();
assertEquals(upsertFn.apply(entity), exceptedMutation);
}
开发者ID:apache,项目名称:beam,代码行数:13,代码来源:DatastoreV1Test.java
示例19: testDeleteEntitiesWithIncompleteKeys
import com.google.datastore.v1.Key; //导入依赖的package包/类
/**
* Test that entities with incomplete keys cannot be deleted.
*/
@Test
public void testDeleteEntitiesWithIncompleteKeys() throws Exception {
Key key = makeKey("bird").build();
Entity entity = Entity.newBuilder().setKey(key).build();
DeleteEntityFn deleteEntityFn = new DeleteEntityFn();
thrown.expect(IllegalArgumentException.class);
thrown.expectMessage("Entities to be deleted from the Cloud Datastore must have complete keys");
deleteEntityFn.apply(entity);
}
开发者ID:apache,项目名称:beam,代码行数:15,代码来源:DatastoreV1Test.java
示例20: testDeleteEntities
import com.google.datastore.v1.Key; //导入依赖的package包/类
/**
* Test that entities with valid keys are transformed to delete mutations.
*/
@Test
public void testDeleteEntities() throws Exception {
Key key = makeKey("bird", "finch").build();
Entity entity = Entity.newBuilder().setKey(key).build();
DeleteEntityFn deleteEntityFn = new DeleteEntityFn();
Mutation exceptedMutation = makeDelete(entity.getKey()).build();
assertEquals(deleteEntityFn.apply(entity), exceptedMutation);
}
开发者ID:apache,项目名称:beam,代码行数:13,代码来源:DatastoreV1Test.java
注:本文中的com.google.datastore.v1.Key类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论