Package spark.serialization
Class BytesSerializer
- java.lang.Object
-
- spark.serialization.Serializer
-
- spark.serialization.BytesSerializer
-
class BytesSerializer extends Serializer
Bytes serializer.
-
-
Constructor Summary
Constructors Constructor Description BytesSerializer()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
canProcess(java.lang.Object element)
Checks if the serializer implementation can process the element type.void
process(java.io.OutputStream outputStream, java.lang.Object element)
Processes the provided element and serializes to output stream.-
Methods inherited from class spark.serialization.Serializer
processElement, setNext
-
-
-
-
Method Detail
-
canProcess
public boolean canProcess(java.lang.Object element)
Description copied from class:Serializer
Checks if the serializer implementation can process the element type.- Specified by:
canProcess
in classSerializer
- Parameters:
element
- the element to process.- Returns:
- true if the serializer can process the provided element.
-
process
public void process(java.io.OutputStream outputStream, java.lang.Object element) throws java.io.IOException
Description copied from class:Serializer
Processes the provided element and serializes to output stream.- Specified by:
process
in classSerializer
- Parameters:
outputStream
- the output stream.element
- the element.- Throws:
java.io.IOException
- In the case of IO error.
-
-