Uses of Class
org.apache.ignite.spi.IgniteSpiConfiguration
-
Packages that use IgniteSpiConfiguration Package Description org.apache.ignite.spi Contains common classes and interfaces for SPI implementations.org.apache.ignite.spi.checkpoint.cache Contains cache-based implementation for checkpoint SPI.org.apache.ignite.spi.checkpoint.jdbc Contains JDBC implementation for checkpoint SPI.org.apache.ignite.spi.checkpoint.sharedfs Contains shared file system implementation for checkpoint SPI.org.apache.ignite.spi.collision.fifoqueue Contains FIFO based collision SPI implementation.org.apache.ignite.spi.collision.jobstealing Contains job stealing collision SPI implementation.org.apache.ignite.spi.collision.priorityqueue Contains priority based collision SPI implementation.org.apache.ignite.spi.communication.tcp.internal Contains connection health-checkers for TCP/IP-based implementation of communication SPI.org.apache.ignite.spi.discovery.tcp Contains default TCP/IP implementation for discovery SPI.org.apache.ignite.spi.discovery.tcp.ipfinder Contains IP finder interface and adapter.org.apache.ignite.spi.discovery.tcp.ipfinder.jdbc Contains JDBC IP finder implementation.org.apache.ignite.spi.discovery.tcp.ipfinder.multicast Contains multicast-based IP finder.org.apache.ignite.spi.discovery.tcp.ipfinder.sharedfs Contains shared filesystem-based IP finder.org.apache.ignite.spi.discovery.tcp.ipfinder.vm Contains local JVM-based IP finder.org.apache.ignite.spi.eventstorage.memory Contains default in-memory implementation for event storage SPI.org.apache.ignite.spi.failover.always Contains default "always" failover SPI.org.apache.ignite.spi.failover.jobstealing Contains job stealing failover SPI.org.apache.ignite.spi.loadbalancing.adaptive Contains adaptive load balancing SPI.org.apache.ignite.spi.loadbalancing.roundrobin Contains default round-robin implementation for load balancing SPI.org.apache.ignite.spi.loadbalancing.weightedrandom Contains weighted random-base implementation for load balancing SPI. -
-
Uses of IgniteSpiConfiguration in org.apache.ignite.spi
Methods in org.apache.ignite.spi with annotations of type IgniteSpiConfiguration Modifier and Type Method Description IgniteSpiAdapterIgniteSpiAdapter. setName(String name)Sets SPI name. -
Uses of IgniteSpiConfiguration in org.apache.ignite.spi.checkpoint.cache
Methods in org.apache.ignite.spi.checkpoint.cache with annotations of type IgniteSpiConfiguration Modifier and Type Method Description CacheCheckpointSpiCacheCheckpointSpi. setCacheName(String cacheName)Sets cache name to be used by this SPI. -
Uses of IgniteSpiConfiguration in org.apache.ignite.spi.checkpoint.jdbc
Methods in org.apache.ignite.spi.checkpoint.jdbc with annotations of type IgniteSpiConfiguration Modifier and Type Method Description JdbcCheckpointSpiJdbcCheckpointSpi. setCheckpointTableName(String tblName)Sets checkpoint table name.JdbcCheckpointSpiJdbcCheckpointSpi. setDataSource(DataSource dataSrc)Sets DataSource to use for database access.JdbcCheckpointSpiJdbcCheckpointSpi. setExpireDateFieldName(String expDateName)Sets checkpoint expiration date field name.JdbcCheckpointSpiJdbcCheckpointSpi. setExpireDateFieldType(String expDateType)Sets checkpoint expiration date field type.JdbcCheckpointSpiJdbcCheckpointSpi. setKeyFieldName(String keyName)Sets checkpoint key field name.JdbcCheckpointSpiJdbcCheckpointSpi. setKeyFieldType(String keyType)Sets checkpoint key field type.JdbcCheckpointSpiJdbcCheckpointSpi. setNumberOfRetries(int retryNum)Sets number of retries in case of any database errors.JdbcCheckpointSpiJdbcCheckpointSpi. setPwd(String pwd)Sets checkpoint database password.JdbcCheckpointSpiJdbcCheckpointSpi. setUser(String user)Sets checkpoint database user name.JdbcCheckpointSpiJdbcCheckpointSpi. setValueFieldName(String valName)Sets checkpoint value field name.JdbcCheckpointSpiJdbcCheckpointSpi. setValueFieldType(String valType)Sets checkpoint value field type. -
Uses of IgniteSpiConfiguration in org.apache.ignite.spi.checkpoint.sharedfs
Methods in org.apache.ignite.spi.checkpoint.sharedfs with annotations of type IgniteSpiConfiguration Modifier and Type Method Description SharedFsCheckpointSpiSharedFsCheckpointSpi. setDirectoryPaths(Collection<String> dirPaths)Sets path to a shared directory where checkpoints will be stored. -
Uses of IgniteSpiConfiguration in org.apache.ignite.spi.collision.fifoqueue
Methods in org.apache.ignite.spi.collision.fifoqueue with annotations of type IgniteSpiConfiguration Modifier and Type Method Description FifoQueueCollisionSpiFifoQueueCollisionSpi. setParallelJobsNumber(int parallelJobsNum)Sets number of jobs that can be executed in parallel.FifoQueueCollisionSpiFifoQueueCollisionSpi. setWaitingJobsNumber(int waitJobsNum)Sets maximum number of jobs that are allowed to wait in waiting queue. -
Uses of IgniteSpiConfiguration in org.apache.ignite.spi.collision.jobstealing
Methods in org.apache.ignite.spi.collision.jobstealing with annotations of type IgniteSpiConfiguration Modifier and Type Method Description JobStealingCollisionSpiJobStealingCollisionSpi. setActiveJobsThreshold(int activeJobsThreshold)Sets number of jobs that can be executed in parallel.JobStealingCollisionSpiJobStealingCollisionSpi. setMaximumStealingAttempts(int maxStealingAttempts)Gets maximum number of attempts to steal job by another node.JobStealingCollisionSpiJobStealingCollisionSpi. setMessageExpireTime(long msgExpireTime)Message expire time configuration parameter.JobStealingCollisionSpiJobStealingCollisionSpi. setStealingAttributes(Map<String,? extends Serializable> stealAttrs)Configuration parameter to enable stealing to/from only nodes that have these attributes set (seeClusterNode.attribute(String)andIgniteConfiguration.getUserAttributes()methods).JobStealingCollisionSpiJobStealingCollisionSpi. setStealingEnabled(boolean isStealingEnabled)Gets flag indicating whether this node should attempt to steal jobs from other nodes.JobStealingCollisionSpiJobStealingCollisionSpi. setWaitJobsThreshold(int waitJobsThreshold)Sets job count threshold at which this node will start stealing jobs from other nodes. -
Uses of IgniteSpiConfiguration in org.apache.ignite.spi.collision.priorityqueue
Methods in org.apache.ignite.spi.collision.priorityqueue with annotations of type IgniteSpiConfiguration Modifier and Type Method Description PriorityQueueCollisionSpiPriorityQueueCollisionSpi. setDefaultPriority(int priority)Sets default priority to use if a job does not have priority attribute set.PriorityQueueCollisionSpiPriorityQueueCollisionSpi. setJobPriorityAttributeKey(String jobPriAttrKey)Sets job priority attribute key.PriorityQueueCollisionSpiPriorityQueueCollisionSpi. setParallelJobsNumber(int parallelJobsNum)Sets number of jobs that can be executed in parallel.PriorityQueueCollisionSpiPriorityQueueCollisionSpi. setPriorityAttributeKey(String taskPriAttrKey)Sets task priority attribute key.PriorityQueueCollisionSpiPriorityQueueCollisionSpi. setStarvationIncrement(int starvationInc)Sets value to increment job priority by every time a lower priority job gets behind a higher priority job.PriorityQueueCollisionSpiPriorityQueueCollisionSpi. setStarvationPreventionEnabled(boolean preventStarvation)Sets flag indicating whether job starvation prevention is enabled.PriorityQueueCollisionSpiPriorityQueueCollisionSpi. setWaitingJobsNumber(int waitJobsNum)Maximum number of jobs that are allowed to wait in waiting queue. -
Uses of IgniteSpiConfiguration in org.apache.ignite.spi.communication.tcp.internal
Methods in org.apache.ignite.spi.communication.tcp.internal with annotations of type IgniteSpiConfiguration Modifier and Type Method Description TcpCommunicationSpiTcpCommunicationConfigInitializer. setAckSendThreshold(int ackSndThreshold)Sets number of received messages per connection to node after which acknowledgment message is sent.TcpCommunicationSpiTcpCommunicationConfigInitializer. setAddressResolver(AddressResolver addrRslvr)Sets address resolver.TcpCommunicationSpiTcpCommunicationConfigInitializer. setConnectionsPerNode(int maxConnectionsPerNode)Sets number of connections to each remote node. ifTcpCommunicationConfigInitializer.isUsePairedConnections()istruethen number of connections is doubled and half is used for incoming and half for outgoing messages.TcpCommunicationSpiTcpCommunicationConfigInitializer. setConnectTimeout(long connTimeout)Sets connect timeout used when establishing connection with remote nodes.TcpCommunicationSpiTcpCommunicationConfigInitializer. setDirectBuffer(boolean directBuf)Sets flag to allocate direct or heap buffer in SPI.TcpCommunicationSpiTcpCommunicationConfigInitializer. setDirectSendBuffer(boolean directSndBuf)Sets whether to use direct buffer for sending.TcpCommunicationSpiTcpCommunicationConfigInitializer. setFilterReachableAddresses(boolean filterReachableAddresses)Setting this option totrueenables filter for reachable addresses on creating tcp client.TcpCommunicationSpiTcpCommunicationConfigInitializer. setForceClientToServerConnections(boolean forceClientToSrvConnections)Applicable for clients only.TcpCommunicationSpiTcpCommunicationConfigInitializer. setIdleConnectionTimeout(long idleConnTimeout)Sets maximum idle connection timeout upon which a connection to client will be closed.TcpCommunicationSpiTcpCommunicationConfigInitializer. setLocalAddress(String locAddr)Sets local host address for socket binding.TcpCommunicationSpiTcpCommunicationConfigInitializer. setLocalPort(int locPort)Sets local port for socket binding.TcpCommunicationSpiTcpCommunicationConfigInitializer. setLocalPortRange(int locPortRange)Sets local port range for local host ports (value must greater than or equal to 0).TcpCommunicationSpiTcpCommunicationConfigInitializer. setMaxConnectTimeout(long maxConnTimeout)Sets maximum connect timeout.TcpCommunicationSpiTcpCommunicationConfigInitializer. setMessageQueueLimit(int msgQueueLimit)Sets message queue limit for incoming and outgoing messages.TcpCommunicationSpiTcpCommunicationConfigInitializer. setReconnectCount(int reconCnt)Sets maximum number of reconnect attempts used when establishing connection with remote nodes.TcpCommunicationSpiTcpCommunicationConfigInitializer. setSelectorsCount(int selectorsCnt)Sets the count of selectors te be used in TCP server.TcpCommunicationSpiTcpCommunicationConfigInitializer. setSelectorSpins(long selectorSpins)Defines how many non-blockingselector.selectNow()should be made before falling intoselector.select(long)in NIO server.TcpCommunicationSpiTcpCommunicationConfigInitializer. setSharedMemoryPort(int shmemPort)Deprecated.This property is ignored and will be removed in future releases.TcpCommunicationSpiTcpCommunicationConfigInitializer. setSlowClientQueueLimit(int slowClientQueueLimit)Sets slow client queue limit.TcpCommunicationSpiTcpCommunicationConfigInitializer. setSocketReceiveBuffer(int sockRcvBuf)Sets receive buffer size for sockets created or accepted by this SPI.TcpCommunicationSpiTcpCommunicationConfigInitializer. setSocketSendBuffer(int sockSndBuf)Sets send buffer size for sockets created or accepted by this SPI.TcpCommunicationSpiTcpCommunicationConfigInitializer. setSocketWriteTimeout(long sockWriteTimeout)Sets socket write timeout for TCP connection.TcpCommunicationSpiTcpCommunicationConfigInitializer. setTcpNoDelay(boolean tcpNoDelay)Sets value forTCP_NODELAYsocket option.TcpCommunicationSpiTcpCommunicationConfigInitializer. setUnacknowledgedMessagesBufferSize(int unackedMsgsBufSize)Sets maximum number of stored unacknowledged messages per connection to node.TcpCommunicationSpiTcpCommunicationConfigInitializer. setUsePairedConnections(boolean usePairedConnections)Set this totrueifTcpCommunicationSpishould maintain connection for outgoing and incoming messages separately. -
Uses of IgniteSpiConfiguration in org.apache.ignite.spi.discovery.tcp
Methods in org.apache.ignite.spi.discovery.tcp with annotations of type IgniteSpiConfiguration Modifier and Type Method Description TcpDiscoverySpiTcpDiscoverySpi. setAckTimeout(long ackTimeout)Sets timeout for receiving acknowledgement for sent message.TcpDiscoverySpiTcpDiscoverySpi. setAddressFilter(IgnitePredicate<InetSocketAddress> addressFilter)Sets filter for IP addresses.voidTcpDiscoverySpi. setAddressResolver(AddressResolver addrRslvr)Sets address resolver.voidTcpDiscoverySpi. setClientReconnectDisabled(boolean clientReconnectDisabled)Sets client reconnect disabled flag.TcpDiscoverySpiTcpDiscoverySpi. setForceServerMode(boolean forceSrvMode)Deprecated.Will be removed at 3.0.TcpDiscoverySpiTcpDiscoverySpi. setIpFinder(TcpDiscoveryIpFinder ipFinder)Sets IP finder for IP addresses sharing and storing.TcpDiscoverySpiTcpDiscoverySpi. setIpFinderCleanFrequency(long ipFinderCleanFreq)Sets IP finder clean frequency in milliseconds.TcpDiscoverySpiTcpDiscoverySpi. setJoinTimeout(long joinTimeout)Sets join timeout.TcpDiscoverySpiTcpDiscoverySpi. setLocalAddress(String locAddr)Sets network addresses for the Discovery SPI.TcpDiscoverySpiTcpDiscoverySpi. setLocalPort(int locPort)Sets local port to listen to.TcpDiscoverySpiTcpDiscoverySpi. setLocalPortRange(int locPortRange)Range for local ports.TcpDiscoverySpiTcpDiscoverySpi. setMaxAckTimeout(long maxAckTimeout)Sets maximum timeout for receiving acknowledgement for sent message.TcpDiscoverySpiTcpDiscoverySpi. setNetworkTimeout(long netTimeout)Sets maximum network timeout to use for network operations.TcpDiscoverySpiTcpDiscoverySpi. setReconnectCount(int reconCnt)Number of times node tries to (re)establish connection to another node.TcpDiscoverySpiTcpDiscoverySpi. setReconnectDelay(int reconDelay)Sets the amount of time in milliseconds that node waits before retrying to (re)connect to the cluster.TcpDiscoverySpiTcpDiscoverySpi. setSocketTimeout(long sockTimeout)Sets socket operations timeout.voidTcpDiscoverySpi. setSoLinger(int soLinger)Sets SO_LINGER to use for all created sockets.TcpDiscoverySpiTcpDiscoverySpi. setStatisticsPrintFrequency(long statsPrintFreq)Sets statistics print frequency.TcpDiscoverySpiTcpDiscoverySpi. setThreadPriority(int threadPri)Sets thread priority.TcpDiscoverySpiTcpDiscoverySpi. setTopHistorySize(int topHistSize)Sets size of topology snapshots history. -
Uses of IgniteSpiConfiguration in org.apache.ignite.spi.discovery.tcp.ipfinder
Methods in org.apache.ignite.spi.discovery.tcp.ipfinder with annotations of type IgniteSpiConfiguration Modifier and Type Method Description TcpDiscoveryIpFinderAdapterTcpDiscoveryIpFinderAdapter. setShared(boolean shared)Sets shared flag. -
Uses of IgniteSpiConfiguration in org.apache.ignite.spi.discovery.tcp.ipfinder.jdbc
Methods in org.apache.ignite.spi.discovery.tcp.ipfinder.jdbc with annotations of type IgniteSpiConfiguration Modifier and Type Method Description TcpDiscoveryJdbcIpFinderTcpDiscoveryJdbcIpFinder. setDataSource(DataSource dataSrc)Sets data source.TcpDiscoveryJdbcIpFinderTcpDiscoveryJdbcIpFinder. setInitSchema(boolean initSchema)Flag indicating whether DB schema should be initialized by Ignite (default behaviour) or was explicitly created by user. -
Uses of IgniteSpiConfiguration in org.apache.ignite.spi.discovery.tcp.ipfinder.multicast
Methods in org.apache.ignite.spi.discovery.tcp.ipfinder.multicast with annotations of type IgniteSpiConfiguration Modifier and Type Method Description TcpDiscoveryMulticastIpFinderTcpDiscoveryMulticastIpFinder. setAddressRequestAttempts(int addrReqAttempts)Sets number of attempts to send multicast address request.TcpDiscoveryMulticastIpFinderTcpDiscoveryMulticastIpFinder. setLocalAddress(String locAddr)Sets local host address used by this IP finder.TcpDiscoveryMulticastIpFinderTcpDiscoveryMulticastIpFinder. setMulticastGroup(String mcastGrp)Sets IP address of multicast group.TcpDiscoveryMulticastIpFinderTcpDiscoveryMulticastIpFinder. setMulticastPort(int mcastPort)Sets port number which multicast messages are sent to.TcpDiscoveryMulticastIpFinderTcpDiscoveryMulticastIpFinder. setResponseWaitTime(int resWaitTime)Sets time in milliseconds IP finder waits for reply to multicast address request.TcpDiscoveryMulticastIpFinderTcpDiscoveryMulticastIpFinder. setTimeToLive(int ttl)Set the default time-to-live for multicast packets sent out on this IP finder in order to control the scope of the multicast. -
Uses of IgniteSpiConfiguration in org.apache.ignite.spi.discovery.tcp.ipfinder.sharedfs
Methods in org.apache.ignite.spi.discovery.tcp.ipfinder.sharedfs with annotations of type IgniteSpiConfiguration Modifier and Type Method Description TcpDiscoverySharedFsIpFinderTcpDiscoverySharedFsIpFinder. setPath(String path)Sets path. -
Uses of IgniteSpiConfiguration in org.apache.ignite.spi.discovery.tcp.ipfinder.vm
Methods in org.apache.ignite.spi.discovery.tcp.ipfinder.vm with annotations of type IgniteSpiConfiguration Modifier and Type Method Description TcpDiscoveryVmIpFinderTcpDiscoveryVmIpFinder. setAddresses(Collection<String> addrs)Parses provided values and initializes the internal collection of addresses. -
Uses of IgniteSpiConfiguration in org.apache.ignite.spi.eventstorage.memory
Methods in org.apache.ignite.spi.eventstorage.memory with annotations of type IgniteSpiConfiguration Modifier and Type Method Description MemoryEventStorageSpiMemoryEventStorageSpi. setExpireAgeMs(long expireAgeMs)Sets events expiration time.MemoryEventStorageSpiMemoryEventStorageSpi. setExpireCount(long expireCnt)Sets events queue size.MemoryEventStorageSpiMemoryEventStorageSpi. setFilter(IgnitePredicate<Event> filter)Sets filter for events to be recorded. -
Uses of IgniteSpiConfiguration in org.apache.ignite.spi.failover.always
Methods in org.apache.ignite.spi.failover.always with annotations of type IgniteSpiConfiguration Modifier and Type Method Description AlwaysFailoverSpiAlwaysFailoverSpi. setMaximumFailoverAttempts(int maxFailoverAttempts)Sets maximum number of attempts to execute a failed job on another node. -
Uses of IgniteSpiConfiguration in org.apache.ignite.spi.failover.jobstealing
Methods in org.apache.ignite.spi.failover.jobstealing with annotations of type IgniteSpiConfiguration Modifier and Type Method Description JobStealingFailoverSpiJobStealingFailoverSpi. setMaximumFailoverAttempts(int maxFailoverAttempts)Sets maximum number of attempts to execute a failed job on another node. -
Uses of IgniteSpiConfiguration in org.apache.ignite.spi.loadbalancing.adaptive
Methods in org.apache.ignite.spi.loadbalancing.adaptive with annotations of type IgniteSpiConfiguration Modifier and Type Method Description AdaptiveLoadBalancingSpiAdaptiveLoadBalancingSpi. setLoadProbe(AdaptiveLoadProbe probe)Sets implementation of node load probe. -
Uses of IgniteSpiConfiguration in org.apache.ignite.spi.loadbalancing.roundrobin
Methods in org.apache.ignite.spi.loadbalancing.roundrobin with annotations of type IgniteSpiConfiguration Modifier and Type Method Description RoundRobinLoadBalancingSpiRoundRobinLoadBalancingSpi. setPerTask(boolean isPerTask)Configuration parameter indicating whether a new round robin order should be created for every task. -
Uses of IgniteSpiConfiguration in org.apache.ignite.spi.loadbalancing.weightedrandom
Methods in org.apache.ignite.spi.loadbalancing.weightedrandom with annotations of type IgniteSpiConfiguration Modifier and Type Method Description WeightedRandomLoadBalancingSpiWeightedRandomLoadBalancingSpi. setNodeWeight(int nodeWeight)Sets weight of this node.WeightedRandomLoadBalancingSpiWeightedRandomLoadBalancingSpi. setUseWeights(boolean isUseWeights)Sets a flag to indicate whether node weights should be checked when doing random load balancing.
-