class Source extends HiveEndpoint {

  @Override
  public PartitionsAndStatistics getPartitions(Table sourceTable, String partitionPredicate, int maxPartitions)
    throws TException {
    PartitionsAndStatistics sourcePartitions = super.getPartitions(sourceTable, partitionPredicate, maxPartitions);
    sourceCatalogListener
        .resolvedSourcePartitions(EventUtils.toEventPartitions(sourceTable, sourcePartitions.getPartitions()));
    return sourcePartitions;
  }

    Source(
      SourceCatalog sourceCatalog,
      HiveConf sourceHiveConf,
      Supplier<CloseableMetaStoreClient> sourceMetaStoreClientSupplier,
      SourceCatalogListener sourceCatalogListener,
      boolean snapshotsDisabled,
      String sourceTableLocation);

}