Coder

Coder<T> is an abstraction to define how to encode and decode values of type T into byte streams (similar to Encoder[T] in Spark SQL).

Coder Extensions

Coder Description

CustomCoder

StructuredCoder

encode Method

void encode(
  T value,
  OutputStream outStream)

Encodes the given value to the given OutputStream

decode Method

T decode(
  InputStream inStream)

Decodes a value from the given InputStream