Java 类com.amazonaws.services.dynamodbv2.model.TableDescription 实例源码

项目：dynamodb-client-web-gui 文件：TableController.java

@RequestMapping("/describe/{table}")
public
@ResponseBody
TableDescription definition(@PathVariable String table) {
    TableDescription description = null;

    try {
        if (!names.isEmpty()) {
            description = amazonDynamoDBClient.describeTable(table).getTable();
        }
    } catch (AmazonClientException ex) {
        LOGGER.error(ex.getMessage());
    }

    return description;
}

项目：strongbox 文件：GenericDynamoDBTest.java

@Test
public void testCreateTableWithWait() throws Exception {
    // Create fake responses from AWS. First response is still creating the table, second response the table
    // has become active.
    TableDescription creatingDescription = constructTableDescription(TableStatus.CREATING);
    TableDescription createdDescription = constructTableDescription(TableStatus.ACTIVE);
    CreateTableResult mockCreateResult = new CreateTableResult().withTableDescription(creatingDescription);
    DescribeTableResult mockDescribeResultCreating = new DescribeTableResult().withTable(creatingDescription);
    DescribeTableResult mockDescribeResultCreated = new DescribeTableResult().withTable(createdDescription);

    // Create the table.
    CreateTableRequest expectedRequest = dynamoDB.constructCreateTableRequest();
    when(mockDynamoDBClient.createTable(expectedRequest)).thenReturn(mockCreateResult);
    when(mockDynamoDBClient.describeTable(tableName)).thenReturn(mockDescribeResultCreating, mockDescribeResultCreated);
    assertEquals(dynamoDB.create(), TEST_ARN);

    verify(mockDynamoDBClient, times(1)).createTable(expectedRequest);
    verify(mockDynamoDBClient, times(2)).describeTable(tableName);
}

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

private static Task<TableDescription> waitForActiveTableStatus(final DynamoDBConnection dynamoDBConnection, final String tableName)
{
    try
    {
        for (int i = 0; i < WAITING_FOR_ACTIVE_TABLE_STATUS_MAX_ATTEMPTS; i++)
        {
            final DescribeTableResult describe = dynamoDBConnection.getDynamoClient().describeTable(tableName);
            if (describe.getTable().getTableStatus().equals(TableStatus.ACTIVE.name()))
            {
                return Task.fromValue(describe.getTable());
            }

            Thread.sleep(WAITING_FOR_ACTIVE_TABLE_STATUS_RETRY_DELAY_MILLIS);
        }

    }
    catch (InterruptedException e)
    {
        throw new UncheckedException(e);
    }

    throw new UncheckedException("Hit max retry attempts while waiting for table to become active: " + tableName);
}

项目：emr-dynamodb-connector 文件：DynamoDBImport.java

private void setTableProperties(JobConf jobConf, String tableName, Double writeRatio) {
  jobConf.set(DynamoDBConstants.OUTPUT_TABLE_NAME, tableName);
  jobConf.set(DynamoDBConstants.INPUT_TABLE_NAME, tableName);
  jobConf.set(DynamoDBConstants.TABLE_NAME, tableName);

  DynamoDBClient client = new DynamoDBClient(jobConf);
  TableDescription description = client.describeTable(tableName);

  Long readThroughput = description.getProvisionedThroughput().getReadCapacityUnits();
  Long writeThroughput = description.getProvisionedThroughput().getWriteCapacityUnits();

  jobConf.set(DynamoDBConstants.READ_THROUGHPUT, readThroughput.toString());
  jobConf.set(DynamoDBConstants.WRITE_THROUGHPUT, writeThroughput.toString());

  log.info("Read throughput:       " + readThroughput);
  log.info("Write throughput:      " + writeThroughput);

  // Optional properties
  if (writeRatio != null) {
    jobConf.set(DynamoDBConstants.THROUGHPUT_WRITE_PERCENT, writeRatio.toString());
    log.info("Throughput write ratio: " + writeRatio);
  }
}

项目：emr-dynamodb-connector 文件：DynamoDBStorageHandler.java

@Override
public void preCreateTable(Table table) throws MetaException {
  DynamoDBClient client = createDynamoDBClient(table);
  try {

    boolean isExternal = MetaStoreUtils.isExternalTable(table);

    if (!isExternal) {
      throw new MetaException("Only EXTERNAL tables are supported for DynamoDB.");
    }

    String tableName = HiveDynamoDBUtil.getDynamoDBTableName(table.getParameters()
        .get(DynamoDBConstants.TABLE_NAME), table.getTableName());
    TableDescription tableDescription = client.describeTable(tableName);

    checkTableStatus(tableDescription);
    checkTableSchemaMapping(tableDescription, table);
    checkTableSchemaType(tableDescription, table);
  } finally {
    client.close();
  }
}

项目：emr-dynamodb-connector 文件：DynamoDBStorageHandler.java

void checkTableSchemaMapping(TableDescription tableDescription, Table table) throws
    MetaException {
  String mapping = table.getParameters().get(DynamoDBConstants.DYNAMODB_COLUMN_MAPPING);
  Map<String, String> columnMapping = HiveDynamoDBUtil.getHiveToDynamoDBSchemaMapping(mapping);

  List<FieldSchema> tableSchema = table.getSd().getCols();
  for (FieldSchema fieldSchema : tableSchema) {
    if (HiveDynamoDBTypeFactory.isHiveDynamoDBItemMapType(fieldSchema.getType())) {
      // We don't need column mapping as this column contains full
      // DynamoDB row
      continue;
    }

    String fieldSchemaName = fieldSchema.getName().toLowerCase();
    if (columnMapping.containsKey(fieldSchemaName)) {
      if (columnMapping.get(fieldSchemaName).isEmpty()) {
        throw new MetaException("Invalid column mapping for column: " + fieldSchemaName);
      }
    } else {
      throw new MetaException("Could not find column mapping for column: " + fieldSchemaName);
    }
  }
}

项目：emr-dynamodb-connector 文件：DynamoDBStorageHandler.java

void checkTableSchemaType(TableDescription tableDescription, Table table) throws MetaException {
  List<FieldSchema> tableSchema = table.getSd().getCols();

  for (FieldSchema fieldSchema : tableSchema) {
    for (AttributeDefinition definition : tableDescription.getAttributeDefinitions()) {
      validateKeySchema(definition.getAttributeName(), definition.getAttributeType(),
          fieldSchema);
    }

    // Check for each field type
    if (HiveDynamoDBTypeFactory.getTypeObjectFromHiveType(fieldSchema.getType()) == null) {
      throw new MetaException("The hive type " + fieldSchema.getType() + " is not supported in "
          + "DynamoDB");
    }
  }
}