MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

↓ 5 callersMethodisFlattened
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/UpdatePhysicalRel.java:109
↓ 5 callersMethodisIPv6
()
hazelcast/src/main/java/com/hazelcast/cluster/Address.java:117
↓ 5 callersMethodisIdentifiedDataSerializable
(byte header)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/DataSerializableHeader.java:47
↓ 5 callersMethodisIfExists
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/parse/SqlDropSnapshot.java:58
↓ 5 callersMethodisIncludeValue
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 callersMethodisIncludeValue
()
hazelcast/src/main/java/com/hazelcast/config/EntryListenerConfig.java:87
↓ 5 callersMethodisIndexed
(int partitionId)
hazelcast/src/main/java/com/hazelcast/query/impl/GlobalIndexPartitionTracker.java:80
↓ 5 callersMethodisIntervalType
(RelDataType type)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/validate/types/HazelcastTypeUtils.java:307
↓ 5 callersMethodisJCacheAvailable
(ClassLoader classLoader)
hazelcast/src/main/java/com/hazelcast/cache/impl/JCacheDetector.java:50
↓ 5 callersMethodisJDKClass
(Class<?> clazz)
hazelcast/src/test/java/com/hazelcast/test/starter/HazelcastProxyFactory.java:234
↓ 5 callersMethodisJobSuspendable
(JobConfig jobConfig)
hazelcast/src/main/java/com/hazelcast/jet/impl/util/Util.java:152
↓ 5 callersMethodisLast
()
hazelcast/src/main/java/com/hazelcast/sql/impl/client/SqlPage.java:88
↓ 5 callersMethodisLeaseExpired
()
hazelcast/src/main/java/com/hazelcast/internal/util/LockGuard.java:74
↓ 5 callersMethodisLightJob
()
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/ExecutionContext.java:408
↓ 5 callersMethodisLocal
()
hazelcast/src/main/java/com/hazelcast/config/EntryListenerConfig.java:77
↓ 5 callersMethodisLt
(RelOptCost other)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/cost/Cost.java:118
↓ 5 callersMethodisMapStore
()
hazelcast/src/main/java/com/hazelcast/map/impl/MapStoreWrapper.java:103
↓ 5 callersMethodisMaster
()
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/ClusterServiceImpl.java:665
↓ 5 callersMethodisMetricsEnabled
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 callersMethodisNewDatabase
(String uppercaseProductName)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/jdbc/SupportedDatabases.java:70
↓ 5 callersMethodisNotNull
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 callersMethodisNull_2
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/support/expressions/ExpressionPredicates.java:81
↓ 5 callersMethodisObjectIdentifier
(SqlIdentifier identifier)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/validate/types/HazelcastTypeUtils.java:186
↓ 5 callersMethodisOnCi
()
hazelcast/src/test/java/com/hazelcast/test/CiExecutionDetector.java:29
↓ 5 callersMethodisPartitionPromotionAllowed
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 callersMethodisPartitionTableSafe
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 callersMethodisPortAutoIncrement
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 callersMethodisReadOnly
()
hazelcast/src/main/java/com/hazelcast/dataconnection/impl/ConnectionDelegate.java:111
↓ 5 callersMethodisReadable
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 callersMethodisRedoOperation
()
hazelcast/src/main/java/com/hazelcast/client/impl/spi/ClientInvocationService.java:76
↓ 5 callersMethodisRemote
()
hazelcast/src/main/java/com/hazelcast/jet/impl/connector/MapSinkConfiguration.java:67
↓ 5 callersMethodisReply
()
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/MemberHandshake.java:116
↓ 5 callersMethodisRowSet
Return whether this result has rows to iterate using the {@link #iterator()} method.
hazelcast/src/main/java/com/hazelcast/sql/SqlResult.java:60
↓ 5 callersMethodisRunning
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 callersMethodisSocketTcpNoDelay
()
hazelcast/src/main/java/com/hazelcast/config/EndpointConfig.java:221
↓ 5 callersMethodisStale
(long version)
hazelcast/src/main/java/com/hazelcast/replicatedmap/impl/record/ReplicatedRecordStore.java:85
↓ 5 callersMethodisStarted
()
extensions/kafka-connect/src/test/java/com/hazelcast/jet/kafka/connect/impl/DummySourceConnector.java:92
↓ 5 callersMethodisStatisticsEnabled
@see #setStatisticsEnabled(boolean)
hazelcast/src/main/java/com/hazelcast/config/FlakeIdGeneratorConfig.java:311
↓ 5 callersMethodisSuccessful
()
hazelcast/src/main/java/com/hazelcast/jet/impl/JobResult.java:108
↓ 5 callersMethodisSuspended
Indicates whether job is in suspended state.
hazelcast/src/main/java/com/hazelcast/jet/impl/JobExecutionRecord.java:123
↓ 5 callersMethodisTemporal
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/schema/HazelcastRelOptTable.java:178
↓ 5 callersMethodisTenantControlEnabled
Returns {@code true} if tenant control is enabled.
hazelcast/src/main/java/com/hazelcast/spi/impl/tenantcontrol/impl/TenantControlServiceImpl.java:206
↓ 5 callersMethodisTopologyException
(Throwable t)
hazelcast/src/main/java/com/hazelcast/jet/impl/util/ExceptionUtil.java:81
↓ 5 callersMethodisTrusted
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 callersMethodisWanRepublishingEnabled
()
hazelcast/src/main/java/com/hazelcast/map/impl/wan/MapWanContext.java:150
↓ 5 callersMethoditemAdded
Invoked when an item is added. @param item the added item
hazelcast/src/main/java/com/hazelcast/collection/ItemListener.java:36
↓ 5 callersMethoditemRemoved
Invoked when an item is removed. @param item the removed item.
hazelcast/src/main/java/com/hazelcast/collection/ItemListener.java:43
↓ 5 callersMethoditerator
()
hazelcast/src/main/java/com/hazelcast/replicatedmap/impl/record/LazyCollection.java:55
↓ 5 callersMethoditerator
()
hazelcast/src/main/java/com/hazelcast/internal/util/ResultSet.java:46
↓ 5 callersMethodjdbcRows
(String query)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/jdbc/JdbcSqlTestSupport.java:302
↓ 5 callersMethodjobCompletionFuture
()
hazelcast/src/main/java/com/hazelcast/jet/impl/MasterJobContext.java:219
↓ 5 callersMethodkeyFields
()
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/schema/map/PartitionedMapTable.java:108
↓ 5 callersMethodkeys
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/file/FileTableTest.java:38
↓ 5 callersMethodkeys
(Void name)
hazelcast/src/test/java/com/hazelcast/internal/partition/service/TestMigrationAwareService.java:117
↓ 5 callersMethodkinesisSink
()
extensions/kinesis/src/test/java/com/hazelcast/jet/kinesis/AbstractKinesisTest.java:188
↓ 5 callersMethodlastForwardedWm
(byte key)
hazelcast/src/main/java/com/hazelcast/jet/core/test/TestOutbox.java:223
↓ 5 callersMethodlastPartOf
(String string, String separator)
hazelcast/src/main/java/com/hazelcast/gcp/Utils.java:38
↓ 5 callersMethodlength
()
hazelcast/src/main/java/com/hazelcast/internal/partition/PartitionTableView.java:57
↓ 5 callersMethodlistDatabaseNames
()
extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/dataconnection/CloseableMongoClient.java:84
↓ 5 callersMethodload
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 callersMethodload
(Class<T> clazz, String factoryId, ClassLoader classLoader)
hazelcast/src/main/java/com/hazelcast/internal/util/ServiceLoader.java:65
↓ 5 callersMethodload
{@inheritDoc}
hazelcast/src/main/java/com/hazelcast/map/MapStoreAdapter.java:70
↓ 5 callersMethodloadAddresses
(ClientConnectionProcessListenerRegistry listenerRunner)
hazelcast/src/main/java/com/hazelcast/client/impl/spi/impl/DefaultAddressProvider.java:51
↓ 5 callersMethodloadAll
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 callersMethodloadAll
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 callersMethodlocal
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 callersMethodlocalAddresses_memberWan
()
hazelcast/src/test/java/com/hazelcast/internal/server/tcp/TcpServerControlTest.java:282
↓ 5 callersMethodlockForDirectory
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 callersMethodlogDroppedMessage
(Object msg)
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/NodeMulticastListener.java:55
↓ 5 callersMethodlogLateEvent
Logs a late event that was dropped.
hazelcast/src/main/java/com/hazelcast/jet/impl/util/Util.java:441
↓ 5 callersMethodloggingService
()
hazelcast/src/main/java/com/hazelcast/jet/impl/JobProxy.java:216
↓ 5 callersMethodlookup
(Object key)
hazelcast-spring/src/main/java/com/hazelcast/spring/cache/HazelcastCache.java:158
↓ 5 callersMethodlookupNamespace
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 callersMethodlookupView
()
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/MetricDescriptorImpl.java:303
↓ 5 callersMethodmakeConfig
(String uniqueKey, UniqueKeyTransformation uniqueKeyTransformation)
hazelcast/src/test/java/com/hazelcast/client/map/impl/query/ClientBitmapIndexTest.java:397
↓ 5 callersMethodmakeConfig
(String uniqueKey, UniqueKeyTransformation uniqueKeyTransformation)
hazelcast/src/test/java/com/hazelcast/map/impl/query/SingleValueBitmapIndexTest.java:451
↓ 5 callersMethodmakeConfig
(String uniqueKey, UniqueKeyTransformation uniqueKeyTransformation)
hazelcast/src/test/java/com/hazelcast/map/impl/query/MultiValueBitmapIndexTest.java:368
↓ 5 callersMethodmakeSureDisconnectedFromServer
(final HazelcastInstance client, UUID memberUUID)
hazelcast/src/test/java/com/hazelcast/client/test/ClientTestSupport.java:90
↓ 5 callersMethodmapCount
()
hazelcast/src/test/java/com/hazelcast/map/merge/MapSplitBrainStressTest.java:96
↓ 5 callersMethodmapOf
(K key, V value)
extensions/kafka-connect/src/test/java/com/hazelcast/jet/kafka/connect/impl/JetSourceOffsetStorageReaderTest.java:54
↓ 5 callersMethodmarkPartitionAsIndexed
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 callersMethodmatchAnyDomain
(String name, Collection<String> patterns)
hazelcast/src/main/java/com/hazelcast/internal/util/AddressUtil.java:81
↓ 5 callersMethodmatches
(Collection<String> collection, String name)
hazelcast/src/test/java/com/hazelcast/splitbrainprotection/SplitBrainProtectionOperationTest.java:225
↓ 5 callersMethodmaxMemory
()
hazelcast/src/test/java/com/hazelcast/internal/metrics/metricsets/RuntimeMetricSetTest.java:76
↓ 5 callersMethodmerge
(Address newTargetAddress)
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/ClusterServiceImpl.java:324
↓ 5 callersMethodmergeBack
(HazelcastInstance hz, Address to)
hazelcast/src/test/java/com/hazelcast/cluster/SplitMergeTest.java:182
↓ 5 callersMethodmergeRecordExpiration
(Data key, Record record, MapMergeTypes mergingEntry, long now)
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/AbstractEvictableRecordStore.java:212
↓ 5 callersMethodmergingValueWithGivenValue
(Data value)
hazelcast/src/test/java/com/hazelcast/spi/merge/PutIfAbsentMergePolicyTest.java:76
↓ 5 callersMethodmetricDescriptor
(String metric)
hazelcast/src/test/java/com/hazelcast/internal/metrics/impl/RenderTest.java:79
↓ 5 callersMethodmetrics
Returns all metrics present.
hazelcast/src/main/java/com/hazelcast/jet/core/metrics/JobMetrics.java:88
↓ 5 callersMethodmetricsEnabled
()
hazelcast/src/main/java/com/hazelcast/jet/impl/MasterContext.java:236
↓ 5 callersMethodmetricsRegistry
(MetricsRegistry metricsRegistry)
hazelcast/src/main/java/com/hazelcast/internal/networking/nio/NioNetworking.java:542
↓ 5 callersMethodmigrateWithFailure
(final MigrationInfo migration)
hazelcast/src/test/java/com/hazelcast/internal/partition/impl/MigrationCommitServiceTest.java:397
↓ 5 callersMethodmigrateWithSuccess
(final MigrationInfo migration)
hazelcast/src/test/java/com/hazelcast/internal/partition/impl/MigrationCommitServiceTest.java:385
↓ 5 callersMethodmoduleClass
()
hazelcast/src/main/java/com/hazelcast/internal/util/ModularJavaUtils.java:54
↓ 5 callersMethodmove
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 callersMethodmyCreateMapping
(String mappingName)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/jdbc/SchemaJdbcConnectorTest.java:122
↓ 5 callersMethodmySqlContainer
()
extensions/cdc-debezium/src/test/java/com/hazelcast/jet/cdc/DebeziumCdcIntegrationTest.java:167
↓ 5 callersMethodname
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/string/LikeFunctionIntegrationTest.java:222
↓ 5 callersMethodnameWithoutSchema
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/parse/SqlDropMapping.java:55
← previousnext →10,901–11,000 of 147,315, ranked by callers