xiarixiaoyao commented on pull request #3952:
URL: https://github.com/apache/hudi/pull/3952#issuecomment-980490078
@yihua could you pls help me，now i cannot pull/push any code in github。
those are my modify：
patch1： modify HilbertCurveUitls
public class HilbertCurveUtils {
public static byte[] indexBytes(HilbertCurve hilbertCurve, long[] points,
int paddingNum) {
BigInteger index = hilbertCurve.index(points);
return paddingToNByte(index.toByteArray(), paddingNum);
}
public static byte[] paddingToNByte(byte[] a, int paddingNum) {
if (a.length == paddingNum) {
return a;
}
if (a.length > paddingNum) {
byte[] result = new byte[paddingNum];
System.arraycopy(a, 0, result, 0, paddingNum);
return result;
}
int paddingSize = 8 - a.length;
byte[] result = new byte[paddingNum];
for (int i = 0; i < paddingSize; i++) {
result[i] = 0;
}
System.arraycopy(a, 0, result, paddingSize, a.length);
return result;
}
}
patch2：
line220 in OrderingIndexHelper:
hilbertCurve, longList.stream().mapToLong(l -> l).toArray(), 63);
patch3:
line520 in RangeSample:
HilbertCurveUtils.indexBytes(hilbertCurve.get, values.map(_.toLong).toArray,
32)
patch4:
line 99 in SpaceCurveOptimizeBenchMark:
val df = spark.range(numRows).map(_ => (Random.nextInt(col1Range),
Random.nextInt(col2Range))).toDF("c1_int", "c2_int")
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
