| Package | Description |
|---|---|
| org.apache.ignite.cache |
Contains main Data Grid APIs.
|
| org.apache.ignite.client |
Contains Ignite Thin Client API classes.
|
| org.apache.ignite.configuration |
Contains configuration-related classes.
|
| org.apache.ignite.internal.processors.cache |
This package contain cache-related processors & persistence implementation.
|
| org.apache.ignite.internal.processors.platform.client.cache | |
| org.apache.ignite.internal.processors.platform.utils | |
| org.apache.ignite.internal.processors.query | |
| org.apache.ignite.internal.processors.query.schema.operation | |
| org.apache.ignite.internal.visor.query |
| Modifier and Type | Method and Description |
|---|---|
QueryEntity |
QueryEntity.addQueryField(String fullName,
String type,
String alias)
Utility method for building query entities programmatically.
|
QueryEntity |
QueryEntity.setAliases(Map<String,String> aliases)
Sets mapping from full property name in dot notation to an alias that will be used as SQL column name.
|
QueryEntity |
QueryEntity.setDefaultFieldValues(Map<String,Object> defaultFieldValues)
Sets fields default values.
|
QueryEntity |
QueryEntity.setFields(LinkedHashMap<String,String> fields)
Sets query fields for this query pair.
|
QueryEntity |
QueryEntity.setFieldsPrecision(Map<String,Integer> fieldsPrecision)
Sets fieldsPrecision map for a fields.
|
QueryEntity |
QueryEntity.setFieldsScale(Map<String,Integer> fieldsScale)
Sets fieldsScale map for a fields.
|
QueryEntity |
QueryEntity.setIndexes(Collection<QueryIndex> idxs)
Sets a collection of index entities.
|
QueryEntity |
QueryEntity.setKeyFieldName(String keyFieldName)
Sets key field name.
|
QueryEntity |
QueryEntity.setKeyFields(Set<String> keyFields)
Gets query fields for this query pair that belongs to the key.
|
QueryEntity |
QueryEntity.setKeyType(String keyType)
Sets key type for this query pair.
|
QueryEntity |
QueryEntity.setNotNullFields(@Nullable Set<String> notNullFields)
Sets names of fields that must checked for null.
|
QueryEntity |
QueryEntity.setTableName(String tableName)
Sets table name for this query entity.
|
QueryEntity |
QueryEntity.setValueFieldName(String valueFieldName)
Sets value field name.
|
QueryEntity |
QueryEntity.setValueType(String valType)
Sets value type for this query pair.
|
| Modifier and Type | Method and Description |
|---|---|
@NotNull QueryEntityPatch |
QueryEntity.makePatch(QueryEntity target)
Make query entity patch.
|
| Constructor and Description |
|---|
QueryEntity(QueryEntity other)
Copy constructor.
|
| Modifier and Type | Method and Description |
|---|---|
QueryEntity[] |
ClientCacheConfiguration.getQueryEntities() |
| Modifier and Type | Method and Description |
|---|---|
ClientCacheConfiguration |
ClientCacheConfiguration.setQueryEntities(QueryEntity... newVal) |
| Modifier and Type | Method and Description |
|---|---|
Collection<QueryEntity> |
CacheConfiguration.getQueryEntities()
Gets a collection of configured query entities.
|
| Modifier and Type | Method and Description |
|---|---|
CacheConfiguration<K,V> |
CacheConfiguration.setQueryEntities(Collection<QueryEntity> qryEntities)
Sets query entities configuration.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<QueryEntity> |
StoredCacheData.queryEntities() |
| Modifier and Type | Method and Description |
|---|---|
QuerySchemaPatch |
DynamicCacheDescriptor.makeSchemaPatch(Collection<QueryEntity> target)
Make schema patch for this cache.
|
void |
GridCacheContext.onSchemaAddQueryEntity(Collection<QueryEntity> entities,
String sqlSchema,
boolean isSqlEscape,
int qryParallelism)
Apply changes on enable indexing.
|
static <K,V> CacheConfiguration<K,V> |
GridCacheUtils.patchCacheConfiguration(CacheConfiguration<K,V> oldCfg,
Collection<QueryEntity> entities,
String sqlSchema,
boolean isSqlEscape,
int qryParallelism)
Patch cache configuration with
SchemaAddQueryEntityOperation. |
void |
StoredCacheData.queryEntities(Collection<QueryEntity> qryEntities) |
| Modifier and Type | Method and Description |
|---|---|
static QueryEntity |
ClientCacheConfigurationSerializer.readQueryEntity(BinaryRawReader in,
ClientProtocolContext protocolCtx)
Reads the query entity.
|
| Modifier and Type | Method and Description |
|---|---|
static QueryEntity |
PlatformConfigurationUtils.readQueryEntity(BinaryRawReader in)
Reads the query entity.
|
| Modifier and Type | Method and Description |
|---|---|
static void |
PlatformConfigurationUtils.writeQueryEntity(BinaryRawWriter writer,
QueryEntity qryEntity)
Write query entity.
|
| Modifier and Type | Class and Description |
|---|---|
class |
QueryEntityEx
Extended query entity with not-null fields support.
|
| Modifier and Type | Method and Description |
|---|---|
static QueryEntity |
QueryUtils.copy(QueryEntity entity)
Copy query entity.
|
static QueryEntity |
QueryUtils.normalizeQueryEntity(QueryEntity entity,
boolean escape)
Normalize query entity.
|
QueryEntity |
QueryEntityEx.setNotNullFields(@Nullable Set<String> notNullFields)
Sets names of fields that must checked for null.
|
QueryEntity |
QueryEntityEx.setPreserveKeysOrder(boolean preserveKeysOrder) |
| Modifier and Type | Method and Description |
|---|---|
Collection<QueryEntity> |
QuerySchema.entities() |
static Collection<QueryEntity> |
QueryUtils.normalizeQueryEntities(Collection<QueryEntity> entities,
CacheConfiguration<?,?> cfg)
Normalize cache query entities.
|
| Modifier and Type | Method and Description |
|---|---|
static QueryEntity |
QueryUtils.copy(QueryEntity entity)
Copy query entity.
|
IgniteInternalFuture<?> |
GridQueryProcessor.dynamicAddQueryEntity(String cacheName,
String schemaName,
QueryEntity entity,
Integer qryParallelism,
boolean sqlEscape)
Enable dynamically indexing of existing cache.
|
void |
GridQueryProcessor.dynamicTableCreate(String schemaName,
QueryEntity entity,
String templateName,
String cacheName,
String cacheGroup,
@Nullable String dataRegion,
String affinityKey,
@Nullable CacheAtomicityMode atomicityMode,
@Nullable CacheWriteSynchronizationMode writeSyncMode,
@Nullable Integer backups,
boolean ifNotExists,
@Nullable Boolean encrypted,
@Nullable Integer qryParallelism)
Create cache and table from given query entity.
|
static String |
QueryUtils.fieldNameByAlias(QueryEntity entity,
String alias)
Get field name by alias.
|
static String |
QueryUtils.indexName(QueryEntity entity,
QueryIndex idx)
Get index name.
|
static QueryEntity |
QueryUtils.normalizeQueryEntity(QueryEntity entity,
boolean escape)
Normalize query entity.
|
static void |
QueryUtils.processBinaryMeta(GridKernalContext ctx,
QueryEntity qryEntity,
QueryTypeDescriptorImpl d)
Processes declarative metadata for binary object.
|
static void |
QueryUtils.processClassMeta(QueryEntity qryEntity,
QueryTypeDescriptorImpl d,
CacheObjectContext coCtx)
Processes declarative metadata for binary object.
|
static boolean |
QueryUtils.removeField(QueryEntity entity,
String alias)
Remove field by alias.
|
static String |
QueryUtils.tableName(QueryEntity entity)
Get table name for entity.
|
static QueryTypeCandidate |
QueryUtils.typeForQueryEntity(GridKernalContext ctx,
String cacheName,
String schemaName,
GridCacheContextInfo cacheInfo,
QueryEntity qryEntity,
List<Class<?>> mustDeserializeClss,
boolean escape)
Create type candidate for query entity.
|
static SchemaOperationException |
QueryUtils.validateDropColumn(QueryEntity entity,
String fieldName,
String colName)
Checks if given column can be removed from table using its
QueryEntity. |
| Modifier and Type | Method and Description |
|---|---|
QuerySchemaPatch |
QuerySchema.makePatch(CacheConfiguration<?,?> targetCfg,
Collection<QueryEntity> target)
Make query schema patch.
|
QuerySchemaPatch |
QuerySchema.makePatch(Collection<QueryEntity> target)
Make query schema patch.
|
static Collection<QueryEntity> |
QueryUtils.normalizeQueryEntities(Collection<QueryEntity> entities,
CacheConfiguration<?,?> cfg)
Normalize cache query entities.
|
| Constructor and Description |
|---|
QueryEntityEx(QueryEntity other)
Copying constructor.
|
| Constructor and Description |
|---|
QuerySchema(Collection<QueryEntity> entities)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<QueryEntity> |
SchemaAddQueryEntityOperation.entities() |
| Constructor and Description |
|---|
SchemaAddQueryEntityOperation(UUID opId,
String cacheName,
String schemaName,
Collection<QueryEntity> entities,
int qryParallelism,
boolean sqlEscape) |
| Modifier and Type | Method and Description |
|---|---|
static List<VisorQueryEntity> |
VisorQueryEntity.list(Collection<QueryEntity> qryEntities) |
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.11.0 Release Date : September 11 2021