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
↓ 3 callers
Method
testBasics
()
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/portable/PortableTest.java:67
↓ 3 callers
Method
testClassDefinitionLookup
(InternalSerializationService ss)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/portable/PortableTest.java:332
↓ 3 callers
Method
testConfig2Xml2Config
(String fileName)
hazelcast/src/test/java/com/hazelcast/config/XmlOnlyConfigBuilderTest.java:241
↓ 3 callers
Method
testDrainTo
()
hazelcast/src/test/java/com/hazelcast/internal/util/concurrent/AbstractConcurrentArrayQueueTest.java:260
↓ 3 callers
Method
testExceptionThrownForTooLargeCapacity
()
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/ByteArrayObjectDataOutputTest.java:450
↓ 3 callers
Method
testExecute_withInvalid_partitionId
(Object task)
hazelcast/src/test/java/com/hazelcast/spi/impl/operationexecutor/impl/OperationThreadTest.java:120
↓ 3 callers
Method
testFlushAsync_shouldFlushSelectedPartitions
(@Nullable Set<Integer> partitionsToFlush)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/writebehind/WriteBehindFlushTest.java:170
↓ 3 callers
Method
testIndexForComparableAttributes
(IndexType indexType)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/extractor/QueryTest.java:100
↓ 3 callers
Method
testJoin_With_DifferentBuildNumber
(Config config)
hazelcast/src/test/java/com/hazelcast/cluster/AbstractJoinTest.java:67
↓ 3 callers
Method
testMapJournal_withPredicateAndProjection
(IMap<String, Integer> srcMap, StreamSource<Integer> source)
hazelcast/src/test/java/com/hazelcast/jet/pipeline/Sources_withEventJournalTest.java:399
↓ 3 callers
Method
testMaxAllowed
(RegisterCallback registerCallbackCall)
hazelcast/src/test/java/com/hazelcast/client/ClientMaxAllowedInvocationTest.java:135
↓ 3 callers
Method
testMaxAllowed_withWaitingCallbacks
(RegisterCallback registerCallbackCall)
hazelcast/src/test/java/com/hazelcast/client/ClientMaxAllowedInvocationTest.java:179
↓ 3 callers
Method
testMaxIdle_readThroughIndex
(IndexType type)
hazelcast/src/test/java/com/hazelcast/map/EvictionTest.java:230
↓ 3 callers
Method
testMergeAfterSplitBrain
(boolean multicast)
hazelcast/src/test/java/com/hazelcast/cluster/SplitBrainHandlerTest.java:199
↓ 3 callers
Method
testMigrationListenerInvoked
( T clientListener, Function<MigrationListener, HazelcastInstance> clientFactory,
hazelcast/src/test/java/com/hazelcast/client/partitionservice/ClientMigrationListenerTest.java:185
↓ 3 callers
Method
testMultipleOrPredicates
(IMap<Integer, Employee> map)
hazelcast/src/test/java/com/hazelcast/map/impl/query/QueryBasicTest.java:819
↓ 3 callers
Method
testNext
(Operation operation)
hazelcast/src/test/java/com/hazelcast/spi/impl/sequence/CallIdSequenceWithBackpressureTest.java:64
↓ 3 callers
Method
testPaths
(WriterConfig config)
hazelcast/src/test/java/com/hazelcast/json/internal/AbstractJsonSchemaTest.java:63
↓ 3 callers
Method
testProxyCreation
(String serviceName, ClientConfig clientConfig)
hazelcast/src/test/java/com/hazelcast/client/impl/spi/ProxyFactoryTest.java:120
↓ 3 callers
Method
testQueue
(Callable<Object> task)
hazelcast/src/test/java/com/hazelcast/client/txn/ClientTxnDisconnectionTest.java:103
↓ 3 callers
Method
testReplicatedMapCreated
(int numberOfLiteNodes, int numberOfDataNodes,
hazelcast/src/test/java/com/hazelcast/client/replicatedmap/ClientReplicatedMapLiteMemberTest.java:94
↓ 3 callers
Method
testScripting
(Boolean enabled)
hazelcast/src/test/java/com/hazelcast/internal/management/TimedMemberStateIntegrationTest.java:103
↓ 3 callers
Method
testSerialization
(RingbufferContainer original)
hazelcast/src/test/java/com/hazelcast/ringbuffer/impl/RingbufferContainerSerializationTest.java:131
↓ 3 callers
Method
testSerializer
()
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/CustomSerializationTest.java:47
↓ 3 callers
Method
testSyncListener_shouldNotHang_AfterAction
(String cacheName, CachingProvider provider, Runnable action)
hazelcast/src/test/java/com/hazelcast/cache/CacheListenerTest.java:281
↓ 3 callers
Method
testTopologyChange
( Supplier<HazelcastInstance> secondMemberSupplier, Consumer<HazelcastInstance> change
hazelcast/src/test/java/com/hazelcast/jet/pipeline/SourceBuilder_TopologyChangeTest.java:72
↓ 3 callers
Method
test_DefaultOutOfMemoryHandler_using_accessor
(MemoryInfoAccessor memoryInfoAccessor, Verific
hazelcast/src/test/java/com/hazelcast/instance/impl/OutOfMemoryErrorDispatcherTest.java:216
↓ 3 callers
Method
test_twoSlavesDisconnectedFromOneSlave
()
hazelcast/src/test/java/com/hazelcast/internal/cluster/impl/MembershipFailureTest.java:698
↓ 3 callers
Method
test_whenSpace
()
hazelcast/src/test/java/com/hazelcast/topic/impl/reliable/TopicOverloadAbstractTest.java:64
↓ 3 callers
Method
test_whenSpace_all
()
hazelcast/src/test/java/com/hazelcast/topic/impl/reliable/TopicOverloadAbstractTest.java:158
↓ 3 callers
Method
thenAcceptBoth
()
hazelcast/src/test/java/com/hazelcast/spi/impl/CompletableFutureAbstractTest.java:1286
↓ 3 callers
Method
thenCombine
()
hazelcast/src/test/java/com/hazelcast/spi/impl/CompletableFutureAbstractTest.java:1334
↓ 3 callers
Method
thenCombineAsync
()
hazelcast/src/test/java/com/hazelcast/spi/impl/CompletableFutureAbstractTest.java:1344
↓ 3 callers
Method
throwException
(long currentCapacity, long maxPerNodeCapacity, int requiredCapacity)
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/writebehind/NodeWideUsedCapacityCounter.java:81
↓ 3 callers
Method
throwJetExceptionFromJobMetaData
(JobMetaDataParameterObject jobMetaDataParameterObject, Exception exception)
hazelcast/src/main/java/com/hazelcast/jet/impl/JetServiceBackend.java:538
↓ 3 callers
Method
throwUnknownFieldException
(@Nonnull String fieldName)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/portable/DefaultPortableReader.java:467
↓ 3 callers
Method
timeToStringFriendly
Returns a String representation of the time. If time is 0, then 'never' is returned. <p> This method is not particularly efficient since it generates
hazelcast/src/main/java/com/hazelcast/internal/util/StringUtil.java:166
↓ 3 callers
Method
timeout
(Operation op)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/OperationRunnerImpl.java:373
↓ 3 callers
Method
timestampFn
Returns the function that extracts the timestamp from the event.
hazelcast/src/main/java/com/hazelcast/jet/core/EventTimePolicy.java:227
↓ 3 callers
Method
timestampToTimestampWithTimezone
Convert TIMESTAMP to TIMESTAMP WITH TIMEZONE as per ANSI standard. @param timestamp Original timestamp. @return Timestamp with timezone.
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/converter/AbstractTemporalConverter.java:65
↓ 3 callers
Method
toAccumulatorInfo
(QueryCacheConfig config, String mapName,
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/accumulator/AccumulatorInfo.java:60
↓ 3 callers
Method
toBackingDataKeyFormat
(Data key)
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/Storage.java:166
↓ 3 callers
Method
toBean
Secure parser of JSON to given type. Rejects dangerous types.
hazelcast/src/main/java/com/hazelcast/jet/json/impl/JsonUtilImpl.java:45
↓ 3 callers
Method
toBeanBiFn
Secure parser of JSON to given type. Rejects dangerous types.
hazelcast/src/main/java/com/hazelcast/jet/json/impl/JsonUtilImpl.java:54
↓ 3 callers
Method
toBuilder
@return SearchOptionsBuilder with the same settings @since 5.6
hazelcast/src/main/java/com/hazelcast/vector/SearchOptions.java:58
↓ 3 callers
Method
toData
(Object item)
hazelcast/src/test/java/com/hazelcast/ringbuffer/impl/operations/ReadOneOperationTest.java:76
↓ 3 callers
Method
toData
(Object val)
hazelcast/src/main/java/com/hazelcast/cache/impl/journal/RingbufferCacheEventJournalImpl.java:222
↓ 3 callers
Method
toData
(Data data, Object o)
hazelcast/src/main/java/com/hazelcast/cache/impl/journal/DeserializingEventJournalCacheEvent.java:124
↓ 3 callers
Method
toData
(Object val)
hazelcast/src/main/java/com/hazelcast/map/impl/journal/RingbufferMapEventJournalImpl.java:189
↓ 3 callers
Method
toData
(Data data, Object o)
hazelcast/src/main/java/com/hazelcast/map/impl/journal/DeserializingEventJournalMapEvent.java:120
↓ 3 callers
Method
toDataCollectionWithNonNullKeyValidation
(Set<K> keys, Collection<Data> dataKeys)
hazelcast/src/main/java/com/hazelcast/map/impl/proxy/MapProxySupport.java:1456
↓ 3 callers
Method
toEntry
(String key, Object value)
hazelcast/src/main/java/com/hazelcast/internal/ascii/memcache/EntryConverter.java:37
↓ 3 callers
Method
toFuture
Allows you to post-process the results of a Jet job on the client side using the standard Java {@link java.util.stream Stream API}. You provide a func
hazelcast/src/main/java/com/hazelcast/jet/Observable.java:202
↓ 3 callers
Method
toImmutableLazySet
(List resultSet)
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/subscriber/AbstractInternalQueryCache.java:175
↓ 3 callers
Method
toIndex
(long sequence)
hazelcast/src/main/java/com/hazelcast/ringbuffer/impl/ArrayRingbuffer.java:141
↓ 3 callers
Method
toIndex
(long sequence)
hazelcast/src/main/java/com/hazelcast/spi/merge/RingbufferMergeData.java:202
↓ 3 callers
Method
toJobMetrics
(List<RawJobMetrics> rawJobMetrics)
hazelcast/src/main/java/com/hazelcast/jet/impl/JobMetricsUtil.java:58
↓ 3 callers
Method
toJsonArray
(JsonValue jsonValue)
hazelcast/src/main/java/com/hazelcast/azure/AzureComputeApi.java:147
↓ 3 callers
Method
toJsonObject
(JsonValue jsonValue)
hazelcast/src/main/java/com/hazelcast/azure/AzureComputeApi.java:155
↓ 3 callers
Method
toMap
(Properties properties)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/util/PropertiesUtil.java:37
↓ 3 callers
Method
toNearCacheValue
(V value, Data valueData)
hazelcast/src/main/java/com/hazelcast/client/cache/impl/nearcache/NearCachedClientCacheProxy.java:927
↓ 3 callers
Method
toNode
(String yaml)
hazelcast/src/test/java/com/hazelcast/internal/config/YamlMemberDomConfigProcessorTest.java:61
↓ 3 callers
Method
toNullFunction
Returns a function that passes its argument to the given {@code consumer} and returns {@code null}.
hazelcast/src/main/java/com/hazelcast/jet/impl/JobCoordinationService.java:1034
↓ 3 callers
Method
toObject
(Object data)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheIterator.java:235
↓ 3 callers
Method
toObject
(Object responseData)
hazelcast/src/main/java/com/hazelcast/client/cache/impl/CacheStatsHandler.java:175
↓ 3 callers
Method
toProperties
()
extensions/cdc-debezium/src/main/java/com/hazelcast/jet/cdc/impl/DebeziumConfig.java:68
↓ 3 callers
Method
toQueryEntry
(Object key, Object value)
hazelcast/src/test/java/com/hazelcast/query/PortablePredicatesTest.java:71
↓ 3 callers
Method
toSocketOption
(Option option)
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/nio/NioAsyncServerSocketOptions.java:44
↓ 3 callers
Method
toSocketOption
(Option option)
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/nio/NioAsyncSocketOptions.java:44
↓ 3 callers
Method
toString
()
hazelcast/src/test/java/com/hazelcast/kubernetes/RuntimeContextTest.java:187
↓ 3 callers
Method
toString
()
hazelcast/src/main/java/com/hazelcast/sql/SqlColumnType.java:138
↓ 3 callers
Method
toString
(JsonValue jsonValue)
hazelcast/src/main/java/com/hazelcast/kubernetes/KubernetesClient.java:633
↓ 3 callers
Method
toString
()
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/MetricDescriptorImpl.java:420
↓ 3 callers
Method
toString
()
hazelcast/src/main/java/com/hazelcast/internal/partition/PartitionMigrationEvent.java:124
↓ 3 callers
Method
toString
Converts the provided collection to string, joined by LINE_SEPARATOR @param collection collection to convert to string @return string
hazelcast/src/main/java/com/hazelcast/internal/util/StringUtil.java:381
↓ 3 callers
Method
toStringFn
Sets the function which converts the item to its string representation. Each item is followed with a platform-specific line separator. Default value i
hazelcast/src/main/java/com/hazelcast/jet/pipeline/FileSinkBuilder.java:76
↓ 3 callers
Method
toTtlFromExpiryTime
(long expirationTime, long now)
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/DefaultRecordStore.java:570
↓ 3 callers
Method
toTumblingByFrame
Converts this definition to one defining a tumbling window of the same length as this definition's frame.
hazelcast/src/main/java/com/hazelcast/jet/core/SlidingWindowPolicy.java:143
↓ 3 callers
Method
toUnmodifiableHasSet
(Collection<Member> members)
hazelcast/src/main/java/com/hazelcast/client/impl/spi/impl/ClientClusterServiceImpl.java:275
↓ 3 callers
Method
toVectorValues
(List<VectorPairHolder> vectors)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/CustomTypeFactory.java:363
↓ 3 callers
Method
topObservedWm
Returns the highest received watermark from any input.
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/WatermarkCoalescer.java:93
↓ 3 callers
Method
totalFramesPending
(TcpServerConnection connection)
hazelcast/src/test/java/com/hazelcast/internal/server/tcp/TcpServerConnection_AbstractTransferStressTest.java:136
↓ 3 callers
Method
totalHeapCost
()
hazelcast/src/test/java/com/hazelcast/map/EntryCostEstimatorTest.java:285
↓ 3 callers
Method
touch
Simulates a Linux {@code touch} command, by setting the last modified time of given file. @param file the file to touch
hazelcast/src/main/java/com/hazelcast/internal/nio/IOUtil.java:675
↓ 3 callers
Method
trackNullInstance
()
hazelcast/src/test/java/com/hazelcast/map/MapListenerTest.java:116
↓ 3 callers
Method
transferTo
(long position, long count, WritableByteChannel target)
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/preloader/NearCachePreloaderLockTest.java:196
↓ 3 callers
Method
transformToSetWithNamespace
(QueryResult result, Predicate predicate, IterationType iterationT
hazelcast/src/main/java/com/hazelcast/map/impl/proxy/MapProxyImpl.java:828
↓ 3 callers
Method
transitionTransactionManagerStateTo
( Object transactionManager, String state)
extensions/kafka/src/main/java/com/hazelcast/jet/kafka/impl/ResumeTransactionUtil.java:171
↓ 3 callers
Method
translate
(Object[] input)
hazelcast/src/test/java/com/hazelcast/query/impl/extractor/AbstractExtractionTest.java:155
↓ 3 callers
Method
translateAddress
(Function<A, Address> addressTranslator, A target, String listenerMethodName)
hazelcast/src/main/java/com/hazelcast/client/impl/management/ClientConnectionProcessListenerRegistry.java:182
↓ 3 callers
Method
translateGrpcException
{@link io.grpc.StatusException} and {@link io.grpc.StatusRuntimeException} break the Serializable contract, see <a href="https://github.com/grpc/grpc-
extensions/grpc/src/main/java/com/hazelcast/jet/grpc/impl/GrpcUtil.java:40
↓ 3 callers
Method
transmit
(Address target, Packet packet, ServerConnectionManager connectionManager)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/OutboundResponseHandler.java:213
↓ 3 callers
Method
traverseAutoCloseableIterator
Returns an adapter from {@code Iterator} to {@code Traverser}. The iterator must return non-{@code null} items. Each time its {@code next()} method is
hazelcast/src/main/java/com/hazelcast/jet/impl/AutoCloseableTraversers.java:49
↓ 3 callers
Method
traverseSpliterator
Returns an adapter from {@code Spliterator} to {@code Traverser}. Each time its {@code next()} method is called, the traverser calls {@link Spliterato
hazelcast/src/main/java/com/hazelcast/jet/Traversers.java:110
↓ 3 callers
Method
triggerControlTask
()
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/MigrationManagerImpl.java:549
↓ 3 callers
Method
tryAcquirePermit
()
hazelcast/src/main/java/com/hazelcast/jet/impl/connector/AsyncHazelcastWriterP.java:121
↓ 3 callers
Method
tryExternalRollback
()
extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/impl/WriteMongoP.java:544
↓ 3 callers
Method
tryToConnect
(InetSocketAddress socketAddress, int timeout)
hazelcast/src/main/java/com/hazelcast/internal/server/tcp/TcpServerConnector.java:179
↓ 3 callers
Method
tupleToItemsByTag
()
hazelcast/src/test/java/com/hazelcast/jet/impl/processor/HashJoinPTest.java:377
↓ 3 callers
Method
txn
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/client/txn/ClientXATest.java:241
← previous
next →
15,901–16,000 of 147,315, ranked by callers