Modifier and Type | Method and Description |
---|---|
SimpleVersionedSerializer<String> |
StreamingFileSinkProgram.KeyBucketAssigner.getSerializer() |
Modifier and Type | Method and Description |
---|---|
SimpleVersionedSerializer<RecoverableWriter.CommitRecoverable> |
RecoverableWriter.getCommitRecoverableSerializer()
The serializer for the CommitRecoverable types created in this writer.
|
SimpleVersionedSerializer<RecoverableWriter.ResumeRecoverable> |
RecoverableWriter.getResumeRecoverableSerializer()
The serializer for the ResumeRecoverable types created in this writer.
|
Modifier and Type | Method and Description |
---|---|
SimpleVersionedSerializer<RecoverableWriter.CommitRecoverable> |
LocalRecoverableWriter.getCommitRecoverableSerializer() |
SimpleVersionedSerializer<RecoverableWriter.ResumeRecoverable> |
LocalRecoverableWriter.getResumeRecoverableSerializer() |
Modifier and Type | Method and Description |
---|---|
static <T> T |
SimpleVersionedSerialization.readVersionAndDeSerialize(SimpleVersionedSerializer<T> serializer,
byte[] bytes)
Deserializes the version and datum from a byte array.
|
static <T> T |
SimpleVersionedSerialization.readVersionAndDeSerialize(SimpleVersionedSerializer<T> serializer,
DataInputView in)
Deserializes the version and datum from a stream.
|
static <T> byte[] |
SimpleVersionedSerialization.writeVersionAndSerialize(SimpleVersionedSerializer<T> serializer,
T datum)
Serializes the version and datum into a byte array.
|
static <T> void |
SimpleVersionedSerialization.writeVersionAndSerialize(SimpleVersionedSerializer<T> serializer,
T datum,
DataOutputView out)
Serializes the version and datum into a stream.
|
Modifier and Type | Method and Description |
---|---|
SimpleVersionedSerializer<RecoverableWriter.CommitRecoverable> |
S3RecoverableWriter.getCommitRecoverableSerializer() |
SimpleVersionedSerializer<RecoverableWriter.ResumeRecoverable> |
S3RecoverableWriter.getResumeRecoverableSerializer() |
Modifier and Type | Method and Description |
---|---|
SimpleVersionedSerializer<T> |
MasterTriggerRestoreHook.createCheckpointDataSerializer()
Creates a the serializer to (de)serializes the data stored by this hook.
|
Modifier and Type | Method and Description |
---|---|
SimpleVersionedSerializer<RecoverableWriter.CommitRecoverable> |
HadoopRecoverableWriter.getCommitRecoverableSerializer() |
SimpleVersionedSerializer<RecoverableWriter.ResumeRecoverable> |
HadoopRecoverableWriter.getResumeRecoverableSerializer() |
Modifier and Type | Method and Description |
---|---|
SimpleVersionedSerializer<String> |
StreamSQLTestProgram.KeyBucketAssigner.getSerializer() |
Modifier and Type | Method and Description |
---|---|
SimpleVersionedSerializer<BucketID> |
BucketAssigner.getSerializer() |
Modifier and Type | Class and Description |
---|---|
class |
SimpleVersionedStringSerializer
A
SimpleVersionedSerializer implementation for Strings. |
Modifier and Type | Method and Description |
---|---|
SimpleVersionedSerializer<String> |
DateTimeBucketAssigner.getSerializer() |
SimpleVersionedSerializer<String> |
BasePathBucketAssigner.getSerializer() |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.