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

Packages that use DataInputView

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 DataInputView in org.apache.flink.api.common.io

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

Modifier and Type	Method	Description
protected abstract T	BinaryInputFormat.deserialize(T reuse, DataInputView dataInput)
protected T	SerializedInputFormat.deserialize(T reuse, DataInputView dataInput)
void	BlockInfo.read(DataInputView in)

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

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

Modifier and Type	Method	Description
abstract int	TypeComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)	Compares two records in serialized form.
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)
T	CompositeSerializer.deserialize(DataInputView source)
T	CompositeSerializer.deserialize(T reuse, DataInputView source)
T	SingleThreadAccessCheckingTypeSerializer.deserialize(DataInputView source)
T	SingleThreadAccessCheckingTypeSerializer.deserialize(T reuse, DataInputView source)
abstract T	TypeSerializer.deserialize(DataInputView source)	De-serializes a record from the given source input view.
abstract T	TypeSerializer.deserialize(T reuse, DataInputView source)	De-serializes a record from the given source input view into the given reuse record instance if mutable.
T	UnloadableDummyTypeSerializer.deserialize(DataInputView source)
T	UnloadableDummyTypeSerializer.deserialize(T reuse, DataInputView source)
static <T> TypeSerializerSnapshot<T>	TypeSerializerSnapshotSerializationUtil.readAndInstantiateSnapshotClass(DataInputView in, ClassLoader cl)
static NestedSerializersSnapshotDelegate	NestedSerializersSnapshotDelegate.readNestedSerializerSnapshots(DataInputView in, ClassLoader cl)	Reads the composite snapshot of all the contained serializers.
protected void	CompositeTypeSerializerSnapshot.readOuterSnapshot(int readOuterSnapshotVersion, DataInputView in, ClassLoader userCodeClassLoader)	Reads the outer snapshot, i.e.
static <T> TypeSerializerSnapshot<T>	TypeSerializerSnapshotSerializationUtil.readSerializerSnapshot(DataInputView in, ClassLoader userCodeClassLoader)	Reads from a data input view a TypeSerializerSnapshot that was previously written using {@link #writeSerializerSnapshot(DataOutputView, TypeSerializerSnapshot}.
void	CompositeTypeSerializerSnapshot.readSnapshot(int readVersion, DataInputView in, ClassLoader userCodeClassLoader)
void	GenericTypeSerializerSnapshot.readSnapshot(int readVersion, DataInputView in, ClassLoader userCodeClassLoader)
void	SimpleTypeSerializerSnapshot.readSnapshot(int readVersion, DataInputView in, ClassLoader classLoader)
void	TypeSerializerSnapshot.readSnapshot(int readVersion, DataInputView in, ClassLoader userCodeClassLoader)	Reads the serializer snapshot from the provided DataInputView.
static <T> TypeSerializerSnapshot<T>	TypeSerializerSnapshot.readVersionedSnapshot(DataInputView in, ClassLoader cl)	Reads a snapshot from the stream, performing resolving
abstract T	TypeComparator.readWithKeyDenormalization(T reuse, DataInputView source)	Reads the record back while de-normalizing the key fields.

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

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

Modifier and Type	Method	Description
int	BigDecComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	BigIntComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	BooleanComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	BooleanValueComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	ByteComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	ByteValueComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	CharComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	CharValueComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	DateComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	DoubleComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	DoubleValueComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	EnumComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	FloatComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	FloatValueComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	InstantComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	IntComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	IntValueComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	LocalDateComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	LocalDateTimeComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	LocalTimeComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	LongComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	LongValueComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	NullValueComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	ShortComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	ShortValueComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	SqlTimestampComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	StringComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	StringValueComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
static int	DateComparator.compareSerializedDate(DataInputView firstSource, DataInputView secondSource, boolean ascendingComparison)
static int	LocalDateComparator.compareSerializedLocalDate(DataInputView firstSource, DataInputView secondSource, boolean ascendingComparison)
static int	LocalTimeComparator.compareSerializedLocalTime(DataInputView firstSource, DataInputView secondSource, boolean ascendingComparison)
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)
BigDecimal	BigDecSerializer.deserialize(BigDecimal reuse, DataInputView source)
BigDecimal	BigDecSerializer.deserialize(DataInputView source)
BigInteger	BigIntSerializer.deserialize(BigInteger reuse, DataInputView source)
BigInteger	BigIntSerializer.deserialize(DataInputView source)
Boolean	BooleanSerializer.deserialize(Boolean reuse, DataInputView source)
Boolean	BooleanSerializer.deserialize(DataInputView source)
BooleanValue	BooleanValueSerializer.deserialize(DataInputView source)
BooleanValue	BooleanValueSerializer.deserialize(BooleanValue reuse, DataInputView source)
Byte	ByteSerializer.deserialize(Byte reuse, DataInputView source)
Byte	ByteSerializer.deserialize(DataInputView source)
ByteValue	ByteValueSerializer.deserialize(DataInputView source)
ByteValue	ByteValueSerializer.deserialize(ByteValue reuse, DataInputView source)
Character	CharSerializer.deserialize(Character reuse, DataInputView source)
Character	CharSerializer.deserialize(DataInputView source)
CharValue	CharValueSerializer.deserialize(DataInputView source)
CharValue	CharValueSerializer.deserialize(CharValue reuse, DataInputView source)
Date	DateSerializer.deserialize(Date reuse, DataInputView source)
Date	DateSerializer.deserialize(DataInputView source)
Double	DoubleSerializer.deserialize(Double reuse, DataInputView source)
Double	DoubleSerializer.deserialize(DataInputView source)
DoubleValue	DoubleValueSerializer.deserialize(DataInputView source)
DoubleValue	DoubleValueSerializer.deserialize(DoubleValue reuse, DataInputView source)
T	EnumSerializer.deserialize(DataInputView source)
T	EnumSerializer.deserialize(T reuse, DataInputView source)
Float	FloatSerializer.deserialize(Float reuse, DataInputView source)
Float	FloatSerializer.deserialize(DataInputView source)
FloatValue	FloatValueSerializer.deserialize(DataInputView source)
FloatValue	FloatValueSerializer.deserialize(FloatValue reuse, DataInputView source)
C[]	GenericArraySerializer.deserialize(C[] reuse, DataInputView source)
C[]	GenericArraySerializer.deserialize(DataInputView source)
java.time.Instant	InstantSerializer.deserialize(java.time.Instant reuse, DataInputView source)
java.time.Instant	InstantSerializer.deserialize(DataInputView source)
Integer	IntSerializer.deserialize(Integer reuse, DataInputView source)
Integer	IntSerializer.deserialize(DataInputView source)
IntValue	IntValueSerializer.deserialize(DataInputView source)
IntValue	IntValueSerializer.deserialize(IntValue reuse, DataInputView source)
List<T>	ListSerializer.deserialize(List<T> reuse, DataInputView source)
List<T>	ListSerializer.deserialize(DataInputView source)
java.time.LocalDate	LocalDateSerializer.deserialize(java.time.LocalDate reuse, DataInputView source)
java.time.LocalDate	LocalDateSerializer.deserialize(DataInputView source)
java.time.LocalDateTime	LocalDateTimeSerializer.deserialize(java.time.LocalDateTime reuse, DataInputView source)
java.time.LocalDateTime	LocalDateTimeSerializer.deserialize(DataInputView source)
java.time.LocalTime	LocalTimeSerializer.deserialize(java.time.LocalTime reuse, DataInputView source)
java.time.LocalTime	LocalTimeSerializer.deserialize(DataInputView source)
Long	LongSerializer.deserialize(Long reuse, DataInputView source)
Long	LongSerializer.deserialize(DataInputView source)
LongValue	LongValueSerializer.deserialize(DataInputView source)
LongValue	LongValueSerializer.deserialize(LongValue reuse, DataInputView source)
Map<K,V>	MapSerializer.deserialize(Map<K,V> reuse, DataInputView source)
Map<K,V>	MapSerializer.deserialize(DataInputView source)
NullValue	NullValueSerializer.deserialize(DataInputView source)
NullValue	NullValueSerializer.deserialize(NullValue reuse, DataInputView source)
Short	ShortSerializer.deserialize(Short reuse, DataInputView source)
Short	ShortSerializer.deserialize(DataInputView source)
ShortValue	ShortValueSerializer.deserialize(DataInputView source)
ShortValue	ShortValueSerializer.deserialize(ShortValue reuse, DataInputView source)
Date	SqlDateSerializer.deserialize(Date reuse, DataInputView source)
Date	SqlDateSerializer.deserialize(DataInputView source)
Time	SqlTimeSerializer.deserialize(Time reuse, DataInputView source)
Time	SqlTimeSerializer.deserialize(DataInputView source)
Timestamp	SqlTimestampSerializer.deserialize(Timestamp reuse, DataInputView source)
Timestamp	SqlTimestampSerializer.deserialize(DataInputView source)
String	StringSerializer.deserialize(String record, DataInputView source)
String	StringSerializer.deserialize(DataInputView source)
StringValue	StringValueSerializer.deserialize(DataInputView source)
StringValue	StringValueSerializer.deserialize(StringValue reuse, DataInputView source)
Void	VoidSerializer.deserialize(Void reuse, DataInputView source)
Void	VoidSerializer.deserialize(DataInputView source)
static BigDecimal	BigDecSerializer.readBigDecimal(DataInputView source)
static BigInteger	BigIntSerializer.readBigInteger(DataInputView source)
protected void	GenericArraySerializerSnapshot.readOuterSnapshot(int readOuterSnapshotVersion, DataInputView in, ClassLoader userCodeClassLoader)
void	EnumSerializer.EnumSerializerSnapshot.readSnapshot(int readVersion, DataInputView in, ClassLoader userCodeClassLoader)
void	GenericArraySerializerConfigSnapshot.readSnapshot(int readVersion, DataInputView in, ClassLoader classLoader)	Deprecated.
T	BasicTypeComparator.readWithKeyDenormalization(T reuse, DataInputView source)
BooleanValue	BooleanValueComparator.readWithKeyDenormalization(BooleanValue reuse, DataInputView source)
ByteValue	ByteValueComparator.readWithKeyDenormalization(ByteValue reuse, DataInputView source)
CharValue	CharValueComparator.readWithKeyDenormalization(CharValue reuse, DataInputView source)
DoubleValue	DoubleValueComparator.readWithKeyDenormalization(DoubleValue reuse, DataInputView source)
FloatValue	FloatValueComparator.readWithKeyDenormalization(FloatValue reuse, DataInputView source)
IntValue	IntValueComparator.readWithKeyDenormalization(IntValue reuse, DataInputView source)
java.time.LocalDate	LocalDateComparator.readWithKeyDenormalization(java.time.LocalDate reuse, DataInputView source)
java.time.LocalDateTime	LocalDateTimeComparator.readWithKeyDenormalization(java.time.LocalDateTime reuse, DataInputView source)
LongValue	LongValueComparator.readWithKeyDenormalization(LongValue reuse, DataInputView source)
NullValue	NullValueComparator.readWithKeyDenormalization(NullValue reuse, DataInputView source)
ShortValue	ShortValueComparator.readWithKeyDenormalization(ShortValue reuse, DataInputView source)
StringValue	StringValueComparator.readWithKeyDenormalization(StringValue reuse, DataInputView source)

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

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

