Package org.hibernate.reactive.loader.ast.internal

Class ReactiveMultiKeyLoadChunker<K>

java.lang.Object
org.hibernate.reactive.loader.ast.internal.ReactiveMultiKeyLoadChunker<K>
public class ReactiveMultiKeyLoadChunker<K> extends Object
See Also:
  • MultiKeyLoadChunker

  • Constructor Summary

    Constructors
    Constructor
    Description
    ReactiveMultiKeyLoadChunker(int chunkSize, int keyColumnCount, org.hibernate.metamodel.mapping.Bindable bindable, org.hibernate.sql.exec.spi.JdbcParametersList jdbcParameters, org.hibernate.sql.ast.tree.select.SelectStatement sqlAst, org.hibernate.sql.exec.spi.JdbcOperationQuerySelect jdbcSelect)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    CompletionStage<Void>
    processChunks(K[] keys, int nonNullElementCount, org.hibernate.reactive.loader.ast.internal.ReactiveMultiKeyLoadChunker.SqlExecutionContextCreator sqlExecutionContextCreator, org.hibernate.reactive.loader.ast.internal.ReactiveMultiKeyLoadChunker.KeyCollector<K> keyCollector, org.hibernate.reactive.loader.ast.internal.ReactiveMultiKeyLoadChunker.ChunkStartListener startListener, org.hibernate.reactive.loader.ast.internal.ReactiveMultiKeyLoadChunker.ChunkBoundaryListener boundaryListener, org.hibernate.engine.spi.SharedSessionContractImplementor session)
    Process the chunks

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • ReactiveMultiKeyLoadChunker

      public ReactiveMultiKeyLoadChunker(int chunkSize, int keyColumnCount, org.hibernate.metamodel.mapping.Bindable bindable, org.hibernate.sql.exec.spi.JdbcParametersList jdbcParameters, org.hibernate.sql.ast.tree.select.SelectStatement sqlAst, org.hibernate.sql.exec.spi.JdbcOperationQuerySelect jdbcSelect)

  • Method Details

    • processChunks

      public CompletionStage<Void> processChunks(K[] keys, int nonNullElementCount, org.hibernate.reactive.loader.ast.internal.ReactiveMultiKeyLoadChunker.SqlExecutionContextCreator sqlExecutionContextCreator, org.hibernate.reactive.loader.ast.internal.ReactiveMultiKeyLoadChunker.KeyCollector<K> keyCollector, org.hibernate.reactive.loader.ast.internal.ReactiveMultiKeyLoadChunker.ChunkStartListener startListener, org.hibernate.reactive.loader.ast.internal.ReactiveMultiKeyLoadChunker.ChunkBoundaryListener boundaryListener, org.hibernate.engine.spi.SharedSessionContractImplementor session)
      Process the chunks
      Parameters:
      keys - The group of keys to be initialized
      nonNullElementCount - The number of non-null values in keys, which will be less-than-or-equal-to the number of keys
      startListener - Notifications that processing a chunk has starting
      keyCollector - Called for each key as it is processed
      boundaryListener - Notifications that processing a chunk has completed