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

Class ProtobufSchemaFactory

java.lang.Object

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

All Implemented Interfaces:

SchemaFactory

public class ProtobufSchemaFactory
extends Object
implements SchemaFactory

Constructor Summary

Constructors

Constructor	Description
ProtobufSchemaFactory(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 config)

Methods inherited from class java.lang.Object

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

Constructor Details

ProtobufSchemaFactory

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

Method Details

createSchema

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

Specified by:

createSchema in interface SchemaFactory