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.io
org.apache.flink.api.java.typeutils.runtime
org.apache.flink.api.java.typeutils.runtime.kryo
org.apache.flink.cep.nfa
org.apache.flink.configuration
org.apache.flink.contrib.streaming.state
org.apache.flink.core.fs
org.apache.flink.core.io
org.apache.flink.core.memory
org.apache.flink.formats.avro.typeutils
org.apache.flink.graph.drivers.transform
org.apache.flink.graph.types.valuearray
org.apache.flink.queryablestate.client
org.apache.flink.runtime.io.disk
org.apache.flink.runtime.io.disk.iomanager
org.apache.flink.runtime.io.network.api
org.apache.flink.runtime.iterative.concurrent
org.apache.flink.runtime.iterative.event
org.apache.flink.runtime.memory
org.apache.flink.runtime.operators.hash
org.apache.flink.runtime.operators.resettable
org.apache.flink.runtime.plugable
org.apache.flink.runtime.state
org.apache.flink.streaming.api.functions.sink
org.apache.flink.streaming.api.operators
org.apache.flink.streaming.api.windowing.windows
org.apache.flink.streaming.connectors.kafka
org.apache.flink.streaming.runtime.streamrecord
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 and Description
protected T	SerializedInputFormat.deserialize(T reuse, DataInputView dataInput)
protected abstract T	BinaryInputFormat.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 and Description
abstract int	TypeComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource) Compares two records in serialized form.
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.
T	TypeDeserializer.deserialize(DataInputView source) De-serializes a record from the given source input view.
T	TypeDeserializerAdapter.deserialize(DataInputView source)
T	UnloadableDummyTypeSerializer.deserialize(DataInputView source)
abstract T	TypeSerializer.deserialize(DataInputView source) De-serializes a record from the given source input view.
T	TypeDeserializer.deserialize(T reuse, DataInputView source) De-serializes a record from the given source input view into the given reuse record instance if mutable.
T	TypeDeserializerAdapter.deserialize(T reuse, DataInputView source)
T	UnloadableDummyTypeSerializer.deserialize(T reuse, DataInputView source)
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.
void	CompositeTypeSerializerConfigSnapshot.read(DataInputView in)
void	TypeSerializerSerializationUtil.TypeSerializerSerializationProxy.read(DataInputView in)
void	ParameterlessTypeSerializerConfig.read(DataInputView in)
void	GenericTypeSerializerConfigSnapshot.read(DataInputView in)
static TypeSerializerConfigSnapshot	TypeSerializerSerializationUtil.readSerializerConfigSnapshot(DataInputView in, ClassLoader userCodeClassLoader) Reads from a data input view a TypeSerializerConfigSnapshot that was previously written using TypeSerializerSerializationUtil.writeSerializerConfigSnapshot(DataOutputView, TypeSerializerConfigSnapshot).
static TypeSerializerConfigSnapshot[]	TypeSerializerSerializationUtil.readSerializerConfigSnapshots(DataInputView in, ClassLoader userCodeClassLoader) Reads from a data input view multiple TypeSerializerConfigSnapshots that was previously written using TypeSerializerSerializationUtil.writeSerializerConfigSnapshot(DataOutputView, TypeSerializerConfigSnapshot).
static List<Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>>	TypeSerializerSerializationUtil.readSerializersAndConfigsWithResilience(DataInputView in, ClassLoader userCodeClassLoader) Reads from a data input view a list of serializers and their corresponding config snapshots written using TypeSerializerSerializationUtil.writeSerializersAndConfigsWithResilience(DataOutputView, List).
abstract T	TypeComparator.readWithKeyDenormalization(T reuse, DataInputView source) Reads the record back while de-normalizing the key fields.
static <T> TypeSerializer<T>	TypeSerializerSerializationUtil.tryReadSerializer(DataInputView in, ClassLoader userCodeClassLoader) Reads from a data input view a TypeSerializer that was previously written using TypeSerializerSerializationUtil.writeSerializer(DataOutputView, TypeSerializer).
static <T> TypeSerializer<T>	TypeSerializerSerializationUtil.tryReadSerializer(DataInputView in, ClassLoader userCodeClassLoader, boolean useDummyPlaceholder) Reads from a data input view a TypeSerializer that was previously written using TypeSerializerSerializationUtil.writeSerializer(DataOutputView, TypeSerializer).

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 and Description
int	ShortComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	StringComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	NullValueComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	DoubleValueComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	CharValueComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	StringValueComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	FloatValueComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	ByteValueComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	ShortValueComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	BigDecComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	ByteComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	BigIntComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	LongValueComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	CharComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	SqlTimestampComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	BooleanComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	IntValueComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	FloatComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	DoubleComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	DateComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	BooleanValueComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	IntComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	EnumComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	LongComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
static int	DateComparator.compareSerializedDate(DataInputView firstSource, DataInputView secondSource, boolean ascendingComparison)
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)
BigDecimal	BigDecSerializer.deserialize(BigDecimal reuse, DataInputView source)
BigInteger	BigIntSerializer.deserialize(BigInteger reuse, DataInputView source)
Boolean	BooleanSerializer.deserialize(Boolean reuse, DataInputView source)
BooleanValue	BooleanValueSerializer.deserialize(BooleanValue reuse, DataInputView source)
Byte	ByteSerializer.deserialize(Byte reuse, DataInputView source)
ByteValue	ByteValueSerializer.deserialize(ByteValue reuse, DataInputView source)
C[]	GenericArraySerializer.deserialize(C[] reuse, DataInputView source)
Character	CharSerializer.deserialize(Character reuse, DataInputView source)
CharValue	CharValueSerializer.deserialize(CharValue reuse, DataInputView source)
Double	DoubleSerializer.deserialize(DataInputView source)
Timestamp	SqlTimestampSerializer.deserialize(DataInputView source)
BigInteger	BigIntSerializer.deserialize(DataInputView source)
C[]	GenericArraySerializer.deserialize(DataInputView source)
Void	VoidSerializer.deserialize(DataInputView source)
BooleanValue	BooleanValueSerializer.deserialize(DataInputView source)
ShortValue	ShortValueSerializer.deserialize(DataInputView source)
DoubleValue	DoubleValueSerializer.deserialize(DataInputView source)
Integer	IntSerializer.deserialize(DataInputView source)
Time	SqlTimeSerializer.deserialize(DataInputView source)
Map<K,V>	MapSerializer.deserialize(DataInputView source)
Date	SqlDateSerializer.deserialize(DataInputView source)
List<T>	ListSerializer.deserialize(DataInputView source)
Short	ShortSerializer.deserialize(DataInputView source)
IntValue	IntValueSerializer.deserialize(DataInputView source)
Boolean	BooleanSerializer.deserialize(DataInputView source)
CharValue	CharValueSerializer.deserialize(DataInputView source)
Byte	ByteSerializer.deserialize(DataInputView source)
String	StringSerializer.deserialize(DataInputView source)
Float	FloatSerializer.deserialize(DataInputView source)
Long	LongSerializer.deserialize(DataInputView source)
LongValue	LongValueSerializer.deserialize(DataInputView source)
Date	DateSerializer.deserialize(DataInputView source)
BigDecimal	BigDecSerializer.deserialize(DataInputView source)
T	EnumSerializer.deserialize(DataInputView source)
FloatValue	FloatValueSerializer.deserialize(DataInputView source)
StringValue	StringValueSerializer.deserialize(DataInputView source)
Character	CharSerializer.deserialize(DataInputView source)
NullValue	NullValueSerializer.deserialize(DataInputView source)
ByteValue	ByteValueSerializer.deserialize(DataInputView source)
Date	SqlDateSerializer.deserialize(Date reuse, DataInputView source)
Date	DateSerializer.deserialize(Date reuse, DataInputView source)
Double	DoubleSerializer.deserialize(Double reuse, DataInputView source)
DoubleValue	DoubleValueSerializer.deserialize(DoubleValue reuse, DataInputView source)
Float	FloatSerializer.deserialize(Float reuse, DataInputView source)
FloatValue	FloatValueSerializer.deserialize(FloatValue reuse, DataInputView source)
Integer	IntSerializer.deserialize(Integer reuse, DataInputView source)
IntValue	IntValueSerializer.deserialize(IntValue reuse, DataInputView source)
List<T>	ListSerializer.deserialize(List<T> reuse, DataInputView source)
Long	LongSerializer.deserialize(Long reuse, DataInputView source)
LongValue	LongValueSerializer.deserialize(LongValue reuse, DataInputView source)
Map<K,V>	MapSerializer.deserialize(Map<K,V> reuse, DataInputView source)
NullValue	NullValueSerializer.deserialize(NullValue reuse, DataInputView source)
Short	ShortSerializer.deserialize(Short reuse, DataInputView source)
ShortValue	ShortValueSerializer.deserialize(ShortValue reuse, DataInputView source)
String	StringSerializer.deserialize(String record, DataInputView source)
StringValue	StringValueSerializer.deserialize(StringValue reuse, DataInputView source)
T	EnumSerializer.deserialize(T reuse, DataInputView source)
Time	SqlTimeSerializer.deserialize(Time reuse, DataInputView source)
Timestamp	SqlTimestampSerializer.deserialize(Timestamp reuse, DataInputView source)
Void	VoidSerializer.deserialize(Void reuse, DataInputView source)
void	GenericArraySerializerConfigSnapshot.read(DataInputView in)
void	EnumSerializer.EnumSerializerConfigSnapshot.read(DataInputView in)
static BigDecimal	BigDecSerializer.readBigDecimal(DataInputView source)
static BigInteger	BigIntSerializer.readBigInteger(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)
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)
T	BasicTypeComparator.readWithKeyDenormalization(T 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 and Description
int	PrimitiveArrayComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
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)
boolean[]	BooleanPrimitiveArraySerializer.deserialize(boolean[] reuse, DataInputView source)
byte[]	BytePrimitiveArraySerializer.deserialize(byte[] reuse, DataInputView source)
char[]	CharPrimitiveArraySerializer.deserialize(char[] reuse, DataInputView source)
char[]	CharPrimitiveArraySerializer.deserialize(DataInputView source)
double[]	DoublePrimitiveArraySerializer.deserialize(DataInputView source)
byte[]	BytePrimitiveArraySerializer.deserialize(DataInputView source)
String[]	StringArraySerializer.deserialize(DataInputView source)
short[]	ShortPrimitiveArraySerializer.deserialize(DataInputView source)
boolean[]	BooleanPrimitiveArraySerializer.deserialize(DataInputView source)
float[]	FloatPrimitiveArraySerializer.deserialize(DataInputView source)
long[]	LongPrimitiveArraySerializer.deserialize(DataInputView source)
int[]	IntPrimitiveArraySerializer.deserialize(DataInputView source)
double[]	DoublePrimitiveArraySerializer.deserialize(double[] reuse, DataInputView source)
float[]	FloatPrimitiveArraySerializer.deserialize(float[] reuse, DataInputView source)
int[]	IntPrimitiveArraySerializer.deserialize(int[] reuse, DataInputView source)
long[]	LongPrimitiveArraySerializer.deserialize(long[] reuse, DataInputView source)
short[]	ShortPrimitiveArraySerializer.deserialize(short[] reuse, DataInputView source)
String[]	StringArraySerializer.deserialize(String[] reuse, DataInputView source)
T	PrimitiveArrayComparator.readWithKeyDenormalization(T reuse, DataInputView source)

