DirectBatchUnboundedSource.CheckpointCoder

java.lang.Object
- org.apache.beam.sdk.coders.Coder<DirectBatchUnboundedSource.Checkpoint>
- - cz.o2.proxima.beam.core.direct.io.DirectBatchUnboundedSource.CheckpointCoder

All Implemented Interfaces:

java.io.Serializable

Enclosing class:

DirectBatchUnboundedSource
```
public static class DirectBatchUnboundedSource.CheckpointCoder
extends org.apache.beam.sdk.coders.Coder<DirectBatchUnboundedSource.Checkpoint>
```
Use gzip to compress the serialized checkpoint, as it might easily grow in size (batch partitions might contain many files).

See Also:

Serialized Form

Nested Class Summary
- Nested classes/interfaces inherited from class org.apache.beam.sdk.coders.Coder
  org.apache.beam.sdk.coders.Coder.Context, org.apache.beam.sdk.coders.Coder.NonDeterministicException

Constructor Summary

Constructors
Constructor Description

CheckpointCoder()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`DirectBatchUnboundedSource.Checkpoint`	`decode(java.io.InputStream inStream)`
`void`	`encode(DirectBatchUnboundedSource.Checkpoint value, java.io.OutputStream outStream)`
`java.util.List<? extends org.apache.beam.sdk.coders.Coder<?>>`	`getCoderArguments()`
`void`	`verifyDeterministic()`

Methods inherited from class org.apache.beam.sdk.coders.Coder
consistentWithEquals, decode, encode, getEncodedElementByteSize, getEncodedElementByteSizeUsingCoder, getEncodedTypeDescriptor, isRegisterByteSizeObserverCheap, registerByteSizeObserver, structuralValue, verifyDeterministic, verifyDeterministic

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

- Constructor Detail
  - CheckpointCoder
```
public CheckpointCoder()
```
- Method Detail
  - encode
```
public void encode(DirectBatchUnboundedSource.Checkpoint value,
                   java.io.OutputStream outStream)
            throws java.io.IOException
```
    Specified by:
    
    encode in class org.apache.beam.sdk.coders.Coder<DirectBatchUnboundedSource.Checkpoint>
    
    Throws:
    
    java.io.IOException
  - decode
```
public DirectBatchUnboundedSource.Checkpoint decode(java.io.InputStream inStream)
                                             throws java.io.IOException
```
    Specified by:
    
    decode in class org.apache.beam.sdk.coders.Coder<DirectBatchUnboundedSource.Checkpoint>
    
    Throws:
    
    java.io.IOException
  - getCoderArguments
```
public java.util.List<? extends org.apache.beam.sdk.coders.Coder<?>> getCoderArguments()
```
    Specified by:
    
    getCoderArguments in class org.apache.beam.sdk.coders.Coder<DirectBatchUnboundedSource.Checkpoint>
  - verifyDeterministic
```
public void verifyDeterministic()
```
    Specified by:
    
    verifyDeterministic in class org.apache.beam.sdk.coders.Coder<DirectBatchUnboundedSource.Checkpoint>