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
childrenPairs
Returns the children as {@link YamlNameNodePair}s <p> This method may have {@code null} values as the {@code childNode} in the returned pairs if the n
hazelcast/src/main/java/com/hazelcast/internal/yaml/YamlMapping.java:46
↓ 5 callers
Method
classResource
(Class<?> clazz)
hazelcast/src/test/java/com/hazelcast/jet/impl/util/ReflectionUtilsTest.java:273
↓ 5 callers
Method
cleanUpClient
()
hazelcast/src/test/java/com/hazelcast/kubernetes/KubernetesClientTest.java:110
↓ 5 callers
Method
clear
Clears the data in the ringbuffer.
hazelcast/src/main/java/com/hazelcast/ringbuffer/impl/Ringbuffer.java:178
↓ 5 callers
Method
clear
()
hazelcast/src/main/java/com/hazelcast/replicatedmap/impl/record/ReplicatedRecordStore.java:69
↓ 5 callers
Method
clear
()
hazelcast/src/main/java/com/hazelcast/internal/adapter/DataStructureAdapter.java:135
↓ 5 callers
Method
clear
clears all interfaces.
hazelcast/src/main/java/com/hazelcast/config/InterfacesConfig.java:60
↓ 5 callers
Method
clientInitializedOnCluster
Returns {@code true} if the client is initialized on the cluster, by sending its local state, if necessary.
hazelcast/src/main/java/com/hazelcast/client/impl/connection/ClientConnectionManager.java:63
↓ 5 callers
Method
close
Called as the last method in the processor lifecycle. It is called whether the job was successful or not, and strictly before {@link ProcessorSupplier
hazelcast/src/main/java/com/hazelcast/jet/core/Processor.java:550
↓ 5 callers
Method
close
()
hazelcast/src/main/java/com/hazelcast/jet/impl/deployment/IMapOutputStream.java:44
↓ 5 callers
Method
closeWithLogging
(PooledConnection closeable)
hazelcast/src/main/java/com/hazelcast/jet/impl/connector/WriteJdbcP.java:325
↓ 5 callers
Method
clusterConnectionFailed
Called when connection to a candidate cluster failed & could not establish connection with any members. The failure reasons are indicated by previousl
hazelcast/src/main/java/com/hazelcast/client/impl/management/ClientConnectionProcessListener.java:115
↓ 5 callers
Method
collect
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/aggregate/ValueSqlAggregation.java:48
↓ 5 callers
Method
collectAll
(Iterator<T> iterator)
hazelcast/src/test/java/com/hazelcast/map/AbstractMapQueryIterableTest.java:237
↓ 5 callers
Method
collectNoValue
(MetricDescriptor descriptor)
hazelcast/src/main/java/com/hazelcast/internal/metrics/collectors/MetricsCollector.java:34
↓ 5 callers
Method
collectObjectKeys
(Table table)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/CreateTopLevelDagVisitor.java:793
↓ 5 callers
Method
collections
()
hazelcast/src/main/java/com/hazelcast/internal/metrics/managementcenter/MetricsResultSet.java:39
↓ 5 callers
Method
compareTo
()
hazelcast/src/test/java/com/hazelcast/version/VersionTest.java:151
↓ 5 callers
Method
compareTo
(Object o)
hazelcast/src/main/java/com/hazelcast/internal/partition/PartitionServiceProxy.java:227
↓ 5 callers
Method
compareTrees
Compares the provided local and the remote Merkle trees and returns the breadth-first orders of the leaves that found to be different. <p> This method
hazelcast/src/main/java/com/hazelcast/wan/impl/merkletree/MerkleTreeUtil.java:324
↓ 5 callers
Method
complement
Mutates this set, so it contains its complement with respect to the universe of all partition IDs.
hazelcast/src/main/java/com/hazelcast/internal/util/collection/PartitionIdSet.java:233
↓ 5 callers
Method
complete
(Object value)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/Invocation.java:688
↓ 5 callers
Method
completeInFlightOperationExceptionally
(long schemaId, InternalCompletableFuture<Collection<U
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/compact/schema/SchemaReplicator.java:328
↓ 5 callers
Method
compositeCollector
( OutboundCollector[] collectors, EdgeDef outboundEdge, int partitionCount
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/OutboundCollector.java:59
↓ 5 callers
Method
computeDigest
(StringBuilder sb, Set<String> seen)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/QueryDataType.java:434
↓ 5 callers
Method
computeMaxCliques
(Graph<String> graph)
hazelcast/src/test/java/com/hazelcast/internal/util/graph/BronKerboschCliqueFinderTest.java:87
↓ 5 callers
Method
conclude
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/inject/PortableUpsertTarget.java:87
↓ 5 callers
Method
configureCapacity
Set the capacity of the underlying {@link Ringbuffer}, which defaults to {@value RingbufferConfig#DEFAULT_CAPACITY}. <p> This method can be called onl
hazelcast/src/main/java/com/hazelcast/jet/Observable.java:137
↓ 5 callers
Method
configureEdgeFn
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/SqlConnector.java:639
↓ 5 callers
Method
configureTcpIpConfig
(Config config)
hazelcast/src/test/java/com/hazelcast/internal/networking/nio/AbstractAdvancedNetworkIntegrationTest.java:96
↓ 5 callers
Method
containerIterator
(int partitionId)
hazelcast/src/test/java/com/hazelcast/spi/impl/merge/TestContainerCollector.java:45
↓ 5 callers
Method
contains
(BigInteger value)
extensions/kinesis/src/main/java/com/hazelcast/jet/kinesis/impl/source/HashRange.java:101
↓ 5 callers
Method
contains
{@inheritDoc}
hazelcast/src/main/java/com/hazelcast/internal/util/collection/LongHashSet.java:159
↓ 5 callers
Method
containsValue
Returns whether the multimap contains an entry with the value. @param value the value whose existence is checked @return {@code true} if the multimap
hazelcast/src/main/java/com/hazelcast/multimap/MultiMap.java:259
↓ 5 callers
Method
context
Allows for objects to be bound to this Reactor. Useful for the lookup of services and other dependencies. <p/> This method is thread-safe.
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/Reactor.java:130
↓ 5 callers
Method
coordinatorId
Return the ID of the coordinator - the master member for normal jobs and the {@link #lightJobCoordinator} for light jobs.
hazelcast/src/main/java/com/hazelcast/jet/impl/AbstractJobProxy.java:430
↓ 5 callers
Method
copyToHeapBuffer
Copies the contents of the {@code src} to {@code dst} backed by an on-heap buffer. The {@code src} can be backed by either on-heap or off-heap buffer.
hazelcast/src/main/java/com/hazelcast/internal/nio/IOUtil.java:393
↓ 5 callers
Method
count
()
extensions/kinesis/src/test/java/com/hazelcast/jet/kinesis/KinesisStressIntegrationTest.java:202
↓ 5 callers
Method
count
()
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/MetricsCompressor.java:317
↓ 5 callers
Method
create
(Expression<?> operand)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/expression/string/LowerFunction.java:35
↓ 5 callers
Method
create
(Expression<?> operand)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/expression/string/InitcapFunction.java:35
↓ 5 callers
Method
create
(Expression<?> operand)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/expression/string/AsciiFunction.java:35
↓ 5 callers
Method
create
(Expression<?> operand)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/expression/string/CharLengthFunction.java:35
↓ 5 callers
Method
create
(Expression<?> operand)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/expression/string/UpperFunction.java:35
↓ 5 callers
Method
create
(Expression<?> seedExp)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/expression/math/RandFunction.java:41
↓ 5 callers
Method
create
Create the optimization context. @param searchPaths Search paths to support "current schema" feature. @return Context.
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/OptimizerContext.java:110
↓ 5 callers
Method
create
(Supplier<T> initFunction, Supplier<Boolean> existsFunction,
hazelcast/src/main/java/com/hazelcast/spi/impl/tenantcontrol/TenantContextual.java:50
↓ 5 callers
Method
createAddressProvider
(ClientConfig config)
hazelcast/src/test/java/com/hazelcast/client/test/TestHazelcastFactory.java:108
↓ 5 callers
Method
createAndFillListedBean
(Node node, Class<?> clazz, String propertyName,
hazelcast-spring/src/main/java/com/hazelcast/spring/AbstractHazelcastBeanDefinitionParser.java:154
↓ 5 callers
Method
createBaseEventContext
(@Nonnull CacheEventType eventType, @Nonnull Data d
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheEventContextUtil.java:119
↓ 5 callers
Method
createCacheConfig
(SimpleEntryListener simpleEntryListener, HazelcastExpiryPolicy expiryPolicy)
hazelcast/src/test/java/com/hazelcast/internal/eviction/CacheExpirationManagerTest.java:264
↓ 5 callers
Method
createCachingProvider
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/cache/instance/CacheThroughHazelcastInstanceTest.java:81
↓ 5 callers
Method
createCancellationException
Creates exception with appropriate type for job cancellation.
hazelcast/src/main/java/com/hazelcast/jet/impl/MasterJobContext.java:238
↓ 5 callers
Method
createClient
(boolean allMembersRouting)
hazelcast/src/test/java/com/hazelcast/client/executor/ClientExecutorServiceCancelTest.java:87
↓ 5 callers
Method
createClientConfig
()
hazelcast/src/test/java/com/hazelcast/client/usercodedeployment/ClientUserCodeDeploymentTest.java:101
↓ 5 callers
Method
createCluster
()
hazelcast/src/test/java/com/hazelcast/jet/impl/submitjob/clientside/execute/JobExecuteClientSuccessTest.java:208
↓ 5 callers
Method
createConfigWithDummyTxService
()
hazelcast/src/test/java/com/hazelcast/map/impl/tx/MapTransactionStressTest.java:194
↓ 5 callers
Method
createConnectionProcessListenerRunner
()
hazelcast/src/test/java/com/hazelcast/client/impl/spi/impl/DefaultAddressProviderTest.java:124
↓ 5 callers
Method
createDiscovery
()
hazelcast/src/test/java/com/hazelcast/client/impl/spi/impl/discovery/ViridianAddressProviderTest.java:155
↓ 5 callers
Method
createExecutionPlans
( NodeEngineImpl nodeEngine, List<MemberInfo> memberInfos, DAG dag,
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/init/ExecutionPlanBuilder.java:83
↓ 5 callers
Method
createFactory
()
hazelcast/src/main/java/com/hazelcast/internal/serialization/DataSerializerHook.java:31
↓ 5 callers
Method
createFileWithString
(String string)
hazelcast/src/test/java/com/hazelcast/config/replacer/EncryptionReplacerTest.java:184
↓ 5 callers
Method
createFunction
(String search, String text, int start)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/string/PositionFunctionIntegrationTest.java:181
↓ 5 callers
Method
createHazelcastInstances
()
hazelcast/src/test/java/com/hazelcast/collection/impl/queue/QueueAdvancedTest.java:694
↓ 5 callers
Method
createHeader
(boolean identified, boolean versioned)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/DataSerializableHeader.java:55
↓ 5 callers
Method
createIndex
Creates a new index with the given name. @param node The node object @param config Index configuration. @param extractors the extract
hazelcast/src/main/java/com/hazelcast/query/impl/IndexProvider.java:46
↓ 5 callers
Method
createJdbcMappingUsingDataConnection
(String name, String dataConnection)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/jdbc/JdbcSqlTestSupport.java:247
↓ 5 callers
Method
createKafkaMappingUsingDataConnection
(String name, String dataConnection, String sqlOptions)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/kafka/KafkaSqlTestSupport.java:133
↓ 5 callers
Method
createMapFromNewClient
(String mapName)
hazelcast/src/test/java/com/hazelcast/client/map/impl/nearcache/invalidation/ClientMapReconciliationTest.java:170
↓ 5 callers
Method
createMapping
(boolean includeIdInMapping)
extensions/mongodb/src/test/java/com/hazelcast/jet/sql/impl/connector/mongodb/MongoSqlConnectorIT.java:410
↓ 5 callers
Method
createMasterInvocationBuilder
Creates an {@link InvocationBuilder} for invoking an operation on the master member of the cluster. <p> Note: This method only guarantees that the ope
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/OperationService.java:267
↓ 5 callers
Method
createMembers
()
hazelcast/src/test/java/com/hazelcast/spi/discovery/DiscoverySpiTest.java:816
↓ 5 callers
Method
createMultiResultSet
()
hazelcast/src/main/java/com/hazelcast/query/impl/BaseSingleValueIndexStore.java:77
↓ 5 callers
Method
createNearCacheConfig
(String mapName)
hazelcast/src/test/java/com/hazelcast/map/impl/tx/TxnMapNearCacheInvalidationTest.java:254
↓ 5 callers
Method
createNearCacheWithMaxSizePolicy
(InMemoryFormat inMemoryFormat, MaxSizePolicy maxSizePolicy, int size)
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/NearCacheRecordStoreTestSupport.java:234
↓ 5 callers
Method
createObjectDataInputStream
(InputStream in, InternalSerializationService ss)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/SerializationUtil.java:180
↓ 5 callers
Method
createParamSet
( FunctionEx<StreamStage<Integer>, StreamStage<Integer>> transform, List<String> verte
hazelcast/src/test/java/com/hazelcast/jet/pipeline/OrderedStreamParallelismTest.java:124
↓ 5 callers
Method
createPartitionStateInternal
Returns a copy of the partition table or {@code null} if not initialized. This method will acquire the partition service lock.
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/InternalPartitionServiceImpl.java:469
↓ 5 callers
Method
createPlan
(PlanKey key, Map<UUID, PartitionIdSet> partitions, int... objectKeys)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/cache/PlanCacheTestSupport.java:66
↓ 5 callers
Method
createReaderWriterForArray
(CompactStreamSerializer compactStreamSerializer,
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/compact/zeroconfig/ValueReaderWriters.java:220
↓ 5 callers
Method
createRexToExpressionVisitor
( PlanNodeFieldTypeProvider schema, QueryParameterMetadata parameterMetadata)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/OptUtils.java:325
↓ 5 callers
Method
createRunnableAdapter
(Runnable command)
hazelcast/src/main/java/com/hazelcast/client/impl/proxy/ClientDurableExecutorServiceProxy.java:234
↓ 5 callers
Method
createRunnableAdapter
(Runnable command)
hazelcast/src/main/java/com/hazelcast/durableexecutor/impl/DurableExecutorServiceProxy.java:284
↓ 5 callers
Method
createSqlCatalogConfig
()
hazelcast/src/main/java/com/hazelcast/jet/impl/JetServiceBackend.java:198
↓ 5 callers
Method
createSupplier
(List<Integer> assignedPartitions, long idleTimeout)
hazelcast/src/test/java/com/hazelcast/jet/impl/connector/StreamEventJournalP_WmCoalescingTest.java:189
↓ 5 callers
Method
currentTask
Returns the current task that is executing. This value could be null if no operation is executing. <p> Value could be stale as soon as it is returned.
hazelcast/src/main/java/com/hazelcast/spi/impl/operationexecutor/OperationRunner.java:95
↓ 5 callers
Method
dataConnection
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/schema/DataConnectionResolverTest.java:162
↓ 5 callers
Method
dataMapIndex
The data map index of current successful snapshot (0 or 1) or -1, if there's no successful snapshot.
hazelcast/src/main/java/com/hazelcast/jet/impl/JobExecutionRecord.java:211
↓ 5 callers
Method
decode
(ClientMessage.ForwardFrameIterator iterator)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/ListUUIDCodec.java:46
↓ 5 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/MCSetDiagnosticsConfigCodec.java:134
↓ 5 callers
Method
decrementOwnedEntryCount
()
hazelcast/src/main/java/com/hazelcast/internal/monitor/impl/NearCacheStatsImpl.java:137
↓ 5 callers
Method
decrementOwnedEntryMemoryCost
(long ownedEntryMemoryCost)
hazelcast/src/main/java/com/hazelcast/internal/monitor/impl/NearCacheStatsImpl.java:154
↓ 5 callers
Method
deleteClientCursor
(QueryId queryId)
hazelcast/src/main/java/com/hazelcast/sql/impl/state/QueryClientStateRegistry.java:255
↓ 5 callers
Method
deserializeAliasedDiscoveryConfig
Deserializes the aliased discovery config nested under the {@code tag} in the provided JSON. @param json the JSON object containing the serialized co
hazelcast/src/main/java/com/hazelcast/internal/management/dto/WanBatchPublisherConfigDTO.java:197
↓ 5 callers
Method
deserializeWithCustomClassLoader
( SerializationService serializationService, ClassLoader cl, Data data )
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/init/CustomClassLoadedObject.java:59
↓ 5 callers
Method
destroy
()
hazelcast/src/main/java/com/hazelcast/replicatedmap/impl/record/ReplicatedRecordStore.java:81
↓ 5 callers
Method
destroy
Clears the record store and destroys it.
hazelcast/src/main/java/com/hazelcast/internal/nearcache/NearCache.java:158
↓ 5 callers
Method
destroy
()
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/impl/ScheduledExecutorContainerHolder.java:25
↓ 5 callers
Method
detectTimeout
(long heartbeatTimeoutMillis)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/Invocation.java:473
↓ 5 callers
Method
disableLogging
Disables logging of input and output objects. Normally they are logged as they are processed to standard output. @return {@code this} instance for fl
hazelcast/src/main/java/com/hazelcast/jet/core/test/TestSupport.java:501
← previous
next →
10,301–10,400 of 147,315, ranked by callers