@Override
  public void init(Context context) {
    table.init(context);
    TableMetricsUtil metricsUtil = new TableMetricsUtil(context, this, tableId);
    if (readRetryPolicy != null) {
      readRetryMetrics = new RetryMetrics("reader", metricsUtil);
    }
    if (writeRetryPolicy != null) {
      writeRetryMetrics = new RetryMetrics("writer", metricsUtil);
    }
  }
A composable asynchronous retriable table implementation that supports features
defined in {@link TableRetryPolicy}.

@param <K> the type of the key in this table
@param <V> the type of the value in this table
@param <U> the type of the update applied to records in this table
samza-core/src/main/java/org/apache/samza/table/retry/AsyncRetriableTable.java