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
↓ 2 callers
Method
collectDynamicMetrics
(Collection<DynamicMetricsProvider> metricsSources)
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/MetricsCollectionCycle.java:91
↓ 2 callers
Method
collectLong
(Object source, MetricDescriptor descriptor, LongProbeFunction function)
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/MetricsCollectionCycle.java:173
↓ 2 callers
Method
collectMergeTasks
(boolean coreServices)
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/ClusterMergeTask.java:124
↓ 2 callers
Method
collectMetrics
(String prefix, HazelcastInstance... instances)
hazelcast/src/test/java/com/hazelcast/scheduledexecutor/impl/ScheduledExecutorServiceTestSupport.java:548
↓ 2 callers
Method
collectMetrics
(CompletableFuture<List<RawJobMetrics>> clientFuture)
hazelcast/src/main/java/com/hazelcast/jet/impl/MasterJobContext.java:1135
↓ 2 callers
Method
collectOwnedReplicaVersions
(Node node, Map<Integer, PartitionReplicaVersionsView> replicaVersions)
hazelcast/src/test/java/com/hazelcast/internal/partition/TestPartitionUtils.java:100
↓ 2 callers
Method
collectReplicationOperations
Collect replication operations of a single fragmented service. <p> If the service implements {@link OffloadedReplicationPreparation} interface, then t
hazelcast/src/main/java/com/hazelcast/internal/partition/operation/AbstractPartitionOperation.java:274
↓ 2 callers
Method
collectionToString
(Collection<?> list)
hazelcast/src/test/java/com/hazelcast/jet/impl/processor/SlidingWindowP_twoStageSnapshotTest.java:216
↓ 2 callers
Method
collectionXmlGenerator
(ConfigXmlGenerator.XmlGenerator gen, String type,
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/DynamicConfigXmlGenerator.java:473
↓ 2 callers
Method
columns
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/parse/SqlCreateIndex.java:85
↓ 2 callers
Method
combine
(PlanNodeSchema schema1, PlanNodeSchema schema2)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/plan/node/PlanNodeSchema.java:42
↓ 2 callers
Method
combineStats
(IMap map1, IMap map2)
hazelcast/src/test/java/com/hazelcast/client/map/ClientIndexStatsTest.java:267
↓ 2 callers
Method
commit
(NodeEngine nodeEngine)
hazelcast/src/main/java/com/hazelcast/transaction/impl/TransactionLog.java:89
↓ 2 callers
Method
commitPendingTransactions
()
hazelcast/src/main/java/com/hazelcast/jet/impl/processor/UnboundedTransactionsProcessorUtility.java:172
↓ 2 callers
Method
commitRecord
(SourceRecord rec, RecordMetadata metadata)
extensions/kafka-connect/src/test/java/com/hazelcast/jet/kafka/connect/impl/DummySourceConnector.java:206
↓ 2 callers
Method
commitRecord
(SourceRecord rec)
extensions/kafka-connect/src/main/java/com/hazelcast/jet/kafka/connect/impl/TaskRunner.java:141
↓ 2 callers
Method
commitRetryStrategy
Sets the retry strategy in case of commit failure. <p> MongoDB by default retries simple operations, but commits must be retried manually. <p> This op
extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/MongoSinkBuilder.java:202
↓ 2 callers
Method
commonSymmetricEncInterceptorConfigXmlBodyGenerator
(XmlGenerator gen, AbstractSymmetricEncry
hazelcast/src/main/java/com/hazelcast/config/ConfigXmlGenerator.java:819
↓ 2 callers
Method
compactChain
(int deleteIndex)
hazelcast/src/main/java/com/hazelcast/internal/util/collection/Object2LongHashMap.java:591
↓ 2 callers
Method
compactChain
(int deleteIndex)
hazelcast/src/main/java/com/hazelcast/internal/util/collection/Long2ObjectHashMap.java:350
↓ 2 callers
Method
compactChain
(int deleteIndex)
hazelcast/src/main/java/com/hazelcast/internal/util/collection/Int2ObjectHashMap.java:350
↓ 2 callers
Method
compactOrClear
Compacts or clears the buffer depending if bytes are remaining in the byte-buffer. @param bb the ByteBuffer
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/util/BufferUtil.java:30
↓ 2 callers
Method
compactSerialization
Generates the Compact serialization configuration out of the given configuration.
hazelcast/src/main/java/com/hazelcast/internal/config/ConfigXmlGeneratorHelper.java:75
↓ 2 callers
Method
compactTypeName
(Map<String, String> options, boolean isKey)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/map/MetadataCompactResolver.java:158
↓ 2 callers
Method
compare
(Object left, Object right)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/aggregate/MaxSqlAggregation.java:53
↓ 2 callers
Method
compare
(Object left, Object right)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/aggregate/MinSqlAggregation.java:53
↓ 2 callers
Method
compare
(Object v1, Object v2)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheRecordStore.java:683
↓ 2 callers
Method
compareActualValues
(Class<? extends Enum<?>> enumClass, String... expected)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/json/CalciteEnumStabilityTest.java:58
↓ 2 callers
Method
compareAnchor
(PagingPredicate pagingPredicate, QueryableEntry queryEntry, Map.Entry
hazelcast/src/main/java/com/hazelcast/internal/util/SortingUtil.java:159
↓ 2 callers
Method
compareAndRemove
(boolean retain, @Nonnull Collection<?> c)
hazelcast/src/main/java/com/hazelcast/collection/impl/collection/AbstractCollectionProxyImpl.java:185
↓ 2 callers
Method
compareIntegers
Compares two integers by considering their signs. <p> Suppose that i1 = -500.000.000 i2 = 2.000.000.000 <p> Normally "i1 < i2", but if we use "i1 - i2
hazelcast/src/main/java/com/hazelcast/internal/util/SortingUtil.java:112
↓ 2 callers
Method
compareLongWithDouble
(long l, double d)
hazelcast/src/main/java/com/hazelcast/query/impl/Numbers.java:314
↓ 2 callers
Method
comparePartitionOwnership
(boolean ownedBy, Member member, Partition partition)
hazelcast/src/test/java/com/hazelcast/test/HazelcastTestSupport.java:640
↓ 2 callers
Method
compareTo
(ChipPortable o)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/portable/portablereader/DefaultPortableReaderQuickTest.java:559
↓ 2 callers
Method
complete
(Object value)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/BaseInvocation.java:167
↓ 2 callers
Method
complete
(int partition, boolean indexed)
hazelcast/src/main/java/com/hazelcast/query/impl/GlobalIndexPartitionTracker.java:114
↓ 2 callers
Method
complete
()
hazelcast/src/main/java/com/hazelcast/jet/impl/connector/StreamEventJournalP.java:187
↓ 2 callers
Method
complete0
(Object value)
hazelcast/src/main/java/com/hazelcast/spi/impl/AbstractInvocationFuture.java:1225
↓ 2 callers
Method
complete0
()
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/Invocation.java:701
↓ 2 callers
Method
completeConstruction
Completes the construction of this result. <p> Implementations may release intermediary resources associated with the construction in this method. No
hazelcast/src/main/java/com/hazelcast/map/impl/query/Result.java:104
↓ 2 callers
Method
completeDependentExceptionally
Completes dependent {@code future} exceptionally. When the parent future was completed exceptionally, then dependent future is also completed exceptio
hazelcast/src/main/java/com/hazelcast/spi/impl/AbstractInvocationFuture.java:1904
↓ 2 callers
Method
completeExceptionally
(Throwable ex)
hazelcast/src/main/java/com/hazelcast/spi/impl/DelegatingCompletableFuture.java:225
↓ 2 callers
Method
completeExceptionally
(Throwable t)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/BaseInvocation.java:169
↓ 2 callers
Method
completeInFlightOperation
(long schemaId, InternalCompletableFuture<Collection<UUID>> future,
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/compact/schema/SchemaReplicator.java:317
↓ 2 callers
Method
completeJob
Puts a JobResult for the given job and deletes the JobRecord. @throws JobNotFoundException if the JobRecord is not found @throws IllegalStateExcepti
hazelcast/src/main/java/com/hazelcast/jet/impl/JobRepository.java:406
↓ 2 callers
Method
completeSuper
(Object value, Throwable t)
hazelcast/src/main/java/com/hazelcast/spi/impl/DelegatingCompletableFuture.java:491
↓ 2 callers
Method
completeWhenRetryRejected
(RejectedExecutionException e)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/Invocation.java:738
↓ 2 callers
Method
completeWithPendingResponse
()
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/BaseInvocation.java:157
↓ 2 callers
Method
completedExceptionally
(Throwable t, Executor executor)
hazelcast/src/main/java/com/hazelcast/client/impl/proxy/ClientDurableExecutorServiceProxy.java:253
↓ 2 callers
Method
completedSynchronously
(Future<V> future, SerializationSer
hazelcast/src/main/java/com/hazelcast/executor/impl/ExecutorServiceProxy.java:648
↓ 2 callers
Method
composeAttributeValueExtractionFailedMessage
(Member member)
hazelcast/src/main/java/com/hazelcast/query/impl/getters/AbstractMultiValueGetter.java:222
↓ 2 callers
Method
composeEqualsFilter
Composes an equality filter from multiple single-column components. <p> If the number of single-column filters is equal to the number of index compone
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/index/IndexResolver.java:1140
↓ 2 callers
Method
composeRangeFilter
Create the composite range filter from the given per-column filters. <p> If the number of per-column filters if less than the number of index componen
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/index/IndexResolver.java:1237
↓ 2 callers
Method
composeRowWithNulls
(JetSqlRow row, int ordinal)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/processors/StreamToStreamJoinP.java:524
↓ 2 callers
Method
composeSelect
(String fieldName, String... tableComponents)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/parse/ParserNameResolutionTest.java:172
↓ 2 callers
Method
computeIfAbsent
(K key, Function<? super K, ? extends V> valueFunction)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/expression/ConcurrentInitialSetCache.java:64
↓ 2 callers
Method
computeRowType
(List<RexNode> projects)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/schema/HazelcastTable.java:195
↓ 2 callers
Method
computeWindow
(long frameTs)
hazelcast/src/main/java/com/hazelcast/jet/impl/processor/SlidingWindowP.java:404
↓ 2 callers
Method
conclude
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/inject/AvroUpsertTarget.java:162
↓ 2 callers
Method
conclude
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/inject/HazelcastJsonUpsertTarget.java:148
↓ 2 callers
Method
conclude
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/inject/JsonUpsertTarget.java:128
↓ 2 callers
Method
concurrencyDetection
(ConcurrencyDetection concurrencyDetection)
hazelcast/src/main/java/com/hazelcast/internal/networking/nio/NioNetworking.java:522
↓ 2 callers
Method
concurrentInvocations
()
hazelcast/src/main/java/com/hazelcast/spi/impl/sequence/AbstractCallIdSequence.java:104
↓ 2 callers
Method
concurrentSetOfValues
(Set<V> values)
hazelcast/src/main/java/com/hazelcast/cache/impl/DeferredValue.java:149
↓ 2 callers
Method
concurrent_MapTryLock
(boolean withTimeOut)
hazelcast/src/test/java/com/hazelcast/client/map/ClientMapTryLockConcurrentTests.java:67
↓ 2 callers
Method
config
(int port)
hazelcast/src/test/java/com/hazelcast/internal/ascii/RestNodeStateTest.java:117
↓ 2 callers
Method
config
(JobConfig config)
hazelcast/src/test/java/com/hazelcast/jet/JobStatusListenerTest.java:378
↓ 2 callers
Method
config
(boolean advancedNetwork, boolean multicast)
hazelcast/src/test/java/com/hazelcast/cluster/SplitBrainHandlerTest.java:866
↓ 2 callers
Method
configReload
(String clusterName, String clusterPassword)
hazelcast/src/test/java/com/hazelcast/internal/ascii/HTTPCommunicator.java:370
↓ 2 callers
Method
configUpdate
(String clusterName, String clusterPassword, String configAsString)
hazelcast/src/test/java/com/hazelcast/internal/ascii/HTTPCommunicator.java:375
↓ 2 callers
Method
configuration
(boolean ignoreFileNotFound)
extensions/hadoop/src/test/java/com/hazelcast/jet/hadoop/impl/FileNotFoundReadHadoopPTest.java:84
↓ 2 callers
Method
configure
Configures {@link IPermissionPolicy}. @param config Hazelcast {@link Config} @param properties additional properties used to configure the IPermissio
hazelcast/src/main/java/com/hazelcast/security/IPermissionPolicy.java:40
↓ 2 callers
Method
configureDummyDataConnection
(String name, Config config)
hazelcast/src/test/java/com/hazelcast/dataconnection/impl/DataConnectionTestUtil.java:77
↓ 2 callers
Method
configureForTurnsActivePassiveTest
(HazelcastInstance node)
hazelcast/src/test/java/com/hazelcast/internal/eviction/AbstractExpirationManagerTest.java:241
↓ 2 callers
Method
configureHostAware
(Config config)
hazelcast/src/test/java/com/hazelcast/partition/PartitionDistributionTest.java:64
↓ 2 callers
Method
configureLogging
()
hazelcast/src/main/java/com/hazelcast/client/console/HazelcastCommandLine.java:517
↓ 2 callers
Method
configureLogging
()
hazelcast/src/main/java/com/hazelcast/instance/impl/HazelcastBootstrap.java:160
↓ 2 callers
Method
configureMavenEnvironment
(ProcessBuilder processBuilder)
hazelcast/src/test/java/com/hazelcast/test/starter/MavenInterface.java:149
↓ 2 callers
Method
configureNeedsReplicaStateCheckResponse
()
hazelcast/src/test/java/com/hazelcast/internal/partition/impl/PartitionReplicaStateChecker_triggerAndWaitForReplicaSyncTest.java:167
↓ 2 callers
Method
configureNeedsReplicaStateCheckResponseOnEachSecondCall
()
hazelcast/src/test/java/com/hazelcast/internal/partition/impl/PartitionReplicaStateChecker_triggerAndWaitForReplicaSyncTest.java:172
↓ 2 callers
Method
configurePersistence
(Config cfg)
hazelcast/src/test/java/com/hazelcast/config/ConfigXmlGeneratorTest.java:485
↓ 2 callers
Method
connect
(A target, Function<A, ClientConnection> getOrConnectFunction, Function<A, Ad
hazelcast/src/main/java/com/hazelcast/client/impl/connection/tcp/TcpClientConnectionManager.java:516
↓ 2 callers
Method
connect
(V v1, V v2)
hazelcast/src/main/java/com/hazelcast/internal/util/graph/Graph.java:44
↓ 2 callers
Method
connect0
(SocketAddress address, CompletableFuture<Void> future)
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/nio/NioAsyncSocket.java:235
↓ 2 callers
Method
connectAndPrepareStatement
()
hazelcast/src/main/java/com/hazelcast/jet/impl/connector/WriteJdbcP.java:252
↓ 2 callers
Method
connectToCluster
()
extensions/kafka-connect/src/test/java/com/hazelcast/jet/kafka/connect/KafkaConnectCouchbaseIT.java:209
↓ 2 callers
Method
connectionCount
Returns the number of connections that satisfy some predicate. @param predicate the Predicate. Predicate can be null which means that no filtering is
hazelcast/src/main/java/com/hazelcast/internal/server/ServerConnectionManager.java:55
↓ 2 callers
Method
connectionFailed
()
hazelcast/src/main/java/com/hazelcast/client/impl/connection/tcp/TpcChannelConnector.java:199
↓ 2 callers
Method
connectionFn
Sets the function which creates a connection given a connection factory. <p> If not provided, the following will be used: <pre>{@code if (factory
hazelcast/src/main/java/com/hazelcast/jet/pipeline/JmsSinkBuilder.java:99
↓ 2 callers
Method
constantWmPolicy
(long value)
hazelcast/src/test/java/com/hazelcast/jet/core/EventTimeMapperTest.java:243
↓ 2 callers
Method
construct
(Class<?> clazz, Object delegate)
hazelcast/src/test/java/com/hazelcast/test/starter/HazelcastProxyFactory.java:285
↓ 2 callers
Method
constructHazelcastClient
( String instanceName, ClientConfig config, ClientFailoverConfig failoverC
hazelcast/src/main/java/com/hazelcast/client/HazelcastClient.java:460
↓ 2 callers
Method
constructHazelcastInstance
(Config config, String instanceName, NodeContext nodeContext,
hazelcast/src/main/java/com/hazelcast/instance/impl/HazelcastInstanceFactory.java:209
↓ 2 callers
Method
constructReflectively
(Class<T> clazz)
hazelcast/src/main/java/com/hazelcast/internal/config/ConfigUtils.java:166
↓ 2 callers
Method
consumeIfExists
(JsonObject json, String attribute, Consumer<JsonValue> valueConsumer)
hazelcast/src/main/java/com/hazelcast/internal/management/dto/CustomWanPublisherConfigDTO.java:69
↓ 2 callers
Method
consumerFn
Sets the function which creates the message consumer from session. <p> If not provided, {@code Session#createConsumer(destinationName)} is used to cre
hazelcast/src/main/java/com/hazelcast/jet/pipeline/JmsSourceBuilder.java:133
↓ 2 callers
Method
containerPort
(JsonValue container)
hazelcast/src/main/java/com/hazelcast/kubernetes/KubernetesClient.java:497
↓ 2 callers
Method
contains
(int partitionId)
hazelcast/src/test/java/com/hazelcast/internal/partition/service/TestMigrationAwareService.java:122
↓ 2 callers
Method
containsAll
(final Collection<?> coll)
hazelcast/src/main/java/com/hazelcast/internal/util/collection/IntHashSet.java:187
↓ 2 callers
Method
containsAll
{@inheritDoc}
hazelcast/src/main/java/com/hazelcast/internal/util/collection/LongHashSet.java:214
← previous
next →
17,001–17,100 of 147,315, ranked by callers