public class SendToRandomPartitioner extends Object implements Partitioner
Constructor and Description |
---|
SendToRandomPartitioner() |
public ds.funnel.topic.Topic[] partition(StreamEvent event, ds.funnel.topic.Topic[] allTopics)
partition
in interface Partitioner
Copyright © 2015. All rights reserved.