Package org.apache.spark.sql.streaming

Class StatefulProcessor.implicits$

Object

org.apache.spark.sql.streaming.StatefulProcessor.implicits$

All Implemented Interfaces:

Serializable, EncoderImplicits, LowPrioritySQLImplicits

Enclosing class:

StatefulProcessor<K,I,O>

public class StatefulProcessor.implicits$
extends Object
implements EncoderImplicits

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
static final implicits$	MODULE$	Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor	Description
implicits$()

Method Summary

Modifier and Type	Method	Description
Encoder<boolean[]>	newBooleanArrayEncoder()
Encoder<scala.collection.immutable.Seq<Object>>	newBooleanSeqEncoder()	Deprecated. Use newSequenceEncoder instead.
Encoder<byte[]>	newByteArrayEncoder()
Encoder<scala.collection.immutable.Seq<Object>>	newByteSeqEncoder()	Deprecated. Use newSequenceEncoder instead.
Encoder<double[]>	newDoubleArrayEncoder()
Encoder<scala.collection.immutable.Seq<Object>>	newDoubleSeqEncoder()	Deprecated. Use newSequenceEncoder instead.
Encoder<float[]>	newFloatArrayEncoder()
Encoder<scala.collection.immutable.Seq<Object>>	newFloatSeqEncoder()	Deprecated. Use newSequenceEncoder instead.
Encoder<int[]>	newIntArrayEncoder()
Encoder<scala.collection.immutable.Seq<Object>>	newIntSeqEncoder()	Deprecated. Use newSequenceEncoder instead.
Encoder<long[]>	newLongArrayEncoder()
Encoder<scala.collection.immutable.Seq<Object>>	newLongSeqEncoder()	Deprecated. Use newSequenceEncoder instead.
Encoder<short[]>	newShortArrayEncoder()
Encoder<scala.collection.immutable.Seq<Object>>	newShortSeqEncoder()	Deprecated. Use newSequenceEncoder instead.
Encoder<String[]>	newStringArrayEncoder()
Encoder<scala.collection.immutable.Seq<String>>	newStringSeqEncoder()	Deprecated. Use newSequenceEncoder instead.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.spark.sql.EncoderImplicits

newArrayEncoder, newBooleanEncoder, newBoxedBooleanEncoder, newBoxedByteEncoder, newBoxedDoubleEncoder, newBoxedFloatEncoder, newBoxedIntEncoder, newBoxedLongEncoder, newBoxedShortEncoder, newByteEncoder, newDateEncoder, newDoubleEncoder, newDurationEncoder, newFloatEncoder, newInstantEncoder, newIntEncoder, newJavaDecimalEncoder, newJavaEnumEncoder, newLocalDateEncoder, newLocalDateTimeEncoder, newLocalTimeEncoder, newLongEncoder, newMapEncoder, newPeriodEncoder, newProductArrayEncoder, newProductSeqEncoder, newScalaDecimalEncoder, newSeqEncoder, newSequenceEncoder, newSetEncoder, newShortEncoder, newStringEncoder, newTimeStampEncoder

Methods inherited from interface org.apache.spark.sql.LowPrioritySQLImplicits

newProductEncoder

Field Details

MODULE$

public static final implicits$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Details

implicits$

public implicits$()

Method Details

newIntSeqEncoder

public Encoder<scala.collection.immutable.Seq<Object>> newIntSeqEncoder()

Deprecated.

Use newSequenceEncoder instead. Since 2.2.0.

Specified by:

newIntSeqEncoder in interface EncoderImplicits

Returns:

(undocumented)

newLongSeqEncoder

public Encoder<scala.collection.immutable.Seq<Object>> newLongSeqEncoder()

Deprecated.

Use newSequenceEncoder instead. Since 2.2.0.

Specified by:

newLongSeqEncoder in interface EncoderImplicits

Returns:

(undocumented)

newDoubleSeqEncoder

public Encoder<scala.collection.immutable.Seq<Object>> newDoubleSeqEncoder()

Deprecated.

Use newSequenceEncoder instead. Since 2.2.0.

Specified by:

newDoubleSeqEncoder in interface EncoderImplicits

Returns:

(undocumented)

newFloatSeqEncoder

public Encoder<scala.collection.immutable.Seq<Object>> newFloatSeqEncoder()

Deprecated.

Use newSequenceEncoder instead. Since 2.2.0.

Specified by:

newFloatSeqEncoder in interface EncoderImplicits

Returns:

(undocumented)

newByteSeqEncoder

public Encoder<scala.collection.immutable.Seq<Object>> newByteSeqEncoder()

Deprecated.

Use newSequenceEncoder instead. Since 2.2.0.

Specified by:

newByteSeqEncoder in interface EncoderImplicits

Returns:

(undocumented)

newShortSeqEncoder

public Encoder<scala.collection.immutable.Seq<Object>> newShortSeqEncoder()

Deprecated.

Use newSequenceEncoder instead. Since 2.2.0.

Specified by:

newShortSeqEncoder in interface EncoderImplicits

Returns:

(undocumented)

newBooleanSeqEncoder

public Encoder<scala.collection.immutable.Seq<Object>> newBooleanSeqEncoder()

Deprecated.

Use newSequenceEncoder instead. Since 2.2.0.

Specified by:

newBooleanSeqEncoder in interface EncoderImplicits

Returns:

(undocumented)

newStringSeqEncoder

public Encoder<scala.collection.immutable.Seq<String>> newStringSeqEncoder()

Deprecated.

Use newSequenceEncoder instead. Since 2.2.0.

Specified by:

newStringSeqEncoder in interface EncoderImplicits

Returns:

(undocumented)

newIntArrayEncoder

public Encoder<int[]> newIntArrayEncoder()

Specified by:

newIntArrayEncoder in interface EncoderImplicits

newLongArrayEncoder

public Encoder<long[]> newLongArrayEncoder()

Specified by:

newLongArrayEncoder in interface EncoderImplicits

newDoubleArrayEncoder

public Encoder<double[]> newDoubleArrayEncoder()

Specified by:

newDoubleArrayEncoder in interface EncoderImplicits

newFloatArrayEncoder

public Encoder<float[]> newFloatArrayEncoder()

Specified by:

newFloatArrayEncoder in interface EncoderImplicits

newByteArrayEncoder

public Encoder<byte[]> newByteArrayEncoder()

Specified by:

newByteArrayEncoder in interface EncoderImplicits

newShortArrayEncoder

public Encoder<short[]> newShortArrayEncoder()

Specified by:

newShortArrayEncoder in interface EncoderImplicits

newBooleanArrayEncoder

public Encoder<boolean[]> newBooleanArrayEncoder()

Specified by:

newBooleanArrayEncoder in interface EncoderImplicits

newStringArrayEncoder

public Encoder<String[]> newStringArrayEncoder()

Specified by:

newStringArrayEncoder in interface EncoderImplicits