IgniteFuture<V> restartFut
IgniteFuture<V> reconnectFut
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
IOException
String keyType
String valType
String keyFieldName
String valueFieldName
LinkedHashMap<K,V> fields
Set<E> keyFields
Map<K,V> aliases
Collection<E> idxs
String tableName
String name
LinkedHashMap<K,V> fields
QueryIndexType type
int inlineSize
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
IOException
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
IOException
int parts
int mask
boolean exclNeighbors
IgniteBiPredicate<E1,E2> backupFilter
IgniteBiPredicate<E1,E2> affinityBackupFilter
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
IOException
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
IOException
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
IOException
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
IOException
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
IOException
Query<R> initQry
javax.cache.event.CacheEntryUpdatedListener<K,V> locLsnr
CacheEntryEventSerializableFilter<K,V> rmtFilter
javax.cache.configuration.Factory<T> rmtFilterFactory
long timeInterval
boolean autoUnsubscribe
boolean includeExpired
EventType.EXPIRED
events.IgniteBiPredicate<E1,E2> filter
Integer part
Object[] args
String sql
Object[] args
boolean collocated
int timeout
boolean enforceJoinOrder
boolean distributedJoins
boolean replicatedOnly
int[] parts
String schema
Object appCtx
String dataSrcBean
String persistenceSettingsBean
DataSource dataSrc
KeyValuePersistenceSettings persistenceSettings
int maxPoolSize
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
IOException
Integer ttl
String keyspace
String tbl
String tblOptions
String keyspaceOptions
KeyPersistenceSettings keyPersistenceSettings
ValuePersistenceSettings valPersistenceSettings
List<E> tableColumns
PersistenceStrategy stgy
Class<T> javaCls
String col
Serializer serializer
List<E> tableColumns
List<E> casUniqueFields
PojoKeyField.SortOrder sortOrder
String connUrl
String createTblQry
String loadQry
String updateQry
String insertQry
String delQry
String user
String passwd
boolean initSchema
String dataSrcBean
Object appCtx
int batchSize
String dataSrcBean
JdbcDialect dialect
int maxPoolSize
int maxWrtAttempts
int parallelLoadCacheMinThreshold
0
then load sequentially.JdbcTypeHasher hasher
JdbcTypesTransformer transformer
JdbcType[] types
javax.cache.configuration.Factory<T> dataSrcFactory
boolean sqlEscapeAll
String cacheName
String dbSchema
String dbTbl
String keyType
JdbcTypeField[] keyFields
String valType
JdbcTypeField[] valFlds
JdbcTypeHasher hasher
Object[] args
ComputeLoadBalancer balancer
Ignite ignite
ComputeTaskSession ses
IgniteLogger log
ComputeLoadBalancer balancer
ComputeTaskContinuousMapper mapper
GridifyNodeFilter nodeFilter
int splitSize
int threshold
boolean limitedSplit
Ignite ignite
ComputeLoadBalancer balancer
protected Object writeReplace()
String name
String grpName
String memPlcName
MemoryPolicyConfiguration
for this cacheint storeConcurrentLoadAllThreshold
CacheStore
.int rebalancePoolSize
long rebalanceTimeout
EvictionPolicy<K,V> evictPlc
boolean onheapCache
EvictionFilter<K,V> evictFilter
boolean eagerTtl
long dfltLockTimeout
NearCacheConfiguration<K,V> nearCfg
CacheWriteSynchronizationMode writeSync
javax.cache.configuration.Factory<T> storeFactory
Boolean storeKeepBinary
boolean loadPrevVal
AffinityFunction aff
CacheMode cacheMode
CacheAtomicityMode atomicityMode
int backups
boolean invalidate
String tmLookupClsName
CacheRebalanceMode rebalanceMode
int rebalanceOrder
int rebalanceBatchSize
long rebalanceBatchesPrefetchCnt
int maxConcurrentAsyncOps
int sqlIdxMaxInlineSize
boolean writeBehindEnabled
int writeBehindFlushSize
long writeBehindFlushFreq
int writeBehindFlushThreadCnt
int writeBehindBatchSize
boolean writeBehindCoalescing
int maxQryIterCnt
AffinityKeyMapper affMapper
long rebalanceDelay
long rebalanceThrottle
CacheInterceptor<K,V> interceptor
Class<T>[] sqlFuncCls
long longQryWarnTimeout
int qryDetailMetricsSz
boolean readFromBackup
false
always get data from primary node (never from backup).IgnitePredicate<E> nodeFilter
String sqlSchema
boolean sqlEscapeAll
boolean cpOnRead
CachePluginConfiguration<K,V>[] pluginCfgs
TopologyValidator topValidator
javax.cache.configuration.Factory<T>[] storeSesLsnrs
Collection<E> qryEntities
PartitionLossPolicy partLossPlc
int qryParallelism
CacheKeyConfiguration[] keyCfg
CacheAtomicityMode atomicityMode
CacheMode cacheMode
IgnitePredicate<E> nodeFilter
int backups
long offHeapMaxMem
boolean collocated
String grpName
long sysCacheInitSize
long sysCacheMaxSize
int pageSize
int concLvl
String dfltMemPlcName
long dfltMemPlcSize
MemoryPolicyConfiguration[] memPlcs
String name
long initialSize
long maxSize
String swapFilePath
DataPageEvictionMode pageEvictionMode
double evictionThreshold
int emptyPagesPoolSize
boolean metricsEnabled
int subIntervals
MemoryPolicyConfiguration.setRateTimeInterval(long)
will be split into to calculate
MemoryMetrics.getAllocationRate()
and MemoryMetrics.getEvictionRate()
rates (5 by default).
Setting it to a bigger value will result in more precise calculation and smaller drops of
MemoryMetrics.getAllocationRate()
metric when next sub-interval has to be recycled but introduces bigger
calculation overhead.
long rateTimeInterval
MemoryMetrics.getAllocationRate()
and MemoryMetrics.getEvictionRate()
monitoring purposes.
For instance, after setting the interval to 60_000 milliseconds, subsequent calls to MemoryMetrics.getAllocationRate()
will return average allocation rate (pages per second) for the last minute.
EvictionPolicy<K,V> nearEvictPlc
int nearStartSize
String persistenceStorePath
long checkpointingFreq
long lockWaitTime
long checkpointingPageBufSize
int checkpointingThreads
CheckpointWriteOrder checkpointWriteOrder
int walHistSize
int walSegments
int walSegmentSize
String walStorePath
String walArchivePath
boolean metricsEnabled
WALMode walMode
int tlbSize
long walFlushFreq
long walFsyncDelay
int walRecordIterBuffSize
boolean alwaysWriteFullPages
org.apache.ignite.internal.processors.cache.persistence.file.FileIOFactory fileIOFactory
int subIntervals
PersistentStoreConfiguration.setRateTimeInterval(long)
will be split into to calculate
rate-based metrics.
Setting it to a bigger value will result in more precise calculation and smaller drops of rate-based metrics when next sub-interval has to be recycled but introduces bigger calculation overhead.
long rateTimeInterval
long walAutoArchiveAfterInactivity
boolean txSerEnabled
TransactionIsolation dfltIsolation
TransactionConcurrency dfltConcurrency
long dfltTxTimeout
int pessimisticTxLogSize
int pessimisticTxLogLinger
String tmLookupClsName
javax.cache.configuration.Factory<T> txManagerFactory
javax.transaction.TransactionManager
factory.boolean useJtaSync
javax.transaction.Synchronization
instead of javax.transaction.xa.XAResource
.String cacheName
int part
Object key
IgniteUuid xid
Object lockId
Object newVal
Object oldVal
boolean hasOldVal
boolean hasNewVal
ClusterNode evtNode
boolean near
near
or partitioned
cache.UUID subjId
String cloClsName
String taskName
String qryType
String cacheName
String clsName
String clause
IgniteBiPredicate<E1,E2> scanQryFilter
CacheEntryEventSerializableFilter<K,V> contQryFilter
Object[] args
UUID subjId
String taskName
String qryType
String cacheName
String clsName
String clause
IgniteBiPredicate<E1,E2> scanQryFilter
CacheEntryEventSerializableFilter<K,V> contQryFilter
Object[] args
UUID subjId
String taskName
Object key
Object val
Object oldVal
Object row
String cacheName
int part
ClusterNode discoNode
int discoEvtType
long discoTs
String cpKey
String alias
ClusterNode evtNode
long topVer
Collection<E> topSnapshot
IgniteUuid id
long tstamp
ClusterNode node
String msg
int type
long locId
String taskName
String taskClsName
IgniteUuid sesId
IgniteUuid jobId
ClusterNode taskNode
UUID taskSubjId
String taskName
String taskClsName
IgniteUuid sesId
boolean internal
UUID subjId
long absWalSegmentIdx
File archiveFile
public void readExternal(ObjectInput arg0) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
public void writeExternal(ObjectOutput arg0) throws IOException
IOException
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
IOException
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
IOException
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
IOException
UserNameMapper[] mappers
public void readExternal(ObjectInput in) throws IOException
IOException
public void writeExternal(ObjectOutput out) throws IOException
IOException
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
IOException
Ignite ignite
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
IOException
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
IOException
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
IOException
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
IOException
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
IOException
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
IOException
public void readExternal(ObjectInput in) throws IOException
IOException
public void writeExternal(ObjectOutput out) throws IOException
IOException
boolean keepGoing
UUID nodeId
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
IOException
Object nativeFactory
String name
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
IOException
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
IOException
UUID nodeId
long rcvCnt
long connectCnt
String proto
String keyAlgorithm
String keyStoreType
String keyStoreFilePath
char[] keyStorePwd
String trustStoreType
String trustStoreFilePath
char[] trustStorePwd
TrustManager[] trustMgrs
int gridCnt
int threadCnt
int iterCnt
int keyRange
int discoveryPort
String[] warmupMethods
String appName
String bannerSpec
String ver
Date release
String copyright
GridBagConstraints gbc
Action closeAct
JButton closeBtn
Collection<E> igniteInstanceNames
IgniteLogger log
String igniteTupleField
long autoFlushFrequency
boolean allowOverwrite
org.apache.storm.task.OutputCollector collector
IgniteLogger log
TransactionConcurrency transactionConcurrency
String cfgPath
IgniteConfiguration cfg
String igniteInstanceName
Ignite ignite
org.springframework.context.ApplicationContext springCtx
Follow @ApacheIgnite
Ignite Fabric : ver. 2.2.0 Release Date : September 15 2017