Package spark.serialization

Class InputStreamSerializer

java.lang.Object

spark.serialization.Serializer

spark.serialization.InputStreamSerializer

class InputStreamSerializer
extends Serializer

Input stream serializer.

Constructor Summary

Constructors

Constructor	Description
InputStreamSerializer()

Method Summary

Modifier and Type	Method	Description
boolean	canProcess(Object element)	Checks if the serializer implementation can process the element type.
void	process(OutputStream outputStream, Object element)	Processes the provided element and serializes to output stream.

Methods inherited from class spark.serialization.Serializer

processElement, setNext

Methods inherited from class java.lang.Object

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

Constructor Details

InputStreamSerializer

InputStreamSerializer()

Method Details

canProcess

public boolean canProcess(Object element)

Description copied from class: Serializer

Checks if the serializer implementation can process the element type.

Specified by:

canProcess in class Serializer

Parameters:

element - the element to process.

Returns:

true if the serializer can process the provided element.

process

public void process(OutputStream outputStream,
 Object element)
             throws IOException

Description copied from class: Serializer

Processes the provided element and serializes to output stream.

Specified by:

process in class Serializer

Parameters:

outputStream - the output stream.

element - the element.

Throws:

IOException - In the case of IO error.