MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

↓ 11 callersMethodclient
()
hazelcast/src/test/java/com/hazelcast/client/impl/proxy/ClientClusterProxyTest.java:53
↓ 11 callersMethodconcatenate
(byte[] a, byte[] b)
hazelcast/src/main/java/com/hazelcast/internal/ascii/memcache/MemcacheCommandProcessor.java:34
↓ 11 callersMethodconstant
(String value)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/string/TrimFunctionIntegrationTest.java:211
↓ 11 callersMethodcontent
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/processors/StreamToStreamJoinListBuffer.java:57
↓ 11 callersMethodconvertFilter
Converts a boolean {@link HazelcastRexNode}. When evaluating a {@link RexInputRef}, this context is assumed:<ul> <li>If a table is set (see {@link #ge
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/SqlConnector.java:603
↓ 11 callersMethodcreate
(Expression<?> operand1, Expression<?> operand2, QueryDataType resultType)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/expression/math/PlusFunction.java:52
↓ 11 callersMethodcreate
(boolean nullable)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/validate/types/HazelcastJsonType.java:46
↓ 11 callersMethodcreate
()
extensions/kafka/src/test/java/com/hazelcast/jet/kafka/impl/KafkaTestSupport.java:84
↓ 11 callersMethodcreateAccessorInstance
@return instance(client / member) with given serialization config
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/portable/integration/AbstractGenericRecordIntegrationTest.java:61
↓ 11 callersMethodcreateBiClass
(ExpressionType<?> type1, ExpressionType<?> type2)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/support/expressions/ExpressionBiValue.java:37
↓ 11 callersMethodcreateCluster
@return cluster without any Portable Factory Config
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/portable/integration/AbstractGenericRecordIntegrationTest.java:66
↓ 11 callersMethodcreateCluster
()
hazelcast/src/test/java/com/hazelcast/jet/impl/submitjob/clientside/upload/JobUploadClientFailureTest.java:373
↓ 11 callersMethodcreateExpressionEvalContext
(Object... args)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlTestSupport.java:770
↓ 11 callersMethodcreateExtractors
(AttributeConfig config)
hazelcast/src/test/java/com/hazelcast/query/impl/getters/ExtractorsTest.java:193
↓ 11 callersMethodcreateInstance
()
hazelcast/src/test/java/com/hazelcast/cache/instance/CacheThroughHazelcastInstanceTest.java:85
↓ 11 callersMethodcreateJavaMapping
(String name, Class<?> valueClass, String... valueFields)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/type/RecurrentStructuresNestedFieldsTest.java:49
↓ 11 callersMethodcreateMergePolicyConfig
(Node node, MergePolicyConfig baseMergePolicyConfig)
hazelcast/src/main/java/com/hazelcast/internal/config/MemberDomConfigProcessor.java:2580
↓ 11 callersMethodcreateObjectName
(String type, String name)
hazelcast/src/main/java/com/hazelcast/internal/jmx/ManagementService.java:185
↓ 11 callersMethodcreateProxy
Creates a DistributedObject proxy if it is not created yet @param name The name of the distributedObject proxy object. @param source The UU
hazelcast/src/main/java/com/hazelcast/spi/impl/proxyservice/impl/ProxyRegistry.java:222
↓ 11 callersMethodcreateSchema
()
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/schema/CompactSchemaReplicatorTest.java:299
↓ 11 callersMethodcreateServer
(BindableService service)
extensions/grpc/src/test/java/com/hazelcast/jet/grpc/GrpcServiceTest.java:384
↓ 11 callersMethodcreateService
Creates a service which is an implementation of given type parameter. @param type type of service @param params additional parameter to create the se
hazelcast/src/main/java/com/hazelcast/instance/impl/NodeExtension.java:255
↓ 11 callersMethodcreateSnapshotFn
( @Nonnull FunctionEx<? super C, ? extends S> createSnapshotFn )
hazelcast/src/main/java/com/hazelcast/jet/pipeline/SourceBuilder.java:583
↓ 11 callersMethodcreateTableNoQuote
Creates table with id INT, name VARCHAR columns Does not quote the given tableName.
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/jdbc/JdbcSqlTestSupport.java:146
↓ 11 callersMethodcreateTasklet
()
hazelcast/src/test/java/com/hazelcast/jet/impl/execution/ProcessorTaskletTest_Blocking.java:295
↓ 11 callersMethoddataSize
Returns size of internal binary data in bytes @return internal data size
hazelcast/src/main/java/com/hazelcast/internal/serialization/Data.java:72
↓ 11 callersMethoddeactivate
Deactivates the service.
hazelcast/src/main/java/com/hazelcast/osgi/impl/HazelcastInternalOSGiService.java:59
↓ 11 callersMethoddecode
( ClientMessage.Frame frame, int itemSizeInBytes, DecodeFunction<T> decodeFunction
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/ListCNFixedSizeCodec.java:115
↓ 11 callersMethoddecodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/JetRemoveJobStatusListenerCodec.java:89
↓ 11 callersMethoddecodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/DynamicConfigAddDataConnectionConfigCodec.java:105
↓ 11 callersMethoddecodeResponse
A unique registration ID which is used as a key to remove the listener.
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/JetAddJobStatusListenerCodec.java:126
↓ 11 callersMethoddecodeResponse
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/JetUpdateJobConfigCodec.java:105
↓ 11 callersMethoddecodeResponse
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/JetIsJobUserCancelledCodec.java:92
↓ 11 callersMethoddecodeResponse
True if registration is removed, false otherwise.
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/JetRemoveJobStatusListenerCodec.java:111
↓ 11 callersMethoddepth
Returns the depth of the tree @return the depth of the tree
hazelcast/src/main/java/com/hazelcast/wan/impl/merkletree/MerkleTreeView.java:36
↓ 11 callersMethodderegisterListener
(String cacheNameWithPrefix, UUID registrationId)
hazelcast/src/main/java/com/hazelcast/cache/impl/ICacheService.java:122
↓ 11 callersMethodderiveType
(SqlValidator validator, SqlValidatorScope scope, SqlCall call)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/validate/operators/misc/HazelcastCaseOperator.java:69
↓ 11 callersMethoddestroy
Removes all previously registered observers and destroys the backing {@link Ringbuffer}. <p> <strong>Note:</strong> if you call this while a job that
hazelcast/src/main/java/com/hazelcast/jet/Observable.java:221
↓ 11 callersMethoddisableCompleteCall
Disables calling {@code complete()} method during the test. Suitable for testing of streaming processors to make sure that the flushing code in {@code
hazelcast/src/main/java/com/hazelcast/jet/core/test/TestSupport.java:513
↓ 11 callersMethoddiscriminatorValue
Returns the discriminator tag's value of the metric denoted by this instance. Used to distinguish metrics that have the same {@link #prefix()} and {@l
hazelcast/src/main/java/com/hazelcast/internal/metrics/MetricDescriptor.java:94
↓ 11 callersMethoddistributeObjects
Distributes the {@code objects} to {@code count} processors in a round-robin fashion. If the object count is smaller than processor count, an empty li
hazelcast/src/main/java/com/hazelcast/jet/impl/util/Util.java:309
↓ 11 callersMethoddoPostOperateOps
()
hazelcast/src/main/java/com/hazelcast/map/impl/operation/EntryOperator.java:301
↓ 11 callersMethoddriver
()
hazelcast/src/test/java/com/hazelcast/internal/dynamicconfig/DynamicConfigSmokeTest.java:75
↓ 11 callersMethodelements
()
hazelcast/src/test/java/com/hazelcast/test/HazelcastParallelClassRunner.java:246
↓ 11 callersMethodencode
( ClientMessage clientMessage, Iterable<T> items, int itemSizeInBytes, EncodeF
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/ListCNFixedSizeCodec.java:49
↓ 11 callersMethodencodeJobStatusEvent
(long jobId, int previousStatus, int newStatus, @Nullable java.lang.String description, boolean userRequested)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/JetAddJobStatusListenerCodec.java:132
↓ 11 callersMethodencodeRequest
(java.lang.String name, java.util.List<com.hazelcast.client.impl.protocol.task.dynamicconfig.ResourceDefinitio
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/DynamicConfigAddUserCodeNamespaceConfigCodec.java:72
↓ 11 callersMethodencodeRequest
(long jobId, @Nullable java.util.UUID lightJobCoordinator, boolean localOnly)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/JetAddJobStatusListenerCodec.java:89
↓ 11 callersMethodencodeRequest
(long jobId, com.hazelcast.internal.serialization.Data deltaConfig)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/JetUpdateJobConfigCodec.java:70
↓ 11 callersMethodencodeRequest
(long jobId)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/JetIsJobUserCancelledCodec.java:60
↓ 11 callersMethodencodeRequest
(long jobId, java.util.UUID registrationId)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/JetRemoveJobStatusListenerCodec.java:76
↓ 11 callersMethodencodeRequest
(java.lang.String name, java.lang.String type, boolean shared, java.util.Map<java.lang.String, java.lang.Strin
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/DynamicConfigAddDataConnectionConfigCodec.java:90
↓ 11 callersMethodencodeRequest
(java.util.UUID sessionId, int currentPartNumber, int totalPartNumber, byte[] partData, int partSize, java.lan
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/JetUploadJobMultipartCodec.java:95
↓ 11 callersMethodencodeResponse
()
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/JetUploadJobMetaDataCodec.java:137
↓ 11 callersMethodencodeResponse
(boolean response)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/JetRemoveJobStatusListenerCodec.java:98
↓ 11 callersMethodencodeResponse
()
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/DynamicConfigAddDataConnectionConfigCodec.java:116
↓ 11 callersMethodencodeResponse
()
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/JetUploadJobMultipartCodec.java:125
↓ 11 callersMethodenqueue
(PriorityElement task)
hazelcast/src/test/java/com/hazelcast/collection/impl/queue/QueuePriorityWithDuplicateCheckTest.java:199
↓ 11 callersMethodequals
(Object obj)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/keyvalue/KvMetadataNullResolver.java:87
↓ 11 callersMethodequals
(Object obj)
hazelcast/src/test/java/com/hazelcast/internal/util/collection/InflatableSetTest.java:207
↓ 11 callersMethodequals
(Object o)
hazelcast/src/test/java/com/hazelcast/query/impl/predicates/NestedPredicateTest.java:142
↓ 11 callersMethodequals
(Object o)
hazelcast/src/test/java/com/hazelcast/jet/impl/processor/InsertWatermarksPTest.java:356
↓ 11 callersMethodequals
(Object o)
hazelcast/src/main/java/com/hazelcast/query/impl/QueryEntry.java:130
↓ 11 callersMethodequals
(Object o)
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/init/DagNodeUtil.java:197
↓ 11 callersMethodequals
(Object o)
hazelcast/src/main/java/com/hazelcast/map/impl/query/QueryEventFilter.java:74
↓ 11 callersMethodequals
(Object o)
hazelcast/src/main/java/com/hazelcast/multimap/impl/txn/TransactionRecordKey.java:31
↓ 11 callersMethodevaluate
Evaluate projection&predicate for multiple rows.
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/ExpressionUtil.java:173
↓ 11 callersMethodfillMap
(IMap<String, String> map, int partitionId, int count, String value)
hazelcast/src/test/java/com/hazelcast/map/AbstractMapQueryIterableTest.java:223
↓ 11 callersMethodfindMultiMapConfig
Finds existing Multimap config. @param name name of the config @return Multimap config or {@code null} when requested MultiMap configuration does not
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/ConfigurationService.java:142
↓ 11 callersMethodfindPropertySetter
Return a set-method for a class and a property. The setter must start with "set", must be public, non-static, must return void or the containing class
hazelcast/src/main/java/com/hazelcast/jet/impl/util/ReflectionUtils.java:169
↓ 11 callersMethodfindScheduledExecutorConfig
Finds existing Scheduled Executor config. @param name name of the config @return Scheduled Executor config or {@code null} when requested Scheduled E
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/ConfigurationService.java:190
↓ 11 callersMethodfirstArrangement
Causes the partition table to be arranged and published to members if : <ul> <li>this instance has started</li> <li>this instance is the master</li> <
hazelcast/src/main/java/com/hazelcast/internal/partition/InternalPartitionService.java:103
↓ 11 callersMethodgcd
Calculate greatest common divisor of a series of integer numbers. Returns 0, if the number of values is 0.
hazelcast/src/main/java/com/hazelcast/jet/impl/util/Util.java:462
↓ 11 callersMethodgenerateUniqueHazelcastInjectionId
()
hazelcast/src/test/java/com/hazelcast/cache/instance/CacheHazelcastInstanceAwareTest.java:101
↓ 11 callersMethodgetAccessKey
()
extensions/kinesis/src/main/java/com/hazelcast/jet/kinesis/impl/AwsConfig.java:81
↓ 11 callersMethodgetAllScheduledFutures
Fetches and returns all scheduled (not disposed yet) futures from all members in the cluster. If a member has no running tasks for this scheduler, it
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/IScheduledExecutorService.java:450
↓ 11 callersMethodgetArgument
Returns the value to which the specified key is mapped, or null if there is no mapping for the key. @param key the key whose associated value is to b
hazelcast/src/main/java/com/hazelcast/jet/config/JobConfig.java:1208
↓ 11 callersMethodgetArrayOfBoolean
@param fieldName the name of the field @return the value of the field @throws HazelcastSerializationException if the field name does not exist
hazelcast/src/main/java/com/hazelcast/nio/serialization/genericrecord/GenericRecord.java:346
↓ 11 callersMethodgetArrayOfFloat32
@param fieldName the name of the field @return the value of the field @throws HazelcastSerializationException if the field name does not exist
hazelcast/src/main/java/com/hazelcast/nio/serialization/genericrecord/GenericRecord.java:420
↓ 11 callersMethodgetArrayOfFloat64
@param fieldName the name of the field @return the value of the field @throws HazelcastSerializationException if the field name does not exist
hazelcast/src/main/java/com/hazelcast/nio/serialization/genericrecord/GenericRecord.java:432
↓ 11 callersMethodgetArrayOfGenericRecord
@param fieldName the name of the field @return the value of the field @throws HazelcastSerializationException if the field name does not exist
hazelcast/src/main/java/com/hazelcast/nio/serialization/genericrecord/GenericRecord.java:521
↓ 11 callersMethodgetArrayOfInt16
@param fieldName the name of the field @return the value of the field @throws HazelcastSerializationException if the field name does not exist
hazelcast/src/main/java/com/hazelcast/nio/serialization/genericrecord/GenericRecord.java:384
↓ 11 callersMethodgetArrayOfInt64
@param fieldName the name of the field @return the value of the field @throws HazelcastSerializationException if the field name does not exist
hazelcast/src/main/java/com/hazelcast/nio/serialization/genericrecord/GenericRecord.java:408
↓ 11 callersMethodgetArrayOfInt8
@param fieldName the name of the field @return the value of the field @throws HazelcastSerializationException if the field name does not exist
hazelcast/src/main/java/com/hazelcast/nio/serialization/genericrecord/GenericRecord.java:372
↓ 11 callersMethodgetArrayOfVariableSize
(FieldDescriptor fieldDescriptor, IntFunction<T[]> constructor,
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/compact/CompactInternalGenericRecord.java:815
↓ 11 callersMethodgetAttribute
()
hazelcast/src/main/java/com/hazelcast/query/impl/PredicateBuilderImpl.java:66
↓ 11 callersMethodgetAttributes
Gets index attributes. @return Index attributes.
hazelcast/src/main/java/com/hazelcast/config/IndexConfig.java:157
↓ 11 callersMethodgetBeforeEvents
()
hazelcast/src/test/java/com/hazelcast/internal/partition/service/TestAbstractMigrationAwareService.java:94
↓ 11 callersMethodgetBitWidth
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/validate/types/HazelcastIntegerType.java:137
↓ 11 callersMethodgetByType
@return the matching EntryEventType for the supplied {@code typeId} or {@code null} if there is no match
hazelcast/src/main/java/com/hazelcast/core/EntryEventType.java:90
↓ 11 callersMethodgetCRDTOperationTarget
Returns the target on which this proxy should invoke a CRDT operation. On first invocation of this method, the method will choose a target address and
hazelcast/src/main/java/com/hazelcast/client/impl/proxy/ClientPNCounterProxy.java:324
↓ 11 callersMethodgetCachedOwnedPartitions
Returns cached collection of owned partitions, When it is null, reloads and caches it again.
hazelcast/src/main/java/com/hazelcast/map/impl/MapServiceContext.java:174
↓ 11 callersMethodgetClassName
()
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/holder/WanConsumerConfigHolder.java:47
↓ 11 callersMethodgetClassName
Returns the name of the MapStore implementation class @return the name of the MapStore implementation class
hazelcast/src/main/java/com/hazelcast/config/MapStoreConfig.java:108
↓ 11 callersMethodgetClientConfig
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/client/replicatedmap/DummyClientReplicatedMapTest.java:255
↓ 11 callersMethodgetClientEngineImpl
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/test/Accessors.java:74
↓ 11 callersMethodgetClusterStartTime
()
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/ClusterClockImpl.java:100
↓ 11 callersMethodgetCollection
()
hazelcast/src/main/java/com/hazelcast/collection/impl/list/ListContainer.java:164
↓ 11 callersMethodgetComparable
Gets the value to be queried. Used by upper filter to construct the final lookup request. @return the value to be queried
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/exec/scan/index/IndexFilter.java:32
↓ 11 callersMethodgetConfig
(String ringbufferName, int capacity,
hazelcast/src/test/java/com/hazelcast/ringbuffer/impl/RingbufferStoreTest.java:68
← previousnext →6,201–6,300 of 147,315, ranked by callers