Uses of DataInputView in org.apache.flink.api.java.io

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

Modifier and Type	Method and Description
protected T	TypeSerializerInputFormat.deserialize(T reuse, DataInputView dataInput)

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 and Description
protected DataInputView	DataInputViewStream.inputView

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

Modifier and Type	Method and Description
DataInputView	DataInputViewStream.getInputView()

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

Modifier and Type	Method and Description
int	WritableComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	ValueComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	PojoComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	TupleComparatorBase.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	NullAwareComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	GenericTypeComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	RowComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	CopyableValueComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
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	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)
T	AvroSerializer.deserialize(DataInputView source) Deprecated.
T	WritableSerializer.deserialize(DataInputView source)
T	ValueSerializer.deserialize(DataInputView source)
Either<L,R>	EitherSerializer.deserialize(DataInputView source)
T	CopyableValueSerializer.deserialize(DataInputView source)
Tuple0	Tuple0Serializer.deserialize(DataInputView source)
Row	RowSerializer.deserialize(DataInputView source)
T	TupleSerializer.deserialize(DataInputView source)
T	PojoSerializer.deserialize(DataInputView source)
Either<L,R>	EitherSerializer.deserialize(Either<L,R> reuse, DataInputView source)
Row	RowSerializer.deserialize(Row reuse, DataInputView source)
T	AvroSerializer.deserialize(T reuse, DataInputView source) Deprecated.
T	WritableSerializer.deserialize(T reuse, DataInputView source)
T	ValueSerializer.deserialize(T reuse, DataInputView source)
T	CopyableValueSerializer.deserialize(T reuse, DataInputView source)
T	TupleSerializer.deserialize(T reuse, DataInputView source)
T	PojoSerializer.deserialize(T reuse, DataInputView source)
Tuple0	Tuple0Serializer.deserialize(Tuple0 reuse, DataInputView source)
void	AvroSerializer.AvroSerializerConfigSnapshot.read(DataInputView in)
void	TupleSerializerConfigSnapshot.read(DataInputView in)
void	PojoSerializer.PojoSerializerConfigSnapshot.read(DataInputView in)
void	KryoRegistrationSerializerConfigSnapshot.read(DataInputView in)
static void	NullMaskUtils.readIntoAndCopyNullMask(int len, DataInputView source, DataOutputView target, boolean[] nullMask)
static void	NullMaskUtils.readIntoNullMask(int len, DataInputView source, boolean[] nullMask)
Row	RowComparator.readWithKeyDenormalization(Row reuse, DataInputView source)
T	WritableComparator.readWithKeyDenormalization(T reuse, DataInputView source)
T	ValueComparator.readWithKeyDenormalization(T reuse, DataInputView source)
T	PojoComparator.readWithKeyDenormalization(T reuse, DataInputView source)
T	TupleComparatorBase.readWithKeyDenormalization(T reuse, DataInputView source)
T	NullAwareComparator.readWithKeyDenormalization(T reuse, DataInputView source)
T	GenericTypeComparator.readWithKeyDenormalization(T reuse, DataInputView source)
T	CopyableValueComparator.readWithKeyDenormalization(T reuse, DataInputView source)

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

