org.apache.paimon.crosspartition

Class IndexBootstrap

java.lang.Object

org.apache.paimon.crosspartition.IndexBootstrap

All Implemented Interfaces:

Serializable

public class IndexBootstrap
extends Object
implements Serializable

Bootstrap key index from Paimon table.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static String	BUCKET_FIELD

Constructor Summary

Constructors

Constructor and Description
IndexBootstrap(Table table)

Method Summary

Modifier and Type	Method and Description
RecordReader<InternalRow>	bootstrap(int numAssigners, int assignId)
void	bootstrap(int numAssigners, int assignId, java.util.function.Consumer<InternalRow> collector)
static RowType	bootstrapType(TableSchema schema)

Methods inherited from class java.lang.Object

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

Field Detail

BUCKET_FIELD

public static final String BUCKET_FIELD

See Also:

Constant Field Values

Constructor Detail

IndexBootstrap

public IndexBootstrap(Table table)

Method Detail

bootstrap

public void bootstrap(int numAssigners,
                      int assignId,
                      java.util.function.Consumer<InternalRow> collector)
               throws IOException

Throws:

IOException

bootstrap

public RecordReader<InternalRow> bootstrap(int numAssigners,
                                           int assignId)
                                    throws IOException

Throws:

IOException

bootstrapType

public static RowType bootstrapType(TableSchema schema)