public RetryPredicate getRetryPredicate() {
    return retryPredicate;
  }
@return Custom predicate for retriable exception identification or null if not specified.
samza-api/src/main/java/org/apache/samza/table/retry/TableRetryPolicy.java