Constructor and 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 and Description
void	KryoSerializer.copy(DataInputView source, DataOutputView target)
T	KryoSerializer.deserialize(DataInputView source)
T	KryoSerializer.deserialize(T reuse, DataInputView source)

Uses of DataInputView in org.apache.flink.cep.nfa

Methods in org.apache.flink.cep.nfa with parameters of type DataInputView

Modifier and Type	Method and Description
void	NFA.NFASerializer.copy(DataInputView source, DataOutputView target)
void	DeweyNumber.DeweyNumberSerializer.copy(DataInputView source, DataOutputView target)
void	SharedBuffer.SharedBufferSerializer.copy(DataInputView source, DataOutputView target)
NFA<T>	NFA.NFASerializer.deserialize(DataInputView source)
DeweyNumber	DeweyNumber.DeweyNumberSerializer.deserialize(DataInputView source)
SharedBuffer<K,V>	SharedBuffer.SharedBufferSerializer.deserialize(DataInputView source)
DeweyNumber	DeweyNumber.DeweyNumberSerializer.deserialize(DeweyNumber reuse, DataInputView source)
NFA<T>	NFA.NFASerializer.deserialize(NFA<T> reuse, DataInputView source)
SharedBuffer<K,V>	SharedBuffer.SharedBufferSerializer.deserialize(SharedBuffer<K,V> reuse, DataInputView source)

