This is an automated email from the ASF dual-hosted git repository.
timoninmaxim pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git
The following commit(s) were added to refs/heads/master by this push:
new b2bb0001908 IGNITE-27665 IgniteApplicationAttributesAware inherits
IgniteEx (#12657)
b2bb0001908 is described below
commit b2bb0001908c26861989a36e08c306b8e6342022
Author: Maksim Timonin <[email protected]>
AuthorDate: Tue Jan 27 18:05:54 2026 +0300
IGNITE-27665 IgniteApplicationAttributesAware inherits IgniteEx (#12657)
https://issues.apache.org/jira/browse/IGNITE-27665
Thank you for submitting the pull request to the Apache Ignite.
In order to streamline the review of the contribution
we ask you to ensure the following steps have been taken:
### The Contribution Checklist
- [ ] There is a single JIRA ticket related to the pull request.
- [ ] The web-link to the pull request is attached to the JIRA ticket.
- [ ] The JIRA ticket has the _Patch Available_ state.
- [ ] The pull request body describes changes that have been made.
The description explains _WHAT_ and _WHY_ was made instead of _HOW_.
- [ ] The pull request title is treated as the final commit message.
The following pattern must be used: `IGNITE-XXXX Change summary` where
`XXXX` - number of JIRA issue.
- [ ] A reviewer has been mentioned through the JIRA comments
(see [the Maintainers
list](https://cwiki.apache.org/confluence/display/IGNITE/How+to+Contribute#HowtoContribute-ReviewProcessandMaintainers))
- [ ] The pull request has been checked by the Teamcity Bot and
the `green visa` attached to the JIRA ticket (see [TC.Bot: Check
PR](https://mtcga.gridgain.com/prs.html))
### Notes
- [How to
Contribute](https://cwiki.apache.org/confluence/display/IGNITE/How+to+Contribute)
- [Coding abbreviation
rules](https://cwiki.apache.org/confluence/display/IGNITE/Abbreviation+Rules)
- [Coding
Guidelines](https://cwiki.apache.org/confluence/display/IGNITE/Coding+Guidelines)
- [Apache Ignite Teamcity
Bot](https://cwiki.apache.org/confluence/display/IGNITE/Apache+Ignite+Teamcity+Bot)
If you need any help, please email [email protected] or ask anу
advice on http://asf.slack.com _#ignite_ channel.
---
.../internal/IgniteApplicationAttributesAware.java | 99 ++++++++++++++++++++--
1 file changed, 94 insertions(+), 5 deletions(-)
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/IgniteApplicationAttributesAware.java
b/modules/core/src/main/java/org/apache/ignite/internal/IgniteApplicationAttributesAware.java
index 265004cefe1..8feac116e60 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/IgniteApplicationAttributesAware.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/IgniteApplicationAttributesAware.java
@@ -32,7 +32,6 @@ import org.apache.ignite.IgniteAtomicSequence;
import org.apache.ignite.IgniteAtomicStamped;
import org.apache.ignite.IgniteBinary;
import org.apache.ignite.IgniteCache;
-import org.apache.ignite.IgniteCluster;
import org.apache.ignite.IgniteCompute;
import org.apache.ignite.IgniteCountDownLatch;
import org.apache.ignite.IgniteDataStreamer;
@@ -52,14 +51,21 @@ import org.apache.ignite.IgniteTransactions;
import org.apache.ignite.MemoryMetrics;
import org.apache.ignite.cache.affinity.Affinity;
import org.apache.ignite.cluster.ClusterGroup;
+import org.apache.ignite.cluster.ClusterNode;
import org.apache.ignite.configuration.AtomicConfiguration;
import org.apache.ignite.configuration.CacheConfiguration;
import org.apache.ignite.configuration.CollectionConfiguration;
import org.apache.ignite.configuration.IgniteConfiguration;
import org.apache.ignite.configuration.NearCacheConfiguration;
+import org.apache.ignite.internal.cluster.IgniteClusterEx;
+import org.apache.ignite.internal.management.IgniteCommandRegistry;
+import org.apache.ignite.internal.processors.cache.GridCacheUtilityKey;
import org.apache.ignite.internal.processors.cache.IgniteCacheProxy;
+import org.apache.ignite.internal.processors.cache.IgniteInternalCache;
import
org.apache.ignite.internal.processors.cache.transactions.IgniteTransactionsImpl;
import org.apache.ignite.internal.util.typedef.internal.A;
+import org.apache.ignite.lang.IgniteBiTuple;
+import org.apache.ignite.lang.IgnitePredicate;
import org.apache.ignite.lang.IgniteProductVersion;
import org.apache.ignite.metric.IgniteMetrics;
import org.apache.ignite.plugin.IgnitePlugin;
@@ -69,9 +75,9 @@ import org.jetbrains.annotations.NotNull;
import org.jetbrains.annotations.Nullable;
/** Ignite instance aware of application attributes set with {@link
Ignite#withApplicationAttributes(Map)}. */
-public class IgniteApplicationAttributesAware implements Ignite {
+public class IgniteApplicationAttributesAware implements IgniteEx {
/** */
- private final Ignite delegate;
+ private final IgniteEx delegate;
/** Application attributes. */
private final Map<String, String> attrs;
@@ -83,7 +89,7 @@ public class IgniteApplicationAttributesAware implements
Ignite {
* @param delegate Parent Ignite instance.
* @param attrs Application attributes.
*/
- public IgniteApplicationAttributesAware(Ignite delegate, Map<String,
String> attrs) {
+ public IgniteApplicationAttributesAware(IgniteEx delegate, Map<String,
String> attrs) {
A.notNull(attrs, "application attributes");
this.delegate = delegate;
@@ -204,10 +210,93 @@ public class IgniteApplicationAttributesAware implements
Ignite {
}
/** {@inheritDoc} */
- @Override public IgniteCluster cluster() {
+ @Override public <K extends GridCacheUtilityKey, V> IgniteInternalCache<K,
V> utilityCache() {
+ return delegate.utilityCache();
+ }
+
+ /** {@inheritDoc} */
+ @Override public @Nullable <K, V> IgniteInternalCache<K, V> cachex(String
name) {
+ return delegate.cachex(name);
+ }
+
+ /** {@inheritDoc} */
+ @Override public Collection<IgniteInternalCache<?, ?>> cachesx(@Nullable
IgnitePredicate<? super IgniteInternalCache<?, ?>>... p) {
+ return delegate.cachesx(p);
+ }
+
+ /** {@inheritDoc} */
+ @Override public <K, V> IgniteBiTuple<IgniteCache<K, V>, Boolean>
getOrCreateCache0(
+ CacheConfiguration<K, V> cacheCfg,
+ boolean sql
+ ) throws CacheException {
+ return delegate.getOrCreateCache0(cacheCfg, sql);
+ }
+
+ /** {@inheritDoc} */
+ @Override public boolean destroyCache0(String cacheName, boolean sql)
throws CacheException {
+ return delegate.destroyCache0(cacheName, sql);
+ }
+
+ /** {@inheritDoc} */
+ @Override public boolean eventUserRecordable(int type) {
+ return delegate.eventUserRecordable(type);
+ }
+
+ /** {@inheritDoc} */
+ @Override public boolean allEventsUserRecordable(int[] types) {
+ return delegate.allEventsUserRecordable(types);
+ }
+
+ /** {@inheritDoc} */
+ @Override public boolean isJmxRemoteEnabled() {
+ return delegate.isJmxRemoteEnabled();
+ }
+
+ /** {@inheritDoc} */
+ @Override public boolean isRestartEnabled() {
+ return delegate.isRestartEnabled();
+ }
+
+ /** {@inheritDoc} */
+ @Override public IgniteClusterEx cluster() {
return delegate.cluster();
}
+ /** {@inheritDoc} */
+ @Override public @Nullable String latestVersion() {
+ return delegate.latestVersion();
+ }
+
+ /** {@inheritDoc} */
+ @Override public ClusterNode localNode() {
+ return delegate.localNode();
+ }
+
+ /** {@inheritDoc} */
+ @Override public GridKernalContext context() {
+ return delegate.context();
+ }
+
+ /** {@inheritDoc} */
+ @Override public boolean isRebalanceEnabled() {
+ return delegate.isRebalanceEnabled();
+ }
+
+ /** {@inheritDoc} */
+ @Override public void rebalanceEnabled(boolean rebalanceEnabled) {
+ delegate.rebalanceEnabled(rebalanceEnabled);
+ }
+
+ /** {@inheritDoc} */
+ @Override public <T> IgniteSet<T> set(String name, int cacheId, boolean
collocated, boolean separated) throws IgniteException {
+ return delegate.set(name, cacheId, collocated, separated);
+ }
+
+ /** {@inheritDoc} */
+ @Override public IgniteCommandRegistry commandsRegistry() {
+ return delegate.commandsRegistry();
+ }
+
/** {@inheritDoc} */
@Override public IgniteCompute compute() {
return delegate.compute();
