org.apache.paimon.sort.hilbert

Class HilbertIndexer

java.lang.Object

org.apache.paimon.sort.hilbert.HilbertIndexer

All Implemented Interfaces:

Serializable

public class HilbertIndexer
extends Object
implements Serializable

Hilbert indexer for responsibility to generate hilbert-index.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	HilbertIndexer.HProcessFunction Process function interface.
static class	HilbertIndexer.RowProcessor Be used as converting row field record to devoted bytes.
static class	HilbertIndexer.TypeVisitor Type Visitor to generate function map from row column to hilbert-index.

Constructor Summary

Constructors

Constructor and Description
HilbertIndexer(RowType rowType, List<String> orderColumns)

Method Summary

Modifier and Type	Method and Description
Set<HilbertIndexer.RowProcessor>	constructFunctionMap(List<DataField> fields)
static byte[]	hilbertCurvePosBytes(Long[] points)
static HilbertIndexer.RowProcessor	hmapColumnToCalculator(DataField field, int index)
byte[]	index(InternalRow row)
void	open()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HilbertIndexer

public HilbertIndexer(RowType rowType,
                      List<String> orderColumns)

Method Detail

open

public void open()

index

public byte[] index(InternalRow row)

constructFunctionMap

public Set<HilbertIndexer.RowProcessor> constructFunctionMap(List<DataField> fields)

hmapColumnToCalculator

public static HilbertIndexer.RowProcessor hmapColumnToCalculator(DataField field,
                                                                 int index)

hilbertCurvePosBytes

public static byte[] hilbertCurvePosBytes(Long[] points)