public class DefaultTablestoreSplitManager extends Object implements ITablestoreSplitManager
| Constructor and Description |
|---|
DefaultTablestoreSplitManager(SyncClient client) |
| Modifier and Type | Method and Description |
|---|---|
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 in interface ITablestoreSplitManagerpublic List<Split> getTableSplits(SyncClient client, String tableName, ComputeParameters parameter)
public LeftMatchResult calculateComputeMode(SyncClient client, TableCatalog catalog, Filter filter, ComputeParameters parameter, List<String> requiredColumns)
Copyright © 2024. All Rights Reserved.