MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

↓ 4 callersMethodinit
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 callersMethodinit
(@Nonnull Context context)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/map/SpecificPartitionsImapReaderPms.java:71
↓ 4 callersMethodinit
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 callersMethodinit
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 callersMethodinit
()
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/ProcessorTasklet.java:266
↓ 4 callersMethodinit
(Properties properties)
hazelcast/src/main/java/com/hazelcast/config/replacer/EncryptionReplacer.java:86
↓ 4 callersMethodinitDataSerializableInputAndSkipTheHeader
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 callersMethodinitHasFinished
()
extensions/mapstore/src/main/java/com/hazelcast/mapstore/GenericMapLoader.java:415
↓ 4 callersMethodinitLasts
(long millis)
hazelcast/src/test/java/com/hazelcast/jet/impl/execution/TaskletExecutionServiceTest.java:466
↓ 4 callersMethodinitSnapshotDoneCounter
()
hazelcast/src/test/java/com/hazelcast/jet/core/IndeterminateSnapshotTest.java:130
↓ 4 callersMethodinitialiseForMapStore
(String mapName)
hazelcast/src/test/java/com/hazelcast/internal/util/phonehome/PhoneHomeTest.java:568
↓ 4 callersMethodinitializeJobUploadCall
(Path jarPath)
hazelcast/src/main/java/com/hazelcast/jet/impl/JetClientInstanceImpl.java:248
↓ 4 callersMethodinitializePredicatePushDownTest
(TestDatabaseProvider provider)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/jdbc/PredicatePushDownJdbcSqlConnectorTest.java:123
↓ 4 callersMethodinitializeStabilityTest
(TestDatabaseProvider provider)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/jdbc/JdbcSqlConnectorStabilityTest.java:38
↓ 4 callersMethodinputFormat
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 callersMethodinsertIntoTable
(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 callersMethodinsertItemsNoQuote
(String tableName, int count)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/jdbc/JdbcSqlTestSupport.java:221
↓ 4 callersMethodinsertRecord
(Object... values)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/kafka/SqlAvroSchemaEvolutionTest.java:290
↓ 4 callersMethodinsertRecords
(MySQLContainer<?> mysql, int... ids)
extensions/cdc-mysql/src/test/java/com/hazelcast/jet/cdc/mysql/MySqlCdcNetworkIntegrationTest.java:383
↓ 4 callersMethodinsertToTable
(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 callersMethodinstance
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/validate/HazelcastSqlOperatorTable.java:345
↓ 4 callersMethodinstance
()
hazelcast/src/main/java/com/hazelcast/jet/impl/connector/AsyncHazelcastWriterP.java:145
↓ 4 callersMethodinterceptAfterGet
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 callersMethodinterceptPut
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 callersMethodinternalComplete
()
hazelcast/src/main/java/com/hazelcast/jet/impl/util/NonCompletableFuture.java:65
↓ 4 callersMethodintersection
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 callersMethodinvalidInputToSink
(Entry<String, byte[]> valid, Entry<String, byte[]> invalid, String error)
extensions/kinesis/src/test/java/com/hazelcast/jet/kinesis/KinesisFailureTest.java:249
↓ 4 callersMethodinvalidate
(K key)
hazelcast/src/main/java/com/hazelcast/client/impl/proxy/ClientReplicatedMapProxy.java:643
↓ 4 callersMethodinvoke
(Operation operation)
hazelcast/src/main/java/com/hazelcast/collection/impl/txnqueue/TransactionalQueueProxySupport.java:198
↓ 4 callersMethodinvoke
(ClientMessage request, ClientConnection connection)
hazelcast/src/main/java/com/hazelcast/sql/impl/client/SqlClientService.java:450
↓ 4 callersMethodinvokeMBeanOperation
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 callersMethodinvokeOnAllPartitions
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 callersMethodinvokeOnPartitionAsync
(String serviceName, Operation op, int partitionId)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/OperationServiceImpl.java:357
↓ 4 callersMethodinvokeOnPartitionInterruptibly
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/proxy/PartitionSpecificClientProxy.java:54
↓ 4 callersMethodinvokeOnPartitionOwner
(ClientMessage request, int partitionId)
hazelcast/src/main/java/com/hazelcast/client/impl/proxy/ClientExecutorServiceProxy.java:622
↓ 4 callersMethodinvokeOnPartitionsAsync
( String serviceName, OperationFactory operationFactory, Collection<Integer> partitions)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/OperationServiceImpl.java:513
↓ 4 callersMethodisAllNullOrEmptyAfterTrim
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 callersMethodisAnyNullOrEmptyAfterTrim
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 callersMethodisAutoStepDownWhenLeader
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 callersMethodisBigEndian
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 callersMethodisBitSet
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 callersMethodisBoolean
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 callersMethodisCPDirectToLeaderRoutingEnabled
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 callersMethodisChunkedMigrationEnabled
()
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/MigrationManager.java:64
↓ 4 callersMethodisClient
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 callersMethodisClientFailoverSupported
@return true if client failover feature is supported
hazelcast/src/main/java/com/hazelcast/instance/impl/NodeExtension.java:160
↓ 4 callersMethodisClosed
()
hazelcast/src/test/java/com/hazelcast/dataconnection/impl/DataConnectionTestUtil.java:112
↓ 4 callersMethodisCommandPrefix
(String prefix)
hazelcast/src/main/java/com/hazelcast/internal/nio/ascii/TextParsers.java:45
↓ 4 callersMethodisCompatibility
(boolean isCompatibility)
hazelcast/src/main/java/com/hazelcast/internal/serialization/SerializationServiceBuilder.java:73
↓ 4 callersMethodisCompatible
(Map<String, RealmConfig> c1, Map<String, RealmConfig> c2)
hazelcast/src/test/java/com/hazelcast/config/ConfigCompatibilityChecker.java:1737
↓ 4 callersMethodisConnected
()
hazelcast/src/main/java/com/hazelcast/internal/monitor/impl/LocalWanPublisherStatsImpl.java:60
↓ 4 callersMethodisCooperative
()
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/Tasklet.java:36
↓ 4 callersMethodisDeny
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 callersMethodisDisablePerEntryInvalidationEvents
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 callersMethodisEmpty
()
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/expiry/ExpirySystemImpl.java:101
↓ 4 callersMethodisEmpty
Transactional implementation of {@link IMap#isEmpty()}. @see IMap#isEmpty()
hazelcast/src/main/java/com/hazelcast/transaction/TransactionalMap.java:114
↓ 4 callersMethodisEnabled
(HazelcastInstance client)
hazelcast/src/test/java/com/hazelcast/client/ClientBackupAckTest.java:113
↓ 4 callersMethodisEnabled
()
hazelcast/src/main/java/com/hazelcast/config/RingbufferStoreConfig.java:70
↓ 4 callersMethodisEnabled
@return {@code true} if the interface is enabled, {@code false} otherwise
hazelcast/src/main/java/com/hazelcast/config/InterfacesConfig.java:35
↓ 4 callersMethodisEnabled
()
hazelcast/src/main/java/com/hazelcast/config/DiscoveryConfig.java:95
↓ 4 callersMethodisEnabled
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 callersMethodisEnabled
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 callersMethodisEqual
(Object a, Object b)
hazelcast/src/test/java/com/hazelcast/client/protocol/compatibility/ReferenceObjects.java:129
↓ 4 callersMethodisEvaluateOnly
@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 callersMethodisExpirable
@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 callersMethodisExportOnly
@see SnapshotFlags#isExportOnly(int)
hazelcast/src/main/java/com/hazelcast/jet/impl/MasterSnapshotContext.java:109
↓ 4 callersMethodisFromInclusive
()
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/exec/scan/index/IndexRangeFilter.java:88
↓ 4 callersMethodisGreaterOrEqual
()
hazelcast/src/test/java/com/hazelcast/version/VersionTest.java:71
↓ 4 callersMethodisGreaterThan
@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 callersMethodisIPv4
()
hazelcast/src/main/java/com/hazelcast/internal/util/AddressUtil.java:538
↓ 4 callersMethodisInstanceMetadataAvailable
()
hazelcast/src/main/java/com/hazelcast/azure/AzureConfig.java:75
↓ 4 callersMethodisJarOnMember
()
hazelcast/src/main/java/com/hazelcast/jet/impl/SubmitJobParameters.java:85
↓ 4 callersMethodisJoinOperation
(Operation op)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/Operations.java:33
↓ 4 callersMethodisLiteMember
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 callersMethodisLocal
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 callersMethodisLocalAddress
(final Address address)
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/TcpIpJoiner.java:433
↓ 4 callersMethodisLoopback
()
hazelcast/src/main/java/com/hazelcast/internal/util/NetworkInterfaceInfo.java:58
↓ 4 callersMethodisMac
@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 callersMethodisMapLoader
@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 callersMethodisMemberExcluded
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 callersMethodisMergeApplied
()
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheMergeResponse.java:67
↓ 4 callersMethodisMinSizeReached
()
hazelcast/src/main/java/com/hazelcast/ringbuffer/impl/ReadResultSetImpl.java:105
↓ 4 callersMethodisMissingPartitions
@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 callersMethodisNotFalse
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 callersMethodisNotTrue
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 callersMethodisNullnessCheck
@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 callersMethodisNumeric
(QueryDataType type)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/QueryDataTypeUtils.java:255
↓ 4 callersMethodisOldValueRequired
()
hazelcast/src/test/java/com/hazelcast/cache/instance/CacheHazelcastInstanceAwareTest.java:517
↓ 4 callersMethodisPersistenceEnabled
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 callersMethodisPostProcessingMapStore
()
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/MapDataStore.java:103
↓ 4 callersMethodisPrimaryKey
()
extensions/mongodb/src/main/java/com/hazelcast/jet/sql/impl/connector/mongodb/MongoTableField.java:46
↓ 4 callersMethodisPublishable
()
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/accumulator/AccumulatorInfo.java:146
↓ 4 callersMethodisPutIfAbsent
()
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/StaticParams.java:222
↓ 4 callersMethodisPutIfExists
()
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/StaticParams.java:230
↓ 4 callersMethodisPutVanilla
()
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/StaticParams.java:226
↓ 4 callersMethodisQueryResultLimitEnabled
Just for testing.
hazelcast/src/main/java/com/hazelcast/map/impl/query/QueryResultSizeLimiter.java:113
↓ 4 callersMethodisReceived
(V message)
hazelcast/src/test/java/com/hazelcast/topic/impl/reliable/SubscriptionMigrationTest.java:104
↓ 4 callersMethodisRecordExistsInMemory
()
hazelcast/src/main/java/com/hazelcast/map/impl/operation/steps/engine/State.java:247
↓ 4 callersMethodisRedoOperation
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 callersMethodisRemote
()
hazelcast/src/main/java/com/hazelcast/jet/impl/connector/StreamEventJournalP.java:448
← previousnext →12,501–12,600 of 147,315, ranked by callers