Modifier and Type | Method and Description |
---|---|
protected void |
SerializedOutputFormat.serialize(T record,
DataOutputView dataOutputView) |
protected abstract void |
BinaryOutputFormat.serialize(T record,
DataOutputView dataOutput) |
void |
BlockInfo.write(DataOutputView out) |
Modifier and Type | Method and Description |
---|---|
abstract void |
TypeSerializer.copy(DataInputView source,
DataOutputView target)
Copies exactly one record from the source input view to the target output view.
|
abstract void |
TypeSerializer.serialize(T record,
DataOutputView target)
Serializes the given record to the given target output view.
|
void |
TypeSerializerSerializationProxy.write(DataOutputView out) |
abstract void |
TypeComparator.writeWithKeyNormalization(T record,
DataOutputView target)
Writes the record in such a fashion that all keys are normalizing and at the beginning of the serialized data.
|
Modifier and Type | Method and Description |
---|---|
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) |
void |
BigDecSerializer.serialize(BigDecimal record,
DataOutputView target) |
void |
BigIntSerializer.serialize(BigInteger record,
DataOutputView target) |
void |
BooleanSerializer.serialize(Boolean record,
DataOutputView target) |
void |
BooleanValueSerializer.serialize(BooleanValue record,
DataOutputView target) |
void |
ByteSerializer.serialize(Byte record,
DataOutputView target) |
void |
ByteValueSerializer.serialize(ByteValue record,
DataOutputView target) |
void |
GenericArraySerializer.serialize(C[] value,
DataOutputView target) |
void |
CharSerializer.serialize(Character record,
DataOutputView target) |
void |
CharValueSerializer.serialize(CharValue record,
DataOutputView target) |
void |
SqlDateSerializer.serialize(Date record,
DataOutputView target) |
void |
DateSerializer.serialize(Date record,
DataOutputView target) |
void |
DoubleSerializer.serialize(Double record,
DataOutputView target) |
void |
DoubleValueSerializer.serialize(DoubleValue record,
DataOutputView target) |
void |
FloatSerializer.serialize(Float record,
DataOutputView target) |
void |
FloatValueSerializer.serialize(FloatValue record,
DataOutputView target) |
void |
IntSerializer.serialize(Integer record,
DataOutputView target) |
void |
IntValueSerializer.serialize(IntValue record,
DataOutputView target) |
void |
LongSerializer.serialize(Long record,
DataOutputView target) |
void |
LongValueSerializer.serialize(LongValue record,
DataOutputView target) |
void |
NullValueSerializer.serialize(NullValue record,
DataOutputView target) |
void |
ShortSerializer.serialize(Short record,
DataOutputView target) |
void |
ShortValueSerializer.serialize(ShortValue record,
DataOutputView target) |
void |
StringSerializer.serialize(String record,
DataOutputView target) |
void |
StringValueSerializer.serialize(StringValue record,
DataOutputView target) |
void |
EnumSerializer.serialize(T record,
DataOutputView target) |
void |
SqlTimeSerializer.serialize(Time record,
DataOutputView target) |
void |
SqlTimestampSerializer.serialize(Timestamp record,
DataOutputView target) |
void |
VoidSerializer.serialize(Void record,
DataOutputView target) |
static void |
BigIntSerializer.writeBigInteger(BigInteger record,
DataOutputView target) |
void |
BooleanValueComparator.writeWithKeyNormalization(BooleanValue record,
DataOutputView target) |
void |
ByteValueComparator.writeWithKeyNormalization(ByteValue record,
DataOutputView target) |
void |
CharValueComparator.writeWithKeyNormalization(CharValue record,
DataOutputView target) |
void |
DoubleValueComparator.writeWithKeyNormalization(DoubleValue record,
DataOutputView target) |
void |
FloatValueComparator.writeWithKeyNormalization(FloatValue record,
DataOutputView target) |
void |
IntValueComparator.writeWithKeyNormalization(IntValue record,
DataOutputView target) |
void |
LongValueComparator.writeWithKeyNormalization(LongValue record,
DataOutputView target) |
void |
NullValueComparator.writeWithKeyNormalization(NullValue record,
DataOutputView target) |
void |
ShortValueComparator.writeWithKeyNormalization(ShortValue record,
DataOutputView target) |
void |
StringValueComparator.writeWithKeyNormalization(StringValue record,
DataOutputView target) |
void |
BasicTypeComparator.writeWithKeyNormalization(T record,
DataOutputView target) |
Modifier and Type | Method and Description |
---|---|
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) |
void |
BooleanPrimitiveArraySerializer.serialize(boolean[] record,
DataOutputView target) |
void |
BytePrimitiveArraySerializer.serialize(byte[] record,
DataOutputView target) |
void |
CharPrimitiveArraySerializer.serialize(char[] record,
DataOutputView target) |
void |
DoublePrimitiveArraySerializer.serialize(double[] record,
DataOutputView target) |
void |
FloatPrimitiveArraySerializer.serialize(float[] record,
DataOutputView target) |
void |
IntPrimitiveArraySerializer.serialize(int[] record,
DataOutputView target) |
void |
LongPrimitiveArraySerializer.serialize(long[] record,
DataOutputView target) |
void |
ShortPrimitiveArraySerializer.serialize(short[] record,
DataOutputView target) |
void |
StringArraySerializer.serialize(String[] record,
DataOutputView target) |
void |
PrimitiveArrayComparator.writeWithKeyNormalization(T record,
DataOutputView target) |
Modifier and Type | Method and Description |
---|---|
protected void |
TypeSerializerOutputFormat.serialize(T record,
DataOutputView dataOutput) |
Modifier and Type | Field and Description |
---|---|
protected DataOutputView |
DataOutputViewStream.outputView |
Modifier and Type | Method and Description |
---|---|
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) |
static void |
NullMaskUtils.readIntoAndCopyNullMask(int len,
DataInputView source,
DataOutputView target,
boolean[] nullMask) |
void |
EitherSerializer.serialize(Either<L,R> record,
DataOutputView target) |
void |
RowSerializer.serialize(Row record,
DataOutputView target) |
void |
WritableSerializer.serialize(T record,
DataOutputView target) |
void |
ValueSerializer.serialize(T value,
DataOutputView target) |
void |
TupleSerializer.serialize(T value,
DataOutputView target) |
void |
PojoSerializer.serialize(T value,
DataOutputView target) |
void |
CopyableValueSerializer.serialize(T value,
DataOutputView target) |
void |
AvroSerializer.serialize(T value,
DataOutputView target) |
void |
Tuple0Serializer.serialize(Tuple0 record,
DataOutputView target) |
static void |
NullMaskUtils.writeNullMask(int len,
Row value,
DataOutputView target) |
void |
RowComparator.writeWithKeyNormalization(Row record,
DataOutputView target) |
void |
WritableComparator.writeWithKeyNormalization(T record,
DataOutputView target) |
void |
ValueComparator.writeWithKeyNormalization(T record,
DataOutputView target) |
void |
TupleComparatorBase.writeWithKeyNormalization(T record,
DataOutputView target) |
void |
PojoComparator.writeWithKeyNormalization(T record,
DataOutputView target) |
void |
NullAwareComparator.writeWithKeyNormalization(T record,
DataOutputView target) |
void |
GenericTypeComparator.writeWithKeyNormalization(T record,
DataOutputView target) |
void |
CopyableValueComparator.writeWithKeyNormalization(T record,
DataOutputView target) |
Constructor and Description |
---|
DataOutputViewStream(DataOutputView outputView) |
Modifier and Type | Method and Description |
---|---|
void |
KryoSerializer.copy(DataInputView source,
DataOutputView target) |
void |
KryoSerializer.serialize(T record,
DataOutputView target) |
Modifier and Type | Method and Description |
---|---|
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.serialize(scala.runtime.BoxedUnit record,
DataOutputView target) |
void |
EnumValueSerializer.serialize(scala.Enumeration.Value v,
DataOutputView tgt) |
void |
NothingSerializer.serialize(Object any,
DataOutputView target) |
void |
OptionSerializer.serialize(scala.Option<A> either,
DataOutputView target) |
void |
TraversableSerializer.serialize(T coll,
DataOutputView target) |
void |
EitherSerializer.serialize(T either,
DataOutputView target) |
void |
CaseClassSerializer.serialize(T value,
DataOutputView target) |
void |
TrySerializer.serialize(scala.util.Try<A> either,
DataOutputView target) |
void |
EnumValueComparator.writeWithKeyNormalization(scala.Enumeration.Value record,
DataOutputView target) |
scala.runtime.Nothing$ |
OptionTypeComparator.writeWithKeyNormalization(scala.Option<A> record,
DataOutputView target) |
Modifier and Type | Method and Description |
---|---|
void |
NonDuplicatingTypeSerializer.copy(DataInputView source,
DataOutputView target) |
void |
NonDuplicatingTypeSerializer.serialize(T record,
DataOutputView target)
Serializes the given record.
|
Modifier and Type | Method and Description |
---|---|
void |
NFA.Serializer.copy(DataInputView source,
DataOutputView target) |
void |
NFA.Serializer.serialize(NFA<T> record,
DataOutputView target) |
Modifier and Type | Method and Description |
---|---|
void |
DelegatingConfiguration.write(DataOutputView out) |
void |
Configuration.write(DataOutputView out) |
Modifier and Type | Field and Description |
---|---|
protected DataOutputView |
AbstractRocksDBState.keySerializationDataOutputView |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractRocksDBState.writeKeyWithGroupAndNamespace(int keyGroup,
K key,
N namespace,
ByteArrayOutputStreamWithPos keySerializationStream,
DataOutputView keySerializationDataOutputView) |
Modifier and Type | Method and Description |
---|---|
void |
Path.write(DataOutputView out) |
Modifier and Type | Method and Description |
---|---|
void |
VersionedIOReadableWritable.write(DataOutputView out) |
void |
IOReadableWritable.write(DataOutputView out)
Writes the object's internal data to the given data output view.
|
Modifier and Type | Interface and Description |
---|---|
interface |
SeekableDataOutputView
Interface marking a
DataOutputView as seekable. |
Modifier and Type | Class and Description |
---|---|
class |
DataOutputViewStreamWrapper
Utility class that turns an
OutputStream into a DataOutputView . |
Modifier and Type | Method and Description |
---|---|
void |
MigrationNamespaceSerializerProxy.copy(DataInputView source,
DataOutputView target)
Deprecated.
|
void |
MigrationNamespaceSerializerProxy.serialize(Serializable record,
DataOutputView target)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
ALS.OutLinks.write(DataOutputView out) |
Modifier and Type | Class and Description |
---|---|
class |
FileChannelOutputView
A
DataOutputView that is backed by a BlockChannelWriter , making it effectively a data output
stream. |
class |
RandomAccessOutputView |
class |
SimpleCollectingOutputView
The list with the full segments contains at any point all completely full segments, plus the segment that is
currently filled.
|
class |
SpillingBuffer
An output view that buffers written data in memory pages and spills them when they are full.
|
Modifier and Type | Class and Description |
---|---|
class |
ChannelWriterOutputView
A
DataOutputView that is backed by a
BlockChannelWriter , making it effectively a data output
stream. |
Modifier and Type | Method and Description |
---|---|
void |
EndOfSuperstepEvent.write(DataOutputView out) |
void |
EndOfPartitionEvent.write(DataOutputView out) |
void |
CheckpointBarrier.write(DataOutputView out) |
void |
CancelCheckpointMarker.write(DataOutputView out) |
Modifier and Type | Method and Description |
---|---|
DataOutputView |
BlockingBackChannel.getWriteEnd()
Called by iteration tail to save the output of the current superstep.
|
Modifier and Type | Method and Description |
---|---|
void |
WorkerDoneEvent.write(DataOutputView out) |
void |
TerminationEvent.write(DataOutputView out) |
void |
IterationEventWithAggregators.write(DataOutputView out) |
Modifier and Type | Class and Description |
---|---|
class |
SerializedUpdateBuffer |
Constructor and Description |
---|
WorksetUpdateOutputCollector(DataOutputView outputView,
TypeSerializer<T> serializer) |
WorksetUpdateOutputCollector(DataOutputView outputView,
TypeSerializer<T> serializer,
Collector<T> delegate) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractPagedOutputView
The base class for all output views that are backed by multiple memory pages.
|
Modifier and Type | Class and Description |
---|---|
protected static class |
HashPartition.BuildSideBuffer |
Modifier and Type | Method and Description |
---|---|
void |
SerializationDelegate.write(DataOutputView out) |
void |
ReusingDeserializationDelegate.write(DataOutputView out) |
void |
NonReusingDeserializationDelegate.write(DataOutputView out) |
Modifier and Type | Method and Description |
---|---|
void |
VoidNamespaceSerializer.copy(DataInputView source,
DataOutputView target) |
void |
ArrayListSerializer.copy(DataInputView source,
DataOutputView target) |
void |
ArrayListSerializer.serialize(ArrayList<T> list,
DataOutputView target) |
void |
VoidNamespaceSerializer.serialize(VoidNamespace record,
DataOutputView target) |
void |
OperatorBackendSerializationProxy.write(DataOutputView out) |
void |
OperatorBackendSerializationProxy.StateMetaInfo.write(DataOutputView out) |
void |
KeyedBackendSerializationProxy.write(DataOutputView out) |
void |
KeyedBackendSerializationProxy.StateMetaInfo.write(DataOutputView out) |
Modifier and Type | Method and Description |
---|---|
void |
CopyOnWriteStateTableSnapshot.writeMappingsInKeyGroup(DataOutputView dov,
int keyGroupId) |
Modifier and Type | Class and Description |
---|---|
class |
DataOutputSerializer
A simple and efficient serializer for the
DataOutput interface. |
Modifier and Type | Method and Description |
---|---|
void |
InternalTimer.TimerSerializer.copy(DataInputView source,
DataOutputView target) |
void |
InternalTimer.TimerSerializer.serialize(InternalTimer<K,N> record,
DataOutputView target) |
Modifier and Type | Method and Description |
---|---|
void |
TimeWindow.Serializer.copy(DataInputView source,
DataOutputView target) |
void |
GlobalWindow.Serializer.copy(DataInputView source,
DataOutputView target) |
void |
GlobalWindow.Serializer.serialize(GlobalWindow record,
DataOutputView target) |
void |
TimeWindow.Serializer.serialize(TimeWindow record,
DataOutputView target) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractKeyedTimePanes.writeToOutput(DataOutputView output,
TypeSerializer<Key> keySerializer,
TypeSerializer<Aggregate> aggSerializer) |
Modifier and Type | Method and Description |
---|---|
void |
StreamElementSerializer.copy(DataInputView source,
DataOutputView target) |
void |
StreamElementSerializer.serialize(StreamElement value,
DataOutputView target) |
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) |
long |
Record.serialize(DataOutputView target)
Writes this record to the given output view.
|
void |
StringValue.write(DataOutputView out) |
void |
ShortValue.write(DataOutputView out) |
void |
Record.write(DataOutputView out) |
void |
NullValue.write(DataOutputView out) |
void |
MapValue.write(DataOutputView out) |
void |
LongValue.write(DataOutputView out) |
void |
ListValue.write(DataOutputView out) |
void |
IntValue.write(DataOutputView out) |
void |
FloatValue.write(DataOutputView out) |
void |
DoubleValue.write(DataOutputView out) |
void |
CharValue.write(DataOutputView out) |
void |
ByteValue.write(DataOutputView out) |
void |
BooleanValue.write(DataOutputView out) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractID.write(DataOutputView out) |
static void |
StringUtils.writeNullableString(String str,
DataOutputView out)
Writes a String to the given output.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.