Package org.apache.spark.sql.pipelines.util

Class StreamingReadOptions

Object
org.apache.spark.sql.pipelines.util.StreamingReadOptions
All Implemented Interfaces:
Serializable, InputReadOptions, scala.Equals, scala.Product
public final class StreamingReadOptions extends Object implements InputReadOptions, scala.Product, Serializable
Options for a streaming read of an input.

param: userOptions Holds the user defined read options. param: droppedUserOptions Holds the options that were specified by the user but not actually used. This is a bug but we are preserving this behavior for now to avoid making a backwards incompatible change.

See Also:

  • Constructor Summary

    Constructors
    Constructor
    Description
    StreamingReadOptions(org.apache.spark.sql.catalyst.util.CaseInsensitiveMap<String> userOptions, org.apache.spark.sql.catalyst.util.CaseInsensitiveMap<String> droppedUserOptions)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.spark.sql.catalyst.util.CaseInsensitiveMap<String>
    droppedUserOptions()
     
    static org.apache.spark.sql.catalyst.util.CaseInsensitiveMap<String>
    EmptyUserOptions()
     
    org.apache.spark.sql.catalyst.util.CaseInsensitiveMap<String>
    userOptions()
     

    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

    • StreamingReadOptions

      public StreamingReadOptions(org.apache.spark.sql.catalyst.util.CaseInsensitiveMap<String> userOptions, org.apache.spark.sql.catalyst.util.CaseInsensitiveMap<String> droppedUserOptions)

  • Method Details

    • EmptyUserOptions

      public static org.apache.spark.sql.catalyst.util.CaseInsensitiveMap<String> EmptyUserOptions()

    • userOptions

      public org.apache.spark.sql.catalyst.util.CaseInsensitiveMap<String> userOptions()

    • droppedUserOptions

      public org.apache.spark.sql.catalyst.util.CaseInsensitiveMap<String> droppedUserOptions()