Package it.bancaditalia.oss.vtl.impl.environment.spark

Class DataPointEncoder

java.lang.Object

it.bancaditalia.oss.vtl.impl.environment.spark.DataPointEncoder

All Implemented Interfaces:

Serializable

public class DataPointEncoder
extends Object
implements Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
DataPointEncoder(Set<? extends DataStructureComponent<?,?,?>> dataStructure)

Method Summary

Modifier and Type	Method	Description
DataPoint	decode(Object[] row)
DataPoint	decode(Object[] row, int startFrom)
DataPoint	decode(org.apache.spark.sql.Row row)
DataPoint	decode(org.apache.spark.sql.Row row, int startFrom)
SerFunction<org.apache.spark.sql.Row,DataPoint>	decodeFrom(int startFrom)
org.apache.spark.sql.Row	encode(DataPoint dp)
static org.apache.spark.sql.types.DataType	getDataTypeForComponent(DataStructureComponent<?,?,?> component)
static org.apache.spark.sql.Encoder<?>	getEncoderForComponent(DataStructureComponent<?,?,?> component)
org.apache.spark.sql.Encoder<org.apache.spark.sql.Row>	getRowEncoder()
org.apache.spark.sql.Encoder<org.apache.spark.sql.Row>	getRowEncoderNoLineage()
org.apache.spark.sql.types.StructType	getSchema()
DataSetMetadata	getStructure()

Methods inherited from class java.lang.Object

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

Constructor Detail

DataPointEncoder

public DataPointEncoder(Set<? extends DataStructureComponent<?,?,?>> dataStructure)

Method Detail

encode

public org.apache.spark.sql.Row encode(DataPoint dp)

decode

public DataPoint decode(Object[] row)

decode

public DataPoint decode(Object[] row,
                        int startFrom)

decode

public DataPoint decode(org.apache.spark.sql.Row row)

decodeFrom

public SerFunction<org.apache.spark.sql.Row,DataPoint> decodeFrom(int startFrom)

decode

public DataPoint decode(org.apache.spark.sql.Row row,
                        int startFrom)

getSchema

public org.apache.spark.sql.types.StructType getSchema()

getRowEncoder

public org.apache.spark.sql.Encoder<org.apache.spark.sql.Row> getRowEncoder()

getRowEncoderNoLineage

public org.apache.spark.sql.Encoder<org.apache.spark.sql.Row> getRowEncoderNoLineage()

getStructure

public DataSetMetadata getStructure()

getEncoderForComponent

public static org.apache.spark.sql.Encoder<?> getEncoderForComponent(DataStructureComponent<?,?,?> component)

getDataTypeForComponent

public static org.apache.spark.sql.types.DataType getDataTypeForComponent(DataStructureComponent<?,?,?> component)