oracle.ord.spark.streaming

Class OrdSparkFrameProcessor

java.lang.Object

oracle.ord.spark.streaming.OrdSparkFrameProcessor

public abstract class OrdSparkFrameProcessor
extends java.lang.Object

OrdSparkFrameProcessor is an abstract class which allows processing video frames in a flat map function in Spark. Implementation must be threadsafe!

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.Properties	m_props

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	OrdSparkFrameProcessor(java.util.Properties props) Create an OrdSparkFrameProcessor object that processes video frames in a flat map function in Spark.

Method Summary

Modifier and Type	Method and Description
protected void	close() Close the OrdSparkFrameProcessor object, releasing any resources being used.
protected void	finalize()
abstract java.lang.Iterable<scala.Tuple2<org.apache.hadoop.io.Text,oracle.ord.hadoop.mapreduce.OrdImageWritable>>	processFrame(scala.Tuple2<org.apache.hadoop.io.Text,oracle.ord.hadoop.mapreduce.OrdImageWritable> tuple) Processes the tuple of Text and OrdImageWritable in a flat map function in Spark.

Methods inherited from class java.lang.Object

clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

m_props

protected final java.util.Properties m_props

Constructor Detail

OrdSparkFrameProcessor

protected OrdSparkFrameProcessor(java.util.Properties props)

Create an OrdSparkFrameProcessor object that processes video frames in a flat map function in Spark.

Parameters:

props - A java Properties object that contains all the properties set in SparkConf

Method Detail

processFrame

public abstract java.lang.Iterable<scala.Tuple2<org.apache.hadoop.io.Text,oracle.ord.hadoop.mapreduce.OrdImageWritable>> processFrame(scala.Tuple2<org.apache.hadoop.io.Text,oracle.ord.hadoop.mapreduce.OrdImageWritable> tuple)

Processes the tuple of Text and OrdImageWritable in a flat map function in Spark.

Parameters:

tuple - The pair of Text and OrdImageWritable, which includes text information and image information for a frame.

Returns:

the processed tuple

close

protected void close()

Close the OrdSparkFrameProcessor object, releasing any resources being used.

finalize

protected void finalize()

Overrides:

finalize in class java.lang.Object