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
indexOf
(T[] array, T object)
hazelcast/src/main/java/com/hazelcast/internal/util/collection/ArrayUtils.java:105
↓ 2 callers
Method
indexOf
(HazelcastInstance[] instances, HazelcastInstance instance)
hazelcast/src/main/java/com/hazelcast/instance/impl/OutOfMemoryErrorDispatcher.java:133
↓ 2 callers
Method
indexOfInternal
(boolean last, @Nonnull Object o)
hazelcast/src/main/java/com/hazelcast/collection/impl/list/ListProxyImpl.java:104
↓ 2 callers
Method
indexProvider
@param indexProvider the index provider @return this builder instance
hazelcast/src/main/java/com/hazelcast/query/impl/IndexRegistry.java:664
↓ 2 callers
Method
indexType
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/SqlPlanImpl.java:401
↓ 2 callers
Method
inflateIfNeeded
()
hazelcast/src/main/java/com/hazelcast/internal/util/collection/InflatableSet.java:200
↓ 2 callers
Method
inheritsFromWhiteListedClass
(Class<?> klass)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/DataSerializableConventionsTest.java:287
↓ 2 callers
Method
init
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/inject/AvroUpsertTarget.java:157
↓ 2 callers
Method
init
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/inject/HazelcastJsonUpsertTarget.java:143
↓ 2 callers
Method
init
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/inject/HazelcastObjectUpsertTarget.java:48
↓ 2 callers
Method
init
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/inject/JsonUpsertTarget.java:121
↓ 2 callers
Method
init
()
hazelcast/src/test/java/com/hazelcast/journal/AbstractEventJournalExpiringTest.java:60
↓ 2 callers
Method
init
()
hazelcast/src/test/java/com/hazelcast/map/EntryListenerConfigTest.java:155
↓ 2 callers
Method
init
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 callers
Method
init
()
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/compact/Schema.java:62
↓ 2 callers
Method
init
Called on each cluster member after deserialization.
hazelcast/src/main/java/com/hazelcast/jet/core/ProcessorSupplier.java:45
↓ 2 callers
Method
init
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 callers
Method
init
(RecordStore recordStore, MapOperation operation)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/steps/engine/State.java:133
↓ 2 callers
Method
init
(int maxSize)
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/accumulator/DefaultCyclicBuffer.java:49
↓ 2 callers
Method
init
(final int p, final byte[] register)
hazelcast/src/main/java/com/hazelcast/cardinality/impl/hyperloglog/impl/DenseHyperLogLogEncoder.java:56
↓ 2 callers
Method
init
(int p, VariableLengthDiffArray register)
hazelcast/src/main/java/com/hazelcast/cardinality/impl/hyperloglog/impl/SparseHyperLogLogEncoder.java:59
↓ 2 callers
Method
init
(Properties properties)
hazelcast/src/main/java/com/hazelcast/config/replacer/PropertyReplacer.java:31
↓ 2 callers
Method
initAndGetConfig
()
hazelcast/src/test/java/com/hazelcast/ringbuffer/impl/RingbufferAbstractTest.java:81
↓ 2 callers
Method
initChannelForText
(String protocol, boolean restApi)
hazelcast/src/main/java/com/hazelcast/internal/server/tcp/UnifiedProtocolDecoder.java:175
↓ 2 callers
Method
initConfigSearcher
()
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/DynamicConfigurationAwareConfig.java:1212
↓ 2 callers
Method
initCurrentMap
()
hazelcast/src/main/java/com/hazelcast/jet/impl/util/AsyncSnapshotWriterImpl.java:272
↓ 2 callers
Method
initCurrentOperationData
(OperationRunner[] operationRunners)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationexecutor/slowoperationdetector/SlowOperationDetector.java:115
↓ 2 callers
Method
initDefault
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/type/UdtObjectToJsonFunctionTest.java:86
↓ 2 callers
Method
initEndpoint
()
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/task/AbstractMessageTask.java:133
↓ 2 callers
Method
initExecution
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 callers
Method
initIncomingQueue
(Queue<byte[]> incomingQueue)
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/ReceiverTasklet.java:323
↓ 2 callers
Method
initInvocationTarget
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 callers
Method
initListIfNull
(List<DelayedEntry> list, int capacity)
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/writebehind/StoreWorker.java:163
↓ 2 callers
Method
initNetwork
()
extensions/cdc-mysql/src/test/java/com/hazelcast/jet/cdc/mysql/MySqlCdcNetworkIntegrationTest.java:364
↓ 2 callers
Method
initNetwork
()
extensions/cdc-postgres/src/test/java/com/hazelcast/jet/cdc/postgres/PostgresCdcNetworkIntegrationTest.java:384
↓ 2 callers
Method
initNetworkConfig
(NetworkConfig networkConfig, int basePort, int portSeed, boolean multicast, int nodeCount)
hazelcast/src/test/java/com/hazelcast/cluster/JoinStressTest.java:224
↓ 2 callers
Method
initPartitionReplica
(int partitionId)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheService.java:309
↓ 2 callers
Method
initProcessor
(Processor processor, TestOutbox outbox)
hazelcast/src/main/java/com/hazelcast/jet/core/test/TestSupport.java:1028
↓ 2 callers
Method
initProxy
(ToxiproxyContainer toxiproxy)
extensions/cdc-mysql/src/test/java/com/hazelcast/jet/cdc/mysql/MySqlCdcNetworkIntegrationTest.java:368
↓ 2 callers
Method
initProxy
(ToxiproxyContainer toxiproxy)
extensions/cdc-postgres/src/test/java/com/hazelcast/jet/cdc/postgres/PostgresCdcNetworkIntegrationTest.java:388
↓ 2 callers
Method
initRemovedCountHolders
(int partitionCount)
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/subscriber/SubscriberAccumulatorHandler.java:69
↓ 2 callers
Method
initRepairingHandler
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 callers
Method
initRowType
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/schema/HazelcastTable.java:115
↓ 2 callers
Method
initSending
(@Nullable Inbox inbox)
extensions/kinesis/src/main/java/com/hazelcast/jet/kinesis/impl/sink/KinesisSinkP.java:187
↓ 2 callers
Method
initState
()
hazelcast/src/test/java/com/hazelcast/spi/tenantcontrol/TenantControlTestSupport.java:50
↓ 2 callers
Method
initToxiproxy
(Network network)
extensions/cdc-mysql/src/test/java/com/hazelcast/jet/cdc/mysql/MySqlCdcNetworkIntegrationTest.java:357
↓ 2 callers
Method
initToxiproxy
(Network network)
extensions/cdc-postgres/src/test/java/com/hazelcast/jet/cdc/postgres/PostgresCdcNetworkIntegrationTest.java:377
↓ 2 callers
Method
initTransientFields
(Map<Integer, VertexDef> vMap, VertexDef nearVertex, boolean isOutbound)
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/init/EdgeDef.java:67
↓ 2 callers
Method
initialize
( @Nonnull Address coordinator, @Nonnull Set<Address> participants, @Nonnu
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/ExecutionContext.java:147
↓ 2 callers
Method
initializeBeforeClass
(TestDatabaseProvider testDatabaseProvider, String... args)
hazelcast/src/test/java/com/hazelcast/jet/impl/connector/ReadJdbcPPropertiesTest.java:62
↓ 2 callers
Method
initializeClientOnCluster
(@Nonnull UUID targetClusterId)
hazelcast/src/main/java/com/hazelcast/client/impl/connection/tcp/TcpClientConnectionManager.java:1332
↓ 2 callers
Method
initializeIfSpringAwareIsPresent
(Object obj)
hazelcast-spring/src/main/java/com/hazelcast/spring/context/SpringManagedContext.java:55
↓ 2 callers
Method
initializeJobExecuteCall
(Path jarPath)
hazelcast/src/main/java/com/hazelcast/jet/impl/JetClientInstanceImpl.java:256
↓ 2 callers
Method
initializeListener
(ListenerConfig listenerConfig)
hazelcast/src/main/java/com/hazelcast/map/impl/proxy/MapProxySupport.java:305
↓ 2 callers
Method
initializePartitionAssignments
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 callers
Method
initializeWitSupplier
(int memberCount, Supplier<Config> configSupplier)
hazelcast/src/test/java/com/hazelcast/jet/SimpleTestInClusterSupport.java:94
↓ 2 callers
Method
initializeWithClientAndConfigSupplier
(int memberCount, Supplier<Config> configSuppl
hazelcast/src/test/java/com/hazelcast/jet/SimpleTestInClusterSupport.java:116
↓ 2 callers
Method
injectCustomStepsToOperation
(MapOperation operation, Step targetStep)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/steps/engine/StepSupplier.java:96
↓ 2 callers
Method
injectDependencies
(Object obj)
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheProxySupport.java:295
↓ 2 callers
Method
injectDependencies
(T obj)
hazelcast/src/main/java/com/hazelcast/client/cache/impl/ClientCacheProxySupport.java:279
↓ 2 callers
Method
inlineSchema
(Map<String, String> options, boolean isKey)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/keyvalue/KvMetadataAvroResolver.java:288
↓ 2 callers
Method
inputThreadAffinity
(ThreadAffinity inputThreadAffinity)
hazelcast/src/main/java/com/hazelcast/internal/networking/nio/NioNetworking.java:573
↓ 2 callers
Method
insertData
(MySQLContainer<?> container)
extensions/cdc-debezium/src/test/java/com/hazelcast/jet/cdc/MySQLTestUtils.java:53
↓ 2 callers
Method
insertData
(PostgreSQLContainer<?> container)
extensions/cdc-debezium/src/test/java/com/hazelcast/jet/cdc/PostgresTestUtils.java:35
↓ 2 callers
Method
insertDocuments
(String collectionName)
extensions/kafka-connect/src/test/java/com/hazelcast/jet/kafka/connect/KafkaConnectCouchbaseIT.java:192
↓ 2 callers
Method
insertInternal
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 callers
Method
insertIntoMap
(IMap<String, Person> map, List<Person> peopleList)
hazelcast/src/test/java/com/hazelcast/map/impl/operation/MapFetchIndexOperationTest.java:539
↓ 2 callers
Method
insertItems
(String connectionUrl, String tableName)
extensions/kafka-connect/src/test/java/com/hazelcast/jet/kafka/connect/KafkaConnectJdbcIT.java:406
↓ 2 callers
Method
insertLiterals
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 callers
Method
insertNodes
(String sourceName, String prefix)
extensions/kafka-connect/src/test/java/com/hazelcast/jet/kafka/connect/KafkaConnectNeo4jIT.java:247
↓ 2 callers
Method
instancesResponse
Reponse recorded from the real Cloud Compute API call.
hazelcast/src/test/java/com/hazelcast/gcp/GcpComputeApiTest.java:115
↓ 2 callers
Method
instantiateExtractor
(AttributeConfig attributeConfig)
hazelcast/src/test/java/com/hazelcast/query/impl/getters/ExtractorHelperTest.java:250
↓ 2 callers
Method
instantiateExtractor
(AttributeConfig config, ClassLoader classLoader)
hazelcast/src/main/java/com/hazelcast/query/impl/getters/ExtractorHelper.java:49
↓ 2 callers
Method
instantiateExtractors
(List<AttributeConfig> attributeConfigs, ClassLoa
hazelcast/src/main/java/com/hazelcast/query/impl/getters/ExtractorHelper.java:36
↓ 2 callers
Method
instrument
(NodeEngine nodeEngine)
hazelcast/src/main/java/com/hazelcast/ringbuffer/impl/RingbufferStoreWrapper.java:171
↓ 2 callers
Method
intWrapperGenericRecord
(Class<?> topClazz, String otherField, int n)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/NestedReflectiveRestrictionTest.java:127
↓ 2 callers
Method
integrationTest
(ProcessingGuarantee guarantee)
extensions/kafka/src/test/java/com/hazelcast/jet/kafka/impl/StreamKafkaPTest.java:383
↓ 2 callers
Method
interceptGet
(State state)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/steps/EntryOpSteps.java:369
↓ 2 callers
Method
interceptLockOperation
()
hazelcast/src/main/java/com/hazelcast/internal/locksupport/operations/AbstractLockOperation.java:124
↓ 2 callers
Method
interceptSocket
(EndpointQualifier endpointQualifier, Socket socket, boolean onAccept)
hazelcast/src/main/java/com/hazelcast/internal/server/ServerContext.java:100
↓ 2 callers
Method
interfacesConfigXmlGenerator
(XmlGenerator gen, InterfacesConfig interfaces)
hazelcast/src/main/java/com/hazelcast/config/ConfigXmlGenerator.java:766
↓ 2 callers
Method
interfacesConfigYamlGenerator
(Map<String, Object> parent, InterfacesConfig interfaces)
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/DynamicConfigYamlGenerator.java:926
↓ 2 callers
Method
internalRunQuick
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 callers
Method
interruptBackupTask
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 callers
Method
interruptCurrentThread
(final int delayMillis)
hazelcast/src/test/java/com/hazelcast/test/HazelcastTestSupport.java:369
↓ 2 callers
Method
intersect
(RangePredicate predicate)
hazelcast/src/main/java/com/hazelcast/query/impl/predicates/RangeVisitor.java:261
↓ 2 callers
Method
invalidate
(SqlPlan plan)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/plan/cache/PlanCache.java:60
↓ 2 callers
Method
invalidate
(WaitSetEntry entry)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationparker/impl/OperationParkerImpl.java:321
↓ 2 callers
Method
invalidateAll
(UUID callerUuid)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationparker/impl/WaitSet.java:284
↓ 2 callers
Method
invalidateAllKeysInNearCaches
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 callers
Method
invalidateNearCache
(Object nearCacheKey)
hazelcast/src/main/java/com/hazelcast/map/impl/tx/TransactionalMapProxySupport.java:181
↓ 2 callers
Method
inverse
(final ClientSelector clientSelector)
hazelcast/src/main/java/com/hazelcast/client/impl/ClientSelectors.java:153
↓ 2 callers
Method
invertBit
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 callers
Method
invoke
(Object object, String methodName, Object... args)
extensions/kafka/src/main/java/com/hazelcast/jet/kafka/impl/ResumeTransactionUtil.java:86
↓ 2 callers
Method
invoke
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 callers
Method
invoke
(OperationService operationService, Operation operation)
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheIterator.java:86
↓ 2 callers
Method
invoke
(K key, EntryProcessor<K, V, T> entryProcessor, Object... arguments)
hazelcast/src/main/java/com/hazelcast/client/cache/impl/ClientCacheProxy.java:251
↓ 2 callers
Method
invoke
(ClientListenerRegistration listenerRegistration, ClientConnection connection)
hazelcast/src/main/java/com/hazelcast/client/impl/spi/impl/listener/ClientListenerServiceImpl.java:215
↓ 2 callers
Method
invoke
(Function<ClientMessage, Object> decoder, ClientInvocation invocation)
hazelcast/src/main/java/com/hazelcast/jet/impl/JetClientInstanceImpl.java:350
↓ 2 callers
Method
invoke
Executes the operation on all targets.
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/impl/InvokeOnMembers.java:72
← previous
next →
19,401–19,500 of 147,315, ranked by callers