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

Class SinkImpl

Object
org.apache.spark.sql.pipelines.graph.SinkImpl
All Implemented Interfaces:
Serializable, GraphElement, Output, Sink, scala.Equals, scala.Product
public class SinkImpl extends Object implements Sink, scala.Product, Serializable
See Also:

  • Constructor Summary

    Constructors
    Constructor
    Description
    SinkImpl(org.apache.spark.sql.catalyst.TableIdentifier identifier, String format, scala.collection.immutable.Map<String,String> options, QueryOrigin origin)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    abstract static R
    apply(T1 v1, T2 v2, T3 v3, T4 v4)
     
    String
    format()
    format of the sink
    org.apache.spark.sql.catalyst.TableIdentifier
    identifier()
    Returns the unique identifier for this GraphElement.
    scala.collection.immutable.Map<String,String>
    options()
    options defined for the sink
    QueryOrigin
    origin()
    Contains provenance to tie back this GraphElement to the user code that defined it.
    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 org.apache.spark.sql.pipelines.graph.GraphElement

    displayName, spark

    Methods inherited from interface scala.Product

    productArity, productElement, productElementName, productElementNames, productIterator, productPrefix

  • Constructor Details

    • SinkImpl

      public SinkImpl(org.apache.spark.sql.catalyst.TableIdentifier identifier, String format, scala.collection.immutable.Map<String,String> options, QueryOrigin origin)

  • Method Details

    • apply

      public abstract static R apply(T1 v1, T2 v2, T3 v3, T4 v4)

    • toString

      public static String toString()

    • identifier

      public org.apache.spark.sql.catalyst.TableIdentifier identifier()
      Description copied from interface: GraphElement
      Returns the unique identifier for this GraphElement.
      Specified by:
      identifier in interface GraphElement

    • format

      public String format()
      Description copied from interface: Sink
      format of the sink
      Specified by:
      format in interface Sink

    • options

      public scala.collection.immutable.Map<String,String> options()
      Description copied from interface: Sink
      options defined for the sink
      Specified by:
      options in interface Sink

    • origin

      public QueryOrigin origin()
      Description copied from interface: GraphElement
      Contains provenance to tie back this GraphElement to the user code that defined it.

      This must be set when a GraphElement is directly created by some user code. Subsequently, this initial origin must be propagated as is without modification. If this GraphElement is copied or converted to a different type, then this origin must be copied as is.

      Specified by:
      origin in interface GraphElement
      Returns:
      (undocumented)