Package org.apache.spark.sql.pipelines.graph

Class GraphElementTypeUtils

Object

org.apache.spark.sql.pipelines.graph.GraphElementTypeUtils

public class GraphElementTypeUtils
extends Object

Constructor Summary

Constructors

Constructor	Description
GraphElementTypeUtils()

Method Summary

Modifier and Type	Method	Description
static DatasetType	getDatasetTypeForMaterializedViewOrStreamingTable(scala.collection.immutable.Seq<ResolvedFlow> flowsToTable)	Helper function to obtain the DatasetType.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

GraphElementTypeUtils

public GraphElementTypeUtils()

Method Details

getDatasetTypeForMaterializedViewOrStreamingTable

public static DatasetType getDatasetTypeForMaterializedViewOrStreamingTable(scala.collection.immutable.Seq<ResolvedFlow> flowsToTable)

Helper function to obtain the DatasetType. This function should be called with all the flows that are writing into a table and all the flows should be resolved.

Parameters:

flowsToTable - (undocumented)

Returns:

(undocumented)