MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

↓ 16 callersMethodsetRedoOperation
If true, client will redo the operations that were executing on the server and client lost the connection. This can be because of network, or simply b
hazelcast/src/main/java/com/hazelcast/client/config/ClientNetworkConfig.java:286
↓ 16 callersMethodsetResult
(Object result)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/steps/engine/State.java:325
↓ 16 callersMethodsetSchemaService
(SchemaService schemaService)
hazelcast/src/main/java/com/hazelcast/internal/serialization/SerializationServiceBuilder.java:71
↓ 16 callersMethodsetStoreInitialDelaySeconds
()
hazelcast/src/test/java/com/hazelcast/config/NearCachePreloaderConfigTest.java:58
↓ 16 callersMethodsignatureError
(SqlColumnType type)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/datetime/ToTimestampTzIntegrationTest.java:183
↓ 16 callersMethodsignatureError
(SqlColumnType type)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/math/RandFunctionIntegrationTest.java:179
↓ 16 callersMethodsize
@return the size of this result.
hazelcast/src/main/java/com/hazelcast/map/impl/query/QueryResult.java:160
↓ 16 callersMethodsourceBuilder
(String name)
extensions/cdc-mysql/src/test/java/com/hazelcast/jet/cdc/mysql/AbstractMySqlCdcIntegrationTest.java:49
↓ 16 callersMethodsplit
This method uses ',' character by default. It is for splitting into key=value tokens. @param statString the statistics string to be split @return a l
hazelcast/src/main/java/com/hazelcast/client/impl/statistics/ClientStatisticsService.java:296
↓ 16 callersMethodspliterator
()
hazelcast/src/main/java/com/hazelcast/jet/impl/ICacheDecorator.java:379
↓ 16 callersMethodstringResults
Returns a string representation of the aggregation output, one result per line.
hazelcast/src/test/java/com/hazelcast/jet/pipeline/PipelineStreamTestSupport.java:129
↓ 16 callersMethodtag2
Returns the tag constant {@link #TAG_2}.
hazelcast/src/main/java/com/hazelcast/jet/datamodel/Tag.java:94
↓ 16 callersMethodtestPartitionDistribution
(int partitionCount, int dataNodeCount, int liteNodeCount)
hazelcast/src/test/java/com/hazelcast/partition/PartitionDistributionTest.java:151
↓ 16 callersMethodthenAcceptAsync
(Consumer<? super V> action)
hazelcast/src/main/java/com/hazelcast/client/impl/ClientDelegatingFuture.java:183
↓ 16 callersMethodtoKeyFn
Set the key-extracting function. The resulting value will be used as the key in the sink IMap. <p> The function must be {@link java.io.Serializable}.
hazelcast/src/main/java/com/hazelcast/jet/pipeline/MapSinkBuilder.java:119
↓ 16 callersMethodtoLocalTime
(TimeString string)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/visitor/RexToExpression.java:652
↓ 16 callersMethodtoMap
(Tuple2<K, Object>... entries)
hazelcast/src/test/java/com/hazelcast/jet/impl/processor/HashJoinPTest.java:372
↓ 16 callersMethodtryReserveForUpdate
Reservations are done with this method. Tries to reserve supplied key for update. <p> If one thread takes reservation, only that thread can update th
hazelcast/src/main/java/com/hazelcast/internal/nearcache/NearCache.java:231
↓ 16 callersMethodtuple4
Returns a new 5-tuple with the supplied values.
hazelcast/src/main/java/com/hazelcast/jet/datamodel/Tuple4.java:51
↓ 16 callersMethodusToBucketIndex
(int us)
hazelcast/src/main/java/com/hazelcast/internal/util/LatencyDistribution.java:162
↓ 16 callersMethodvalueAddress
@return Address of the current slot's value block.
hazelcast/src/main/java/com/hazelcast/internal/util/hashslot/HashSlotCursor.java:43
↓ 16 callersMethodvalues
(boolean lazy)
hazelcast/src/main/java/com/hazelcast/replicatedmap/impl/record/ReplicatedRecordStore.java:61
↓ 16 callersMethodvalues
Transactional implementation of {@link IMap#values()}. @see IMap#values()
hazelcast/src/main/java/com/hazelcast/transaction/TransactionalMap.java:256
↓ 16 callersMethodwriteCharArray
@param chars char array to be written @throws IOException in case of any exceptional case
hazelcast/src/main/java/com/hazelcast/nio/ObjectDataOutput.java:58
↓ 16 callersMethodwriteInt64
Writes a 64-bit two's complement signed integer. @param fieldName name of the field. @param value to be written.
hazelcast/src/main/java/com/hazelcast/nio/serialization/compact/CompactWriter.java:75
↓ 16 callersMethodwriteUTF
@deprecated for the sake of better naming. Use {@link #writeString(String)} instead
hazelcast/src/main/java/com/hazelcast/nio/ObjectDataOutput.java:32
↓ 15 callersMethodaddClientListener
Adds a ClientListener. When a ClientListener is added more than once, it will receive duplicate events. @param clientListener the ClientListener to
hazelcast/src/main/java/com/hazelcast/client/ClientService.java:51
↓ 15 callersMethodaddQueryCacheConfig
(String mapName, QueryCacheConfig queryCacheConfig)
hazelcast/src/main/java/com/hazelcast/client/config/ClientConfig.java:762
↓ 15 callersMethodadvanceTime
(long millis)
hazelcast/src/test/java/com/hazelcast/jet/retry/impl/RetryTrackerTest.java:175
↓ 15 callersMethodapplyAsLong
(T value)
hazelcast/src/main/java/com/hazelcast/function/ToLongFunctionEx.java:41
↓ 15 callersMethodassertContainsInAnyOrder
(MultiResult multiResult, Object... items)
hazelcast/src/test/java/com/hazelcast/query/impl/getters/FieldGetterTest.java:382
↓ 15 callersMethodassertMapDoesNotContainKey
(int key)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/map/SqlDeleteTest.java:218
↓ 15 callersMethodassertNewLastAccessTime
()
hazelcast/src/test/java/com/hazelcast/multimap/MultiMapContainerStatisticsTest.java:196
↓ 15 callersMethodassertNoDataMissing
(IMap<Integer, Person> map, int expectedSize)
hazelcast/src/test/java/com/hazelcast/aggregation/AggregatorsSpecTest.java:479
↓ 15 callersMethodassertSampleRunnable
(String expectedKey, Object event, String serviceName)
hazelcast/src/test/java/com/hazelcast/internal/diagnostics/EventQueuePluginTest.java:292
↓ 15 callersMethodassumeNoTieredStorageConfigured
()
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/EntryStoreSimpleTest.java:360
↓ 15 callersMethodawaitTermination
Awaits for the termination of the Reactor with the given timeout. <p/> This method is thread-safe. @param timeout the timeout @param unit the Time
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/Reactor.java:309
↓ 15 callersMethodcallUntil
(ProcessorTasklet tasklet)
hazelcast/src/test/java/com/hazelcast/jet/impl/execution/ProcessorTaskletTest_Watermarks.java:350
↓ 15 callersMethodcanonicalizeAttribute
Produces canonical attribute representation by stripping an unnecessary "this." qualifier from the passed attribute, if any. @param attribute the att
hazelcast/src/main/java/com/hazelcast/query/impl/IndexUtils.java:217
↓ 15 callersMethodcheckCompositeConverter
(TypeConverter converter1, TypeConverter converter2, QueryDataType... expectedTypes)
hazelcast-sql/src/test/java/com/hazelcast/sql/impl/schema/map/MapTableConverterResolutionTest.java:166
↓ 15 callersMethodcheckCompositeConverters
(TypeConverter converter1, QueryDataType expectedType)
hazelcast-sql/src/test/java/com/hazelcast/sql/impl/schema/map/MapTableConverterResolutionTest.java:143
↓ 15 callersMethodcheckFamily
(QueryDataType expectedType, QueryDataTypeFamily typeFamily)
hazelcast-sql/src/test/java/com/hazelcast/sql/impl/type/QueryDataTypeTest.java:362
↓ 15 callersMethodcheckGenerated
(SqlColumnType type, Supplier<ValueFactory> factoryProducer)
hazelcast/src/test/java/com/hazelcast/client/impl/protocol/codec/builtin/SqlPageCodecTest.java:157
↓ 15 callersMethodcheckIndex
(IndexRegistry indexes, String attribute, String expAttribute)
hazelcast/src/test/java/com/hazelcast/query/impl/predicates/AttributeCanonicalizationTest.java:95
↓ 15 callersMethodcheckSignatureErrorCommute
(Object field1, Object field2, SqlColumnType type1, SqlColumnType type2)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/math/ArithmeticOperatorIntegrationTest.java:190
↓ 15 callersMethodcheckSimpleConverter
(TypeConverter converter, QueryDataType expectedType)
hazelcast-sql/src/test/java/com/hazelcast/sql/impl/schema/map/MapTableConverterResolutionTest.java:103
↓ 15 callersMethodcheckUpdateCount
(String sql, int expected)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/map/SqlDeleteTest.java:204
↓ 15 callersMethodcheck_2
(Object operand1, Object operand2, SqlColumnType expectedType, Object expectedValue, Object... params)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/math/RoundFunctionIntegrationTest.java:353
↓ 15 callersMethodcheck_2
(Object operand1, Object operand2, SqlColumnType expectedType, Object expectedValue, Object... params)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/math/TruncateFunctionIntegrationTest.java:344
↓ 15 callersMethodchildAsSequence
Gets a child sequence node by its name @param name the name of the child node @return the child sequence node with the given name if exists, {@code n
hazelcast/src/main/java/com/hazelcast/internal/yaml/YamlMapping.java:64
↓ 15 callersMethodcodePoint
(Character value)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/string/AsciiFunctionIntegrationTest.java:99
↓ 15 callersMethodcollectDouble
(MetricDescriptor descriptor, double value)
hazelcast/src/main/java/com/hazelcast/internal/metrics/collectors/MetricsCollector.java:30
↓ 15 callersMethodcollectLong
(MetricDescriptor descriptor, long value)
hazelcast/src/main/java/com/hazelcast/internal/metrics/collectors/MetricsCollector.java:28
↓ 15 callersMethodcreateCacheConfig
(M expiryPolicy, T listener)
hazelcast/src/test/java/com/hazelcast/cache/eviction/CacheExpirationTest.java:120
↓ 15 callersMethodcreateClass
(ExpressionType<?> type)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/support/expressions/ExpressionValue.java:43
↓ 15 callersMethodcreateContext
( @Nonnull List<Object> arguments, @Nonnull NodeEngine nodeEngine, @Nonnul
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/expression/ExpressionEvalContext.java:82
↓ 15 callersMethodcreateDataSource
(boolean xa)
hazelcast/src/test/java/com/hazelcast/jet/impl/connector/JdbcDatabaseProviderTestSupport.java:56
↓ 15 callersMethodcreateDirectory
(String path)
hazelcast/src/test/java/com/hazelcast/jet/config/ResourceConfigTest.java:993
↓ 15 callersMethodcreateDisabled
()
hazelcast/src/main/java/com/hazelcast/internal/util/ConcurrencyDetection.java:70
↓ 15 callersMethodcreateInjector
(@Nullable String path, QueryDataType type)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/inject/AvroUpsertTarget.java:82
↓ 15 callersMethodcreateMap
()
hazelcast/src/test/java/com/hazelcast/map/ExpirationTimeTest.java:671
↓ 15 callersMethodcreateNearCacheConfig
Creates a {@link NearCacheConfig} with a given {@link InMemoryFormat}. @param inMemoryFormat the {@link InMemoryFormat} to set @param serializeKeys
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/NearCacheTestUtils.java:115
↓ 15 callersMethodcreateString
(int length)
hazelcast/src/test/java/com/hazelcast/internal/json/WritingBuffer_Test.java:150
↓ 15 callersMethodcreateType
(String name, String... fields)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/type/RecurrentStructuresNestedFieldsTest.java:53
↓ 15 callersMethoddata
()
extensions/cdc-mysql/src/test/java/com/hazelcast/jet/cdc/mysql/MySqlCdcNetworkIntegrationTest.java:95
↓ 15 callersMethoddecode
(ClientMessage.ForwardFrameIterator iterator, Function<ClientMessage
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/MapCodec.java:58
↓ 15 callersMethoddecodeRequest
Name of the Queue for which the age-related statistics should be reset to 0
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/MCResetQueueAgeStatisticsCodec.java:74
↓ 15 callersMethoddecodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/MapReplaceAllCodec.java:88
↓ 15 callersMethoddecodeRequest
the config patch (XML or YAML string) to be applied to the current configuration
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/MCUpdateConfigCodec.java:75
↓ 15 callersMethoddeleteAll
Deletes multiple entries from the external store. <p> This method is primarily used with write-behind enabled ({@code writeDelaySeconds > 0}) when bat
hazelcast/src/main/java/com/hazelcast/map/MapStore.java:166
↓ 15 callersMethoddeserialized
()
extensions/avro/src/main/java/com/hazelcast/jet/avro/impl/AvroSerializerHooks.java:190
↓ 15 callersMethoddestVertex
()
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/init/EdgeDef.java:94
↓ 15 callersMethoddestinationName
Sets the name of the destination.
hazelcast/src/main/java/com/hazelcast/jet/pipeline/JmsSinkBuilder.java:109
↓ 15 callersMethoddestroy
Destroys this cache. Clears and releases all local and remote resources created for this cache.
hazelcast/src/main/java/com/hazelcast/map/QueryCache.java:226
↓ 15 callersMethoddestroyFn
Sets the function that will destroy the context object and perform any cleanup. The function is called when the job has been completed or cancelled. J
hazelcast/src/main/java/com/hazelcast/jet/pipeline/SinkBuilder.java:166
↓ 15 callersMethoddetermineColumnWidth
(String header, int typeLength)
hazelcast/src/main/java/com/hazelcast/client/console/SqlConsole.java:392
↓ 15 callersMethoddriverCount
(int count)
hazelcast/src/test/java/com/hazelcast/test/bounce/BounceMemberRule.java:538
↓ 15 callersMethoddst
Gets the destination of this ChannelHandler. <p> This method should only be called from the thread that owns this ChannelHandler. @return the destina
hazelcast/src/main/java/com/hazelcast/internal/networking/ChannelHandler.java:73
↓ 15 callersMethodempty
()
hazelcast-spring/src/main/java/com/hazelcast/spring/ExposeHazelcastObjects.java:106
↓ 15 callersMethodencode
(ClientMessage clientMessage, Map<K, V> map, BiConsumer<ClientMessage, K>
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/MapCodec.java:37
↓ 15 callersMethodencodeRequest
()
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/MCReloadConfigCodec.java:60
↓ 15 callersMethodencodeRequest
(java.lang.String name)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/MCResetQueueAgeStatisticsCodec.java:59
↓ 15 callersMethodencodeRequest
(java.lang.String name, com.hazelcast.internal.serialization.Data function)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/MapReplaceAllCodec.java:74
↓ 15 callersMethodencodeRequest
(java.lang.String configuration)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/MCUpdateConfigCodec.java:60
↓ 15 callersMethodencodeResponse
(java.util.UUID configReloadProcessId)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/MCReloadConfigCodec.java:71
↓ 15 callersMethodencodeResponse
()
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/MCResetQueueAgeStatisticsCodec.java:81
↓ 15 callersMethodencodeResponse
()
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/MapReplaceAllCodec.java:98
↓ 15 callersMethodencodeResponse
(java.util.UUID configUpdateProcessId)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/MCUpdateConfigCodec.java:82
↓ 15 callersMethodensureJetEvents
(@Nonnull ComputeStageImplBase stage, @Nonnull String name)
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/ComputeStageImplBase.java:584
↓ 15 callersMethodequalDoubles
Checks the provided double values for equality exactly as {@link Double#equals} does it, avoiding the boxing-unboxing cycle. @param lhs the left-hand
hazelcast/src/main/java/com/hazelcast/query/impl/Numbers.java:160
↓ 15 callersMethodequals
(Object o)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/type/BasicNestedFieldsTest.java:554
↓ 15 callersMethodequals
(Object o)
hazelcast/src/test/java/com/hazelcast/jet/core/JobSerializerTest.java:224
↓ 15 callersMethodequals
(Object o)
hazelcast/src/main/java/com/hazelcast/query/impl/predicates/InPredicate.java:162
↓ 15 callersMethodexecuteOnMembers
Executes a task on each of the specified members. @param command the task executed on the specified members @param members the specified members
hazelcast/src/main/java/com/hazelcast/core/IExecutorService.java:80
↓ 15 callersMethodextractAttributeNameNameWithoutArguments
(String attributeNameWithArguments)
hazelcast/src/main/java/com/hazelcast/query/impl/getters/ExtractorHelper.java:100
↓ 15 callersMethodfactory
()
hazelcast/src/test/java/com/hazelcast/jet/SimpleTestInClusterSupport.java:275
↓ 15 callersMethodfield
(String name, QueryDataType type, String externalName)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/keyvalue/KvMetadataJavaResolverTest.java:310
↓ 15 callersMethodfield2
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/support/expressions/ExpressionBiValue.java:120
↓ 15 callersMethodfillProperties
(final Node node, Map<String, Comparable> properties, boolean domLevel3)
hazelcast/src/main/java/com/hazelcast/internal/config/DomConfigHelper.java:48
↓ 15 callersMethodfilterUsingService
( @Nonnull ServiceFactory<?, S> serviceFactory, @Nonnull BiPredicateEx<? super S, ? su
hazelcast/src/main/java/com/hazelcast/jet/pipeline/BatchStage.java:168
← previousnext →5,001–5,100 of 147,315, ranked by callers