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
↓ 5 callers
Method
isFlattened
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/UpdatePhysicalRel.java:109
↓ 5 callers
Method
isIPv6
()
hazelcast/src/main/java/com/hazelcast/cluster/Address.java:117
↓ 5 callers
Method
isIdentifiedDataSerializable
(byte header)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/DataSerializableHeader.java:47
↓ 5 callers
Method
isIfExists
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/parse/SqlDropSnapshot.java:58
↓ 5 callers
Method
isIncludeValue
Returns {@code true} if value caching enabled, otherwise returns {@code false}. <p> Default value is {@value #DEFAULT_INCLUDE_VALUE}. @return {@code
hazelcast/src/main/java/com/hazelcast/config/QueryCacheConfig.java:303
↓ 5 callers
Method
isIncludeValue
()
hazelcast/src/main/java/com/hazelcast/config/EntryListenerConfig.java:87
↓ 5 callers
Method
isIndexed
(int partitionId)
hazelcast/src/main/java/com/hazelcast/query/impl/GlobalIndexPartitionTracker.java:80
↓ 5 callers
Method
isIntervalType
(RelDataType type)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/validate/types/HazelcastTypeUtils.java:307
↓ 5 callers
Method
isJCacheAvailable
(ClassLoader classLoader)
hazelcast/src/main/java/com/hazelcast/cache/impl/JCacheDetector.java:50
↓ 5 callers
Method
isJDKClass
(Class<?> clazz)
hazelcast/src/test/java/com/hazelcast/test/starter/HazelcastProxyFactory.java:234
↓ 5 callers
Method
isJobSuspendable
(JobConfig jobConfig)
hazelcast/src/main/java/com/hazelcast/jet/impl/util/Util.java:152
↓ 5 callers
Method
isLast
()
hazelcast/src/main/java/com/hazelcast/sql/impl/client/SqlPage.java:88
↓ 5 callers
Method
isLeaseExpired
()
hazelcast/src/main/java/com/hazelcast/internal/util/LockGuard.java:74
↓ 5 callers
Method
isLightJob
()
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/ExecutionContext.java:408
↓ 5 callers
Method
isLocal
()
hazelcast/src/main/java/com/hazelcast/config/EntryListenerConfig.java:77
↓ 5 callers
Method
isLt
(RelOptCost other)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/cost/Cost.java:118
↓ 5 callers
Method
isMapStore
()
hazelcast/src/main/java/com/hazelcast/map/impl/MapStoreWrapper.java:103
↓ 5 callers
Method
isMaster
()
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/ClusterServiceImpl.java:665
↓ 5 callers
Method
isMetricsEnabled
Returns if metrics collection is enabled for the job. @since Jet 3.2
hazelcast/src/main/java/com/hazelcast/jet/config/JobConfig.java:1322
↓ 5 callers
Method
isNewDatabase
(String uppercaseProductName)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/jdbc/SupportedDatabases.java:70
↓ 5 callers
Method
isNotNull
Checks whether the given value is not {@code null}. @param value the value to check. @return {@code false} if the passed value is {@code null}, {@cod
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/expression/predicate/TernaryLogic.java:130
↓ 5 callers
Method
isNull_2
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/support/expressions/ExpressionPredicates.java:81
↓ 5 callers
Method
isObjectIdentifier
(SqlIdentifier identifier)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/validate/types/HazelcastTypeUtils.java:186
↓ 5 callers
Method
isOnCi
()
hazelcast/src/test/java/com/hazelcast/test/CiExecutionDetector.java:29
↓ 5 callers
Method
isPartitionPromotionAllowed
Returns {@code true}, if partition promotions are allowed in this state. @return {@code true} if partition promotions are allowed in this state.
hazelcast/src/main/java/com/hazelcast/cluster/ClusterState.java:204
↓ 5 callers
Method
isPartitionTableSafe
Queries and returns if the partition table is safe, meaning partition replicas are assigned to owners, no migrations are ongoing and there is no need
hazelcast/src/main/java/com/hazelcast/internal/partition/IPartitionService.java:174
↓ 5 callers
Method
isPortAutoIncrement
Checks if a Hazelcast member is allowed find a free port by incrementing the port number when it encounters an occupied port. @return the portAutoInc
hazelcast/src/main/java/com/hazelcast/config/ServerSocketEndpointConfig.java:143
↓ 5 callers
Method
isReadOnly
()
hazelcast/src/main/java/com/hazelcast/dataconnection/impl/ConnectionDelegate.java:111
↓ 5 callers
Method
isReadable
Checks if this AsyncSocket is readable. For more information see {@link #setReadable(boolean)}. <p/> This call can safely be made from any thread, but
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/net/AsyncSocket.java:124
↓ 5 callers
Method
isRedoOperation
()
hazelcast/src/main/java/com/hazelcast/client/impl/spi/ClientInvocationService.java:76
↓ 5 callers
Method
isRemote
()
hazelcast/src/main/java/com/hazelcast/jet/impl/connector/MapSinkConfiguration.java:67
↓ 5 callers
Method
isReply
()
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/MemberHandshake.java:116
↓ 5 callers
Method
isRowSet
Return whether this result has rows to iterate using the {@link #iterator()} method.
hazelcast/src/main/java/com/hazelcast/sql/SqlResult.java:60
↓ 5 callers
Method
isRunning
Indicates that node is not shutting down, or it has not already shut down @return true if node is not shutting down, or it has not already shut down
hazelcast/src/main/java/com/hazelcast/instance/impl/Node.java:702
↓ 5 callers
Method
isSocketTcpNoDelay
()
hazelcast/src/main/java/com/hazelcast/config/EndpointConfig.java:221
↓ 5 callers
Method
isStale
(long version)
hazelcast/src/main/java/com/hazelcast/replicatedmap/impl/record/ReplicatedRecordStore.java:85
↓ 5 callers
Method
isStarted
()
extensions/kafka-connect/src/test/java/com/hazelcast/jet/kafka/connect/impl/DummySourceConnector.java:92
↓ 5 callers
Method
isStatisticsEnabled
@see #setStatisticsEnabled(boolean)
hazelcast/src/main/java/com/hazelcast/config/FlakeIdGeneratorConfig.java:311
↓ 5 callers
Method
isSuccessful
()
hazelcast/src/main/java/com/hazelcast/jet/impl/JobResult.java:108
↓ 5 callers
Method
isSuspended
Indicates whether job is in suspended state.
hazelcast/src/main/java/com/hazelcast/jet/impl/JobExecutionRecord.java:123
↓ 5 callers
Method
isTemporal
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/schema/HazelcastRelOptTable.java:178
↓ 5 callers
Method
isTenantControlEnabled
Returns {@code true} if tenant control is enabled.
hazelcast/src/main/java/com/hazelcast/spi/impl/tenantcontrol/impl/TenantControlServiceImpl.java:206
↓ 5 callers
Method
isTopologyException
(Throwable t)
hazelcast/src/main/java/com/hazelcast/jet/impl/util/ExceptionUtil.java:81
↓ 5 callers
Method
isTrusted
Returns {@code true} if the code is trusted. @param address The {@link Address} to be checked. @return {@code true} when trusted; false otherwise
hazelcast/src/main/java/com/hazelcast/internal/cluster/AddressChecker.java:32
↓ 5 callers
Method
isWanRepublishingEnabled
()
hazelcast/src/main/java/com/hazelcast/map/impl/wan/MapWanContext.java:150
↓ 5 callers
Method
itemAdded
Invoked when an item is added. @param item the added item
hazelcast/src/main/java/com/hazelcast/collection/ItemListener.java:36
↓ 5 callers
Method
itemRemoved
Invoked when an item is removed. @param item the removed item.
hazelcast/src/main/java/com/hazelcast/collection/ItemListener.java:43
↓ 5 callers
Method
iterator
()
hazelcast/src/main/java/com/hazelcast/replicatedmap/impl/record/LazyCollection.java:55
↓ 5 callers
Method
iterator
()
hazelcast/src/main/java/com/hazelcast/internal/util/ResultSet.java:46
↓ 5 callers
Method
jdbcRows
(String query)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/jdbc/JdbcSqlTestSupport.java:302
↓ 5 callers
Method
jobCompletionFuture
()
hazelcast/src/main/java/com/hazelcast/jet/impl/MasterJobContext.java:219
↓ 5 callers
Method
keyFields
()
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/schema/map/PartitionedMapTable.java:108
↓ 5 callers
Method
keys
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/file/FileTableTest.java:38
↓ 5 callers
Method
keys
(Void name)
hazelcast/src/test/java/com/hazelcast/internal/partition/service/TestMigrationAwareService.java:117
↓ 5 callers
Method
kinesisSink
()
extensions/kinesis/src/test/java/com/hazelcast/jet/kinesis/AbstractKinesisTest.java:188
↓ 5 callers
Method
lastForwardedWm
(byte key)
hazelcast/src/main/java/com/hazelcast/jet/core/test/TestOutbox.java:223
↓ 5 callers
Method
lastPartOf
(String string, String separator)
hazelcast/src/main/java/com/hazelcast/gcp/Utils.java:38
↓ 5 callers
Method
length
()
hazelcast/src/main/java/com/hazelcast/internal/partition/PartitionTableView.java:57
↓ 5 callers
Method
listDatabaseNames
()
extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/dataconnection/CloseableMongoClient.java:84
↓ 5 callers
Method
load
Loads the value of a given key. <p> Implementation can use any means of loading the given key; such as an O/R mapping tool, simple SQL, reading a file
hazelcast/src/main/java/com/hazelcast/collection/QueueStore.java:71
↓ 5 callers
Method
load
(Class<T> clazz, String factoryId, ClassLoader classLoader)
hazelcast/src/main/java/com/hazelcast/internal/util/ServiceLoader.java:65
↓ 5 callers
Method
load
{@inheritDoc}
hazelcast/src/main/java/com/hazelcast/map/MapStoreAdapter.java:70
↓ 5 callers
Method
loadAddresses
(ClientConnectionProcessListenerRegistry listenerRunner)
hazelcast/src/main/java/com/hazelcast/client/impl/spi/impl/DefaultAddressProvider.java:51
↓ 5 callers
Method
loadAll
Loads the given keys. This is a batch load operation so that implementation can optimize the multiple loads. <p> Set the bulk-load property to configu
hazelcast/src/main/java/com/hazelcast/collection/QueueStore.java:83
↓ 5 callers
Method
loadAll
Loads values for the provided keys if a {@link MapLoader} is configured for this map. This method never returns {@code null}. The returned map will co
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/MapDataStore.java:72
↓ 5 callers
Method
local
Declares that the edge is local. A local edge only transfers data within the same member, network is not involved. This setting is the default. @see
hazelcast/src/main/java/com/hazelcast/jet/core/Edge.java:471
↓ 5 callers
Method
localAddresses_memberWan
()
hazelcast/src/test/java/com/hazelcast/internal/server/tcp/TcpServerControlTest.java:282
↓ 5 callers
Method
lockForDirectory
Acquires a lock for given directory. A special file, named <strong>lock</strong>, is created inside the directory and that file is locked. @param dir
hazelcast/src/main/java/com/hazelcast/internal/util/DirectoryLock.java:98
↓ 5 callers
Method
logDroppedMessage
(Object msg)
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/NodeMulticastListener.java:55
↓ 5 callers
Method
logLateEvent
Logs a late event that was dropped.
hazelcast/src/main/java/com/hazelcast/jet/impl/util/Util.java:441
↓ 5 callers
Method
loggingService
()
hazelcast/src/main/java/com/hazelcast/jet/impl/JobProxy.java:216
↓ 5 callers
Method
lookup
(Object key)
hazelcast-spring/src/main/java/com/hazelcast/spring/cache/HazelcastCache.java:158
↓ 5 callers
Method
lookupNamespace
Looks up the User Code Namespace name associated with the specified multimap name. This is done by checking the Node's config tree directly. @param e
hazelcast/src/main/java/com/hazelcast/multimap/impl/MultiMapService.java:581
↓ 5 callers
Method
lookupView
()
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/MetricDescriptorImpl.java:303
↓ 5 callers
Method
makeConfig
(String uniqueKey, UniqueKeyTransformation uniqueKeyTransformation)
hazelcast/src/test/java/com/hazelcast/client/map/impl/query/ClientBitmapIndexTest.java:397
↓ 5 callers
Method
makeConfig
(String uniqueKey, UniqueKeyTransformation uniqueKeyTransformation)
hazelcast/src/test/java/com/hazelcast/map/impl/query/SingleValueBitmapIndexTest.java:451
↓ 5 callers
Method
makeConfig
(String uniqueKey, UniqueKeyTransformation uniqueKeyTransformation)
hazelcast/src/test/java/com/hazelcast/map/impl/query/MultiValueBitmapIndexTest.java:368
↓ 5 callers
Method
makeSureDisconnectedFromServer
(final HazelcastInstance client, UUID memberUUID)
hazelcast/src/test/java/com/hazelcast/client/test/ClientTestSupport.java:90
↓ 5 callers
Method
mapCount
()
hazelcast/src/test/java/com/hazelcast/map/merge/MapSplitBrainStressTest.java:96
↓ 5 callers
Method
mapOf
(K key, V value)
extensions/kafka-connect/src/test/java/com/hazelcast/jet/kafka/connect/impl/JetSourceOffsetStorageReaderTest.java:54
↓ 5 callers
Method
markPartitionAsIndexed
Marks the given partition as indexed by this index. @param partitionId the ID of the partition to mark as indexed.
hazelcast/src/main/java/com/hazelcast/query/impl/InternalIndex.java:84
↓ 5 callers
Method
matchAnyDomain
(String name, Collection<String> patterns)
hazelcast/src/main/java/com/hazelcast/internal/util/AddressUtil.java:81
↓ 5 callers
Method
matches
(Collection<String> collection, String name)
hazelcast/src/test/java/com/hazelcast/splitbrainprotection/SplitBrainProtectionOperationTest.java:225
↓ 5 callers
Method
maxMemory
()
hazelcast/src/test/java/com/hazelcast/internal/metrics/metricsets/RuntimeMetricSetTest.java:76
↓ 5 callers
Method
merge
(Address newTargetAddress)
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/ClusterServiceImpl.java:324
↓ 5 callers
Method
mergeBack
(HazelcastInstance hz, Address to)
hazelcast/src/test/java/com/hazelcast/cluster/SplitMergeTest.java:182
↓ 5 callers
Method
mergeRecordExpiration
(Data key, Record record, MapMergeTypes mergingEntry, long now)
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/AbstractEvictableRecordStore.java:212
↓ 5 callers
Method
mergingValueWithGivenValue
(Data value)
hazelcast/src/test/java/com/hazelcast/spi/merge/PutIfAbsentMergePolicyTest.java:76
↓ 5 callers
Method
metricDescriptor
(String metric)
hazelcast/src/test/java/com/hazelcast/internal/metrics/impl/RenderTest.java:79
↓ 5 callers
Method
metrics
Returns all metrics present.
hazelcast/src/main/java/com/hazelcast/jet/core/metrics/JobMetrics.java:88
↓ 5 callers
Method
metricsEnabled
()
hazelcast/src/main/java/com/hazelcast/jet/impl/MasterContext.java:236
↓ 5 callers
Method
metricsRegistry
(MetricsRegistry metricsRegistry)
hazelcast/src/main/java/com/hazelcast/internal/networking/nio/NioNetworking.java:542
↓ 5 callers
Method
migrateWithFailure
(final MigrationInfo migration)
hazelcast/src/test/java/com/hazelcast/internal/partition/impl/MigrationCommitServiceTest.java:397
↓ 5 callers
Method
migrateWithSuccess
(final MigrationInfo migration)
hazelcast/src/test/java/com/hazelcast/internal/partition/impl/MigrationCommitServiceTest.java:385
↓ 5 callers
Method
moduleClass
()
hazelcast/src/main/java/com/hazelcast/internal/util/ModularJavaUtils.java:54
↓ 5 callers
Method
move
Move or rename a file to a target file. This move method contains a fallback (delete target + atomic move) for cases when the first try fails. It's a
hazelcast/src/main/java/com/hazelcast/internal/nio/IOUtil.java:596
↓ 5 callers
Method
myCreateMapping
(String mappingName)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/jdbc/SchemaJdbcConnectorTest.java:122
↓ 5 callers
Method
mySqlContainer
()
extensions/cdc-debezium/src/test/java/com/hazelcast/jet/cdc/DebeziumCdcIntegrationTest.java:167
↓ 5 callers
Method
name
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/string/LikeFunctionIntegrationTest.java:222
↓ 5 callers
Method
nameWithoutSchema
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/parse/SqlDropMapping.java:55
← previous
next →
10,901–11,000 of 147,315, ranked by callers