org.apache.shardingsphere.core.execute

Class ShardingExecuteEngine

java.lang.Object

org.apache.shardingsphere.core.execute.ShardingExecuteEngine

All Implemented Interfaces:

AutoCloseable

public final class ShardingExecuteEngine
extends Object
implements AutoCloseable

Sharding execute engine.

Author:

zhangliang

Constructor Summary

Constructors

Constructor and Description
ShardingExecuteEngine(int executorSize)

Method Summary

Modifier and Type	Method and Description
void	close()
<I,O> List<O>	groupExecute(Collection<ShardingExecuteGroup<I>> inputGroups, ShardingGroupExecuteCallback<I,O> callback) Execute for group.
<I,O> List<O>	groupExecute(Collection<ShardingExecuteGroup<I>> inputGroups, ShardingGroupExecuteCallback<I,O> firstCallback, ShardingGroupExecuteCallback<I,O> callback, boolean serial) Execute for group.

Methods inherited from class java.lang.Object

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

Constructor Detail

ShardingExecuteEngine

public ShardingExecuteEngine(int executorSize)

Method Detail

groupExecute

public <I,O> List<O> groupExecute(Collection<ShardingExecuteGroup<I>> inputGroups,
                                  ShardingGroupExecuteCallback<I,O> callback)
                           throws SQLException

Execute for group.

Type Parameters:

I - type of input value

O - type of return value

Parameters:

inputGroups - input groups

callback - sharding execute callback

Returns:

execute result

Throws:

SQLException - throw if execute failure

groupExecute

public <I,O> List<O> groupExecute(Collection<ShardingExecuteGroup<I>> inputGroups,
                                  ShardingGroupExecuteCallback<I,O> firstCallback,
                                  ShardingGroupExecuteCallback<I,O> callback,
                                  boolean serial)
                           throws SQLException

Execute for group.

Type Parameters:

I - type of input value

O - type of return value

Parameters:

inputGroups - input groups

firstCallback - first sharding execute callback

callback - sharding execute callback

serial - whether using multi thread execute or not

Returns:

execute result

Throws:

SQLException - throw if execute failure

close

public void close()

Specified by:

close in interface AutoCloseable