Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/hazelcast/hazelcast
/ functions
Functions
147,315 in github.com/hazelcast/hazelcast
⨍
Functions
147,315
◇
Types & classes
15,944
↓ 3 callers
Method
txn
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/xa/HazelcastXATest.java:241
↓ 3 callers
Method
typeConverter
The {@link com.hazelcast.core.TypeConverter} to be used to convert the string value read from XML to the expected type automatically. @return a defin
hazelcast/src/main/java/com/hazelcast/config/properties/PropertyDefinition.java:44
↓ 3 callers
Method
types
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/file/FileTable.java:64
↓ 3 callers
Method
unblock
()
hazelcast/src/test/java/com/hazelcast/jet/job/AbstractJobInitialSnapshotTest.java:189
↓ 3 callers
Method
unescapeSpecialCharacters
@param buffer the string for which the escape character '\' is removed properly @return the unescaped string
hazelcast/src/main/java/com/hazelcast/client/impl/statistics/ClientStatisticsService.java:271
↓ 3 callers
Method
uniqueName
Creates a {@code Vertex} name that is unique in this DAG and starts with the given prefix.
hazelcast/src/main/java/com/hazelcast/jet/core/DAG.java:333
↓ 3 callers
Method
unit
Return the measurement unit for the associated metric. Meant to provide further information on the type of value measured by the user-defined metric.
hazelcast/src/main/java/com/hazelcast/jet/core/metrics/Metric.java:49
↓ 3 callers
Method
unknownJobOption
(String key)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/parse/ParserResource.java:85
↓ 3 callers
Method
unlock
()
hazelcast/src/main/java/com/hazelcast/jet/impl/MasterContext.java:145
↓ 3 callers
Method
unmodifiableArray
Returns an unmodifiable wrapper for the specified JsonArray. This method allows to provide read-only access to a JsonArray. <p> The returned JsonArray
hazelcast/src/main/java/com/hazelcast/internal/json/JsonArray.java:108
↓ 3 callers
Method
unmodifiableObject
Returns an unmodifiable JsonObject for the specified one. This method allows to provide read-only access to a JsonObject. <p> The returned JsonObject
hazelcast/src/main/java/com/hazelcast/internal/json/JsonObject.java:126
↓ 3 callers
Method
unprocessedNodes
(ConfigNode node)
hazelcast/src/main/java/com/hazelcast/internal/config/override/ConfigNodeStateTracker.java:27
↓ 3 callers
Method
unregisterMBeanIgnoreError
(ObjectName objectName)
hazelcast/src/main/java/com/hazelcast/internal/metrics/jmx/JmxPublisher.java:139
↓ 3 callers
Method
unscheduleExpirationTask
Ends scheduling of the task that clears expired entries. Calling this method multiple times has same effect.
hazelcast/src/main/java/com/hazelcast/internal/eviction/ExpirationManager.java:100
↓ 3 callers
Method
unwrap
@return internal implementation specific instance of supplied clazz, otherwise returns null.
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/writebehind/WriteBehindQueue.java:112
↓ 3 callers
Method
unwrapPayload
(Object jetEvent)
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/FunctionAdapter.java:292
↓ 3 callers
Method
unzip
(InputStream is, Path targetDir)
hazelcast/src/main/java/com/hazelcast/jet/impl/util/IOUtil.java:103
↓ 3 callers
Method
update
()
hazelcast/src/main/java/com/hazelcast/query/impl/bitmap/BitmapAlgorithms.java:235
↓ 3 callers
Method
updateBranch
Synchronously calculates the hash for all the parent nodes of the node referenced by {@code leafOrder} up to the root node. @param leafOrder The orde
hazelcast/src/main/java/com/hazelcast/wan/impl/merkletree/ArrayMerkleTree.java:168
↓ 3 callers
Method
updateGetNextRecordsTime
(long currentTime, long minimumIncrease)
extensions/kinesis/src/main/java/com/hazelcast/jet/kinesis/impl/source/ShardReader.java:313
↓ 3 callers
Method
updateMemberGroupsSize
()
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/PartitionStateManager.java:86
↓ 3 callers
Method
updateRecordValue
Updates record's value. Performs an update in-place if the record can accommodate the new value (applicable for the inlined records only). Otherwise,
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/Storage.java:61
↓ 3 callers
Method
updateTcpIpMemberList
(String clusterName, String clusterPassword, String memberListText)
hazelcast/src/test/java/com/hazelcast/internal/ascii/HTTPCommunicator.java:437
↓ 3 callers
Method
updatesMongo_using
(String expr)
extensions/mongodb/src/test/java/com/hazelcast/jet/sql/impl/connector/mongodb/MongoBatchSqlConnectorUpdateIT.java:380
↓ 3 callers
Method
uploadJobResources
Uploads job resources and returns a unique job id generated for the job. If the upload process fails for any reason, such as being unable to access a
hazelcast/src/main/java/com/hazelcast/jet/impl/JobRepository.java:225
↓ 3 callers
Method
uploadResourcesForNewJob
()
hazelcast/src/test/java/com/hazelcast/jet/impl/JobRepositoryTest.java:277
↓ 3 callers
Method
url
@return the path of the resource
hazelcast/src/main/java/com/hazelcast/internal/namespace/ResourceDefinition.java:45
↓ 3 callers
Method
user
()
hazelcast/src/test/java/com/hazelcast/test/jdbc/MSSQLDatabaseProvider.java:105
↓ 3 callers
Method
valOrNull
(final long value)
hazelcast/src/main/java/com/hazelcast/internal/util/collection/Object2LongHashMap.java:620
↓ 3 callers
Method
validateAttribute
Validate attribute name. @param config Index config. @param attributeName Attribute name.
hazelcast/src/main/java/com/hazelcast/query/impl/IndexUtils.java:172
↓ 3 callers
Method
validateConfiguredKeyType
Validates the key with key type. @param keyType key class. @param key key to be validated. @param <K> the type of key. @throws ClassCastExcep
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheProxyUtil.java:214
↓ 3 callers
Method
validateConfiguredValueType
Validates the value with value type. @param valueType value class. @param value value to be validated. @param <V> the type of value. @throw
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheProxyUtil.java:231
↓ 3 callers
Method
validateJoinMessage
Validate that the configuration received from the remote node in {@code joinMessage} is compatible with the configuration of this node. @param joinMe
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/ClusterJoinManager.java:258
↓ 3 callers
Method
validateMembersViewMetadata
(MembersViewMetadata membersViewMetadata)
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/MembershipManager.java:612
↓ 3 callers
Method
validatePartitionStamp
Verifies that the given partition stamp is still valid. It is valid iff there were no partition updates since the call to the {@link #getPartitionStam
hazelcast/src/main/java/com/hazelcast/query/impl/InternalIndex.java:117
↓ 3 callers
Method
validateProcessor
()
hazelcast/src/test/java/com/hazelcast/jet/core/VertexTest.java:107
↓ 3 callers
Method
validateRegion
(String region)
hazelcast/src/main/java/com/hazelcast/aws/RegionValidator.java:34
↓ 3 callers
Method
validateRegistrationsOnMembers
(final TestHazelcastFactory factory, int expected)
hazelcast/src/test/java/com/hazelcast/client/listeners/AbstractListenersOnReconnectTest.java:299
↓ 3 callers
Method
validateRestConfig
(Config config)
hazelcast/src/test/java/com/hazelcast/config/AbstractConfigBuilderTest.java:757
↓ 3 callers
Method
validateSenderIsMaster
(Address sender, String messageType)
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/InternalPartitionServiceImpl.java:661
↓ 3 callers
Method
validateSuffixInSystemProperty
Validates if the config file referenced in {@code propertyKey} has an accepted suffix. If the system property is not set, the validation passes withou
hazelcast/src/main/java/com/hazelcast/internal/config/DeclarativeConfigUtil.java:99
↓ 3 callers
Method
value
(T item)
hazelcast/src/main/java/com/hazelcast/jet/impl/connector/WriteMapP.java:117
↓ 3 callers
Method
valueFields
()
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/schema/map/PartitionedMapTable.java:112
↓ 3 callers
Method
valueIterator
(Comparable value, TypeConverter converter)
hazelcast/src/main/java/com/hazelcast/query/impl/bitmap/Bitmap.java:212
↓ 3 callers
Method
valueToData
(Object value)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheRecordStore.java:344
↓ 3 callers
Method
verifyClass
Verifies that the provided {@link Class} is safe to use for attribute extraction in this policy. @param clazz the class to verify @return the verifie
hazelcast/src/main/java/com/hazelcast/query/impl/getters/policy/ReflectiveAttributeLookupPolicy.java:56
↓ 3 callers
Method
verifyCollectedOnce
(CapturingCollector collector, MetricDescriptor expectedDescriptor)
hazelcast/src/test/java/com/hazelcast/internal/server/tcp/TcpServerConnectionManagerMetricsTest.java:61
↓ 3 callers
Method
verifyDataStructureMetricPresent
(HazelcastInstance instance, boolean shouldContain)
hazelcast/src/test/java/com/hazelcast/internal/metrics/impl/MetricsPropertiesTest.java:215
↓ 3 callers
Method
verifyNotBuilt
()
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/nio/NioAsyncServerSocketBuilder.java:99
↓ 3 callers
Method
verifyRunning
()
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/Reactor.java:242
↓ 3 callers
Method
verifyScriptEngineFactory
(ScriptEngineFactory scriptEngineFactory)
hazelcast/src/test/java/com/hazelcast/osgi/impl/HazelcastOSGiScriptEngineFactoryTest.java:63
↓ 3 callers
Method
verifyTreesAreSameOnCommonLevels
(MerkleTree merkleTreeShallow, MerkleTree merkleTreeDeep)
hazelcast/src/test/java/com/hazelcast/wan/impl/merkletree/ArrayMerkleTreeTest.java:300
↓ 3 callers
Method
verifyValue
(long key1, long key2, long valueAddress)
hazelcast/src/test/java/com/hazelcast/internal/util/hashslot/impl/HashSlotArray16byteKeyImplTest.java:412
↓ 3 callers
Method
verifyValue
(long key, long valueAddress)
hazelcast/src/test/java/com/hazelcast/internal/util/hashslot/impl/HashSlotArray8byteKeyImplTest.java:313
↓ 3 callers
Method
waitAllForSafeStateAndDumpPartitionServiceOnFailure
(List<HazelcastInstance> instances,
hazelcast/src/test/java/com/hazelcast/partition/AbstractPartitionLostListenerTest.java:182
↓ 3 callers
Method
waitBlockingSemaphore
()
hazelcast/src/test/java/com/hazelcast/jet/core/TestProcessors.java:358
↓ 3 callers
Method
waitForFirstStatisticsCollection
(final HazelcastClientInstanceImpl client, final Clie
hazelcast/src/test/java/com/hazelcast/client/statistics/ClientStatisticsTest.java:350
↓ 3 callers
Method
waitForJobRunning
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlMetadataInJobConfigTest.java:147
↓ 3 callers
Method
waitForNearCachePersistence
(final NearCacheTestContext context, final int persistenceCount)
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/AbstractNearCachePreloaderTest.java:446
↓ 3 callers
Method
waitForTopicConsumption
()
hazelcast/src/test/java/com/hazelcast/jet/impl/connector/JmsSourceIntegrationTestBase.java:137
↓ 3 callers
Method
waitInstanceForSafeState
(final HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/test/HazelcastTestSupport.java:757
↓ 3 callers
Method
waitPartitionReplicaSyncOnCluster
Waits until partition replicas (primaries and backups) get in sync. @param unit time unit @param supplier the {@link SafeStateCheckOperation} supplie
hazelcast/src/main/java/com/hazelcast/internal/hotrestart/InternalHotRestartService.java:153
↓ 3 callers
Method
waitUntilAllResponded
(Collection<? extends Future> futures)
hazelcast/src/main/java/com/hazelcast/internal/util/FutureUtil.java:291
↓ 3 callers
Method
waitUntilLoaded
()
hazelcast/src/main/java/com/hazelcast/map/impl/proxy/MapProxySupport.java:776
↓ 3 callers
Method
wanMapConsistencyCheck
(String clusterName, String clusterPassword, String wanRepName, Strin
hazelcast/src/test/java/com/hazelcast/internal/ascii/HTTPCommunicator.java:334
↓ 3 callers
Method
watermarkedColumnIndex
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/FullScan.java:53
↓ 3 callers
Method
watermarkedFieldByIndex
(int watermarkedFieldIndex)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/metadata/HazelcastRelMdWatermarkedFields.java:81
↓ 3 callers
Method
whenNoProblemPacket
(int threadCount)
hazelcast/src/test/java/com/hazelcast/spi/impl/operationservice/impl/InboundResponseHandlerSupplierTest.java:128
↓ 3 callers
Method
when_maxAccumulatedRecordsCountIsExceededWhileS2SJoin_then_throws
(Object[][] rows1, Object[][] rows2)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlMemoryManagementTest.java:163
↓ 3 callers
Method
when_snapshotFails
(ProcessingGuarantee guarantee, boolean expectFailure)
hazelcast/src/test/java/com/hazelcast/jet/impl/connector/JmsSourceIntegration_NonSharedClusterTest.java:119
↓ 3 callers
Method
when_zipSlipVulnerability_then_zipEntryIgnored
@param entryFunction maps from (targetDir, nonTargetDir) to an entry path
hazelcast/src/test/java/com/hazelcast/jet/impl/util/IOUtilTest.java:137
↓ 3 callers
Method
windowDefinition
Returns the definition of the window for the windowed aggregation operation that you are about to construct using this object.
hazelcast/src/main/java/com/hazelcast/jet/pipeline/StageWithWindow.java:57
↓ 3 callers
Method
windowPolicyProvider
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/SlidingWindowAggregatePhysicalRel.java:114
↓ 3 callers
Method
withBackupCount
(int backupCount)
hazelcast/src/test/java/com/hazelcast/map/EntryCostEstimatorTest.java:267
↓ 3 callers
Method
withBackupProcessingDelay
(int backupDelaySeconds)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/writebehind/TestMapUsingMapStoreBuilder.java:86
↓ 3 callers
Method
withCacheName
(String cacheName)
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/subscriber/QueryCacheRequest.java:58
↓ 3 callers
Method
withCatalog
(String schema)
hazelcast/src/main/java/com/hazelcast/dataconnection/impl/ResourceReader.java:38
↓ 3 callers
Method
withClassName
(String className)
hazelcast/src/test/java/com/hazelcast/config/test/builders/MapXmlStoreConfigBuilder.java:43
↓ 3 callers
Method
withCodecRegistry
(CodecRegistry codecRegistry)
extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/dataconnection/CloseableMongoClient.java:207
↓ 3 callers
Method
withContext
(QueryCacheContext context)
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/subscriber/QueryCacheRequest.java:80
↓ 3 callers
Method
withDefaults
()
hazelcast/src/test/java/com/hazelcast/jet/impl/util/JsonUtilTest.java:322
↓ 3 callers
Method
withFilter
(RexNode filter)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/schema/HazelcastTable.java:133
↓ 3 callers
Method
withHeaders
(Map<String, String> headers)
hazelcast/src/main/java/com/hazelcast/spi/utils/RestClient.java:137
↓ 3 callers
Method
withHeartbeatIntervalMillis
Bootstrap the stats with heartbeats that corresponds to this duration in milliseconds, with a rather high standard deviation (since environment is unk
hazelcast/src/main/java/com/hazelcast/config/ProbabilisticSplitBrainProtectionConfigBuilder.java:119
↓ 3 callers
Method
withInMemoryFormat
(InMemoryFormat inMemoryFormat)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/writebehind/TestMapUsingMapStoreBuilder.java:137
↓ 3 callers
Method
withInitialMode
(MapStoreConfig.InitialLoadMode initialMode)
hazelcast/src/test/java/com/hazelcast/config/test/builders/MapXmlStoreConfigBuilder.java:38
↓ 3 callers
Method
withKey
(K key)
hazelcast/src/main/java/com/hazelcast/map/impl/SimpleEntryView.java:69
↓ 3 callers
Method
withMapName
(String mapName)
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/event/QueryCacheEventDataBuilder.java:80
↓ 3 callers
Method
withMaxSampleSize
Number of samples to use for calculation of mean and standard deviation of inter-arrival times.
hazelcast/src/main/java/com/hazelcast/config/ProbabilisticSplitBrainProtectionConfigBuilder.java:89
↓ 3 callers
Method
withMemberSelector
Selects the members on which the job will run. <p> If there is no member matching the selector during submission, the submission will be successful, b
hazelcast/src/main/java/com/hazelcast/jet/JetService.java:341
↓ 3 callers
Method
withMinStdDeviationMillis
Minimum standard deviation (in milliseconds) to use for the normal distribution used when calculating phi. Too low standard deviation might result in
hazelcast/src/main/java/com/hazelcast/config/ProbabilisticSplitBrainProtectionConfigBuilder.java:99
↓ 3 callers
Method
withNodeCount
(int nodeCount)
hazelcast/src/test/java/com/hazelcast/map/EntryCostEstimatorTest.java:258
↓ 3 callers
Method
withPartitionId
(int partitionId)
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/event/QueryCacheEventDataBuilder.java:70
↓ 3 callers
Method
withRetryStrategy
Specifies how the source should behave when reading data from the stream fails. The default behavior retries the read operation indefinitely, but afte
extensions/kinesis/src/main/java/com/hazelcast/jet/kinesis/KinesisSinks.java:288
↓ 3 callers
Method
withStore
(MapXmlStoreConfigBuilder mapXmlStoreConfigBuilder)
hazelcast/src/test/java/com/hazelcast/config/test/builders/MapXmlConfigBuilder.java:42
↓ 3 callers
Method
withSuspicionThreshold
Threshold for suspicion (φ) level. A low threshold is prone to generate many wrong suspicions but ensures a quick detection in the event of a real cra
hazelcast/src/main/java/com/hazelcast/config/ProbabilisticSplitBrainProtectionConfigBuilder.java:81
↓ 3 callers
Method
withWriteBatchSize
(int writeBatchSize)
hazelcast/src/test/java/com/hazelcast/config/test/builders/MapXmlStoreConfigBuilder.java:53
↓ 3 callers
Method
withWriteBehindQueueCapacity
(int writeBehindQueueCapacity)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/writebehind/TestMapUsingMapStoreBuilder.java:110
↓ 3 callers
Method
withWriteDelay
(int writeDelaySeconds)
hazelcast/src/test/java/com/hazelcast/config/test/builders/MapXmlStoreConfigBuilder.java:48
↓ 3 callers
Method
word
()
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/MetricsDictionary.java:78
← previous
next →
16,001–16,100 of 147,315, ranked by callers