Package org.apache.spark.sql.streaming

Class StatefulProcessor.implicits

Object
org.apache.spark.sql.streaming.StatefulProcessor.implicits
Enclosing class:
StatefulProcessor<K,I,O>
public class StatefulProcessor.implicits extends Object

  • Constructor Details

    • implicits

      public implicits()

  • Method Details

    • newIntSeqEncoder

      public static Encoder<scala.collection.immutable.Seq<Object>> newIntSeqEncoder()
      Deprecated.
      Use newSequenceEncoder instead. Since 2.2.0.

    • newLongSeqEncoder

      public static Encoder<scala.collection.immutable.Seq<Object>> newLongSeqEncoder()
      Deprecated.
      Use newSequenceEncoder instead. Since 2.2.0.

    • newDoubleSeqEncoder

      public static Encoder<scala.collection.immutable.Seq<Object>> newDoubleSeqEncoder()
      Deprecated.
      Use newSequenceEncoder instead. Since 2.2.0.

    • newFloatSeqEncoder

      public static Encoder<scala.collection.immutable.Seq<Object>> newFloatSeqEncoder()
      Deprecated.
      Use newSequenceEncoder instead. Since 2.2.0.

    • newByteSeqEncoder

      public static Encoder<scala.collection.immutable.Seq<Object>> newByteSeqEncoder()
      Deprecated.
      Use newSequenceEncoder instead. Since 2.2.0.

    • newShortSeqEncoder

      public static Encoder<scala.collection.immutable.Seq<Object>> newShortSeqEncoder()
      Deprecated.
      Use newSequenceEncoder instead. Since 2.2.0.

    • newBooleanSeqEncoder

      public static Encoder<scala.collection.immutable.Seq<Object>> newBooleanSeqEncoder()
      Deprecated.
      Use newSequenceEncoder instead. Since 2.2.0.

    • newStringSeqEncoder

      public static Encoder<scala.collection.immutable.Seq<String>> newStringSeqEncoder()
      Deprecated.
      Use newSequenceEncoder instead. Since 2.2.0.

    • newIntArrayEncoder

      public static Encoder<int[]> newIntArrayEncoder()

    • newLongArrayEncoder

      public static Encoder<long[]> newLongArrayEncoder()

    • newDoubleArrayEncoder

      public static Encoder<double[]> newDoubleArrayEncoder()

    • newFloatArrayEncoder

      public static Encoder<float[]> newFloatArrayEncoder()

    • newByteArrayEncoder

      public static Encoder<byte[]> newByteArrayEncoder()

    • newShortArrayEncoder

      public static Encoder<short[]> newShortArrayEncoder()

    • newBooleanArrayEncoder

      public static Encoder<boolean[]> newBooleanArrayEncoder()

    • newStringArrayEncoder

      public static Encoder<String[]> newStringArrayEncoder()

    • newProductEncoder

      public static <T extends scala.Product> Encoder<T> newProductEncoder(scala.reflect.api.TypeTags.TypeTag<T> evidence$9)

    • newIntEncoder

      public static Encoder<Object> newIntEncoder()

    • newLongEncoder

      public static Encoder<Object> newLongEncoder()

    • newDoubleEncoder

      public static Encoder<Object> newDoubleEncoder()

    • newFloatEncoder

      public static Encoder<Object> newFloatEncoder()

    • newByteEncoder

      public static Encoder<Object> newByteEncoder()

    • newShortEncoder

      public static Encoder<Object> newShortEncoder()

    • newBooleanEncoder

      public static Encoder<Object> newBooleanEncoder()

    • newStringEncoder

      public static Encoder<String> newStringEncoder()

    • newJavaDecimalEncoder

      public static Encoder<BigDecimal> newJavaDecimalEncoder()

    • newScalaDecimalEncoder

      public static Encoder<scala.math.BigDecimal> newScalaDecimalEncoder()

    • newDateEncoder

      public static Encoder<Date> newDateEncoder()

    • newLocalDateEncoder

      public static Encoder<LocalDate> newLocalDateEncoder()

    • newLocalDateTimeEncoder

      public static Encoder<LocalDateTime> newLocalDateTimeEncoder()

    • newTimeStampEncoder

      public static Encoder<Timestamp> newTimeStampEncoder()

    • newInstantEncoder

      public static Encoder<Instant> newInstantEncoder()

    • newDurationEncoder

      public static Encoder<Duration> newDurationEncoder()

    • newPeriodEncoder

      public static Encoder<Period> newPeriodEncoder()

    • newJavaEnumEncoder

      public static <A extends Enum<?>> Encoder<A> newJavaEnumEncoder(scala.reflect.api.TypeTags.TypeTag<A> evidence$3)

    • newBoxedIntEncoder

      public static Encoder<Integer> newBoxedIntEncoder()

    • newBoxedLongEncoder

      public static Encoder<Long> newBoxedLongEncoder()

    • newBoxedDoubleEncoder

      public static Encoder<Double> newBoxedDoubleEncoder()

    • newBoxedFloatEncoder

      public static Encoder<Float> newBoxedFloatEncoder()

    • newBoxedByteEncoder

      public static Encoder<Byte> newBoxedByteEncoder()

    • newBoxedShortEncoder

      public static Encoder<Short> newBoxedShortEncoder()

    • newBoxedBooleanEncoder

      public static Encoder<Boolean> newBoxedBooleanEncoder()

    • newProductSeqEncoder

      public static <A extends scala.Product> Encoder<scala.collection.immutable.Seq<A>> newProductSeqEncoder(scala.reflect.api.TypeTags.TypeTag<A> evidence$4)

    • newSequenceEncoder

      public static <T extends scala.collection.immutable.Seq<Object>> Encoder<T> newSequenceEncoder(scala.reflect.api.TypeTags.TypeTag<T> evidence$5)

    • newMapEncoder

      public static <T extends scala.collection.Map<?, ?>> Encoder<T> newMapEncoder(scala.reflect.api.TypeTags.TypeTag<T> evidence$6)

    • newSetEncoder

      public static <T extends scala.collection.immutable.Set<?>> Encoder<T> newSetEncoder(scala.reflect.api.TypeTags.TypeTag<T> evidence$7)

    • newProductArrayEncoder

      public static <A extends scala.Product> Encoder<Object> newProductArrayEncoder(scala.reflect.api.TypeTags.TypeTag<A> evidence$8)