MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

↓ 52 callersMethodwithCreate
Returns a builder object, initialized with the supplied {@link #createFn() create} primitive, that can be used to construct the definition of an aggre
hazelcast/src/main/java/com/hazelcast/jet/aggregate/AggregateOperation.java:363
↓ 51 callersMethodaddClasses
Adds the given class names to this filter. @param names class names to add @return this filter
hazelcast/src/main/java/com/hazelcast/config/ClassFilter.java:98
↓ 51 callersMethodasObject
()
hazelcast/src/test/java/com/hazelcast/internal/json/JsonObject_Test.java:767
↓ 51 callersMethodassertGreaterOrEquals
(String label, long actualValue, long lowerBound)
hazelcast/src/test/java/com/hazelcast/test/HazelcastTestSupport.java:1384
↓ 51 callersMethodcheckParameter
(Object param, Object expectedResult)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/string/StringFunctionIntegrationTestSupport.java:144
↓ 51 callersMethodend
Returns the ending timestamp of the window.
hazelcast/src/main/java/com/hazelcast/jet/datamodel/WindowResult.java:73
↓ 51 callersMethodgetAsync
Asynchronously gets the given key. {@link CompletionStage} can be converted to a {@link java.util.concurrent.CompletableFuture} to obtain the value in
hazelcast/src/main/java/com/hazelcast/map/IMap.java:643
↓ 51 callersMethodgetCPSubsystem
Returns the CP subsystem that offers a set of in-memory linearizable data structures @return the CP subsystem that offers a set of in-memory lineariz
hazelcast/src/main/java/com/hazelcast/core/HazelcastInstance.java:456
↓ 51 callersMethodgetDistributedObjectName
Used for {@link com.hazelcast.security.SecurityInterceptor}
hazelcast/src/main/java/com/hazelcast/client/impl/client/SecureRequest.java:52
↓ 51 callersMethodgetManagedContext
see {@link com.hazelcast.config.Config#setManagedContext(ManagedContext)} @return ManagedContext that is set by user in Config
hazelcast/src/main/java/com/hazelcast/internal/serialization/SerializationService.java:114
↓ 51 callersMethodgetPartitionStateStamp
Returns stamp of the current partition state.
hazelcast/src/main/java/com/hazelcast/internal/partition/IPartitionService.java:189
↓ 51 callersMethodgetRestApiConfig
Returns initialized {@link RestApiConfig} for the node.
hazelcast/src/main/java/com/hazelcast/internal/server/ServerContext.java:81
↓ 51 callersMethodgetSource
()
hazelcast/src/main/java/com/hazelcast/map/impl/event/EventData.java:29
↓ 51 callersMethodisRecognized
Recognizes the configuration given in the {@code configStream} argument. @param configStream The stream with the declarative configuration @return {@
hazelcast/src/main/java/com/hazelcast/config/ConfigRecognizer.java:35
↓ 51 callersMethodmapStateful
( @Nonnull SupplierEx<? extends S> createFn, @Nonnull BiFunctionEx<? super S, ? super
hazelcast/src/main/java/com/hazelcast/jet/pipeline/BatchStage.java:125
↓ 51 callersMethodnoop
Returns a sink which discards all received items.
hazelcast/src/main/java/com/hazelcast/jet/pipeline/Sinks.java:1311
↓ 51 callersMethodout
Create a test event with an output item. Equivalent to {@link #out(int, Object) out(0, item)}. @return the new test event @see #expectExactOutput(Tes
hazelcast/src/main/java/com/hazelcast/jet/core/test/TestSupport.java:1232
↓ 51 callersMethodoverwriteMemberConfig
(Config config)
hazelcast/src/main/java/com/hazelcast/internal/config/override/ExternalConfigurationOverride.java:58
↓ 51 callersMethodput
(long key, long value)
hazelcast/src/main/java/com/hazelcast/internal/util/collection/Long2LongMap.java:26
↓ 51 callersMethodset
Sets the current value.
hazelcast/src/main/java/com/hazelcast/jet/core/metrics/Metric.java:75
↓ 51 callersMethodsetMaxIdleSeconds
Maximum number of seconds for each entry to stay idle in the map. Entries that are idle (not touched) for more than {@code maxIdleSeconds} will get au
hazelcast/src/main/java/com/hazelcast/config/MapConfig.java:370
↓ 51 callersMethodsignatureError
(Object type1, Object type2)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/math/ModFunctionIntegrationTest.java:30
↓ 51 callersMethodtoArray
()
hazelcast-spring-tests/src/test/java/com/hazelcast/spring/TestSpringNotCallsEntrySet.java:187
↓ 50 callersMethodassertCompletesEventually
(final Future<?> future)
hazelcast/src/test/java/com/hazelcast/test/HazelcastTestSupport.java:974
↓ 50 callersMethodcallWithNamespace
Obtains a {@link NodeEngine} reference from {@link NodeEngineThreadLocalContext} and uses it to call {@link UserCodeNamespaceService#callWithNamespace
hazelcast/src/main/java/com/hazelcast/internal/namespace/NamespaceUtil.java:127
↓ 50 callersMethodcheckCompatibleConfigs
(String type, T c1, T c2, ConfigChecker<T> checker)
hazelcast/src/test/java/com/hazelcast/config/ConfigCompatibilityChecker.java:171
↓ 50 callersMethodconnectTo
(Node node)
hazelcast/src/test/java/com/hazelcast/internal/util/phonehome/TestUtil.java:81
↓ 50 callersMethodcurrent
()
hazelcast/src/main/java/com/hazelcast/client/impl/clientside/ClusterDiscoveryService.java:58
↓ 50 callersMethodendSection
()
hazelcast/src/main/java/com/hazelcast/internal/diagnostics/DiagnosticsLogWriter.java:29
↓ 50 callersMethodevict
Evicts the specified key from this map. <p> If a {@code MapStore} is defined for this map, then the entry is not deleted from the underlying {@code Ma
hazelcast/src/main/java/com/hazelcast/map/IMap.java:2397
↓ 50 callersMethodgetClassId
Returns class identifier for this portable class. Class ID should be unique per PortableFactory. @return class ID
hazelcast/src/main/java/com/hazelcast/nio/serialization/Portable.java:59
↓ 50 callersMethodgetConfig
()
hazelcast/src/test/java/com/hazelcast/map/EntryProcessorTest.java:135
↓ 50 callersMethodgetFactoryId
(String prop, int defaultId)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/FactoryIdHelper.java:175
↓ 50 callersMethodgetOriginal
()
hazelcast/src/main/java/com/hazelcast/instance/impl/HazelcastInstanceProxy.java:326
↓ 50 callersMethodgetPartitionService
()
hazelcast/src/main/java/com/hazelcast/spi/impl/NodeEngineImpl.java:386
↓ 50 callersMethodgetReplicatedMap
@since Jet 3.0 @deprecated Use {@link HazelcastInstance#getReplicatedMap(String)} instead.
hazelcast/src/main/java/com/hazelcast/jet/JetInstance.java:101
↓ 50 callersMethodisBeginFrame
()
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/ClientMessage.java:513
↓ 50 callersMethodisClosed
Checks if this Channel is closed. This method is very cheap to make. @return true if closed, false otherwise.
hazelcast/src/main/java/com/hazelcast/internal/networking/Channel.java:219
↓ 50 callersMethodisFalse
()
hazelcast/src/test/java/com/hazelcast/internal/json/JsonLiteral_Test.java:64
↓ 50 callersMethodnewValidationError
(SqlNode node, Resources.ExInst<SqlValidatorException> e)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/validate/HazelcastSqlValidator.java:555
↓ 50 callersMethodprepareResponse
If the {@code value} is {@code null}, prepares a {@link HttpURLConnection#HTTP_NO_CONTENT} response, otherwise prepares an {@link HttpURLConnection#HT
hazelcast/src/main/java/com/hazelcast/internal/ascii/rest/HttpCommandProcessor.java:133
↓ 50 callersMethodreader
(Portable portable)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/portable/portablereader/DefaultPortableReaderQuickTest.java:359
↓ 49 callersMethodadd
Appends the JSON representation of the specified <code>int</code> value to the end of this array. @param value the value to add to the array
hazelcast/src/main/java/com/hazelcast/internal/json/JsonArray.java:120
↓ 49 callersMethodaddListenerConfig
Adds a configuration for an {@link EventListener}. This includes listeners for events related to this instance/member or the cluster, such as partitio
hazelcast/src/main/java/com/hazelcast/config/Config.java:2470
↓ 49 callersMethodbuildConfig
(String yaml)
hazelcast/src/test/java/com/hazelcast/client/config/YamlClientConfigBuilderTest.java:941
↓ 49 callersMethodcheck
(ExpressionType<?> typeFrom, QueryDataTypeFamily typeTo, boolean expectedIndexUsage)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/map/index/SqlIndexCastTest.java:145
↓ 49 callersMethodcloseConnectionBetween
(HazelcastInstance h1, HazelcastInstance h2)
hazelcast/src/test/java/com/hazelcast/test/HazelcastTestSupport.java:687
↓ 49 callersMethodcompile
(String path)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/expression/json/JsonPathUtil.java:63
↓ 49 callersMethodequals
(Object other)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/cost/Cost.java:175
↓ 49 callersMethodestimate
Computes a new estimate for the current status of the registers. If it was previously estimated and never invalidated, then a cached version is used.
hazelcast/src/main/java/com/hazelcast/cardinality/impl/hyperloglog/HyperLogLog.java:41
↓ 49 callersMethodgetAndIncrement
Atomically increments the current value by one. @return the old value
hazelcast/src/main/java/com/hazelcast/cp/IAtomicLong.java:143
↓ 49 callersMethodgetCacheConfig
(String cacheNameWithPrefix)
hazelcast/src/main/java/com/hazelcast/cache/impl/ICacheService.java:81
↓ 49 callersMethodgetClientService
Returns the client service of this Hazelcast instance. Client service allows you to get information about connected clients. @return the {@link Clien
hazelcast/src/main/java/com/hazelcast/core/HazelcastInstance.java:349
↓ 49 callersMethodgetDistributedObjects
Returns all {@link DistributedObject}s, that is all maps, queues, topics, locks etc. <p> The results are returned on a best-effort basis. The result m
hazelcast/src/main/java/com/hazelcast/core/HazelcastInstance.java:294
↓ 49 callersMethodgetEntryObject
()
hazelcast/src/main/java/com/hazelcast/query/PredicateBuilder.java:31
↓ 49 callersMethodgetMapOperationProvider
(String mapName)
hazelcast/src/main/java/com/hazelcast/map/impl/MapServiceContext.java:198
↓ 49 callersMethodgetMapServiceContext
()
hazelcast/src/main/java/com/hazelcast/map/impl/MapContainer.java:100
↓ 49 callersMethodgetMaxSize
Returns the maximum size of the Queue. @return the maximum size of the Queue
hazelcast/src/main/java/com/hazelcast/config/QueueConfig.java:130
↓ 49 callersMethodgetMessage
()
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/exception/ErrorHolder.java:43
↓ 49 callersMethodisLocal
Returns {@code true} if the device configuration is for a local device, otherwise, returns {@code false} if this configuration is for a remote device.
hazelcast/src/main/java/com/hazelcast/config/DeviceConfig.java:31
↓ 49 callersMethoditerate
Starts iteration on this storage using the given iterator. <p> Always succeeds since we never keep empty storages. @param iterator the iterator to it
hazelcast/src/main/java/com/hazelcast/query/impl/bitmap/SparseBitSet.java:198
↓ 49 callersMethodof
Returns a {@code ProcessorSupplier} which will delegate to the given {@code Supplier<Processor>} to create all {@code Processor} instances.
hazelcast/src/main/java/com/hazelcast/jet/core/ProcessorSupplier.java:106
↓ 49 callersMethodpayload
@return the contents of the resource.
hazelcast/src/main/java/com/hazelcast/internal/namespace/ResourceDefinition.java:39
↓ 49 callersMethodplus
(RelOptCost other)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/cost/Cost.java:123
↓ 49 callersMethodreadByteArray
@return the byte array read @throws IOException if it reaches end of file before finish reading
hazelcast/src/main/java/com/hazelcast/nio/ObjectDataInput.java:48
↓ 49 callersMethodremaining
Returns the number of bytes remaining in this buffer for reading or writing
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/iobuffer/IOBuffer.java:111
↓ 49 callersMethodserializeAndCheck
(Object original, int expectedClassId)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlTestSupport.java:472
↓ 49 callersMethodsize
Returns the number of key-value pairs in the multimap. If the multimap contains more than <tt>Integer.MAX_VALUE</tt> elements, returns <tt>Integer.MAX
hazelcast/src/main/java/com/hazelcast/multimap/MultiMap.java:282
↓ 49 callersMethodverifyAdvanceAtLeastTo
(AscendingLongIterator actual, TreeSet<Long> expected, long step)
hazelcast/src/test/java/com/hazelcast/query/impl/bitmap/BitmapAlgorithmsTest.java:399
↓ 49 callersMethodwriteByte
(int position, int v)
hazelcast/src/main/java/com/hazelcast/internal/nio/BufferObjectDataOutput.java:47
↓ 48 callersMethodaddInterface
Adds a new interface @param ip the added interface
hazelcast/src/main/java/com/hazelcast/config/InterfacesConfig.java:52
↓ 48 callersMethodassertPredicates
(Predicate expectedPredicate, Predicate actualPredicate)
hazelcast/src/test/java/com/hazelcast/map/impl/query/MixedTypeQueriesTest.java:402
↓ 48 callersMethodbuild
Builds Config object. @return Built Config object
hazelcast/src/main/java/com/hazelcast/config/ConfigBuilder.java:30
↓ 48 callersMethodcombineFn
A primitive that accepts two accumulators and updates the state of the left-hand one by combining it with the state of the right-hand one. The right-h
hazelcast/src/main/java/com/hazelcast/jet/aggregate/AggregateOperation.java:176
↓ 48 callersMethodcreateHazelcastOSGiInstance
(HazelcastInstance instance, HazelcastOSGiService service)
hazelcast/src/test/java/com/hazelcast/osgi/impl/HazelcastOSGiTestUtil.java:30
↓ 48 callersMethodcreateMap
()
hazelcast/src/test/java/com/hazelcast/client/map/ClientMapTest.java:1170
↓ 48 callersMethodfinishFn
A primitive that transforms the accumulator into a result of the aggregation. This is a relaxed version of {@link #exportFn() export} primitive: the a
hazelcast/src/main/java/com/hazelcast/jet/aggregate/AggregateOperation.java:257
↓ 48 callersMethodgetFields
If {@code __key}/{@code this} is the only key/value field and has a custom type, return type fields. Otherwise, return mapping fields without {@code _
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/keyvalue/KvMetadataResolver.java:92
↓ 48 callersMethodgetInstanceName
Returns the instance name uniquely identifying the hazelcast instance created by this configuration. This name is used in different scenarios, such as
hazelcast/src/main/java/com/hazelcast/config/Config.java:659
↓ 48 callersMethodgetNext
Returns the next attribute path part. The returned string is either the name of the next attribute or the string representation of an array index. {@c
hazelcast/src/main/java/com/hazelcast/query/impl/getters/JsonPathCursor.java:107
↓ 48 callersMethodgetNode
(HazelcastInstance hz)
hazelcast/src/test/java/com/hazelcast/test/Accessors.java:62
↓ 48 callersMethodgetThisAddress
Gets the address of this member. @return the address of this member (the returned value will never be {@code null})
hazelcast/src/main/java/com/hazelcast/internal/cluster/ClusterService.java:121
↓ 48 callersMethodgetType
()
hazelcast/src/main/java/com/hazelcast/internal/cluster/Joiner.java:33
↓ 48 callersMethodjobConfig
Returns the {@link JobConfig}.
hazelcast/src/main/java/com/hazelcast/jet/core/ProcessorMetaSupplier.java:844
↓ 48 callersMethodlocalKeySet
Returns the locally owned immutable set of keys. <p> Each key in this map is owned and managed by a specific member in the cluster. <p> Note that owne
hazelcast/src/main/java/com/hazelcast/map/IMap.java:2637
↓ 48 callersMethodnewPredicateBuilder
Creates a new instance of {@link PredicateBuilder}. @return the new {@link PredicateBuilder} instance.
hazelcast/src/main/java/com/hazelcast/query/Predicates.java:193
↓ 48 callersMethodpartitioned
Activates the {@link RoutingPolicy#PARTITIONED PARTITIONED} routing policy and applies the {@link Partitioner#defaultPartitioner() default} Hazelcast
hazelcast/src/main/java/com/hazelcast/jet/core/Edge.java:315
↓ 48 callersMethodputByte
Writes the given byte value to given address. @param address the address where the byte value will be written to @param x the byte value to be
hazelcast/src/main/java/com/hazelcast/internal/memory/MemoryAccessor.java:64
↓ 48 callersMethodputJsonString
(Map map, String name, int age, boolean onDuty)
hazelcast/src/test/java/com/hazelcast/json/MapPredicateJsonTest.java:114
↓ 48 callersMethodreset
()
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/ClientMessageReader.java:59
↓ 48 callersMethodsignatureError
(SqlColumnType... columnTypes)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/string/SubstringFunctionIntegrationTest.java:288
↓ 48 callersMethodsql
(String operand)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/math/DoubleBiFunctionIntegrationTest.java:145
↓ 48 callersMethodsql3
(String inputOperand, String fromOperand, String forOperand)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/string/SubstringFunctionIntegrationTest.java:248
↓ 48 callersMethodtest
(int payloadSize, int concurrency, boolean useWriter)
hazelcast-tpc-engine/src/test/java/com/hazelcast/internal/tpcengine/net/AsyncSocket_LargePayloadTest.java:328
↓ 47 callersMethodadd
(OneToOneConcurrentArrayQueue<Object> q, Object... items)
hazelcast/src/test/java/com/hazelcast/jet/impl/execution/ConcurrentInboundEdgeStreamTest.java:272
↓ 47 callersMethodaddHash
Adds a hash to the accumulated hash of a tree node <p> Notes: <ul> <li>The hash function must be associative. For the detailed reasoning see {@link Me
hazelcast/src/main/java/com/hazelcast/wan/impl/merkletree/MerkleTreeUtil.java:121
↓ 47 callersMethodbuildConfig
(String xml, Properties properties)
hazelcast/src/test/java/com/hazelcast/client/config/XmlClientConfigBuilderTest.java:930
↓ 47 callersMethodcapacity
Returns the capacity of this Ringbuffer. @return the capacity.
hazelcast/src/main/java/com/hazelcast/ringbuffer/Ringbuffer.java:109
↓ 47 callersMethodcopy
Takes a mutable copy of this instance. @return the copy of this instance
hazelcast/src/main/java/com/hazelcast/internal/metrics/MetricDescriptor.java:273
↓ 47 callersMethodcreateCache
(HazelcastInstance hazelcastInstance, String testCacheName,
hazelcast/src/test/java/com/hazelcast/client/statistics/ClientStatisticsTest.java:312
← previousnext →1,101–1,200 of 147,315, ranked by callers