public class DefaultTablestoreSplitManager extends Object implements ITablestoreSplitManager
构造器和说明 |
---|
DefaultTablestoreSplitManager(SyncClient client) |
限定符和类型 | 方法和说明 |
---|---|
LeftMatchResult |
calculateComputeMode(SyncClient client,
TableCatalog catalog,
Filter filter,
ComputeParameters parameter,
List<String> requiredColumns) |
List<ITablestoreSplit> |
generateTablestoreSplits(SyncClient client,
Filter filter,
String tableName,
ComputeParameters parameter,
List<String> requiredColumns) |
List<Split> |
getTableSplits(SyncClient client,
String tableName,
ComputeParameters parameter) |
static void |
setEnableSplitCache(boolean enableSplitCache) |
public DefaultTablestoreSplitManager(SyncClient client)
public static void setEnableSplitCache(boolean enableSplitCache)
public List<ITablestoreSplit> generateTablestoreSplits(SyncClient client, Filter filter, String tableName, ComputeParameters parameter, List<String> requiredColumns)
generateTablestoreSplits
在接口中 ITablestoreSplitManager
public List<Split> getTableSplits(SyncClient client, String tableName, ComputeParameters parameter)
public LeftMatchResult calculateComputeMode(SyncClient client, TableCatalog catalog, Filter filter, ComputeParameters parameter, List<String> requiredColumns)
Copyright © 2021. All Rights Reserved.