Hierarchy For All Packages

Package Hierarchies:

• com.logicalclocks.hsfs,
• com.logicalclocks.hsfs.constructor,
• com.logicalclocks.hsfs.engine,
• com.logicalclocks.hsfs.flink,
• com.logicalclocks.hsfs.flink.engine,
• com.logicalclocks.hsfs.metadata,
• com.logicalclocks.hsfs.spark,
• com.logicalclocks.hsfs.spark.constructor,
• com.logicalclocks.hsfs.spark.engine,
• com.logicalclocks.hsfs.spark.engine.hudi,
• com.logicalclocks.hsfs.spark.util,
• com.logicalclocks.hsfs.util

Class Hierarchy

• java.lang.Object
  • org.apache.flink.api.common.functions.AbstractRichFunction (implements org.apache.flink.api.common.functions.RichFunction, java.io.Serializable)
    • org.apache.flink.api.common.functions.RichMapFunction<IN,OUT> (implements org.apache.flink.api.common.functions.MapFunction<T,O>)
      • com.logicalclocks.hsfs.flink.engine.PojoToAvroRecord<T> (implements org.apache.flink.api.java.typeutils.ResultTypeQueryable<T>)
  • com.logicalclocks.hsfs.metadata.AuthorizationHandler<T> (implements org.apache.http.client.ResponseHandler<T>)
  • com.logicalclocks.hsfs.metadata.CodeApi
  • com.logicalclocks.hsfs.engine.CodeEngine
  • com.logicalclocks.hsfs.util.Constants
  • com.logicalclocks.hsfs.metadata.Credentials
  • 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.DeltaStreamerJobConf
  • com.logicalclocks.hsfs.spark.engine.hudi.DeltaStreamerTransformer (implements org.apache.hudi.utilities.transform.Transformer)
  • com.logicalclocks.hsfs.Feature
  • com.logicalclocks.hsfs.constructor.FeatureGroupAlias<T>
  • com.logicalclocks.hsfs.metadata.FeatureGroupApi
  • com.logicalclocks.hsfs.FeatureGroupBase<T>
    • com.logicalclocks.hsfs.spark.ExternalFeatureGroup
    • com.logicalclocks.hsfs.spark.FeatureGroup
    • com.logicalclocks.hsfs.FeatureGroupBaseForApi
    • com.logicalclocks.hsfs.spark.StreamFeatureGroup
    • com.logicalclocks.hsfs.flink.StreamFeatureGroup
  • com.logicalclocks.hsfs.engine.FeatureGroupEngineBase
    • com.logicalclocks.hsfs.spark.engine.FeatureGroupEngine
    • com.logicalclocks.hsfs.flink.engine.FeatureGroupEngine
  • com.logicalclocks.hsfs.engine.FeatureGroupUtils
  • com.logicalclocks.hsfs.metadata.FeatureStoreApi
  • com.logicalclocks.hsfs.FeatureStoreBase<T2>
    • com.logicalclocks.hsfs.spark.FeatureStore
    • com.logicalclocks.hsfs.flink.FeatureStore
  • com.logicalclocks.hsfs.spark.FeatureView.FeatureViewBuilder
  • com.logicalclocks.hsfs.metadata.FeatureViewApi
  • com.logicalclocks.hsfs.FeatureViewBase<T,T3,T4,T5>
    • com.logicalclocks.hsfs.spark.FeatureView
    • com.logicalclocks.hsfs.flink.FeatureView
  • com.logicalclocks.hsfs.engine.FeatureViewEngineBase<T1,T2,T3,T4,T5>
    • com.logicalclocks.hsfs.spark.engine.FeatureViewEngine
    • com.logicalclocks.hsfs.flink.engine.FeatureViewEngine
  • com.logicalclocks.hsfs.constructor.Filter
  • com.logicalclocks.hsfs.constructor.FilterLogic
  • com.logicalclocks.hsfs.flink.engine.FlinkEngine
  • com.logicalclocks.hsfs.constructor.FsQueryBase<T,T2>
    • com.logicalclocks.hsfs.spark.constructor.FsQuery
  • com.logicalclocks.hsfs.flink.engine.GenericRecordAvroSerializer (implements org.apache.flink.api.common.serialization.SerializationSchema<T>)
  • com.logicalclocks.hsfs.metadata.HopsworksClient
  • com.logicalclocks.hsfs.metadata.HopsworksClient.BaseHandler<T> (implements org.apache.http.client.ResponseHandler<T>)
  • com.logicalclocks.hsfs.metadata.HopsworksClient.HopsworksErrorClass
  • com.logicalclocks.hsfs.HopsworksConnectionBase (implements java.io.Closeable)
    • com.logicalclocks.hsfs.spark.HopsworksConnection
    • com.logicalclocks.hsfs.flink.HopsworksConnection
  • com.logicalclocks.hsfs.metadata.HopsworksExternalClient (implements com.logicalclocks.hsfs.metadata.HopsworksHttpClient)
  • com.logicalclocks.hsfs.metadata.HopsworksHostnameVerifier (implements javax.net.ssl.HostnameVerifier)
  • com.logicalclocks.hsfs.metadata.HopsworksInternalClient (implements com.logicalclocks.hsfs.metadata.HopsworksHttpClient)
  • com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
  • com.logicalclocks.hsfs.JobConfiguration
  • com.logicalclocks.hsfs.constructor.Join<T>
  • com.logicalclocks.hsfs.metadata.KafkaApi
  • com.logicalclocks.hsfs.flink.engine.KeySerializationSchema (implements org.apache.flink.api.common.serialization.SerializationSchema<T>)
  • com.logicalclocks.hsfs.metadata.OnDemandOptions
  • com.logicalclocks.hsfs.metadata.Option
  • com.logicalclocks.hsfs.constructor.PreparedStatementParameter
  • com.logicalclocks.hsfs.Project
  • com.logicalclocks.hsfs.metadata.ProjectApi
  • com.logicalclocks.hsfs.constructor.QueryBase<T,T2,T3>
    • com.logicalclocks.hsfs.spark.constructor.Query
  • com.logicalclocks.hsfs.metadata.QueryConstructorApi
  • com.logicalclocks.hsfs.metadata.RestDto<D>
    • com.logicalclocks.hsfs.metadata.Code
    • com.logicalclocks.hsfs.FeatureGroupCommit
    • com.logicalclocks.hsfs.metadata.KafkaClusterInfo
    • com.logicalclocks.hsfs.metadata.PartitionDetails
    • com.logicalclocks.hsfs.constructor.ServingPreparedStatement
    • com.logicalclocks.hsfs.metadata.Statistics
    • com.logicalclocks.hsfs.metadata.Tags
    • com.logicalclocks.hsfs.TransformationFunction
    • com.logicalclocks.hsfs.metadata.TransformationFunctionAttached
  • org.apache.hudi.utilities.schema.SchemaProvider (implements java.io.Serializable)
    • com.logicalclocks.hsfs.spark.engine.hudi.DeltaStreamerSchemaProvider
  • org.apache.hudi.utilities.sources.Source<T> (implements java.io.Serializable, org.apache.hudi.utilities.callback.SourceCommitCallback)
    • org.apache.hudi.utilities.sources.AvroSource
      • com.logicalclocks.hsfs.spark.engine.hudi.DeltaStreamerKafkaSource
  • com.logicalclocks.hsfs.spark.engine.SparkEngine
  • com.logicalclocks.hsfs.Split
  • com.logicalclocks.hsfs.metadata.SplitStatistics
  • com.logicalclocks.hsfs.metadata.StatisticsApi
  • com.logicalclocks.hsfs.StatisticsConfig
  • com.logicalclocks.hsfs.spark.engine.StatisticsEngine
  • com.logicalclocks.hsfs.StorageConnector
    • com.logicalclocks.hsfs.StorageConnector.AdlsConnector
    • com.logicalclocks.hsfs.StorageConnector.BigqueryConnector
    • com.logicalclocks.hsfs.StorageConnector.GcsConnector
    • com.logicalclocks.hsfs.StorageConnector.HopsFsConnector
    • com.logicalclocks.hsfs.StorageConnector.JdbcConnector
    • com.logicalclocks.hsfs.StorageConnector.KafkaConnector
    • com.logicalclocks.hsfs.StorageConnector.RedshiftConnector
    • com.logicalclocks.hsfs.StorageConnector.S3Connector
    • com.logicalclocks.hsfs.StorageConnector.SnowflakeConnector
  • com.logicalclocks.hsfs.metadata.StorageConnectorApi
  • com.logicalclocks.hsfs.spark.util.StorageConnectorUtils
  • com.logicalclocks.hsfs.metadata.Subject
  • com.logicalclocks.hsfs.metadata.TagsApi
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception
      • com.logicalclocks.hsfs.FeatureStoreException
      • java.io.IOException
        • org.apache.http.client.ClientProtocolException
          • com.logicalclocks.hsfs.metadata.InternalException
          • com.logicalclocks.hsfs.metadata.UnauthorizedException
  • com.logicalclocks.hsfs.metadata.TrainingDatasetApi
  • com.logicalclocks.hsfs.TrainingDatasetBase
    • com.logicalclocks.hsfs.spark.TrainingDataset
  • com.logicalclocks.hsfs.spark.TrainingDatasetBundle
  • com.logicalclocks.hsfs.spark.engine.TrainingDatasetEngine
  • com.logicalclocks.hsfs.TrainingDatasetFeature
  • com.logicalclocks.hsfs.spark.engine.TrainingDatasetUtils
  • com.logicalclocks.hsfs.metadata.User
  • com.logicalclocks.hsfs.metadata.Variable
  • com.logicalclocks.hsfs.metadata.VariablesApi
  • com.logicalclocks.hsfs.engine.VectorServer

Interface Hierarchy

• com.logicalclocks.hsfs.metadata.HopsworksHttpClient

Enum Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • com.logicalclocks.hsfs.TrainingDatasetType
    • com.logicalclocks.hsfs.DataFormat
    • com.logicalclocks.hsfs.SecretStore
    • com.logicalclocks.hsfs.StorageConnectorType
    • com.logicalclocks.hsfs.FeatureType
    • com.logicalclocks.hsfs.SslEndpointIdentificationAlgorithm
    • com.logicalclocks.hsfs.ExternalDataFormat
    • com.logicalclocks.hsfs.EntityEndpointType
    • com.logicalclocks.hsfs.constructor.JoinType
    • com.logicalclocks.hsfs.constructor.SqlFilterLogic
    • com.logicalclocks.hsfs.constructor.SqlFilterCondition
    • com.logicalclocks.hsfs.TimeTravelFormat
    • com.logicalclocks.hsfs.Storage
    • com.logicalclocks.hsfs.SecurityProtocol
    • com.logicalclocks.hsfs.metadata.Code.RunType
    • com.logicalclocks.hsfs.HudiOperationType
    • com.logicalclocks.hsfs.Split.SplitType