package com.cloudera.flume.handlers.hive;
import java.io.IOException;
import com.cloudera.flume.core.EventSink;
import com.cloudera.flume.core.EventSinkDecorator;
EventSinkDecorator<S> {
super(s);
}
public abstract void notify(E e);
@Override
public void close()
throws IOException {
super.close();
notify(getNotificationEvent());
}
}