Uses of Interface
org.apache.flink.core.memory.DataOutputView

Packages that use DataOutputView

Package	Description
org.apache.flink.api.common.io
org.apache.flink.api.common.typeutils
org.apache.flink.api.common.typeutils.base
org.apache.flink.api.common.typeutils.base.array
org.apache.flink.api.java.typeutils.runtime
org.apache.flink.api.java.typeutils.runtime.kryo
org.apache.flink.configuration
org.apache.flink.core.fs
org.apache.flink.core.io
org.apache.flink.core.memory
org.apache.flink.types
org.apache.flink.util

Uses of DataOutputView in org.apache.flink.api.common.io

Methods in org.apache.flink.api.common.io with parameters of type DataOutputView

Modifier and Type	Method	Description
protected abstract void	BinaryOutputFormat.serialize(T record, DataOutputView dataOutput)
protected void	SerializedOutputFormat.serialize(T record, DataOutputView dataOutputView)
void	BlockInfo.write(DataOutputView out)

Uses of DataOutputView in org.apache.flink.api.common.typeutils

Methods in org.apache.flink.api.common.typeutils with parameters of type DataOutputView

Modifier and Type	Method	Description
void	CompositeSerializer.copy(DataInputView source, DataOutputView target)
void	SingleThreadAccessCheckingTypeSerializer.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	UnloadableDummyTypeSerializer.copy(DataInputView source, DataOutputView target)
void	CompositeSerializer.serialize(T record, DataOutputView target)
void	SingleThreadAccessCheckingTypeSerializer.serialize(T record, DataOutputView target)
abstract void	TypeSerializer.serialize(T record, DataOutputView target)	Serializes the given record to the given target output view.
void	UnloadableDummyTypeSerializer.serialize(T record, DataOutputView target)
void	NestedSerializersSnapshotDelegate.writeNestedSerializerSnapshots(DataOutputView out)	Writes the composite snapshot of all the contained serializers.
protected void	CompositeTypeSerializerSnapshot.writeOuterSnapshot(DataOutputView out)	Writes the outer snapshot, i.e.
static <T> void	TypeSerializerSnapshotSerializationUtil.writeSerializerSnapshot(DataOutputView out, TypeSerializerSnapshot<T> serializerSnapshot)	Writes a TypeSerializerSnapshot to the provided data output view.
void	CompositeTypeSerializerSnapshot.writeSnapshot(DataOutputView out)
void	GenericTypeSerializerSnapshot.writeSnapshot(DataOutputView out)
void	SimpleTypeSerializerSnapshot.writeSnapshot(DataOutputView out)
void	TypeSerializerSnapshot.writeSnapshot(DataOutputView out)	Writes the serializer snapshot to the provided DataOutputView.
static void	TypeSerializerSnapshot.writeVersionedSnapshot(DataOutputView out, TypeSerializerSnapshot<?> snapshot)	Writes the given snapshot to the out stream.
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.

Uses of DataOutputView in org.apache.flink.api.common.typeutils.base

Methods in org.apache.flink.api.common.typeutils.base with parameters of type DataOutputView

