MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

↓ 3 callersMethodtestBasics
()
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/portable/PortableTest.java:67
↓ 3 callersMethodtestClassDefinitionLookup
(InternalSerializationService ss)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/portable/PortableTest.java:332
↓ 3 callersMethodtestConfig2Xml2Config
(String fileName)
hazelcast/src/test/java/com/hazelcast/config/XmlOnlyConfigBuilderTest.java:241
↓ 3 callersMethodtestDrainTo
()
hazelcast/src/test/java/com/hazelcast/internal/util/concurrent/AbstractConcurrentArrayQueueTest.java:260
↓ 3 callersMethodtestExceptionThrownForTooLargeCapacity
()
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/ByteArrayObjectDataOutputTest.java:450
↓ 3 callersMethodtestExecute_withInvalid_partitionId
(Object task)
hazelcast/src/test/java/com/hazelcast/spi/impl/operationexecutor/impl/OperationThreadTest.java:120
↓ 3 callersMethodtestFlushAsync_shouldFlushSelectedPartitions
(@Nullable Set<Integer> partitionsToFlush)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/writebehind/WriteBehindFlushTest.java:170
↓ 3 callersMethodtestIndexForComparableAttributes
(IndexType indexType)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/extractor/QueryTest.java:100
↓ 3 callersMethodtestJoin_With_DifferentBuildNumber
(Config config)
hazelcast/src/test/java/com/hazelcast/cluster/AbstractJoinTest.java:67
↓ 3 callersMethodtestMapJournal_withPredicateAndProjection
(IMap<String, Integer> srcMap, StreamSource<Integer> source)
hazelcast/src/test/java/com/hazelcast/jet/pipeline/Sources_withEventJournalTest.java:399
↓ 3 callersMethodtestMaxAllowed
(RegisterCallback registerCallbackCall)
hazelcast/src/test/java/com/hazelcast/client/ClientMaxAllowedInvocationTest.java:135
↓ 3 callersMethodtestMaxAllowed_withWaitingCallbacks
(RegisterCallback registerCallbackCall)
hazelcast/src/test/java/com/hazelcast/client/ClientMaxAllowedInvocationTest.java:179
↓ 3 callersMethodtestMaxIdle_readThroughIndex
(IndexType type)
hazelcast/src/test/java/com/hazelcast/map/EvictionTest.java:230
↓ 3 callersMethodtestMergeAfterSplitBrain
(boolean multicast)
hazelcast/src/test/java/com/hazelcast/cluster/SplitBrainHandlerTest.java:199
↓ 3 callersMethodtestMigrationListenerInvoked
( T clientListener, Function<MigrationListener, HazelcastInstance> clientFactory,
hazelcast/src/test/java/com/hazelcast/client/partitionservice/ClientMigrationListenerTest.java:185
↓ 3 callersMethodtestMultipleOrPredicates
(IMap<Integer, Employee> map)
hazelcast/src/test/java/com/hazelcast/map/impl/query/QueryBasicTest.java:819
↓ 3 callersMethodtestNext
(Operation operation)
hazelcast/src/test/java/com/hazelcast/spi/impl/sequence/CallIdSequenceWithBackpressureTest.java:64
↓ 3 callersMethodtestPaths
(WriterConfig config)
hazelcast/src/test/java/com/hazelcast/json/internal/AbstractJsonSchemaTest.java:63
↓ 3 callersMethodtestProxyCreation
(String serviceName, ClientConfig clientConfig)
hazelcast/src/test/java/com/hazelcast/client/impl/spi/ProxyFactoryTest.java:120
↓ 3 callersMethodtestQueue
(Callable<Object> task)
hazelcast/src/test/java/com/hazelcast/client/txn/ClientTxnDisconnectionTest.java:103
↓ 3 callersMethodtestReplicatedMapCreated
(int numberOfLiteNodes, int numberOfDataNodes,
hazelcast/src/test/java/com/hazelcast/client/replicatedmap/ClientReplicatedMapLiteMemberTest.java:94
↓ 3 callersMethodtestScripting
(Boolean enabled)
hazelcast/src/test/java/com/hazelcast/internal/management/TimedMemberStateIntegrationTest.java:103
↓ 3 callersMethodtestSerialization
(RingbufferContainer original)
hazelcast/src/test/java/com/hazelcast/ringbuffer/impl/RingbufferContainerSerializationTest.java:131
↓ 3 callersMethodtestSerializer
()
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/CustomSerializationTest.java:47
↓ 3 callersMethodtestSyncListener_shouldNotHang_AfterAction
(String cacheName, CachingProvider provider, Runnable action)
hazelcast/src/test/java/com/hazelcast/cache/CacheListenerTest.java:281
↓ 3 callersMethodtestTopologyChange
( Supplier<HazelcastInstance> secondMemberSupplier, Consumer<HazelcastInstance> change
hazelcast/src/test/java/com/hazelcast/jet/pipeline/SourceBuilder_TopologyChangeTest.java:72
↓ 3 callersMethodtest_DefaultOutOfMemoryHandler_using_accessor
(MemoryInfoAccessor memoryInfoAccessor, Verific
hazelcast/src/test/java/com/hazelcast/instance/impl/OutOfMemoryErrorDispatcherTest.java:216
↓ 3 callersMethodtest_twoSlavesDisconnectedFromOneSlave
()
hazelcast/src/test/java/com/hazelcast/internal/cluster/impl/MembershipFailureTest.java:698
↓ 3 callersMethodtest_whenSpace
()
hazelcast/src/test/java/com/hazelcast/topic/impl/reliable/TopicOverloadAbstractTest.java:64
↓ 3 callersMethodtest_whenSpace_all
()
hazelcast/src/test/java/com/hazelcast/topic/impl/reliable/TopicOverloadAbstractTest.java:158
↓ 3 callersMethodthenAcceptBoth
()
hazelcast/src/test/java/com/hazelcast/spi/impl/CompletableFutureAbstractTest.java:1286
↓ 3 callersMethodthenCombine
()
hazelcast/src/test/java/com/hazelcast/spi/impl/CompletableFutureAbstractTest.java:1334
↓ 3 callersMethodthenCombineAsync
()
hazelcast/src/test/java/com/hazelcast/spi/impl/CompletableFutureAbstractTest.java:1344
↓ 3 callersMethodthrowException
(long currentCapacity, long maxPerNodeCapacity, int requiredCapacity)
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/writebehind/NodeWideUsedCapacityCounter.java:81
↓ 3 callersMethodthrowJetExceptionFromJobMetaData
(JobMetaDataParameterObject jobMetaDataParameterObject, Exception exception)
hazelcast/src/main/java/com/hazelcast/jet/impl/JetServiceBackend.java:538
↓ 3 callersMethodthrowUnknownFieldException
(@Nonnull String fieldName)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/portable/DefaultPortableReader.java:467
↓ 3 callersMethodtimeToStringFriendly
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 callersMethodtimeout
(Operation op)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/OperationRunnerImpl.java:373
↓ 3 callersMethodtimestampFn
Returns the function that extracts the timestamp from the event.
hazelcast/src/main/java/com/hazelcast/jet/core/EventTimePolicy.java:227
↓ 3 callersMethodtimestampToTimestampWithTimezone
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 callersMethodtoAccumulatorInfo
(QueryCacheConfig config, String mapName,
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/accumulator/AccumulatorInfo.java:60
↓ 3 callersMethodtoBackingDataKeyFormat
(Data key)
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/Storage.java:166
↓ 3 callersMethodtoBean
Secure parser of JSON to given type. Rejects dangerous types.
hazelcast/src/main/java/com/hazelcast/jet/json/impl/JsonUtilImpl.java:45
↓ 3 callersMethodtoBeanBiFn
Secure parser of JSON to given type. Rejects dangerous types.
hazelcast/src/main/java/com/hazelcast/jet/json/impl/JsonUtilImpl.java:54
↓ 3 callersMethodtoBuilder
@return SearchOptionsBuilder with the same settings @since 5.6
hazelcast/src/main/java/com/hazelcast/vector/SearchOptions.java:58
↓ 3 callersMethodtoData
(Object item)
hazelcast/src/test/java/com/hazelcast/ringbuffer/impl/operations/ReadOneOperationTest.java:76
↓ 3 callersMethodtoData
(Object val)
hazelcast/src/main/java/com/hazelcast/cache/impl/journal/RingbufferCacheEventJournalImpl.java:222
↓ 3 callersMethodtoData
(Data data, Object o)
hazelcast/src/main/java/com/hazelcast/cache/impl/journal/DeserializingEventJournalCacheEvent.java:124
↓ 3 callersMethodtoData
(Object val)
hazelcast/src/main/java/com/hazelcast/map/impl/journal/RingbufferMapEventJournalImpl.java:189
↓ 3 callersMethodtoData
(Data data, Object o)
hazelcast/src/main/java/com/hazelcast/map/impl/journal/DeserializingEventJournalMapEvent.java:120
↓ 3 callersMethodtoDataCollectionWithNonNullKeyValidation
(Set<K> keys, Collection<Data> dataKeys)
hazelcast/src/main/java/com/hazelcast/map/impl/proxy/MapProxySupport.java:1456
↓ 3 callersMethodtoEntry
(String key, Object value)
hazelcast/src/main/java/com/hazelcast/internal/ascii/memcache/EntryConverter.java:37
↓ 3 callersMethodtoFuture
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 callersMethodtoImmutableLazySet
(List resultSet)
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/subscriber/AbstractInternalQueryCache.java:175
↓ 3 callersMethodtoIndex
(long sequence)
hazelcast/src/main/java/com/hazelcast/ringbuffer/impl/ArrayRingbuffer.java:141
↓ 3 callersMethodtoIndex
(long sequence)
hazelcast/src/main/java/com/hazelcast/spi/merge/RingbufferMergeData.java:202
↓ 3 callersMethodtoJobMetrics
(List<RawJobMetrics> rawJobMetrics)
hazelcast/src/main/java/com/hazelcast/jet/impl/JobMetricsUtil.java:58
↓ 3 callersMethodtoJsonArray
(JsonValue jsonValue)
hazelcast/src/main/java/com/hazelcast/azure/AzureComputeApi.java:147
↓ 3 callersMethodtoJsonObject
(JsonValue jsonValue)
hazelcast/src/main/java/com/hazelcast/azure/AzureComputeApi.java:155
↓ 3 callersMethodtoMap
(Properties properties)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/util/PropertiesUtil.java:37
↓ 3 callersMethodtoNearCacheValue
(V value, Data valueData)
hazelcast/src/main/java/com/hazelcast/client/cache/impl/nearcache/NearCachedClientCacheProxy.java:927
↓ 3 callersMethodtoNode
(String yaml)
hazelcast/src/test/java/com/hazelcast/internal/config/YamlMemberDomConfigProcessorTest.java:61
↓ 3 callersMethodtoNullFunction
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 callersMethodtoObject
(Object data)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheIterator.java:235
↓ 3 callersMethodtoObject
(Object responseData)
hazelcast/src/main/java/com/hazelcast/client/cache/impl/CacheStatsHandler.java:175
↓ 3 callersMethodtoProperties
()
extensions/cdc-debezium/src/main/java/com/hazelcast/jet/cdc/impl/DebeziumConfig.java:68
↓ 3 callersMethodtoQueryEntry
(Object key, Object value)
hazelcast/src/test/java/com/hazelcast/query/PortablePredicatesTest.java:71
↓ 3 callersMethodtoSocketOption
(Option option)
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/nio/NioAsyncServerSocketOptions.java:44
↓ 3 callersMethodtoSocketOption
(Option option)
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/nio/NioAsyncSocketOptions.java:44
↓ 3 callersMethodtoString
()
hazelcast/src/test/java/com/hazelcast/kubernetes/RuntimeContextTest.java:187
↓ 3 callersMethodtoString
()
hazelcast/src/main/java/com/hazelcast/sql/SqlColumnType.java:138
↓ 3 callersMethodtoString
(JsonValue jsonValue)
hazelcast/src/main/java/com/hazelcast/kubernetes/KubernetesClient.java:633
↓ 3 callersMethodtoString
()
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/MetricDescriptorImpl.java:420
↓ 3 callersMethodtoString
()
hazelcast/src/main/java/com/hazelcast/internal/partition/PartitionMigrationEvent.java:124
↓ 3 callersMethodtoString
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 callersMethodtoStringFn
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 callersMethodtoTtlFromExpiryTime
(long expirationTime, long now)
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/DefaultRecordStore.java:570
↓ 3 callersMethodtoTumblingByFrame
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 callersMethodtoUnmodifiableHasSet
(Collection<Member> members)
hazelcast/src/main/java/com/hazelcast/client/impl/spi/impl/ClientClusterServiceImpl.java:275
↓ 3 callersMethodtoVectorValues
(List<VectorPairHolder> vectors)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/CustomTypeFactory.java:363
↓ 3 callersMethodtopObservedWm
Returns the highest received watermark from any input.
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/WatermarkCoalescer.java:93
↓ 3 callersMethodtotalFramesPending
(TcpServerConnection connection)
hazelcast/src/test/java/com/hazelcast/internal/server/tcp/TcpServerConnection_AbstractTransferStressTest.java:136
↓ 3 callersMethodtotalHeapCost
()
hazelcast/src/test/java/com/hazelcast/map/EntryCostEstimatorTest.java:285
↓ 3 callersMethodtouch
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 callersMethodtrackNullInstance
()
hazelcast/src/test/java/com/hazelcast/map/MapListenerTest.java:116
↓ 3 callersMethodtransferTo
(long position, long count, WritableByteChannel target)
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/preloader/NearCachePreloaderLockTest.java:196
↓ 3 callersMethodtransformToSetWithNamespace
(QueryResult result, Predicate predicate, IterationType iterationT
hazelcast/src/main/java/com/hazelcast/map/impl/proxy/MapProxyImpl.java:828
↓ 3 callersMethodtransitionTransactionManagerStateTo
( Object transactionManager, String state)
extensions/kafka/src/main/java/com/hazelcast/jet/kafka/impl/ResumeTransactionUtil.java:171
↓ 3 callersMethodtranslate
(Object[] input)
hazelcast/src/test/java/com/hazelcast/query/impl/extractor/AbstractExtractionTest.java:155
↓ 3 callersMethodtranslateAddress
(Function<A, Address> addressTranslator, A target, String listenerMethodName)
hazelcast/src/main/java/com/hazelcast/client/impl/management/ClientConnectionProcessListenerRegistry.java:182
↓ 3 callersMethodtranslateGrpcException
{@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 callersMethodtransmit
(Address target, Packet packet, ServerConnectionManager connectionManager)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/OutboundResponseHandler.java:213
↓ 3 callersMethodtraverseAutoCloseableIterator
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 callersMethodtraverseSpliterator
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 callersMethodtriggerControlTask
()
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/MigrationManagerImpl.java:549
↓ 3 callersMethodtryAcquirePermit
()
hazelcast/src/main/java/com/hazelcast/jet/impl/connector/AsyncHazelcastWriterP.java:121
↓ 3 callersMethodtryExternalRollback
()
extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/impl/WriteMongoP.java:544
↓ 3 callersMethodtryToConnect
(InetSocketAddress socketAddress, int timeout)
hazelcast/src/main/java/com/hazelcast/internal/server/tcp/TcpServerConnector.java:179
↓ 3 callersMethodtupleToItemsByTag
()
hazelcast/src/test/java/com/hazelcast/jet/impl/processor/HashJoinPTest.java:377
↓ 3 callersMethodtxn
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/client/txn/ClientXATest.java:241
← previousnext →15,901–16,000 of 147,315, ranked by callers