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

Class AvroSchemaFactory

java.lang.Object

com.here.platform.data.client.flink.impl.schema.AvroSchemaFactory

All Implemented Interfaces:

SchemaFactory

public class AvroSchemaFactory
extends Object
implements SchemaFactory

Constructor Summary

Constructors

Constructor	Description
AvroSchemaFactory(scala.Function1<String,BlobConverter> createblobConverterFn, com.here.platform.data.client.flink.scaladsl.LayerTypeProvider layerTypeProvider)

Method Summary

Modifier and Type	Method	Description
PartitionSchema	createSchema(HRN hrn, String layerId, org.apache.flink.configuration.ReadableConfig properties)

Methods inherited from class java.lang.Object

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

Constructor Details

AvroSchemaFactory

public AvroSchemaFactory(scala.Function1<String,BlobConverter> createblobConverterFn,
 com.here.platform.data.client.flink.scaladsl.LayerTypeProvider layerTypeProvider)

Method Details

createSchema

public PartitionSchema createSchema(HRN hrn,
 String layerId,
 org.apache.flink.configuration.ReadableConfig properties)

Specified by:

createSchema in interface SchemaFactory