Modifier and Type | Method and Description |
---|---|
protected abstract T |
BinaryInputFormat.deserialize(T reuse,
DataInputView dataInput) |
protected T |
SerializedInputFormat.deserialize(T reuse,
DataInputView dataInput) |
void |
BlockInfo.read(DataInputView in) |
Modifier and Type | Method and Description |
---|---|
abstract int |
TypeComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource)
Compares two records in serialized form.
|
abstract void |
TypeSerializer.copy(DataInputView source,
DataOutputView target)
Copies exactly one record from the source input view to the target output view.
|
void |
SingleThreadAccessCheckingTypeSerializer.copy(DataInputView source,
DataOutputView target) |
void |
UnloadableDummyTypeSerializer.copy(DataInputView source,
DataOutputView target) |
void |
CompositeSerializer.copy(DataInputView source,
DataOutputView target) |
abstract T |
TypeSerializer.deserialize(DataInputView source)
De-serializes a record from the given source input view.
|
T |
SingleThreadAccessCheckingTypeSerializer.deserialize(DataInputView source) |
T |
UnloadableDummyTypeSerializer.deserialize(DataInputView source) |
T |
CompositeSerializer.deserialize(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.
|
T |
SingleThreadAccessCheckingTypeSerializer.deserialize(T reuse,
DataInputView source) |
T |
UnloadableDummyTypeSerializer.deserialize(T reuse,
DataInputView source) |
T |
CompositeSerializer.deserialize(T reuse,
DataInputView source) |
static NestedSerializersSnapshotDelegate |
NestedSerializersSnapshotDelegate.legacyReadNestedSerializerSnapshots(DataInputView in,
ClassLoader cl)
Reads the composite snapshot of all the contained serializers in a way that is compatible
with Version 1 of the deprecated
CompositeTypeSerializerConfigSnapshot . |
void |
GenericTypeSerializerConfigSnapshot.read(DataInputView in) |
void |
ParameterlessTypeSerializerConfig.read(DataInputView in)
Deprecated.
|
void |
TypeSerializerSerializationUtil.TypeSerializerSerializationProxy.read(DataInputView in) |
void |
CompositeTypeSerializerConfigSnapshot.read(DataInputView in) |
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 List<Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> |
TypeSerializerSerializationUtil.readSerializersAndConfigsWithResilience(DataInputView in,
ClassLoader userCodeClassLoader)
Deprecated.
Reads from a data input view a list of serializers and their corresponding config snapshots
written using
TypeSerializerSerializationUtil.writeSerializersAndConfigsWithResilience(DataOutputView, List) . |
static <T> TypeSerializerSnapshot<T> |
TypeSerializerSnapshotSerializationUtil.readSerializerSnapshot(DataInputView in,
ClassLoader userCodeClassLoader,
TypeSerializer<T> existingPriorSerializer)
Reads from a data input view a
TypeSerializerSnapshot that was previously written
using TypeSerializerSnapshotSerializationUtil.writeSerializerSnapshot(DataOutputView,
TypeSerializerSnapshot, TypeSerializer) . |
void |
SimpleTypeSerializerSnapshot.readSnapshot(int readVersion,
DataInputView in,
ClassLoader classLoader) |
void |
GenericTypeSerializerSnapshot.readSnapshot(int readVersion,
DataInputView in,
ClassLoader userCodeClassLoader) |
void |
CompositeTypeSerializerSnapshot.readSnapshot(int readVersion,
DataInputView in,
ClassLoader userCodeClassLoader) |
void |
TypeSerializerConfigSnapshot.readSnapshot(int readVersion,
DataInputView in,
ClassLoader userCodeClassLoader)
Deprecated.
|
void |
BackwardsCompatibleSerializerSnapshot.readSnapshot(int version,
DataInputView in,
ClassLoader userCodeClassLoader) |
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.
|
static <T> TypeSerializer<T> |
TypeSerializerSerializationUtil.tryReadSerializer(DataInputView in,
ClassLoader userCodeClassLoader)
Deprecated.
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)
Deprecated.
Reads from a data input view a
TypeSerializer that was previously written using
TypeSerializerSerializationUtil.writeSerializer(DataOutputView, TypeSerializer) . |
Modifier and Type | Method and Description |
---|---|
int |
BooleanValueComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
StringValueComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
CharComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
BigIntComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
CharValueComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
LocalTimeComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
ShortValueComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
ByteValueComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
SqlTimestampComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
FloatValueComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
FloatComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
InstantComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
LocalDateComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
LocalDateTimeComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
IntValueComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
StringComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
ByteComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
BooleanComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
IntComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
DoubleValueComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
EnumComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
DoubleComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
LongComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
BigDecComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
DateComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
LongValueComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
ShortComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
NullValueComparator.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 |
DoubleValueSerializer.copy(DataInputView source,
DataOutputView target) |
void |
BooleanValueSerializer.copy(DataInputView source,
DataOutputView target) |
void |
CharValueSerializer.copy(DataInputView source,
DataOutputView target) |
void |
BooleanSerializer.copy(DataInputView source,
DataOutputView target) |
void |
EnumSerializer.copy(DataInputView source,
DataOutputView target) |
void |
VoidSerializer.copy(DataInputView source,
DataOutputView target) |
void |
IntValueSerializer.copy(DataInputView source,
DataOutputView target) |
void |
FloatValueSerializer.copy(DataInputView source,
DataOutputView target) |
void |
CharSerializer.copy(DataInputView source,
DataOutputView target) |
void |
InstantSerializer.copy(DataInputView source,
DataOutputView target) |
void |
DateSerializer.copy(DataInputView source,
DataOutputView target) |
void |
LongSerializer.copy(DataInputView source,
DataOutputView target) |
void |
ByteValueSerializer.copy(DataInputView source,
DataOutputView target) |
void |
SqlDateSerializer.copy(DataInputView source,
DataOutputView target) |
void |
DoubleSerializer.copy(DataInputView source,
DataOutputView target) |
void |
StringSerializer.copy(DataInputView source,
DataOutputView target) |
void |
LocalDateTimeSerializer.copy(DataInputView source,
DataOutputView target) |
void |
BigDecSerializer.copy(DataInputView source,
DataOutputView target) |
void |
IntSerializer.copy(DataInputView source,
DataOutputView target) |
void |
LocalTimeSerializer.copy(DataInputView source,
DataOutputView target) |
void |
NullValueSerializer.copy(DataInputView source,
DataOutputView target) |
void |
SqlTimeSerializer.copy(DataInputView source,
DataOutputView target) |
void |
MapSerializer.copy(DataInputView source,
DataOutputView target) |
void |
BigIntSerializer.copy(DataInputView source,
DataOutputView target) |
void |
GenericArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
LocalDateSerializer.copy(DataInputView source,
DataOutputView target) |
void |
SqlTimestampSerializer.copy(DataInputView source,
DataOutputView target) |
void |
ShortValueSerializer.copy(DataInputView source,
DataOutputView target) |
void |
LongValueSerializer.copy(DataInputView source,
DataOutputView target) |
void |
ListSerializer.copy(DataInputView source,
DataOutputView target) |
void |
StringValueSerializer.copy(DataInputView source,
DataOutputView target) |
void |
ShortSerializer.copy(DataInputView source,
DataOutputView target) |
void |
ByteSerializer.copy(DataInputView source,
DataOutputView target) |
void |
FloatSerializer.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) |
DoubleValue |
DoubleValueSerializer.deserialize(DataInputView source) |
BooleanValue |
BooleanValueSerializer.deserialize(DataInputView source) |
CharValue |
CharValueSerializer.deserialize(DataInputView source) |
Boolean |
BooleanSerializer.deserialize(DataInputView source) |
T |
EnumSerializer.deserialize(DataInputView source) |
Void |
VoidSerializer.deserialize(DataInputView source) |
IntValue |
IntValueSerializer.deserialize(DataInputView source) |
FloatValue |
FloatValueSerializer.deserialize(DataInputView source) |
Character |
CharSerializer.deserialize(DataInputView source) |
java.time.Instant |
InstantSerializer.deserialize(DataInputView source) |
Date |
DateSerializer.deserialize(DataInputView source) |
Long |
LongSerializer.deserialize(DataInputView source) |
ByteValue |
ByteValueSerializer.deserialize(DataInputView source) |
Date |
SqlDateSerializer.deserialize(DataInputView source) |
Double |
DoubleSerializer.deserialize(DataInputView source) |
String |
StringSerializer.deserialize(DataInputView source) |
java.time.LocalDateTime |
LocalDateTimeSerializer.deserialize(DataInputView source) |
BigDecimal |
BigDecSerializer.deserialize(DataInputView source) |
Integer |
IntSerializer.deserialize(DataInputView source) |
java.time.LocalTime |
LocalTimeSerializer.deserialize(DataInputView source) |
NullValue |
NullValueSerializer.deserialize(DataInputView source) |
Time |
SqlTimeSerializer.deserialize(DataInputView source) |
Map<K,V> |
MapSerializer.deserialize(DataInputView source) |
BigInteger |
BigIntSerializer.deserialize(DataInputView source) |
C[] |
GenericArraySerializer.deserialize(DataInputView source) |
java.time.LocalDate |
LocalDateSerializer.deserialize(DataInputView source) |
Timestamp |
SqlTimestampSerializer.deserialize(DataInputView source) |
ShortValue |
ShortValueSerializer.deserialize(DataInputView source) |
LongValue |
LongValueSerializer.deserialize(DataInputView source) |
List<T> |
ListSerializer.deserialize(DataInputView source) |
StringValue |
StringValueSerializer.deserialize(DataInputView source) |
Short |
ShortSerializer.deserialize(DataInputView source) |
Byte |
ByteSerializer.deserialize(DataInputView source) |
Float |
FloatSerializer.deserialize(DataInputView source) |
Date |
DateSerializer.deserialize(Date reuse,
DataInputView source) |
Date |
SqlDateSerializer.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) |
java.time.Instant |
InstantSerializer.deserialize(java.time.Instant 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) |
java.time.LocalDate |
LocalDateSerializer.deserialize(java.time.LocalDate reuse,
DataInputView source) |
java.time.LocalDateTime |
LocalDateTimeSerializer.deserialize(java.time.LocalDateTime reuse,
DataInputView source) |
java.time.LocalTime |
LocalTimeSerializer.deserialize(java.time.LocalTime 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 |
EnumSerializer.EnumSerializerConfigSnapshot.read(DataInputView in)
Deprecated.
|
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.
|
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) |
T |
BasicTypeComparator.readWithKeyDenormalization(T reuse,
DataInputView source) |
Modifier and Type | Method and Description |
---|---|
int |
PrimitiveArrayComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
void |
FloatPrimitiveArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
StringArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
BooleanPrimitiveArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
LongPrimitiveArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
ShortPrimitiveArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
IntPrimitiveArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
DoublePrimitiveArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
BytePrimitiveArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
CharPrimitiveArraySerializer.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) |
float[] |
FloatPrimitiveArraySerializer.deserialize(DataInputView source) |
String[] |
StringArraySerializer.deserialize(DataInputView source) |
boolean[] |
BooleanPrimitiveArraySerializer.deserialize(DataInputView source) |
long[] |
LongPrimitiveArraySerializer.deserialize(DataInputView source) |
short[] |
ShortPrimitiveArraySerializer.deserialize(DataInputView source) |
int[] |
IntPrimitiveArraySerializer.deserialize(DataInputView source) |
double[] |
DoublePrimitiveArraySerializer.deserialize(DataInputView source) |
byte[] |
BytePrimitiveArraySerializer.deserialize(DataInputView source) |
char[] |
CharPrimitiveArraySerializer.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) |
Modifier and Type | Method and Description |
---|---|
protected T |
TypeSerializerInputFormat.deserialize(T reuse,
DataInputView dataInput) |
Modifier and Type | Field and Description |
---|---|
protected DataInputView |
DataInputViewStream.inputView |
Modifier and Type | Method and Description |
---|---|
DataInputView |
DataInputViewStream.getInputView() |
Modifier and Type | Method and Description |
---|---|
int |
WritableComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
CopyableValueComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
GenericTypeComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
ValueComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
TupleComparatorBase.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
RowComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
PojoComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
NullAwareComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
void |
WritableSerializer.copy(DataInputView source,
DataOutputView target) |
void |
PojoSerializer.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 |
ValueSerializer.copy(DataInputView source,
DataOutputView target) |
void |
NullableSerializer.copy(DataInputView source,
DataOutputView target) |
void |
EitherSerializer.copy(DataInputView source,
DataOutputView target) |
T |
WritableSerializer.deserialize(DataInputView source) |
T |
PojoSerializer.deserialize(DataInputView source) |
T |
CopyableValueSerializer.deserialize(DataInputView source) |
Tuple0 |
Tuple0Serializer.deserialize(DataInputView source) |
T |
TupleSerializer.deserialize(DataInputView source) |
Row |
RowSerializer.deserialize(DataInputView source) |
T |
ValueSerializer.deserialize(DataInputView source) |
T |
NullableSerializer.deserialize(DataInputView source) |
Either<L,R> |
EitherSerializer.deserialize(DataInputView source) |
Either<L,R> |
EitherSerializer.deserialize(Either<L,R> reuse,
DataInputView source) |
Row |
RowSerializer.deserialize(Row reuse,
DataInputView source) |
T |
WritableSerializer.deserialize(T reuse,
DataInputView source) |
T |
PojoSerializer.deserialize(T reuse,
DataInputView source) |
T |
CopyableValueSerializer.deserialize(T reuse,
DataInputView source) |
T |
TupleSerializer.deserialize(T reuse,
DataInputView source) |
T |
ValueSerializer.deserialize(T reuse,
DataInputView source) |
T |
NullableSerializer.deserialize(T reuse,
DataInputView source) |
Tuple0 |
Tuple0Serializer.deserialize(Tuple0 reuse,
DataInputView source) |
void |
PojoSerializer.PojoSerializerConfigSnapshot.read(DataInputView in)
Deprecated.
|
void |
TupleSerializerConfigSnapshot.read(DataInputView in) |
void |
KryoRegistrationSerializerConfigSnapshot.read(DataInputView in) |
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 |
TupleSerializerSnapshot.readOuterSnapshot(int readOuterSnapshotVersion,
DataInputView in,
ClassLoader userCodeClassLoader) |
protected void |
RowSerializer.RowSerializerSnapshot.readOuterSnapshot(int readOuterSnapshotVersion,
DataInputView in,
ClassLoader userCodeClassLoader) |
protected void |
NullableSerializer.NullableSerializerSnapshot.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) |
Row |
RowComparator.readWithKeyDenormalization(Row reuse,
DataInputView source) |
T |
WritableComparator.readWithKeyDenormalization(T reuse,
DataInputView source) |
T |
CopyableValueComparator.readWithKeyDenormalization(T reuse,
DataInputView source) |
T |
GenericTypeComparator.readWithKeyDenormalization(T reuse,
DataInputView source) |
T |
ValueComparator.readWithKeyDenormalization(T reuse,
DataInputView source) |
T |
TupleComparatorBase.readWithKeyDenormalization(T reuse,
DataInputView source) |
T |
PojoComparator.readWithKeyDenormalization(T reuse,
DataInputView source) |
T |
NullAwareComparator.readWithKeyDenormalization(T reuse,
DataInputView source) |
Constructor and Description |
---|
DataInputViewStream(DataInputView inputView) |
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) |
void |
KryoSerializerSnapshot.readSnapshot(int readVersion,
DataInputView in,
ClassLoader userCodeClassLoader) |
Modifier and Type | Method and Description |
---|---|
protected void |
ScalaCaseClassSerializerSnapshot.readOuterSnapshot(int readOuterSnapshotVersion,
DataInputView in,
ClassLoader userCodeClassLoader) |
protected void |
Tuple2CaseClassSerializerSnapshot.readOuterSnapshot(int readOuterSnapshotVersion,
DataInputView in,
ClassLoader userCodeClassLoader) |
protected void |
TraversableSerializerSnapshot.readOuterSnapshot(int readOuterSnapshotVersion,
DataInputView in,
ClassLoader userCodeClassLoader) |
Modifier and Type | Method and Description |
---|---|
void |
NFAStateSerializer.copy(DataInputView source,
DataOutputView target) |
void |
DeweyNumber.DeweyNumberSerializer.copy(DataInputView source,
DataOutputView target) |
void |
SharedBuffer.SharedBufferSerializer.copy(DataInputView source,
DataOutputView target) |
void |
NFA.NFASerializer.copy(DataInputView source,
DataOutputView target)
Deprecated.
|
NFAState |
NFAStateSerializer.deserialize(DataInputView source) |
DeweyNumber |
DeweyNumber.DeweyNumberSerializer.deserialize(DataInputView source) |
SharedBuffer<V> |
SharedBuffer.SharedBufferSerializer.deserialize(DataInputView source) |
NFA.MigratedNFA<T> |
NFA.NFASerializer.deserialize(DataInputView source)
Deprecated.
|
DeweyNumber |
DeweyNumber.DeweyNumberSerializer.deserialize(DeweyNumber reuse,
DataInputView source) |
NFA.MigratedNFA<T> |
NFA.NFASerializer.deserialize(NFA.MigratedNFA<T> reuse,
DataInputView source)
Deprecated.
|
NFAState |
NFAStateSerializer.deserialize(NFAState reuse,
DataInputView source) |
SharedBuffer<V> |
SharedBuffer.SharedBufferSerializer.deserialize(SharedBuffer<V> reuse,
DataInputView source) |
Modifier and Type | Method and Description |
---|---|
void |
EventId.EventIdSerializer.copy(DataInputView source,
DataOutputView target) |
void |
SharedBufferNode.SharedBufferNodeSerializer.copy(DataInputView source,
DataOutputView target)
Deprecated.
|
void |
Lockable.LockableTypeSerializer.copy(DataInputView source,
DataOutputView target) |
void |
SharedBufferNodeSerializer.copy(DataInputView source,
DataOutputView target) |
void |
SharedBufferEdge.SharedBufferEdgeSerializer.copy(DataInputView source,
DataOutputView target) |
void |
NodeId.NodeIdSerializer.copy(DataInputView source,
DataOutputView target) |
EventId |
EventId.EventIdSerializer.deserialize(DataInputView source) |
SharedBufferNode |
SharedBufferNode.SharedBufferNodeSerializer.deserialize(DataInputView source)
Deprecated.
|
Lockable<E> |
Lockable.LockableTypeSerializer.deserialize(DataInputView source) |
SharedBufferNode |
SharedBufferNodeSerializer.deserialize(DataInputView source) |
SharedBufferEdge |
SharedBufferEdge.SharedBufferEdgeSerializer.deserialize(DataInputView source) |
NodeId |
NodeId.NodeIdSerializer.deserialize(DataInputView source) |
EventId |
EventId.EventIdSerializer.deserialize(EventId reuse,
DataInputView source) |
Lockable<E> |
Lockable.LockableTypeSerializer.deserialize(Lockable<E> reuse,
DataInputView source) |
NodeId |
NodeId.NodeIdSerializer.deserialize(NodeId reuse,
DataInputView source) |
SharedBufferEdge |
SharedBufferEdge.SharedBufferEdgeSerializer.deserialize(SharedBufferEdge reuse,
DataInputView source) |
SharedBufferNode |
SharedBufferNode.SharedBufferNodeSerializer.deserialize(SharedBufferNode reuse,
DataInputView source)
Deprecated.
|
SharedBufferNode |
SharedBufferNodeSerializer.deserialize(SharedBufferNode reuse,
DataInputView source) |
Modifier and Type | Method and Description |
---|---|
void |
DelegatingConfiguration.read(DataInputView in) |
void |
Configuration.read(DataInputView in) |
Modifier and Type | Method and Description |
---|---|
void |
CheckpointAndXidSerializer.copy(DataInputView source,
DataOutputView target) |
void |
XidSerializer.copy(DataInputView source,
DataOutputView target) |
void |
XaSinkStateSerializer.copy(DataInputView source,
DataOutputView target) |
CheckpointAndXid |
CheckpointAndXidSerializer.deserialize(CheckpointAndXid reuse,
DataInputView source) |
CheckpointAndXid |
CheckpointAndXidSerializer.deserialize(DataInputView source) |
Xid |
XidSerializer.deserialize(DataInputView source) |
org.apache.flink.connector.jdbc.xa.JdbcXaSinkFunctionState |
XaSinkStateSerializer.deserialize(DataInputView source) |
org.apache.flink.connector.jdbc.xa.JdbcXaSinkFunctionState |
XaSinkStateSerializer.deserialize(org.apache.flink.connector.jdbc.xa.JdbcXaSinkFunctionState reuse,
DataInputView source) |
Xid |
XidSerializer.deserialize(Xid reuse,
DataInputView source) |
void |
CheckpointAndXidSerializer.CheckpointAndXidSimpleTypeSerializerSnapshot.readSnapshot(int readVersion,
DataInputView in,
ClassLoader classLoader) |
void |
XidSerializer.XidSimpleTypeSerializerSnapshot.readSnapshot(int readVersion,
DataInputView in,
ClassLoader classLoader) |
void |
XaSinkStateSerializer.XaSinkStateSimpleXaTypeSerializerSnapshot.readSnapshot(int readVersion,
DataInputView in,
ClassLoader classLoader) |
Modifier and Type | Method and Description |
---|---|
void |
Path.read(DataInputView in) |
Modifier and Type | Method and 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. |
void |
VersionedIOReadableWritable.read(DataInputView in) |
protected abstract void |
PostVersionedIOReadableWritable.read(DataInputView in,
boolean wasVersioned)
Read from the provided
in . |
static <T> T |
SimpleVersionedSerialization.readVersionAndDeSerialize(SimpleVersionedSerializer<T> serializer,
DataInputView in)
Deserializes the version and datum from a stream.
|
Modifier and Type | Interface and Description |
---|---|
interface |
SeekableDataInputView
Interface marking a
DataInputView as seekable. |
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 . |
Modifier and Type | Method and Description |
---|---|
void |
DataOutputViewStreamWrapper.write(DataInputView source,
int numBytes) |
void |
DataOutputSerializer.write(DataInputView source,
int numBytes) |
void |
DataOutputView.write(DataInputView source,
int numBytes)
Copies
numBytes bytes from the source to this view. |
Modifier and Type | Method and Description |
---|---|
void |
AvroSerializer.copy(DataInputView source,
DataOutputView target) |
T |
AvroSerializer.deserialize(DataInputView source) |
T |
AvroSerializer.deserialize(T reuse,
DataInputView source) |
void |
AvroSerializerSnapshot.readSnapshot(int readVersion,
DataInputView in,
ClassLoader userCodeClassLoader) |
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) |
Modifier and Type | Method and Description |
---|---|
int |
StringValueArrayComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
LongValueArrayComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
IntValueArrayComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
FloatValueArrayComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
ByteValueArrayComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
ShortValueArrayComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
DoubleValueArrayComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
NullValueArrayComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
CharValueArrayComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
void |
ShortValueArray.copy(DataInputView source,
DataOutputView target) |
void |
ShortValueArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
NullValueArray.copy(DataInputView source,
DataOutputView target) |
void |
DoubleValueArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
ByteValueArray.copy(DataInputView source,
DataOutputView target) |
void |
LongValueArray.copy(DataInputView source,
DataOutputView target) |
void |
StringValueArray.copy(DataInputView source,
DataOutputView target) |
void |
FloatValueArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
CharValueArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
NullValueArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
DoubleValueArray.copy(DataInputView source,
DataOutputView target) |
void |
StringValueArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
FloatValueArray.copy(DataInputView source,
DataOutputView target) |
void |
ByteValueArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
IntValueArray.copy(DataInputView source,
DataOutputView target) |
void |
LongValueArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
IntValueArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
CharValueArray.copy(DataInputView source,
DataOutputView target) |
protected static void |
ShortValueArray.copyInternal(DataInputView source,
DataOutputView target) |
protected static void |
ByteValueArray.copyInternal(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 |
FloatValueArray.copyInternal(DataInputView source,
DataOutputView target) |
protected static void |
IntValueArray.copyInternal(DataInputView source,
DataOutputView target) |
protected static void |
CharValueArray.copyInternal(DataInputView source,
DataOutputView target) |
ByteValueArray |
ByteValueArraySerializer.deserialize(ByteValueArray reuse,
DataInputView source) |
CharValueArray |
CharValueArraySerializer.deserialize(CharValueArray reuse,
DataInputView source) |
ShortValueArray |
ShortValueArraySerializer.deserialize(DataInputView source) |
DoubleValueArray |
DoubleValueArraySerializer.deserialize(DataInputView source) |
FloatValueArray |
FloatValueArraySerializer.deserialize(DataInputView source) |
CharValueArray |
CharValueArraySerializer.deserialize(DataInputView source) |
NullValueArray |
NullValueArraySerializer.deserialize(DataInputView source) |
StringValueArray |
StringValueArraySerializer.deserialize(DataInputView source) |
ByteValueArray |
ByteValueArraySerializer.deserialize(DataInputView source) |
LongValueArray |
LongValueArraySerializer.deserialize(DataInputView source) |
IntValueArray |
IntValueArraySerializer.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 |
ShortValueArray.read(DataInputView in) |
void |
NullValueArray.read(DataInputView in) |
void |
ByteValueArray.read(DataInputView in) |
void |
LongValueArray.read(DataInputView in) |
void |
StringValueArray.read(DataInputView in) |
void |
DoubleValueArray.read(DataInputView in) |
void |
FloatValueArray.read(DataInputView in) |
void |
IntValueArray.read(DataInputView in) |
void |
CharValueArray.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) |
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) |
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. |
Modifier and Type | Method and Description |
---|---|
DataInputView |
SpillingBuffer.flip() |
Constructor and Description |
---|
InputViewIterator(DataInputView inputView,
TypeSerializer<E> serializer) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractChannelReaderInputView
A
DataInputView that is backed by a FileIOChannel ,
making it effectively a data input stream. |
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. |
Modifier and Type | Method and Description |
---|---|
void |
EventAnnouncement.read(DataInputView in) |
void |
SubtaskConnectionDescriptor.read(DataInputView in) |
void |
CheckpointBarrier.read(DataInputView in) |
void |
CancelCheckpointMarker.read(DataInputView in) |
void |
EndOfPartitionEvent.read(DataInputView in) |
void |
EndOfSuperstepEvent.read(DataInputView in) |
Modifier and Type | Method and Description |
---|---|
void |
EndOfChannelStateEvent.read(DataInputView in) |
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).
|
Modifier and Type | Method and Description |
---|---|
void |
IterationEventWithAggregators.read(DataInputView in) |
void |
TerminationEvent.read(DataInputView in) |
void |
WorkerDoneEvent.read(DataInputView in) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractPagedInputView
The base class for all input views that are backed by multiple memory pages.
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractPagedOutputView.write(DataInputView source,
int numBytes) |
Modifier and Type | Class and Description |
---|---|
class |
HashPartition<BT,PT> |
class |
ReOpenableHashPartition<BT,PT> |
Modifier and Type | Field and Description |
---|---|
protected DataInputView |
SpillingResettableIterator.inView |
protected DataInputView |
SpillingResettableMutableObjectIterator.inView |
Modifier and Type | Method and Description |
---|---|
void |
ReusingDeserializationDelegate.read(DataInputView in) |
void |
NonReusingDeserializationDelegate.read(DataInputView in) |
void |
SerializationDelegate.read(DataInputView in) |
Modifier and Type | Method and Description |
---|---|
void |
ArrayListSerializer.copy(DataInputView source,
DataOutputView target) |
void |
JavaSerializer.copy(DataInputView source,
DataOutputView target) |
void |
VoidNamespaceSerializer.copy(DataInputView source,
DataOutputView target) |
ArrayList<T> |
ArrayListSerializer.deserialize(ArrayList<T> reuse,
DataInputView source) |
ArrayList<T> |
ArrayListSerializer.deserialize(DataInputView source) |
T |
JavaSerializer.deserialize(DataInputView source) |
VoidNamespace |
VoidNamespaceSerializer.deserialize(DataInputView source) |
T |
JavaSerializer.deserialize(T reuse,
DataInputView source) |
VoidNamespace |
VoidNamespaceSerializer.deserialize(VoidNamespace reuse,
DataInputView source) |
void |
KeyedBackendSerializationProxy.read(DataInputView in) |
void |
OperatorBackendSerializationProxy.read(DataInputView in) |
T |
KeyGroupPartitioner.ElementReaderFunction.readElement(DataInputView div) |
static int |
CompositeKeySerializationUtils.readKeyGroup(int keyGroupPrefixBytes,
DataInputView inputView) |
void |
StateSnapshotKeyGroupReader.readMappingsInKeyGroup(DataInputView div,
int keyGroupId)
Read the data for the specified key-group from the input.
|
static void |
CompositeKeySerializationUtils.readVariableIntBytes(DataInputView inputView,
int value) |
Modifier and Type | Method and Description |
---|---|
StateMetaInfoSnapshot |
LegacyStateMetaInfoReaders.OperatorBackendStateMetaInfoReaderV1.readStateMetaInfoSnapshot(DataInputView in,
ClassLoader userCodeClassLoader) |
StateMetaInfoSnapshot |
StateMetaInfoReader.readStateMetaInfoSnapshot(DataInputView inputView,
ClassLoader userCodeClassLoader)
Reads a snapshot from the given input view.
|
Modifier and Type | Method and Description |
---|---|
void |
CoGroupedStreams.UnionSerializer.copy(DataInputView source,
DataOutputView target) |
CoGroupedStreams.TaggedUnion<T1,T2> |
CoGroupedStreams.UnionSerializer.deserialize(CoGroupedStreams.TaggedUnion<T1,T2> reuse,
DataInputView source) |
CoGroupedStreams.TaggedUnion<T1,T2> |
CoGroupedStreams.UnionSerializer.deserialize(DataInputView source) |
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) |
Modifier and Type | Method and Description |
---|---|
void |
TimerSerializer.copy(DataInputView source,
DataOutputView target) |
void |
InternalTimersSnapshotReaderWriters.LegacyTimerSerializer.copy(DataInputView source,
DataOutputView target) |
TimerHeapInternalTimer<K,N> |
TimerSerializer.deserialize(DataInputView source) |
TimerHeapInternalTimer<K,N> |
InternalTimersSnapshotReaderWriters.LegacyTimerSerializer.deserialize(DataInputView source) |
TimerHeapInternalTimer<K,N> |
TimerSerializer.deserialize(TimerHeapInternalTimer<K,N> reuse,
DataInputView source) |
TimerHeapInternalTimer<K,N> |
InternalTimersSnapshotReaderWriters.LegacyTimerSerializer.deserialize(TimerHeapInternalTimer<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.
|
Modifier and Type | Method and Description |
---|---|
void |
IntervalJoinOperator.BufferEntrySerializer.copy(DataInputView source,
DataOutputView target) |
IntervalJoinOperator.BufferEntry<T> |
IntervalJoinOperator.BufferEntrySerializer.deserialize(DataInputView source) |
IntervalJoinOperator.BufferEntry<T> |
IntervalJoinOperator.BufferEntrySerializer.deserialize(IntervalJoinOperator.BufferEntry<T> reuse,
DataInputView source) |
Constructor and Description |
---|
CollectCoordinationRequest(DataInputView inView) |
CollectCoordinationResponse(DataInputView inView) |
Modifier and Type | Method and Description |
---|---|
void |
ByteArrayWrapperSerializer.copy(DataInputView source,
DataOutputView target) |
ByteArrayWrapper |
ByteArrayWrapperSerializer.deserialize(ByteArrayWrapper reuse,
DataInputView source) |
ByteArrayWrapper |
ByteArrayWrapperSerializer.deserialize(DataInputView source) |
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) |
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) |
Modifier and Type | Method and Description |
---|---|
void |
StatefulComplexPayloadSerializer.copy(DataInputView source,
DataOutputView target) |
ComplexPayload |
StatefulComplexPayloadSerializer.deserialize(ComplexPayload reuse,
DataInputView source) |
ComplexPayload |
StatefulComplexPayloadSerializer.deserialize(DataInputView source) |
Modifier and Type | Method and Description |
---|---|
void |
NullAwareMapSerializer.copy(DataInputView source,
DataOutputView target)
Deprecated.
|
void |
ListViewSerializer.copy(DataInputView source,
DataOutputView target)
Deprecated.
|
void |
MapViewSerializer.copy(DataInputView source,
DataOutputView target)
Deprecated.
|
void |
NullSerializer.copy(DataInputView source,
DataOutputView target) |
Map<K,V> |
NullAwareMapSerializer.deserialize(DataInputView source)
Deprecated.
|
ListView<T> |
ListViewSerializer.deserialize(DataInputView source)
Deprecated.
|
MapView<K,V> |
MapViewSerializer.deserialize(DataInputView source)
Deprecated.
|
Object |
NullSerializer.deserialize(DataInputView source) |
ListView<T> |
ListViewSerializer.deserialize(ListView<T> reuse,
DataInputView source)
Deprecated.
|
Map<K,V> |
NullAwareMapSerializer.deserialize(Map<K,V> reuse,
DataInputView source)
Deprecated.
|
MapView<K,V> |
MapViewSerializer.deserialize(MapView<K,V> reuse,
DataInputView source)
Deprecated.
|
Object |
NullSerializer.deserialize(Object reuse,
DataInputView source) |
Modifier and Type | Class and Description |
---|---|
class |
BinaryHashPartition
A partition.
|
class |
LongHashPartition
Partition for
LongHybridHashTable . |
Modifier and Type | Class and Description |
---|---|
class |
CompressedHeaderlessChannelReaderInputView
A
DataInputView that is backed by a BufferFileReader , making it effectively a data input stream. |
Modifier and Type | Method and Description |
---|---|
void |
TimeWindow.Serializer.copy(DataInputView source,
DataOutputView target) |
void |
CountWindow.Serializer.copy(DataInputView source,
DataOutputView target) |
CountWindow |
CountWindow.Serializer.deserialize(CountWindow reuse,
DataInputView source) |
TimeWindow |
TimeWindow.Serializer.deserialize(DataInputView source) |
CountWindow |
CountWindow.Serializer.deserialize(DataInputView source) |
TimeWindow |
TimeWindow.Serializer.deserialize(TimeWindow reuse,
DataInputView source) |
Modifier and Type | Method and Description |
---|---|
void |
BinaryRowDataSerializer.copy(DataInputView source,
DataOutputView target) |
void |
RawValueDataSerializer.copy(DataInputView source,
DataOutputView target) |
void |
TimestampDataSerializer.copy(DataInputView source,
DataOutputView target) |
void |
LinkedListSerializer.copy(DataInputView source,
DataOutputView target) |
void |
WindowKeySerializer.copy(DataInputView source,
DataOutputView target) |
void |
ExternalSerializer.copy(DataInputView source,
DataOutputView target) |
void |
MapDataSerializer.copy(DataInputView source,
DataOutputView target) |
void |
StringDataSerializer.copy(DataInputView source,
DataOutputView target) |
void |
RowDataSerializer.copy(DataInputView source,
DataOutputView target) |
void |
ArrayDataSerializer.copy(DataInputView source,
DataOutputView target) |
void |
DecimalDataSerializer.copy(DataInputView source,
DataOutputView target) |
ArrayData |
ArrayDataSerializer.deserialize(ArrayData reuse,
DataInputView source) |
BinaryRowData |
BinaryRowDataSerializer.deserialize(BinaryRowData reuse,
DataInputView source) |
BinaryRowData |
BinaryRowDataSerializer.deserialize(DataInputView source) |
RawValueData<T> |
RawValueDataSerializer.deserialize(DataInputView source) |
TimestampData |
TimestampDataSerializer.deserialize(DataInputView source) |
LinkedList<T> |
LinkedListSerializer.deserialize(DataInputView source) |
WindowKey |
WindowKeySerializer.deserialize(DataInputView source) |
E |
ExternalSerializer.deserialize(DataInputView source) |
MapData |
MapDataSerializer.deserialize(DataInputView source) |
StringData |
StringDataSerializer.deserialize(DataInputView source) |
RowData |
RowDataSerializer.deserialize(DataInputView source) |
ArrayData |
ArrayDataSerializer.deserialize(DataInputView source) |
DecimalData |
DecimalDataSerializer.deserialize(DataInputView source) |
DecimalData |
DecimalDataSerializer.deserialize(DecimalData record,
DataInputView source) |
E |
ExternalSerializer.deserialize(E reuse,
DataInputView source) |
LinkedList<T> |
LinkedListSerializer.deserialize(LinkedList<T> reuse,
DataInputView source) |
MapData |
MapDataSerializer.deserialize(MapData reuse,
DataInputView source) |
RawValueData<T> |
RawValueDataSerializer.deserialize(RawValueData<T> record,
DataInputView source) |
RowData |
RowDataSerializer.deserialize(RowData reuse,
DataInputView source) |
StringData |
StringDataSerializer.deserialize(StringData record,
DataInputView source) |
TimestampData |
TimestampDataSerializer.deserialize(TimestampData reuse,
DataInputView source) |
WindowKey |
WindowKeySerializer.deserialize(WindowKey reuse,
DataInputView source) |
static StringData |
StringDataSerializer.deserializeInternal(DataInputView source) |
protected void |
LinkedListSerializer.LinkedListSerializerSnapshot.readOuterSnapshot(int readOuterSnapshotVersion,
DataInputView in,
ClassLoader userCodeClassLoader) |
protected void |
ExternalSerializer.ExternalSerializerSnapshot.readOuterSnapshot(int readOuterSnapshotVersion,
DataInputView in,
ClassLoader userCodeClassLoader) |
void |
BinaryRowDataSerializer.BinaryRowDataSerializerSnapshot.readSnapshot(int readVersion,
DataInputView in,
ClassLoader userCodeClassLoader) |
void |
TimestampDataSerializer.TimestampDataSerializerSnapshot.readSnapshot(int readVersion,
DataInputView in,
ClassLoader userCodeClassLoader) |
void |
MapDataSerializer.MapDataSerializerSnapshot.readSnapshot(int readVersion,
DataInputView in,
ClassLoader userCodeClassLoader) |
void |
RowDataSerializer.RowDataSerializerSnapshot.readSnapshot(int readVersion,
DataInputView in,
ClassLoader userCodeClassLoader) |
void |
ArrayDataSerializer.ArrayDataSerializerSnapshot.readSnapshot(int readVersion,
DataInputView in,
ClassLoader userCodeClassLoader) |
void |
SortedMapSerializerSnapshot.readSnapshot(int readVersion,
DataInputView in,
ClassLoader userCodeClassLoader) |
void |
DecimalDataSerializer.DecimalSerializerSnapshot.readSnapshot(int readVersion,
DataInputView in,
ClassLoader userCodeClassLoader) |
Modifier and Type | Method and Description |
---|---|
void |
TimeSerializer.copy(DataInputView source,
DataOutputView target) |
void |
DateSerializer.copy(DataInputView source,
DataOutputView target) |
void |
StringSerializer.copy(DataInputView source,
DataOutputView target) |
void |
BigDecSerializer.copy(DataInputView source,
DataOutputView target) |
void |
MapDataSerializer.copy(DataInputView source,
DataOutputView target) |
void |
TimestampSerializer.copy(DataInputView source,
DataOutputView target) |
void |
RowDataSerializer.copy(DataInputView source,
DataOutputView target) |
void |
ArrayDataSerializer.copy(DataInputView source,
DataOutputView target) |
void |
DecimalDataSerializer.copy(DataInputView source,
DataOutputView target) |
ArrayData |
ArrayDataSerializer.deserialize(ArrayData reuse,
DataInputView source) |
BigDecimal |
BigDecSerializer.deserialize(BigDecimal reuse,
DataInputView source) |
Time |
TimeSerializer.deserialize(DataInputView source) |
Date |
DateSerializer.deserialize(DataInputView source) |
String |
StringSerializer.deserialize(DataInputView source) |
BigDecimal |
BigDecSerializer.deserialize(DataInputView source) |
MapData |
MapDataSerializer.deserialize(DataInputView source) |
Timestamp |
TimestampSerializer.deserialize(DataInputView source) |
RowData |
RowDataSerializer.deserialize(DataInputView source) |
ArrayData |
ArrayDataSerializer.deserialize(DataInputView source) |
DecimalData |
DecimalDataSerializer.deserialize(DataInputView source) |
Date |
DateSerializer.deserialize(Date reuse,
DataInputView source) |
DecimalData |
DecimalDataSerializer.deserialize(DecimalData reuse,
DataInputView source) |
MapData |
MapDataSerializer.deserialize(MapData reuse,
DataInputView source) |
RowData |
RowDataSerializer.deserialize(RowData reuse,
DataInputView source) |
String |
StringSerializer.deserialize(String reuse,
DataInputView source) |
Time |
TimeSerializer.deserialize(Time reuse,
DataInputView source) |
Timestamp |
TimestampSerializer.deserialize(Timestamp reuse,
DataInputView source) |
void |
MapDataSerializer.BaseMapSerializerSnapshot.readSnapshot(int readVersion,
DataInputView in,
ClassLoader userCodeClassLoader) |
void |
TimestampSerializer.TimestampSerializerSnapshot.readSnapshot(int readVersion,
DataInputView in,
ClassLoader userCodeClassLoader) |
void |
RowDataSerializer.RowDataSerializerSnapshot.readSnapshot(int readVersion,
DataInputView in,
ClassLoader userCodeClassLoader) |
void |
ArrayDataSerializer.ArrayDataSerializerSnapshot.readSnapshot(int readVersion,
DataInputView in,
ClassLoader userCodeClassLoader) |
void |
DecimalDataSerializer.DecimalSerializerSnapshot.readSnapshot(int readVersion,
DataInputView in,
ClassLoader userCodeClassLoader) |
Modifier and Type | Method and Description |
---|---|
void |
ByteValue.copy(DataInputView source,
DataOutputView target) |
void |
DoubleValue.copy(DataInputView source,
DataOutputView target) |
void |
BooleanValue.copy(DataInputView source,
DataOutputView target) |
void |
CharValue.copy(DataInputView source,
DataOutputView target) |
void |
NullValue.copy(DataInputView source,
DataOutputView target) |
void |
LongValue.copy(DataInputView source,
DataOutputView target) |
void |
Record.copy(DataInputView source,
DataOutputView target) |
void |
IntValue.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 |
FloatValue.copy(DataInputView source,
DataOutputView target) |
void |
StringValue.copy(DataInputView in,
DataOutputView target) |
void |
Record.deserialize(DataInputView source) |
void |
ByteValue.read(DataInputView in) |
void |
DoubleValue.read(DataInputView in) |
void |
BooleanValue.read(DataInputView in) |
void |
CharValue.read(DataInputView in) |
void |
NullValue.read(DataInputView in) |
void |
LongValue.read(DataInputView in) |
void |
Record.read(DataInputView in) |
void |
IntValue.read(DataInputView in) |
void |
ShortValue.read(DataInputView in) |
void |
FloatValue.read(DataInputView in) |
void |
ListValue.read(DataInputView in) |
void |
StringValue.read(DataInputView in) |
void |
MapValue.read(DataInputView in) |
Modifier and Type | Method and 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.
|
Modifier and Type | Method and Description |
---|---|
static <K,V> LinkedOptionalMap<K,V> |
LinkedOptionalMapSerializer.readOptionalMap(DataInputView in,
BiFunctionWithException<DataInputView,String,K,IOException> keyReader,
BiFunctionWithException<DataInputView,String,V,IOException> valueReader) |
static <K,V> LinkedOptionalMap<K,V> |
LinkedOptionalMapSerializer.readOptionalMap(DataInputView in,
BiFunctionWithException<DataInputView,String,K,IOException> keyReader,
BiFunctionWithException<DataInputView,String,V,IOException> valueReader) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.