public abstract void internalPrepare(OutputCollector collector,IMetadataChangeNotifyService metadataManager,Config config,TopologyContext context);

public abstract void internalPrepare ( OutputCollector collector , IMetadataChangeNotifyService metadataManager , Config config , TopologyContext context ) ;
subclass should implement more initialization for example . 1 ) register metadata change 2 ) init stream context
