MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

↓ 2 callersMethodcollectDynamicMetrics
(Collection<DynamicMetricsProvider> metricsSources)
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/MetricsCollectionCycle.java:91
↓ 2 callersMethodcollectLong
(Object source, MetricDescriptor descriptor, LongProbeFunction function)
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/MetricsCollectionCycle.java:173
↓ 2 callersMethodcollectMergeTasks
(boolean coreServices)
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/ClusterMergeTask.java:124
↓ 2 callersMethodcollectMetrics
(String prefix, HazelcastInstance... instances)
hazelcast/src/test/java/com/hazelcast/scheduledexecutor/impl/ScheduledExecutorServiceTestSupport.java:548
↓ 2 callersMethodcollectMetrics
(CompletableFuture<List<RawJobMetrics>> clientFuture)
hazelcast/src/main/java/com/hazelcast/jet/impl/MasterJobContext.java:1135
↓ 2 callersMethodcollectOwnedReplicaVersions
(Node node, Map<Integer, PartitionReplicaVersionsView> replicaVersions)
hazelcast/src/test/java/com/hazelcast/internal/partition/TestPartitionUtils.java:100
↓ 2 callersMethodcollectReplicationOperations
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 callersMethodcollectionToString
(Collection<?> list)
hazelcast/src/test/java/com/hazelcast/jet/impl/processor/SlidingWindowP_twoStageSnapshotTest.java:216
↓ 2 callersMethodcollectionXmlGenerator
(ConfigXmlGenerator.XmlGenerator gen, String type,
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/DynamicConfigXmlGenerator.java:473
↓ 2 callersMethodcolumns
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/parse/SqlCreateIndex.java:85
↓ 2 callersMethodcombine
(PlanNodeSchema schema1, PlanNodeSchema schema2)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/plan/node/PlanNodeSchema.java:42
↓ 2 callersMethodcombineStats
(IMap map1, IMap map2)
hazelcast/src/test/java/com/hazelcast/client/map/ClientIndexStatsTest.java:267
↓ 2 callersMethodcommit
(NodeEngine nodeEngine)
hazelcast/src/main/java/com/hazelcast/transaction/impl/TransactionLog.java:89
↓ 2 callersMethodcommitPendingTransactions
()
hazelcast/src/main/java/com/hazelcast/jet/impl/processor/UnboundedTransactionsProcessorUtility.java:172
↓ 2 callersMethodcommitRecord
(SourceRecord rec, RecordMetadata metadata)
extensions/kafka-connect/src/test/java/com/hazelcast/jet/kafka/connect/impl/DummySourceConnector.java:206
↓ 2 callersMethodcommitRecord
(SourceRecord rec)
extensions/kafka-connect/src/main/java/com/hazelcast/jet/kafka/connect/impl/TaskRunner.java:141
↓ 2 callersMethodcommitRetryStrategy
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 callersMethodcommonSymmetricEncInterceptorConfigXmlBodyGenerator
(XmlGenerator gen, AbstractSymmetricEncry
hazelcast/src/main/java/com/hazelcast/config/ConfigXmlGenerator.java:819
↓ 2 callersMethodcompactChain
(int deleteIndex)
hazelcast/src/main/java/com/hazelcast/internal/util/collection/Object2LongHashMap.java:591
↓ 2 callersMethodcompactChain
(int deleteIndex)
hazelcast/src/main/java/com/hazelcast/internal/util/collection/Long2ObjectHashMap.java:350
↓ 2 callersMethodcompactChain
(int deleteIndex)
hazelcast/src/main/java/com/hazelcast/internal/util/collection/Int2ObjectHashMap.java:350
↓ 2 callersMethodcompactOrClear
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 callersMethodcompactSerialization
Generates the Compact serialization configuration out of the given configuration.
hazelcast/src/main/java/com/hazelcast/internal/config/ConfigXmlGeneratorHelper.java:75
↓ 2 callersMethodcompactTypeName
(Map<String, String> options, boolean isKey)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/map/MetadataCompactResolver.java:158
↓ 2 callersMethodcompare
(Object left, Object right)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/aggregate/MaxSqlAggregation.java:53
↓ 2 callersMethodcompare
(Object left, Object right)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/aggregate/MinSqlAggregation.java:53
↓ 2 callersMethodcompare
(Object v1, Object v2)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheRecordStore.java:683
↓ 2 callersMethodcompareActualValues
(Class<? extends Enum<?>> enumClass, String... expected)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/json/CalciteEnumStabilityTest.java:58
↓ 2 callersMethodcompareAnchor
(PagingPredicate pagingPredicate, QueryableEntry queryEntry, Map.Entry
hazelcast/src/main/java/com/hazelcast/internal/util/SortingUtil.java:159
↓ 2 callersMethodcompareAndRemove
(boolean retain, @Nonnull Collection<?> c)
hazelcast/src/main/java/com/hazelcast/collection/impl/collection/AbstractCollectionProxyImpl.java:185
↓ 2 callersMethodcompareIntegers
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 callersMethodcompareLongWithDouble
(long l, double d)
hazelcast/src/main/java/com/hazelcast/query/impl/Numbers.java:314
↓ 2 callersMethodcomparePartitionOwnership
(boolean ownedBy, Member member, Partition partition)
hazelcast/src/test/java/com/hazelcast/test/HazelcastTestSupport.java:640
↓ 2 callersMethodcompareTo
(ChipPortable o)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/portable/portablereader/DefaultPortableReaderQuickTest.java:559
↓ 2 callersMethodcomplete
(Object value)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/BaseInvocation.java:167
↓ 2 callersMethodcomplete
(int partition, boolean indexed)
hazelcast/src/main/java/com/hazelcast/query/impl/GlobalIndexPartitionTracker.java:114
↓ 2 callersMethodcomplete
()
hazelcast/src/main/java/com/hazelcast/jet/impl/connector/StreamEventJournalP.java:187
↓ 2 callersMethodcomplete0
(Object value)
hazelcast/src/main/java/com/hazelcast/spi/impl/AbstractInvocationFuture.java:1225
↓ 2 callersMethodcomplete0
()
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/Invocation.java:701
↓ 2 callersMethodcompleteConstruction
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 callersMethodcompleteDependentExceptionally
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 callersMethodcompleteExceptionally
(Throwable ex)
hazelcast/src/main/java/com/hazelcast/spi/impl/DelegatingCompletableFuture.java:225
↓ 2 callersMethodcompleteExceptionally
(Throwable t)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/BaseInvocation.java:169
↓ 2 callersMethodcompleteInFlightOperation
(long schemaId, InternalCompletableFuture<Collection<UUID>> future,
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/compact/schema/SchemaReplicator.java:317
↓ 2 callersMethodcompleteJob
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 callersMethodcompleteSuper
(Object value, Throwable t)
hazelcast/src/main/java/com/hazelcast/spi/impl/DelegatingCompletableFuture.java:491
↓ 2 callersMethodcompleteWhenRetryRejected
(RejectedExecutionException e)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/Invocation.java:738
↓ 2 callersMethodcompleteWithPendingResponse
()
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/BaseInvocation.java:157
↓ 2 callersMethodcompletedExceptionally
(Throwable t, Executor executor)
hazelcast/src/main/java/com/hazelcast/client/impl/proxy/ClientDurableExecutorServiceProxy.java:253
↓ 2 callersMethodcompletedSynchronously
(Future<V> future, SerializationSer
hazelcast/src/main/java/com/hazelcast/executor/impl/ExecutorServiceProxy.java:648
↓ 2 callersMethodcomposeAttributeValueExtractionFailedMessage
(Member member)
hazelcast/src/main/java/com/hazelcast/query/impl/getters/AbstractMultiValueGetter.java:222
↓ 2 callersMethodcomposeEqualsFilter
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 callersMethodcomposeRangeFilter
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 callersMethodcomposeRowWithNulls
(JetSqlRow row, int ordinal)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/processors/StreamToStreamJoinP.java:524
↓ 2 callersMethodcomposeSelect
(String fieldName, String... tableComponents)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/parse/ParserNameResolutionTest.java:172
↓ 2 callersMethodcomputeIfAbsent
(K key, Function<? super K, ? extends V> valueFunction)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/expression/ConcurrentInitialSetCache.java:64
↓ 2 callersMethodcomputeRowType
(List<RexNode> projects)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/schema/HazelcastTable.java:195
↓ 2 callersMethodcomputeWindow
(long frameTs)
hazelcast/src/main/java/com/hazelcast/jet/impl/processor/SlidingWindowP.java:404
↓ 2 callersMethodconclude
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/inject/AvroUpsertTarget.java:162
↓ 2 callersMethodconclude
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/inject/HazelcastJsonUpsertTarget.java:148
↓ 2 callersMethodconclude
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/inject/JsonUpsertTarget.java:128
↓ 2 callersMethodconcurrencyDetection
(ConcurrencyDetection concurrencyDetection)
hazelcast/src/main/java/com/hazelcast/internal/networking/nio/NioNetworking.java:522
↓ 2 callersMethodconcurrentInvocations
()
hazelcast/src/main/java/com/hazelcast/spi/impl/sequence/AbstractCallIdSequence.java:104
↓ 2 callersMethodconcurrentSetOfValues
(Set<V> values)
hazelcast/src/main/java/com/hazelcast/cache/impl/DeferredValue.java:149
↓ 2 callersMethodconcurrent_MapTryLock
(boolean withTimeOut)
hazelcast/src/test/java/com/hazelcast/client/map/ClientMapTryLockConcurrentTests.java:67
↓ 2 callersMethodconfig
(int port)
hazelcast/src/test/java/com/hazelcast/internal/ascii/RestNodeStateTest.java:117
↓ 2 callersMethodconfig
(JobConfig config)
hazelcast/src/test/java/com/hazelcast/jet/JobStatusListenerTest.java:378
↓ 2 callersMethodconfig
(boolean advancedNetwork, boolean multicast)
hazelcast/src/test/java/com/hazelcast/cluster/SplitBrainHandlerTest.java:866
↓ 2 callersMethodconfigReload
(String clusterName, String clusterPassword)
hazelcast/src/test/java/com/hazelcast/internal/ascii/HTTPCommunicator.java:370
↓ 2 callersMethodconfigUpdate
(String clusterName, String clusterPassword, String configAsString)
hazelcast/src/test/java/com/hazelcast/internal/ascii/HTTPCommunicator.java:375
↓ 2 callersMethodconfiguration
(boolean ignoreFileNotFound)
extensions/hadoop/src/test/java/com/hazelcast/jet/hadoop/impl/FileNotFoundReadHadoopPTest.java:84
↓ 2 callersMethodconfigure
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 callersMethodconfigureDummyDataConnection
(String name, Config config)
hazelcast/src/test/java/com/hazelcast/dataconnection/impl/DataConnectionTestUtil.java:77
↓ 2 callersMethodconfigureForTurnsActivePassiveTest
(HazelcastInstance node)
hazelcast/src/test/java/com/hazelcast/internal/eviction/AbstractExpirationManagerTest.java:241
↓ 2 callersMethodconfigureHostAware
(Config config)
hazelcast/src/test/java/com/hazelcast/partition/PartitionDistributionTest.java:64
↓ 2 callersMethodconfigureLogging
()
hazelcast/src/main/java/com/hazelcast/client/console/HazelcastCommandLine.java:517
↓ 2 callersMethodconfigureLogging
()
hazelcast/src/main/java/com/hazelcast/instance/impl/HazelcastBootstrap.java:160
↓ 2 callersMethodconfigureMavenEnvironment
(ProcessBuilder processBuilder)
hazelcast/src/test/java/com/hazelcast/test/starter/MavenInterface.java:149
↓ 2 callersMethodconfigureNeedsReplicaStateCheckResponse
()
hazelcast/src/test/java/com/hazelcast/internal/partition/impl/PartitionReplicaStateChecker_triggerAndWaitForReplicaSyncTest.java:167
↓ 2 callersMethodconfigureNeedsReplicaStateCheckResponseOnEachSecondCall
()
hazelcast/src/test/java/com/hazelcast/internal/partition/impl/PartitionReplicaStateChecker_triggerAndWaitForReplicaSyncTest.java:172
↓ 2 callersMethodconfigurePersistence
(Config cfg)
hazelcast/src/test/java/com/hazelcast/config/ConfigXmlGeneratorTest.java:485
↓ 2 callersMethodconnect
(A target, Function<A, ClientConnection> getOrConnectFunction, Function<A, Ad
hazelcast/src/main/java/com/hazelcast/client/impl/connection/tcp/TcpClientConnectionManager.java:516
↓ 2 callersMethodconnect
(V v1, V v2)
hazelcast/src/main/java/com/hazelcast/internal/util/graph/Graph.java:44
↓ 2 callersMethodconnect0
(SocketAddress address, CompletableFuture<Void> future)
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/nio/NioAsyncSocket.java:235
↓ 2 callersMethodconnectAndPrepareStatement
()
hazelcast/src/main/java/com/hazelcast/jet/impl/connector/WriteJdbcP.java:252
↓ 2 callersMethodconnectToCluster
()
extensions/kafka-connect/src/test/java/com/hazelcast/jet/kafka/connect/KafkaConnectCouchbaseIT.java:209
↓ 2 callersMethodconnectionCount
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 callersMethodconnectionFailed
()
hazelcast/src/main/java/com/hazelcast/client/impl/connection/tcp/TpcChannelConnector.java:199
↓ 2 callersMethodconnectionFn
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 callersMethodconstantWmPolicy
(long value)
hazelcast/src/test/java/com/hazelcast/jet/core/EventTimeMapperTest.java:243
↓ 2 callersMethodconstruct
(Class<?> clazz, Object delegate)
hazelcast/src/test/java/com/hazelcast/test/starter/HazelcastProxyFactory.java:285
↓ 2 callersMethodconstructHazelcastClient
( String instanceName, ClientConfig config, ClientFailoverConfig failoverC
hazelcast/src/main/java/com/hazelcast/client/HazelcastClient.java:460
↓ 2 callersMethodconstructHazelcastInstance
(Config config, String instanceName, NodeContext nodeContext,
hazelcast/src/main/java/com/hazelcast/instance/impl/HazelcastInstanceFactory.java:209
↓ 2 callersMethodconstructReflectively
(Class<T> clazz)
hazelcast/src/main/java/com/hazelcast/internal/config/ConfigUtils.java:166
↓ 2 callersMethodconsumeIfExists
(JsonObject json, String attribute, Consumer<JsonValue> valueConsumer)
hazelcast/src/main/java/com/hazelcast/internal/management/dto/CustomWanPublisherConfigDTO.java:69
↓ 2 callersMethodconsumerFn
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 callersMethodcontainerPort
(JsonValue container)
hazelcast/src/main/java/com/hazelcast/kubernetes/KubernetesClient.java:497
↓ 2 callersMethodcontains
(int partitionId)
hazelcast/src/test/java/com/hazelcast/internal/partition/service/TestMigrationAwareService.java:122
↓ 2 callersMethodcontainsAll
(final Collection<?> coll)
hazelcast/src/main/java/com/hazelcast/internal/util/collection/IntHashSet.java:187
↓ 2 callersMethodcontainsAll
{@inheritDoc}
hazelcast/src/main/java/com/hazelcast/internal/util/collection/LongHashSet.java:214
← previousnext →17,001–17,100 of 147,315, ranked by callers