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
↓ 17 callers
Method
setWriteDelaySeconds
Sets the number of seconds to delay before writing (storing) the dirty records <p> Default value is {@value #DEFAULT_WRITE_DELAY_SECONDS}. @param wri
hazelcast/src/main/java/com/hazelcast/config/MapStoreConfig.java:159
↓ 17 callers
Method
shouldTryAgain
()
extensions/kinesis/src/main/java/com/hazelcast/jet/kinesis/impl/RetryTracker.java:39
↓ 17 callers
Method
size
()
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/RecordStore.java:377
↓ 17 callers
Method
source
(Map<String, ?> debeziumPartition, Map<String, ?> debeziumOffset)
extensions/cdc-debezium/src/main/java/com/hazelcast/jet/cdc/impl/SequenceExtractor.java:39
↓ 17 callers
Method
sourceBuilder
(String name)
extensions/cdc-postgres/src/test/java/com/hazelcast/jet/cdc/postgres/AbstractPostgresCdcIntegrationTest.java:60
↓ 17 callers
Method
start
Starts the reactor. <p/> This method is thread-safe. @throws IllegalStateException if the reactor isn't in NEW state.
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/Reactor.java:256
↓ 17 callers
Method
start
Starts the configured MembershipListeners.
hazelcast/src/main/java/com/hazelcast/client/impl/spi/ClientClusterService.java:139
↓ 17 callers
Method
stats
()
hazelcast/src/test/java/com/hazelcast/map/LocalIndexStatsTest.java:693
↓ 17 callers
Method
stats
()
hazelcast/src/test/java/com/hazelcast/map/IndexStatsQueryingInCollectionsAndArraysTest.java:298
↓ 17 callers
Method
storeAll
Stores multiple entries in the external store. <p> This method is primarily used with write-behind enabled ({@code writeDelaySeconds > 0}) when batchi
hazelcast/src/main/java/com/hazelcast/map/MapStore.java:119
↓ 17 callers
Method
streamFromIterator
(Iterator<Integer> iter)
hazelcast/src/test/java/com/hazelcast/jet/pipeline/RebalanceBatchStageTest.java:659
↓ 17 callers
Method
submit
Submits a value-returning task for execution and returns a Future representing the pending results of the task. The Future's {@code get} method will r
hazelcast/src/main/java/com/hazelcast/durableexecutor/DurableExecutorService.java:61
↓ 17 callers
Method
submitToKeyOwner
Submits a task to the owner of the specified key and returns a Future representing that task. @param task task submitted to the owner of the specifie
hazelcast/src/main/java/com/hazelcast/durableexecutor/DurableExecutorService.java:140
↓ 17 callers
Method
toCalciteType
(QueryDataType type)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/validate/types/HazelcastTypeUtils.java:103
↓ 17 callers
Method
toString
Converts a Throwable stacktrace to a String. @param cause the Throwable @return the String.
hazelcast/src/main/java/com/hazelcast/internal/util/ExceptionUtil.java:62
↓ 17 callers
Method
toValue
(final Object key, final Map<String, String> phrases)
hazelcast/src/main/java/com/hazelcast/query/impl/predicates/SqlPredicate.java:288
↓ 17 callers
Method
tryRemove
Tries to remove the entry with the given key from this map within the specified timeout value. If the key is already locked by another thread and/or m
hazelcast/src/main/java/com/hazelcast/map/IMap.java:1235
↓ 17 callers
Method
vertexExists
(VertexDef vertex)
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/init/DagNodeUtil.java:177
↓ 17 callers
Method
whenEntryIsAddedWithCacheOnUpdate_thenNearCacheShouldBePopulated
(DataStructureMethods method)
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/AbstractNearCacheBasicTest.java:412
↓ 17 callers
Method
withBackupCount
(int backupCount)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/writebehind/TestMapUsingMapStoreBuilder.java:102
↓ 17 callers
Method
write
(CompactWriter writer, Object o)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/compact/ReflectiveCompactSerializer.java:350
↓ 17 callers
Method
writeInt
(final int v)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/ByteArrayObjectDataOutput.java:214
↓ 17 callers
Method
writeNullableList
Writes a list to an {@link ObjectDataOutput}. The list's size is written to the data output, then each object in the list is serialized. The list is a
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/SerializationUtil.java:341
↓ 16 callers
Method
acceptStream
Uses the integers in the stream as both timestamps and data.
hazelcast/src/test/java/com/hazelcast/jet/pipeline/PipelineStreamTestSupport.java:120
↓ 16 callers
Method
actualIterators
()
hazelcast/src/test/java/com/hazelcast/query/impl/bitmap/BitmapAlgorithmsTest.java:286
↓ 16 callers
Method
adaptKeyFn
(@Nonnull FunctionEx<? super T, ? extends K> keyFn)
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/FunctionAdapter.java:53
↓ 16 callers
Method
add
(K key, V value, long expirationTime, long now, UUID transactionId)
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/MapDataStore.java:40
↓ 16 callers
Method
addClassDefinition
(ClassDefinition cd)
hazelcast/src/main/java/com/hazelcast/internal/serialization/SerializationServiceBuilder.java:47
↓ 16 callers
Method
addClassDefinition
@param classDefinition the class definition to be registered @return configured {@link com.hazelcast.config.SerializerConfig} for chaining @see ClassD
hazelcast/src/main/java/com/hazelcast/config/SerializationConfig.java:364
↓ 16 callers
Method
addReplicatedMapConfig
Adds the replicated map configuration. The configuration is saved under the config name, which may be a pattern with which the configuration will be o
hazelcast/src/main/java/com/hazelcast/config/Config.java:1434
↓ 16 callers
Method
afterOperation
(int threadIndex)
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/Storage.java:173
↓ 16 callers
Method
aggregate
Creates new aggregating maps.
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/AggregatingMap.java:55
↓ 16 callers
Method
and
Creates an <b>and</b> predicate that will perform the logical <b>and</b> operation on the given {@code predicates}. <p> If the given {@code predicates
hazelcast/src/main/java/com/hazelcast/query/Predicates.java:239
↓ 16 callers
Method
array
(String... values)
hazelcast/src/test/java/com/hazelcast/internal/json/JsonArray_Test.java:628
↓ 16 callers
Method
asString
Returns this JSON value as String, assuming that this value represents a JSON string. If this is not the case, an exception is thrown. @return the st
hazelcast/src/main/java/com/hazelcast/internal/json/JsonValue.java:245
↓ 16 callers
Method
asTime
(Object val)
hazelcast-sql/src/test/java/com/hazelcast/sql/impl/type/converter/ConvertersTest.java:1183
↓ 16 callers
Method
assertMultiMapsA
(String key, Object... expectedValues)
hazelcast/src/test/java/com/hazelcast/multimap/MultiMapSplitBrainTest.java:428
↓ 16 callers
Method
assertPrepareCalled
()
hazelcast/src/test/java/com/hazelcast/transaction/impl/MockTransactionLogRecord.java:108
↓ 16 callers
Method
assertSqlResultCount
(String sql, int expectedCount)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlOrderByTest.java:927
↓ 16 callers
Method
assertSqlResultOrdered
(String sql, List<String> orderFields, List<Boolean> orderDirections,
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlOrderByTest.java:874
↓ 16 callers
Method
beforeOperation
()
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/Storage.java:168
↓ 16 callers
Method
between
Creates a <b>between</b> predicate that will pass items if the value stored under the given item {@code attribute} is contained inside the given range
hazelcast/src/main/java/com/hazelcast/query/Predicates.java:461
↓ 16 callers
Method
builder
()
hazelcast/src/main/java/com/hazelcast/gcp/GcpConfig.java:70
↓ 16 callers
Method
cascadeException
If {@code resolved} is an {@link ExceptionalResult}, complete the {@code dependent} exceptionally with a {@link CompletionException} that wraps the ca
hazelcast/src/main/java/com/hazelcast/spi/impl/AbstractInvocationFuture.java:1338
↓ 16 callers
Method
check
(Object input, String format, String result)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/datetime/ToCharIntegrationTest.java:85
↓ 16 callers
Method
check
(String sql, String expectedResult)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/string/ReplaceFunctionIntegrationTest.java:123
↓ 16 callers
Method
checkColumn
(ExpressionType<?> type)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/predicate/IsNullPredicateIntegrationTest.java:94
↓ 16 callers
Method
checkFailure
(Object operand, int expectedErrorCode, String expectedErrorMessage, Object... params)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/datetime/ToTimestampTzIntegrationTest.java:167
↓ 16 callers
Method
checkFailure
(Object operand, int expectedErrorCode, String expectedErrorMessage, Object... params)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/math/AbsFunctionIntegrationTest.java:228
↓ 16 callers
Method
checkFailure
(Object operand, int expectedErrorCode, String expectedErrorMessage, Object... params)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/math/RandFunctionIntegrationTest.java:189
↓ 16 callers
Method
checkNearCacheEvictionConfig
(EvictionPolicy evictionPolicy, String comparatorClassName
hazelcast/src/main/java/com/hazelcast/internal/config/ConfigValidator.java:505
↓ 16 callers
Method
checkParameter
(int key, ExpressionType<?> type)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/predicate/IsNullPredicateIntegrationTest.java:206
↓ 16 callers
Method
checkQuery
(String query)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/parse/UnparseTest.java:87
↓ 16 callers
Method
checkTransactionState
()
hazelcast/src/main/java/com/hazelcast/map/impl/tx/TransactionalMapProxySupport.java:118
↓ 16 callers
Method
check_1
(Object operand, SqlColumnType expectedType, Object expectedValue, Object... params)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/math/RoundFunctionIntegrationTest.java:349
↓ 16 callers
Method
check_1
(Object operand, SqlColumnType expectedType, Object expectedValue, Object... params)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/math/TruncateFunctionIntegrationTest.java:340
↓ 16 callers
Method
classLoader
Processor classloader configured via {@link JobConfig#addCustomClasspath(String, String)} @return processor classloader, null if no custom classpath
hazelcast/src/main/java/com/hazelcast/jet/core/ProcessorMetaSupplier.java:921
↓ 16 callers
Method
clear
(long index)
hazelcast/src/test/java/com/hazelcast/query/impl/bitmap/SparseArrayTest.java:372
↓ 16 callers
Method
client
Create Elastic client for an instance running on localhost on default port (9200)
extensions/elasticsearch/elasticsearch-7/src/main/java/com/hazelcast/jet/elastic/ElasticClients.java:54
↓ 16 callers
Method
computeIfPresent
{@inheritDoc} <p> </p> <p> If the supplied {@code remappingFunction} is a lambda, anonymous class or an inner class, it would be executed loc
hazelcast/src/main/java/com/hazelcast/map/IMap.java:3239
↓ 16 callers
Method
create
(Expression<?> operand, QueryDataType resultType, boolean ceil)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/expression/math/FloorCeilFunction.java:51
↓ 16 callers
Method
create
Create new query ID for the given member. @param memberId Member ID. @return Query ID.
hazelcast/src/main/java/com/hazelcast/sql/impl/QueryId.java:60
↓ 16 callers
Method
createConsumer
(String... topicIds)
extensions/kafka/src/test/java/com/hazelcast/jet/kafka/impl/KafkaTestSupport.java:248
↓ 16 callers
Method
createExtractor
(String path, QueryDataType type)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/extract/CsvQueryTarget.java:46
↓ 16 callers
Method
createInjector
(@Nullable String path, QueryDataType type)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/inject/HazelcastJsonUpsertTarget.java:39
↓ 16 callers
Method
createInjector
(@Nullable String path, QueryDataType type)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/inject/JsonUpsertTarget.java:43
↓ 16 callers
Method
createJavaMapping
(HazelcastInstance instance, String name, Class<?> valueClass, String... valueFields)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/type/BasicNestedFieldsTest.java:83
↓ 16 callers
Method
createMap
Create a {@code HashMap} from a list of keys and values. The sequence must have even length and be of the form {@code key1, value1, key2, value2, ...}
hazelcast/src/test/java/com/hazelcast/jet/core/TestUtil.java:104
↓ 16 callers
Method
createParamSet
( int idx, FunctionEx<StreamStage<Map.Entry<Long, Long>>, StreamStage<Map.Entry<Long,
hazelcast/src/test/java/com/hazelcast/jet/pipeline/OrderedProcessingMultipleMemberTest.java:226
↓ 16 callers
Method
createParamSet
( FunctionEx<BatchStage<Integer>, BatchStage<Integer>> transform, String transformName
hazelcast/src/test/java/com/hazelcast/jet/pipeline/OrderedBatchProcessingTest.java:191
↓ 16 callers
Method
createTable
(List<String> names, List<QueryDataTypeFamily> types, String[]... values)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/map/SqlJoinTest.java:984
↓ 16 callers
Method
csv
Returns a file format for CSV files which specifies to deserialize each line into {@code String[]}. It assumes the CSV has a header line and specifies
hazelcast/src/main/java/com/hazelcast/jet/pipeline/file/FileFormat.java:86
↓ 16 callers
Method
decodeResponse
CREATE MAPPING SQL.
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/SqlMappingDdlCodec.java:94
↓ 16 callers
Method
ensureNoTimeout
(String name, long timeout)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/SqlPlanImpl.java:1772
↓ 16 callers
Method
entrySet
(boolean lazy)
hazelcast/src/main/java/com/hazelcast/replicatedmap/impl/record/ReplicatedRecordStore.java:65
↓ 16 callers
Method
eq_2
(Object operand)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/support/expressions/ExpressionPredicates.java:33
↓ 16 callers
Method
equals
(Object o)
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/Option.java:67
↓ 16 callers
Method
equals
(Object o)
hazelcast/src/main/java/com/hazelcast/kubernetes/KubernetesClient.java:755
↓ 16 callers
Method
equals
(Object o)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/compact/Schema.java:252
↓ 16 callers
Method
equals
(Object o)
hazelcast/src/main/java/com/hazelcast/internal/util/collection/OAHashSet.java:354
↓ 16 callers
Method
eventuallyJobRunning
Asserts that a job status is eventually RUNNING. When it's running, checks that the execution ID is different from the given {@code ignoredExecutionId
hazelcast/src/test/java/com/hazelcast/jet/core/JobAssertions.java:152
↓ 16 callers
Method
expandObjectArrayPrimitiveScenario
Expands test cases for that navigate from object array to a primitive field. Word objectArray is replaced to: objects[0], objects[1], objects[2], obje
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/reader/CompactStreamSerializerValueReaderSpecTest.java:285
↓ 16 callers
Method
expandPortableArrayPrimitiveScenario
Expands test cases for that navigate from portable array to a primitive field. Word portableArray is replaced to: portables[0], portables[1], portable
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/portable/portablereader/DefaultPortableReaderSpecTest.java:295
↓ 16 callers
Method
flattenCompound
Return a {@link CompoundPredicate}, possibly flattened if one or both arguments is an instance of {@code CompoundPredicate}.
hazelcast/src/main/java/com/hazelcast/query/impl/predicates/SqlPredicate.java:335
↓ 16 callers
Method
frameSize
Returns the length of the frame (equal to the sliding step).
hazelcast/src/main/java/com/hazelcast/jet/core/SlidingWindowPolicy.java:73
↓ 16 callers
Method
getAccessor
@return the associated {@link MemoryAccessor}
hazelcast/src/main/java/com/hazelcast/internal/memory/MemoryManager.java:36
↓ 16 callers
Method
getAddress
(HazelcastInstance hz)
hazelcast/src/test/java/com/hazelcast/test/Accessors.java:115
↓ 16 callers
Method
getAllReplicatedRecordStores
(String name)
hazelcast/src/main/java/com/hazelcast/replicatedmap/impl/ReplicatedMapService.java:257
↓ 16 callers
Method
getAuditlogConfig
()
hazelcast/src/main/java/com/hazelcast/config/Config.java:3025
↓ 16 callers
Method
getAzureConfig
@return the azureConfig join configuration
hazelcast/src/main/java/com/hazelcast/config/JoinConfig.java:116
↓ 16 callers
Method
getBackupEntryCount
Returns the number of backup entries hold by this member. @return number of backup entries hold by this member.
hazelcast/src/main/java/com/hazelcast/map/LocalMapStats.java:53
↓ 16 callers
Method
getChannel
()
hazelcast/src/main/java/com/hazelcast/internal/server/tcp/TcpServerConnection.java:131
↓ 16 callers
Method
getClientMessage
()
hazelcast/src/main/java/com/hazelcast/client/impl/spi/impl/ClientInvocation.java:145
↓ 16 callers
Method
getClusterClock
Returns the {@link ClusterClock} of the cluster. <p> The returned value will never be {@code null} and will never change. @return the ClusterClock
hazelcast/src/main/java/com/hazelcast/internal/cluster/ClusterService.java:169
↓ 16 callers
Method
getClusterTime
Returns the cluster-wide time in milliseconds. <p> Cluster tries to keep a cluster-wide time which might be different than the member's own system tim
hazelcast/src/main/java/com/hazelcast/cluster/Cluster.java:138
↓ 16 callers
Method
getComparator
Returns the instance of the configured {@link EvictionPolicyComparator} implementation. @return the instance of the configured {@link EvictionPolicyC
hazelcast/src/main/java/com/hazelcast/config/EvictionConfig.java:215
↓ 16 callers
Method
getConnections
Returns all connections. <p> This can be a relatively expensive operations the returned collection might be created on every invocation. So if you are
hazelcast/src/main/java/com/hazelcast/internal/server/Server.java:67
↓ 16 callers
Method
getDataLoadTimeoutSeconds
Returns configured data load timeout for persistence restart process. @return data load timeout in seconds
hazelcast/src/main/java/com/hazelcast/config/PersistenceConfig.java:204
↓ 16 callers
Method
getDelegatedInstance
Gets the delegated (underlying) {@link com.hazelcast.core.HazelcastInstance}. @return the delegated (underlying) {@link com.hazelcast.core.HazelcastI
hazelcast/src/main/java/com/hazelcast/osgi/HazelcastOSGiInstance.java:32
↓ 16 callers
Method
getExecutorConfig
Returns the ExecutorConfig for the given name, creating one if necessary and adding it to the collection of known configurations. <p> The configuratio
hazelcast/src/main/java/com/hazelcast/config/Config.java:1928
← previous
next →
4,801–4,900 of 147,315, ranked by callers