BeamEncoderFactory (Nemo Project 0.4 API)

java.lang.Object
- org.apache.nemo.compiler.frontend.beam.coder.BeamEncoderFactory<T>

Type Parameters:

T - the type of element to encode.

All Implemented Interfaces:

java.io.Serializable, EncoderFactory<T>
```
public final class BeamEncoderFactory<T>
extends java.lang.Object
implements EncoderFactory<T>
```
EncoderFactory from Coder.

See Also:

Serialized Form

Nested Class Summary
- Nested classes/interfaces inherited from interface org.apache.nemo.common.coder.EncoderFactory
  EncoderFactory.DummyEncoderFactory, EncoderFactory.Encoder<T>

Field Summary
- Fields inherited from interface org.apache.nemo.common.coder.EncoderFactory
  DUMMY_ENCODER_FACTORY

Constructor Summary

Constructors
Constructor Description

BeamEncoderFactory(org.apache.beam.sdk.coders.Coder<T> beamCoder)
Constructor of BeamEncoderFactory.

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`EncoderFactory.Encoder<T>`	`create(java.io.OutputStream outputStream)`	Get an encoder instance.
`java.lang.String`	`toString()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

- Constructor Detail
  - BeamEncoderFactory
```
public BeamEncoderFactory(org.apache.beam.sdk.coders.Coder<T> beamCoder)
```
    Constructor of BeamEncoderFactory.
    
    Parameters:
    
    beamCoder - actual Beam coder to use.
- Method Detail
  - create
```
public EncoderFactory.Encoder<T> create(java.io.OutputStream outputStream)
```
    Description copied from interface: EncoderFactory
    
    Get an encoder instance.
    
    Specified by:
    
    create in interface EncoderFactory<T>
    
    Parameters:
    
    outputStream - the stream on which encoded bytes are written
    
    Returns:
    
    the encoder instance.
  - toString
```
public java.lang.String toString()
```
    Overrides:
    
    toString in class java.lang.Object