@Test public void onLoadPartitionDone() { listener.onLoadPartitionDone(mock(LoadPartitionDoneEvent.class)); verify(kafkaMessageSender, never()).send(any(KafkaMessage.class)); verify(eventSerDe, never()).marshal(any(ApiaryListenerEvent.class)); }
@Override public void onLoadPartitionDone(LoadPartitionDoneEvent partSetDoneEvent) {}
KafkaMetaStoreEventListener extends MetaStoreEventListener { @Override public void onLoadPartitionDone(LoadPartitionDoneEvent partSetDoneEvent) {} }
KafkaMetaStoreEventListener extends MetaStoreEventListener { @Override public void onLoadPartitionDone(LoadPartitionDoneEvent partSetDoneEvent) {} KafkaMetaStoreEventListener(Configuration config); @VisibleForTesting  KafkaMetaStoreEventListener(
      Configuration config,
      ApiaryListenerEventFactory apiaryListenerEventFactory,
      MetaStoreEventSerDe eventSerDe,
      KafkaMessageSender kafkaMessageSender); }
KafkaMetaStoreEventListener extends MetaStoreEventListener { @Override public void onLoadPartitionDone(LoadPartitionDoneEvent partSetDoneEvent) {} KafkaMetaStoreEventListener(Configuration config); @VisibleForTesting  KafkaMetaStoreEventListener(
      Configuration config,
      ApiaryListenerEventFactory apiaryListenerEventFactory,
      MetaStoreEventSerDe eventSerDe,
      KafkaMessageSender kafkaMessageSender); @Override void onCreateTable(CreateTableEvent tableEvent); @Override void onDropTable(DropTableEvent tableEvent); @Override void onAlterTable(AlterTableEvent tableEvent); @Override void onAddPartition(AddPartitionEvent partitionEvent); @Override void onDropPartition(DropPartitionEvent partitionEvent); @Override void onAlterPartition(AlterPartitionEvent partitionEvent); @Override void onInsert(InsertEvent insertEvent); @Override void onConfigChange(ConfigChangeEvent tableEvent); @Override void onCreateDatabase(CreateDatabaseEvent dbEvent); @Override void onDropDatabase(DropDatabaseEvent dbEvent); @Override void onLoadPartitionDone(LoadPartitionDoneEvent partSetDoneEvent); @Override void onAddIndex(AddIndexEvent indexEvent); @Override void onDropIndex(DropIndexEvent indexEvent); @Override void onAlterIndex(AlterIndexEvent indexEvent); @Override void onCreateFunction(CreateFunctionEvent fnEvent); @Override void onDropFunction(DropFunctionEvent fnEvent); }
KafkaMetaStoreEventListener extends MetaStoreEventListener { @Override public void onLoadPartitionDone(LoadPartitionDoneEvent partSetDoneEvent) {} KafkaMetaStoreEventListener(Configuration config); @VisibleForTesting  KafkaMetaStoreEventListener(
      Configuration config,
      ApiaryListenerEventFactory apiaryListenerEventFactory,
      MetaStoreEventSerDe eventSerDe,
      KafkaMessageSender kafkaMessageSender); @Override void onCreateTable(CreateTableEvent tableEvent); @Override void onDropTable(DropTableEvent tableEvent); @Override void onAlterTable(AlterTableEvent tableEvent); @Override void onAddPartition(AddPartitionEvent partitionEvent); @Override void onDropPartition(DropPartitionEvent partitionEvent); @Override void onAlterPartition(AlterPartitionEvent partitionEvent); @Override void onInsert(InsertEvent insertEvent); @Override void onConfigChange(ConfigChangeEvent tableEvent); @Override void onCreateDatabase(CreateDatabaseEvent dbEvent); @Override void onDropDatabase(DropDatabaseEvent dbEvent); @Override void onLoadPartitionDone(LoadPartitionDoneEvent partSetDoneEvent); @Override void onAddIndex(AddIndexEvent indexEvent); @Override void onDropIndex(DropIndexEvent indexEvent); @Override void onAlterIndex(AlterIndexEvent indexEvent); @Override void onCreateFunction(CreateFunctionEvent fnEvent); @Override void onDropFunction(DropFunctionEvent fnEvent);  }