org.apache.beam.runners.spark.structuredstreaming.translation.helpers

Class EncoderHelpers.Utils

java.lang.Object

org.apache.beam.runners.spark.structuredstreaming.translation.helpers.EncoderHelpers.Utils

Enclosing class:

EncoderHelpers

public static class EncoderHelpers.Utils
extends java.lang.Object

Encoder / expression utils that are called from generated code.

Constructor Summary

Constructors

Constructor and Description
Utils()

Method Summary

Modifier and Type	Method and Description
static Instant	maxTimestamp(java.lang.Iterable<BoundedWindow> windows) The end of the only window (max timestamp).
static PaneInfo	paneInfoFromBytes(byte[] bytes)
static byte[]	paneInfoToBytes(PaneInfo pane)
static java.util.List<java.lang.Object>	toList(org.apache.spark.sql.catalyst.util.ArrayData arrayData, org.apache.spark.sql.types.DataType type)
static java.util.HashMap<java.lang.Object,java.lang.Object>	toMap(org.apache.spark.sql.catalyst.util.ArrayData keys, org.apache.spark.sql.catalyst.util.ArrayData values, org.apache.spark.sql.types.DataType keyType, org.apache.spark.sql.types.DataType valueType)
static scala.collection.Seq<java.lang.Object>	toSeq(org.apache.spark.sql.catalyst.util.ArrayData arrayData)
static scala.collection.Seq<java.lang.Object>	toSeq(java.util.Collection<java.lang.Object> col)
static java.util.TreeMap<java.lang.Object,java.lang.Object>	toTreeMap(org.apache.spark.sql.catalyst.util.ArrayData keys, org.apache.spark.sql.catalyst.util.ArrayData values, org.apache.spark.sql.types.DataType keyType, org.apache.spark.sql.types.DataType valueType)

Methods inherited from class java.lang.Object

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

Constructor Detail

Utils

public Utils()

Method Detail

paneInfoFromBytes

public static PaneInfo paneInfoFromBytes(byte[] bytes)

paneInfoToBytes

public static byte[] paneInfoToBytes(PaneInfo pane)

maxTimestamp

public static Instant maxTimestamp(java.lang.Iterable<BoundedWindow> windows)

The end of the only window (max timestamp).

toList

public static java.util.List<java.lang.Object> toList(org.apache.spark.sql.catalyst.util.ArrayData arrayData,
                                                      org.apache.spark.sql.types.DataType type)

toSeq

public static scala.collection.Seq<java.lang.Object> toSeq(org.apache.spark.sql.catalyst.util.ArrayData arrayData)

toSeq

public static scala.collection.Seq<java.lang.Object> toSeq(java.util.Collection<java.lang.Object> col)

toTreeMap

public static java.util.TreeMap<java.lang.Object,java.lang.Object> toTreeMap(org.apache.spark.sql.catalyst.util.ArrayData keys,
                                                                             org.apache.spark.sql.catalyst.util.ArrayData values,
                                                                             org.apache.spark.sql.types.DataType keyType,
                                                                             org.apache.spark.sql.types.DataType valueType)

toMap

public static java.util.HashMap<java.lang.Object,java.lang.Object> toMap(org.apache.spark.sql.catalyst.util.ArrayData keys,
                                                                         org.apache.spark.sql.catalyst.util.ArrayData values,
                                                                         org.apache.spark.sql.types.DataType keyType,
                                                                         org.apache.spark.sql.types.DataType valueType)