Modifier and Type	Method	Description
int	PrimitiveArrayComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
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)
boolean[]	BooleanPrimitiveArraySerializer.deserialize(boolean[] reuse, DataInputView source)
boolean[]	BooleanPrimitiveArraySerializer.deserialize(DataInputView source)
byte[]	BytePrimitiveArraySerializer.deserialize(byte[] reuse, DataInputView source)
byte[]	BytePrimitiveArraySerializer.deserialize(DataInputView source)
char[]	CharPrimitiveArraySerializer.deserialize(char[] reuse, DataInputView source)
char[]	CharPrimitiveArraySerializer.deserialize(DataInputView source)
double[]	DoublePrimitiveArraySerializer.deserialize(double[] reuse, DataInputView source)
double[]	DoublePrimitiveArraySerializer.deserialize(DataInputView source)
float[]	FloatPrimitiveArraySerializer.deserialize(float[] reuse, DataInputView source)
float[]	FloatPrimitiveArraySerializer.deserialize(DataInputView source)
int[]	IntPrimitiveArraySerializer.deserialize(int[] reuse, DataInputView source)
int[]	IntPrimitiveArraySerializer.deserialize(DataInputView source)
long[]	LongPrimitiveArraySerializer.deserialize(long[] reuse, DataInputView source)
long[]	LongPrimitiveArraySerializer.deserialize(DataInputView source)
short[]	ShortPrimitiveArraySerializer.deserialize(short[] reuse, DataInputView source)
short[]	ShortPrimitiveArraySerializer.deserialize(DataInputView source)
String[]	StringArraySerializer.deserialize(String[] reuse, DataInputView source)
String[]	StringArraySerializer.deserialize(DataInputView source)
T	PrimitiveArrayComparator.readWithKeyDenormalization(T reuse, DataInputView source)

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

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

