@Override
  public void clearCheckpoints() {
    LOG.debug("Clearing all checkpoints in Azure table");

    for (TaskName taskName : taskNames) {
      String partitionQueryKey = taskName.toString();

      // Generate table query
      String partitionFilter = TableQuery.generateFilterCondition(
              PARTITION_KEY,
              TableQuery.QueryComparisons.EQUAL,
              partitionQueryKey);
      TableQuery<TaskCheckpointEntity> partitionQuery = TableQuery.from(TaskCheckpointEntity.class)
              .where(partitionFilter);

      // All entities in a given batch must have the same partition key
      deleteEntities(cloudTable.execute(partitionQuery).iterator());
    }
  }
Azure checkpoint manager is used to store checkpoints in a Azure Table.
All the task checkpoints are added to the a single table named "SamzaTaskCheckpoints".
The table entities take the following form:

+-----------------+---------------------+-------------------+
|                 |     Serialized      |                   |
|   TaskName      |     JSON SSP        |     Offset        |
|                 |                     |                   |
+-----------------+---------------------+-------------------+

 Each entity have a partitionKey set as the TaskName and the rowKey set as the SSP.
samza-azure/src/main/java/org/apache/samza/checkpoint/azure/AzureCheckpointManager.java