Class Hierarchy
- java.lang.Object
- com.logicalclocks.hsfs.spark.engine.hudi.DeltaStreamerAvroDeserializer (implements org.apache.kafka.common.serialization.Deserializer<T>)
- com.logicalclocks.hsfs.spark.engine.hudi.DeltaStreamerConfig (implements java.io.Serializable)
- com.logicalclocks.hsfs.spark.engine.hudi.DeltaStreamerTransformer (implements org.apache.hudi.utilities.transform.Transformer)
- com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
- org.apache.hudi.utilities.schema.SchemaProvider (implements java.io.Serializable)
- org.apache.hudi.utilities.sources.Source<T> (implements java.io.Serializable, org.apache.hudi.utilities.callback.SourceCommitCallback)
- org.apache.hudi.utilities.sources.KafkaSource<T>
- com.logicalclocks.hsfs.spark.engine.hudi.TableMigrateUtils