Package com.here.platform.data.client.flink.impl.decoders

Class IndexFieldValuesExtractor

java.lang.Object

com.here.platform.data.client.flink.impl.decoders.IndexFieldValuesExtractor

public class IndexFieldValuesExtractor
extends Object

Constructor Summary

Constructors

Constructor	Description
IndexFieldValuesExtractor()

Method Summary

Modifier and Type	Method	Description
static scala.collection.immutable.Seq<Object>	extractFieldValues(scala.collection.immutable.Seq<String> fieldNames, com.here.platform.data.client.scaladsl.IndexPartition partition)
static scala.collection.immutable.Map<String,IndexValue>	extractIndexFields(LayerType layerType, org.apache.flink.types.Row row, scala.collection.immutable.Seq<String> fieldNames)

Methods inherited from class java.lang.Object

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

Constructor Details

IndexFieldValuesExtractor

public IndexFieldValuesExtractor()

Method Details

extractIndexFields

public static scala.collection.immutable.Map<String,IndexValue> extractIndexFields(LayerType layerType,
 org.apache.flink.types.Row row,
 scala.collection.immutable.Seq<String> fieldNames)

extractFieldValues

public static scala.collection.immutable.Seq<Object> extractFieldValues(scala.collection.immutable.Seq<String> fieldNames,
 com.here.platform.data.client.scaladsl.IndexPartition partition)