org.apache.paimon.crosspartition

Class GlobalIndexAssigner

java.lang.Object

org.apache.paimon.crosspartition.GlobalIndexAssigner

All Implemented Interfaces:

Closeable, Serializable, AutoCloseable

public class GlobalIndexAssigner
extends Object
implements Serializable, Closeable

Assign UPDATE_BEFORE and bucket for the input record, output record with bucket.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
GlobalIndexAssigner(Table table)

Method Summary

Modifier and Type	Method and Description
void	bootstrapKey(InternalRow value)
void	close()
void	endBoostrap(boolean isEndInput)
CloseableIterator<BinaryRow>	endBoostrapWithoutEmit(boolean isEndInput)
boolean	inBoostrap()
void	open(long offHeapMemory, IOManager ioManager, int numAssigners, int assignId, java.util.function.BiConsumer<InternalRow,Integer> collector)
void	processInput(InternalRow value)

Methods inherited from class java.lang.Object

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

Constructor Detail

GlobalIndexAssigner

public GlobalIndexAssigner(Table table)

Method Detail

open

public void open(long offHeapMemory,
                 IOManager ioManager,
                 int numAssigners,
                 int assignId,
                 java.util.function.BiConsumer<InternalRow,Integer> collector)
          throws Exception

Throws:

Exception

bootstrapKey

public void bootstrapKey(InternalRow value)
                  throws IOException

Throws:

IOException

inBoostrap

public boolean inBoostrap()

endBoostrap

public void endBoostrap(boolean isEndInput)
                 throws Exception

Throws:

Exception

endBoostrapWithoutEmit

public CloseableIterator<BinaryRow> endBoostrapWithoutEmit(boolean isEndInput)
                                                    throws Exception

Throws:

Exception

processInput

public void processInput(InternalRow value)
                  throws Exception

Throws:

Exception

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException