@Override
  public long extract(final Object key, final GenericRow value) {
    final String colValue = (String) extractor.extract(key, value);

    try {
      return timestampParser.parse(colValue);
    } catch (final KsqlException e) {
      throw new KsqlException("Unable to parse string timestamp."
          + " timestamp=" + value
          + " timestamp_format=" + format,
          e);
    }
  }
@SuppressFBWarnings("RV_RETURN_VALUE_IGNORED_NO_SIDE_EFFECT")
  @Test
  public void shouldPassRecordToColumnExtractor() {
    // When:
    extractor.extract(key, value);

    // Then:
    verify(columnExtractor).extract(key, value);
  }