Class InputStreamSerializer

java.lang.Object
spark.serialization.Serializer
spark.serialization.InputStreamSerializer

class InputStreamSerializer extends Serializer
Input stream serializer.
  • 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.