Uses of Class
org.apache.flink.cdc.common.data.TimestampData
-
-
Uses of TimestampData in org.apache.flink.cdc.common.data
Methods in org.apache.flink.cdc.common.data that return TimestampData Modifier and Type Method Description static TimestampDataTimestampData. fromLocalDateTime(java.time.LocalDateTime dateTime)Creates an instance ofTimestampDatafrom an instance ofLocalDateTime.static TimestampDataTimestampData. fromMillis(long milliseconds)Creates an instance ofTimestampDatafrom milliseconds.static TimestampDataTimestampData. fromMillis(long milliseconds, int nanosOfMillisecond)Creates an instance ofTimestampDatafrom milliseconds and a nanos-of-millisecond.static TimestampDataTimestampData. fromTimestamp(Timestamp timestamp)Creates an instance ofTimestampDatafrom an instance ofTimestamp.TimestampDataArrayData. getTimestamp(int pos, int precision)Returns the timestamp value at the given position.TimestampDataGenericArrayData. getTimestamp(int pos, int precision)TimestampDataGenericRecordData. getTimestamp(int pos, int precision)TimestampDataRecordData. getTimestamp(int pos, int precision)Returns the timestamp value at the given position.Methods in org.apache.flink.cdc.common.data with parameters of type TimestampData Modifier and Type Method Description intTimestampData. compareTo(TimestampData that) -
Uses of TimestampData in org.apache.flink.cdc.common.data.binary
Methods in org.apache.flink.cdc.common.data.binary that return TimestampData Modifier and Type Method Description TimestampDataBinaryArrayData. getTimestamp(int pos, int precision)TimestampDataBinaryRecordData. getTimestamp(int pos, int precision)static TimestampDataBinarySegmentUtils. readTimestampData(org.apache.flink.core.memory.MemorySegment[] segments, int baseOffset, long offsetAndNanos)Gets an instance ofTimestampDatafrom underlyingMemorySegment.Methods in org.apache.flink.cdc.common.data.binary with parameters of type TimestampData Modifier and Type Method Description voidBinaryArrayData. setTimestamp(int pos, TimestampData value, int precision) -
Uses of TimestampData in org.apache.flink.cdc.runtime.serializer.data
Methods in org.apache.flink.cdc.runtime.serializer.data that return TimestampData Modifier and Type Method Description TimestampDataTimestampDataSerializer. copy(TimestampData from)TimestampDataTimestampDataSerializer. copy(TimestampData from, TimestampData reuse)TimestampDataTimestampDataSerializer. createInstance()TimestampDataTimestampDataSerializer. deserialize(TimestampData reuse, org.apache.flink.core.memory.DataInputView source)TimestampDataTimestampDataSerializer. deserialize(org.apache.flink.core.memory.DataInputView source)Methods in org.apache.flink.cdc.runtime.serializer.data that return types with arguments of type TimestampData Modifier and Type Method Description org.apache.flink.api.common.typeutils.TypeSerializer<TimestampData>TimestampDataSerializer. duplicate()org.apache.flink.api.common.typeutils.TypeSerializerSchemaCompatibility<TimestampData>TimestampDataSerializer.TimestampDataSerializerSnapshot. resolveSchemaCompatibility(org.apache.flink.api.common.typeutils.TypeSerializer<TimestampData> newSerializer)org.apache.flink.api.common.typeutils.TypeSerializer<TimestampData>TimestampDataSerializer.TimestampDataSerializerSnapshot. restoreSerializer()org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<TimestampData>TimestampDataSerializer. snapshotConfiguration()Methods in org.apache.flink.cdc.runtime.serializer.data with parameters of type TimestampData Modifier and Type Method Description TimestampDataTimestampDataSerializer. copy(TimestampData from)TimestampDataTimestampDataSerializer. copy(TimestampData from, TimestampData reuse)TimestampDataTimestampDataSerializer. deserialize(TimestampData reuse, org.apache.flink.core.memory.DataInputView source)voidTimestampDataSerializer. serialize(TimestampData record, org.apache.flink.core.memory.DataOutputView target)Method parameters in org.apache.flink.cdc.runtime.serializer.data with type arguments of type TimestampData Modifier and Type Method Description org.apache.flink.api.common.typeutils.TypeSerializerSchemaCompatibility<TimestampData>TimestampDataSerializer.TimestampDataSerializerSnapshot. resolveSchemaCompatibility(org.apache.flink.api.common.typeutils.TypeSerializer<TimestampData> newSerializer) -
Uses of TimestampData in org.apache.flink.cdc.runtime.serializer.data.writer
Methods in org.apache.flink.cdc.runtime.serializer.data.writer with parameters of type TimestampData Modifier and Type Method Description voidBinaryWriter. writeTimestamp(int pos, TimestampData value, int precision)
-