Modifier and Type	Field	Description
protected DataInputView	DataInputViewStream.inputView

Methods in org.apache.flink.api.java.typeutils.runtime that return DataInputView

Modifier and Type	Method	Description
DataInputView	DataInputViewStream.getInputView()

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

Modifier and Type	Method	Description
int	CopyableValueComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	GenericTypeComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	NullAwareComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	PojoComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	RowComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	TupleComparatorBase.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	ValueComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
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)
T	CopyableValueSerializer.deserialize(DataInputView source)
T	CopyableValueSerializer.deserialize(T reuse, DataInputView source)
Either<L,R>	EitherSerializer.deserialize(DataInputView source)
Either<L,R>	EitherSerializer.deserialize(Either<L,R> reuse, DataInputView source)
T	NullableSerializer.deserialize(DataInputView source)
T	NullableSerializer.deserialize(T reuse, DataInputView source)
T	PojoSerializer.deserialize(DataInputView source)
T	PojoSerializer.deserialize(T reuse, DataInputView source)
Row	RowSerializer.deserialize(DataInputView source)
Row	RowSerializer.deserialize(Row reuse, DataInputView source)
Tuple0	Tuple0Serializer.deserialize(Tuple0 reuse, DataInputView source)
Tuple0	Tuple0Serializer.deserialize(DataInputView source)
T	TupleSerializer.deserialize(DataInputView source)
T	TupleSerializer.deserialize(T reuse, DataInputView source)
T	ValueSerializer.deserialize(DataInputView source)
T	ValueSerializer.deserialize(T reuse, DataInputView source)
static void	MaskUtils.readIntoAndCopyMask(DataInputView source, DataOutputView target, boolean[] mask)
static void	MaskUtils.readIntoAndCopyMask(DataInputView source, DataOutputView target, boolean[] mask, int len)
static void	MaskUtils.readIntoMask(DataInputView source, boolean[] mask)
static void	MaskUtils.readIntoMask(DataInputView source, boolean[] mask, int len)
protected void	NullableSerializer.NullableSerializerSnapshot.readOuterSnapshot(int readOuterSnapshotVersion, DataInputView in, ClassLoader userCodeClassLoader)
protected void	RowSerializer.RowSerializerSnapshot.readOuterSnapshot(int readOuterSnapshotVersion, DataInputView in, ClassLoader userCodeClassLoader)
protected void	TupleSerializerSnapshot.readOuterSnapshot(int readOuterSnapshotVersion, DataInputView in, ClassLoader userCodeClassLoader)
void	EitherSerializerSnapshot.readSnapshot(int readVersion, DataInputView in, ClassLoader classLoader)	Deprecated.
void	PojoSerializerSnapshot.readSnapshot(int readVersion, DataInputView in, ClassLoader userCodeClassLoader)
T	CopyableValueComparator.readWithKeyDenormalization(T reuse, DataInputView source)
T	GenericTypeComparator.readWithKeyDenormalization(T reuse, DataInputView source)
T	NullAwareComparator.readWithKeyDenormalization(T reuse, DataInputView source)
T	PojoComparator.readWithKeyDenormalization(T reuse, DataInputView source)
Row	RowComparator.readWithKeyDenormalization(Row reuse, DataInputView source)
T	TupleComparatorBase.readWithKeyDenormalization(T reuse, DataInputView source)
T	ValueComparator.readWithKeyDenormalization(T reuse, DataInputView source)

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

