Function writeDecimalParts

go/fory/decimal.go:101–122

(buffer *ByteBuffer, scale int32, unscaled *big.Int)

}

func writeDecimalParts(buffer *ByteBuffer, scale int32, unscaled *big.Int) {
	if unscaled == nil {
		unscaled = new(big.Int)
	}
	buffer.WriteVarint32(scale)
	if canUseSmallDecimalEncoding(unscaled) {
		smallValue := unscaled.Int64()
		header := encodeDecimalZigZag64(smallValue) << 1
		buffer.WriteVarUint64(header)
		return
	}

	abs := new(big.Int).Abs(unscaled)
	magnitudeBytes := abs.Bytes()
	if len(magnitudeBytes) == 0 {
		panic("decimal zero must use the small encoding")
	}
	reverseBytes(magnitudeBytes)
	meta := (uint64(len(magnitudeBytes)) << 1) | uint64(signBit(unscaled.Sign()))
	buffer.WriteVarUint64((meta << 1) | 1)
	buffer.WriteBinary(magnitudeBytes)
}

func readDecimalParts(ctx *ReadContext) (int32, *big.Int) {
	err := ctx.Err()