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
↓ 12 callers
Method
setOffload
Default value is {@value #DEFAULT_OFFLOAD}. <p> {@link MapStore} interaction can be slow compared to in-memory processing of data, to make partition t
hazelcast/src/main/java/com/hazelcast/config/MapStoreConfig.java:225
↓ 12 callers
Method
setPartData
(byte[] partData)
hazelcast/src/main/java/com/hazelcast/jet/impl/submitjob/memberside/JobMultiPartParameterObject.java:66
↓ 12 callers
Method
setPartSize
(int partSize)
hazelcast/src/main/java/com/hazelcast/jet/impl/submitjob/memberside/JobMultiPartParameterObject.java:74
↓ 12 callers
Method
setPopulate
Set {@code true} to enable initial population, otherwise set {@code false}. <p> Default value is {@value #DEFAULT_POPULATE}. @param populate set {@co
hazelcast/src/main/java/com/hazelcast/config/QueryCacheConfig.java:339
↓ 12 callers
Method
setPortableVersion
(int portableVersion)
hazelcast/src/main/java/com/hazelcast/internal/serialization/SerializationServiceBuilder.java:37
↓ 12 callers
Method
setQueueSize
Sets the capacity of processor-to-processor concurrent queues. The value is rounded upwards to the next power of 2. <p> When data needs to travel betw
hazelcast/src/main/java/com/hazelcast/jet/config/EdgeConfig.java:73
↓ 12 callers
Method
setSSLConfig
Sets the {@link SSLConfig}. null value indicates that no SSLConfig should be used. @param sslConfig the SSLConfig @return the updated NetworkConfig @
hazelcast/src/main/java/com/hazelcast/config/NetworkConfig.java:354
↓ 12 callers
Method
setStatus
(MigrationStatus status)
hazelcast/src/main/java/com/hazelcast/internal/partition/MigrationInfo.java:148
↓ 12 callers
Method
setTime
Sets a time field consisting of hour, minute, seconds, and nanos parts. <p> It is legal to set the field again only when Builder is created with {@lin
hazelcast/src/main/java/com/hazelcast/nio/serialization/genericrecord/GenericRecordBuilder.java:584
↓ 12 callers
Method
setTotalPartNumber
(int totalPartNumber)
hazelcast/src/main/java/com/hazelcast/jet/impl/submitjob/memberside/JobMultiPartParameterObject.java:58
↓ 12 callers
Method
setTryCount
Sets the try count; the number of times this operation can be retried. @param tryCount the try count; the number of times this operation can be retri
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/InvocationBuilder.java:145
↓ 12 callers
Method
setUsernamePasswordIdentityConfig
(UsernamePasswordIdentityConfig identityConfig)
hazelcast/src/main/java/com/hazelcast/config/security/RealmConfig.java:91
↓ 12 callers
Method
setWriteCoalescing
()
hazelcast/src/test/java/com/hazelcast/config/MapStoreConfigTest.java:207
↓ 12 callers
Method
setWriteThrough
Set if write-through caching should be used. <p> It is an invalid configuration to set this to {@code true} without specifying a {@link javax.cache.in
hazelcast/src/main/java/com/hazelcast/config/CacheConfiguration.java:120
↓ 12 callers
Method
shutdown
Shutdowns the Server completely. Connections and the networking engine will not be operational anymore and cannot be restarted. <p> This method has no
hazelcast/src/main/java/com/hazelcast/internal/server/Server.java:135
↓ 12 callers
Method
shutdownNodeFactory
()
hazelcast/src/test/java/com/hazelcast/test/HazelcastTestSupport.java:177
↓ 12 callers
Method
sinkStreamOfKeyedWinResult
()
hazelcast/src/test/java/com/hazelcast/jet/pipeline/PipelineStreamTestSupport.java:81
↓ 12 callers
Method
start
()
hazelcast/src/main/java/com/hazelcast/client/impl/spi/impl/ClientUserCodeDeploymentService.java:63
↓ 12 callers
Method
startInstance
()
hazelcast/src/test/java/com/hazelcast/wan/WanRESTTest.java:181
↓ 12 callers
Method
startJob
(HazelcastInstance hz, DAG dag, JobConfig config)
hazelcast/src/test/java/com/hazelcast/jet/core/SplitBrainTest.java:431
↓ 12 callers
Method
sumValueFor
(JobMetrics metrics, String vertex, String metric)
hazelcast/src/test/java/com/hazelcast/jet/core/metrics/JobMetrics_StreamTest.java:355
↓ 12 callers
Method
tag
()
hazelcast/src/test/java/com/hazelcast/azure/TagTest.java:25
↓ 12 callers
Method
takeWriteLock
()
hazelcast/src/main/java/com/hazelcast/query/impl/BaseIndexStore.java:70
↓ 12 callers
Method
test
(StreamSource<ChangeRecord> source, List<String> expectedRecords, int expectedInitialOps)
extensions/cdc-mysql/src/test/java/com/hazelcast/jet/cdc/mysql/MySqlCdcWhiteBlackListIntegrationTest.java:232
↓ 12 callers
Method
test
(StreamSource<ChangeRecord> source, List<String> expectedRecords, int expectedInitialOps)
extensions/cdc-postgres/src/test/java/com/hazelcast/jet/cdc/postgres/PostgresCdcWhiteBlackListIntegrationTest.java:233
↓ 12 callers
Method
test
(Set<Integer> keySet, boolean update, EntryProcessor entryProcessor, boolean expectShift
hazelcast/src/test/java/com/hazelcast/map/EntryProcessorExpiryTimeTest.java:162
↓ 12 callers
Method
toAdapter
(HazelcastJsonValue jsonValue)
hazelcast/src/test/java/com/hazelcast/json/internal/AbstractJsonSchemaTest.java:55
↓ 12 callers
Method
toArray
()
extensions/avro/src/main/java/com/hazelcast/jet/avro/impl/AvroSerializerHooks.java:310
↓ 12 callers
Method
toKey
(int i)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/offload/MapStoreOffloadingBouncingNodeTest.java:316
↓ 12 callers
Method
toStorageIndex
(long addr)
hazelcast/src/test/java/com/hazelcast/internal/memory/impl/HeapMemoryManager.java:157
↓ 12 callers
Method
tryLock
Acquires the lock if it is available or already held by the current thread at the time of invocation & the acquire limit is not exceeded, and imme
hazelcast/src/main/java/com/hazelcast/cp/lock/FencedLock.java:335
↓ 12 callers
Method
tryLock
Tries to acquire the lock for the specified key. <p> If the lock is not available, then the current thread does not wait and the method returns false
hazelcast/src/main/java/com/hazelcast/multimap/MultiMap.java:462
↓ 12 callers
Method
tumblingWinPolicy
Returns the definition of a tumbling window of length {@code windowSize}. The tumbling window is a special case of the sliding window with {@code slid
hazelcast/src/main/java/com/hazelcast/jet/core/SlidingWindowPolicy.java:176
↓ 12 callers
Method
unit
Returns the unit of the metric denoted by this instance. @return the unit
hazelcast/src/main/java/com/hazelcast/internal/metrics/MetricDescriptor.java:112
↓ 12 callers
Method
unlock
(Data key, UUID caller, long threadId, long referenceId)
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/RecordStore.java:389
↓ 12 callers
Method
upstream
()
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/transform/Transform.java:63
↓ 12 callers
Method
using
Applies extension to this stage in a fluent way. <pre>{@code srcStage.using(IMapExtension.iMapExtension()) // additional methods available he
hazelcast/src/main/java/com/hazelcast/jet/pipeline/BatchStage.java:692
↓ 12 callers
Method
valueOf
(int ordinal)
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/MetricsCompressor.java:478
↓ 12 callers
Method
verifyNotAndThenClear
()
hazelcast/src/test/java/com/hazelcast/query/impl/bitmap/BitmapAlgorithmsTest.java:255
↓ 12 callers
Method
verifyOr
()
hazelcast/src/test/java/com/hazelcast/query/impl/bitmap/BitmapAlgorithmsTest.java:232
↓ 12 callers
Method
waitAfterAttempt
Returns the wait time required before the specified attempt. In this context attempt no. 1 means the first attempt, so it's not an index and zero is n
hazelcast/src/main/java/com/hazelcast/jet/retry/IntervalFunction.java:69
↓ 12 callers
Method
waitForFirstSnapshot
(JobRepository jr, long jobId, int timeoutSeconds, boolean allowEmptySnapshot)
hazelcast/src/test/java/com/hazelcast/jet/core/JetTestSupport.java:301
↓ 12 callers
Method
withDatabaseName
(String databaseName)
extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/impl/DbCheckingPMetaSupplierBuilder.java:44
↓ 12 callers
Method
withEndpoint
(@Nullable String endpoint)
extensions/kinesis/src/main/java/com/hazelcast/jet/kinesis/impl/AwsConfig.java:52
↓ 12 callers
Method
withIdentityFinish
Returns a copy of this aggregate operation, but with the {@code finish} primitive replaced with the identity function. It will return the accumulator
hazelcast/src/main/java/com/hazelcast/jet/aggregate/AggregateOperation.java:281
↓ 12 callers
Method
withRegion
(@Nullable String region)
extensions/kinesis/src/main/java/com/hazelcast/jet/kinesis/impl/AwsConfig.java:62
↓ 12 callers
Method
wrapDataConnectionKey
(String dataConnectionKey)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/QueryUtils.java:70
↓ 11 callers
Method
add
Adds an task to this queue. This method is thread safe. @param task the item to add @param priority if the task has priority or not @throws java
hazelcast/src/main/java/com/hazelcast/spi/impl/operationexecutor/impl/OperationQueue.java:44
↓ 11 callers
Method
add
Convenience for {@code inbox.queue().add(o)}
hazelcast/src/main/java/com/hazelcast/jet/core/test/TestInbox.java:79
↓ 11 callers
Method
addByteField
@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:136
↓ 11 callers
Method
addClamped
(long a, long b)
hazelcast/src/main/java/com/hazelcast/jet/impl/util/Util.java:202
↓ 11 callers
Method
addCustomClasspath
Adds custom classpath element to a stage with the given name. <pre>{@code BatchSource<String> source = ... JobConfig config = new JobConfig(); config
hazelcast/src/main/java/com/hazelcast/jet/config/JobConfig.java:659
↓ 11 callers
Method
addDirectoryConfig
Adds the persistent memory directory configuration to be used to store memory structures allocated by native memory manager. <p/> If the specified dir
hazelcast/src/main/java/com/hazelcast/config/PersistentMemoryConfig.java:144
↓ 11 callers
Method
addFlakeIdGeneratorConfig
Adds a flake ID generator configuration. The configuration is saved under the config name, which may be a pattern with which the configuration will be
hazelcast/src/main/java/com/hazelcast/config/Config.java:2579
↓ 11 callers
Method
addJar
String jarPath is searched in following order: 1. as absolute path, 2. as URL, 3. and in classpath. @param jarPath path of the jar that will be sent
hazelcast/src/main/java/com/hazelcast/client/config/ClientUserCodeDeploymentConfig.java:138
↓ 11 callers
Method
addOrIncrementIndexInName
If the name ends with "-N", returns a new name where "-N" is replaced with "-M" where M = N + 1. If N is too large for {@code int}, negative, unparsea
hazelcast/src/main/java/com/hazelcast/jet/impl/util/Util.java:564
↓ 11 callers
Method
addSetConfig
Adds the set configuration. The configuration is saved under the config name, which may be a pattern with which the configuration will be obtained in
hazelcast/src/main/java/com/hazelcast/config/Config.java:1233
↓ 11 callers
Method
addWanReplicationConfig
Adds a new {@link WanReplicationConfig} to the cluster. This method can also accept WAN configs with an existing WAN replication name. Such configs wi
hazelcast/src/main/java/com/hazelcast/wan/impl/WanReplicationService.java:229
↓ 11 callers
Method
allocate
()
hazelcast/src/test/java/com/hazelcast/internal/util/collection/HsaHeapMemoryManagerTest.java:152
↓ 11 callers
Method
analyzeJobConfig
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/SqlPlanImpl.java:1229
↓ 11 callers
Method
and
Performs AND for the given operands acting on the given row in the given context. <p> The method exhibits a short-circuiting behaviour: there is no gu
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/expression/predicate/TernaryLogic.java:50
↓ 11 callers
Method
applyConfig
Applies the given config. @param configDTO configuration object
hazelcast/src/main/java/com/hazelcast/internal/management/ClientBwListConfigHandler.java:50
↓ 11 callers
Method
asCompletableFuture
(Future<V> future)
hazelcast/src/main/java/com/hazelcast/spi/impl/executionservice/ExecutionService.java:170
↓ 11 callers
Method
asInt
()
hazelcast/src/test/java/com/hazelcast/internal/json/JsonNumber_Test.java:74
↓ 11 callers
Method
assertCommitNotCalled
()
hazelcast/src/test/java/com/hazelcast/transaction/impl/MockTransactionLogRecord.java:118
↓ 11 callers
Method
assertContains
(Object state, Thread waiter, boolean contains)
hazelcast/src/test/java/com/hazelcast/spi/impl/AbstractInvocationFuture_GetWithTimeoutTest.java:213
↓ 11 callers
Method
assertContainsSensor
(String parameter)
hazelcast/src/test/java/com/hazelcast/internal/metrics/metricsets/OperatingSystemMetricSetTest.java:95
↓ 11 callers
Method
assertEntries
(Entry<Integer, Integer>... entries)
hazelcast/src/test/java/com/hazelcast/internal/util/collection/ReadOptimizedLruCacheTest.java:107
↓ 11 callers
Method
assertIndex
(IMap<Integer, HazelcastJsonValue> map, int targetCount, Comparable comparable, String attributeName)
hazelcast/src/test/java/com/hazelcast/json/MapIndexJsonTest.java:208
↓ 11 callers
Method
assertItemsInOrder
(WeightedEvictableList<String> weightedList, T... values)
hazelcast/src/test/java/com/hazelcast/internal/util/collection/WeightedEvictableListTest.java:149
↓ 11 callers
Method
assertJobFailed
( FileSourceBuilder<?> source, Class<? extends Throwable> expectedRootException,
extensions/hadoop/src/test/java/com/hazelcast/jet/hadoop/file/BaseFileFormatTest.java:96
↓ 11 callers
Method
assertNearCacheStats
Asserts the {@link NearCacheStats} for expected values. @param context the {@link NearCacheTestContext} to retrieve the stats from @p
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/NearCacheTestUtils.java:483
↓ 11 callers
Method
assertNewLastUpdateTime
()
hazelcast/src/test/java/com/hazelcast/collection/impl/AbstractCollectionStatisticsTest.java:48
↓ 11 callers
Method
assertResult
(List<Integer> expected, Iterator<IndexKeyEntries> actual)
hazelcast/src/test/java/com/hazelcast/query/impl/OrderedIndexStoreTest.java:180
↓ 11 callers
Method
assertResultContains
(Set<Map.Entry<String, String>> result, String key, String value)
hazelcast/src/test/java/com/hazelcast/map/impl/query/MapEntrySetTest.java:198
↓ 11 callers
Method
assertResultSorted
(MapFetchIndexOperationResult result, List<Person> orderedPeopleList)
hazelcast/src/test/java/com/hazelcast/map/impl/operation/MapFetchIndexOperationTest.java:553
↓ 11 callers
Method
assertSuccessJson
(ConnectionResponse resp, String... attributesAndValues)
hazelcast/src/test/java/com/hazelcast/internal/ascii/RestClusterTest.java:568
↓ 11 callers
Method
assertValid
()
hazelcast/src/main/java/com/hazelcast/internal/util/hashslot/impl/HashSlotArrayBase.java:339
↓ 11 callers
Method
assertWithCause
(CompletableFuture<?> future)
hazelcast/src/test/java/com/hazelcast/spi/impl/DelegatingCompletableFuture_SerializationExceptionTest.java:275
↓ 11 callers
Method
assertXsdVersion
(String buildVersion, String expectedXsdVersion)
hazelcast/src/test/java/com/hazelcast/config/XmlOnlyConfigBuilderTest.java:235
↓ 11 callers
Method
assignWatermarkKeys
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/WatermarkKeysAssigner.java:63
↓ 11 callers
Method
assumeThatMethodIsAvailable
Assumes that the {@link DataStructureAdapter} created by the Near Cache test supports a given {@link DataStructureAdapterMethod}. @param method the {
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/AbstractNearCacheBasicTest.java:138
↓ 11 callers
Method
asyncBackups
(int requestedSyncBackups, int requestedAsyncBackups, boolean syncForced)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/OperationBackupHandler.java:126
↓ 11 callers
Method
attributes
(Map<String, String> attributes)
hazelcast/src/main/java/com/hazelcast/cluster/impl/MemberImpl.java:192
↓ 11 callers
Method
beforeRemoteCall
(Object key, Data keyData, Object value, Data valueData)
hazelcast/src/main/java/com/hazelcast/internal/nearcache/impl/RemoteCallHook.java:35
↓ 11 callers
Method
bigDecimalAvg
@param <I> type of the input object. @return an aggregator that calculates the average of the input values. Does NOT accept null input values. Accepts
hazelcast/src/main/java/com/hazelcast/aggregation/Aggregators.java:127
↓ 11 callers
Method
blockMessagesFromInstance
Blocks incoming messages to client from given instance
hazelcast/src/test/java/com/hazelcast/client/test/ClientTestSupport.java:45
↓ 11 callers
Method
boundsCheck
Bounds check when copying to/from a buffer @param capacity capacity of the buffer @param index index of copying will start from/to @param length
hazelcast/src/main/java/com/hazelcast/internal/util/collection/ArrayUtils.java:152
↓ 11 callers
Method
bsonToDocument
Converts given {@link Bson} to {@link Document}.
extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/impl/Mappers.java:109
↓ 11 callers
Method
build
Builds the schema from the written fields and returns it.
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/compact/SchemaWriter.java:52
↓ 11 callers
Method
byteBuffer
()
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/iobuffer/IOBuffer.java:84
↓ 11 callers
Method
calculate
(PhysicalRel rel, ExpressionEvalContext evalContext)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/WatermarkThrottlingFrameSizeCalculator.java:36
↓ 11 callers
Method
callListeners
(Consumer<ClientConnectionProcessListener> consumer)
hazelcast/src/main/java/com/hazelcast/client/impl/management/ClientConnectionProcessListenerRegistry.java:192
↓ 11 callers
Method
callsBeforeDone
(int count)
hazelcast/src/test/java/com/hazelcast/jet/impl/execution/TaskletExecutionServiceTest.java:476
↓ 11 callers
Method
checkParameter
(Object parameterValue, Object expectedValue)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/datetime/ToTimestampTzIntegrationTest.java:159
↓ 11 callers
Method
checkSelectWithOrderBy
(List<String> indexAttrs, List<String> orderFields, List<Boolean> orderDirections)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlOrderByTest.java:842
↓ 11 callers
Method
childAsScalarValue
Gets a child scalar node's value by its name <p> See {@link YamlScalar} for the possible types <p> Please note that if the scalar's type is not the ex
hazelcast/src/main/java/com/hazelcast/internal/yaml/YamlMapping.java:89
↓ 11 callers
Method
children
Returns the children nodes @return the children nodes
hazelcast/src/main/java/com/hazelcast/internal/yaml/YamlCollection.java:29
↓ 11 callers
Method
cleanup
Cleans up the event journal by removing any expired items. Items are considered expired according to the configured expiration policy. @param namespa
hazelcast/src/main/java/com/hazelcast/internal/journal/EventJournal.java:157
↓ 11 callers
Method
clear
Clears the multimap. Removes all key-value pairs.
hazelcast/src/main/java/com/hazelcast/multimap/MultiMap.java:288
← previous
next →
6,101–6,200 of 147,315, ranked by callers