MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

↓ 8 callersMethodrecordNanos
(long durationNanos)
hazelcast/src/main/java/com/hazelcast/internal/util/LatencyDistribution.java:141
↓ 8 callersMethodrecordStoreIterator
()
hazelcast/src/main/java/com/hazelcast/cache/impl/CachePartitionSegment.java:68
↓ 8 callersMethodrecover
(XAResource xaResource)
hazelcast/src/test/java/com/hazelcast/xa/HazelcastXACompatibilityTest.java:165
↓ 8 callersMethodregisterDynamicMetricsProvider
(DynamicMetricsProvider metricsProvider)
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/MetricsRegistryImpl.java:165
↓ 8 callersMethodregisterLocalListener
(String cacheNameWithPrefix, CacheEventListener listener)
hazelcast/src/main/java/com/hazelcast/cache/impl/ICacheService.java:109
↓ 8 callersMethodregisterSerializer
Registers the given serializer for the given class for the scope of the job. It will be accessible to all the code attached to the underlying pipeline
hazelcast/src/main/java/com/hazelcast/jet/config/JobConfig.java:1152
↓ 8 callersMethodreleaseReadLock
()
hazelcast/src/main/java/com/hazelcast/query/impl/BaseIndexStore.java:88
↓ 8 callersMethodreleaseReplicaSyncPermits
Releases the previously acquired permits. @param permitsToRelease number of permits
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/PartitionReplicaManager.java:454
↓ 8 callersMethodremoteSocketAddress
@return the remote address. Returned value could be null.
hazelcast/src/main/java/com/hazelcast/internal/networking/Channel.java:135
↓ 8 callersMethodremove
(K key)
hazelcast/src/main/java/com/hazelcast/internal/adapter/DataStructureAdapter.java:82
↓ 8 callersMethodreplicaMigrationCompleted
Called when a partition replica migration is completed successfully. @param event the event for the partition replica migration
hazelcast/src/main/java/com/hazelcast/partition/MigrationListener.java:64
↓ 8 callersMethodreset
Resets the descriptor instance @return the this instance after reset
hazelcast/src/main/java/com/hazelcast/internal/metrics/MetricDescriptor.java:292
↓ 8 callersMethodreset
Resets this service back to its initial state. This should represent the same state that the service would be in after a normal startup, including con
hazelcast/src/main/java/com/hazelcast/internal/services/ManagedService.java:49
↓ 8 callersMethodreset
()
hazelcast/src/main/java/com/hazelcast/internal/cluster/Joiner.java:31
↓ 8 callersMethodreset
Returns all associated resources of this map-data-store back to the initial state.
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/MapDataStore.java:59
↓ 8 callersMethodresetInternalMigrationListener
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/internal/partition/impl/MigrationCommitTest.java:523
↓ 8 callersMethodresolveClass
(ObjectStreamClass desc)
hazelcast/src/main/java/com/hazelcast/internal/nio/IOUtil.java:959
↓ 8 callersMethodresolveClientFailoverConfig
Loads failover configuration using the search logic described in {@link HazelcastClient#newHazelcastFailoverClient()} and builds {@link ClientFailover
hazelcast/src/main/java/com/hazelcast/client/impl/clientside/FailoverClientConfigSupport.java:45
↓ 8 callersMethodresolveDialect
(JdbcTable table, DagBuildContext context)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/jdbc/JdbcSqlConnector.java:305
↓ 8 callersMethodrestoreProperty
(String sysProp, String previous)
hazelcast/src/test/java/com/hazelcast/internal/eviction/AbstractExpirationManagerTest.java:223
↓ 8 callersMethodretrieveResult
Retrieves the result with the given taskId @param taskId combination of partitionId and sequence @param <T> the type of the task's result @return
hazelcast/src/main/java/com/hazelcast/durableexecutor/DurableExecutorService.java:104
↓ 8 callersMethodreturnInputBuffer
Returns a BufferObjectDataInput back to the pool. The implementation is free to not return the instance to the pool. In that case this call does not
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/bufferpool/BufferPool.java:66
↓ 8 callersMethodreturnsResponse
()
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/operations/Backup.java:263
↓ 8 callersMethodrun
()
extensions/kinesis/src/main/java/com/hazelcast/jet/kinesis/impl/sink/ShardCountMonitor.java:20
↓ 8 callersMethodrun
Returns {@code true} if this task has successfully run, {@code false} otherwise. @return {@code true} if this task has successfully run. @throws Exce
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/writebehind/DefaultWriteBehindProcessor.java:379
↓ 8 callersMethodrunMapFullTest
Extensive test which ensures that the {@link QueryResultSizeExceededException} will not be thrown under the configured limit. <p> This test fills the
hazelcast/src/test/java/com/hazelcast/map/MapUnboundedReturnValuesTestSupport.java:79
↓ 8 callersMethodrunProcessor
()
extensions/elasticsearch/elasticsearch-7/src/test/java/com/hazelcast/jet/elastic/impl/ElasticSourcePTest.java:92
↓ 8 callersMethodrunTest
( JoinRelType joinType, Expression<Boolean> rowProjectorCondition, Express
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/map/JoinByEquiJoinProcessorTest.java:141
↓ 8 callersMethodrunTest
( JoinRelType joinType, Expression<Boolean> rowProjectorCondition, List<Ex
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/map/JoinScanProcessorTest.java:153
↓ 8 callersMethodsampleIntegers
()
hazelcast/src/test/java/com/hazelcast/aggregation/TestSamples.java:50
↓ 8 callersMethodsampleLongs
()
hazelcast/src/test/java/com/hazelcast/aggregation/TestSamples.java:59
↓ 8 callersMethodschedule
(IScheduledExecutorService scheduledExecutorService, int name, int taskValue)
hazelcast/src/test/java/com/hazelcast/scheduledexecutor/impl/ScheduledExecutorSplitBrainTest.java:235
↓ 8 callersMethodscheduleOnAllMembers
Creates and executes a one-shot action that becomes enabled after the given delay on all cluster {@link Member}s. <p> <b>Note:</b> In the event of Me
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/IScheduledExecutorService.java:293
↓ 8 callersMethodsecondary
()
hazelcast/src/main/java/com/hazelcast/client/impl/connection/Addresses.java:51
↓ 8 callersMethodselectClassLoaders
(ClassLoader classLoader)
hazelcast/src/main/java/com/hazelcast/internal/util/ServiceLoader.java:152
↓ 8 callersMethodselectMembers
(MemberSelector memberSelector)
hazelcast/src/main/java/com/hazelcast/client/impl/proxy/ClientExecutorServiceProxy.java:555
↓ 8 callersMethodselectMembers
(@Nonnull MemberSelector memberSelector)
hazelcast/src/main/java/com/hazelcast/executor/impl/ExecutorServiceProxy.java:628
↓ 8 callersMethodserialize
(String o)
hazelcast/src/test/java/com/hazelcast/jet/impl/execution/StoreSnapshotTaskletTest.java:196
↓ 8 callersMethodservicePortWithName
(String name, Integer port, Integer targetPort, Integer nodePort)
hazelcast/src/test/java/com/hazelcast/kubernetes/KubernetesFakeUtils.java:505
↓ 8 callersMethodsession
Returns a window definition that aggregates events into session windows. In a session window, the items are grouped into variable size, non-overlappin
hazelcast/src/main/java/com/hazelcast/jet/pipeline/WindowDefinition.java:142
↓ 8 callersMethodset
Sets the value of the member with the specified name to the JSON representation of the specified <code>int</code> value. If this object does not conta
hazelcast/src/main/java/com/hazelcast/internal/json/JsonObject.java:316
↓ 8 callersMethodsetAcknowledgeType
Sets the strategy for when the target cluster should acknowledge that a WAN event batch has been processed. @param acknowledgeType acknowledge type @
hazelcast/src/main/java/com/hazelcast/config/WanBatchPublisherConfig.java:280
↓ 8 callersMethodsetAllocatorType
Sets the {@link MemoryAllocatorType} to be used while allocating native memory. @param allocatorType {@code MemoryAllocatorType} @return this {@link
hazelcast/src/main/java/com/hazelcast/config/NativeMemoryConfig.java:171
↓ 8 callersMethodsetAllowOverrideDefaultSerializers
This configuration should be used cautiously. <p> Default serializers are used heavily by the hazelcast internally. If any of the instance in the same
hazelcast/src/main/java/com/hazelcast/config/SerializationConfig.java:545
↓ 8 callersMethodsetBackupCount
Sets the number of synchronous backups. @param backupCount the number of synchronous backups to set @return the updated SemaphoreConfig @throws Illeg
hazelcast/src/main/java/com/hazelcast/config/RingbufferConfig.java:198
↓ 8 callersMethodsetBatchMaxDelayMillis
Sets the maximum amount of time in milliseconds to wait before sending a batch of events to target cluster, if {@link #getBatchSize()} of events have
hazelcast/src/main/java/com/hazelcast/config/WanBatchPublisherConfig.java:233
↓ 8 callersMethodsetBatchSize
Sets the batch size which will be used to determine number of events to be sent in a batch to {@code QueryCache} @param batchSize the batch size @ret
hazelcast/src/main/java/com/hazelcast/config/QueryCacheConfig.java:222
↓ 8 callersMethodsetCacheManager
Sets relevant {@link HazelcastCacheManager} to client/server. @param cacheManager client or server {@link HazelcastCacheManager}
hazelcast/src/main/java/com/hazelcast/cache/impl/ICacheInternal.java:77
↓ 8 callersMethodsetCapacity
Sets the capacity of this memory tier. @param capacity capacity. @return this MemoryTierConfig
hazelcast/src/main/java/com/hazelcast/config/MemoryTierConfig.java:66
↓ 8 callersMethodsetCompactSerializationConfig
@param compactSerializationConfig config for the compact serialization format @return configured {@link com.hazelcast.config.SerializerConfig} for cha
hazelcast/src/main/java/com/hazelcast/config/SerializationConfig.java:572
↓ 8 callersMethodsetConn
Sets the Connection this Packet is send with. <p> This is done on the reading side of the Packet to make it possible to retrieve information about the
hazelcast/src/main/java/com/hazelcast/internal/nio/Packet.java:145
↓ 8 callersMethodsetConnectionType
Sets the type of the connection @param connectionType to be set
hazelcast/src/main/java/com/hazelcast/internal/server/ServerConnection.java:49
↓ 8 callersMethodsetDiscoveryServiceProvider
(DiscoveryServiceProvider discoveryServiceProvider)
hazelcast/src/main/java/com/hazelcast/config/DiscoveryConfig.java:66
↓ 8 callersMethodsetEfConstruction
Sets the size of the dynamic list search to use during index time. @param efConstruction the size of the dynamic list search. @return this VectorInde
hazelcast/src/main/java/com/hazelcast/config/vector/VectorIndexConfig.java:220
↓ 8 callersMethodsetEmptyQueueTtl
@param emptyQueueTtl set the TTL (time to live) for destroying the Queue (in seconds). <br> Once items have been removed and the Queue has been
hazelcast/src/main/java/com/hazelcast/config/QueueConfig.java:120
↓ 8 callersMethodsetEnabled
@param enabled the enabled interface to set
hazelcast/src/main/java/com/hazelcast/config/InterfacesConfig.java:42
↓ 8 callersMethodsetEnabled
(boolean enabled)
hazelcast/src/main/java/com/hazelcast/config/AdvancedNetworkConfig.java:224
↓ 8 callersMethodsetEndpoint
Sets the WAN endpoint configuration qualifier. When using pre-3.12 network configuration, its value can be {@code null} and is not taken into account.
hazelcast/src/main/java/com/hazelcast/config/WanBatchPublisherConfig.java:776
↓ 8 callersMethodsetFeature
(DocumentBuilderFactory dbf, String featureName)
hazelcast/src/main/java/com/hazelcast/internal/util/XmlUtil.java:205
↓ 8 callersMethodsetIfSupported
Sets the option on the underlying socket if that option is supported. @param option the option @param value the value @param <T> the type of the
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/net/AsyncServerSocketBuilder.java:64
↓ 8 callersMethodsetIndexConfigs
(List<IndexConfig> indexConfigs)
hazelcast/src/main/java/com/hazelcast/config/MapConfig.java:581
↓ 8 callersMethodsetInitError
(SupplierEx<? extends Throwable> initError)
hazelcast/src/test/java/com/hazelcast/jet/core/TestProcessors.java:459
↓ 8 callersMethodsetKeyClassName
(String keyClassName)
hazelcast/src/main/java/com/hazelcast/config/AbstractCacheConfig.java:368
↓ 8 callersMethodsetKeyType
Sets the key type for this {@link com.hazelcast.cache.ICache}. @param keyType the key type to set for this {@link com.hazelcast.cache.ICache} @return
hazelcast/src/main/java/com/hazelcast/config/CacheSimpleConfig.java:207
↓ 8 callersMethodsetLabel
(String label)
hazelcast/src/test/java/com/hazelcast/ringbuffer/RingbufferSplitBrainTest.java:390
↓ 8 callersMethodsetLastUpdateTime
Sets the cache last update time as atomic if the given time is bigger than it. @param time time to set the cache last update time
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheStatisticsImpl.java:254
↓ 8 callersMethodsetLogger
(@Nonnull ILogger logger)
hazelcast/src/main/java/com/hazelcast/jet/core/test/TestProcessorContext.java:78
↓ 8 callersMethodsetMasterAddressToJoin
(final Address master)
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/ClusterServiceImpl.java:630
↓ 8 callersMethodsetMaxConcurrentReplicationTargets
Sets the maximum number of target members that we replicate the CRDT states to in one period. A higher count will lead to states being disseminated mo
hazelcast/src/main/java/com/hazelcast/config/CRDTReplicationConfig.java:90
↓ 8 callersMethodsetMaxDegree
Sets the maximum number of connections allowed per node. @param maxDegree The maximum degree to set. @return this VectorIndexConfig instance
hazelcast/src/main/java/com/hazelcast/config/vector/VectorIndexConfig.java:197
↓ 8 callersMethodsetMinimumClusterSize
(int minimumClusterSize)
hazelcast/src/main/java/com/hazelcast/config/SplitBrainProtectionConfig.java:132
↓ 8 callersMethodsetName
Sets a descriptive name for this transform. @param name the stage name. If {@code null}, the stage will use its default name
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/transform/Transform.java:45
↓ 8 callersMethodsetName
(String name)
hazelcast/src/main/java/com/hazelcast/config/ServerSocketEndpointConfig.java:201
↓ 8 callersMethodsetNativeMemoryConfig
Sets the native memory configuration for this hazelcast instance. The native memory configuration defines how native memory is used and the limits on
hazelcast/src/main/java/com/hazelcast/config/Config.java:2848
↓ 8 callersMethodsetNewValue
(Object newValue)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/steps/engine/State.java:161
↓ 8 callersMethodsetNullableBoolean
It is legal to set the field again only when Builder is created with {@link GenericRecord#newBuilderWithClone()}. Otherwise, it is illegal to set to t
hazelcast/src/main/java/com/hazelcast/nio/serialization/genericrecord/GenericRecordBuilder.java:317
↓ 8 callersMethodsetNullableFloat32
It is legal to set the field again only when Builder is created with {@link GenericRecord#newBuilderWithClone()}. Otherwise, it is illegal to set to t
hazelcast/src/main/java/com/hazelcast/nio/serialization/genericrecord/GenericRecordBuilder.java:448
↓ 8 callersMethodsetNullableFloat64
It is legal to set the field again only when Builder is created with {@link GenericRecord#newBuilderWithClone()}. Otherwise, it is illegal to set to t
hazelcast/src/main/java/com/hazelcast/nio/serialization/genericrecord/GenericRecordBuilder.java:474
↓ 8 callersMethodsetNullableInt8
It is legal to set the field again only when Builder is created with {@link GenericRecord#newBuilderWithClone()}. Otherwise, it is illegal to set to t
hazelcast/src/main/java/com/hazelcast/nio/serialization/genericrecord/GenericRecordBuilder.java:343
↓ 8 callersMethodsetOf
(Object... objects)
hazelcast/src/test/java/com/hazelcast/kubernetes/DnsEndpointResolverTest.java:137
↓ 8 callersMethodsetOwnerUuid
(UUID ownerUuid)
hazelcast/src/main/java/com/hazelcast/map/impl/tx/MapTxnOperation.java:35
↓ 8 callersMethodsetPartitionLostListenerConfigs
(List<MapPartitionLostListenerConfig> listenerConfigs)
hazelcast/src/main/java/com/hazelcast/config/MapConfig.java:564
↓ 8 callersMethodsetPort
Sets the port the Hazelcast member will try to bind on. <p> A valid port value is between 0 and 65535. A port number of 0 will let the system pick up
hazelcast/src/main/java/com/hazelcast/config/NetworkConfig.java:108
↓ 8 callersMethodsetPrefetchCount
Sets how many IDs are pre-fetched on the background when one call to {@link FlakeIdGenerator#newId()} is made. Default is 100. <p> This setting pertai
hazelcast/src/main/java/com/hazelcast/config/FlakeIdGeneratorConfig.java:152
↓ 8 callersMethodsetProtectOn
(SplitBrainProtectionOn protectOn)
hazelcast/src/main/java/com/hazelcast/config/SplitBrainProtectionConfig.java:145
↓ 8 callersMethodsetQueueCapacity
Sets the queue capacity of the executor task. 0 means {@code Integer.MAX_VALUE}. @param queueCapacity Queue capacity of the executor task. 0 means {@
hazelcast/src/main/java/com/hazelcast/config/ExecutorConfig.java:139
↓ 8 callersMethodsetQueueFullBehavior
Sets the configured behaviour of this WAN publisher when the WAN queue is full. @param queueFullBehavior the behaviour of this publisher when the WAN
hazelcast/src/main/java/com/hazelcast/config/WanBatchPublisherConfig.java:395
↓ 8 callersMethodsetRel
(@Nullable PhysicalRel rel)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/DagBuildContextImpl.java:79
↓ 8 callersMethodsetReplicaCount
Sets the number of replicas on which state for this PN counter will be kept. This number applies in quiescent state, if there are currently membership
hazelcast/src/main/java/com/hazelcast/config/PNCounterConfig.java:132
↓ 8 callersMethodsetReplicationPeriodMillis
Sets the period between two replications of CRDT states in milliseconds. A lower value will increase the speed at which changes are disseminated to ot
hazelcast/src/main/java/com/hazelcast/config/CRDTReplicationConfig.java:63
↓ 8 callersMethodsetResponseTimeoutMillis
Sets the duration in milliseconds for the waiting time before retrying to send the events to target cluster again in case of acknowledgement is not ar
hazelcast/src/main/java/com/hazelcast/config/WanBatchPublisherConfig.java:257
↓ 8 callersMethodsetRetentionSeconds
Sets the number of seconds the metrics will be retained on the instance. By default, metrics are retained for 5 seconds (that is for one collection of
hazelcast/src/main/java/com/hazelcast/config/MetricsManagementCenterConfig.java:102
↓ 8 callersMethodsetSalt
Sets the salt used for encryption. @param salt the salt
hazelcast/src/main/java/com/hazelcast/config/AbstractSymmetricEncryptionConfig.java:92
↓ 8 callersMethodsetSocketInterceptorConfig
Sets the {@link SocketInterceptorConfig}. The value can be {@code null} if no socket interception is needed. @param socketInterceptorConfig the Socke
hazelcast/src/main/java/com/hazelcast/config/NetworkConfig.java:298
↓ 8 callersMethodsetTable
(Table table)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/DagBuildContextImpl.java:83
↓ 8 callersMethodsetTableWhitelist
Optional regular expressions that match fully-qualified table identifiers for tables to be monitored; any table not included in the whitelist will be
extensions/cdc-postgres/src/main/java/com/hazelcast/jet/cdc/postgres/PostgresCdcSources.java:262
↓ 8 callersMethodsetTailSequence
Sets the tail sequence. The tail sequence cannot be less than {@code headSequence() - 1}. @param tailSequence the new tail sequence @throws IllegalAr
hazelcast/src/main/java/com/hazelcast/ringbuffer/impl/Ringbuffer.java:71
↓ 8 callersMethodsetTarget
Provides the designated target member address to which the operation will be sent. <ul> <li> This method is invoked on the implementing ob
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/TargetAware.java:57
↓ 8 callersMethodsetToValueFn
(FunctionEx<? super T, ? extends V> toValueFn)
hazelcast/src/main/java/com/hazelcast/jet/impl/connector/MapSinkConfiguration.java:83
↓ 8 callersMethodsetUseNativeByteOrder
(boolean useNativeByteOrder)
hazelcast/src/main/java/com/hazelcast/internal/serialization/SerializationServiceBuilder.java:53
← previousnext →8,101–8,200 of 147,315, ranked by callers