Class 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
-
-
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()
-
-
-
Method Detail
-
encode
public void encode(DirectBatchUnboundedSource.Checkpoint value, java.io.OutputStream outStream) throws java.io.IOException
- Specified by:
encode
in classorg.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 classorg.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 classorg.apache.beam.sdk.coders.Coder<DirectBatchUnboundedSource.Checkpoint>
-
verifyDeterministic
public void verifyDeterministic()
- Specified by:
verifyDeterministic
in classorg.apache.beam.sdk.coders.Coder<DirectBatchUnboundedSource.Checkpoint>
-
-