Uses of DataInputView in org.apache.flink.configuration

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

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

Uses of DataInputView in org.apache.flink.contrib.streaming.state

Methods in org.apache.flink.contrib.streaming.state with parameters of type DataInputView

Modifier and Type	Method and Description
static <K> K	RocksDBKeySerializationUtils.readKey(TypeSerializer<K> keySerializer, ByteArrayInputStreamWithPos inputStream, DataInputView inputView, boolean ambiguousKeyPossible)
static int	RocksDBKeySerializationUtils.readKeyGroup(int keyGroupPrefixBytes, DataInputView inputView)
static <N> N	RocksDBKeySerializationUtils.readNamespace(TypeSerializer<N> namespaceSerializer, ByteArrayInputStreamWithPos inputStream, DataInputView inputView, boolean ambiguousKeyPossible)

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 and 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 and Description
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.
void	VersionedIOReadableWritable.read(DataInputView in)
protected abstract void	PostVersionedIOReadableWritable.read(DataInputView in, boolean wasVersioned) Read from the provided in.

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

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

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

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

Modifier and Type	Class and 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 and 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.formats.avro.typeutils

Methods in org.apache.flink.formats.avro.typeutils with parameters of type DataInputView

Modifier and Type	Method and Description
void	BackwardsCompatibleAvroSerializer.copy(DataInputView source, DataOutputView target)
void	AvroSerializer.copy(DataInputView source, DataOutputView target)
T	BackwardsCompatibleAvroSerializer.deserialize(DataInputView source)
T	AvroSerializer.deserialize(DataInputView source)
T	BackwardsCompatibleAvroSerializer.deserialize(T reuse, DataInputView source)
T	AvroSerializer.deserialize(T reuse, DataInputView source)
void	AvroSerializer.AvroSchemaSerializerConfigSnapshot.read(DataInputView in)
void	AvroSerializer.AvroSerializerConfigSnapshot.read(DataInputView in) Deprecated.

