Module org.elasticsearch.compute

Package org.elasticsearch.compute.data

Class AbstractDelegatingCompoundBlock.AbstractCompositeBlockBuilder<T extends Block>

java.lang.Object

org.elasticsearch.compute.data.AbstractDelegatingCompoundBlock.AbstractCompositeBlockBuilder<T>

All Implemented Interfaces:

Closeable, AutoCloseable, Block.Builder, Releasable, BlockLoader.Builder

Direct Known Subclasses:

ExponentialHistogramBlockBuilder, TDigestBlockBuilder

Enclosing class:

AbstractDelegatingCompoundBlock<T extends Block>

protected abstract static class AbstractDelegatingCompoundBlock.AbstractCompositeBlockBuilder<T extends Block>
extends Object
implements Block.Builder

Manages firstValueIndexes and positionCount for multi-value support.

Field Summary

Fields

Modifier and Type	Field	Description
protected final BlockFactory	blockFactory

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractCompositeBlockBuilder(BlockFactory blockFactory)

Method Summary

Modifier and Type	Method	Description
final Block.Builder	beginPositionEntry()	Begins a multivalued entry.
final T	build()	Builds the block.
final void	close()
Block.Builder	copyFrom(Block block, int beginInclusive, int endExclusive)	Copy the values in block from beginInclusive to endExclusive into this builder.
protected abstract void	copySubBlockPositions(AbstractDelegatingCompoundBlock<?> block, int startSubBlockPos, int endSubBlockPos)	Copy the range of sub-block positions from the provided block into this builder.
protected abstract T	doBuild(int positionCount, int[] firstValueIndexes)
final Block.Builder	endPositionEntry()	Ends the current multi-value entry.
long	estimatedBytes()	An estimate of the number of bytes the Block created by Block.Builder.build() will use.
protected void	extraClose()	Called when close() was invoked.
protected boolean	isPositionEntryOpen()
protected final void	valueAppended()	Must be called after a new value (null or non-null) has been appended.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.elasticsearch.compute.data.Block.Builder

appendNull, mvOrdering

Field Details

blockFactory

protected final BlockFactory blockFactory

Constructor Details

AbstractCompositeBlockBuilder

protected AbstractCompositeBlockBuilder(BlockFactory blockFactory)

Method Details

beginPositionEntry

public final Block.Builder beginPositionEntry()

Description copied from interface: Block.Builder

Begins a multivalued entry. Calling this for the first time will put the builder into a mode that generates Blocks that return true from Block.mayHaveMultivaluedFields() which can force less optimized code paths. So don't call this unless you are sure you are emitting more than one value for this position.

Specified by:

beginPositionEntry in interface Block.Builder

Specified by:

beginPositionEntry in interface BlockLoader.Builder

isPositionEntryOpen

protected boolean isPositionEntryOpen()

valueAppended

protected final void valueAppended()

Must be called after a new value (null or non-null) has been appended.

endPositionEntry

public final Block.Builder endPositionEntry()

Description copied from interface: Block.Builder

Ends the current multi-value entry.

Specified by:

endPositionEntry in interface Block.Builder

Specified by:

endPositionEntry in interface BlockLoader.Builder

build

public final T build()

Description copied from interface: Block.Builder

Builds the block. This method can be called multiple times.

Specified by:

build in interface Block.Builder

Specified by:

build in interface BlockLoader.Builder

doBuild

protected abstract T doBuild(int positionCount,
 @Nullable
 int[] firstValueIndexes)

copyFrom

public Block.Builder copyFrom(Block block,
 int beginInclusive,
 int endExclusive)

Description copied from interface: Block.Builder

Copy the values in block from beginInclusive to endExclusive into this builder.

For single position copies use the faster IntBlock.Builder.copyFrom(IntBlock, int), LongBlock.Builder.copyFrom(LongBlock, int), etc.

Specified by:

copyFrom in interface Block.Builder

copySubBlockPositions

protected abstract void copySubBlockPositions(AbstractDelegatingCompoundBlock<?> block,
 int startSubBlockPos,
 int endSubBlockPos)

Copy the range of sub-block positions from the provided block into this builder.

estimatedBytes

public long estimatedBytes()

Description copied from interface: Block.Builder

An estimate of the number of bytes the Block created by Block.Builder.build() will use. This may overestimate the size but shouldn't underestimate it.

Specified by:

estimatedBytes in interface Block.Builder

close

public final void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface Releasable

extraClose

protected void extraClose()

Called when close() was invoked.