MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

↓ 4 callersMethodreplaceIfSameInternal
(Object key, Object oldValue, Object newValue)
hazelcast/src/main/java/com/hazelcast/client/impl/proxy/ClientMapProxy.java:658
↓ 4 callersMethodreplicaBackupLog
(List<TransactionLogRecord> records, UUID callerUuid, UUID txnId, long timeou
hazelcast/src/main/java/com/hazelcast/transaction/impl/TransactionManagerServiceImpl.java:310
↓ 4 callersMethodrequestTermination
(boolean userInitiated)
hazelcast/src/main/java/com/hazelcast/jet/impl/LightMasterContext.java:365
↓ 4 callersMethodrequestedTerminationMode
()
hazelcast/src/main/java/com/hazelcast/jet/impl/MasterJobContext.java:227
↓ 4 callersMethodrequireNonBlank
(@Nonnull String in, @Nonnull String name)
extensions/python/src/main/java/com/hazelcast/jet/python/PythonServiceConfig.java:289
↓ 4 callersMethodrequiresSort
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/IndexScanMapPhysicalRel.java:125
↓ 4 callersMethodreset
()
hazelcast/src/main/java/com/hazelcast/sql/impl/InternalSqlService.java:39
↓ 4 callersMethodreset
()
hazelcast/src/main/java/com/hazelcast/query/impl/getters/JsonPathCursor.java:158
↓ 4 callersMethodresetFlagsTo
Resets the entire {@code flags} bitfield to the supplied value. This also affects the packet type bits. @param flagsToSet the flags. Only the least s
hazelcast/src/main/java/com/hazelcast/internal/nio/Packet.java:184
↓ 4 callersMethodresetPointers
Resets the iteration state.
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheIterator.java:210
↓ 4 callersMethodresetSystemOut
Clears standard output buffer. @return original content of the standard output
hazelcast/src/test/java/com/hazelcast/client/console/ClientConsoleAppTest.java:189
↓ 4 callersMethodresetSystemOut
Clears standard output buffer. @return original content of the standard output
hazelcast/src/test/java/com/hazelcast/console/ConsoleAppTest.java:168
↓ 4 callersMethodresolve
(Object value)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/support/expressions/ExpressionTypes.java:55
↓ 4 callersMethodresolve
(Object object)
hazelcast/src/main/java/com/hazelcast/spi/impl/DeserializingCompletableFuture.java:320
↓ 4 callersMethodresolveAndThrowIfException
(Object state)
hazelcast/src/main/java/com/hazelcast/spi/impl/AbstractInvocationFuture.java:116
↓ 4 callersMethodresolveClass
Return a list of fields and their types from a {@link Class}.
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/FieldUtils.java:60
↓ 4 callersMethodresolveCluster
(AwsConfig awsConfig, AwsMetadataApi metadataApi, Environment environment)
hazelcast/src/main/java/com/hazelcast/aws/AwsClientConfigurator.java:170
↓ 4 callersMethodresolveFields
(Schema schema)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/file/AvroResolver.java:37
↓ 4 callersMethodresolveObjectFile
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/extract/JsonQueryTargetTest.java:91
↓ 4 callersMethodresolvePortable
(ClassDefinition classDefinition, boolean key)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/map/SampleMetadataResolver.java:99
↓ 4 callersMethodresolveRegion
(AwsConfig awsConfig, AwsMetadataApi metadataApi, Environment environment)
hazelcast/src/main/java/com/hazelcast/aws/AwsClientConfigurator.java:72
↓ 4 callersMethodresolveType
Convert the column type received from database to QueryDataType. QueryDataType represents the data types that can be used in Hazelcast's distributed q
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/jdbc/DefaultTypeResolver.java:34
↓ 4 callersMethodresponse
(String json)
extensions/elasticsearch/elasticsearch-7/src/test/java/com/hazelcast/jet/elastic/impl/ElasticCatClientTest.java:90
↓ 4 callersMethodrestartCluster
(boolean graceful, ClusterState restartInState, String indexMapName)
hazelcast/src/test/java/com/hazelcast/client/map/ClientIndexStatsTest.java:218
↓ 4 callersMethodrestoreInterrupt
(boolean interrupted)
hazelcast/src/main/java/com/hazelcast/spi/impl/AbstractInvocationFuture.java:1939
↓ 4 callersMethodresult
(long winEnd, Collection<String> result)
hazelcast/src/test/java/com/hazelcast/jet/impl/processor/SlidingWindowP_FrameCombiningTest.java:63
↓ 4 callersMethodresults
Returns the results. <p> The results are returned in the order the requests were done. <p> This call waits till all requests have completed. @return
hazelcast/src/main/java/com/hazelcast/core/Pipelining.java:113
↓ 4 callersMethodrethrowAllowInterrupted
(final Throwable t)
hazelcast/src/main/java/com/hazelcast/internal/util/ExceptionUtil.java:167
↓ 4 callersMethodretryAllOperations
()
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/InvokeOnLocalPartitions.java:129
↓ 4 callersMethodreturnsResponse
Method is intended to be overridden. If it returns {@code true}, {@link #getResponse()} will be called right after {@link #run()} method. If it return
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/Operation.java:224
↓ 4 callersMethodroundCapacity
Round the capacity to the next allowed value.
hazelcast/src/main/java/com/hazelcast/internal/util/hashslot/impl/CapacityUtil.java:47
↓ 4 callersMethodroundUp
(long value, long unit)
hazelcast/src/test/java/com/hazelcast/jet/pipeline/PipelineTestSupport.java:212
↓ 4 callersMethodrows
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/infoschema/MappingsTable.java:87
↓ 4 callersMethodrun
()
hazelcast/src/main/java/com/hazelcast/ringbuffer/impl/operations/AddAllOperation.java:57
↓ 4 callersMethodrun
()
hazelcast/src/main/java/com/hazelcast/ringbuffer/impl/operations/AddOperation.java:57
↓ 4 callersMethodrunDirect
Runs op directly without checking any conditions; node state, partition ownership, timeouts etc. <p> {@link Operation#beforeRun()}, {@link Operation#c
hazelcast/src/main/java/com/hazelcast/spi/impl/operationexecutor/OperationRunner.java:173
↓ 4 callersMethodrunInternal
()
hazelcast/src/main/java/com/hazelcast/map/impl/operation/MapOperation.java:272
↓ 4 callersMethodrunInternalDirect
()
hazelcast/src/main/java/com/hazelcast/map/impl/operation/MapOperation.java:277
↓ 4 callersMethodrunLightJob
()
hazelcast/src/test/java/com/hazelcast/jet/JobStatusListenerTest.java:403
↓ 4 callersMethodrunQuery
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/AnalyzeStatementTest.java:381
↓ 4 callersMethodrunTest
( JoinRelType joinType, Expression<Boolean> nonEquiCondition, int rightInp
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/processors/SqlHashJoinPTest.java:145
↓ 4 callersMethodrunTest
(SupplierEx<Processor> sup)
hazelcast/src/test/java/com/hazelcast/jet/impl/connector/UpdateMapPTest.java:126
↓ 4 callersMethodsave
Task callback to capture its state on the provided map. This is invoked after each invocation of {@link Runnable#run()} or {@link Callable#call()} to
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/StatefulTask.java:76
↓ 4 callersMethodsaveIndex
(Data dataKey, Record record, Object oldValue, Index.OperationSource operationSourc
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/IndexingMutationObserver.java:162
↓ 4 callersMethodscan
()
hazelcast/src/main/java/com/hazelcast/internal/jmx/HazelcastMBean.java:86
↓ 4 callersMethodscheduleActiveMigrationFinalization
Finalizes the active migration if it is equal to the {@code migrationInfo} or if this node was a backup replica before the migration (see {@link Final
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/MigrationManager.java:108
↓ 4 callersMethodscheduleMigrationTask
Schedules a {@link CRDTMigrationTask} with a delay of {@code delaySeconds} seconds.
hazelcast/src/main/java/com/hazelcast/internal/crdt/CRDTReplicationMigrationService.java:252
↓ 4 callersMethodscheduleOnAllMembersAtFixedRate
Creates and executes a periodic action that becomes enabled first after the given initial delay, and subsequently with the given period on all cluster
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/IScheduledExecutorService.java:346
↓ 4 callersMethodscheduleOnMembers
(@Nonnull Runnable command, @Nonnull Collect
hazelcast/src/main/java/com/hazelcast/client/impl/proxy/ClientScheduledExecutorProxy.java:240
↓ 4 callersMethodscheduleOnMembers
(@Nonnull Runnable command, @Nonnull Collect
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/impl/ScheduledExecutorServiceProxy.java:278
↓ 4 callersMethodscheduleOnPartition
(String name, TaskDefinition definition, int partitionId)
hazelcast/src/main/java/com/hazelcast/client/impl/proxy/ClientScheduledExecutorProxy.java:420
↓ 4 callersMethodscheduleRestart
(String description)
hazelcast/src/main/java/com/hazelcast/jet/impl/MasterJobContext.java:594
↓ 4 callersMethodscheduleSelectAction
(SelectionKey selectionKey)
hazelcast/src/test/java/com/hazelcast/internal/networking/nio/NioThreadAbstractTest.java:180
↓ 4 callersMethodscheduleWithFixedDelay
Creates a periodically executing task with a fixed delay between the completion and start of the task. @param task the task to periodically e
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/Eventloop.java:219
↓ 4 callersMethodschema
(HazelcastTable... tables)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/opt/OptimizerTestSupport.java:128
↓ 4 callersMethodselect
(Client client)
hazelcast/src/main/java/com/hazelcast/client/impl/ClientSelector.java:23
↓ 4 callersMethodselectNow
()
hazelcast/src/test/java/com/hazelcast/internal/networking/nio/NioThreadAbstractTest.java:221
↓ 4 callersMethodselectedKeys
()
hazelcast/src/test/java/com/hazelcast/internal/networking/nio/NioThreadAbstractTest.java:213
↓ 4 callersMethodselectorMode
()
hazelcast/src/test/java/com/hazelcast/internal/networking/nio/Select_NioThreadTest.java:29
↓ 4 callersMethodself
()
hazelcast/src/main/java/com/hazelcast/config/security/SimpleAuthenticationConfig.java:193
↓ 4 callersMethodsend
(Operation operation, InetSocketAddress address)
hazelcast/src/test/java/com/hazelcast/internal/cluster/impl/operations/JoinShutdownTest.java:154
↓ 4 callersMethodsend503
Prepares a {@link HttpURLConnection#HTTP_UNAVAILABLE} response.
hazelcast/src/main/java/com/hazelcast/internal/ascii/rest/HttpCommand.java:113
↓ 4 callersMethodsendIfAlive
(ClientMessage eventMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/task/AddMigrationListenerMessageTask.java:83
↓ 4 callersMethodsendMemberListToMember
Sends the current member list to the {@code target}. Called on the master node. @param target the destination for the member update operation
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/MembershipManager.java:209
↓ 4 callersMethodsendOperations
(Collection<Operation> operations, Collection<ChunkSupplier> chunkSuppliers,
hazelcast/src/main/java/com/hazelcast/internal/partition/operation/PartitionReplicaSyncRequest.java:202
↓ 4 callersMethodsendRequestForAcknowledgment
(long schemaId)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/compact/schema/SchemaReplicator.java:346
↓ 4 callersMethodsendShutdownResponseOperation
Sends a {@link ShutdownResponseOperation} to the {@code address} or takes a shortcut if shutdown is local.
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/MigrationManagerImpl.java:760
↓ 4 callersMethodserde
(T object)
hazelcast-sql/src/test/java/com/hazelcast/sql/impl/type/QueryDataTypeTest.java:358
↓ 4 callersMethodserializationException
(@Nullable Class<?> clazz, Throwable t)
hazelcast/src/main/java/com/hazelcast/jet/impl/serialization/DelegatingSerializationService.java:156
↓ 4 callersMethodserialize
(Object o)
hazelcast/src/test/java/com/hazelcast/jet/aggregate/AggregateOperationsTest.java:826
↓ 4 callersMethodserviceLb
(ServicePort port, String lbIp)
hazelcast/src/test/java/com/hazelcast/kubernetes/KubernetesFakeUtils.java:427
↓ 4 callersMethodserviceLbWithMultiplePorts
(String name, List<ServicePort> ports, String lbIp)
hazelcast/src/test/java/com/hazelcast/kubernetes/KubernetesFakeUtils.java:443
↓ 4 callersMethodsessionTimeout
Returns the session timeout, which is the largest difference in the timestamps of any two consecutive events in the session window.
hazelcast/src/main/java/com/hazelcast/jet/pipeline/SessionWindowDefinition.java:49
↓ 4 callersMethodsetActive
(boolean active)
extensions/kafka-connect/src/main/java/com/hazelcast/jet/kafka/connect/impl/ReadKafkaConnectP.java:266
↓ 4 callersMethodsetAddresses
(List<String> addresses)
hazelcast/src/main/java/com/hazelcast/client/config/ClientNetworkConfig.java:249
↓ 4 callersMethodsetAlgorithm
Sets the encryption algorithm, such as {@code AES/CBC/PKCS5Padding}. @param algorithm the encryption algorithm
hazelcast/src/main/java/com/hazelcast/config/AbstractSymmetricEncryptionConfig.java:73
↓ 4 callersMethodsetAllowUnsafe
Unsafe, it is not public api of java. Use with caution! @param allowUnsafe set to {@code true} to allow usage of unsafe @return configured {@link com
hazelcast/src/main/java/com/hazelcast/config/SerializationConfig.java:507
↓ 4 callersMethodsetArrayOfBoolean
It is legal to set the field again only when Builder is created with {@link GenericRecord#newBuilderWithClone()}. Otherwise, it is illegal to set to t
hazelcast/src/main/java/com/hazelcast/nio/serialization/genericrecord/GenericRecordBuilder.java:694
↓ 4 callersMethodsetAttributeConfigs
(List<AttributeConfig> attributeConfigs)
hazelcast/src/main/java/com/hazelcast/config/MapConfig.java:598
↓ 4 callersMethodsetAwsConfig
@param awsConfig the AwsConfig join configuration to set @throws IllegalArgumentException if awsConfig is null
hazelcast/src/main/java/com/hazelcast/config/JoinConfig.java:92
↓ 4 callersMethodsetBackup
(boolean backup)
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/StaticParams.java:136
↓ 4 callersMethodsetBackupCount
Sets the number of backups that Jet will maintain for the job metadata and snapshots. Each backup is on another cluster member; all backup write opera
hazelcast/src/main/java/com/hazelcast/jet/config/InstanceConfig.java:120
↓ 4 callersMethodsetBackupEntryMemoryCost
(long backupEntryMemoryCost)
hazelcast/src/main/java/com/hazelcast/internal/monitor/impl/LocalMapStatsImpl.java:253
↓ 4 callersMethodsetBit
Sets 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:219
↓ 4 callersMethodsetBitsNodeId
Sets the bit-length of node id component. See {@link FlakeIdGenerator}'s class javadoc for more information. @param bitsNodeId node id component bit-
hazelcast/src/main/java/com/hazelcast/config/FlakeIdGeneratorConfig.java:269
↓ 4 callersMethodsetBitsSequence
Sets the bit-length of the sequence component. This setting determines the maximum rate at which IDs can be generated. See {@link FlakeIdGenerator}'s
hazelcast/src/main/java/com/hazelcast/config/FlakeIdGeneratorConfig.java:248
↓ 4 callersMethodsetCallback
(CompletionStage stage)
hazelcast/src/main/java/com/hazelcast/jet/impl/connector/AsyncHazelcastWriterP.java:117
↓ 4 callersMethodsetCapacityPolicy
Set the capacity policy for the configured capacity value <p> To prevent any undesirable data-loss, capacity is ignored during partition migrations, t
hazelcast/src/main/java/com/hazelcast/config/ScheduledExecutorConfig.java:224
↓ 4 callersMethodsetCatalogPersistenceEnabled
Sets whether SQL Catalog persistence is enabled for the node. With SQL Catalog persistence enabled you can restart the whole cluster without losing sc
hazelcast/src/main/java/com/hazelcast/config/SqlConfig.java:95
↓ 4 callersMethodsetChannel
Sets the Channel. <p> Should only be called by the {@link InboundPipeline}. @param channel the Channel @return this instance
hazelcast/src/main/java/com/hazelcast/internal/networking/ChannelHandler.java:97
↓ 4 callersMethodsetCheckClassDefErrors
(boolean checkClassDefErrors)
hazelcast/src/main/java/com/hazelcast/internal/serialization/SerializationServiceBuilder.java:49
↓ 4 callersMethodsetClass
Sets the class of the serializer implementation. @param clazz the set class of the serializer implementation @return SerializerConfig
hazelcast/src/main/java/com/hazelcast/config/SerializerConfig.java:65
↓ 4 callersMethodsetClasses
Sets the class names for this filter. @param names class names to set @return this filter
hazelcast/src/main/java/com/hazelcast/config/ClassFilter.java:110
↓ 4 callersMethodsetClientRealmConfig
(String realmName, RealmConfig realmConfig)
hazelcast/src/main/java/com/hazelcast/config/SecurityConfig.java:166
↓ 4 callersMethodsetColumnBlacklist
Optional regular expressions that match the fully-qualified names of columns that should be excluded from change event message values. Fully-qualified
extensions/cdc-mysql/src/main/java/com/hazelcast/jet/cdc/mysql/MySqlCdcSources.java:238
↓ 4 callersMethodsetColumnBlacklist
Optional regular expressions that match the fully-qualified names of columns that should be excluded from change event message values. Fully-qualified
extensions/cdc-postgres/src/main/java/com/hazelcast/jet/cdc/postgres/PostgresCdcSources.java:287
↓ 4 callersMethodsetCommitRetryStrategy
(RetryStrategy commitRetryStrategy)
extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/impl/WriteMongoParams.java:185
↓ 4 callersMethodsetCompletionId
(int completionId)
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheEventContext.java:166
↓ 4 callersMethodsetConfigClassLoader
(ClassLoader configClassLoader)
hazelcast/src/main/java/com/hazelcast/spi/discovery/integration/DiscoveryServiceSettings.java:64
↓ 4 callersMethodsetConfigurationUrl
Sets the {@link URL} from which this configuration has been retrieved and created. <p> Is set by the {@link XmlConfigBuilder}, when the XML configurat
hazelcast/src/main/java/com/hazelcast/config/Config.java:2874
← previousnext →12,901–13,000 of 147,315, ranked by callers