Class FlowsForTables
Object
org.apache.spark.sql.pipelines.graph.FlowsForTables
- All Implemented Interfaces:
Serializable
,FlowFilter
,GraphFilter<ResolvedFlow>
,scala.Equals
,scala.Product
Used in partial graph updates to select flows that flow to "selectedTables".
- See Also:
-
Constructor Summary
ConstructorsConstructorDescriptionFlowsForTables
(scala.collection.immutable.Set<org.apache.spark.sql.catalyst.TableIdentifier> selectedTables) -
Method Summary
Modifier and TypeMethodDescriptionabstract static R
apply
(T1 v1) scala.collection.immutable.Seq<ResolvedFlow>
filter
(scala.collection.immutable.Seq<ResolvedFlow> flows) Returns the subset of elements provided that match this filter.scala.collection.immutable.Seq<ResolvedFlow>
filterNot
(scala.collection.immutable.Seq<ResolvedFlow> flows) Returns the subset of elements provided that do not match this filter.scala.collection.immutable.Set<org.apache.spark.sql.catalyst.TableIdentifier>
static String
toString()
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface scala.Equals
canEqual, equals
Methods inherited from interface scala.Product
productArity, productElement, productElementName, productElementNames, productIterator, productPrefix
-
Constructor Details
-
FlowsForTables
public FlowsForTables(scala.collection.immutable.Set<org.apache.spark.sql.catalyst.TableIdentifier> selectedTables)
-
-
Method Details
-
apply
public abstract static R apply(T1 v1) -
toString
-
selectedTables
public scala.collection.immutable.Set<org.apache.spark.sql.catalyst.TableIdentifier> selectedTables() -
filter
public scala.collection.immutable.Seq<ResolvedFlow> filter(scala.collection.immutable.Seq<ResolvedFlow> flows) Description copied from interface:GraphFilter
Returns the subset of elements provided that match this filter.- Specified by:
filter
in interfaceGraphFilter<ResolvedFlow>
-
filterNot
public scala.collection.immutable.Seq<ResolvedFlow> filterNot(scala.collection.immutable.Seq<ResolvedFlow> flows) Description copied from interface:GraphFilter
Returns the subset of elements provided that do not match this filter.- Specified by:
filterNot
in interfaceGraphFilter<ResolvedFlow>
-