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
↓ 3 callers
Method
wrap
(DagBuildContext ctx, ProcessorSupplier supplier)
extensions/mongodb/src/main/java/com/hazelcast/jet/sql/impl/connector/mongodb/MongoSqlConnectorBase.java:209
↓ 3 callers
Method
wrap
(ServerConnection c)
hazelcast/src/test/java/com/hazelcast/internal/server/FirewallingServer.java:291
↓ 3 callers
Method
wrapInCompletionException
(Throwable t)
hazelcast/src/main/java/com/hazelcast/spi/impl/AbstractInvocationFuture.java:1346
↓ 3 callers
Method
wrapOrPeel
(Throwable cause)
hazelcast/src/main/java/com/hazelcast/spi/impl/AbstractInvocationFuture.java:1945
↓ 3 callers
Method
wrapThrowable
(Object value)
hazelcast/src/main/java/com/hazelcast/spi/impl/AbstractInvocationFuture.java:1352
↓ 3 callers
Method
wrapToJetEvent
()
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/StreamSourceStageImpl.java:98
↓ 3 callers
Method
writeArraySeparator
()
hazelcast/src/test/java/com/hazelcast/internal/json/RandomPrint.java:66
↓ 3 callers
Method
writeBufferedP
Shortcut for {@link #writeBufferedP(FunctionEx, BiConsumerEx, ConsumerEx, ConsumerEx)} with a no-op {@code destroyFn}.
hazelcast/src/main/java/com/hazelcast/jet/core/processor/SinkProcessors.java:341
↓ 3 callers
Method
writeChar
( ByteAccessStrategy<R> strategy, R resource, long offset, char v, boolean useBigEndian)
hazelcast/src/main/java/com/hazelcast/internal/memory/impl/EndiannessUtil.java:73
↓ 3 callers
Method
writeChar
(byte[] buffer, int pos, char v, boolean useBigEndian)
hazelcast/src/main/java/com/hazelcast/internal/nio/Bits.java:99
↓ 3 callers
Method
writeDateArray
Writes an array of Date's @param fieldName name of the field @param values LocalDate array to be written @throws IOException in case of any except
hazelcast/src/main/java/com/hazelcast/nio/serialization/PortableWriter.java:328
↓ 3 callers
Method
writeDecimalArray
Writes an array of Decimals @param fieldName name of the field @param values BigDecimal array to be written @throws IOException in case of any exc
hazelcast/src/main/java/com/hazelcast/nio/serialization/PortableWriter.java:308
↓ 3 callers
Method
writeDuration
(ObjectDataOutput out, Duration duration)
hazelcast/src/main/java/com/hazelcast/cache/HazelcastExpiryPolicy.java:162
↓ 3 callers
Method
writeGenericRecord
(@Nonnull String fieldName, @Nullable GenericRecord value)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/compact/DefaultCompactWriter.java:266
↓ 3 callers
Method
writeInt
( ByteAccessStrategy<R> strategy, R resource, long offset, int v, boolean useBigEndian)
hazelcast/src/main/java/com/hazelcast/internal/memory/impl/EndiannessUtil.java:151
↓ 3 callers
Method
writeInt
(FileOutputStream fos, int dataSize)
hazelcast/src/main/java/com/hazelcast/internal/nearcache/impl/preloader/NearCachePreloader.java:265
↓ 3 callers
Method
writeInt32
(@Nonnull String fieldName, int value)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/compact/SchemaWriter.java:68
↓ 3 callers
Method
writeIntB
(ByteAccessStrategy<R> strategy, R resource, long offset, int v)
hazelcast/src/main/java/com/hazelcast/internal/memory/impl/EndiannessUtil.java:160
↓ 3 callers
Method
writeInternal
(ObjectDataOutput out)
hazelcast/src/test/java/com/hazelcast/internal/util/SerialOperationInvokerTest.java:323
↓ 3 callers
Method
writeInternal
(BufferObjectDataOutput out, Portable p)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/portable/PortableSerializer.java:77
↓ 3 callers
Method
writeJobExecutionRecordSafe
Ensure that {@link JobExecutionRecord} is safe, that is: it is stored in IMap and all backups succeeded. @throws IndeterminateOperationStateException
hazelcast/src/main/java/com/hazelcast/jet/impl/MasterContext.java:413
↓ 3 callers
Method
writeLocalDate
(ObjectDataOutput out, LocalDate value)
hazelcast/src/main/java/com/hazelcast/internal/nio/IOUtil.java:203
↓ 3 callers
Method
writeLocalTime
(ObjectDataOutput out, LocalTime value)
hazelcast/src/main/java/com/hazelcast/internal/nio/IOUtil.java:184
↓ 3 callers
Method
writeLong
(long value)
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/iobuffer/IOBuffer.java:206
↓ 3 callers
Method
writeLong
( ByteAccessStrategy<R> strategy, R resource, long offset, long v, boolean useBigEndian)
hazelcast/src/main/java/com/hazelcast/internal/memory/impl/EndiannessUtil.java:235
↓ 3 callers
Method
writeLongB
(ByteAccessStrategy<R> strategy, R resource, long offset, long v)
hazelcast/src/main/java/com/hazelcast/internal/memory/impl/EndiannessUtil.java:244
↓ 3 callers
Method
writeLongL
(byte[] buffer, int pos, long v)
hazelcast/src/main/java/com/hazelcast/internal/nio/Bits.java:199
↓ 3 callers
Method
writeNullPortable
To write a null portable value, user needs to provide class and factoryIds of related class. @param fieldName name of the field @param factoryId fact
hazelcast/src/main/java/com/hazelcast/nio/serialization/PortableWriter.java:150
↓ 3 callers
Method
writeObjectTypeMetadata
(QueryDataType type, ObjectDataOutput out)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/QueryDataType.java:325
↓ 3 callers
Method
writePortableGenericRecordInternal
(ObjectDataOutput out, PortableGenericRecord record)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/portable/PortableSerializer.java:184
↓ 3 callers
Method
writeShort
( ByteAccessStrategy<R> strategy, R resource, long offset, short v, boolean useBigEndian)
hazelcast/src/main/java/com/hazelcast/internal/memory/impl/EndiannessUtil.java:110
↓ 3 callers
Method
writeShortL
(ByteAccessStrategy<R> strategy, R resource, long offset, short v)
hazelcast/src/main/java/com/hazelcast/internal/memory/impl/EndiannessUtil.java:124
↓ 3 callers
Method
writeShortL
(byte[] buffer, int pos, short v)
hazelcast/src/main/java/com/hazelcast/internal/nio/Bits.java:135
↓ 3 callers
Method
writeString
(@Nonnull String fieldName, @Nullable String str)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/compact/SchemaWriter.java:78
↓ 3 callers
Method
writeThroughCache
(Data key, Object value)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheRecordStore.java:1051
↓ 3 callers
Method
writeThroughEnabled
(boolean writeThroughEnabled)
hazelcast/src/main/java/com/hazelcast/internal/networking/nio/NioNetworking.java:517
↓ 3 callers
Method
writeTimeArray
Writes an array of Time's @param fieldName name of the field @param values LocalTime array to be written @throws IOException in case of any except
hazelcast/src/main/java/com/hazelcast/nio/serialization/PortableWriter.java:318
↓ 3 callers
Method
writeTimestampArray
Writes an array of Timestamp's @param fieldName name of the field @param values LocalDateTime array to be written @throws IOException in case of a
hazelcast/src/main/java/com/hazelcast/nio/serialization/PortableWriter.java:338
↓ 3 callers
Method
writeTimestampWithTimezoneArray
Writes an array of TimestampWithTimezone's @param fieldName name of the field @param values OffsetDateTime array to be written @throws IOException
hazelcast/src/main/java/com/hazelcast/nio/serialization/PortableWriter.java:348
↓ 3 callers
Method
writeTo
(ByteBuffer dst, ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/ClientMessageWriter.java:32
↓ 3 callers
Method
writeUtf8Char
(byte[] buffer, int pos, int c)
hazelcast/src/main/java/com/hazelcast/internal/nio/Bits.java:203
↓ 2 callers
Method
Default
()
hazelcast/src/main/java/com/hazelcast/jet/core/Partitioner.java:125
↓ 2 callers
Method
abort
()
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/MigrationManagerImpl.java:1343
↓ 2 callers
Method
abortTransaction
(Xid xid)
hazelcast/src/main/java/com/hazelcast/jet/impl/connector/XaSinkProcessorBase.java:180
↓ 2 callers
Method
abortUnfinishedTransactions
()
hazelcast/src/main/java/com/hazelcast/jet/impl/processor/UnboundedTransactionsProcessorUtility.java:180
↓ 2 callers
Method
abortUpload
()
extensions/s3/src/main/java/com/hazelcast/jet/s3/S3Sinks.java:272
↓ 2 callers
Method
accept
(Visitor visitor, IndexRegistry indexes)
hazelcast/src/main/java/com/hazelcast/query/impl/predicates/NotPredicate.java:75
↓ 2 callers
Method
acceptEitherAsync
()
hazelcast/src/test/java/com/hazelcast/spi/impl/CompletableFutureAbstractTest.java:1166
↓ 2 callers
Method
acceptEx
Exception-declaring version of {@link BiConsumer#accept}. @throws Exception in case of any exceptional case
hazelcast/src/main/java/com/hazelcast/function/BiConsumerEx.java:42
↓ 2 callers
Method
acceptLiteral
(String literal)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/expression/datetime/Formatter.java:254
↓ 2 callers
Method
acceptMultilineJson
(Configuration configuration)
extensions/hadoop/src/main/java/com/hazelcast/jet/hadoop/impl/JsonInputFormat.java:73
↓ 2 callers
Method
access
()
hazelcast/src/main/java/com/hazelcast/internal/iteration/IteratorWithCursor.java:78
↓ 2 callers
Method
access
()
hazelcast/src/main/java/com/hazelcast/multimap/impl/MultiMapContainer.java:195
↓ 2 callers
Method
accessRecord
(QueryCacheRecord record)
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/subscriber/DefaultQueryCacheRecordStore.java:79
↓ 2 callers
Method
accessToken
()
hazelcast/src/test/java/com/hazelcast/gcp/GcpMetadataApiTest.java:96
↓ 2 callers
Method
accumulateExtracted
Accumulates a single extracted value. This method may be called multiple times per accumulated entry if the attributePath contains [any] operator. @p
hazelcast/src/main/java/com/hazelcast/aggregation/impl/AbstractAggregator.java:111
↓ 2 callers
Method
accumulateFn
()
hazelcast/src/main/java/com/hazelcast/jet/impl/aggregate/AggregateOperation1Impl.java:57
↓ 2 callers
Method
accumulateFn0
()
hazelcast/src/main/java/com/hazelcast/jet/impl/aggregate/AggregateOperation3Impl.java:67
↓ 2 callers
Method
accumulateFn1
()
hazelcast/src/main/java/com/hazelcast/jet/impl/aggregate/AggregateOperation3Impl.java:73
↓ 2 callers
Method
accumulateFn2
()
hazelcast/src/main/java/com/hazelcast/jet/impl/aggregate/AggregateOperation3Impl.java:79
↓ 2 callers
Method
accumulateOrSendExpiredKeysToBackup
(Data key, R record)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheRecordStore.java:547
↓ 2 callers
Method
accumulateTaskHandlersAsScheduledFutures
(Map<Member, List<IScheduledFuture<V>>> accumulator,
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/impl/ScheduledExecutorServiceProxy.java:397
↓ 2 callers
Method
accumulateTaskHandlersAsUrnValues
(List<ScheduledTaskHandler> accumulator, Map<?, ?> taskHand
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/task/scheduledexecutor/ScheduledExecutorGetAllScheduledMessageTask.java:120
↓ 2 callers
Method
accumulatorInfoCountOfMap
(String mapName)
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/accumulator/DefaultAccumulatorInfoSupplier.java:76
↓ 2 callers
Method
acquirePermit
(boolean quietly)
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/impl/ScheduledExecutorContainer.java:355
↓ 2 callers
Method
adapt
(final Runnable runnable)
hazelcast/src/test/java/com/hazelcast/internal/json/TestUtil.java:71
↓ 2 callers
Method
adaptAggregateOperation
( @Nonnull AggregateOperation<A, ? extends R> aggrOp )
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/FunctionAdapter.java:187
↓ 2 callers
Method
adaptAggregateOperation1
( @Nonnull AggregateOperation1<? super T, A, ? extends R> aggrOp )
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/FunctionAdapter.java:194
↓ 2 callers
Method
adaptDeleteStatePredicate
( @Nonnull TriPredicate<? super S, ? super K, ? super T> deleteStatePredicate )
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/FunctionAdapter.java:89
↓ 2 callers
Method
adaptFilterFn
(@Nonnull PredicateEx<? super T> filterFn)
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/FunctionAdapter.java:69
↓ 2 callers
Method
adaptFilterUsingServiceFn
( @Nonnull BiPredicateEx<? super S, ? super T> filterFn )
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/FunctionAdapter.java:124
↓ 2 callers
Method
adaptFlatMapUsingServiceAsyncBatchedFn
( @Nonnull BiFunctionEx<? super S, ? super List<T>, ? extends CompletableFuture<List<Traverser<R>>
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/FunctionAdapter.java:146
↓ 2 callers
Method
adaptFlatMapUsingServiceAsyncFn
( @Nonnull BiFunctionEx<? super S, ? super T, ? extends CompletableFuture<Traverser<R>>> flatMapAs
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/FunctionAdapter.java:138
↓ 2 callers
Method
adaptFlatMapUsingServiceFn
( @Nonnull BiFunctionEx<? super S, ? super T, ? extends Traverser<R>> flatMapFn )
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/FunctionAdapter.java:131
↓ 2 callers
Method
adaptMapUsingServiceFn
( @Nonnull BiFunctionEx<? super S, ? super T, ? extends R> mapFn )
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/FunctionAdapter.java:117
↓ 2 callers
Method
adaptStatefulFlatMapFn
( @Nonnull TriFunction<? super S, ? super K, ? super T, ? extends Traverser<R>> flatMapFn )
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/FunctionAdapter.java:103
↓ 2 callers
Method
adaptStatefulMapFn
( @Nonnull TriFunction<? super S, ? super K, ? super T, ? extends R> mapFn )
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/FunctionAdapter.java:82
↓ 2 callers
Method
add
(Object value, long count)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/aggregate/AvgSqlAggregations.java:74
↓ 2 callers
Method
add
(Object value, long count)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/aggregate/AvgSqlAggregations.java:130
↓ 2 callers
Method
add
(int value)
hazelcast/src/test/java/com/hazelcast/map/EntryProcessorBouncingNodesTest.java:210
↓ 2 callers
Method
add
Adds one item to the ring buffer. Sets the expiration time if TTL is configured and also attempts to store the item in the data store if one is config
hazelcast/src/main/java/com/hazelcast/ringbuffer/impl/RingbufferContainer.java:309
↓ 2 callers
Method
add
Adds an item to the tail of the ringbuffer. If there is no space in the ringbuffer, the add will overwrite the oldest item in the ringbuffer. The meth
hazelcast/src/main/java/com/hazelcast/spi/merge/RingbufferMergeData.java:141
↓ 2 callers
Method
add
(Object task, boolean priority)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationexecutor/impl/OperationQueueImpl.java:61
↓ 2 callers
Method
add
(RemoteCallHook newHook)
hazelcast/src/main/java/com/hazelcast/internal/nearcache/impl/CompositeRemoteCallHook.java:30
↓ 2 callers
Method
addActiveMigration
Adds the active migration if none is set for the partition and returns {@code null}, otherwise returns the currently set active migration.
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/MigrationManager.java:76
↓ 2 callers
Method
addAdded
(@Nonnull Shard shard)
extensions/kinesis/src/main/java/com/hazelcast/jet/kinesis/impl/source/ShardQueue.java:30
↓ 2 callers
Method
addAddends
( RexNode expr, Integer[] positiveField, Integer[] negativeField,
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/StreamToStreamJoinPhysicalRule.java:280
↓ 2 callers
Method
addAll
(Addresses addresses)
hazelcast/src/main/java/com/hazelcast/client/impl/connection/Addresses.java:42
↓ 2 callers
Method
addAll
{@inheritDoc}
hazelcast/src/main/java/com/hazelcast/internal/util/collection/LongHashSet.java:202
↓ 2 callers
Method
addAndGet
Adds the given value to the current value. <p> The method can throw a {@link ConsistencyLostException} when the state of this CRDT is not causally rel
hazelcast/src/main/java/com/hazelcast/internal/crdt/pncounter/PNCounterImpl.java:141
↓ 2 callers
Method
addAndGet
(long delta)
hazelcast/src/main/java/com/hazelcast/internal/longregister/LongRegister.java:30
↓ 2 callers
Method
addAndGetMissedSequenceCount
(long missCount)
hazelcast/src/main/java/com/hazelcast/internal/nearcache/impl/invalidation/MetaDataContainer.java:103
↓ 2 callers
Method
addAndGetSequence
@param fullFlush {@code true} if flush cause is {@link IMap#flush()}, {@code false} for flushes caused by eviction. @return last stor
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/writebehind/WriteBehindStore.java:343
↓ 2 callers
Method
addAsync
(List<ReliableTopicMessage> messages, OverflowPolicy overflowPolicy)
hazelcast/src/main/java/com/hazelcast/client/impl/proxy/ClientReliableTopicProxy.java:313
↓ 2 callers
Method
addAsync
(List<ReliableTopicMessage> messages, OverflowPolicy overflowPolicy)
hazelcast/src/main/java/com/hazelcast/topic/impl/reliable/ReliableTopicProxy.java:362
↓ 2 callers
Method
addAsync_whenOverwrite
()
hazelcast/src/test/java/com/hazelcast/ringbuffer/impl/RingbufferAbstractTest.java:259
↓ 2 callers
Method
addAttributeInternal
(String attribute)
hazelcast/src/main/java/com/hazelcast/config/IndexConfig.java:177
↓ 2 callers
Method
addBackupListener
(UUID clientUUID, LongConsumer backupListener)
hazelcast/src/main/java/com/hazelcast/client/impl/ClientEngine.java:172
↓ 2 callers
Method
addBatchToBuffer
(SourceBuffer<? super T> buffer)
extensions/s3/src/main/java/com/hazelcast/jet/s3/S3Sources.java:307
↓ 2 callers
Method
addCacheConfig
(CacheConfig cacheConfig)
hazelcast/src/main/java/com/hazelcast/cache/impl/operation/OnJoinCacheOperation.java:54
← previous
next →
16,101–16,200 of 147,315, ranked by callers