Constructor	Description
DataInputViewStream(DataInputView inputView)

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

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

Modifier and Type	Method	Description
void	KryoSerializer.copy(DataInputView source, DataOutputView target)
T	KryoSerializer.deserialize(DataInputView source)
T	KryoSerializer.deserialize(T reuse, DataInputView source)
void	KryoSerializerSnapshot.readSnapshot(int readVersion, DataInputView in, ClassLoader userCodeClassLoader)

Uses of DataInputView in org.apache.flink.configuration

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

Modifier and Type	Method	Description
void	Configuration.read(DataInputView in)
void	DelegatingConfiguration.read(DataInputView in)

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

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

Modifier and Type	Method	Description
void	Path.read(DataInputView in)

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

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

Modifier and Type	Method	Description
void	SimpleVersionedSerializerTypeSerializerProxy.copy(DataInputView source, DataOutputView target)
T	SimpleVersionedSerializerTypeSerializerProxy.deserialize(DataInputView source)
T	SimpleVersionedSerializerTypeSerializerProxy.deserialize(T reuse, DataInputView source)
void	IOReadableWritable.read(DataInputView in)	Reads the object's internal data from the given data input view.
void	PostVersionedIOReadableWritable.read(DataInputView in)	We do not support reading from a DataInputView, because it does not support pushing back already read bytes.
protected abstract void	PostVersionedIOReadableWritable.read(DataInputView in, boolean wasVersioned)	Read from the provided in.
void	VersionedIOReadableWritable.read(DataInputView in)
static <T> T	SimpleVersionedSerialization.readVersionAndDeSerialize(SimpleVersionedSerializer<T> serializer, DataInputView in)	Deserializes the version and datum from a stream.
static <T> List<T>	SimpleVersionedSerialization.readVersionAndDeserializeList(SimpleVersionedSerializer<T> serializer, DataInputView in)	Deserializes the version and data from a stream.

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

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

