MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

↓ 2 callersMethodindexOf
(T[] array, T object)
hazelcast/src/main/java/com/hazelcast/internal/util/collection/ArrayUtils.java:105
↓ 2 callersMethodindexOf
(HazelcastInstance[] instances, HazelcastInstance instance)
hazelcast/src/main/java/com/hazelcast/instance/impl/OutOfMemoryErrorDispatcher.java:133
↓ 2 callersMethodindexOfInternal
(boolean last, @Nonnull Object o)
hazelcast/src/main/java/com/hazelcast/collection/impl/list/ListProxyImpl.java:104
↓ 2 callersMethodindexProvider
@param indexProvider the index provider @return this builder instance
hazelcast/src/main/java/com/hazelcast/query/impl/IndexRegistry.java:664
↓ 2 callersMethodindexType
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/SqlPlanImpl.java:401
↓ 2 callersMethodinflateIfNeeded
()
hazelcast/src/main/java/com/hazelcast/internal/util/collection/InflatableSet.java:200
↓ 2 callersMethodinheritsFromWhiteListedClass
(Class<?> klass)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/DataSerializableConventionsTest.java:287
↓ 2 callersMethodinit
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/inject/AvroUpsertTarget.java:157
↓ 2 callersMethodinit
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/inject/HazelcastJsonUpsertTarget.java:143
↓ 2 callersMethodinit
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/inject/HazelcastObjectUpsertTarget.java:48
↓ 2 callersMethodinit
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/inject/JsonUpsertTarget.java:121
↓ 2 callersMethodinit
()
hazelcast/src/test/java/com/hazelcast/journal/AbstractEventJournalExpiringTest.java:60
↓ 2 callersMethodinit
()
hazelcast/src/test/java/com/hazelcast/map/EntryListenerConfigTest.java:155
↓ 2 callersMethodinit
Initializes the Offload. <p> As part of the initialization, the {@link OperationResponseHandler} of the offloaded {@link Operation} is replaced by a d
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/Offload.java:115
↓ 2 callersMethodinit
()
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/compact/Schema.java:62
↓ 2 callersMethodinit
Called on each cluster member after deserialization.
hazelcast/src/main/java/com/hazelcast/jet/core/ProcessorSupplier.java:45
↓ 2 callersMethodinit
Callback that injects the Hazelcast's default partitioning strategy into this partitioner, so it can be consulted by the {@link #getPartition(Object,
hazelcast/src/main/java/com/hazelcast/jet/core/Partitioner.java:83
↓ 2 callersMethodinit
(RecordStore recordStore, MapOperation operation)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/steps/engine/State.java:133
↓ 2 callersMethodinit
(int maxSize)
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/accumulator/DefaultCyclicBuffer.java:49
↓ 2 callersMethodinit
(final int p, final byte[] register)
hazelcast/src/main/java/com/hazelcast/cardinality/impl/hyperloglog/impl/DenseHyperLogLogEncoder.java:56
↓ 2 callersMethodinit
(int p, VariableLengthDiffArray register)
hazelcast/src/main/java/com/hazelcast/cardinality/impl/hyperloglog/impl/SparseHyperLogLogEncoder.java:59
↓ 2 callersMethodinit
(Properties properties)
hazelcast/src/main/java/com/hazelcast/config/replacer/PropertyReplacer.java:31
↓ 2 callersMethodinitAndGetConfig
()
hazelcast/src/test/java/com/hazelcast/ringbuffer/impl/RingbufferAbstractTest.java:81
↓ 2 callersMethodinitChannelForText
(String protocol, boolean restApi)
hazelcast/src/main/java/com/hazelcast/internal/server/tcp/UnifiedProtocolDecoder.java:175
↓ 2 callersMethodinitConfigSearcher
()
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/DynamicConfigurationAwareConfig.java:1212
↓ 2 callersMethodinitCurrentMap
()
hazelcast/src/main/java/com/hazelcast/jet/impl/util/AsyncSnapshotWriterImpl.java:272
↓ 2 callersMethodinitCurrentOperationData
(OperationRunner[] operationRunners)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationexecutor/slowoperationdetector/SlowOperationDetector.java:115
↓ 2 callersMethodinitDefault
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/type/UdtObjectToJsonFunctionTest.java:86
↓ 2 callersMethodinitEndpoint
()
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/task/AbstractMessageTask.java:133
↓ 2 callersMethodinitExecution
Initiates the given execution if the local node accepts the coordinator as its master, and has an up-to-date member list information. <ul><li> If
hazelcast/src/main/java/com/hazelcast/jet/impl/JobExecutionService.java:334
↓ 2 callersMethodinitIncomingQueue
(Queue<byte[]> incomingQueue)
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/ReceiverTasklet.java:323
↓ 2 callersMethodinitInvocationTarget
Initializes the invocation target. @throws Exception if the initialization was a failure
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/Invocation.java:267
↓ 2 callersMethodinitListIfNull
(List<DelayedEntry> list, int capacity)
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/writebehind/StoreWorker.java:163
↓ 2 callersMethodinitNetwork
()
extensions/cdc-mysql/src/test/java/com/hazelcast/jet/cdc/mysql/MySqlCdcNetworkIntegrationTest.java:364
↓ 2 callersMethodinitNetwork
()
extensions/cdc-postgres/src/test/java/com/hazelcast/jet/cdc/postgres/PostgresCdcNetworkIntegrationTest.java:384
↓ 2 callersMethodinitNetworkConfig
(NetworkConfig networkConfig, int basePort, int portSeed, boolean multicast, int nodeCount)
hazelcast/src/test/java/com/hazelcast/cluster/JoinStressTest.java:224
↓ 2 callersMethodinitPartitionReplica
(int partitionId)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheService.java:309
↓ 2 callersMethodinitProcessor
(Processor processor, TestOutbox outbox)
hazelcast/src/main/java/com/hazelcast/jet/core/test/TestSupport.java:1028
↓ 2 callersMethodinitProxy
(ToxiproxyContainer toxiproxy)
extensions/cdc-mysql/src/test/java/com/hazelcast/jet/cdc/mysql/MySqlCdcNetworkIntegrationTest.java:368
↓ 2 callersMethodinitProxy
(ToxiproxyContainer toxiproxy)
extensions/cdc-postgres/src/test/java/com/hazelcast/jet/cdc/postgres/PostgresCdcNetworkIntegrationTest.java:388
↓ 2 callersMethodinitRemovedCountHolders
(int partitionCount)
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/subscriber/SubscriberAccumulatorHandler.java:69
↓ 2 callersMethodinitRepairingHandler
Synchronously makes initial population of partition UUIDs & sequences. <p> This initialization is done for every data structure with a Near Cache.
hazelcast/src/main/java/com/hazelcast/internal/nearcache/impl/invalidation/RepairingTask.java:218
↓ 2 callersMethodinitRowType
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/schema/HazelcastTable.java:115
↓ 2 callersMethodinitSending
(@Nullable Inbox inbox)
extensions/kinesis/src/main/java/com/hazelcast/jet/kinesis/impl/sink/KinesisSinkP.java:187
↓ 2 callersMethodinitState
()
hazelcast/src/test/java/com/hazelcast/spi/tenantcontrol/TenantControlTestSupport.java:50
↓ 2 callersMethodinitToxiproxy
(Network network)
extensions/cdc-mysql/src/test/java/com/hazelcast/jet/cdc/mysql/MySqlCdcNetworkIntegrationTest.java:357
↓ 2 callersMethodinitToxiproxy
(Network network)
extensions/cdc-postgres/src/test/java/com/hazelcast/jet/cdc/postgres/PostgresCdcNetworkIntegrationTest.java:377
↓ 2 callersMethodinitTransientFields
(Map<Integer, VertexDef> vMap, VertexDef nearVertex, boolean isOutbound)
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/init/EdgeDef.java:67
↓ 2 callersMethodinitialize
( @Nonnull Address coordinator, @Nonnull Set<Address> participants, @Nonnu
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/ExecutionContext.java:147
↓ 2 callersMethodinitializeBeforeClass
(TestDatabaseProvider testDatabaseProvider, String... args)
hazelcast/src/test/java/com/hazelcast/jet/impl/connector/ReadJdbcPPropertiesTest.java:62
↓ 2 callersMethodinitializeClientOnCluster
(@Nonnull UUID targetClusterId)
hazelcast/src/main/java/com/hazelcast/client/impl/connection/tcp/TcpClientConnectionManager.java:1332
↓ 2 callersMethodinitializeIfSpringAwareIsPresent
(Object obj)
hazelcast-spring/src/main/java/com/hazelcast/spring/context/SpringManagedContext.java:55
↓ 2 callersMethodinitializeJobExecuteCall
(Path jarPath)
hazelcast/src/main/java/com/hazelcast/jet/impl/JetClientInstanceImpl.java:256
↓ 2 callersMethodinitializeListener
(ListenerConfig listenerConfig)
hazelcast/src/main/java/com/hazelcast/map/impl/proxy/MapProxySupport.java:305
↓ 2 callersMethodinitializePartitionAssignments
Arranges the partitions if: <ul> <li>this instance {@link NodeExtension#isStartCompleted()}</li> <li>the cluster state allows migrations. See {@link C
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/PartitionStateManager.java:63
↓ 2 callersMethodinitializeWitSupplier
(int memberCount, Supplier<Config> configSupplier)
hazelcast/src/test/java/com/hazelcast/jet/SimpleTestInClusterSupport.java:94
↓ 2 callersMethodinitializeWithClientAndConfigSupplier
(int memberCount, Supplier<Config> configSuppl
hazelcast/src/test/java/com/hazelcast/jet/SimpleTestInClusterSupport.java:116
↓ 2 callersMethodinjectCustomStepsToOperation
(MapOperation operation, Step targetStep)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/steps/engine/StepSupplier.java:96
↓ 2 callersMethodinjectDependencies
(Object obj)
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheProxySupport.java:295
↓ 2 callersMethodinjectDependencies
(T obj)
hazelcast/src/main/java/com/hazelcast/client/cache/impl/ClientCacheProxySupport.java:279
↓ 2 callersMethodinlineSchema
(Map<String, String> options, boolean isKey)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/keyvalue/KvMetadataAvroResolver.java:288
↓ 2 callersMethodinputThreadAffinity
(ThreadAffinity inputThreadAffinity)
hazelcast/src/main/java/com/hazelcast/internal/networking/nio/NioNetworking.java:573
↓ 2 callersMethodinsertData
(MySQLContainer<?> container)
extensions/cdc-debezium/src/test/java/com/hazelcast/jet/cdc/MySQLTestUtils.java:53
↓ 2 callersMethodinsertData
(PostgreSQLContainer<?> container)
extensions/cdc-debezium/src/test/java/com/hazelcast/jet/cdc/PostgresTestUtils.java:35
↓ 2 callersMethodinsertDocuments
(String collectionName)
extensions/kafka-connect/src/test/java/com/hazelcast/jet/kafka/connect/KafkaConnectCouchbaseIT.java:192
↓ 2 callersMethodinsertInternal
Associates the given value in this index store with the given record. <p> Despite the name the given value acts as a key into this index store. In oth
hazelcast/src/main/java/com/hazelcast/query/impl/BaseSingleValueIndexStore.java:61
↓ 2 callersMethodinsertIntoMap
(IMap<String, Person> map, List<Person> peopleList)
hazelcast/src/test/java/com/hazelcast/map/impl/operation/MapFetchIndexOperationTest.java:539
↓ 2 callersMethodinsertItems
(String connectionUrl, String tableName)
extensions/kafka-connect/src/test/java/com/hazelcast/jet/kafka/connect/KafkaConnectJdbcIT.java:406
↓ 2 callersMethodinsertLiterals
Inserts the specified record into the given mapping by converting values into string and using row syntax {@code (...)} for nested fields.
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlTestSupport.java:799
↓ 2 callersMethodinsertNodes
(String sourceName, String prefix)
extensions/kafka-connect/src/test/java/com/hazelcast/jet/kafka/connect/KafkaConnectNeo4jIT.java:247
↓ 2 callersMethodinstancesResponse
Reponse recorded from the real Cloud Compute API call.
hazelcast/src/test/java/com/hazelcast/gcp/GcpComputeApiTest.java:115
↓ 2 callersMethodinstantiateExtractor
(AttributeConfig attributeConfig)
hazelcast/src/test/java/com/hazelcast/query/impl/getters/ExtractorHelperTest.java:250
↓ 2 callersMethodinstantiateExtractor
(AttributeConfig config, ClassLoader classLoader)
hazelcast/src/main/java/com/hazelcast/query/impl/getters/ExtractorHelper.java:49
↓ 2 callersMethodinstantiateExtractors
(List<AttributeConfig> attributeConfigs, ClassLoa
hazelcast/src/main/java/com/hazelcast/query/impl/getters/ExtractorHelper.java:36
↓ 2 callersMethodinstrument
(NodeEngine nodeEngine)
hazelcast/src/main/java/com/hazelcast/ringbuffer/impl/RingbufferStoreWrapper.java:171
↓ 2 callersMethodintWrapperGenericRecord
(Class<?> topClazz, String otherField, int n)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/NestedReflectiveRestrictionTest.java:127
↓ 2 callersMethodintegrationTest
(ProcessingGuarantee guarantee)
extensions/kafka/src/test/java/com/hazelcast/jet/kafka/impl/StreamKafkaPTest.java:383
↓ 2 callersMethodinterceptGet
(State state)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/steps/EntryOpSteps.java:369
↓ 2 callersMethodinterceptLockOperation
()
hazelcast/src/main/java/com/hazelcast/internal/locksupport/operations/AbstractLockOperation.java:124
↓ 2 callersMethodinterceptSocket
(EndpointQualifier endpointQualifier, Socket socket, boolean onAccept)
hazelcast/src/main/java/com/hazelcast/internal/server/ServerContext.java:100
↓ 2 callersMethodinterfacesConfigXmlGenerator
(XmlGenerator gen, InterfacesConfig interfaces)
hazelcast/src/main/java/com/hazelcast/config/ConfigXmlGenerator.java:766
↓ 2 callersMethodinterfacesConfigYamlGenerator
(Map<String, Object> parent, InterfacesConfig interfaces)
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/DynamicConfigYamlGenerator.java:926
↓ 2 callersMethodinternalRunQuick
Quick run which just executes the {@link IMap} methods once and check for the {@link QueryResultSizeExceededException}. <p> This method requires the m
hazelcast/src/test/java/com/hazelcast/map/MapUnboundedReturnValuesTestSupport.java:262
↓ 2 callersMethodinterruptBackupTask
Interrupts the backup tasks on each cluster member if one is currently running. The contents of the target backup directories will be left as-is. @si
hazelcast/src/main/java/com/hazelcast/persistence/PersistenceService.java:73
↓ 2 callersMethodinterruptCurrentThread
(final int delayMillis)
hazelcast/src/test/java/com/hazelcast/test/HazelcastTestSupport.java:369
↓ 2 callersMethodintersect
(RangePredicate predicate)
hazelcast/src/main/java/com/hazelcast/query/impl/predicates/RangeVisitor.java:261
↓ 2 callersMethodinvalidate
(SqlPlan plan)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/plan/cache/PlanCache.java:60
↓ 2 callersMethodinvalidate
(WaitSetEntry entry)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationparker/impl/OperationParkerImpl.java:321
↓ 2 callersMethodinvalidateAll
(UUID callerUuid)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationparker/impl/WaitSet.java:284
↓ 2 callersMethodinvalidateAllKeysInNearCaches
This method helps to add clearing Near Cache event only from one-partition which matches partitionId of the map name.
hazelcast/src/main/java/com/hazelcast/map/impl/operation/MapOperation.java:435
↓ 2 callersMethodinvalidateNearCache
(Object nearCacheKey)
hazelcast/src/main/java/com/hazelcast/map/impl/tx/TransactionalMapProxySupport.java:181
↓ 2 callersMethodinverse
(final ClientSelector clientSelector)
hazelcast/src/main/java/com/hazelcast/client/impl/ClientSelectors.java:153
↓ 2 callersMethodinvertBit
Inverts n-th bit of the byte value @param value byte value @param bit n-th bit @return value
hazelcast/src/main/java/com/hazelcast/internal/nio/Bits.java:243
↓ 2 callersMethodinvoke
(Object object, String methodName, Object... args)
extensions/kafka/src/main/java/com/hazelcast/jet/kafka/impl/ResumeTransactionUtil.java:86
↓ 2 callersMethodinvoke
Invokes the given {@link InvocationOnMock} and returns a proxied result, if needed. <p> This method is used for most invocations and tries to resolve
hazelcast/src/test/java/com/hazelcast/test/starter/answer/AbstractAnswer.java:171
↓ 2 callersMethodinvoke
(OperationService operationService, Operation operation)
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheIterator.java:86
↓ 2 callersMethodinvoke
(K key, EntryProcessor<K, V, T> entryProcessor, Object... arguments)
hazelcast/src/main/java/com/hazelcast/client/cache/impl/ClientCacheProxy.java:251
↓ 2 callersMethodinvoke
(ClientListenerRegistration listenerRegistration, ClientConnection connection)
hazelcast/src/main/java/com/hazelcast/client/impl/spi/impl/listener/ClientListenerServiceImpl.java:215
↓ 2 callersMethodinvoke
(Function<ClientMessage, Object> decoder, ClientInvocation invocation)
hazelcast/src/main/java/com/hazelcast/jet/impl/JetClientInstanceImpl.java:350
↓ 2 callersMethodinvoke
Executes the operation on all targets.
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/impl/InvokeOnMembers.java:72
← previousnext →19,401–19,500 of 147,315, ranked by callers