Uses of DataInputView in org.apache.flink.graph.drivers.transform

Methods in org.apache.flink.graph.drivers.transform with parameters of type DataInputView

Modifier and Type	Method and Description
void	LongValueWithProperHashCode.LongValueWithProperHashCodeSerializer.copy(DataInputView source, DataOutputView target)
LongValueWithProperHashCode	LongValueWithProperHashCode.LongValueWithProperHashCodeSerializer.deserialize(DataInputView source)
LongValueWithProperHashCode	LongValueWithProperHashCode.LongValueWithProperHashCodeSerializer.deserialize(LongValueWithProperHashCode reuse, DataInputView source)

Uses of DataInputView in org.apache.flink.graph.types.valuearray

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

Modifier and Type	Method and Description
int	ByteValueArrayComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	CharValueArrayComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	NullValueArrayComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	DoubleValueArrayComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	StringValueArrayComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	FloatValueArrayComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	IntValueArrayComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	LongValueArrayComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
int	ShortValueArrayComparator.compareSerialized(DataInputView firstSource, DataInputView secondSource)
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)
ByteValueArray	ByteValueArraySerializer.deserialize(ByteValueArray reuse, DataInputView source)
CharValueArray	CharValueArraySerializer.deserialize(CharValueArray reuse, DataInputView source)
ByteValueArray	ByteValueArraySerializer.deserialize(DataInputView source)
NullValueArray	NullValueArraySerializer.deserialize(DataInputView source)
CharValueArray	CharValueArraySerializer.deserialize(DataInputView source)
FloatValueArray	FloatValueArraySerializer.deserialize(DataInputView source)
LongValueArray	LongValueArraySerializer.deserialize(DataInputView source)
IntValueArray	IntValueArraySerializer.deserialize(DataInputView source)
DoubleValueArray	DoubleValueArraySerializer.deserialize(DataInputView source)
ShortValueArray	ShortValueArraySerializer.deserialize(DataInputView source)
StringValueArray	StringValueArraySerializer.deserialize(DataInputView source)
DoubleValueArray	DoubleValueArraySerializer.deserialize(DoubleValueArray reuse, DataInputView source)
FloatValueArray	FloatValueArraySerializer.deserialize(FloatValueArray reuse, DataInputView source)
IntValueArray	IntValueArraySerializer.deserialize(IntValueArray reuse, DataInputView source)
LongValueArray	LongValueArraySerializer.deserialize(LongValueArray reuse, DataInputView source)
NullValueArray	NullValueArraySerializer.deserialize(NullValueArray reuse, DataInputView source)
ShortValueArray	ShortValueArraySerializer.deserialize(ShortValueArray reuse, DataInputView source)
StringValueArray	StringValueArraySerializer.deserialize(StringValueArray reuse, DataInputView source)
void	LongValueArray.read(DataInputView in)
void	NullValueArray.read(DataInputView in)
void	StringValueArray.read(DataInputView in)
void	DoubleValueArray.read(DataInputView in)
void	ByteValueArray.read(DataInputView in)
void	IntValueArray.read(DataInputView in)
void	FloatValueArray.read(DataInputView in)
void	CharValueArray.read(DataInputView in)
void	ShortValueArray.read(DataInputView in)
ByteValueArray	ByteValueArrayComparator.readWithKeyDenormalization(ByteValueArray reuse, DataInputView source)
CharValueArray	CharValueArrayComparator.readWithKeyDenormalization(CharValueArray reuse, DataInputView source)
DoubleValueArray	DoubleValueArrayComparator.readWithKeyDenormalization(DoubleValueArray reuse, DataInputView source)
FloatValueArray	FloatValueArrayComparator.readWithKeyDenormalization(FloatValueArray reuse, DataInputView source)
IntValueArray	IntValueArrayComparator.readWithKeyDenormalization(IntValueArray reuse, DataInputView source)
LongValueArray	LongValueArrayComparator.readWithKeyDenormalization(LongValueArray reuse, DataInputView source)
NullValueArray	NullValueArrayComparator.readWithKeyDenormalization(NullValueArray reuse, DataInputView source)
ShortValueArray	ShortValueArrayComparator.readWithKeyDenormalization(ShortValueArray reuse, DataInputView source)
StringValueArray	StringValueArrayComparator.readWithKeyDenormalization(StringValueArray reuse, DataInputView source)

