REQUEST_TIMEOUT
HttpDeleteResponseReceiver HttpGetResponseReceiver HttpPostResponseReceiver HttpPutResponseReceiver HttpClientWriter
RESPONSE_TIMEOUT
HttpWeatherResponseReceiver WeatherRESTClient
RandomForestClassifierPredictOperator
analysis
RandomForestClassifierTrainOperator
analysis
RandomSamplingOperator
reduction
ReloadServing
runner
RenameColumnOperator
transformation
ReshapeWithConcat
integration
ReshapeWithTimeWindowOperator
transformation
read
FileReader HBaseFuncAPI HttpClientReader HttpServerReader HttpWeatherClientReader KafkaOnDemandReader KafkaReader MongodbReader MultipleReaders Onem2mHttpReader PhoenixReader PhoenixReaderBySql TableReader AnyJsonFormat DateTimeFormat
reader
component
receive
WeatherRESTClient ServingMaster MlKbServingActor ServingActor
receiver
ingestion
reduction
operator
result
MinMaxScalingOperator
resultDf
WindowedSparkSessionOrStreamController
retry
ServingMaster
round
CalculatorUtils
route
MlKbServingActor ServingActor
rowCountToSend
WindowedSparkSessionOrStreamController
run
KBEServingRunner ServingRunner SimpleSparkRunner TensorflowServingRunner TensorflowRunner
runner
BatchDummyController ExternalAnalysisController KBEServingController ServingWithKbController SparkSessionController SparkSessionOrStreamController SparkStreamController TensorflowServingController WindowedSparkSessionOrStreamController component ingestion