Java 类com.amazonaws.services.dynamodbv2.document.Item 实例源码

项目：outland 文件：DefaultGroupStorage.java

@Override public Void create(Group group) {
  Item item = preparePutItem(group);

  PutItemSpec putItemSpec = new PutItemSpec()
      .withItem(item)
      .withConditionExpression("attribute_not_exists(#ns_key)")
      .withNameMap(new NameMap().with("#ns_key", HASH_KEY));

  Table table = dynamoDB.getTable(groupTableName);
  final Supplier<PutItemOutcome> putItemOutcomeSupplier = () -> {
    try {
      return table.putItem(putItemSpec);
    } catch (ConditionalCheckFailedException e) {
      throwConflictAlreadyExists(group);
      return null;
    }
  };
  return putItem(group, putItemOutcomeSupplier);
}

项目：outland 文件：DefaultFeatureStorage.java

@Override public Optional<Feature> loadFeatureByKey(String group, String key) {
  logger.info("{}", kvp("op", "loadFeatureByKey", HASH_KEY, group, RANGE_KEY, key));

  Table table = dynamoDB.getTable(featureTableName);

  DynamoDbCommand<Item> cmd = new DynamoDbCommand<>("loadFeatureByKey",
      () -> getItem(group, key, table),
      () -> {
        throw new RuntimeException("loadFeatureById");
      },
      hystrixReadConfiguration,
      metrics);

  Item item = cmd.execute();
  if (item == null) {
    return Optional.empty();
  }
  return Optional.of(FeatureSupport.toFeature(item.getString("json")));
}

项目：serverless-cf-analysis 文件：CreateAthenaPartitionsBasedOnS3EventWithDDB.java

private boolean tryAddMissingPartition(String dyanmoDBTaableName,DynamoDB dynamoDBClient, Partition partition){

        Table ddbTable= dynamoDBClient.getTable(dyanmoDBTaableName);

        Item item=new Item()
                .withPrimaryKey("PartitionSpec",partition.spec())
                .withString("PartitionPath",partition.path())
                .withString("PartitionName", partition.name());

        PutItemSpec itemSpec=new PutItemSpec()
                .withItem(item)
                .withConditionExpression("attribute_not_exists(#ps)")
                .withNameMap(new NameMap()
                        .with("#ps","PartitionSpec"));

        try{
            ddbTable.putItem(itemSpec);
            System.out.println("Item was added to the table.PartitionSpec="+partition.spec()+"; Path="+partition.path());
            return true;
        }
        catch(ConditionalCheckFailedException e){
            System.out.println(e.toString());
            System.out.println("Item already exists. PartitionSpec="+partition.spec()+"; Path="+partition.path());
            return false;
        }
    }

项目：webcrawler 文件：CrawlerBatchService.java

@Override
public Map<String, AttributeValue> getNodes(WebsiteModel websiteModel) {

    try
    {
        ObjectMapper mapper = new ObjectMapper();
        String string = mapper.writeValueAsString(websiteModel);
        Item item = new Item().withJSON(Utils.params.nodes, string);
        return InternalUtils.toAttributeValues(item);
    }
    catch (JsonProcessingException e)
    {
        LOG.error(e.getMessage());
    }

    return new HashMap<>();
}

项目：orbit-dynamodb 文件：DynamoDBStorageExtension.java

protected void readStateInternal(final Object state, final Class<?> stateClass, final Item item, final ObjectMapper mapper)
{
    try
    {
        if (!state.getClass().equals(stateClass))
        {
            throw new IllegalArgumentException(String.format("State class (%s) did not match expected class (%s), Storage Extension should override generatePutItem method",
                    state.getClass().getName(),
                    stateClass.getName()));
        }

        mapper.readerForUpdating(state).readValue(item.getJSON(DynamoDBUtils.FIELD_NAME_DATA));
    }
    catch (IOException e)
    {
        throw new UncheckedException(e);
    }
}

项目：orbit-dynamodb 文件：DynamoDBPersistenceTest.java

@Override
public StorageTestState readState(final String identity)
{
    final Table table = dynamoDBConnection.getDynamoDB().getTable(getTableName());
    final Item item = table.getItem("_id", generateItemId(identity));

    if (item != null)
    {
        try
        {
            final StorageTestState testState = new HelloState();
            dynamoDBConnection.getMapper().readerForUpdating(testState).readValue(item.getJSON("_state"));
            return testState;
        }
        catch (Exception e)
        {
            throw new UncheckedException(e);
        }
    }
    return null;
}

项目：drill-dynamo-adapter 文件：DynamoRecordReader.java

@Override
public int next() {
  Stopwatch watch = Stopwatch.createStarted();
  topLevelState.reset();

  int count = 0;
  Page<Item, ?> page;
  while (resultIter.hasNext()) {
    page = resultIter.next();
    for (Item item : page) {
      int rowCount = count++;
      for (Map.Entry<String, Object> attribute : item.attributes()) {
        String name = attribute.getKey();
        Object value = attribute.getValue();
        SchemaPath column = getSchemaPath(name);
        topLevelState.setColumn(column);
        handleTopField(rowCount, name, value, topLevelState);
      }
    }
  }

  topLevelState.setRowCount(count);
  LOG.debug("Took {} ms to get {} records", watch.elapsed(TimeUnit.MILLISECONDS), count);
  return count;
}

项目：drill-dynamo-adapter 文件：BaseDynamoTest.java

protected void verify(List<Map<String, Object>> rows, Item... items) {
  assertEquals("Wrong number of expected rows!" +
               "\nExpected: " + toString(items) +
               "\nGot rows: " + rows,
    items.length, rows.size());
  for (int i = 0; i < items.length; i++) {
    Map<String, Object> row = rows.get(i);
    Item item = items[i];
    assertEquals("Wrong number of fields in row! Got row: " + row + "\nExpected: " + item,
      row.size(), item.asMap().size());
    for (Map.Entry<String, Object> field : row.entrySet()) {
      String name = field.getKey();
      Object o = field.getValue();
      if (o instanceof Text) {
        o = o.toString();
      }
      if (item.get(name) instanceof Number) {
        equalsNumber(item, name, row);
      } else if (o instanceof byte[]) {
        assertArrayEquals("Array mismatch for: " + name, (byte[]) item.get(name), (byte[]) o);
      } else {
        assertEquals("Mismatch for: " + name, item.get(name), o);
      }
    }
  }
}