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 ContainerFilter
moduleDescriptor
- the module descriptoravailableContainers
- the matched containers