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
↓ 10 callers
Method
createKafkaDataConnection
(KafkaTestSupport kafkaTestSupport)
extensions/kafka/src/test/java/com/hazelcast/jet/kafka/KafkaDataConnectionTest.java:232
↓ 10 callers
Method
createManagedNearCacheRecordStore
( Map<Integer, String> expectedKeyValueMappings)
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/NearCacheTestSupport.java:80
↓ 10 callers
Method
createMapWithMaxIdleSeconds
(int maxIdleSeconds)
hazelcast/src/test/java/com/hazelcast/map/ExpirationTimeTest.java:693
↓ 10 callers
Method
createNearCache
(String name, NearCacheConfig nearCacheConfig,
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/NearCacheTestSupport.java:65
↓ 10 callers
Method
createNodes
()
hazelcast/src/test/java/com/hazelcast/client/listeners/leak/ListenerLeakTest.java:96
↓ 10 callers
Method
createOperation
(String host, int port, long callId)
hazelcast/src/test/java/com/hazelcast/internal/metrics/impl/LiveOperationRegistryTest.java:104
↓ 10 callers
Method
createOperation
(String host, int port, long callId)
hazelcast/src/test/java/com/hazelcast/jet/impl/LiveOperationRegistryTest.java:104
↓ 10 callers
Method
createQueue
(SqsClient sqsClient)
extensions/kafka-connect/src/test/java/com/hazelcast/jet/kafka/connect/KafkaConnectSQSIT.java:173
↓ 10 callers
Method
createScheduledFutureMock
()
hazelcast/src/test/java/com/hazelcast/scheduledexecutor/impl/DelegatingScheduledFutureStripperTest.java:199
↓ 10 callers
Method
createSerializationService
()
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/CompactWithSchemaStreamSerializerTest.java:137
↓ 10 callers
Method
createSerializationService
(int version)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/portable/PortableTest.java:124
↓ 10 callers
Method
createTasklet
()
hazelcast/src/test/java/com/hazelcast/jet/impl/execution/ProcessorTaskletTest.java:267
↓ 10 callers
Method
createTranslateProvider
()
hazelcast/src/test/java/com/hazelcast/client/impl/spi/impl/TranslateToPublicAddressProviderTest.java:216
↓ 10 callers
Method
createType
(String name, String... fields)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/type/BasicNestedFieldsTest.java:98
↓ 10 callers
Method
createWithPartitionCount
(int partitionCount, int... partitions)
hazelcast/src/test/java/com/hazelcast/internal/util/collection/PartitionIdSetTest.java:314
↓ 10 callers
Method
createWithSSL
(String url, String caCertificate)
hazelcast/src/main/java/com/hazelcast/spi/utils/RestClient.java:129
↓ 10 callers
Method
dataConnectionService
A service to access {@link DataConnection}s in processors. @since 5.3
hazelcast/src/main/java/com/hazelcast/jet/core/ProcessorMetaSupplier.java:928
↓ 10 callers
Method
date
(long epochMillis)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlTestSupport.java:758
↓ 10 callers
Method
decode
(ClientMessage.ForwardFrameIterator iterator)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/EntryListIntegerIntegerCodec.java:51
↓ 10 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/JetUploadJobMetaDataCodec.java:122
↓ 10 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/JetAddJobStatusListenerCodec.java:103
↓ 10 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/JetUpdateJobConfigCodec.java:84
↓ 10 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/JetIsJobUserCancelledCodec.java:74
↓ 10 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/JetUploadJobMultipartCodec.java:112
↓ 10 callers
Method
decodeResponse
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ReplicatedMapFetchEntryViewsCodec.java:149
↓ 10 callers
Method
deregisterListener
Deregisters a listener with the given registration ID. @param serviceName service name @param topic topic name @param id registration
hazelcast/src/main/java/com/hazelcast/spi/impl/eventservice/EventService.java:154
↓ 10 callers
Method
destroy
Destroys this object cluster-wide. Clears and releases all resources for this object.
hazelcast/src/main/java/com/hazelcast/core/DistributedObject.java:79
↓ 10 callers
Method
destroyDistributedObject
Destroys a distributed object. @param objectName the name of the distributed object to destroy
hazelcast/src/main/java/com/hazelcast/internal/services/RemoteService.java:49
↓ 10 callers
Method
destroyIndexes
Destroys and then removes all the indexes from this indexes instance.
hazelcast/src/main/java/com/hazelcast/query/impl/IndexRegistry.java:267
↓ 10 callers
Method
disconnect
(V v1, V v2)
hazelcast/src/main/java/com/hazelcast/internal/util/graph/Graph.java:55
↓ 10 callers
Method
discriminator
Returns the discriminator tag's name of the metric denoted by this instance. Used to distinguish metrics that have the same {@link #prefix()} and {@li
hazelcast/src/main/java/com/hazelcast/internal/metrics/MetricDescriptor.java:83
↓ 10 callers
Method
divideExact
Divides the left-hand side operand by the right-hand side operand. <p> Unlike the regular Java division operator, throws an exception if division resu
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/expression/math/ExpressionMath.java:46
↓ 10 callers
Method
doSomeWorkWithXa
(HazelcastXAResource xaResource)
hazelcast/src/test/java/com/hazelcast/client/txn/ClientXACompatibilityTest.java:188
↓ 10 callers
Method
doTest
(List<Object> input, List<Object> expectedOutput)
hazelcast/src/test/java/com/hazelcast/jet/impl/processor/InsertWatermarksPTest.java:280
↓ 10 callers
Method
encode
(ClientMessage clientMessage, Collection<Map.Entry<Integer, Integer>> collection)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/EntryListIntegerIntegerCodec.java:39
↓ 10 callers
Method
encodeRequest
(java.lang.String name, java.util.UUID cursorId, boolean newIteration, int partitionId, int batchSize)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ReplicatedMapFetchEntryViewsCodec.java:97
↓ 10 callers
Method
encodeResponse
(@Nullable java.util.UUID response)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/JetAddJobStatusListenerCodec.java:113
↓ 10 callers
Method
encodeResponse
(com.hazelcast.internal.serialization.Data updatedConfig)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/JetUpdateJobConfigCodec.java:93
↓ 10 callers
Method
encodeResponse
(boolean response)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/JetIsJobUserCancelledCodec.java:80
↓ 10 callers
Method
entryValue
Returns a function that extracts the value of a {@link Entry}. @param <V> type of entry's value
hazelcast/src/main/java/com/hazelcast/function/Functions.java:57
↓ 10 callers
Method
equals
(Object o)
hazelcast/src/main/java/com/hazelcast/cache/impl/wan/WanCacheEntryView.java:159
↓ 10 callers
Method
equals
(Object o)
hazelcast/src/main/java/com/hazelcast/internal/nio/Packet.java:229
↓ 10 callers
Method
equals
(Object obj)
hazelcast/src/main/java/com/hazelcast/jet/core/Edge.java:632
↓ 10 callers
Method
exceptionally
()
hazelcast/src/test/java/com/hazelcast/spi/impl/CompletableFutureAbstractTest.java:809
↓ 10 callers
Method
execute
(String sql, Object... params)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/map/SqlUpdateTest.java:317
↓ 10 callers
Method
executeOnKeyOwner
Executes a task on the owner of the specified key. @param command a task executed on the owner of the specified key @param key the specified key
hazelcast/src/main/java/com/hazelcast/core/IExecutorService.java:62
↓ 10 callers
Method
exists
()
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheEntryProcessorEntry.java:72
↓ 10 callers
Method
extractPrunability
(RelNode rel, RelMetadataQuery mq)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/metadata/HazelcastRelMdPrunability.java:199
↓ 10 callers
Method
fieldOperations
(FieldKind fieldKind)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/FieldOperations.java:1129
↓ 10 callers
Method
fieldWithSameExternal
(String name, QueryDataType type, BsonType externalType)
extensions/mongodb/src/test/java/com/hazelcast/jet/sql/impl/connector/mongodb/FieldResolverTest.java:208
↓ 10 callers
Method
fields
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/map/Metadata.java:46
↓ 10 callers
Method
findPNCounterConfig
Finds existing PN counter config. @param name name of the config @return PN counter config or {@code null} when requested PN counter configuration do
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/ConfigurationService.java:174
↓ 10 callers
Method
findReplicatedMapConfig
Finds existing ReplicatedMap config. @param name name of the config @return ReplicatedMap config or {@code null} when requested ReplicatedMap configu
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/ConfigurationService.java:238
↓ 10 callers
Method
floorFrameTs
Returns the highest frame timestamp less than or equal to the given timestamp. If there is no such {@code long} value, returns {@code Long.MIN_VALUE}.
hazelcast/src/main/java/com/hazelcast/jet/core/SlidingWindowPolicy.java:107
↓ 10 callers
Method
formatPublic
(List<Endpoint> addresses)
hazelcast/src/test/java/com/hazelcast/kubernetes/KubernetesClientTest.java:968
↓ 10 callers
Method
freeMemory
()
hazelcast/src/test/java/com/hazelcast/internal/metrics/metricsets/RuntimeMetricSetTest.java:63
↓ 10 callers
Method
fromEpochMillis
(final Long timestamp)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/datetime/ToEpochMillisIntegrationTest.java:121
↓ 10 callers
Method
generateAndUploadObjects
(String bucketName, String prefix, int objectCount, int lineCount)
extensions/s3/src/test/java/com/hazelcast/jet/s3/S3MockTest.java:257
↓ 10 callers
Method
generateEntries
(int count)
hazelcast/src/test/java/com/hazelcast/query/impl/AndResultSetTest.java:182
↓ 10 callers
Method
get
(Metric metric)
hazelcast/src/test/java/com/hazelcast/internal/util/phonehome/PhoneHomeDifferentConfigTest.java:61
↓ 10 callers
Method
get
(Object name)
hazelcast/src/main/java/com/hazelcast/internal/json/JsonObject.java:871
↓ 10 callers
Method
get
Returns all {@link Measurement}s associated with a given metric name. <p> For a list of job-specific metric names please see {@link MetricNames}.
hazelcast/src/main/java/com/hazelcast/jet/core/metrics/JobMetrics.java:98
↓ 10 callers
Method
get1
Returns the first value.
hazelcast/src/main/java/com/hazelcast/jet/accumulator/LongLongAccumulator.java:46
↓ 10 callers
Method
getAddress
()
hazelcast/src/main/java/com/hazelcast/internal/util/AddressUtil.java:514
↓ 10 callers
Method
getAddressMatcher
Gets an AddressMatcher for a given addresses. @param address the address @return the returned AddressMatcher. The returned value will never be null.
hazelcast/src/main/java/com/hazelcast/internal/util/AddressUtil.java:307
↓ 10 callers
Method
getAge
()
hazelcast/src/test/java/com/hazelcast/map/MapListenerTest.java:180
↓ 10 callers
Method
getAllowedFutureMillis
@see #setAllowedFutureMillis(long)
hazelcast/src/main/java/com/hazelcast/config/FlakeIdGeneratorConfig.java:278
↓ 10 callers
Method
getAsyncBackupCount
Returns the asynchronous backup count for this {@link IMap}. @return the asynchronous backup count @see #setBackupCount(int)
hazelcast/src/main/java/com/hazelcast/config/MapConfig.java:296
↓ 10 callers
Method
getAsyncBackupCount
Gets the number of asynchronous backups. @return the number of asynchronous backups
hazelcast/src/main/java/com/hazelcast/config/RingbufferConfig.java:208
↓ 10 callers
Method
getAutoOffFuture
()
hazelcast/src/main/java/com/hazelcast/internal/diagnostics/Diagnostics.java:621
↓ 10 callers
Method
getBackupCount
Gets the number of synchronous backups. @return number of synchronous backups
hazelcast/src/main/java/com/hazelcast/config/RingbufferConfig.java:183
↓ 10 callers
Method
getBackupMap
Return the map containing queue items when this instance is a backup replica. The map contains both items that are parts of different transactions and
hazelcast/src/main/java/com/hazelcast/collection/impl/queue/QueueContainer.java:996
↓ 10 callers
Method
getBaseDir
Base directory for this device. Can be an absolute or relative path to the node startup directory.
hazelcast/src/main/java/com/hazelcast/config/LocalDeviceConfig.java:109
↓ 10 callers
Method
getCPMemberCount
Returns the number of CP members that will initialize CP Subsystem. CP Subsystem is disabled if it is 0. @return the number of CP members that will i
hazelcast/src/main/java/com/hazelcast/config/cp/CPSubsystemConfig.java:373
↓ 10 callers
Method
getCacheEventHandler
()
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheService.java:842
↓ 10 callers
Method
getCacheManager
(URI uri, ClassLoader classLoader, Properties properties)
hazelcast/src/main/java/com/hazelcast/client/cache/HazelcastClientCachingProvider.java:61
↓ 10 callers
Method
getCallTimeout
Gets the call timeout in milliseconds. For example, if a call should start execution within 60 seconds, or it should be aborted otherwise, then the ca
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/Operation.java:526
↓ 10 callers
Method
getClassName
()
hazelcast/src/main/java/com/hazelcast/config/CacheSimpleConfig.java:1051
↓ 10 callers
Method
getClassName
()
hazelcast/src/main/java/com/hazelcast/config/DiscoveryStrategyConfig.java:86
↓ 10 callers
Method
getClientEventRegistrations
(HazelcastInstance client, UUID id)
hazelcast/src/test/java/com/hazelcast/client/listeners/leak/ListenerLeakTest.java:115
↓ 10 callers
Method
getClientPermissionConfigs
Returns latest client permission configuration.
hazelcast/src/main/java/com/hazelcast/security/SecurityService.java:37
↓ 10 callers
Method
getCloseCause
Gets the cause this Connection was closed. Can be null if no cause was given or if the connection is still active. It is purely meant for debugging to
hazelcast/src/main/java/com/hazelcast/internal/nio/Connection.java:203
↓ 10 callers
Method
getCloudConfig
()
hazelcast/src/main/java/com/hazelcast/client/config/ClientNetworkConfig.java:440
↓ 10 callers
Method
getClusterId
@return cluster's uuid
hazelcast/src/main/java/com/hazelcast/client/impl/spi/ClientClusterService.java:111
↓ 10 callers
Method
getClusterStateManager
()
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/ClusterServiceImpl.java:1023
↓ 10 callers
Method
getCollection
()
hazelcast/src/main/java/com/hazelcast/multimap/impl/operations/MultiMapResponse.java:57
↓ 10 callers
Method
getConfig
()
hazelcast/src/test/java/com/hazelcast/internal/partition/PartitionServiceSafetyCheckTest.java:58
↓ 10 callers
Method
getConfig
()
hazelcast/src/test/java/com/hazelcast/internal/eviction/MapExpirationManagerTest.java:58
↓ 10 callers
Method
getConfig
()
hazelcast/src/main/java/com/hazelcast/ringbuffer/impl/RingbufferContainer.java:194
↓ 10 callers
Method
getConfigurationFile
Returns the {@link File} to the declarative configuration, which has been parsed to create this {@link Config} instance. @return the configuration fi
hazelcast/src/main/java/com/hazelcast/config/Config.java:2886
↓ 10 callers
Method
getConflictingSchemas
()
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/schema/Table.java:105
↓ 10 callers
Method
getConnectionType
Returns the connection type. <p> See {@link com.hazelcast.internal.nio.ConnectionType} for in-house candidates. Note that a type could be provided by
hazelcast/src/main/java/com/hazelcast/internal/server/ServerConnection.java:42
↓ 10 callers
Method
getContainers
()
hazelcast/src/main/java/com/hazelcast/ringbuffer/impl/RingbufferService.java:131
↓ 10 callers
Method
getCreatedInstancesShuffledAfterWarmedUp
()
hazelcast/src/test/java/com/hazelcast/partition/AbstractPartitionLostListenerTest.java:110
↓ 10 callers
Method
getCreationTime
Gets the cache creation time. @return the cache creation time
hazelcast/src/main/java/com/hazelcast/cache/CacheStatistics.java:47
↓ 10 callers
Method
getCursorId
()
hazelcast/src/main/java/com/hazelcast/internal/iteration/IterationResult.java:39
↓ 10 callers
Method
getDistributedTo
Note: unlike {@link Edge#getDistributedTo()}, this method always returns null if the DAG is about to be run on a single member. See {@linkplain #EdgeD
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/init/EdgeDef.java:119
↓ 10 callers
Method
getDriver
()
hazelcast/src/test/java/com/hazelcast/executor/AbstractExecutorNullTest.java:180
↓ 10 callers
Method
getDurability
Gets the transaction durability. @return the transaction durability. @see #setDurability(int)
hazelcast/src/main/java/com/hazelcast/transaction/TransactionOptions.java:128
↓ 10 callers
Method
getEnabled
Returns if the merkle tree is enabled. @return {@code TRUE} if the merkle tree is enabled, {@code FALSE} if disabled or {@code null} if user
hazelcast/src/main/java/com/hazelcast/config/MerkleTreeConfig.java:144
← previous
next →
6,601–6,700 of 147,315, ranked by callers