IgniteFuture<V> reconnectFut
org.apache.ignite.internal.jdbc.thin.ConnectionPropertiesImpl props
int loginTimeout
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
IOException
String typeName
BinaryIdMapper idMapper
BinaryNameMapper nameMapper
BinarySerializer serializer
boolean isEnum
Map<K,V> enumValues
String keyType
String valType
String keyFieldName
String valueFieldName
LinkedHashMap<K,V> fields
Set<E> keyFields
Map<K,V> aliases
Collection<E> idxs
String tableName
Set<E> _notNullFields
Map<K,V> defaultFieldValues
Map<K,V> fieldsPrecision
Map<K,V> fieldsScale
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
String[] attributeNames
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
int maxSize
int batchSize
long maxMemSize
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
Comparator<T> comp
org.hibernate.cache.spi.access.AccessType dfltAccessType
HibernateKeyTransformer hibernate4transformer
HibernateAccessStrategyFactory accessStgyFactory
org.hibernate.boot.spi.SessionFactoryOptions options
Query<R> initQry
javax.cache.configuration.Factory<T> rmtFilterFactory
long timeInterval
boolean autoUnsubscribe
boolean includeExpired
EventType.EXPIRED
events.javax.cache.event.CacheEntryUpdatedListener<K,V> locLsnr
CacheEntryEventSerializableFilter<K,V> rmtFilter
javax.cache.configuration.Factory<T> rmtTransFactory
ContinuousQueryWithTransformer.EventListener<T> locLsnr
String valType
String idxName
int limit
List<E> criteria
Integer part
String label
IgniteBiPredicate<E1,E2> filter
int pageSize
boolean loc
IgniteBiPredicate<E1,E2> filter
Integer part
Object[] args
String sql
Object[] args
boolean collocated
int timeout
boolean enforceJoinOrder
boolean distributedJoins
boolean replicatedOnly
boolean lazy
int[] parts
String schema
int updateBatchSize
String qryInitiatorId
boolean skipReducerOnUpdate
String label
String type
String alias
String sql
Object[] args
int timeout
boolean distributedJoins
boolean replicatedOnly
int[] parts
String sqlState
SQLException.getSQLState()
.int errCode
SQLException.getErrorCode()
.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
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
Serializable
Integer ttl
String keyspace
String tbl
String tblOptions
String keyspaceOptions
KeyPersistenceSettings keyPersistenceSettings
ValuePersistenceSettings valPersistenceSettings
List<E> tableColumns
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
Serializable
PersistenceStrategy stgy
Class<T> javaCls
String col
Serializer serializer
List<E> tableColumns
List<E> casUniqueFields
private void readObject(ObjectInputStream ois) throws IOException, ClassNotFoundException
IOException
- if some error in object reading.ClassNotFoundException
- throwsPojoKeyField.SortOrder sortOrder
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
Serializable
String sesFactoryBean
String hibernateCfgPath
Properties hibernateProps
Object appCtx
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
int maxParamsCnt
int fetchSize
String name
CacheAtomicityMode atomicityMode
int backups
CacheMode cacheMode
boolean eagerTtl
String grpName
long dfltLockTimeout
PartitionLossPolicy partLossPlc
boolean readFromBackup
int rebalanceBatchSize
long rebalanceBatchesPrefetchCnt
long rebalanceDelay
CacheRebalanceMode rebalanceMode
int rebalanceOrder
long rebalanceThrottle
long rebalanceTimeout
CacheWriteSynchronizationMode writeSynchronizationMode
boolean cpOnRead
String dataRegionName
boolean statisticsEnabled
int maxConcurrentAsyncOperations
int maxQryIteratorsCnt
boolean onheapCacheEnabled
int qryDetailMetricsSize
int qryParallelism
boolean sqlEscapeAll
int sqlIdxMaxInlineSize
String sqlSchema
CacheKeyConfiguration[] keyCfg
QueryEntity[] qryEntities
javax.cache.expiry.ExpiryPolicy expiryPlc
ClientCachePluginConfiguration[] pluginCfgs
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
BinaryIdMapper idMapper
BinaryNameMapper nameMapper
BinarySerializer serializer
Collection<E> typeCfgs
boolean compactFooter
protected Object writeReplace()
String name
String grpName
String memPlcName
DataRegionConfiguration
for this cacheint storeConcurrentLoadAllThreshold
CacheStore
.int rebalancePoolSize
long rebalanceTimeout
EvictionPolicy<K,V> evictPlc
javax.cache.configuration.Factory<T> evictPlcFactory
boolean onheapCache
boolean sqlOnheapCache
int sqlOnheapCacheMaxSize
EvictionFilter<K,V> evictFilter
boolean eagerTtl
long dfltLockTimeout
NearCacheConfiguration<K,V> nearCfg
PlatformCacheConfiguration platformCfg
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
boolean evtsDisabled
boolean encryptionEnabled
true
data on the disk will be encrypted.EncryptionSpi
,
KeystoreEncryptionSpi
EntryCompressionConfiguration entryCompressionCfg
String[] addrs
boolean tcpNoDelay
int timeout
int sndBufSize
int rcvBufSize
BinaryConfiguration binaryCfg
SslMode sslMode
String sslClientCertKeyStorePath
String sslClientCertKeyStorePwd
String sslTrustCertKeyStorePath
String sslTrustCertKeyStorePwd
String sslClientCertKeyStoreType
String sslTrustCertKeyStoreType
String sslKeyAlgorithm
boolean sslTrustAll
SslProtocol sslProto
javax.cache.configuration.Factory<T> sslCtxFactory
String userName
String userPwd
Map<K,V> userAttrs
ClientTransactionConfiguration txCfg
boolean affinityAwarenessEnabled
boolean clusterDiscoveryEnabled
long reconnectThrottlingPeriod
reconnectThrottlingRetries
attempts to reconnect will be made within reconnectThrottlingPeriod
in case of connection loss.
Throttling is disabled if either reconnectThrottlingRetries
or reconnectThrottlingPeriod
is 0.int reconnectThrottlingRetries
reconnectThrottlingPeriod
.int retryLimit
ClientRetryPolicy retryPolicy
Executor asyncContinuationExecutor
boolean heartbeatEnabled
long heartbeatInterval
boolean autoBinaryConfigurationEnabled
IgniteLogger logger
EventListener[] eventListeners
TransactionIsolation dfltIsolation
TransactionConcurrency dfltConcurrency
long dfltTxTimeout
CacheAtomicityMode atomicityMode
CacheMode cacheMode
IgnitePredicate<E> nodeFilter
int backups
long offHeapMaxMem
boolean collocated
String grpName
String name
long maxSize
long initSize
String swapPath
DataPageEvictionMode pageEvictionMode
PageReplacementMode pageReplacementMode
double evictionThreshold
int emptyPagesPoolSize
boolean metricsEnabled
int metricsSubIntervalCount
DataRegionConfiguration.setMetricsRateTimeInterval(long)
will be split into to calculate
DataRegionMetrics.getAllocationRate()
and DataRegionMetrics.getEvictionRate()
rates (5 by default).
Setting it to a bigger value will result in more precise calculation and smaller drops of
DataRegionMetrics.getAllocationRate()
metric when next sub-interval has to be recycled but introduces bigger
calculation overhead.
long metricsRateTimeInterval
DataRegionMetrics.getAllocationRate()
and DataRegionMetrics.getEvictionRate()
monitoring purposes.
For instance, after setting the interval to 60_000 milliseconds, subsequent calls to DataRegionMetrics.getAllocationRate()
will return average allocation rate (pages per second) for the last minute.
boolean persistenceEnabled
long checkpointPageBufSize
boolean lazyMemoryAllocation
true
, memory for DataRegion
will be allocated only on the creation of the first cache
belonged to this DataRegion
.
Default is true
.WarmUpConfiguration warmUpCfg
MemoryAllocator memoryAllocator
long sysRegionInitSize
long sysRegionMaxSize
int pageSize
int concLvl
DataRegionConfiguration dfltDataRegConf
DataRegionConfiguration[] dataRegions
String storagePath
long checkpointFreq
long lockWaitTime
int checkpointThreads
CheckpointWriteOrder checkpointWriteOrder
int walHistSize
long maxWalArchiveSize
int walSegments
int walSegmentSize
String walPath
String walArchivePath
boolean metricsEnabled
WALMode walMode
int walTlbSize
int walBuffSize
long walFlushFreq
long walFsyncDelay
int walRecordIterBuffSize
boolean alwaysWriteFullPages
org.apache.ignite.internal.processors.cache.persistence.file.FileIOFactory fileIOFactory
int metricsSubIntervalCnt
DataStorageConfiguration.setMetricsRateTimeInterval(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 metricsRateTimeInterval
long walAutoArchiveAfterInactivity
boolean writeThrottlingEnabled
boolean walCompactionEnabled
int walCompactionLevel
Long checkpointReadLockTimeout
DiskPageCompression walPageCompression
Integer walPageCompressionLevel
WarmUpConfiguration dfltWarmUpCfg
EncryptionConfiguration encCfg
int defragmentationThreadPoolSize
long minWalArchiveSize
MemoryAllocator memoryAllocator
double reencryptionRateLimit
0
for unlimited scanning).int reencryptionBatchSize
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
javax.cache.configuration.Factory<T> nearEvictPlcFactory
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 walBuffSize
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 writeThrottlingEnabled
boolean txSerEnabled
TransactionIsolation dfltIsolation
TransactionConcurrency dfltConcurrency
long dfltTxTimeout
long txTimeoutOnPartitionMapExchange
long deadlockTimeout
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
.Collection<E> baselineNodes
boolean autoAdjustEnabled
long autoAdjustTimeout
String cacheName
int part
Object key
IgniteUuid xid
String txLbl
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
Collection<E> baselineNodes
ClusterState prevState
ClusterState state
Collection<E> baselineNodes
ClusterState prevState
ClusterState state
String alias
ClusterNode evtNode
long topVer
Collection<E> topSnapshot
String msgTemplate
DiscoveryEvent.message()
lazily. Will be joined with DiscoveryEvent.eventNode()
converted to string.IgniteUuid id
long tstamp
ClusterNode node
String msg
int type
long locId
String taskName
String taskClsName
IgniteUuid sesId
IgniteUuid jobId
ClusterNode taskNode
UUID taskSubjId
ComputeJobResultPolicy resPlc
String dataRegionName
String taskName
String taskClsName
IgniteUuid sesId
boolean internal
UUID subjId
Transaction tx
long absWalSegmentIdx
File archiveFile
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
long totalRowCount
long rowCountForNewCluster
Vector sumOfAnomalies
Vector[] centers
DistanceMeasure distanceMeasure
Vector[] centers
DistanceMeasure distance
PredictionsAggregator predictionsAggregator
List<E> models
List<E> models
PredictionsAggregator predictionsAggregator
IgniteModel<T,V> mdl
BaggedTrainer
.IgniteFunction<T,R> internalToExternalLblMapping
long sampleSize
IgniteFunction<T,R> externalLbToInternalMapping
Loss loss
Preprocessor<K,V> preprocessor
double precision
IgniteModel<T,V> mdl1
IgniteModel<T,V> mdl2
double[] weights
double bias
IgniteModel<T,V> mdl
FeatureMeta featureMeta
double bucketSize
double minVal
String name
int featureId
boolean isCategoricalFeature
Vectorizer.LabelCoordinate lbCoordinateShortcut
boolean useAllValues
List<E> extractionCoordinates
Serializable labelCoord
HashSet<E> excludedCoords
Preprocessor<K,V> preprocessor
LabeledVector
.int samplesCnt
double subsampleSize
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
IOException
AffinityFunction delegate
partition()
.Preprocessor<K,V> preprocessor
upstream
data.Preprocessor<K,V> preprocessor
upstream
data.Preprocessor<K,V> vectorizer
upstream
data.IgniteFunction<T,R> parallelismStgy
IgniteFunction<T,R> loggingFactory
IgniteFunction<T,R> seed
IgniteFunction<T,R> rngSupplier
long dataTtl
Ignite ignite
IgniteLogger log
Long key1
Long key2
double crossOverRate
Ignite ignite
GAConfiguration cfg
Long key
Ignite ignite
IgniteLogger log
IFitnessFunction fitnessFuncton
Ignite ignite
GAConfiguration cfg
Ignite ignite
GAConfiguration cfg
Ignite ignite
IgniteLogger log
Double totalFitnessScore
LinkedHashMap<K,V> map
Ignite ignite
ComputeLoadBalancer balancer
GAConfiguration cfg
String name
String desc
ModelSignature signature
ModelReader reader
ModelParser<I,O,M extends Model<I,O>> parser
String schema
String inputMsg
ModelSignature.schema
.String outputMsg
ModelSignature.schema
).Map<K,V> inputs
List<E> outputNames
TensorFlowBaseModelParser.OutputTransformer<O> outputTransformer
String[] tags
String path
byte[] data
String path
IgniteSupplier<T> mdlStorageSupplier
Dataset<C extends Serializable,D extends AutoCloseable> dataset
SpatialIndex
as a partition data.DistanceMeasure distanceMeasure
int k
boolean weighted
Preprocessor<K,V> preprocessor
SpatialIndexType spatialIdxType
DistanceMeasure distanceMeasure
int k
DistanceMeasure distanceMeasure
boolean weighted
LabeledVectorSet<Row extends LabeledVector> candidates
ANNClassificationTrainer.CentroidStat centroindsStat
ConcurrentHashMap<K,V> centroidStat
ConcurrentHashMap<K,V> counts
ConcurrentSkipListSet<E> clsLblsSet
ANNClassificationTrainer.CentroidStat candidatesStat
LabeledVectorSet<Row extends LabeledVector> candidates
int k
DistanceMeasure distanceMeasure
boolean weighted
org.apache.ignite.ml.knn.regression.KNNRegressionModel.KNNRegressionPredictor predictor
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
double[] x
int iterations
double[] u
int isstop
double r1norm
double r2norm
double anorm
double acond
double arnorm
double xnorm
double[] var
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, 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, 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
double[][][] probabilities
labels[c][f][b]
contains a probability for
class c
for feature f
for bucket b
.double[] clsProbabilities
double[] labels
double[][] bucketThresholds
bucketThresholds[f][b]
contains the right
border for feature f
for bucket b
. Everything which is above the last thresdold goes to the next
bucket.DiscreteNaiveBayesSumsHolder sumsHolder
double[][] means
double[][] variances
double[] classProbabilities
double[] labels
org.apache.ignite.ml.naivebayes.gaussian.GaussianNaiveBayesSumsHolder sumsHolder
MLPArchitecture architecture
List<E> layers
MultilayerPerceptron below
int neuronsCnt
boolean hasBias
IgniteDifferentiableDoubleToDoubleFunction activationFunction
Vector prevIterationUpdates
double learningRate
IgniteFunction<T,R> loss
double momentum
Vector prevIterationUpdates
Vector prevIterationGradient
Vector deltas
Vector updatesMask
double initUpdate
double accelerationRate
double deaccelerationRate
IgniteFunction<T,R> loss
Vector gradient
double learningRate
IgniteFunction<T,R> loss
IgniteModel<T,V> internalMdl
Pipeline
.Preprocessor<K,V> preprocessor
double threshold
Preprocessor<K,V> basePreprocessor
Preprocessor<K,V> original
IgniteFunction<T,R> mapping
Preprocessor<K,V> basePreprocessor
IgniteFunction<T,R> lbPatcher
Vector imputingValues
Preprocessor<K,V> basePreprocessor
double[] maxAbs
Preprocessor<K,V> basePreprocessor
double[] min
double[] max
Preprocessor<K,V> basePreprocessor
int p
Preprocessor<K,V> basePreprocessor
double[] means
double[] sigmas
Preprocessor<K,V> basePreprocessor
Serializable obj
Serializable subj
Double rating
Vector weights
double intercept
Vector weights
double intercept
boolean isKeepingRawLabels
double threshold
UniformMapper<K,V> mapper
IgniteBiPredicate<E1,E2> trainFilter
IgniteBiPredicate<E1,E2> testFilter
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
LabeledVectorSet<Row extends LabeledVector> train
LabeledVectorSet<Row extends LabeledVector> test
Preprocessor<K,V> preprocessor
Preprocessor<K,V> preprocessor
boolean isKeepingRawLabels
double threshold
Vector weights
double intercept
IgniteFunction<T,R> before
IgniteFunction<T,R> after
IgniteModel<T,V> mdl
double subsampleRatio
long seed
int col
double threshold
DecisionTreeNode thenNode
DecisionTreeNode elseNode
DecisionTreeNode missingNode
double val
Preprocessor<K,V> preprocessor
upstream
data.boolean buildIdx
boolean useIdx
long[] left
long[] right
double leftY
double leftY2
long leftCnt
double rightY
double rightY2
long rightCnt
int minSizeToBeCompressed
double minImpurityIncreaseForRecord
double minImpurityDecreaseForRecord
int treeId
long nodeId
int featureId
double val
double impurity
double gain
NodeId id
int featureId
double val
TreeNode.Type type
double impurity
int depth
TreeNode left
TreeNode right
BucketMeta bucketMeta
int sampleId
ObjectHistogram<T> counters
ObjectHistogram<T> sumOfLabels
ObjectHistogram<T> sumOfSquaredLabels
Set<E> bucketIds
BucketMeta bucketMeta
int featureId
int sampleId
double sumOfValues
long cntOfValues
double min
double max
double sumOfSquares
double sumOfValues
long n
int cacheSize
LRUCacheExpirationListener<V> expirationLsnr
Map<K,V> dict
ModelsComposition modelsComposition
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
Collection<E> cfgs
int delta
UUID nodeId
long rcvCnt
long connectCnt
int connIdx
byte[] nodeIdBytes
long rcvCnt
Key k
byte[] digest
private void readObject(ObjectInputStream in)
IgniteLogger log
Scope scope
Scope
of a trace's root span to which some specific tracing configuration will be applied.
It's a mandatory attribute.String lb
double samplingRate
Set<E> includedScopes
Scope
that defines which sub-traces will be included in a given trace.
In other words, if the child's span scope is equal to parent's scope
or it belongs to the parent's span included scopes, then the given child span will be attached to the current trace,
otherwise it'll be skipped.
See Span.isChainable(Scope)
for more details.String proto
String keyAlgorithm
String keyStoreType
String keyStoreFilePath
char[] keyStorePwd
String trustStoreType
String trustStoreFilePath
char[] trustStorePwd
TrustManager[] trustMgrs
String[] cipherSuites
String[] protocols
boolean needClientAuth
AtomicReference<V> sslCtx
SSLContext
.int gridCnt
int threadCnt
int iterCnt
int keyRange
int discoveryPort
String[] warmupMethods
String appName
String bannerSpec
String ver
LocalDate release
String copyright
GridBagConstraints gbc
Action closeAct
JButton closeBtn
Collection<E> igniteInstanceNames
TensorFlowClusterSpec spec
Map<K,V> processes
UUID clusterId
TensorFlowJobArchive jobArchive
String topicName
UUID nodeId
int port
TensorFlowClusterSpec clusterSpec
String jobName
Integer taskIdx
String proto
Boolean loc
UUID nodeId
IgniteRunnable task
LongRunningProcessState state
Exception e
SerializableSupplier<T> procBuilderSupplier
String stdin
UUID nodeId
NativeProcess procSpec
boolean interactive
String[] meta
IgniteLogger log
TransactionConcurrency transactionConcurrency
String cfgPath
IgniteConfiguration cfg
String igniteInstanceName
Ignite ignite
org.springframework.context.ApplicationContext springCtx
int compressionLevel
int dictionarySize
boolean requireDictionary
int samplesBufSz
boolean compressKeys
int batchSndSize
long batchSndFreq
long backupSyncFreq
int maxBatches
int maxBackupQueueSize
CacheDrEntryFilter<K,V> entryFilter
DrSenderLoadBalancingMode loadBalancingMode
long stateTransferThrottle
int stateTransferThrottleBytes
int stateTransferThreadsCnt
boolean preferLocSnd
String senderGroup
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
CacheConflictMode conflictRslvrMode
CacheConflictResolver<K,V> conflictRslvr
boolean drReceiverEnabled
CacheDrSenderConfiguration drSndCacheCfg
SecuritySubjectType subjType
UUID subjId
Object login
InetSocketAddress addr
List<E> allAddr
SecurityPermission op
SecuritySubject subj
String name
Collection<E> dcIds
String name
CacheDrPauseReason reason
UUID initiatorId
byte dcId
int nodeCnt
InetSocketAddress rmtAddr
byte dcId
Byte dcId
UUID licId
long snapshotId
Throwable error
null
if it has succeeded.public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
IOException
long processed
long total
double operationProgress
long finishTime
SnapshotOperationInfo operation
IgniteUuid opId
Map<K,V> progress
Map<K,V> progressDetailed
long startStageTime
int stageNum
long startTime
boolean notCancelable
String shortMsg
org.gridgain.grid.internal.processors.license.LicenseViolationInfoHolder licViolInfoHld
private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException
IOException
- If something wrong.ClassNotFoundException
- If some class is not found.private void writeObject(ObjectOutputStream stream) throws IOException
IOException
- If something wrong.UUID id
SecuritySubjectType type
Object login
InetSocketAddress address
SecurityPermissionSet permissions
Certificate[] certificates
Pattern pattern
Pattern pattern
InetAddress addr
InetAddress itfAddr
NetworkInterface itf
int timeout
int ttl
boolean init
AtomicBoolean initGuard
CountDownLatch initLatch
String path
File folder
AtomicBoolean initGuard
CountDownLatch initLatch
InetSocketAddress addr
String host
int port
InetAddress locAddr
int locPort
int connTimeout
AtomicBoolean initGuard
CountDownLatch initLatch
GridGain In-Memory Computing Platform : ver. 8.9.14 Release Date : November 5 2024