public static final class FileBasedSink.FileResultCoder extends StructuredCoder<FileBasedSink.FileResult>
FileBasedSink.FileResult
objects.Coder.Context, Coder.NonDeterministicException
Modifier | Constructor and Description |
---|---|
protected |
FileResultCoder(Coder<BoundedWindow> windowCoder) |
Modifier and Type | Method and Description |
---|---|
FileBasedSink.FileResult |
decode(java.io.InputStream inStream)
Decodes a value of type
T from the given input stream in
the given context. |
void |
encode(FileBasedSink.FileResult value,
java.io.OutputStream outStream)
Encodes the given value of type
T onto the given output stream. |
java.util.List<? extends Coder<?>> |
getCoderArguments()
|
static FileBasedSink.FileResultCoder |
of(Coder<BoundedWindow> windowCoder) |
void |
verifyDeterministic()
Throw
Coder.NonDeterministicException if the coding is not deterministic. |
consistentWithEquals, equals, getComponents, getEncodedTypeDescriptor, hashCode, structuralValue, toString
decode, encode, getEncodedElementByteSize, isRegisterByteSizeObserverCheap, registerByteSizeObserver, verifyDeterministic, verifyDeterministic
protected FileResultCoder(Coder<BoundedWindow> windowCoder)
public static FileBasedSink.FileResultCoder of(Coder<BoundedWindow> windowCoder)
public java.util.List<? extends Coder<?>> getCoderArguments()
Coder
Coder
for a parameterized type, returns the
list of Coder
s being used for each of the parameters in the same order they appear
within the parameterized type's type signature. If this cannot be done, or this
Coder
does not encode/decode a parameterized type, returns the empty list.getCoderArguments
in class Coder<FileBasedSink.FileResult>
public void encode(FileBasedSink.FileResult value, java.io.OutputStream outStream) throws java.io.IOException
Coder
T
onto the given output stream.encode
in class Coder<FileBasedSink.FileResult>
java.io.IOException
- if writing to the OutputStream
fails
for some reasonCoderException
- if the value could not be encoded for some reasonpublic FileBasedSink.FileResult decode(java.io.InputStream inStream) throws java.io.IOException
Coder
T
from the given input stream in
the given context. Returns the decoded value.decode
in class Coder<FileBasedSink.FileResult>
java.io.IOException
- if reading from the InputStream
fails
for some reasonCoderException
- if the value could not be decoded for some reasonpublic void verifyDeterministic() throws Coder.NonDeterministicException
Coder
Coder.NonDeterministicException
if the coding is not deterministic.
In order for a Coder
to be considered deterministic,
the following must be true:
Object.equals()
or Comparable.compareTo()
, if supported) have the same
encoding.
Coder
always produces a canonical encoding, which is the
same for an instance of an object even if produced on different
computers at different times.
verifyDeterministic
in class Coder<FileBasedSink.FileResult>
Coder.NonDeterministicException
- if this coder is not deterministic.