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

Class SchemaDiscoveryImpl

java.lang.Object

com.here.platform.data.client.flink.impl.SchemaDiscoveryImpl

All Implemented Interfaces:

SchemaDiscovery, Serializable, scala.Equals, scala.Product

public class SchemaDiscoveryImpl
extends Object
implements SchemaDiscovery, scala.Product, Serializable

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
SchemaDiscoveryImpl(scala.Option<com.here.platform.data.client.scaladsl.AdminApi> adminApi, com.here.platform.data.client.flink.scaladsl.LayerTypeProvider layerTypeProvider)

Method Summary

Modifier and Type	Method	Description
scala.Option<com.here.platform.data.client.scaladsl.AdminApi>	adminApi()
abstract static R	apply(T1 v1, T2 v2)
PartitionSchema	discoverSchema(HRN hrn, String layerId, org.apache.flink.configuration.ReadableConfig config)
String	getLayerContentType(HRN hrn, String layerId)
InteractiveMapSchema	interactiveMapSchemaR()
InteractiveMapSchema	interactiveMapSchemaW()
com.here.platform.data.client.flink.scaladsl.LayerTypeProvider	layerTypeProvider()
boolean	shouldUseRawData(org.apache.flink.configuration.ReadableConfig properties)
static String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface scala.Equals

canEqual, equals

Methods inherited from interface scala.Product

productArity, productElement, productElementName, productElementNames, productIterator, productPrefix

Constructor Details

SchemaDiscoveryImpl

public SchemaDiscoveryImpl(scala.Option<com.here.platform.data.client.scaladsl.AdminApi> adminApi,
 com.here.platform.data.client.flink.scaladsl.LayerTypeProvider layerTypeProvider)

Method Details

apply

public abstract static R apply(T1 v1,
 T2 v2)

toString

public static String toString()

interactiveMapSchemaR

public InteractiveMapSchema interactiveMapSchemaR()

Specified by:

interactiveMapSchemaR in interface SchemaDiscovery

interactiveMapSchemaW

public InteractiveMapSchema interactiveMapSchemaW()

Specified by:

interactiveMapSchemaW in interface SchemaDiscovery

adminApi

public scala.Option<com.here.platform.data.client.scaladsl.AdminApi> adminApi()

layerTypeProvider

public com.here.platform.data.client.flink.scaladsl.LayerTypeProvider layerTypeProvider()

getLayerContentType

public String getLayerContentType(HRN hrn,
 String layerId)

shouldUseRawData

public boolean shouldUseRawData(org.apache.flink.configuration.ReadableConfig properties)

discoverSchema

public PartitionSchema discoverSchema(HRN hrn,
 String layerId,
 org.apache.flink.configuration.ReadableConfig config)

Specified by:

discoverSchema in interface SchemaDiscovery