public interface Partitioner
Modifier and Type | Method and Description |
---|---|
ds.funnel.topic.Topic[] |
partition(StreamEvent event,
ds.funnel.topic.Topic[] allTopics) |
ds.funnel.topic.Topic[] partition(StreamEvent event, ds.funnel.topic.Topic[] allTopics)
Copyright © 2015. All rights reserved.