Serialized Form

Package com.logicalclocks.hsfs

Class com.logicalclocks.hsfs.FeatureStoreException extends Exception implements Serializable

Package com.logicalclocks.hsfs.flink.engine

Class com.logicalclocks.hsfs.flink.engine.GenericRecordAvroSerializer extends Object implements Serializable

Class com.logicalclocks.hsfs.flink.engine.KeySerializationSchema extends Object implements Serializable

Serialized Fields

primaryKeys

List<E> primaryKeys

Class com.logicalclocks.hsfs.flink.engine.PojoToAvroRecord extends org.apache.flink.api.common.functions.RichMapFunction<T,org.apache.avro.generic.GenericRecord> implements Serializable

Serialized Fields

schema

String schema

encodedSchema

String encodedSchema

complexFeatureSchemas

Map<K,V> complexFeatureSchemas

Package com.logicalclocks.hsfs.metadata

Class com.logicalclocks.hsfs.metadata.InternalException extends org.apache.http.client.ClientProtocolException implements Serializable

Class com.logicalclocks.hsfs.metadata.UnauthorizedException extends org.apache.http.client.ClientProtocolException implements Serializable

Package com.logicalclocks.hsfs.spark.engine.hudi

Class com.logicalclocks.hsfs.spark.engine.hudi.DeltaStreamerConfig extends Object implements Serializable

Class com.logicalclocks.hsfs.spark.engine.hudi.DeltaStreamerKafkaSource extends org.apache.hudi.utilities.sources.AvroSource implements Serializable

Serialized Fields

offsetGen

org.apache.hudi.utilities.sources.helpers.KafkaOffsetGen offsetGen

metrics

org.apache.hudi.utilities.deltastreamer.HoodieDeltaStreamerMetrics metrics

Class com.logicalclocks.hsfs.spark.engine.hudi.DeltaStreamerSchemaProvider extends org.apache.hudi.utilities.schema.SchemaProvider implements Serializable