public class GlobalIndexAssigner extends Object implements Serializable, Closeable
Constructor and Description |
---|
GlobalIndexAssigner(Table table) |
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) |
public GlobalIndexAssigner(Table table)
public void open(long offHeapMemory, IOManager ioManager, int numAssigners, int assignId, java.util.function.BiConsumer<InternalRow,Integer> collector) throws Exception
Exception
public void bootstrapKey(InternalRow value) throws IOException
IOException
public boolean inBoostrap()
public CloseableIterator<BinaryRow> endBoostrapWithoutEmit(boolean isEndInput) throws Exception
Exception
public void processInput(InternalRow value) throws Exception
Exception
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.