com.splicemachine.derby.impl.sql.execute.operations

Class BroadcastJoinCache

java.lang.Object

com.splicemachine.derby.impl.sql.execute.operations.BroadcastJoinCache

public class BroadcastJoinCache
extends java.lang.Object

Represents a Cache of records for use in a Broadcast Join.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) static interface	BroadcastJoinCache.JoinTableLoader

Constructor Summary

Constructors

Constructor and Description
BroadcastJoinCache()
BroadcastJoinCache(BroadcastJoinCache.JoinTableLoader tableLoader)

Method Summary

Modifier and Type	Method and Description
JoinTable.Factory	get(java.lang.Long operationId, java.util.concurrent.Callable<Stream<ExecRow>> loader, int[] rightHashKeys, int[] leftHashKeys, ExecRow leftTemplateRow)

Methods inherited from class java.lang.Object

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

Constructor Detail

BroadcastJoinCache

public BroadcastJoinCache()

BroadcastJoinCache

public BroadcastJoinCache(BroadcastJoinCache.JoinTableLoader tableLoader)

Method Detail

get

public JoinTable.Factory get(java.lang.Long operationId,
                             java.util.concurrent.Callable<Stream<ExecRow>> loader,
                             int[] rightHashKeys,
                             int[] leftHashKeys,
                             ExecRow leftTemplateRow)
                      throws java.io.IOException,
                             StandardException

Throws:

java.io.IOException

StandardException