public Iterable<ProcessorEntity> getEntitiesWithPartition(String partitionKey) {
    String partitionFilter = TableQuery.generateFilterCondition(PARTITION_KEY, TableQuery.QueryComparisons.EQUAL, partitionKey);
    TableQuery<ProcessorEntity> partitionQuery = TableQuery.from(ProcessorEntity.class).where(partitionFilter);
    return table.execute(partitionQuery);
  }
Retrieve all rows in a table with the given partition key.
@param partitionKey Job model version of the processors to be retrieved.
@return Iterable list of processor entities.
samza-azure/src/main/java/org/apache/samza/util/TableUtils.java