org.apache.samza.system

Interface SystemStreamPartitionMatcher

public interface SystemStreamPartitionMatcher

Method Summary

Modifier and Type	Method and Description
java.util.Set<SystemStreamPartition>	filter(java.util.Set<SystemStreamPartition> systemStreamPartitions, Config config)

Method Detail

filter

java.util.Set<SystemStreamPartition> filter(java.util.Set<SystemStreamPartition> systemStreamPartitions,
                                            Config config)