Uses of DataInputView in org.apache.flink.queryablestate.client

Methods in org.apache.flink.queryablestate.client with parameters of type DataInputView

Modifier and Type	Method and Description
void	VoidNamespaceSerializer.copy(DataInputView source, DataOutputView target)
VoidNamespace	VoidNamespaceSerializer.deserialize(DataInputView source)
VoidNamespace	VoidNamespaceSerializer.deserialize(VoidNamespace reuse, DataInputView source)

Uses of DataInputView in org.apache.flink.runtime.io.disk

Classes in org.apache.flink.runtime.io.disk that implement DataInputView

Modifier and Type	Class and Description
class	FileChannelInputView A DataInputView that is backed by a BlockChannelReader, making it effectively a data input stream.
class	RandomAccessInputView
class	SeekableFileChannelInputView A DataInputView that is backed by a BlockChannelReader, making it effectively a data input stream.

Methods in org.apache.flink.runtime.io.disk that return DataInputView

Modifier and Type	Method and Description
DataInputView	SpillingBuffer.flip()

Constructors in org.apache.flink.runtime.io.disk with parameters of type DataInputView

Constructor and Description
InputViewIterator(DataInputView inputView, TypeSerializer<E> serializer)

Uses of DataInputView in org.apache.flink.runtime.io.disk.iomanager

Classes in org.apache.flink.runtime.io.disk.iomanager that implement DataInputView

Modifier and Type	Class and Description
class	ChannelReaderInputView A DataInputView that is backed by a BlockChannelReader, making it effectively a data input stream.
class	HeaderlessChannelReaderInputView A DataInputView that is backed by a BlockChannelReader, making it effectively a data input stream.

Uses of DataInputView in org.apache.flink.runtime.io.network.api

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

Modifier and Type	Method and Description
void	CheckpointBarrier.read(DataInputView in)
void	CancelCheckpointMarker.read(DataInputView in)
void	EndOfPartitionEvent.read(DataInputView in)
void	EndOfSuperstepEvent.read(DataInputView in)

Uses of DataInputView in org.apache.flink.runtime.iterative.concurrent

Methods in org.apache.flink.runtime.iterative.concurrent that return DataInputView

Modifier and Type	Method and Description
DataInputView	BlockingBackChannel.getReadEndAfterSuperstepEnded() Called by iteration head after it has sent all input for the current superstep through the data channel (blocks iteration head).

Uses of DataInputView in org.apache.flink.runtime.iterative.event

Methods in org.apache.flink.runtime.iterative.event with parameters of type DataInputView

