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