Package co.cask.cdap.etl.spark.streaming.function

Class Summary

Class	Description
ComputeTransformFunction<T,U>	Function used to implement a SparkCompute stage in a DStream.
CountingTransformFunction<T>	Function used to emit a metric for every item in an RDD.
DynamicAggregatorAggregate<GROUP_KEY,GROUP_VAL,OUT>	Serializable function that can be used to perform the aggregate part of an Aggregator.
DynamicAggregatorGroupBy<GROUP_KEY,GROUP_VAL>	Serializable function that can be used to perform the group by part of an Aggregator.
DynamicJoinMerge<JOIN_KEY,INPUT_RECORD,OUT>	Serializable function that can be used to perform the merge part of a Joiner.
DynamicJoinOn<JOIN_KEY,T>	Serializable function that can be used to perform the joinOn part of a Joiner.
DynamicSparkCompute<T,U>	This class is required to make sure that macro substitution occurs each time a pipeline is run instead of just the first time the pipeline is run.
DynamicTransform<T>	Serializable function that can be used to perform a flat map on a DStream.
StreamingAlertPublishFunction	Function used to publish alerts with a JavaDStream.
StreamingBatchSinkFunction<T>	Function used to write a batch of data to a batch sink for use with a JavaDStream.
StreamingSparkSinkFunction<T>	Function used to write a batch of data to a SparkSink for use with a JavaDStream.
WrapOutputTransformFunction<T>	Simply wraps all elements into a non-error, non-port RecordInfo.