Modifier and Type	Method and Description
void	WorkerDoneEvent.read(DataInputView in)
void	IterationEventWithAggregators.read(DataInputView in)
void	TerminationEvent.read(DataInputView in)

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

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

Modifier and Type	Class and Description
class	AbstractPagedInputView The base class for all input views that are backed by multiple memory pages.

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

Modifier and Type	Method and Description
void	AbstractPagedOutputView.write(DataInputView source, int numBytes)

Uses of DataInputView in org.apache.flink.runtime.operators.hash

Classes in org.apache.flink.runtime.operators.hash that implement DataInputView

Modifier and Type	Class and Description
class	HashPartition<BT,PT>
class	ReOpenableHashPartition<BT,PT>

Uses of DataInputView in org.apache.flink.runtime.operators.resettable

Fields in org.apache.flink.runtime.operators.resettable declared as DataInputView

Modifier and Type	Field and Description
protected DataInputView	SpillingResettableMutableObjectIterator.inView
protected DataInputView	SpillingResettableIterator.inView

Uses of DataInputView in org.apache.flink.runtime.plugable

Methods in org.apache.flink.runtime.plugable with parameters of type DataInputView

Modifier and Type	Method and Description
void	ReusingDeserializationDelegate.read(DataInputView in)
void	SerializationDelegate.read(DataInputView in)
void	NonReusingDeserializationDelegate.read(DataInputView in)

Uses of DataInputView in org.apache.flink.runtime.state

Methods in org.apache.flink.runtime.state with parameters of type DataInputView

Modifier and Type	Method and Description
void	VoidNamespaceSerializer.copy(DataInputView source, DataOutputView target)
void	ArrayListSerializer.copy(DataInputView source, DataOutputView target)
ArrayList<T>	ArrayListSerializer.deserialize(ArrayList<T> reuse, DataInputView source)
VoidNamespace	VoidNamespaceSerializer.deserialize(DataInputView source)
ArrayList<T>	ArrayListSerializer.deserialize(DataInputView source)
VoidNamespace	VoidNamespaceSerializer.deserialize(VoidNamespace reuse, DataInputView source)
void	KeyedBackendSerializationProxy.read(DataInputView in)
void	OperatorBackendSerializationProxy.read(DataInputView in)
RegisteredBroadcastBackendStateMetaInfo.Snapshot<K,V>	OperatorBackendStateMetaInfoSnapshotReaderWriters.BroadcastStateMetaInfoReader.readBroadcastStateMetaInfo(DataInputView in)
RegisteredBroadcastBackendStateMetaInfo.Snapshot<K,V>	OperatorBackendStateMetaInfoSnapshotReaderWriters.BroadcastStateMetaInfoReaderV3.readBroadcastStateMetaInfo(DataInputView in)
RegisteredOperatorBackendStateMetaInfo.Snapshot<S>	OperatorBackendStateMetaInfoSnapshotReaderWriters.OperatorBackendStateMetaInfoReader.readOperatorStateMetaInfo(DataInputView in)
RegisteredOperatorBackendStateMetaInfo.Snapshot<S>	OperatorBackendStateMetaInfoSnapshotReaderWriters.OperatorBackendStateMetaInfoReaderV1.readOperatorStateMetaInfo(DataInputView in)
RegisteredOperatorBackendStateMetaInfo.Snapshot<S>	OperatorBackendStateMetaInfoSnapshotReaderWriters.OperatorBackendStateMetaInfoReaderV2.readOperatorStateMetaInfo(DataInputView in)
RegisteredKeyedBackendStateMetaInfo.Snapshot<N,S>	KeyedBackendStateMetaInfoSnapshotReaderWriters.KeyedBackendStateMetaInfoReader.readStateMetaInfo(DataInputView in)

Uses of DataInputView in org.apache.flink.streaming.api.functions.sink

Methods in org.apache.flink.streaming.api.functions.sink with parameters of type DataInputView

Modifier and Type	Method and Description
void	TwoPhaseCommitSinkFunction.StateSerializer.copy(DataInputView source, DataOutputView target)
TwoPhaseCommitSinkFunction.State<TXN,CONTEXT>	TwoPhaseCommitSinkFunction.StateSerializer.deserialize(DataInputView source)
TwoPhaseCommitSinkFunction.State<TXN,CONTEXT>	TwoPhaseCommitSinkFunction.StateSerializer.deserialize(TwoPhaseCommitSinkFunction.State<TXN,CONTEXT> reuse, DataInputView source)

