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
↓ 4 callers
Method
init
Initializes the scheduler with the given eventloop. @param eventloop the Eventloop.
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/Scheduler.java:40
↓ 4 callers
Method
init
(@Nonnull Context context)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/map/SpecificPartitionsImapReaderPms.java:71
↓ 4 callers
Method
init
Initializes the LoadBalancer. @param cluster the Cluster this LoadBalancer uses to select members from. @param config the ClientConfig.
hazelcast/src/main/java/com/hazelcast/client/LoadBalancer.java:41
↓ 4 callers
Method
init
This method is (only) called if the factory instance is newly created from a class name provided in {@link com.hazelcast.config.CredentialsFactoryConf
hazelcast/src/main/java/com/hazelcast/security/ICredentialsFactory.java:37
↓ 4 callers
Method
init
()
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/ProcessorTasklet.java:266
↓ 4 callers
Method
init
(Properties properties)
hazelcast/src/main/java/com/hazelcast/config/replacer/EncryptionReplacer.java:86
↓ 4 callers
Method
initDataSerializableInputAndSkipTheHeader
Init the ObjectDataInput for the given Data skipping the serialization header-bytes and navigating to the position from where the readData() starts re
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/SerializationServiceV1.java:396
↓ 4 callers
Method
initHasFinished
()
extensions/mapstore/src/main/java/com/hazelcast/mapstore/GenericMapLoader.java:415
↓ 4 callers
Method
initLasts
(long millis)
hazelcast/src/test/java/com/hazelcast/jet/impl/execution/TaskletExecutionServiceTest.java:466
↓ 4 callers
Method
initSnapshotDoneCounter
()
hazelcast/src/test/java/com/hazelcast/jet/core/IndeterminateSnapshotTest.java:130
↓ 4 callers
Method
initialiseForMapStore
(String mapName)
hazelcast/src/test/java/com/hazelcast/internal/util/phonehome/PhoneHomeTest.java:568
↓ 4 callers
Method
initializeJobUploadCall
(Path jarPath)
hazelcast/src/main/java/com/hazelcast/jet/impl/JetClientInstanceImpl.java:248
↓ 4 callers
Method
initializePredicatePushDownTest
(TestDatabaseProvider provider)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/jdbc/PredicatePushDownJdbcSqlConnectorTest.java:123
↓ 4 callers
Method
initializeStabilityTest
(TestDatabaseProvider provider)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/jdbc/JdbcSqlConnectorStabilityTest.java:38
↓ 4 callers
Method
inputFormat
Returns a source that reads records from Apache Hadoop HDFS and emits the results of transforming each record (a key-value pair) with the supplied pro
extensions/hadoop/src/main/java/com/hazelcast/jet/hadoop/HadoopSources.java:130
↓ 4 callers
Method
insertIntoTable
(String schema, String table, int id, String val1, String val2)
extensions/cdc-postgres/src/test/java/com/hazelcast/jet/cdc/postgres/PostgresCdcListenBeforeExistsIntegrationTest.java:174
↓ 4 callers
Method
insertItemsNoQuote
(String tableName, int count)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/jdbc/JdbcSqlTestSupport.java:221
↓ 4 callers
Method
insertRecord
(Object... values)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/kafka/SqlAvroSchemaEvolutionTest.java:290
↓ 4 callers
Method
insertRecords
(MySQLContainer<?> mysql, int... ids)
extensions/cdc-mysql/src/test/java/com/hazelcast/jet/cdc/mysql/MySqlCdcNetworkIntegrationTest.java:383
↓ 4 callers
Method
insertToTable
(String database, String table, int id, String val1, String val2)
extensions/cdc-mysql/src/test/java/com/hazelcast/jet/cdc/mysql/MySqlCdcListenBeforeExistIntegrationTest.java:168
↓ 4 callers
Method
instance
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/validate/HazelcastSqlOperatorTable.java:345
↓ 4 callers
Method
instance
()
hazelcast/src/main/java/com/hazelcast/jet/impl/connector/AsyncHazelcastWriterP.java:145
↓ 4 callers
Method
interceptAfterGet
Intercept the get operation after the value is retrieved. <p> This method can modify the input {@Code value}, so use with caution. @param interceptor
hazelcast/src/main/java/com/hazelcast/map/impl/MapServiceContextInterceptorSupport.java:45
↓ 4 callers
Method
interceptPut
Intercepts the put operation before the new value is stored. <p> This method can modify the input {@Code newValue} and {@Code oldValue}, so use with c
hazelcast/src/main/java/com/hazelcast/map/impl/MapServiceContextInterceptorSupport.java:57
↓ 4 callers
Method
internalComplete
()
hazelcast/src/main/java/com/hazelcast/jet/impl/util/NonCompletableFuture.java:65
↓ 4 callers
Method
intersection
Returns intersection of given String arrays. If either array is {@code null}, then {@code null} is returned. @param arr1 first array @param arr2 seco
hazelcast/src/main/java/com/hazelcast/internal/util/StringUtil.java:278
↓ 4 callers
Method
invalidInputToSink
(Entry<String, byte[]> valid, Entry<String, byte[]> invalid, String error)
extensions/kinesis/src/test/java/com/hazelcast/jet/kinesis/KinesisFailureTest.java:249
↓ 4 callers
Method
invalidate
(K key)
hazelcast/src/main/java/com/hazelcast/client/impl/proxy/ClientReplicatedMapProxy.java:643
↓ 4 callers
Method
invoke
(Operation operation)
hazelcast/src/main/java/com/hazelcast/collection/impl/txnqueue/TransactionalQueueProxySupport.java:198
↓ 4 callers
Method
invoke
(ClientMessage request, ClientConnection connection)
hazelcast/src/main/java/com/hazelcast/sql/impl/client/SqlClientService.java:450
↓ 4 callers
Method
invokeMBeanOperation
Calls the MBean operation with given attributes @param type Type of the Hazelcast object (first level of hierarchy), e.g. "IMap" @param obje
hazelcast/src/test/java/com/hazelcast/internal/jmx/MBeanDataHolder.java:121
↓ 4 callers
Method
invokeOnAllPartitions
Invokes a set of operations on each partition. <p> This method blocks until the operations complete. <p> If the operations have sync backups, this met
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/OperationService.java:284
↓ 4 callers
Method
invokeOnPartitionAsync
(String serviceName, Operation op, int partitionId)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/OperationServiceImpl.java:357
↓ 4 callers
Method
invokeOnPartitionInterruptibly
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/proxy/PartitionSpecificClientProxy.java:54
↓ 4 callers
Method
invokeOnPartitionOwner
(ClientMessage request, int partitionId)
hazelcast/src/main/java/com/hazelcast/client/impl/proxy/ClientExecutorServiceProxy.java:622
↓ 4 callers
Method
invokeOnPartitionsAsync
( String serviceName, OperationFactory operationFactory, Collection<Integer> partitions)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/OperationServiceImpl.java:513
↓ 4 callers
Method
isAllNullOrEmptyAfterTrim
Check if all Strings are not blank @param values the strings to check @return true if all the strings are not {@code null} and not blank, false otherw
hazelcast/src/main/java/com/hazelcast/internal/util/StringUtil.java:98
↓ 4 callers
Method
isAnyNullOrEmptyAfterTrim
Check if any String from the provided Strings @param values the strings to check @return true if at least one string of the {@code values} are not {@c
hazelcast/src/main/java/com/hazelcast/internal/util/StringUtil.java:110
↓ 4 callers
Method
isAutoStepDownWhenLeader
Returns whether this CP member is configured to automatically step down from leadership when elected. @return {@code true} if this member always reli
hazelcast/src/main/java/com/hazelcast/config/cp/CPSubsystemConfig.java:642
↓ 4 callers
Method
isBigEndian
Tells whether this memory accessor is big- or little-endian. This applies to all the multibyte-width methods of integral type ({@code get/putChar}, {@
hazelcast/src/main/java/com/hazelcast/internal/memory/MemoryAccessor.java:32
↓ 4 callers
Method
isBitSet
Returns true if n-th bit of the value is set, false otherwise
hazelcast/src/main/java/com/hazelcast/internal/nio/Bits.java:287
↓ 4 callers
Method
isBoolean
Detects whether this value represents a boolean value. @return <code>true</code> if this value represents either the JSON literal <code>true</code> o
hazelcast/src/main/java/com/hazelcast/internal/json/JsonValue.java:112
↓ 4 callers
Method
isCPDirectToLeaderRoutingEnabled
Returns whether CP direct-to-leader operation sending is enabled for this client. This functionality requires Hazelcast Enterprise license components.
hazelcast/src/main/java/com/hazelcast/client/config/ClientConfig.java:1049
↓ 4 callers
Method
isChunkedMigrationEnabled
()
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/MigrationManager.java:64
↓ 4 callers
Method
isClient
Checks if it is a client connection. @return true if client connection, false otherwise.
hazelcast/src/main/java/com/hazelcast/internal/server/ServerConnection.java:56
↓ 4 callers
Method
isClientFailoverSupported
@return true if client failover feature is supported
hazelcast/src/main/java/com/hazelcast/instance/impl/NodeExtension.java:160
↓ 4 callers
Method
isClosed
()
hazelcast/src/test/java/com/hazelcast/dataconnection/impl/DataConnectionTestUtil.java:112
↓ 4 callers
Method
isCommandPrefix
(String prefix)
hazelcast/src/main/java/com/hazelcast/internal/nio/ascii/TextParsers.java:45
↓ 4 callers
Method
isCompatibility
(boolean isCompatibility)
hazelcast/src/main/java/com/hazelcast/internal/serialization/SerializationServiceBuilder.java:73
↓ 4 callers
Method
isCompatible
(Map<String, RealmConfig> c1, Map<String, RealmConfig> c2)
hazelcast/src/test/java/com/hazelcast/config/ConfigCompatibilityChecker.java:1737
↓ 4 callers
Method
isConnected
()
hazelcast/src/main/java/com/hazelcast/internal/monitor/impl/LocalWanPublisherStatsImpl.java:60
↓ 4 callers
Method
isCooperative
()
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/Tasklet.java:36
↓ 4 callers
Method
isDeny
Returns {@code true} when the permission should be subtracted (denied) instead of added (granted). @return {@code true} for deny permissions @since 5.
hazelcast/src/main/java/com/hazelcast/config/PermissionConfig.java:329
↓ 4 callers
Method
isDisablePerEntryInvalidationEvents
Returns invalidation events disabled status for per entry. @return {@code true} if invalidation events are disabled for per entry, {@code false} othe
hazelcast/src/main/java/com/hazelcast/config/CacheSimpleConfig.java:729
↓ 4 callers
Method
isEmpty
()
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/expiry/ExpirySystemImpl.java:101
↓ 4 callers
Method
isEmpty
Transactional implementation of {@link IMap#isEmpty()}. @see IMap#isEmpty()
hazelcast/src/main/java/com/hazelcast/transaction/TransactionalMap.java:114
↓ 4 callers
Method
isEnabled
(HazelcastInstance client)
hazelcast/src/test/java/com/hazelcast/client/ClientBackupAckTest.java:113
↓ 4 callers
Method
isEnabled
()
hazelcast/src/main/java/com/hazelcast/config/RingbufferStoreConfig.java:70
↓ 4 callers
Method
isEnabled
@return {@code true} if the interface is enabled, {@code false} otherwise
hazelcast/src/main/java/com/hazelcast/config/InterfacesConfig.java:35
↓ 4 callers
Method
isEnabled
()
hazelcast/src/main/java/com/hazelcast/config/DiscoveryConfig.java:95
↓ 4 callers
Method
isEnabled
Returns whether disk tier is enabled on the related tiered-store. @return true if disk tier is enabled, false otherwise.
hazelcast/src/main/java/com/hazelcast/config/DiskTierConfig.java:56
↓ 4 callers
Method
isEnabled
Gets the enabled flag which defines TPC is enabled or not. @return true if TPC is enabled
hazelcast/src/main/java/com/hazelcast/config/tpc/TpcConfig.java:44
↓ 4 callers
Method
isEqual
(Object a, Object b)
hazelcast/src/test/java/com/hazelcast/client/protocol/compatibility/ReferenceObjects.java:129
↓ 4 callers
Method
isEvaluateOnly
@return {@code true} if this index supports querying only with {@link #evaluate} method, {@code false} otherwise.
hazelcast/src/main/java/com/hazelcast/query/impl/Index.java:115
↓ 4 callers
Method
isExpirable
@return <code>true</code> if record store has at least one candidate entry for expiration else return <code>false</code>.
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/RecordStore.java:438
↓ 4 callers
Method
isExportOnly
@see SnapshotFlags#isExportOnly(int)
hazelcast/src/main/java/com/hazelcast/jet/impl/MasterSnapshotContext.java:109
↓ 4 callers
Method
isFromInclusive
()
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/exec/scan/index/IndexRangeFilter.java:88
↓ 4 callers
Method
isGreaterOrEqual
()
hazelcast/src/test/java/com/hazelcast/version/VersionTest.java:71
↓ 4 callers
Method
isGreaterThan
@param version other version to compare to @return {@code true} if this version is greater than {@code version}
hazelcast/src/main/java/com/hazelcast/version/Version.java:173
↓ 4 callers
Method
isIPv4
()
hazelcast/src/main/java/com/hazelcast/internal/util/AddressUtil.java:538
↓ 4 callers
Method
isInstanceMetadataAvailable
()
hazelcast/src/main/java/com/hazelcast/azure/AzureConfig.java:75
↓ 4 callers
Method
isJarOnMember
()
hazelcast/src/main/java/com/hazelcast/jet/impl/SubmitJobParameters.java:85
↓ 4 callers
Method
isJoinOperation
(Operation op)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/Operations.java:33
↓ 4 callers
Method
isLiteMember
Returns {@code true} if this member is a lite member. A lite member does not own any partitions. @return {@code true} if this member is a lite member
hazelcast/src/main/java/com/hazelcast/config/Config.java:2938
↓ 4 callers
Method
isLocal
Returns {@code true} if the subscriber of the registration is this node
hazelcast/src/main/java/com/hazelcast/spi/impl/eventservice/impl/EventServiceImpl.java:691
↓ 4 callers
Method
isLocalAddress
(final Address address)
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/TcpIpJoiner.java:433
↓ 4 callers
Method
isLoopback
()
hazelcast/src/main/java/com/hazelcast/internal/util/NetworkInterfaceInfo.java:58
↓ 4 callers
Method
isMac
@return {@code true} if the current system is Mac OS.
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/util/OS.java:153
↓ 4 callers
Method
isMapLoader
@return {@code true} if a {@link MapLoader} is configured for this map
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/MapStoreContext.java:69
↓ 4 callers
Method
isMemberExcluded
Checks if the given member has been excluded during the cluster start or not. If returns true, it means that the given member is not allowed to join t
hazelcast/src/main/java/com/hazelcast/internal/hotrestart/InternalHotRestartService.java:101
↓ 4 callers
Method
isMergeApplied
()
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheMergeResponse.java:67
↓ 4 callers
Method
isMinSizeReached
()
hazelcast/src/main/java/com/hazelcast/ringbuffer/impl/ReadResultSetImpl.java:105
↓ 4 callers
Method
isMissingPartitions
@return {@code false} when all partition IDs in [0, partitionCount) are contained in this set, otherwise {@code true}
hazelcast/src/main/java/com/hazelcast/internal/util/collection/PartitionIdSet.java:242
↓ 4 callers
Method
isNotFalse
Checks whether the given value is not {@code false}. @param value the value to check. @return {@code true} if the passed value is either {@code true}
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/expression/predicate/TernaryLogic.java:176
↓ 4 callers
Method
isNotTrue
Checks whether the given value is not {@code true}. @param value the value to check. @return {@code true} if the passed value is either {@code false}
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/expression/predicate/TernaryLogic.java:153
↓ 4 callers
Method
isNullnessCheck
@return {@code true} if this range is a nullness check range like {@code a = null}, {@code false} otherwise.
hazelcast/src/main/java/com/hazelcast/query/impl/predicates/RangeVisitor.java:378
↓ 4 callers
Method
isNumeric
(QueryDataType type)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/QueryDataTypeUtils.java:255
↓ 4 callers
Method
isOldValueRequired
()
hazelcast/src/test/java/com/hazelcast/cache/instance/CacheHazelcastInstanceAwareTest.java:517
↓ 4 callers
Method
isPersistenceEnabled
Returns whether CP Subsystem Persistence enabled on this member. @return true if CP Subsystem Persistence is enabled, false otherwise
hazelcast/src/main/java/com/hazelcast/config/cp/CPSubsystemConfig.java:523
↓ 4 callers
Method
isPostProcessingMapStore
()
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/MapDataStore.java:103
↓ 4 callers
Method
isPrimaryKey
()
extensions/mongodb/src/main/java/com/hazelcast/jet/sql/impl/connector/mongodb/MongoTableField.java:46
↓ 4 callers
Method
isPublishable
()
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/accumulator/AccumulatorInfo.java:146
↓ 4 callers
Method
isPutIfAbsent
()
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/StaticParams.java:222
↓ 4 callers
Method
isPutIfExists
()
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/StaticParams.java:230
↓ 4 callers
Method
isPutVanilla
()
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/StaticParams.java:226
↓ 4 callers
Method
isQueryResultLimitEnabled
Just for testing.
hazelcast/src/main/java/com/hazelcast/map/impl/query/QueryResultSizeLimiter.java:113
↓ 4 callers
Method
isReceived
(V message)
hazelcast/src/test/java/com/hazelcast/topic/impl/reliable/SubscriptionMigrationTest.java:104
↓ 4 callers
Method
isRecordExistsInMemory
()
hazelcast/src/main/java/com/hazelcast/map/impl/operation/steps/engine/State.java:247
↓ 4 callers
Method
isRedoOperation
See {@link com.hazelcast.client.config.ClientNetworkConfig#setRedoOperation(boolean)} for details @return true if redo operations are enabled
hazelcast/src/main/java/com/hazelcast/client/config/ClientNetworkConfig.java:270
↓ 4 callers
Method
isRemote
()
hazelcast/src/main/java/com/hazelcast/jet/impl/connector/StreamEventJournalP.java:448
← previous
next →
12,501–12,600 of 147,315, ranked by callers