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 |
---|---|
void |
UnloadableDummyTypeSerializer.copy(DataInputView source,
DataOutputView target) |
abstract void |
TypeSerializer.copy(DataInputView source,
DataOutputView target)
Copies exactly one record from the source input view to the target output view.
|
void |
TypeDeserializerAdapter.copy(DataInputView source,
DataOutputView target) |
void |
UnloadableDummyTypeSerializer.serialize(T record,
DataOutputView target) |
abstract void |
TypeSerializer.serialize(T record,
DataOutputView target)
Serializes the given record to the given target output view.
|
void |
TypeDeserializerAdapter.serialize(T record,
DataOutputView target) |
void |
TypeSerializerSerializationUtil.TypeSerializerSerializationProxy.write(DataOutputView out) |
void |
ParameterlessTypeSerializerConfig.write(DataOutputView out) |
void |
GenericTypeSerializerConfigSnapshot.write(DataOutputView out) |
void |
CompositeTypeSerializerConfigSnapshot.write(DataOutputView out) |
static <T> void |
TypeSerializerSerializationUtil.writeSerializer(DataOutputView out,
TypeSerializer<T> serializer)
Writes a
TypeSerializer to the provided data output view. |
static void |
TypeSerializerSerializationUtil.writeSerializerConfigSnapshot(DataOutputView out,
TypeSerializerConfigSnapshot serializerConfigSnapshot)
Writes a
TypeSerializerConfigSnapshot to the provided data output view. |
static void |
TypeSerializerSerializationUtil.writeSerializerConfigSnapshots(DataOutputView out,
TypeSerializerConfigSnapshot... serializerConfigSnapshots)
Writes multiple
TypeSerializerConfigSnapshot s to the provided data output view. |
static void |
TypeSerializerSerializationUtil.writeSerializersAndConfigsWithResilience(DataOutputView out,
List<Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> serializersAndConfigs)
Write a list of serializers and their corresponding config snapshots to the provided
data output view.
|
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 |
MapSerializer.copy(DataInputView source,
DataOutputView target) |
void |
LongValueSerializer.copy(DataInputView source,
DataOutputView target) |
void |
LongSerializer.copy(DataInputView source,
DataOutputView target) |
void |
ListSerializer.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 |
ListSerializer.serialize(List<T> list,
DataOutputView target) |
void |
LongSerializer.serialize(Long record,
DataOutputView target) |
void |
LongValueSerializer.serialize(LongValue record,
DataOutputView target) |
void |
MapSerializer.serialize(Map<K,V> map,
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) |
void |
GenericArraySerializerConfigSnapshot.write(DataOutputView out) |
void |
EnumSerializer.EnumSerializerConfigSnapshot.write(DataOutputView out) |
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) |
void |
TupleSerializerConfigSnapshot.write(DataOutputView out) |
void |
PojoSerializer.PojoSerializerConfigSnapshot.write(DataOutputView out) |
void |
KryoRegistrationSerializerConfigSnapshot.write(DataOutputView out) |
void |
AvroSerializer.AvroSerializerConfigSnapshot.write(DataOutputView out) |
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 |
TraversableSerializer.copy(DataInputView source,
DataOutputView target) |
void |
NothingSerializer.copy(DataInputView source,
DataOutputView target) |
void |
OptionSerializer.copy(DataInputView source,
DataOutputView target) |
void |
EitherSerializer.copy(DataInputView source,
DataOutputView target) |
void |
TrySerializer.copy(DataInputView source,
DataOutputView target) |
void |
UnitSerializer.copy(DataInputView source,
DataOutputView target) |
void |
EnumValueSerializer.copy(DataInputView src,
DataOutputView tgt) |
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 |
CaseClassSerializer.serialize(T value,
DataOutputView target) |
void |
EitherSerializer.serialize(T either,
DataOutputView target) |
void |
TrySerializer.serialize(scala.util.Try<A> either,
DataOutputView target) |
void |
EnumValueSerializer.ScalaEnumSerializerConfigSnapshot.write(DataOutputView out) |
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 |
SharedBuffer.SharedBufferSerializer.copy(DataInputView source,
DataOutputView target) |
void |
NFA.NFASerializer.copy(DataInputView source,
DataOutputView target) |
void |
NFA.Serializer.copy(DataInputView source,
DataOutputView target) |
void |
DeweyNumber.DeweyNumberSerializer.copy(DataInputView source,
DataOutputView target) |
void |
DeweyNumber.DeweyNumberSerializer.serialize(DeweyNumber record,
DataOutputView target) |
void |
NFA.NFASerializer.serialize(NFA<T> record,
DataOutputView target) |
void |
NFA.Serializer.serialize(NFA<T> record,
DataOutputView target) |
void |
SharedBuffer.SharedBufferSerializer.serialize(SharedBuffer 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 |
StringValueArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
StringValueArray.copy(DataInputView source,
DataOutputView target) |
void |
NullValueArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
NullValueArray.copy(DataInputView source,
DataOutputView target) |
void |
LongValueArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
LongValueArray.copy(DataInputView source,
DataOutputView target) |
void |
IntValueArraySerializer.copy(DataInputView source,
DataOutputView target) |
void |
IntValueArray.copy(DataInputView source,
DataOutputView target) |
protected static void |
StringValueArray.copyInternal(DataInputView source,
DataOutputView target) |
protected static void |
LongValueArray.copyInternal(DataInputView source,
DataOutputView target) |
protected static void |
IntValueArray.copyInternal(DataInputView source,
DataOutputView target) |
void |
IntValueArraySerializer.serialize(IntValueArray record,
DataOutputView target) |
void |
LongValueArraySerializer.serialize(LongValueArray record,
DataOutputView target) |
void |
NullValueArraySerializer.serialize(NullValueArray record,
DataOutputView target) |
void |
StringValueArraySerializer.serialize(StringValueArray record,
DataOutputView target) |
void |
StringValueArray.write(DataOutputView out) |
void |
NullValueArray.write(DataOutputView out) |
void |
LongValueArray.write(DataOutputView out) |
void |
IntValueArray.write(DataOutputView out) |
void |
IntValueArrayComparator.writeWithKeyNormalization(IntValueArray record,
DataOutputView target) |
void |
LongValueArrayComparator.writeWithKeyNormalization(LongValueArray record,
DataOutputView target) |
void |
NullValueArrayComparator.writeWithKeyNormalization(NullValueArray record,
DataOutputView target) |
void |
StringValueArrayComparator.writeWithKeyNormalization(StringValueArray record,
DataOutputView target) |
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 |
StreamRecordSerializer.copy(DataInputView source,
DataOutputView target) |
void |
MultiplexingStreamRecordSerializer.copy(DataInputView source,
DataOutputView target) |
void |
MultiplexingStreamRecordSerializer.serialize(StreamElement value,
DataOutputView target) |
void |
StreamRecordSerializer.serialize(StreamRecord<T> value,
DataOutputView target) |
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 |
HashMapSerializer.copy(DataInputView source,
DataOutputView target) |
void |
ArrayListSerializer.copy(DataInputView source,
DataOutputView target) |
void |
ArrayListSerializer.serialize(ArrayList<T> list,
DataOutputView target) |
void |
HashMapSerializer.serialize(HashMap<K,V> map,
DataOutputView target) |
void |
VoidNamespaceSerializer.serialize(VoidNamespace record,
DataOutputView target) |
void |
OperatorBackendSerializationProxy.write(DataOutputView out) |
void |
KeyedBackendSerializationProxy.write(DataOutputView out) |
void |
OperatorBackendStateMetaInfoSnapshotReaderWriters.OperatorBackendStateMetaInfoWriter.writeStateMetaInfo(DataOutputView out) |
void |
OperatorBackendStateMetaInfoSnapshotReaderWriters.OperatorBackendStateMetaInfoWriterV1.writeStateMetaInfo(DataOutputView out) |
void |
OperatorBackendStateMetaInfoSnapshotReaderWriters.OperatorBackendStateMetaInfoWriterV2.writeStateMetaInfo(DataOutputView out) |
void |
KeyedBackendStateMetaInfoSnapshotReaderWriters.KeyedBackendStateMetaInfoWriter.writeStateMetaInfo(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 |
CRowSerializer.copy(DataInputView source,
DataOutputView target) |
void |
CRowSerializer.serialize(CRow record,
DataOutputView target) |
void |
CRowComparator.writeWithKeyNormalization(CRow record,
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 |
---|---|
static void |
StringUtils.writeNullableString(String str,
DataOutputView out)
Writes a String to the given output.
|
static void |
StringUtils.writeString(String str,
DataOutputView out)
Writes a String to the given output.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.