I actually think a property works better as it will let you configure the partitioner like any other operator component. Like the Kafka consumer.
-- sent from mobile On Nov 19, 2015 4:51 PM, "Siyuan Hua" <[email protected]> wrote: > Thomas, this is what I'm going to do. But I like Pramod's idea to have an > annotation > > On Thu, Nov 19, 2015 at 4:34 PM, Thomas Weise <[email protected]> > wrote: > > > Why not implement the interface on the operator and delegate the call to > > the partitioner implementation? > > > > On Thu, Nov 19, 2015 at 4:09 PM, Pramod Immaneni <[email protected] > > > > wrote: > > > > > Idea for an annotation maybe? > > > > > > On Thu, Nov 19, 2015 at 3:49 PM, Siyuan Hua <[email protected]> > > > wrote: > > > > > > > Sometimes I want to separate the Partitioner logic from operator and > > > still > > > > I want to have default partitioner for the operator (with specifying > it > > > > from application) > > > > > > > > > > > > Best, > > > > Siyuan > > > > > > > > > >
