Modifier and Type | Method and Description |
---|---|
protected void |
SerializedOutputFormat.serialize(T record,
DataOutputView dataOutputView) |
protected abstract void |
BinaryOutputFormat.serialize(T record,
DataOutputView dataOutput) |
void |
BlockInfo.write(DataOutputView out) |
Modifier and Type | Method and Description |
---|---|
void |
CompositeSerializer.copy(DataInputView source,
DataOutputView target) |
void |
TypeDeserializerAdapter.copy(DataInputView source,
DataOutputView target) |
void |
UnloadableDummyTypeSerializer.copy(DataInputView source,
DataOutputView target) |
abstract void |
TypeSerializer.copy(DataInputView source,
DataOutputView target)
Copies exactly one record from the source input view to the target output view.
|
void |
CompositeSerializer.serialize(T record,
DataOutputView target) |
void |
TypeDeserializerAdapter.serialize(T record,
DataOutputView target) |
void |
UnloadableDummyTypeSerializer.serialize(T record,
DataOutputView target) |
abstract void |
TypeSerializer.serialize(T record,
DataOutputView target)
Serializes the given record to the given target output view.
|
void |
CompositeTypeSerializerConfigSnapshot.write(DataOutputView out) |
void |
TypeSerializerSerializationUtil.TypeSerializerSerializationProxy.write(DataOutputView out) |
void |
ParameterlessTypeSerializerConfig.write(DataOutputView out) |
void |
GenericTypeSerializerConfigSnapshot.write(DataOutputView out) |
static <T> void |
TypeSerializerSerializationUtil.writeSerializer(DataOutputView out,
TypeSerializer<T> serializer)
Writes a
TypeSerializer to the provided data output view. |
static void |
TypeSerializerSerializationUtil.writeSerializerConfigSnapshot(DataOutputView out,
TypeSerializerConfigSnapshot serializerConfigSnapshot)
Writes a
TypeSerializerConfigSnapshot to the provided data output view. |
static void |
TypeSerializerSerializationUtil.writeSerializerConfigSnapshots(DataOutputView out,
TypeSerializerConfigSnapshot... serializerConfigSnapshots)
Writes multiple
TypeSerializerConfigSnapshot s to the provided data output view. |
static void |
TypeSerializerSerializationUtil.writeSerializersAndConfigsWithResilience(DataOutputView out,
List<Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> serializersAndConfigs)
Write a list of serializers and their corresponding config snapshots to the provided
data output view.
|
abstract void |
TypeComparator.writeWithKeyNormalization(T record,
DataOutputView target)
Writes the record in such a fashion that all keys are normalizing and at the beginning of the serialized data.
|
Modifier and Type | Method and Description |
---|---|
void |
DoubleSerializer.copy(DataInputView source,
DataOutputView target) |
void |
SqlTimestampSerializer.copy(DataInputView source,
DataOutputView target) |
void |
BigIntSerializer.copy(DataInputView source,
DataOutputView target) |
void |
GenericArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
VoidSerializer.copy(DataInputView source,
DataOutputView target) |
void |
BooleanValueSerializer.copy(DataInputView source,
DataOutputView target) |
void |
ShortValueSerializer.copy(DataInputView source,
DataOutputView target) |
void |
DoubleValueSerializer.copy(DataInputView source,
DataOutputView target) |
void |
IntSerializer.copy(DataInputView source,
DataOutputView target) |
void |
SqlTimeSerializer.copy(DataInputView source,
DataOutputView target) |
void |
MapSerializer.copy(DataInputView source,
DataOutputView target) |
void |
SqlDateSerializer.copy(DataInputView source,
DataOutputView target) |
void |
ListSerializer.copy(DataInputView source,
DataOutputView target) |
void |
ShortSerializer.copy(DataInputView source,
DataOutputView target) |
void |
IntValueSerializer.copy(DataInputView source,
DataOutputView target) |
void |
BooleanSerializer.copy(DataInputView source,
DataOutputView target) |
void |
CharValueSerializer.copy(DataInputView source,
DataOutputView target) |
void |
ByteSerializer.copy(DataInputView source,
DataOutputView target) |
void |
StringSerializer.copy(DataInputView source,
DataOutputView target) |
void |
FloatSerializer.copy(DataInputView source,
DataOutputView target) |
void |
LongSerializer.copy(DataInputView source,
DataOutputView target) |
void |
LongValueSerializer.copy(DataInputView source,
DataOutputView target) |
void |
DateSerializer.copy(DataInputView source,
DataOutputView target) |
void |
BigDecSerializer.copy(DataInputView source,
DataOutputView target) |
void |
EnumSerializer.copy(DataInputView source,
DataOutputView target) |
void |
FloatValueSerializer.copy(DataInputView source,
DataOutputView target) |
void |
StringValueSerializer.copy(DataInputView source,
DataOutputView target) |
void |
CharSerializer.copy(DataInputView source,
DataOutputView target) |
void |
NullValueSerializer.copy(DataInputView source,
DataOutputView target) |
void |
ByteValueSerializer.copy(DataInputView source,
DataOutputView target) |
static boolean |
BigIntSerializer.copyBigInteger(DataInputView source,
DataOutputView target) |
void |
BigDecSerializer.serialize(BigDecimal record,
DataOutputView target) |
void |
BigIntSerializer.serialize(BigInteger record,
DataOutputView target) |
void |
BooleanSerializer.serialize(Boolean record,
DataOutputView target) |
void |
BooleanValueSerializer.serialize(BooleanValue record,
DataOutputView target) |
void |
ByteSerializer.serialize(Byte record,
DataOutputView target) |
void |
ByteValueSerializer.serialize(ByteValue record,
DataOutputView target) |
void |
GenericArraySerializer.serialize(C[] value,
DataOutputView target) |
void |
CharSerializer.serialize(Character record,
DataOutputView target) |
void |
CharValueSerializer.serialize(CharValue record,
DataOutputView target) |
void |
SqlDateSerializer.serialize(Date record,
DataOutputView target) |
void |
DateSerializer.serialize(Date record,
DataOutputView target) |
void |
DoubleSerializer.serialize(Double record,
DataOutputView target) |
void |
DoubleValueSerializer.serialize(DoubleValue record,
DataOutputView target) |
void |
FloatSerializer.serialize(Float record,
DataOutputView target) |
void |
FloatValueSerializer.serialize(FloatValue record,
DataOutputView target) |
void |
IntSerializer.serialize(Integer record,
DataOutputView target) |
void |
IntValueSerializer.serialize(IntValue record,
DataOutputView target) |
void |
ListSerializer.serialize(List<T> list,
DataOutputView target) |
void |
LongSerializer.serialize(Long record,
DataOutputView target) |
void |
LongValueSerializer.serialize(LongValue record,
DataOutputView target) |
void |
MapSerializer.serialize(Map<K,V> map,
DataOutputView target) |
void |
NullValueSerializer.serialize(NullValue record,
DataOutputView target) |
void |
ShortSerializer.serialize(Short record,
DataOutputView target) |
void |
ShortValueSerializer.serialize(ShortValue record,
DataOutputView target) |
void |
StringSerializer.serialize(String record,
DataOutputView target) |
void |
StringValueSerializer.serialize(StringValue record,
DataOutputView target) |
void |
EnumSerializer.serialize(T record,
DataOutputView target) |
void |
SqlTimeSerializer.serialize(Time record,
DataOutputView target) |
void |
SqlTimestampSerializer.serialize(Timestamp record,
DataOutputView target) |
void |
VoidSerializer.serialize(Void record,
DataOutputView target) |
void |
GenericArraySerializerConfigSnapshot.write(DataOutputView out) |
void |
EnumSerializer.EnumSerializerConfigSnapshot.write(DataOutputView out) |
static void |
BigIntSerializer.writeBigInteger(BigInteger record,
DataOutputView target) |
void |
BooleanValueComparator.writeWithKeyNormalization(BooleanValue record,
DataOutputView target) |
void |
ByteValueComparator.writeWithKeyNormalization(ByteValue record,
DataOutputView target) |
void |
CharValueComparator.writeWithKeyNormalization(CharValue record,
DataOutputView target) |
void |
DoubleValueComparator.writeWithKeyNormalization(DoubleValue record,
DataOutputView target) |
void |
FloatValueComparator.writeWithKeyNormalization(FloatValue record,
DataOutputView target) |
void |
IntValueComparator.writeWithKeyNormalization(IntValue record,
DataOutputView target) |
void |
LongValueComparator.writeWithKeyNormalization(LongValue record,
DataOutputView target) |
void |
NullValueComparator.writeWithKeyNormalization(NullValue record,
DataOutputView target) |
void |
ShortValueComparator.writeWithKeyNormalization(ShortValue record,
DataOutputView target) |
void |
StringValueComparator.writeWithKeyNormalization(StringValue record,
DataOutputView target) |
void |
BasicTypeComparator.writeWithKeyNormalization(T record,
DataOutputView target) |
Modifier and Type | Method and Description |
---|---|
void |
CharPrimitiveArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
DoublePrimitiveArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
BytePrimitiveArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
StringArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
ShortPrimitiveArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
BooleanPrimitiveArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
FloatPrimitiveArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
LongPrimitiveArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
IntPrimitiveArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
BooleanPrimitiveArraySerializer.serialize(boolean[] record,
DataOutputView target) |
void |
BytePrimitiveArraySerializer.serialize(byte[] record,
DataOutputView target) |
void |
CharPrimitiveArraySerializer.serialize(char[] record,
DataOutputView target) |
void |
DoublePrimitiveArraySerializer.serialize(double[] record,
DataOutputView target) |
void |
FloatPrimitiveArraySerializer.serialize(float[] record,
DataOutputView target) |
void |
IntPrimitiveArraySerializer.serialize(int[] record,
DataOutputView target) |
void |
LongPrimitiveArraySerializer.serialize(long[] record,
DataOutputView target) |
void |
ShortPrimitiveArraySerializer.serialize(short[] record,
DataOutputView target) |
void |
StringArraySerializer.serialize(String[] record,
DataOutputView target) |
void |
PrimitiveArrayComparator.writeWithKeyNormalization(T record,
DataOutputView target) |
Modifier and Type | Method and Description |
---|---|
protected void |
TypeSerializerOutputFormat.serialize(T record,
DataOutputView dataOutput) |
Modifier and Type | Field and Description |
---|---|
protected DataOutputView |
DataOutputViewStream.outputView |
Modifier and Type | Method and Description |
---|---|
void |
AvroSerializer.copy(DataInputView source,
DataOutputView target)
Deprecated.
|
void |
WritableSerializer.copy(DataInputView source,
DataOutputView target) |
void |
ValueSerializer.copy(DataInputView source,
DataOutputView target) |
void |
EitherSerializer.copy(DataInputView source,
DataOutputView target) |
void |
CopyableValueSerializer.copy(DataInputView source,
DataOutputView target) |
void |
NullableSerializer.copy(DataInputView source,
DataOutputView target) |
void |
TupleSerializerBase.copy(DataInputView source,
DataOutputView target) |
void |
Tuple0Serializer.copy(DataInputView source,
DataOutputView target) |
void |
RowSerializer.copy(DataInputView source,
DataOutputView target) |
void |
PojoSerializer.copy(DataInputView source,
DataOutputView target) |
static void |
NullMaskUtils.readIntoAndCopyNullMask(int len,
DataInputView source,
DataOutputView target,
boolean[] nullMask) |
void |
EitherSerializer.serialize(Either<L,R> record,
DataOutputView target) |
void |
RowSerializer.serialize(Row record,
DataOutputView target) |
void |
AvroSerializer.serialize(T value,
DataOutputView target)
Deprecated.
|
void |
WritableSerializer.serialize(T record,
DataOutputView target) |
void |
ValueSerializer.serialize(T value,
DataOutputView target) |
void |
CopyableValueSerializer.serialize(T value,
DataOutputView target) |
void |
NullableSerializer.serialize(T record,
DataOutputView target) |
void |
TupleSerializer.serialize(T value,
DataOutputView target) |
void |
PojoSerializer.serialize(T value,
DataOutputView target) |
void |
Tuple0Serializer.serialize(Tuple0 record,
DataOutputView target) |
void |
AvroSerializer.AvroSerializerConfigSnapshot.write(DataOutputView out) |
void |
TupleSerializerConfigSnapshot.write(DataOutputView out) |
void |
PojoSerializer.PojoSerializerConfigSnapshot.write(DataOutputView out) |
void |
KryoRegistrationSerializerConfigSnapshot.write(DataOutputView out) |
static void |
NullMaskUtils.writeNullMask(int len,
Row value,
DataOutputView target) |
void |
RowComparator.writeWithKeyNormalization(Row record,
DataOutputView target) |
void |
WritableComparator.writeWithKeyNormalization(T record,
DataOutputView target) |
void |
ValueComparator.writeWithKeyNormalization(T record,
DataOutputView target) |
void |
PojoComparator.writeWithKeyNormalization(T record,
DataOutputView target) |
void |
TupleComparatorBase.writeWithKeyNormalization(T record,
DataOutputView target) |
void |
NullAwareComparator.writeWithKeyNormalization(T record,
DataOutputView target) |
void |
GenericTypeComparator.writeWithKeyNormalization(T record,
DataOutputView target) |
void |
CopyableValueComparator.writeWithKeyNormalization(T record,
DataOutputView target) |
Constructor and Description |
---|
DataOutputViewStream(DataOutputView outputView) |
Modifier and Type | Method and Description |
---|---|
void |
KryoSerializer.copy(DataInputView source,
DataOutputView target) |
void |
KryoSerializer.serialize(T record,
DataOutputView target) |
Modifier and Type | Method and Description |
---|---|
void |
NFA.NFASerializer.copy(DataInputView source,
DataOutputView target)
Deprecated.
|
void |
DeweyNumber.DeweyNumberSerializer.copy(DataInputView source,
DataOutputView target) |
void |
SharedBuffer.SharedBufferSerializer.copy(DataInputView source,
DataOutputView target) |
void |
NFAStateSerializer.copy(DataInputView source,
DataOutputView target) |
void |
DeweyNumber.DeweyNumberSerializer.serialize(DeweyNumber record,
DataOutputView target) |
void |
NFA.NFASerializer.serialize(NFA.MigratedNFA<T> record,
DataOutputView target)
Deprecated.
|
void |
NFAStateSerializer.serialize(NFAState record,
DataOutputView target) |
void |
SharedBuffer.SharedBufferSerializer.serialize(SharedBuffer<V> record,
DataOutputView target) |
Modifier and Type | Method and Description |
---|---|
void |
EventId.EventIdSerializer.copy(DataInputView source,
DataOutputView target) |
void |
Lockable.LockableTypeSerializer.copy(DataInputView source,
DataOutputView target) |
void |
NodeId.NodeIdSerializer.copy(DataInputView source,
DataOutputView target) |
void |
SharedBufferEdge.SharedBufferEdgeSerializer.copy(DataInputView source,
DataOutputView target) |
void |
SharedBufferNode.SharedBufferNodeSerializer.copy(DataInputView source,
DataOutputView target) |
void |
EventId.EventIdSerializer.serialize(EventId record,
DataOutputView target) |
void |
Lockable.LockableTypeSerializer.serialize(Lockable<E> record,
DataOutputView target) |
void |
NodeId.NodeIdSerializer.serialize(NodeId record,
DataOutputView target) |
void |
SharedBufferEdge.SharedBufferEdgeSerializer.serialize(SharedBufferEdge record,
DataOutputView target) |
void |
SharedBufferNode.SharedBufferNodeSerializer.serialize(SharedBufferNode record,
DataOutputView target) |
Modifier and Type | Method and Description |
---|---|
void |
DelegatingConfiguration.write(DataOutputView out) |
void |
Configuration.write(DataOutputView out) |
Modifier and Type | Field and Description |
---|---|
protected DataOutputView |
AbstractRocksDBState.keySerializationDataOutputView |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractRocksDBState.writeKeyWithGroupAndNamespace(int keyGroup,
K key,
N namespace,
ByteArrayOutputStreamWithPos keySerializationStream,
DataOutputView keySerializationDataOutputView) |
protected void |
AbstractRocksDBState.writeKeyWithGroupAndNamespace(int keyGroup,
K key,
TypeSerializer<K> keySerializer,
N namespace,
TypeSerializer<N> namespaceSerializer,
ByteArrayOutputStreamWithPos keySerializationStream,
DataOutputView keySerializationDataOutputView) |
Modifier and Type | Method and Description |
---|---|
void |
Path.write(DataOutputView out) |
Modifier and Type | Method and Description |
---|---|
void |
IOReadableWritable.write(DataOutputView out)
Writes the object's internal data to the given data output view.
|
void |
PostVersionedIOReadableWritable.write(DataOutputView out) |
void |
VersionedIOReadableWritable.write(DataOutputView out) |
static <T> void |
SimpleVersionedSerialization.writeVersionAndSerialize(SimpleVersionedSerializer<T> serializer,
T datum,
DataOutputView out)
Serializes the version and datum into a stream.
|
Modifier and Type | Interface and Description |
---|---|
interface |
SeekableDataOutputView
Interface marking a
DataOutputView as seekable. |
Modifier and Type | Class and Description |
---|---|
class |
ByteArrayDataOutputView
Adapter to
DataOutputView that operates on a byte-array and offers read/write access to the current position. |
class |
DataOutputSerializer
A simple and efficient serializer for the
DataOutput interface. |
class |
DataOutputViewStreamWrapper
Utility class that turns an
OutputStream into a DataOutputView . |
Modifier and Type | Method and Description |
---|---|
void |
BackwardsCompatibleAvroSerializer.copy(DataInputView source,
DataOutputView target) |
void |
AvroSerializer.copy(DataInputView source,
DataOutputView target) |
void |
BackwardsCompatibleAvroSerializer.serialize(T value,
DataOutputView target) |
void |
AvroSerializer.serialize(T value,
DataOutputView target) |
void |
AvroSerializer.AvroSchemaSerializerConfigSnapshot.write(DataOutputView out) |
void |
AvroSerializer.AvroSerializerConfigSnapshot.write(DataOutputView out)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
LongValueWithProperHashCode.LongValueWithProperHashCodeSerializer.copy(DataInputView source,
DataOutputView target) |
void |
LongValueWithProperHashCode.LongValueWithProperHashCodeSerializer.serialize(LongValueWithProperHashCode record,
DataOutputView target) |
Modifier and Type | Method and Description |
---|---|
void |
LongValueArray.copy(DataInputView source,
DataOutputView target) |
void |
NullValueArray.copy(DataInputView source,
DataOutputView target) |
void |
ByteValueArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
NullValueArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
StringValueArray.copy(DataInputView source,
DataOutputView target) |
void |
CharValueArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
DoubleValueArray.copy(DataInputView source,
DataOutputView target) |
void |
FloatValueArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
ByteValueArray.copy(DataInputView source,
DataOutputView target) |
void |
IntValueArray.copy(DataInputView source,
DataOutputView target) |
void |
FloatValueArray.copy(DataInputView source,
DataOutputView target) |
void |
LongValueArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
IntValueArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
DoubleValueArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
CharValueArray.copy(DataInputView source,
DataOutputView target) |
void |
ShortValueArray.copy(DataInputView source,
DataOutputView target) |
void |
ShortValueArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
StringValueArraySerializer.copy(DataInputView source,
DataOutputView target) |
protected static void |
LongValueArray.copyInternal(DataInputView source,
DataOutputView target) |
protected static void |
StringValueArray.copyInternal(DataInputView source,
DataOutputView target) |
protected static void |
DoubleValueArray.copyInternal(DataInputView source,
DataOutputView target) |
protected static void |
ByteValueArray.copyInternal(DataInputView source,
DataOutputView target) |
protected static void |
IntValueArray.copyInternal(DataInputView source,
DataOutputView target) |
protected static void |
FloatValueArray.copyInternal(DataInputView source,
DataOutputView target) |
protected static void |
CharValueArray.copyInternal(DataInputView source,
DataOutputView target) |
protected static void |
ShortValueArray.copyInternal(DataInputView source,
DataOutputView target) |
void |
ByteValueArraySerializer.serialize(ByteValueArray record,
DataOutputView target) |
void |
CharValueArraySerializer.serialize(CharValueArray record,
DataOutputView target) |
void |
DoubleValueArraySerializer.serialize(DoubleValueArray record,
DataOutputView target) |
void |
FloatValueArraySerializer.serialize(FloatValueArray record,
DataOutputView target) |
void |
IntValueArraySerializer.serialize(IntValueArray record,
DataOutputView target) |
void |
LongValueArraySerializer.serialize(LongValueArray record,
DataOutputView target) |
void |
NullValueArraySerializer.serialize(NullValueArray record,
DataOutputView target) |
void |
ShortValueArraySerializer.serialize(ShortValueArray record,
DataOutputView target) |
void |
StringValueArraySerializer.serialize(StringValueArray record,
DataOutputView target) |
void |
LongValueArray.write(DataOutputView out) |
void |
NullValueArray.write(DataOutputView out) |
void |
StringValueArray.write(DataOutputView out) |
void |
DoubleValueArray.write(DataOutputView out) |
void |
ByteValueArray.write(DataOutputView out) |
void |
IntValueArray.write(DataOutputView out) |
void |
FloatValueArray.write(DataOutputView out) |
void |
CharValueArray.write(DataOutputView out) |
void |
ShortValueArray.write(DataOutputView out) |
void |
ByteValueArrayComparator.writeWithKeyNormalization(ByteValueArray record,
DataOutputView target) |
void |
CharValueArrayComparator.writeWithKeyNormalization(CharValueArray record,
DataOutputView target) |
void |
DoubleValueArrayComparator.writeWithKeyNormalization(DoubleValueArray record,
DataOutputView target) |
void |
FloatValueArrayComparator.writeWithKeyNormalization(FloatValueArray record,
DataOutputView target) |
void |
IntValueArrayComparator.writeWithKeyNormalization(IntValueArray record,
DataOutputView target) |
void |
LongValueArrayComparator.writeWithKeyNormalization(LongValueArray record,
DataOutputView target) |
void |
NullValueArrayComparator.writeWithKeyNormalization(NullValueArray record,
DataOutputView target) |
void |
ShortValueArrayComparator.writeWithKeyNormalization(ShortValueArray record,
DataOutputView target) |
void |
StringValueArrayComparator.writeWithKeyNormalization(StringValueArray record,
DataOutputView target) |
Modifier and Type | Method and Description |
---|---|
void |
VoidNamespaceSerializer.copy(DataInputView source,
DataOutputView target) |
void |
VoidNamespaceSerializer.serialize(VoidNamespace record,
DataOutputView target) |
Modifier and Type | Class and Description |
---|---|
class |
FileChannelOutputView
A
DataOutputView that is backed by a BlockChannelWriter , making it effectively a data output
stream. |
class |
RandomAccessOutputView |
class |
SimpleCollectingOutputView
The list with the full segments contains at any point all completely full segments, plus the segment that is
currently filled.
|
class |
SpillingBuffer
An output view that buffers written data in memory pages and spills them when they are full.
|
Modifier and Type | Class and Description |
---|---|
class |
ChannelWriterOutputView
A
DataOutputView that is backed by a
BlockChannelWriter , making it effectively a data output
stream. |
Modifier and Type | Method and Description |
---|---|
void |
CheckpointBarrier.write(DataOutputView out) |
void |
CancelCheckpointMarker.write(DataOutputView out) |
void |
EndOfPartitionEvent.write(DataOutputView out) |
void |
EndOfSuperstepEvent.write(DataOutputView out) |
Modifier and Type | Method and Description |
---|---|
DataOutputView |
BlockingBackChannel.getWriteEnd()
Called by iteration tail to save the output of the current superstep.
|
Modifier and Type | Method and Description |
---|---|
void |
WorkerDoneEvent.write(DataOutputView out) |
void |
IterationEventWithAggregators.write(DataOutputView out) |
void |
TerminationEvent.write(DataOutputView out) |
Modifier and Type | Class and Description |
---|---|
class |
SerializedUpdateBuffer
AbstractPagedOutputView used by the BlockingBackChannel for
transmitting superstep results. |
Constructor and Description |
---|
WorksetUpdateOutputCollector(DataOutputView outputView,
TypeSerializer<T> serializer) |
WorksetUpdateOutputCollector(DataOutputView outputView,
TypeSerializer<T> serializer,
Collector<T> delegate) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractPagedOutputView
The base class for all output views that are backed by multiple memory pages.
|
Modifier and Type | Class and Description |
---|---|
protected static class |
HashPartition.BuildSideBuffer |
Modifier and Type | Method and Description |
---|---|
void |
ReusingDeserializationDelegate.write(DataOutputView out) |
void |
SerializationDelegate.write(DataOutputView out) |
void |
NonReusingDeserializationDelegate.write(DataOutputView out) |
Modifier and Type | Method and Description |
---|---|
void |
VoidNamespaceSerializer.copy(DataInputView source,
DataOutputView target) |
void |
ArrayListSerializer.copy(DataInputView source,
DataOutputView target) |
void |
ArrayListSerializer.serialize(ArrayList<T> list,
DataOutputView target) |
void |
VoidNamespaceSerializer.serialize(VoidNamespace record,
DataOutputView target) |
void |
KeyedBackendSerializationProxy.write(DataOutputView out) |
void |
OperatorBackendSerializationProxy.write(DataOutputView out) |
void |
KeyGroupPartitioner.ElementWriterFunction.writeElement(T element,
DataOutputView dov)
This method defines how to write a single element to the output.
|
void |
StateSnapshot.StateKeyGroupWriter.writeStateInKeyGroup(DataOutputView dov,
int keyGroupId)
Writes the data for the specified key-group to the output.
|
Modifier and Type | Method and Description |
---|---|
void |
StateMetaInfoWriter.writeStateMetaInfoSnapshot(StateMetaInfoSnapshot snapshot,
DataOutputView outputView)
Writes the given snapshot to the output view.
|
Modifier and Type | Method and Description |
---|---|
void |
TwoPhaseCommitSinkFunction.StateSerializer.copy(DataInputView source,
DataOutputView target) |
void |
TwoPhaseCommitSinkFunction.StateSerializer.serialize(TwoPhaseCommitSinkFunction.State<TXN,CONTEXT> record,
DataOutputView target) |
Modifier and Type | Method and Description |
---|---|
void |
TimerSerializer.copy(DataInputView source,
DataOutputView target) |
void |
InternalTimersSnapshotReaderWriters.LegacyTimerSerializer.copy(DataInputView source,
DataOutputView target) |
void |
TimerSerializer.serialize(TimerHeapInternalTimer<K,N> record,
DataOutputView target) |
void |
InternalTimersSnapshotReaderWriters.LegacyTimerSerializer.serialize(TimerHeapInternalTimer<K,N> record,
DataOutputView target) |
void |
InternalTimeServiceManager.snapshotStateForKeyGroup(DataOutputView stream,
int keyGroupIdx) |
void |
InternalTimerServiceSerializationProxy.write(DataOutputView out) |
void |
InternalTimersSnapshotReaderWriters.InternalTimersSnapshotWriter.writeTimersSnapshot(DataOutputView out)
Writes the timers snapshot to the output view.
|
Modifier and Type | Method and Description |
---|---|
void |
TimeWindow.Serializer.copy(DataInputView source,
DataOutputView target) |
void |
GlobalWindow.Serializer.copy(DataInputView source,
DataOutputView target) |
void |
GlobalWindow.Serializer.serialize(GlobalWindow record,
DataOutputView target) |
void |
TimeWindow.Serializer.serialize(TimeWindow record,
DataOutputView target) |
Modifier and Type | Method and Description |
---|---|
void |
FlinkKafkaProducer011.TransactionStateSerializer.copy(DataInputView source,
DataOutputView target) |
void |
FlinkKafkaProducer011.ContextStateSerializer.copy(DataInputView source,
DataOutputView target) |
void |
FlinkKafkaProducer011.ContextStateSerializer.serialize(FlinkKafkaProducer011.KafkaTransactionContext record,
DataOutputView target) |
void |
FlinkKafkaProducer011.TransactionStateSerializer.serialize(org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer011.KafkaTransactionState record,
DataOutputView target) |
Modifier and Type | Method and Description |
---|---|
void |
StreamElementSerializer.copy(DataInputView source,
DataOutputView target) |
void |
StreamElementSerializer.serialize(StreamElement value,
DataOutputView target) |
Modifier and Type | Method and Description |
---|---|
void |
ByteValue.copy(DataInputView source,
DataOutputView target) |
void |
StringValue.copy(DataInputView in,
DataOutputView target) |
void |
NullValue.copy(DataInputView source,
DataOutputView target) |
void |
IntValue.copy(DataInputView source,
DataOutputView target) |
void |
Record.copy(DataInputView source,
DataOutputView target) |
void |
FloatValue.copy(DataInputView source,
DataOutputView target) |
void |
BooleanValue.copy(DataInputView source,
DataOutputView target) |
void |
ShortValue.copy(DataInputView source,
DataOutputView target) |
void |
CopyableValue.copy(DataInputView source,
DataOutputView target)
Copies the next serialized instance from
source to target . |
void |
CharValue.copy(DataInputView source,
DataOutputView target) |
void |
DoubleValue.copy(DataInputView source,
DataOutputView target) |
void |
LongValue.copy(DataInputView source,
DataOutputView target) |
long |
Record.serialize(DataOutputView target)
Writes this record to the given output view.
|
void |
ByteValue.write(DataOutputView out) |
void |
StringValue.write(DataOutputView out) |
void |
NullValue.write(DataOutputView out) |
void |
IntValue.write(DataOutputView out) |
void |
Record.write(DataOutputView out) |
void |
ListValue.write(DataOutputView out) |
void |
FloatValue.write(DataOutputView out) |
void |
BooleanValue.write(DataOutputView out) |
void |
ShortValue.write(DataOutputView out) |
void |
CharValue.write(DataOutputView out) |
void |
DoubleValue.write(DataOutputView out) |
void |
MapValue.write(DataOutputView out) |
void |
LongValue.write(DataOutputView out) |
Modifier and Type | Method and Description |
---|---|
static void |
StringUtils.writeNullableString(String str,
DataOutputView out)
Writes a String to the given output.
|
static void |
StringUtils.writeString(String str,
DataOutputView out)
Writes a String to the given output.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.