@Override
  public FailureCollector getFailureCollector() {
    return this.failureCollector;
  }
@Test
  public void getFailureCollector() {
    /** arrange */
    BatchContextImpl context = new BatchSinkContextImpl();

    /** act */
    FailureCollector failureCollector = context.getFailureCollector();

    /** assert */
    ValidationException validationException = failureCollector.getOrThrowException();
    assertEquals(0, validationException.getFailures().size());
  }