Serialized Form

Package com.logicalclocks.hsfs

Exception com.logicalclocks.hsfs.FeatureStoreException

class FeatureStoreException extends Exception implements Serializable

Package com.logicalclocks.hsfs.beam.engine

Class com.logicalclocks.hsfs.beam.engine.BeamProducer

class BeamProducer extends org.apache.beam.sdk.transforms.PTransform<@NonNull org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.Row>,@NonNull org.apache.beam.sdk.values.PDone> implements Serializable

Serialized Fields

deserializedComplexFeatureSchemas

Map<String,org.apache.avro.Schema> deserializedComplexFeatureSchemas

headerMap

Map<String,byte[]> headerMap

primaryKeys

List<String> primaryKeys

properties

Map<String,String> properties

topic

String topic

Package com.logicalclocks.hsfs.flink.engine

Class com.logicalclocks.hsfs.flink.engine.KafkaRecordSerializer

class KafkaRecordSerializer extends Object implements Serializable

Serialized Fields

headerMap

Map<String,byte[]> headerMap

primaryKeys

List<String> primaryKeys

topic

String topic

Class com.logicalclocks.hsfs.flink.engine.PojoToAvroRecord

class PojoToAvroRecord extends org.apache.flink.api.common.functions.RichMapFunction<T,org.apache.avro.generic.GenericRecord> implements Serializable

Serialized Fields

complexFeatureSchemasStr

Map<String,String> complexFeatureSchemasStr

encodedFeatureGroupSchemaStr

String encodedFeatureGroupSchemaStr

featureGroupSchemaStr

String featureGroupSchemaStr

Package com.logicalclocks.hsfs.metadata

Exception com.logicalclocks.hsfs.metadata.InternalException

class InternalException extends org.apache.http.client.ClientProtocolException implements Serializable

Exception com.logicalclocks.hsfs.metadata.UnauthorizedException

class UnauthorizedException extends org.apache.http.client.ClientProtocolException implements Serializable

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

Class com.logicalclocks.hsfs.spark.engine.hudi.DeltaStreamerConfig

class DeltaStreamerConfig extends Object implements Serializable

Class com.logicalclocks.hsfs.spark.engine.hudi.DeltaStreamerKafkaSource

class DeltaStreamerKafkaSource extends org.apache.hudi.utilities.sources.KafkaSource<org.apache.spark.api.java.JavaRDD<org.apache.avro.generic.GenericRecord>> implements Serializable

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

class DeltaStreamerSchemaProvider extends org.apache.hudi.utilities.schema.SchemaProvider implements Serializable