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
↓ 3 callers
Method
addLocalPartitionLostListener
(PartitionLostListener partitionLostListener)
hazelcast/src/main/java/com/hazelcast/internal/partition/IPartitionService.java:148
↓ 3 callers
Method
addOperation
(Operation op)
hazelcast/src/main/java/com/hazelcast/multimap/impl/txn/MultiMapTransactionLogRecord.java:98
↓ 3 callers
Method
addPackage
Adds recursively all the classes and resources in given packages to the Jet job's classpath. They will be accessible to all the code attached to the u
hazelcast/src/main/java/com/hazelcast/jet/config/JobConfig.java:340
↓ 3 callers
Method
addPartition
(int replicaIndex, Integer partitionId)
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/PartitionStateGeneratorImpl.java:418
↓ 3 callers
Method
addPartitionLostListenerAsync
(PartitionLostListener partitionLostListener)
hazelcast/src/main/java/com/hazelcast/internal/partition/IPartitionService.java:146
↓ 3 callers
Method
addPossibleAddresses
(final Set<Address> possibleAddresses, final String host, final InetAddr
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/TcpIpJoiner.java:413
↓ 3 callers
Method
addProxyListener
(DistributedObjectListener distributedObjectListener)
hazelcast/src/main/java/com/hazelcast/spi/impl/proxyservice/ProxyService.java:59
↓ 3 callers
Method
addResult
(int partitionId, Result result)
hazelcast/src/main/java/com/hazelcast/map/impl/query/QueryOperation.java:218
↓ 3 callers
Method
addResultSet
TODO
hazelcast/src/main/java/com/hazelcast/query/impl/MultiResultSet.java:33
↓ 3 callers
Method
addToDeadlines
(K key, long deadline)
hazelcast/src/main/java/com/hazelcast/jet/impl/processor/SessionWindowP.java:225
↓ 3 callers
Method
addToMapEntrySet
(Object key, Object value, MapEntries mapEntries)
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/DefaultRecordStore.java:897
↓ 3 callers
Method
addTransient
(K key, long now)
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/MapDataStore.java:49
↓ 3 callers
Method
addValues
(List<ValueContainer> containerList, ValueContainer.ValueType valueType)
hazelcast/src/test/java/com/hazelcast/aggregation/TestSamples.java:167
↓ 3 callers
Method
addrOfIndex
(long index)
hazelcast/src/main/java/com/hazelcast/internal/util/sort/IntMemArrayQuickSorter.java:59
↓ 3 callers
Method
addrOfIndex
(long index)
hazelcast/src/main/java/com/hazelcast/internal/util/sort/LongMemArrayQuickSorter.java:59
↓ 3 callers
Method
advance
()
hazelcast/src/main/java/com/hazelcast/internal/util/ConcurrentReferenceHashMap.java:1716
↓ 3 callers
Method
advance
(IteratorImpl iterator)
hazelcast/src/main/java/com/hazelcast/query/impl/bitmap/SparseBitSet.java:1040
↓ 3 callers
Method
advance
()
hazelcast/src/main/java/com/hazelcast/query/impl/bitmap/AscendingLongIterator.java:40
↓ 3 callers
Method
advanceTime
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/cache/PlanCacheTestSupport.java:86
↓ 3 callers
Method
afterFactoriesCreated
Gives the hook a chance to further configure factories after all factories were created. It can be used for configuring constructors for classes in su
hazelcast/src/main/java/com/hazelcast/internal/serialization/DataSerializerHook.java:39
↓ 3 callers
Method
afterRun
Is executed called after {@link #run()} or {@link #call()} method completes normally and the operation is not blocked, see {@link CallStatus#WAIT}. R
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/Operation.java:202
↓ 3 callers
Method
afterRun
(Operation op)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/OperationRunnerImpl.java:382
↓ 3 callers
Method
aggregateOperation
( RelDataType inputType, ImmutableBitSet groupSet, List<AggregateCall> agg
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/AggregateAbstractPhysicalRule.java:65
↓ 3 callers
Method
aliasedDiscoveryConfigsGenerator
(XmlGenerator gen, List<AliasedDiscoveryConfig<?>> configs)
hazelcast/src/main/java/com/hazelcast/client/config/ClientConfigXmlGenerator.java:546
↓ 3 callers
Method
allSame
(boolean... booleans)
extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/dataconnection/MongoDataConnection.java:143
↓ 3 callers
Method
allocateArrayAndAdjustFields
(long size, long newCapacity)
hazelcast/src/main/java/com/hazelcast/internal/util/hashslot/impl/HashSlotArrayBase.java:310
↓ 3 callers
Method
anyOf
(Exception e, Class<? extends Exception>[] exceptions)
extensions/elasticsearch/elasticsearch-7/src/main/java/com/hazelcast/jet/elastic/impl/RetryUtils.java:75
↓ 3 callers
Method
anyOfEc2PropertiesConfigured
()
hazelcast/src/main/java/com/hazelcast/aws/AwsConfig.java:134
↓ 3 callers
Method
anyOfEcsPropertiesConfigured
()
hazelcast/src/main/java/com/hazelcast/aws/AwsConfig.java:138
↓ 3 callers
Method
append
(int member)
hazelcast/src/main/java/com/hazelcast/query/impl/bitmap/SparseBitSet.java:651
↓ 3 callers
Method
append
(short member)
hazelcast/src/main/java/com/hazelcast/query/impl/bitmap/SparseBitSet.java:1098
↓ 3 callers
Method
appendPadding
(AttributedStringBuilder builder, int length, char paddingChar)
hazelcast/src/main/java/com/hazelcast/client/console/SqlConsole.java:471
↓ 3 callers
Method
appendPredicate
(StringBuilder sb, RexNode predicate, List<Integer> parameterPositions)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/jdbc/AbstractQueryBuilder.java:68
↓ 3 callers
Method
appendQueryParams
(StringBuilder sb, int n)
extensions/mapstore/src/main/java/com/hazelcast/mapstore/Queries.java:142
↓ 3 callers
Method
appendSelectorInfo
( NioThread minThread, Map<NioThread, Set<MigratablePipeline>> pipelinesPerOwner,
hazelcast/src/main/java/com/hazelcast/internal/networking/nio/iobalancer/LoadTracker.java:218
↓ 3 callers
Method
appendTenantControl
Adds the provided tenant control instance which belongs to the provided distributed object. @param serviceName the distributed object service @para
hazelcast/src/main/java/com/hazelcast/spi/impl/tenantcontrol/impl/TenantControlServiceImpl.java:105
↓ 3 callers
Method
apply
(String providerName, ConfigNode config, T target)
hazelcast/src/main/java/com/hazelcast/internal/config/override/ExternalConfigurationOverride.java:123
↓ 3 callers
Method
apply
(Map.Entry mapEntry)
hazelcast/src/main/java/com/hazelcast/query/impl/predicates/NotEqualPredicate.java:61
↓ 3 callers
Method
applyIfPresent
@throws UnsupportedOperationException @throws ClassCastException @throws NullPointerException @implSpec The default implementation is equivalent to pe
hazelcast/src/main/java/com/hazelcast/internal/util/IConcurrentMap.java:92
↓ 3 callers
Method
applyToEither
()
hazelcast/src/test/java/com/hazelcast/spi/impl/CompletableFutureAbstractTest.java:1098
↓ 3 callers
Method
areMigrationTasksAllowed
()
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/InternalPartitionServiceImpl.java:1190
↓ 3 callers
Method
arrayRemove
(long[] array, int partitionIndex)
hazelcast/src/main/java/com/hazelcast/jet/core/EventTimeMapper.java:334
↓ 3 callers
Method
asDecimal
(Object val)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/converter/ObjectConverter.java:73
↓ 3 callers
Method
asDense
()
hazelcast/src/main/java/com/hazelcast/cardinality/impl/hyperloglog/impl/SparseHyperLogLogEncoder.java:134
↓ 3 callers
Method
asDouble
(Object val)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/converter/ObjectConverter.java:83
↓ 3 callers
Method
asLoginModuleConfigs
Converts current configuration to stack of login modules. @return login modules stack
hazelcast/src/main/java/com/hazelcast/config/security/AuthenticationConfig.java:31
↓ 3 callers
Method
asReal
(Object val)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/converter/ObjectConverter.java:78
↓ 3 callers
Method
asSetWithout
Returns set based on the given {@link Collection} of {@link MetricTarget}s and one other to include in the returned set. Set objects are returned from
hazelcast/src/main/java/com/hazelcast/internal/metrics/MetricTarget.java:122
↓ 3 callers
Method
asTimestamp
(Object val)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/converter/ObjectConverter.java:98
↓ 3 callers
Method
asTimestampWithTimezone
(Object val)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/converter/ObjectConverter.java:103
↓ 3 callers
Method
assembleSupplier
Assembles client supplier - if data connection is used, it will set {@link #clientSupplier} to correct supplier based on the data connection.
extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/impl/MongoConnection.java:150
↓ 3 callers
Method
assertAddressesRemoved
(UUID memberUuid, Set<Address> removedAddresses)
hazelcast/src/test/java/com/hazelcast/internal/server/tcp/LocalAddressRegistryTest.java:180
↓ 3 callers
Method
assertAllClientsNotRunning
()
extensions/elasticsearch/elasticsearch-7/src/test/java/com/hazelcast/jet/elastic/ClientHolder.java:40
↓ 3 callers
Method
assertAllTtlSchedulersEmpty
(ReplicatedMap<Integer, Integer> map)
hazelcast/src/test/java/com/hazelcast/replicatedmap/ReplicatedMapTtlTest.java:162
↓ 3 callers
Method
assertAlmostEquals
(long expected, long found)
hazelcast/src/test/java/com/hazelcast/internal/metrics/metricsets/FileMetricSetTest.java:87
↓ 3 callers
Method
assertBackupLogCreationForced
(String serviceName)
hazelcast/src/test/java/com/hazelcast/transaction/impl/TransactionContextImpl_backupLogsTest.java:87
↓ 3 callers
Method
assertBalanced
An owner thread is balanced if it has no more than one "active" pipeline and several non-active pipelines
hazelcast/src/test/java/com/hazelcast/internal/networking/nio/iobalancer/IOBalancerStressTest.java:107
↓ 3 callers
Method
assertCacheTenantControlCreated
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/spi/tenantcontrol/TenantControlTest.java:241
↓ 3 callers
Method
assertCancelled
(WaitSet waitSet, BlockedOperation operation, Exception cause)
hazelcast/src/test/java/com/hazelcast/spi/impl/operationparker/impl/WaitSetTest.java:210
↓ 3 callers
Method
assertClassLoadersTypes
()
hazelcast/src/test/java/com/hazelcast/jet/impl/deployment/JetClassLoaderTest.java:351
↓ 3 callers
Method
assertCommitted
(TransactionImpl tx)
hazelcast/src/test/java/com/hazelcast/transaction/impl/TransactionImpl_TwoPhaseIT.java:73
↓ 3 callers
Method
assertContainsFused
(DAG dag, boolean expectedContains)
hazelcast/src/test/java/com/hazelcast/jet/pipeline/StreamStageTest.java:376
↓ 3 callers
Method
assertCountAggregatorsAnyCornerCase
(IMap<Integer, Person> map, String p, long value, P
hazelcast/src/test/java/com/hazelcast/aggregation/AggregatorsSpecTest.java:425
↓ 3 callers
Method
assertCounts
(Map<String, Long> wordCounts)
hazelcast/src/test/java/com/hazelcast/jet/benchmark/WordCountTest.java:247
↓ 3 callers
Method
assertDeserializationFails
(JavaSerializationFilterConfig javaSerializationFilterConfig, bool
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/DeserializationProtectionTest.java:119
↓ 3 callers
Method
assertDistinctAggregatorsAnyCornerCase
(IMap<Integer, Person> map, String p, Set result, Predicate<Integer, Person> predicate)
hazelcast/src/test/java/com/hazelcast/aggregation/AggregatorsSpecTest.java:438
↓ 3 callers
Method
assertDistributedObjectCountEventually
(final int expectedCount, final HazelcastInstance hz)
hazelcast/src/test/java/com/hazelcast/core/ProxySplitBrainTest.java:59
↓ 3 callers
Method
assertEntryProcessorOperation
(SlowOperationLog log)
hazelcast/src/test/java/com/hazelcast/spi/impl/operationexecutor/slowoperationdetector/SlowOperationDetectorAbstractTest.java:134
↓ 3 callers
Method
assertEntrySetSizeEventually
(final int expectedSize, final Predicate predicate, final QueryC
hazelcast/src/test/java/com/hazelcast/client/map/impl/querycache/ClientQueryCacheMethodsWithPredicateTest.java:318
↓ 3 callers
Method
assertEntrySetSizeEventually
(final int expectedSize, final Predicate predicate, final QueryC
hazelcast/src/test/java/com/hazelcast/map/impl/querycache/QueryCacheMethodsWithPredicateTest.java:372
↓ 3 callers
Method
assertEqualAndHashCode
(Object o1, Object o2)
hazelcast/src/test/java/com/hazelcast/internal/cluster/impl/MembersViewMetadataTest.java:86
↓ 3 callers
Method
assertEventEmittedEventually
(DiagnosticsConfig expCfg, CountDownLatch latch, List<Event> events)
hazelcast/src/test/java/com/hazelcast/internal/diagnostics/DiagnosticsConfigUpdatedEventTest.java:136
↓ 3 callers
Method
assertEventEventually
(final EventCollectingPartitionLostListener listener, final IPartitionLostEvent internalEvent)
hazelcast/src/test/java/com/hazelcast/partition/PartitionLostListenerTest.java:203
↓ 3 callers
Method
assertExceptionIgnored
(Exception exception)
hazelcast/src/test/java/com/hazelcast/internal/util/SerialOperationInvokerTest.java:265
↓ 3 callers
Method
assertExceptionIgnored
(Exception exception)
hazelcast/src/test/java/com/hazelcast/internal/util/ParallelOperationInvokerTest.java:217
↓ 3 callers
Method
assertExceptionInCauses
Asserts that {@code caught} exception is equal to {@code expected} or one of its causes. <p> Exceptions are considered equal, if their {@code message}
hazelcast/src/test/java/com/hazelcast/jet/core/TestUtil.java:67
↓ 3 callers
Method
assertExecutionContext
(Address callerAddress, long jobId, long executionId, Strin
hazelcast/src/main/java/com/hazelcast/jet/impl/JobExecutionService.java:493
↓ 3 callers
Method
assertExpiryMetadata
(ExpiryMetadata storedMetadata, long ttl, long maxIdle, long expirationTime, long lastUpdateTime)
hazelcast/src/test/java/com/hazelcast/map/impl/recordstore/expiry/ExpirySystemTest.java:187
↓ 3 callers
Method
assertFinalValueEquals
(final int expected, final int actual)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/writebehind/WriteBehindMapStoreWithEvictionsTest.java:283
↓ 3 callers
Method
assertHandlersAreStillCorrect
()
hazelcast/src/test/java/com/hazelcast/scheduledexecutor/impl/ScheduledExecutorSplitBrainTest.java:271
↓ 3 callers
Method
assertHasNoListenerEventually
(String jobIdString, UUID registrationId)
hazelcast/src/test/java/com/hazelcast/jet/JobStatusListenerTest.java:284
↓ 3 callers
Method
assertIndexEqual
(String expectedAttribute, boolean expectedOrdered, IndexConfig indexConfig)
hazelcast/src/test/java/com/hazelcast/config/YamlConfigBuilderTest.java:3084
↓ 3 callers
Method
assertIndexEqual
(String expectedAttribute, boolean expectedOrdered, IndexConfig indexConfig)
hazelcast/src/test/java/com/hazelcast/config/XMLConfigBuilderTest.java:2758
↓ 3 callers
Method
assertInterceptorRegistryContainsInterceptor
()
hazelcast/src/test/java/com/hazelcast/map/impl/InterceptorRegistryTest.java:170
↓ 3 callers
Method
assertInterceptorRegistryContainsNotInterceptor
()
hazelcast/src/test/java/com/hazelcast/map/impl/InterceptorRegistryTest.java:179
↓ 3 callers
Method
assertInvalidation
(Invalidation expected, Invalidation actual, boolean hasKey)
hazelcast/src/test/java/com/hazelcast/map/impl/nearcache/invalidation/InvalidationTest.java:88
↓ 3 callers
Method
assertIsDestroyed
(TcpServerConnection connection)
hazelcast/src/test/java/com/hazelcast/internal/server/tcp/TcpServerConnectionManager_AbstractConnectMemberTest.java:104
↓ 3 callers
Method
assertJdbcQueryRowsAnyOrder
(String query, Row... rows)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/jdbc/JdbcSqlTestSupport.java:275
↓ 3 callers
Method
assertJobFailsWithConnectException
(Job job, boolean lenient)
extensions/cdc-mysql/src/test/java/com/hazelcast/jet/cdc/mysql/MySqlCdcNetworkIntegrationTest.java:396
↓ 3 callers
Method
assertKeySetSizeEventually
(final int expectedSize, final Predicate predicate, final QueryCac
hazelcast/src/test/java/com/hazelcast/client/map/impl/querycache/ClientQueryCacheMethodsWithPredicateTest.java:307
↓ 3 callers
Method
assertKeySetSizeEventually
(final int expectedSize, final Predicate predicate, final QueryCac
hazelcast/src/test/java/com/hazelcast/client/map/impl/querycache/ClientQueryCacheIndexTest.java:262
↓ 3 callers
Method
assertKeySetSizeEventually
(final int expectedSize, final Predicate predicate, final QueryCac
hazelcast/src/test/java/com/hazelcast/map/impl/querycache/QueryCacheMethodsWithPredicateTest.java:361
↓ 3 callers
Method
assertLastNearCachePersistence
(NearCacheTestContext context, File defaultStoreFile, int keyCount)
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/AbstractNearCachePreloaderTest.java:456
↓ 3 callers
Method
assertLockedBy
(Address initiator)
hazelcast/src/test/java/com/hazelcast/internal/cluster/impl/ClusterStateManagerTest.java:276
↓ 3 callers
Method
assertMapImpl
(IMap map)
hazelcast/src/test/java/com/hazelcast/map/IMapAccessors.java:99
↓ 3 callers
Method
assertMapProxyInitializedEventually
(String indexMapName)
hazelcast/src/test/java/com/hazelcast/client/map/ClientIndexStatsTest.java:205
↓ 3 callers
Method
assertMaxAggregatorsAnyCornerCase
(IMap<Integer, Person> map, String p, Predicate<Integer, Person> predicate)
hazelcast/src/test/java/com/hazelcast/aggregation/AggregatorsSpecTest.java:364
↓ 3 callers
Method
assertMaxByAggregatorAnyCornerCase
(IMap<Integer, Person> map, String p, Predicate<Integer, Person> predicate)
hazelcast/src/test/java/com/hazelcast/aggregation/AggregatorsSpecTest.java:332
↓ 3 callers
Method
assertMembersViewEquals
(MemberImpl[] members, MembersView view)
hazelcast/src/test/java/com/hazelcast/internal/cluster/impl/MembersViewTest.java:149
↓ 3 callers
Method
assertMigrationSourceCommit
(final MigrationInfo migration)
hazelcast/src/test/java/com/hazelcast/internal/partition/impl/MigrationCommitServiceTest.java:414
← previous
next →
13,401–13,500 of 147,315, ranked by callers