public class SparkStreamingContainerFilter extends java.lang.Object implements ContainerFilter
ContainerFilter which filters out the containers that have a spark
streaming module running.
This is necessary as multiple spark contexts can not be created on the same JVM. See SPARK-2243.| Constructor and Description |
|---|
SparkStreamingContainerFilter() |
| Modifier and Type | Method and Description |
|---|---|
java.util.List<Container> |
filterContainers(ModuleDescriptor moduleDescriptor,
java.lang.Iterable<Container> availableContainers)
Return the list of containers that can deploy this module.
|
public java.util.List<Container> filterContainers(ModuleDescriptor moduleDescriptor, java.lang.Iterable<Container> availableContainers)
filterContainers in interface ContainerFiltermoduleDescriptor - the module descriptoravailableContainers - the matched containers