Modifier and Type	Method	Description
void	BigDecSerializer.copy(DataInputView source, DataOutputView target)
void	BigIntSerializer.copy(DataInputView source, DataOutputView target)
void	BooleanSerializer.copy(DataInputView source, DataOutputView target)
void	BooleanValueSerializer.copy(DataInputView source, DataOutputView target)
void	ByteSerializer.copy(DataInputView source, DataOutputView target)
void	ByteValueSerializer.copy(DataInputView source, DataOutputView target)
void	CharSerializer.copy(DataInputView source, DataOutputView target)
void	CharValueSerializer.copy(DataInputView source, DataOutputView target)
void	DateSerializer.copy(DataInputView source, DataOutputView target)
void	DoubleSerializer.copy(DataInputView source, DataOutputView target)
void	DoubleValueSerializer.copy(DataInputView source, DataOutputView target)
void	EnumSerializer.copy(DataInputView source, DataOutputView target)
void	FloatSerializer.copy(DataInputView source, DataOutputView target)
void	FloatValueSerializer.copy(DataInputView source, DataOutputView target)
void	GenericArraySerializer.copy(DataInputView source, DataOutputView target)
void	InstantSerializer.copy(DataInputView source, DataOutputView target)
void	IntSerializer.copy(DataInputView source, DataOutputView target)
void	IntValueSerializer.copy(DataInputView source, DataOutputView target)
void	ListSerializer.copy(DataInputView source, DataOutputView target)
void	LocalDateSerializer.copy(DataInputView source, DataOutputView target)
void	LocalDateTimeSerializer.copy(DataInputView source, DataOutputView target)
void	LocalTimeSerializer.copy(DataInputView source, DataOutputView target)
void	LongSerializer.copy(DataInputView source, DataOutputView target)
void	LongValueSerializer.copy(DataInputView source, DataOutputView target)
void	MapSerializer.copy(DataInputView source, DataOutputView target)
void	NullValueSerializer.copy(DataInputView source, DataOutputView target)
void	ShortSerializer.copy(DataInputView source, DataOutputView target)
void	ShortValueSerializer.copy(DataInputView source, DataOutputView target)
void	SqlDateSerializer.copy(DataInputView source, DataOutputView target)
void	SqlTimeSerializer.copy(DataInputView source, DataOutputView target)
void	SqlTimestampSerializer.copy(DataInputView source, DataOutputView target)
void	StringSerializer.copy(DataInputView source, DataOutputView target)
void	StringValueSerializer.copy(DataInputView source, DataOutputView target)
void	VoidSerializer.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	CharSerializer.serialize(Character record, DataOutputView target)
void	CharValueSerializer.serialize(CharValue 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	EnumSerializer.serialize(T record, DataOutputView target)
void	FloatSerializer.serialize(Float record, DataOutputView target)
void	FloatValueSerializer.serialize(FloatValue record, DataOutputView target)
void	GenericArraySerializer.serialize(C[] value, DataOutputView target)
void	InstantSerializer.serialize(java.time.Instant 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	LocalDateSerializer.serialize(java.time.LocalDate record, DataOutputView target)
void	LocalDateTimeSerializer.serialize(java.time.LocalDateTime record, DataOutputView target)
void	LocalTimeSerializer.serialize(java.time.LocalTime record, 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	SqlDateSerializer.serialize(Date record, DataOutputView target)
void	SqlTimeSerializer.serialize(Time record, DataOutputView target)
void	SqlTimestampSerializer.serialize(Timestamp record, DataOutputView target)
void	StringSerializer.serialize(String record, DataOutputView target)
void	StringValueSerializer.serialize(StringValue record, DataOutputView target)
void	VoidSerializer.serialize(Void record, DataOutputView target)
static void	BigIntSerializer.writeBigInteger(BigInteger record, DataOutputView target)
protected void	GenericArraySerializerSnapshot.writeOuterSnapshot(DataOutputView out)
void	EnumSerializer.EnumSerializerSnapshot.writeSnapshot(DataOutputView out)
void	GenericArraySerializerConfigSnapshot.writeSnapshot(DataOutputView out)	Deprecated.
void	BasicTypeComparator.writeWithKeyNormalization(T 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	LocalDateComparator.writeWithKeyNormalization(java.time.LocalDate record, DataOutputView target)
void	LocalDateTimeComparator.writeWithKeyNormalization(java.time.LocalDateTime 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)

Uses of DataOutputView in org.apache.flink.api.common.typeutils.base.array

Methods in org.apache.flink.api.common.typeutils.base.array with parameters of type DataOutputView

Modifier and Type	Method	Description
void	BooleanPrimitiveArraySerializer.copy(DataInputView source, DataOutputView target)
void	BytePrimitiveArraySerializer.copy(DataInputView source, DataOutputView target)
void	CharPrimitiveArraySerializer.copy(DataInputView source, DataOutputView target)
void	DoublePrimitiveArraySerializer.copy(DataInputView source, DataOutputView target)
void	FloatPrimitiveArraySerializer.copy(DataInputView source, DataOutputView target)
void	IntPrimitiveArraySerializer.copy(DataInputView source, DataOutputView target)
void	LongPrimitiveArraySerializer.copy(DataInputView source, DataOutputView target)
void	ShortPrimitiveArraySerializer.copy(DataInputView source, DataOutputView target)
void	StringArraySerializer.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)

Uses of DataOutputView in org.apache.flink.api.java.typeutils.runtime

Fields in org.apache.flink.api.java.typeutils.runtime declared as DataOutputView

Modifier and Type	Field	Description
protected DataOutputView	DataOutputViewStream.outputView

Methods in org.apache.flink.api.java.typeutils.runtime with parameters of type DataOutputView

Modifier and Type	Method	Description
void	CopyableValueSerializer.copy(DataInputView source, DataOutputView target)
void	EitherSerializer.copy(DataInputView source, DataOutputView target)
void	NullableSerializer.copy(DataInputView source, DataOutputView target)
void	PojoSerializer.copy(DataInputView source, DataOutputView target)
void	RowSerializer.copy(DataInputView source, DataOutputView target)
void	Tuple0Serializer.copy(DataInputView source, DataOutputView target)
void	TupleSerializerBase.copy(DataInputView source, DataOutputView target)
void	ValueSerializer.copy(DataInputView source, DataOutputView target)
static void	MaskUtils.readIntoAndCopyMask(DataInputView source, DataOutputView target, boolean[] mask)
static void	MaskUtils.readIntoAndCopyMask(DataInputView source, DataOutputView target, boolean[] mask, int len)
void	CopyableValueSerializer.serialize(T value, DataOutputView target)
void	EitherSerializer.serialize(Either<L,R> record, DataOutputView target)
void	NullableSerializer.serialize(T record, DataOutputView target)
void	PojoSerializer.serialize(T value, DataOutputView target)
void	RowSerializer.serialize(Row record, DataOutputView target)
void	Tuple0Serializer.serialize(Tuple0 record, DataOutputView target)
void	TupleSerializer.serialize(T value, DataOutputView target)
void	ValueSerializer.serialize(T value, DataOutputView target)
static void	MaskUtils.writeMask(boolean[] mask, int len, DataOutputView target)
static void	MaskUtils.writeMask(boolean[] mask, DataOutputView target)
protected void	NullableSerializer.NullableSerializerSnapshot.writeOuterSnapshot(DataOutputView out)
protected void	RowSerializer.RowSerializerSnapshot.writeOuterSnapshot(DataOutputView out)
protected void	TupleSerializerSnapshot.writeOuterSnapshot(DataOutputView out)
void	EitherSerializerSnapshot.writeSnapshot(DataOutputView out)	Deprecated.
void	PojoSerializerSnapshot.writeSnapshot(DataOutputView out)
void	CopyableValueComparator.writeWithKeyNormalization(T record, DataOutputView target)
void	GenericTypeComparator.writeWithKeyNormalization(T record, DataOutputView target)
void	NullAwareComparator.writeWithKeyNormalization(T record, DataOutputView target)
void	PojoComparator.writeWithKeyNormalization(T record, DataOutputView target)
void	RowComparator.writeWithKeyNormalization(Row record, DataOutputView target)
void	TupleComparatorBase.writeWithKeyNormalization(T record, DataOutputView target)
void	ValueComparator.writeWithKeyNormalization(T record, DataOutputView target)

Constructors in org.apache.flink.api.java.typeutils.runtime with parameters of type DataOutputView

Constructor	Description
DataOutputViewStream(DataOutputView outputView)

Uses of DataOutputView in org.apache.flink.api.java.typeutils.runtime.kryo

Methods in org.apache.flink.api.java.typeutils.runtime.kryo with parameters of type DataOutputView

Modifier and Type	Method	Description
void	KryoSerializer.copy(DataInputView source, DataOutputView target)
void	KryoSerializer.serialize(T record, DataOutputView target)
void	KryoSerializerSnapshot.writeSnapshot(DataOutputView out)

Uses of DataOutputView in org.apache.flink.configuration

Methods in org.apache.flink.configuration with parameters of type DataOutputView

Modifier and Type	Method	Description
void	Configuration.write(DataOutputView out)
void	DelegatingConfiguration.write(DataOutputView out)

Uses of DataOutputView in org.apache.flink.core.fs

Methods in org.apache.flink.core.fs with parameters of type DataOutputView

Modifier and Type	Method	Description
void	Path.write(DataOutputView out)

Uses of DataOutputView in org.apache.flink.core.io

Methods in org.apache.flink.core.io with parameters of type DataOutputView

Modifier and Type	Method	Description
void	SimpleVersionedSerializerTypeSerializerProxy.copy(DataInputView source, DataOutputView target)
void	SimpleVersionedSerializerTypeSerializerProxy.serialize(T record, DataOutputView target)
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.
static <T> void	SimpleVersionedSerialization.writeVersionAndSerializeList(SimpleVersionedSerializer<T> serializer, List<T> data, DataOutputView out)	Serializes the version and data into a stream.

Uses of DataOutputView in org.apache.flink.core.memory

Subinterfaces of DataOutputView in org.apache.flink.core.memory

Modifier and Type	Interface	Description
interface	SeekableDataOutputView	Interface marking a DataOutputView as seekable.

Classes in org.apache.flink.core.memory that implement DataOutputView

Modifier and Type	Class	Description
class	DataOutputSerializer	A simple and efficient serializer for the DataOutput interface.
class	DataOutputViewStreamWrapper	Utility class that turns an OutputStream into a DataOutputView.

Uses of DataOutputView in org.apache.flink.types

Methods in org.apache.flink.types with parameters of type DataOutputView

Modifier and Type	Method	Description
void	BooleanValue.copy(DataInputView source, DataOutputView target)
void	ByteValue.copy(DataInputView source, DataOutputView target)
void	CharValue.copy(DataInputView source, DataOutputView target)
void	CopyableValue.copy(DataInputView source, DataOutputView target)	Copies the next serialized instance from source to target.
void	DoubleValue.copy(DataInputView source, DataOutputView target)
void	FloatValue.copy(DataInputView source, DataOutputView target)
void	IntValue.copy(DataInputView source, DataOutputView target)
void	LongValue.copy(DataInputView source, DataOutputView target)
void	NullValue.copy(DataInputView source, DataOutputView target)
void	Record.copy(DataInputView source, DataOutputView target)
void	ShortValue.copy(DataInputView source, DataOutputView target)
void	StringValue.copy(DataInputView in, DataOutputView target)
long	Record.serialize(DataOutputView target)	Writes this record to the given output view.
void	BooleanValue.write(DataOutputView out)
void	ByteValue.write(DataOutputView out)
void	CharValue.write(DataOutputView out)
void	DoubleValue.write(DataOutputView out)
void	FloatValue.write(DataOutputView out)
void	IntValue.write(DataOutputView out)
void	ListValue.write(DataOutputView out)
void	LongValue.write(DataOutputView out)
void	MapValue.write(DataOutputView out)
void	NullValue.write(DataOutputView out)
void	Record.write(DataOutputView out)
void	ShortValue.write(DataOutputView out)
void	StringValue.write(DataOutputView out)

Uses of DataOutputView in org.apache.flink.util

Methods in org.apache.flink.util with parameters of type DataOutputView

Modifier and Type	Method	Description
static void	StringUtils.writeNullableString(String str, DataOutputView out)	Writes a String to the given output.
static <K,V> void	LinkedOptionalMapSerializer.writeOptionalMap(DataOutputView out, LinkedOptionalMap<K,V> map, BiConsumerWithException<DataOutputView,K,IOException> keyWriter, BiConsumerWithException<DataOutputView,V,IOException> valueWriter)
static void	StringUtils.writeString(String str, DataOutputView out)	Writes a String to the given output.

Method parameters in org.apache.flink.util with type arguments of type DataOutputView

Modifier and Type	Method	Description
static <K,V> void	LinkedOptionalMapSerializer.writeOptionalMap(DataOutputView out, LinkedOptionalMap<K,V> map, BiConsumerWithException<DataOutputView,K,IOException> keyWriter, BiConsumerWithException<DataOutputView,V,IOException> valueWriter)