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
↓ 32 callers
Method
addJar
Adds a JAR whose contents will be accessible to all the code attached to the underlying pipeline or DAG, but not to any other code. An important examp
hazelcast/src/main/java/com/hazelcast/jet/config/JobConfig.java:370
↓ 32 callers
Method
addPackages
Adds the given package names to this filter. @param names package names to add @return this filter
hazelcast/src/main/java/com/hazelcast/config/ClassFilter.java:123
↓ 32 callers
Method
arr
(String... strings)
hazelcast/src/test/java/com/hazelcast/internal/util/StringUtilTest.java:219
↓ 32 callers
Method
classNameOrImpl
(String className, Object impl)
hazelcast/src/test/java/com/hazelcast/config/ConfigCompatibilityChecker.java:1513
↓ 32 callers
Method
classNameOrImplClass
(String className, Object impl)
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/DynamicConfigXmlGenerator.java:879
↓ 32 callers
Method
createFile
(String path)
hazelcast/src/test/java/com/hazelcast/jet/config/ResourceConfigTest.java:986
↓ 32 callers
Method
decodeResponse
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/PNCounterAddCodec.java:160
↓ 32 callers
Method
exec
(int index)
hazelcast/src/test/java/com/hazelcast/splitbrainprotection/scheduledexecutor/ScheduledExecutorSplitBrainProtectionWriteTest.java:283
↓ 32 callers
Method
executeBatch
(String... sqlCommands)
extensions/cdc-postgres/src/test/java/com/hazelcast/jet/cdc/postgres/AbstractPostgresCdcIntegrationTest.java:77
↓ 32 callers
Method
get
(@Nonnull String fieldName, FieldType fieldType)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/portable/DeserializedPortableGenericRecord.java:426
↓ 32 callers
Method
getAttributeConfigs
()
hazelcast/src/main/java/com/hazelcast/config/MapConfig.java:591
↓ 32 callers
Method
getCollectionFrequencySeconds
Returns the metrics collection frequency in seconds.
hazelcast/src/main/java/com/hazelcast/config/BaseMetricsConfig.java:110
↓ 32 callers
Method
getIMapWithDefaultConfig
(Predicate predicate)
hazelcast/src/test/java/com/hazelcast/map/impl/querycache/AbstractQueryCacheTestSupport.java:61
↓ 32 callers
Method
getMap
()
hazelcast/src/main/java/com/hazelcast/client/console/ClientConsoleApp.java:174
↓ 32 callers
Method
getMemberListVersion
Returns the current version of member list. @return current version of member list
hazelcast/src/main/java/com/hazelcast/internal/cluster/ClusterService.java:185
↓ 32 callers
Method
getNamedItemNode
(final Node node, String attrName)
hazelcast/src/main/java/com/hazelcast/client/config/impl/AbstractQueryCacheConfigBuilderHelper.java:165
↓ 32 callers
Method
getNearCacheConfig
Gets the {@link NearCacheConfig} configured for the map / cache with name @param name name of the map / cache @return Configured {@link NearCacheConf
hazelcast/src/main/java/com/hazelcast/client/config/ClientConfig.java:423
↓ 32 callers
Method
getSerializationConfig
Gets {@link com.hazelcast.config.SerializationConfig} @return SerializationConfig @see com.hazelcast.config.SerializationConfig
hazelcast/src/main/java/com/hazelcast/client/config/ClientConfig.java:735
↓ 32 callers
Method
getServiceName
@return - name of the corresponding client service
hazelcast/src/main/java/com/hazelcast/client/impl/spi/ClientProxyDescriptor.java:36
↓ 32 callers
Method
getStore
()
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/MapStoreTest.java:1301
↓ 32 callers
Method
getTotalRemoveLatency
Returns the total latency of remove operations. To get the average latency, divide by the number of gets @return the total latency of remove operatio
hazelcast/src/main/java/com/hazelcast/map/LocalMapStats.java:207
↓ 32 callers
Method
getValue
Returns a value this iterator is currently at. If this iterator is already reached its end, the return value is undefined. <p> Just after the creation
hazelcast/src/main/java/com/hazelcast/query/impl/bitmap/SparseArray.java:44
↓ 32 callers
Method
lessEqual
(Comparable value)
hazelcast/src/main/java/com/hazelcast/query/PredicateBuilder.java:63
↓ 32 callers
Method
madeProgress
Lets this progress tracker know whether some pipeline made progress.
hazelcast/src/main/java/com/hazelcast/jet/impl/util/ProgressTracker.java:44
↓ 32 callers
Method
makeCost
(double rowCount, double cpu, double io)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/cost/CostFactory.java:32
↓ 32 callers
Method
newValue
()
hazelcast/src/test/java/com/hazelcast/internal/util/collection/Long2LongMapHsaTest.java:447
↓ 32 callers
Method
populateMap
(IMap<Integer, Integer> map)
hazelcast/src/test/java/com/hazelcast/map/impl/querycache/QueryCacheMemoryLeakTest.java:299
↓ 32 callers
Method
queue
Retrieves the queue backing the inbox.
hazelcast/src/main/java/com/hazelcast/jet/core/test/TestInbox.java:72
↓ 32 callers
Method
remove
Removes the given member from this storage. @param member the member to remove. @return {@code true} if this storage became empty as a result of the
hazelcast/src/main/java/com/hazelcast/query/impl/bitmap/SparseBitSet.java:189
↓ 32 callers
Method
response
(ResponseType type, String... attributes)
hazelcast/src/main/java/com/hazelcast/internal/ascii/rest/HttpCommandProcessor.java:259
↓ 32 callers
Method
setIfConfigured
(Properties props, String propertyName, String value)
hazelcast/src/main/java/com/hazelcast/config/security/AbstractClusterLoginConfig.java:80
↓ 32 callers
Method
setOrClearProperty
(String value)
hazelcast/src/test/java/com/hazelcast/test/OverridePropertyRule.java:80
↓ 32 callers
Method
setReader
Sets the AsyncSocketReader. @param reader the AsyncSocketReader. @return this @throws NullPointerException if reader is null. @throws IllegalStateEx
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/net/AsyncSocketBuilder.java:76
↓ 32 callers
Method
shuffle
(PartitionReplica[] array, int len)
hazelcast/src/test/java/com/hazelcast/internal/partition/impl/MigrationPlannerTest.java:602
↓ 32 callers
Method
size
()
hazelcast/src/main/java/com/hazelcast/spi/partitiongroup/MemberGroup.java:39
↓ 32 callers
Method
test
(int threadCount, int payloadSize)
hazelcast-tpc-engine/src/test/java/com/hazelcast/internal/tpcengine/net/AsyncSocket_RpcTest.java:251
↓ 32 callers
Method
testTemplate
(TestCase<?> testCase)
hazelcast/src/test/java/com/hazelcast/internal/dynamicconfig/ConfigSearchTest.java:62
↓ 32 callers
Method
timestamp
If provided value greater than zero, then it sets the event timestamp explicitly. Otherwise, the timestamp is filled by calling {@link #build()} metho
hazelcast/src/main/java/com/hazelcast/auditlog/EventBuilder.java:71
↓ 32 callers
Method
verify
()
hazelcast/src/test/java/com/hazelcast/query/impl/bitmap/SparseArrayTest.java:295
↓ 32 callers
Method
verifySerializationServiceBuilds
(SerializationConfig serializationConfig)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/CompactTestUtil.java:314
↓ 32 callers
Method
waitWithDeadline
(Collection<? extends Future> futures, long timeout, TimeUnit timeUnit)
hazelcast/src/main/java/com/hazelcast/internal/util/FutureUtil.java:272
↓ 31 callers
Method
add
(Data key, ExpiryMetadata expiryMetadata, long now)
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/expiry/ExpirySystem.java:74
↓ 31 callers
Method
addIndex
(IMap map, String attribute, boolean ordered)
hazelcast/src/test/java/com/hazelcast/map/LocalIndexStatsTest.java:717
↓ 31 callers
Method
addLongField
@param fieldName name of the field that will be added to this class definition @return itself for chaining @throws HazelcastSerializationException if
hazelcast/src/main/java/com/hazelcast/nio/serialization/ClassDefinitionBuilder.java:90
↓ 31 callers
Method
address
()
hazelcast/src/main/java/com/hazelcast/internal/partition/PartitionReplica.java:61
↓ 31 callers
Method
asTimestamp
(Object val)
hazelcast-sql/src/test/java/com/hazelcast/sql/impl/type/converter/ConvertersTest.java:1189
↓ 31 callers
Method
assertCompare
(Comparable<?> lhs, Comparable<?> rhs, int expected)
hazelcast/src/test/java/com/hazelcast/query/impl/NumbersTest.java:182
↓ 31 callers
Method
assertEntryStore
(String key, String value)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/EntryStoreSimpleTest.java:447
↓ 31 callers
Method
begin
()
hazelcast/src/main/java/com/hazelcast/transaction/impl/TransactionImpl.java:206
↓ 31 callers
Method
cancelAndJoin
Cancel the job and wait until it cancels using {@link Job#join()}, ignoring the {@link CancellationException}.
hazelcast/src/test/java/com/hazelcast/jet/core/JetTestSupport.java:451
↓ 31 callers
Method
check
( String operand1, String operand2, Integer expectedRes, Objec
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/predicate/ComparisonPredicateIntegrationTest.java:671
↓ 31 callers
Method
clear
()
hazelcast/src/main/java/com/hazelcast/internal/util/collection/LongSet.java:34
↓ 31 callers
Method
compareTo
(ComparableImpl that)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/predicate/ComparisonPredicateIntegrationTest.java:783
↓ 31 callers
Method
create
( Expression<?> operand1, Expression<?> operand2, QueryDataType resultType, bo
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/expression/math/RoundTruncateFunction.java:51
↓ 31 callers
Method
create
()
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/writebehind/TestMapUsingMapStoreBuilder.java:61
↓ 31 callers
Method
createMap
(String mapName)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/kafka/KafkaIntegrationSqlTest.java:90
↓ 31 callers
Method
debug
(String text)
hazelcast/src/test/java/com/hazelcast/test/starter/HazelcastStarterUtils.java:59
↓ 31 callers
Method
encodeRequest
(java.lang.String name, com.hazelcast.internal.serialization.Data key, com.hazelcast.internal.serialization.Da
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/MapPutCodec.java:92
↓ 31 callers
Method
encodeRequest
(java.lang.String name, com.hazelcast.internal.serialization.Data key, long threadId)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/MapGetCodec.java:79
↓ 31 callers
Method
encodeRequest
(java.lang.String clusterName, @Nullable java.lang.String username, @Nullable java.lang.String password, @Null
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ClientAuthenticationCodec.java:143
↓ 31 callers
Method
ensureOpen
()
hazelcast/src/main/java/com/hazelcast/client/cache/impl/ClientCacheProxySupport.java:273
↓ 31 callers
Method
equals
(Object o)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/kafka/KafkaTable.java:153
↓ 31 callers
Method
externalName
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/jdbc/JdbcTableField.java:35
↓ 31 callers
Method
field
(String name, QueryDataType type, String externalName)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/map/MetadataCompactResolverTest.java:235
↓ 31 callers
Method
finger
(String name)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/extractor/ComplexTestDataStructure.java:151
↓ 31 callers
Method
getClientImpl
()
hazelcast/src/test/java/com/hazelcast/client/impl/management/MCMessageTasksTest.java:531
↓ 31 callers
Method
getClusterState
@return the current node state (status)
hazelcast/src/main/java/com/hazelcast/internal/monitor/NodeState.java:32
↓ 31 callers
Method
getDirectory
()
hazelcast/src/main/java/com/hazelcast/config/NearCachePreloaderConfig.java:88
↓ 31 callers
Method
getFunctionImplementation
()
hazelcast/src/main/java/com/hazelcast/config/SplitBrainProtectionConfig.java:174
↓ 31 callers
Method
getHeapCost
Cost of map & Near Cache & backup & Merkle trees in bytes <p> When {@link com.hazelcast.config.InMemoryFormat#OBJECT} is used, the heap co
hazelcast/src/main/java/com/hazelcast/map/LocalMapStats.java:265
↓ 31 callers
Method
getKey
Gets the key of the cache entry. @return the key of the cache entry
hazelcast/src/main/java/com/hazelcast/cache/CacheEntryView.java:34
↓ 31 callers
Method
getLogger
(String name)
hazelcast/src/main/java/com/hazelcast/spi/impl/NodeEngineImpl.java:470
↓ 31 callers
Method
getLogger
(Class clazz)
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/MapStoreContext.java:50
↓ 31 callers
Method
getMember
Gets the member with the given UUID. @param uuid The UUID of the member. @return The member that was found, or null if not found. If UUID is null, nu
hazelcast/src/main/java/com/hazelcast/client/impl/spi/ClientClusterService.java:48
↓ 31 callers
Method
getMultiMapConfig
Returns the MultiMapConfig for the given name, creating one if necessary and adding it to the collection of known configurations. <p> The configuratio
hazelcast/src/main/java/com/hazelcast/config/Config.java:1321
↓ 31 callers
Method
getNodeHash
(int nodeOrder)
hazelcast/src/main/java/com/hazelcast/wan/impl/merkletree/ArrayMerkleTree.java:147
↓ 31 callers
Method
getOrCreateIndexRegistry
Used to get index registry of one of global or partitioned indexes. @return by default always returns global-index registry otherwise return partitio
hazelcast/src/main/java/com/hazelcast/map/impl/MapContainer.java:74
↓ 31 callers
Method
getPortableContext
()
hazelcast/src/main/java/com/hazelcast/internal/serialization/InternalSerializationService.java:160
↓ 31 callers
Method
getResult
()
hazelcast/src/main/java/com/hazelcast/map/impl/operation/steps/engine/State.java:330
↓ 31 callers
Method
getResults
()
hazelcast/src/test/java/com/hazelcast/executor/ExecutorServiceTestSupport.java:513
↓ 31 callers
Method
getValidator
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/validate/HazelcastCallBinding.java:47
↓ 31 callers
Method
invokeAll
(Set<? extends K> keys, EntryProcessor<K, V, T> entryProcessor,
hazelcast/src/main/java/com/hazelcast/internal/adapter/DataStructureAdapter.java:132
↓ 31 callers
Method
isEmpty
Checks if the queue is empty. @return true when empty
hazelcast/src/main/java/com/hazelcast/spi/impl/operationexecutor/impl/OperationQueue.java:107
↓ 31 callers
Method
isNullOrEmpty
Checks if a string is empty or not. @param s the string to check. @return true if the string is {@code null} or empty, false otherwise
hazelcast/src/main/java/com/hazelcast/internal/util/StringUtil.java:73
↓ 31 callers
Method
needsToWait
()
hazelcast/src/main/java/com/hazelcast/jet/retry/impl/RetryTracker.java:51
↓ 31 callers
Method
newMembers
(int count)
hazelcast/src/test/java/com/hazelcast/internal/cluster/impl/MemberMapTest.java:374
↓ 31 callers
Method
nextLong
Non-boxing variant of next().
hazelcast/src/main/java/com/hazelcast/internal/util/collection/Long2ObjectHashMap.java:553
↓ 31 callers
Method
readStringArray
@return String array read @throws IOException if it reaches end of file before finish reading
hazelcast/src/main/java/com/hazelcast/nio/ObjectDataInput.java:113
↓ 31 callers
Method
setProperty
(String key, String value)
hazelcast/src/test/java/com/hazelcast/test/HazelcastParallelClassRunner.java:216
↓ 31 callers
Method
setVersion
If the serializer supports versioning it may set the version to use for the serialization on this object. @param version version to set
hazelcast/src/main/java/com/hazelcast/nio/VersionAware.java:42
↓ 31 callers
Method
stats
(IMap<?, ?> map)
hazelcast/src/test/java/com/hazelcast/map/IndexStatsChangingNumberOfMembersTest.java:396
↓ 31 callers
Method
testInstance
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/type/BasicNestedFieldsTest.java:79
↓ 31 callers
Method
toData
(Object item)
hazelcast/src/test/java/com/hazelcast/ringbuffer/impl/RingbufferContainerTest.java:64
↓ 31 callers
Method
toLogicalConvention
Convert the given trait set to logical convention. @param traitSet Original trait set. @return New trait set with logical convention.
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/OptUtils.java:99
↓ 31 callers
Method
uuid
(UUID uuid)
hazelcast/src/main/java/com/hazelcast/cluster/impl/MemberImpl.java:187
↓ 31 callers
Method
withMapStore
(MapStore<K, V> mapStore)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/writebehind/TestMapUsingMapStoreBuilder.java:119
↓ 31 callers
Method
withNodeFactory
(TestHazelcastInstanceFactory factory)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/writebehind/TestMapUsingMapStoreBuilder.java:81
↓ 31 callers
Method
writeIntArray
@param ints int array to be written @throws IOException in case of any exceptional case
hazelcast/src/main/java/com/hazelcast/nio/ObjectDataOutput.java:64
↓ 30 callers
Method
accept
Return {{@code true}} when object matches a condition @return {{true}} when object matches a condition
hazelcast/src/main/java/com/hazelcast/internal/util/filter/Filter.java:31
↓ 30 callers
Method
addDataConnectionConfig
Adds a data connection configuration. <p> <p> Example: <pre>{@code Config config = new Config(); Properties properties = new Properties();
hazelcast/src/main/java/com/hazelcast/config/Config.java:3222
← previous
next →
1,701–1,800 of 147,315, ranked by callers