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) |
Modifier and Type | Method and Description |
---|---|
abstract int |
TypeComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource)
Compares two records in serialized from.
|
abstract void |
TypeSerializer.copy(DataInputView source,
DataOutputView target)
Copies exactly one record from the source input view to the target output view.
|
abstract T |
TypeSerializer.deserialize(DataInputView source)
De-serializes a record from the given source input view.
|
abstract T |
TypeSerializer.deserialize(T reuse,
DataInputView source)
De-serializes a record from the given source input view into the given reuse record instance if mutable.
|
void |
TypeSerializerSerializationProxy.read(DataInputView in) |
abstract T |
TypeComparator.readWithKeyDenormalization(T reuse,
DataInputView source)
Reads the record back while de-normalizing the key fields.
|
Modifier and Type | Method and Description |
---|---|
int |
StringValueComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
StringComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
SqlTimestampComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
ShortValueComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
ShortComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
NullValueComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
LongValueComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
LongComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
IntValueComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
IntComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
FloatValueComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
FloatComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
EnumComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
DoubleValueComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
DoubleComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
DateComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
CharValueComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
CharComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
ByteValueComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
ByteComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
BooleanValueComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
BooleanComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
BigIntComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
BigDecComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
static int |
DateComparator.compareSerializedDate(DataInputView firstSource,
DataInputView secondSource,
boolean ascendingComparison) |
void |
VoidSerializer.copy(DataInputView source,
DataOutputView target) |
void |
StringValueSerializer.copy(DataInputView source,
DataOutputView target) |
void |
StringSerializer.copy(DataInputView source,
DataOutputView target) |
void |
SqlTimestampSerializer.copy(DataInputView source,
DataOutputView target) |
void |
SqlTimeSerializer.copy(DataInputView source,
DataOutputView target) |
void |
SqlDateSerializer.copy(DataInputView source,
DataOutputView target) |
void |
ShortValueSerializer.copy(DataInputView source,
DataOutputView target) |
void |
ShortSerializer.copy(DataInputView source,
DataOutputView target) |
void |
NullValueSerializer.copy(DataInputView source,
DataOutputView target) |
void |
LongValueSerializer.copy(DataInputView source,
DataOutputView target) |
void |
LongSerializer.copy(DataInputView source,
DataOutputView target) |
void |
IntValueSerializer.copy(DataInputView source,
DataOutputView target) |
void |
IntSerializer.copy(DataInputView source,
DataOutputView target) |
void |
GenericArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
FloatValueSerializer.copy(DataInputView source,
DataOutputView target) |
void |
FloatSerializer.copy(DataInputView source,
DataOutputView target) |
void |
EnumSerializer.copy(DataInputView source,
DataOutputView target) |
void |
DoubleValueSerializer.copy(DataInputView source,
DataOutputView target) |
void |
DoubleSerializer.copy(DataInputView source,
DataOutputView target) |
void |
DateSerializer.copy(DataInputView source,
DataOutputView target) |
void |
CharValueSerializer.copy(DataInputView source,
DataOutputView target) |
void |
CharSerializer.copy(DataInputView source,
DataOutputView target) |
void |
ByteValueSerializer.copy(DataInputView source,
DataOutputView target) |
void |
ByteSerializer.copy(DataInputView source,
DataOutputView target) |
void |
BooleanValueSerializer.copy(DataInputView source,
DataOutputView target) |
void |
BooleanSerializer.copy(DataInputView source,
DataOutputView target) |
void |
BigIntSerializer.copy(DataInputView source,
DataOutputView target) |
void |
BigDecSerializer.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) |
Void |
VoidSerializer.deserialize(DataInputView source) |
StringValue |
StringValueSerializer.deserialize(DataInputView source) |
String |
StringSerializer.deserialize(DataInputView source) |
Timestamp |
SqlTimestampSerializer.deserialize(DataInputView source) |
Time |
SqlTimeSerializer.deserialize(DataInputView source) |
Date |
SqlDateSerializer.deserialize(DataInputView source) |
ShortValue |
ShortValueSerializer.deserialize(DataInputView source) |
Short |
ShortSerializer.deserialize(DataInputView source) |
NullValue |
NullValueSerializer.deserialize(DataInputView source) |
LongValue |
LongValueSerializer.deserialize(DataInputView source) |
Long |
LongSerializer.deserialize(DataInputView source) |
IntValue |
IntValueSerializer.deserialize(DataInputView source) |
Integer |
IntSerializer.deserialize(DataInputView source) |
C[] |
GenericArraySerializer.deserialize(DataInputView source) |
FloatValue |
FloatValueSerializer.deserialize(DataInputView source) |
Float |
FloatSerializer.deserialize(DataInputView source) |
T |
EnumSerializer.deserialize(DataInputView source) |
DoubleValue |
DoubleValueSerializer.deserialize(DataInputView source) |
Double |
DoubleSerializer.deserialize(DataInputView source) |
Date |
DateSerializer.deserialize(DataInputView source) |
CharValue |
CharValueSerializer.deserialize(DataInputView source) |
Character |
CharSerializer.deserialize(DataInputView source) |
ByteValue |
ByteValueSerializer.deserialize(DataInputView source) |
Byte |
ByteSerializer.deserialize(DataInputView source) |
BooleanValue |
BooleanValueSerializer.deserialize(DataInputView source) |
Boolean |
BooleanSerializer.deserialize(DataInputView source) |
BigInteger |
BigIntSerializer.deserialize(DataInputView source) |
BigDecimal |
BigDecSerializer.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) |
Long |
LongSerializer.deserialize(Long reuse,
DataInputView source) |
LongValue |
LongValueSerializer.deserialize(LongValue 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) |
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) |
Modifier and Type | Method and Description |
---|---|
int |
PrimitiveArrayComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
void |
StringArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
ShortPrimitiveArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
LongPrimitiveArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
IntPrimitiveArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
FloatPrimitiveArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
DoublePrimitiveArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
CharPrimitiveArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
BytePrimitiveArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
BooleanPrimitiveArraySerializer.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) |
String[] |
StringArraySerializer.deserialize(DataInputView source) |
short[] |
ShortPrimitiveArraySerializer.deserialize(DataInputView source) |
long[] |
LongPrimitiveArraySerializer.deserialize(DataInputView source) |
int[] |
IntPrimitiveArraySerializer.deserialize(DataInputView source) |
float[] |
FloatPrimitiveArraySerializer.deserialize(DataInputView source) |
double[] |
DoublePrimitiveArraySerializer.deserialize(DataInputView source) |
char[] |
CharPrimitiveArraySerializer.deserialize(DataInputView source) |
byte[] |
BytePrimitiveArraySerializer.deserialize(DataInputView source) |
boolean[] |
BooleanPrimitiveArraySerializer.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 |
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) |
int |
GenericTypeComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
CopyableValueComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
void |
WritableSerializer.copy(DataInputView source,
DataOutputView target) |
void |
ValueSerializer.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) |
void |
EitherSerializer.copy(DataInputView source,
DataOutputView target) |
void |
CopyableValueSerializer.copy(DataInputView source,
DataOutputView target) |
void |
AvroSerializer.copy(DataInputView source,
DataOutputView target) |
T |
WritableSerializer.deserialize(DataInputView source) |
T |
ValueSerializer.deserialize(DataInputView source) |
T |
TupleSerializer.deserialize(DataInputView source) |
Tuple0 |
Tuple0Serializer.deserialize(DataInputView source) |
Row |
RowSerializer.deserialize(DataInputView source) |
T |
PojoSerializer.deserialize(DataInputView source) |
Either<L,R> |
EitherSerializer.deserialize(DataInputView source) |
T |
CopyableValueSerializer.deserialize(DataInputView source) |
T |
AvroSerializer.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 |
ValueSerializer.deserialize(T reuse,
DataInputView source) |
T |
TupleSerializer.deserialize(T reuse,
DataInputView source) |
T |
PojoSerializer.deserialize(T reuse,
DataInputView source) |
T |
CopyableValueSerializer.deserialize(T reuse,
DataInputView source) |
T |
AvroSerializer.deserialize(T reuse,
DataInputView source) |
Tuple0 |
Tuple0Serializer.deserialize(Tuple0 reuse,
DataInputView source) |
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 |
TupleComparatorBase.readWithKeyDenormalization(T reuse,
DataInputView source) |
T |
PojoComparator.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) |
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) |
Modifier and Type | Method and Description |
---|---|
int |
OptionTypeComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
int |
EnumValueComparator.compareSerialized(DataInputView firstSource,
DataInputView secondSource) |
void |
UnitSerializer.copy(DataInputView source,
DataOutputView target) |
void |
TraversableSerializer.copy(DataInputView source,
DataOutputView target) |
void |
EitherSerializer.copy(DataInputView source,
DataOutputView target) |
void |
OptionSerializer.copy(DataInputView source,
DataOutputView target) |
void |
EnumValueSerializer.copy(DataInputView src,
DataOutputView tgt) |
void |
NothingSerializer.copy(DataInputView source,
DataOutputView target) |
void |
TrySerializer.copy(DataInputView source,
DataOutputView target) |
void |
UnitSerializer.deserialize(scala.runtime.BoxedUnit reuse,
DataInputView source) |
void |
UnitSerializer.deserialize(DataInputView source) |
T |
TraversableSerializer.deserialize(DataInputView source) |
T |
EitherSerializer.deserialize(DataInputView source) |
T |
CaseClassSerializer.deserialize(DataInputView source) |
scala.Option<A> |
OptionSerializer.deserialize(DataInputView source) |
scala.Enumeration.Value |
EnumValueSerializer.deserialize(DataInputView source) |
Object |
NothingSerializer.deserialize(DataInputView source) |
scala.util.Try<A> |
TrySerializer.deserialize(DataInputView source) |
scala.Enumeration.Value |
EnumValueSerializer.deserialize(scala.Enumeration.Value reuse,
DataInputView source) |
Object |
NothingSerializer.deserialize(Object reuse,
DataInputView source) |
scala.Option<A> |
OptionSerializer.deserialize(scala.Option<A> reuse,
DataInputView source) |
T |
TraversableSerializer.deserialize(T reuse,
DataInputView source) |
T |
EitherSerializer.deserialize(T reuse,
DataInputView source) |
T |
CaseClassSerializer.deserialize(T reuse,
DataInputView source) |
scala.util.Try<A> |
TrySerializer.deserialize(scala.util.Try<A> reuse,
DataInputView source) |
scala.Enumeration.Value |
EnumValueComparator.readWithKeyDenormalization(scala.Enumeration.Value reuse,
DataInputView source) |
scala.runtime.Nothing$ |
OptionTypeComparator.readWithKeyDenormalization(scala.Option<A> reuse,
DataInputView source) |
Modifier and Type | Method and Description |
---|---|
void |
NonDuplicatingTypeSerializer.copy(DataInputView source,
DataOutputView target) |
T |
NonDuplicatingTypeSerializer.deserialize(DataInputView source)
Deserializes an object from the input view.
|
T |
NonDuplicatingTypeSerializer.deserialize(T reuse,
DataInputView source) |
Modifier and Type | Method and Description |
---|---|
void |
NFA.Serializer.copy(DataInputView source,
DataOutputView target) |
NFA<T> |
NFA.Serializer.deserialize(DataInputView source) |
NFA<T> |
NFA.Serializer.deserialize(NFA<T> 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 |
Path.read(DataInputView in) |
Modifier and Type | Method and Description |
---|---|
void |
VersionedIOReadableWritable.read(DataInputView in) |
void |
IOReadableWritable.read(DataInputView in)
Reads the object's internal data from the given data input view.
|
Modifier and Type | Interface and Description |
---|---|
interface |
SeekableDataInputView
Interface marking a
DataInputView as seekable. |
Modifier and Type | Class and Description |
---|---|
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 |
DataOutputView.write(DataInputView source,
int numBytes)
Copies
numBytes bytes from the source to this view. |
Modifier and Type | Method and Description |
---|---|
void |
MigrationNamespaceSerializerProxy.copy(DataInputView source,
DataOutputView target)
Deprecated.
|
Serializable |
MigrationNamespaceSerializerProxy.deserialize(DataInputView source)
Deprecated.
|
Serializable |
MigrationNamespaceSerializerProxy.deserialize(Serializable reuse,
DataInputView source)
Deprecated.
|
Modifier and Type | Field and Description |
---|---|
StateHandle<DataInputView> |
RocksDBStateBackend.FinalFullyAsyncSnapshot.stateHandle |
Modifier and Type | Method and Description |
---|---|
DataInputView |
AbstractStateBackend.DataInputViewHandle.getState(ClassLoader userCodeClassLoader) |
Modifier and Type | Method and Description |
---|---|
void |
ALS.OutLinks.read(DataInputView in) |
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 |
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 |
EndOfSuperstepEvent.read(DataInputView in) |
void |
EndOfPartitionEvent.read(DataInputView in) |
void |
CheckpointBarrier.read(DataInputView in) |
void |
CancelCheckpointMarker.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 |
WorkerDoneEvent.read(DataInputView in) |
void |
TerminationEvent.read(DataInputView in) |
void |
IterationEventWithAggregators.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 |
SpillingResettableMutableObjectIterator.inView |
protected DataInputView |
SpillingResettableIterator.inView |
Modifier and Type | Method and Description |
---|---|
void |
SerializationDelegate.read(DataInputView in) |
void |
ReusingDeserializationDelegate.read(DataInputView in) |
void |
NonReusingDeserializationDelegate.read(DataInputView in) |
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 |
OperatorBackendSerializationProxy.read(DataInputView out) |
void |
OperatorBackendSerializationProxy.StateMetaInfo.read(DataInputView in) |
void |
KeyedBackendSerializationProxy.read(DataInputView in) |
void |
KeyedBackendSerializationProxy.StateMetaInfo.read(DataInputView in) |
Modifier and Type | Class and Description |
---|---|
class |
DataInputDeserializer
A simple and efficient deserializer for the
DataInput interface. |
Modifier and Type | Method and Description |
---|---|
void |
DataOutputSerializer.write(DataInputView source,
int numBytes) |
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) |
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 |
AbstractKeyedTimePanes.readFromInput(DataInputView input,
TypeSerializer<Key> keySerializer,
TypeSerializer<Aggregate> aggSerializer) |
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 |
StringValue.copy(DataInputView in,
DataOutputView target) |
void |
ShortValue.copy(DataInputView source,
DataOutputView target) |
void |
Record.copy(DataInputView source,
DataOutputView target) |
void |
NullValue.copy(DataInputView source,
DataOutputView target) |
void |
LongValue.copy(DataInputView source,
DataOutputView target) |
void |
IntValue.copy(DataInputView source,
DataOutputView target) |
void |
FloatValue.copy(DataInputView source,
DataOutputView target) |
void |
DoubleValue.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 |
ByteValue.copy(DataInputView source,
DataOutputView target) |
void |
BooleanValue.copy(DataInputView source,
DataOutputView target) |
void |
Record.deserialize(DataInputView source) |
void |
StringValue.read(DataInputView in) |
void |
ShortValue.read(DataInputView in) |
void |
Record.read(DataInputView in) |
void |
NullValue.read(DataInputView in) |
void |
MapValue.read(DataInputView in) |
void |
LongValue.read(DataInputView in) |
void |
ListValue.read(DataInputView in) |
void |
IntValue.read(DataInputView in) |
void |
FloatValue.read(DataInputView in) |
void |
DoubleValue.read(DataInputView in) |
void |
CharValue.read(DataInputView in) |
void |
ByteValue.read(DataInputView in) |
void |
BooleanValue.read(DataInputView in) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractID.read(DataInputView in) |
static String |
StringUtils.readNullableString(DataInputView in)
Reads a String from the given input.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.