Serialized Form

Package com.logicalclocks.hsfs

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

Package com.logicalclocks.hsfs.beam.engine

Class com.logicalclocks.hsfs.beam.engine.BeamProducer extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.Row>,org.apache.beam.sdk.values.PDone> implements Serializable

Serialized Fields

topic

String topic

properties

Map<K,V> properties

deserializedComplexFeatureSchemas

Map<K,V> deserializedComplexFeatureSchemas

primaryKeys

List<E> primaryKeys

headerMap

Map<K,V> headerMap

Package com.logicalclocks.hsfs.flink.engine

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

Serialized Fields

topic

String topic

primaryKeys

List<E> primaryKeys

headerMap

Map<K,V> headerMap

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