Package 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:

  • Field Summary

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

    config, jssc

  • Constructor Summary

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

  • Method Summary

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

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

    getSourceHoodieSchema, getTargetHoodieSchema, getTargetSchema, refresh

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • DeltaStreamerSchemaProvider

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

  • Method Details

    • getSourceSchema

      public org.apache.avro.Schema getSourceSchema()
      Overrides:
      getSourceSchema in class org.apache.hudi.utilities.schema.SchemaProvider