DefaultDecoder Class

On This Page
Fully Qualified Name

io.iguaz.v3io.spark.streaming.Decoder.DefaultDecoder

Description

A class for defining a Decoder object that returns the input byte array without changes.

Summary

Instance Constructors

class DefaultDecoder(config: Option[Properties] = None)
    extends Decoder[Array[Byte]]
Methods
  • fromBytes

    def fromBytes(bytes: Array[Byte])(
        implicit encoding: Option[Properties] => Charset)
        : Array[Byte]
    

Instance Constructors

Syntax

new DefaultDecoder(config: Option[Properties])

Parameters and Data Members

config

Optional properties. The class implementation ignores this parameter.

  • Type: Option[Properties]
  • Requirement: Optional (ignored)

fromBytes Method

Returns the input byte array without changes.

Syntax

fromBytes(bytes: Array[Byte])(
    implicit encoding: Option[Properties] => Charset)
    : Array[Byte]

Parameters

bytes

The byte array to return.

  • Type: Array[Bytes]
  • Requirement: Required
encoding

An implicit function that returns a character encoding.
The class implementation ignores this parameter.

  • Type: encoding: Option[Properties] => Charset)
  • Requirement: Implicit (ignored)

Return Value

Returns the input byte array without changes.