Api

Instance Constructors

new Api(userConf: Map[String, String])

Abstract Value Members

abstract def externalRegistry: ExternalSourceRegistry
abstract def genKvStore: KVStore
abstract def logResponse(resp: LoggableResponse): Unit

logged responses should be made available to an offline log table in Hive with columns key_bytes, value_bytes, ts_millis, join_name, schema_hash and ds (date string) partitioned by join_name and ds Note the camel case to snake case conversion: Hive doesn't like camel case.
logged responses should be made available to an offline log table in Hive with columns key_bytes, value_bytes, ts_millis, join_name, schema_hash and ds (date string) partitioned by join_name and ds Note the camel case to snake case conversion: Hive doesn't like camel case. The key bytes and value bytes will be transformed by chronon to human readable columns for each join. <team_namespace>.<join_name>_logged To measure consistency - a Side-by-Side comparison table will be created at <team_namespace>.<join_name>_comparison Consistency summary will be available in <logTable>_consistency_summary
abstract def streamDecoder(groupByServingInfoParsed: GroupByServingInfoParsed): StreamDecoder

Concrete Value Members

final def !=(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def ##(): Int

Definition Classes
AnyRef → Any
final def ==(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def asInstanceOf[T0]: T0

Definition Classes
Any
final def buildFetcher(debug: Boolean = false, callerName: String = null, disableErrorThrows: Boolean = false): Fetcher
final def buildJavaFetcher(): JavaFetcher
final def buildJavaFetcher(callerName: String = null, disableErrorThrows: Boolean = false): JavaFetcher
def clone(): AnyRef

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( ... )
final def eq(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def equals(arg0: Any): Boolean

Definition Classes
AnyRef → Any
lazy val fetcher: Fetcher
def finalize(): Unit

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( classOf[java.lang.Throwable] )
def genModelBackend: ModelBackend
def generateStreamBuilder(streamType: String): StreamBuilder
final def getClass(): Class[_]

Definition Classes
AnyRef → Any
def hashCode(): Int

Definition Classes
AnyRef → Any
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
final def javaFetcherBuilder(): Builder
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
final def notifyAll(): Unit

Definition Classes
AnyRef
def registerJoinExternalSources(joins: Seq[String]): Unit

Register external sources from join configurations.
Register external sources from join configurations. This function reads configurations for each join, extracts FactoryConfig information from external sources, and stores this information in the ExternalSourceRegistry.
joins
Sequence of join names to process
def setFlagStore(customFlagStore: FlagStore): Unit
def setTimeout(millis: Long): Unit
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
def toString(): String

Definition Classes
AnyRef → Any
final def wait(): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long, arg1: Int): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )

Related Doc: package online

abstract class Api extends Serializable

Instance Constructors

new Api(userConf: Map[String, String])

Abstract Value Members

abstract def externalRegistry: ExternalSourceRegistry

abstract def genKvStore: KVStore

abstract def logResponse(resp: LoggableResponse): Unit

abstract def streamDecoder(groupByServingInfoParsed: GroupByServingInfoParsed): StreamDecoder

Concrete Value Members

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: Any): Boolean

final def asInstanceOf[T0]: T0

final def buildFetcher(debug: Boolean = false, callerName: String = null, disableErrorThrows: Boolean = false): Fetcher

final def buildJavaFetcher(): JavaFetcher

final def buildJavaFetcher(callerName: String = null, disableErrorThrows: Boolean = false): JavaFetcher

def clone(): AnyRef

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

lazy val fetcher: Fetcher

def finalize(): Unit

def genModelBackend: ModelBackend

def generateStreamBuilder(streamType: String): StreamBuilder

final def getClass(): Class[_]

def hashCode(): Int

final def isInstanceOf[T0]: Boolean

final def javaFetcherBuilder(): Builder

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

def registerJoinExternalSources(joins: Seq[String]): Unit

def setFlagStore(customFlagStore: FlagStore): Unit

def setTimeout(millis: Long): Unit

final def synchronized[T0](arg0: ⇒ T0): T0

def toString(): String

final def wait(): Unit

final def wait(arg0: Long, arg1: Int): Unit

final def wait(arg0: Long): Unit

Inherited from Serializable

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped