com.logicalclocks.hsfs.spark.engine.hudi

Class DeltaStreamerSchemaProvider

java.lang.Object

org.apache.hudi.utilities.schema.SchemaProvider

com.logicalclocks.hsfs.spark.engine.hudi.DeltaStreamerSchemaProvider

All Implemented Interfaces:

Serializable

public class DeltaStreamerSchemaProvider
extends org.apache.hudi.utilities.schema.SchemaProvider

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.hudi.utilities.schema.SchemaProvider

config, jssc

Constructor Summary

Constructors

Constructor and Description
DeltaStreamerSchemaProvider(org.apache.hudi.common.config.TypedProperties props, org.apache.spark.api.java.JavaSparkContext jssc)

Method Summary

Modifier and Type	Method and Description
org.apache.avro.Schema	getSourceSchema()

Methods inherited from class org.apache.hudi.utilities.schema.SchemaProvider

getTargetSchema

Methods inherited from class java.lang.Object

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

Constructor Detail

DeltaStreamerSchemaProvider

public DeltaStreamerSchemaProvider(org.apache.hudi.common.config.TypedProperties props,
                                   org.apache.spark.api.java.JavaSparkContext jssc)

Method Detail

getSourceSchema

public org.apache.avro.Schema getSourceSchema()

Specified by:

getSourceSchema in class org.apache.hudi.utilities.schema.SchemaProvider