Uses of DataInputView in org.apache.flink.streaming.api.operators

Methods in org.apache.flink.streaming.api.operators with parameters of type DataInputView

Modifier and Type	Method and Description
void	InternalTimer.TimerSerializer.copy(DataInputView source, DataOutputView target)
InternalTimer<K,N>	InternalTimer.TimerSerializer.deserialize(DataInputView source)
InternalTimer<K,N>	InternalTimer.TimerSerializer.deserialize(InternalTimer<K,N> reuse, DataInputView source)
protected void	InternalTimerServiceSerializationProxy.read(DataInputView in, boolean wasVersioned)
InternalTimersSnapshot<K,N>	InternalTimersSnapshotReaderWriters.InternalTimersSnapshotReader.readTimersSnapshot(DataInputView in) Reads a timers snapshot from the provided input view.

Uses of DataInputView in org.apache.flink.streaming.api.windowing.windows

Methods in org.apache.flink.streaming.api.windowing.windows with parameters of type DataInputView

Modifier and Type	Method and Description
void	TimeWindow.Serializer.copy(DataInputView source, DataOutputView target)
void	GlobalWindow.Serializer.copy(DataInputView source, DataOutputView target)
TimeWindow	TimeWindow.Serializer.deserialize(DataInputView source)
GlobalWindow	GlobalWindow.Serializer.deserialize(DataInputView source)
GlobalWindow	GlobalWindow.Serializer.deserialize(GlobalWindow reuse, DataInputView source)
TimeWindow	TimeWindow.Serializer.deserialize(TimeWindow reuse, DataInputView source)

Uses of DataInputView in org.apache.flink.streaming.connectors.kafka

Methods in org.apache.flink.streaming.connectors.kafka with parameters of type DataInputView

Modifier and Type	Method and Description
void	FlinkKafkaProducer011.TransactionStateSerializer.copy(DataInputView source, DataOutputView target)
void	FlinkKafkaProducer011.ContextStateSerializer.copy(DataInputView source, DataOutputView target)
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer011.KafkaTransactionState	FlinkKafkaProducer011.TransactionStateSerializer.deserialize(DataInputView source)
FlinkKafkaProducer011.KafkaTransactionContext	FlinkKafkaProducer011.ContextStateSerializer.deserialize(DataInputView source)
FlinkKafkaProducer011.KafkaTransactionContext	FlinkKafkaProducer011.ContextStateSerializer.deserialize(FlinkKafkaProducer011.KafkaTransactionContext reuse, DataInputView source)
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer011.KafkaTransactionState	FlinkKafkaProducer011.TransactionStateSerializer.deserialize(org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer011.KafkaTransactionState reuse, DataInputView source)

Uses of DataInputView in org.apache.flink.streaming.runtime.streamrecord

Methods in org.apache.flink.streaming.runtime.streamrecord with parameters of type DataInputView

Modifier and Type	Method and Description
void	StreamElementSerializer.copy(DataInputView source, DataOutputView target)
StreamElement	StreamElementSerializer.deserialize(DataInputView source)
StreamElement	StreamElementSerializer.deserialize(StreamElement reuse, DataInputView source)

Uses of DataInputView in org.apache.flink.types

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

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)
void	Record.deserialize(DataInputView source)
void	ByteValue.read(DataInputView in)
void	StringValue.read(DataInputView in)
void	NullValue.read(DataInputView in)
void	IntValue.read(DataInputView in)
void	Record.read(DataInputView in)
void	ListValue.read(DataInputView in)
void	FloatValue.read(DataInputView in)
void	BooleanValue.read(DataInputView in)
void	ShortValue.read(DataInputView in)
void	CharValue.read(DataInputView in)
void	DoubleValue.read(DataInputView in)
void	MapValue.read(DataInputView in)
void	LongValue.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 and Description
static String	StringUtils.readNullableString(DataInputView in) Reads a String from the given input.
static String	StringUtils.readString(DataInputView in) Reads a non-null String from the given input.