MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

↓ 3 callersMethodaddLocalPartitionLostListener
(PartitionLostListener partitionLostListener)
hazelcast/src/main/java/com/hazelcast/internal/partition/IPartitionService.java:148
↓ 3 callersMethodaddOperation
(Operation op)
hazelcast/src/main/java/com/hazelcast/multimap/impl/txn/MultiMapTransactionLogRecord.java:98
↓ 3 callersMethodaddPackage
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 callersMethodaddPartition
(int replicaIndex, Integer partitionId)
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/PartitionStateGeneratorImpl.java:418
↓ 3 callersMethodaddPartitionLostListenerAsync
(PartitionLostListener partitionLostListener)
hazelcast/src/main/java/com/hazelcast/internal/partition/IPartitionService.java:146
↓ 3 callersMethodaddPossibleAddresses
(final Set<Address> possibleAddresses, final String host, final InetAddr
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/TcpIpJoiner.java:413
↓ 3 callersMethodaddProxyListener
(DistributedObjectListener distributedObjectListener)
hazelcast/src/main/java/com/hazelcast/spi/impl/proxyservice/ProxyService.java:59
↓ 3 callersMethodaddResult
(int partitionId, Result result)
hazelcast/src/main/java/com/hazelcast/map/impl/query/QueryOperation.java:218
↓ 3 callersMethodaddResultSet
TODO
hazelcast/src/main/java/com/hazelcast/query/impl/MultiResultSet.java:33
↓ 3 callersMethodaddToDeadlines
(K key, long deadline)
hazelcast/src/main/java/com/hazelcast/jet/impl/processor/SessionWindowP.java:225
↓ 3 callersMethodaddToMapEntrySet
(Object key, Object value, MapEntries mapEntries)
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/DefaultRecordStore.java:897
↓ 3 callersMethodaddTransient
(K key, long now)
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/MapDataStore.java:49
↓ 3 callersMethodaddValues
(List<ValueContainer> containerList, ValueContainer.ValueType valueType)
hazelcast/src/test/java/com/hazelcast/aggregation/TestSamples.java:167
↓ 3 callersMethodaddrOfIndex
(long index)
hazelcast/src/main/java/com/hazelcast/internal/util/sort/IntMemArrayQuickSorter.java:59
↓ 3 callersMethodaddrOfIndex
(long index)
hazelcast/src/main/java/com/hazelcast/internal/util/sort/LongMemArrayQuickSorter.java:59
↓ 3 callersMethodadvance
()
hazelcast/src/main/java/com/hazelcast/internal/util/ConcurrentReferenceHashMap.java:1716
↓ 3 callersMethodadvance
(IteratorImpl iterator)
hazelcast/src/main/java/com/hazelcast/query/impl/bitmap/SparseBitSet.java:1040
↓ 3 callersMethodadvance
()
hazelcast/src/main/java/com/hazelcast/query/impl/bitmap/AscendingLongIterator.java:40
↓ 3 callersMethodadvanceTime
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/cache/PlanCacheTestSupport.java:86
↓ 3 callersMethodafterFactoriesCreated
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 callersMethodafterRun
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 callersMethodafterRun
(Operation op)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/OperationRunnerImpl.java:382
↓ 3 callersMethodaggregateOperation
( RelDataType inputType, ImmutableBitSet groupSet, List<AggregateCall> agg
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/AggregateAbstractPhysicalRule.java:65
↓ 3 callersMethodaliasedDiscoveryConfigsGenerator
(XmlGenerator gen, List<AliasedDiscoveryConfig<?>> configs)
hazelcast/src/main/java/com/hazelcast/client/config/ClientConfigXmlGenerator.java:546
↓ 3 callersMethodallSame
(boolean... booleans)
extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/dataconnection/MongoDataConnection.java:143
↓ 3 callersMethodallocateArrayAndAdjustFields
(long size, long newCapacity)
hazelcast/src/main/java/com/hazelcast/internal/util/hashslot/impl/HashSlotArrayBase.java:310
↓ 3 callersMethodanyOf
(Exception e, Class<? extends Exception>[] exceptions)
extensions/elasticsearch/elasticsearch-7/src/main/java/com/hazelcast/jet/elastic/impl/RetryUtils.java:75
↓ 3 callersMethodanyOfEc2PropertiesConfigured
()
hazelcast/src/main/java/com/hazelcast/aws/AwsConfig.java:134
↓ 3 callersMethodanyOfEcsPropertiesConfigured
()
hazelcast/src/main/java/com/hazelcast/aws/AwsConfig.java:138
↓ 3 callersMethodappend
(int member)
hazelcast/src/main/java/com/hazelcast/query/impl/bitmap/SparseBitSet.java:651
↓ 3 callersMethodappend
(short member)
hazelcast/src/main/java/com/hazelcast/query/impl/bitmap/SparseBitSet.java:1098
↓ 3 callersMethodappendPadding
(AttributedStringBuilder builder, int length, char paddingChar)
hazelcast/src/main/java/com/hazelcast/client/console/SqlConsole.java:471
↓ 3 callersMethodappendPredicate
(StringBuilder sb, RexNode predicate, List<Integer> parameterPositions)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/jdbc/AbstractQueryBuilder.java:68
↓ 3 callersMethodappendQueryParams
(StringBuilder sb, int n)
extensions/mapstore/src/main/java/com/hazelcast/mapstore/Queries.java:142
↓ 3 callersMethodappendSelectorInfo
( NioThread minThread, Map<NioThread, Set<MigratablePipeline>> pipelinesPerOwner,
hazelcast/src/main/java/com/hazelcast/internal/networking/nio/iobalancer/LoadTracker.java:218
↓ 3 callersMethodappendTenantControl
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 callersMethodapply
(String providerName, ConfigNode config, T target)
hazelcast/src/main/java/com/hazelcast/internal/config/override/ExternalConfigurationOverride.java:123
↓ 3 callersMethodapply
(Map.Entry mapEntry)
hazelcast/src/main/java/com/hazelcast/query/impl/predicates/NotEqualPredicate.java:61
↓ 3 callersMethodapplyIfPresent
@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 callersMethodapplyToEither
()
hazelcast/src/test/java/com/hazelcast/spi/impl/CompletableFutureAbstractTest.java:1098
↓ 3 callersMethodareMigrationTasksAllowed
()
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/InternalPartitionServiceImpl.java:1190
↓ 3 callersMethodarrayRemove
(long[] array, int partitionIndex)
hazelcast/src/main/java/com/hazelcast/jet/core/EventTimeMapper.java:334
↓ 3 callersMethodasDecimal
(Object val)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/converter/ObjectConverter.java:73
↓ 3 callersMethodasDense
()
hazelcast/src/main/java/com/hazelcast/cardinality/impl/hyperloglog/impl/SparseHyperLogLogEncoder.java:134
↓ 3 callersMethodasDouble
(Object val)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/converter/ObjectConverter.java:83
↓ 3 callersMethodasLoginModuleConfigs
Converts current configuration to stack of login modules. @return login modules stack
hazelcast/src/main/java/com/hazelcast/config/security/AuthenticationConfig.java:31
↓ 3 callersMethodasReal
(Object val)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/converter/ObjectConverter.java:78
↓ 3 callersMethodasSetWithout
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 callersMethodasTimestamp
(Object val)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/converter/ObjectConverter.java:98
↓ 3 callersMethodasTimestampWithTimezone
(Object val)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/converter/ObjectConverter.java:103
↓ 3 callersMethodassembleSupplier
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 callersMethodassertAddressesRemoved
(UUID memberUuid, Set<Address> removedAddresses)
hazelcast/src/test/java/com/hazelcast/internal/server/tcp/LocalAddressRegistryTest.java:180
↓ 3 callersMethodassertAllClientsNotRunning
()
extensions/elasticsearch/elasticsearch-7/src/test/java/com/hazelcast/jet/elastic/ClientHolder.java:40
↓ 3 callersMethodassertAllTtlSchedulersEmpty
(ReplicatedMap<Integer, Integer> map)
hazelcast/src/test/java/com/hazelcast/replicatedmap/ReplicatedMapTtlTest.java:162
↓ 3 callersMethodassertAlmostEquals
(long expected, long found)
hazelcast/src/test/java/com/hazelcast/internal/metrics/metricsets/FileMetricSetTest.java:87
↓ 3 callersMethodassertBackupLogCreationForced
(String serviceName)
hazelcast/src/test/java/com/hazelcast/transaction/impl/TransactionContextImpl_backupLogsTest.java:87
↓ 3 callersMethodassertBalanced
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 callersMethodassertCacheTenantControlCreated
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/spi/tenantcontrol/TenantControlTest.java:241
↓ 3 callersMethodassertCancelled
(WaitSet waitSet, BlockedOperation operation, Exception cause)
hazelcast/src/test/java/com/hazelcast/spi/impl/operationparker/impl/WaitSetTest.java:210
↓ 3 callersMethodassertClassLoadersTypes
()
hazelcast/src/test/java/com/hazelcast/jet/impl/deployment/JetClassLoaderTest.java:351
↓ 3 callersMethodassertCommitted
(TransactionImpl tx)
hazelcast/src/test/java/com/hazelcast/transaction/impl/TransactionImpl_TwoPhaseIT.java:73
↓ 3 callersMethodassertContainsFused
(DAG dag, boolean expectedContains)
hazelcast/src/test/java/com/hazelcast/jet/pipeline/StreamStageTest.java:376
↓ 3 callersMethodassertCountAggregatorsAnyCornerCase
(IMap<Integer, Person> map, String p, long value, P
hazelcast/src/test/java/com/hazelcast/aggregation/AggregatorsSpecTest.java:425
↓ 3 callersMethodassertCounts
(Map<String, Long> wordCounts)
hazelcast/src/test/java/com/hazelcast/jet/benchmark/WordCountTest.java:247
↓ 3 callersMethodassertDeserializationFails
(JavaSerializationFilterConfig javaSerializationFilterConfig, bool
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/DeserializationProtectionTest.java:119
↓ 3 callersMethodassertDistinctAggregatorsAnyCornerCase
(IMap<Integer, Person> map, String p, Set result, Predicate<Integer, Person> predicate)
hazelcast/src/test/java/com/hazelcast/aggregation/AggregatorsSpecTest.java:438
↓ 3 callersMethodassertDistributedObjectCountEventually
(final int expectedCount, final HazelcastInstance hz)
hazelcast/src/test/java/com/hazelcast/core/ProxySplitBrainTest.java:59
↓ 3 callersMethodassertEntryProcessorOperation
(SlowOperationLog log)
hazelcast/src/test/java/com/hazelcast/spi/impl/operationexecutor/slowoperationdetector/SlowOperationDetectorAbstractTest.java:134
↓ 3 callersMethodassertEntrySetSizeEventually
(final int expectedSize, final Predicate predicate, final QueryC
hazelcast/src/test/java/com/hazelcast/client/map/impl/querycache/ClientQueryCacheMethodsWithPredicateTest.java:318
↓ 3 callersMethodassertEntrySetSizeEventually
(final int expectedSize, final Predicate predicate, final QueryC
hazelcast/src/test/java/com/hazelcast/map/impl/querycache/QueryCacheMethodsWithPredicateTest.java:372
↓ 3 callersMethodassertEqualAndHashCode
(Object o1, Object o2)
hazelcast/src/test/java/com/hazelcast/internal/cluster/impl/MembersViewMetadataTest.java:86
↓ 3 callersMethodassertEventEmittedEventually
(DiagnosticsConfig expCfg, CountDownLatch latch, List<Event> events)
hazelcast/src/test/java/com/hazelcast/internal/diagnostics/DiagnosticsConfigUpdatedEventTest.java:136
↓ 3 callersMethodassertEventEventually
(final EventCollectingPartitionLostListener listener, final IPartitionLostEvent internalEvent)
hazelcast/src/test/java/com/hazelcast/partition/PartitionLostListenerTest.java:203
↓ 3 callersMethodassertExceptionIgnored
(Exception exception)
hazelcast/src/test/java/com/hazelcast/internal/util/SerialOperationInvokerTest.java:265
↓ 3 callersMethodassertExceptionIgnored
(Exception exception)
hazelcast/src/test/java/com/hazelcast/internal/util/ParallelOperationInvokerTest.java:217
↓ 3 callersMethodassertExceptionInCauses
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 callersMethodassertExecutionContext
(Address callerAddress, long jobId, long executionId, Strin
hazelcast/src/main/java/com/hazelcast/jet/impl/JobExecutionService.java:493
↓ 3 callersMethodassertExpiryMetadata
(ExpiryMetadata storedMetadata, long ttl, long maxIdle, long expirationTime, long lastUpdateTime)
hazelcast/src/test/java/com/hazelcast/map/impl/recordstore/expiry/ExpirySystemTest.java:187
↓ 3 callersMethodassertFinalValueEquals
(final int expected, final int actual)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/writebehind/WriteBehindMapStoreWithEvictionsTest.java:283
↓ 3 callersMethodassertHandlersAreStillCorrect
()
hazelcast/src/test/java/com/hazelcast/scheduledexecutor/impl/ScheduledExecutorSplitBrainTest.java:271
↓ 3 callersMethodassertHasNoListenerEventually
(String jobIdString, UUID registrationId)
hazelcast/src/test/java/com/hazelcast/jet/JobStatusListenerTest.java:284
↓ 3 callersMethodassertIndexEqual
(String expectedAttribute, boolean expectedOrdered, IndexConfig indexConfig)
hazelcast/src/test/java/com/hazelcast/config/YamlConfigBuilderTest.java:3084
↓ 3 callersMethodassertIndexEqual
(String expectedAttribute, boolean expectedOrdered, IndexConfig indexConfig)
hazelcast/src/test/java/com/hazelcast/config/XMLConfigBuilderTest.java:2758
↓ 3 callersMethodassertInterceptorRegistryContainsInterceptor
()
hazelcast/src/test/java/com/hazelcast/map/impl/InterceptorRegistryTest.java:170
↓ 3 callersMethodassertInterceptorRegistryContainsNotInterceptor
()
hazelcast/src/test/java/com/hazelcast/map/impl/InterceptorRegistryTest.java:179
↓ 3 callersMethodassertInvalidation
(Invalidation expected, Invalidation actual, boolean hasKey)
hazelcast/src/test/java/com/hazelcast/map/impl/nearcache/invalidation/InvalidationTest.java:88
↓ 3 callersMethodassertIsDestroyed
(TcpServerConnection connection)
hazelcast/src/test/java/com/hazelcast/internal/server/tcp/TcpServerConnectionManager_AbstractConnectMemberTest.java:104
↓ 3 callersMethodassertJdbcQueryRowsAnyOrder
(String query, Row... rows)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/jdbc/JdbcSqlTestSupport.java:275
↓ 3 callersMethodassertJobFailsWithConnectException
(Job job, boolean lenient)
extensions/cdc-mysql/src/test/java/com/hazelcast/jet/cdc/mysql/MySqlCdcNetworkIntegrationTest.java:396
↓ 3 callersMethodassertKeySetSizeEventually
(final int expectedSize, final Predicate predicate, final QueryCac
hazelcast/src/test/java/com/hazelcast/client/map/impl/querycache/ClientQueryCacheMethodsWithPredicateTest.java:307
↓ 3 callersMethodassertKeySetSizeEventually
(final int expectedSize, final Predicate predicate, final QueryCac
hazelcast/src/test/java/com/hazelcast/client/map/impl/querycache/ClientQueryCacheIndexTest.java:262
↓ 3 callersMethodassertKeySetSizeEventually
(final int expectedSize, final Predicate predicate, final QueryCac
hazelcast/src/test/java/com/hazelcast/map/impl/querycache/QueryCacheMethodsWithPredicateTest.java:361
↓ 3 callersMethodassertLastNearCachePersistence
(NearCacheTestContext context, File defaultStoreFile, int keyCount)
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/AbstractNearCachePreloaderTest.java:456
↓ 3 callersMethodassertLockedBy
(Address initiator)
hazelcast/src/test/java/com/hazelcast/internal/cluster/impl/ClusterStateManagerTest.java:276
↓ 3 callersMethodassertMapImpl
(IMap map)
hazelcast/src/test/java/com/hazelcast/map/IMapAccessors.java:99
↓ 3 callersMethodassertMapProxyInitializedEventually
(String indexMapName)
hazelcast/src/test/java/com/hazelcast/client/map/ClientIndexStatsTest.java:205
↓ 3 callersMethodassertMaxAggregatorsAnyCornerCase
(IMap<Integer, Person> map, String p, Predicate<Integer, Person> predicate)
hazelcast/src/test/java/com/hazelcast/aggregation/AggregatorsSpecTest.java:364
↓ 3 callersMethodassertMaxByAggregatorAnyCornerCase
(IMap<Integer, Person> map, String p, Predicate<Integer, Person> predicate)
hazelcast/src/test/java/com/hazelcast/aggregation/AggregatorsSpecTest.java:332
↓ 3 callersMethodassertMembersViewEquals
(MemberImpl[] members, MembersView view)
hazelcast/src/test/java/com/hazelcast/internal/cluster/impl/MembersViewTest.java:149
↓ 3 callersMethodassertMigrationSourceCommit
(final MigrationInfo migration)
hazelcast/src/test/java/com/hazelcast/internal/partition/impl/MigrationCommitServiceTest.java:414
← previousnext →13,401–13,500 of 147,315, ranked by callers