online

Type Members

1. abstract class Api extends Serializable

   

2. class CatalystUtil extends AnyRef

   

3. case class DataMetrics(series: Seq[(Long, SortedMap[String, Any])]) extends Product with Serializable

   

4. case class DataStream(df: DataFrame, partitions: Int, topicInfo: TopicInfo) extends Product with Serializable

   

5. abstract class ExternalSourceFactory extends Serializable

   

   Factory interface for creating external source handlers dynamically.

   Factory interface for creating external source handlers dynamically.

   Implementations of this factory can be registered with ExternalSourceRegistry to enable dynamic creation of ExternalSourceHandler instances based on external source configurations at runtime.

   The factory pattern allows for flexible handler creation where the specific handler implementation can be determined by the ExternalSource configuration, including factory parameters passed through ExternalSourceFactoryConfig.

6. abstract class ExternalSourceHandler extends Serializable

   

7. class ExternalSourceRegistry extends Serializable

   

8. class Fetcher extends FetcherBase

   

9. class FetcherBase extends MetadataStore with FetcherCache

   

10. trait FetcherCache extends AnyRef

    

11. trait FlagStore extends Serializable

    

12. class GroupByServingInfoParsed extends GroupByServingInfo with Serializable

    

13. abstract class JTry[V] extends AnyRef

    

14. abstract class JavaExternalSourceHandler extends ExternalSourceHandler

    

15. class JavaFetcher extends AnyRef

    

16. class JavaRequest extends AnyRef

    

17. class JavaResponse extends AnyRef

    

18. class JavaSeriesStatsResponse extends AnyRef

    

19. class JavaStatsRequest extends AnyRef

    

20. class JavaStatsResponse extends AnyRef

    

21. case class JoinCodec(conf: JoinOps, keySchema: StructType, baseValueSchema: StructType) extends Serializable with Product

    

22. trait KVStore extends AnyRef

    

23. case class LoggableResponse(keyBytes: Array[Byte], valueBytes: Array[Byte], joinName: String, tsMillis: Long, schemaHash: String) extends Product with Serializable

    

24. case class LoggableResponseBase64(keyBase64: String, valueBase64: String, name: String, tsMillis: Long, schemaHash: String) extends Product with Serializable

    

25. class MetadataDirWalker extends AnyRef

    

26. case class MetadataEndPoint[Conf <: TBase[_, _]](extractFn: (String, Conf) ⇒ (String, String), name: String)(implicit evidence$1: Manifest[Conf], evidence$2: ClassTag[Conf]) extends Product with Serializable

    

27. class MetadataStore extends AnyRef

    

28. trait ModelBackend extends AnyRef

    

29. case class Mutation(schema: StructType = null, before: Array[Any] = null, after: Array[Any] = null) extends Product with Serializable

    

    Mutation is the general case of an Event Imagine a user impression/view stream - impressions/views are immutable events Imagine a stream of changes to a credit card transaction stream.

    MUTATION vs. EVENT

    Mutation is the general case of an Event Imagine a user impression/view stream - impressions/views are immutable events Imagine a stream of changes to a credit card transaction stream.

    • transactions can be "corrected"/updated & deleted, besides being "inserted"
    • This is one of the core difference between entity and event sources. Events are insert-only.
    • (The other difference is Entites are stored in the warehouse typically as snapshots of the table as of midnight) In case of an update - one must produce both before and after values In case of a delete - only before is populated & after is left as null In case of a insert - only after is populated & before is left as null

    TIME ASSUMPTIONS

    The schema needs to contain a ts(milliseconds as a java Long) For the entities case, mutation_ts when absent will use ts as a replacement

    TYPE CONVERSIONS

    Java types corresponding to the schema types. StreamDecoder should produce mutations that comply. NOTE: everything is nullable (hence boxed) IntType java.lang.Integer LongType java.lang.Long DoubleType java.lang.Double FloatType java.lang.Float ShortType java.lang.Short BooleanType java.lang.Boolean ByteType java.lang.Byte StringType java.lang.String BinaryType Array[Byte] ListType java.util.List[Byte] MapType java.util.Map[Byte] StructType Array[Any]

30. class PoolMap[Key, Value] extends AnyRef

    

31. class PooledCatalystUtil extends AnyRef

    

32. case class RunModelInferenceRequest(model: Model, inputs: Seq[Map[String, AnyRef]]) extends Product with Serializable

    

33. case class RunModelInferenceResponse(request: RunModelInferenceRequest, outputs: Seq[Map[String, AnyRef]]) extends Product with Serializable

    

34. trait SerializableFunction[T, R] extends Function[T, R] with Serializable

    

35. trait StreamBuilder extends AnyRef

    

36. abstract class StreamDecoder extends Serializable

    

37. class TBaseDecoderFactory extends Serializable

    

38. class TTLCache[I, O] extends AnyRef

    

39. class ThriftDecoder extends Serializable

    

40. class TileCodec extends AnyRef

    

    TileCodec is a helper class that allows for the creation of pre-aggregated tiles of feature values.

    TileCodec is a helper class that allows for the creation of pre-aggregated tiles of feature values. These pre-aggregated tiles can be used in the serving layer to compute the final feature values along with batch pre-aggregates produced by GroupByUploads. The pre-aggregated tiles are serialized as Avro and indicate whether the tile is complete or not (partial aggregates)

41. case class TopicInfo(name: String, topicType: String, params: Map[String, String]) extends Product with Serializable