Modifier and Type	Interface	Description
interface	SeekableDataInputView	Interface marking a DataInputView as seekable.

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

Modifier and Type	Class	Description
class	DataInputDeserializer	A simple and efficient deserializer for the DataInput interface.
class	DataInputViewStreamWrapper	Utility class that turns an InputStream into a DataInputView.

Methods in org.apache.flink.core.memory with parameters of type DataInputView

Modifier and Type	Method	Description
void	DataOutputSerializer.write(DataInputView source, int numBytes)
void	DataOutputView.write(DataInputView source, int numBytes)	Copies numBytes bytes from the source to this view.
void	DataOutputViewStreamWrapper.write(DataInputView source, int numBytes)

Uses of DataInputView in org.apache.flink.types

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

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)
void	Record.deserialize(DataInputView source)
void	BooleanValue.read(DataInputView in)
void	ByteValue.read(DataInputView in)
void	CharValue.read(DataInputView in)
void	DoubleValue.read(DataInputView in)
void	FloatValue.read(DataInputView in)
void	IntValue.read(DataInputView in)
void	ListValue.read(DataInputView in)
void	LongValue.read(DataInputView in)
void	MapValue.read(DataInputView in)
void	NullValue.read(DataInputView in)
void	Record.read(DataInputView in)
void	ShortValue.read(DataInputView in)
void	StringValue.read(DataInputView in)

Uses of DataInputView in org.apache.flink.util

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

Modifier and Type	Method	Description
static String	StringUtils.readNullableString(DataInputView in)	Reads a String from the given input.
static <K,V> LinkedOptionalMap<K,V>	LinkedOptionalMapSerializer.readOptionalMap(DataInputView in, BiFunctionWithException<DataInputView,String,K,IOException> keyReader, BiFunctionWithException<DataInputView,String,V,IOException> valueReader)
static String	StringUtils.readString(DataInputView in)	Reads a non-null String from the given input.
static <T> Class<T>	InstantiationUtil.resolveClassByName(DataInputView in, ClassLoader cl)	Loads a class by name from the given input stream and reflectively instantiates it.
static <T> Class<T>	InstantiationUtil.resolveClassByName(DataInputView in, ClassLoader cl, Class<? super T> supertype)	Loads a class by name from the given input stream and reflectively instantiates it.

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

Modifier and Type	Method	Description
static <K,V> LinkedOptionalMap<K,V>	LinkedOptionalMapSerializer.readOptionalMap(DataInputView in, BiFunctionWithException<DataInputView,String,K,IOException> keyReader, BiFunctionWithException<DataInputView,String,V,IOException> valueReader)