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
↓ 2 callers
Method
readFromIndexAsStringEnableSlicingPipeline
( String index, SupplierEx<RestClientBuilder> elasticSupplier, IList<Strin
extensions/elasticsearch/elasticsearch-7/src/test/java/com/hazelcast/jet/elastic/pipeline/CommonElasticSourcesPipeline.java:151
↓ 2 callers
Method
readFromIndexAsStringPipeline
( String index, SupplierEx<RestClientBuilder> elasticSupplier, IList<Strin
extensions/elasticsearch/elasticsearch-7/src/test/java/com/hazelcast/jet/elastic/pipeline/CommonElasticSourcesPipeline.java:38
↓ 2 callers
Method
readFromJournal
(final EventJournalTestContext<K, V, EJ_TYPE> context, final AtomicReference<
hazelcast/src/test/java/com/hazelcast/journal/AbstractEventJournalExpiringTest.java:134
↓ 2 callers
Method
readFromJournal
(int partition, long offset)
hazelcast/src/main/java/com/hazelcast/jet/impl/connector/StreamEventJournalP.java:342
↓ 2 callers
Method
readFromStreamAndAssert
(InputStream is)
hazelcast/src/test/java/com/hazelcast/jet/impl/deployment/LoadResource.java:64
↓ 2 callers
Method
readFully
(byte[] b)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/ObjectDataInputStream.java:75
↓ 2 callers
Method
readInt
(BufferingInputStream bis)
hazelcast/src/main/java/com/hazelcast/internal/nearcache/impl/preloader/NearCachePreloader.java:260
↓ 2 callers
Method
readInt
(byte[] bytes, int offset)
hazelcast/src/main/java/com/hazelcast/jet/impl/serialization/PlainMemoryReader.java:31
↓ 2 callers
Method
readInt
(byte[] bytes, int offset)
hazelcast/src/main/java/com/hazelcast/jet/impl/serialization/UnsafeMemoryReader.java:36
↓ 2 callers
Method
readInternal
(ObjectDataInput in)
hazelcast/src/test/java/com/hazelcast/internal/util/ParallelOperationInvokerTest.java:349
↓ 2 callers
Method
readInternal
(ObjectDataInput in, Class<?> aClass)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/DataSerializableSerializer.java:127
↓ 2 callers
Method
readJSONObject
(String absPath)
hazelcast/src/test/java/com/hazelcast/config/AbstractYamlSchemaTest.java:64
↓ 2 callers
Method
readJdbcProcessorFn
( FunctionEx<ProcessorSupplier.Context, ? extends Connection> newConnectionFn, ToResul
hazelcast/src/main/java/com/hazelcast/jet/impl/connector/ReadJdbcP.java:185
↓ 2 callers
Method
readLength
(int beginPosition)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/compact/CompactInternalGenericRecord.java:893
↓ 2 callers
Method
readLocalMapSupplier
(@Nonnull String mapName)
hazelcast/src/main/java/com/hazelcast/jet/impl/connector/HazelcastReaders.java:181
↓ 2 callers
Method
readLong
()
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/ObjectDataInputStream.java:128
↓ 2 callers
Method
readLong
(byte[] bytes, int offset)
hazelcast/src/main/java/com/hazelcast/jet/impl/serialization/PlainMemoryReader.java:36
↓ 2 callers
Method
readLong
(byte[] bytes, int offset)
hazelcast/src/main/java/com/hazelcast/jet/impl/serialization/UnsafeMemoryReader.java:42
↓ 2 callers
Method
readMany
(RingbufferContainer ringbuffer)
hazelcast/src/main/java/com/hazelcast/ringbuffer/impl/operations/ReadManyOperation.java:105
↓ 2 callers
Method
readMany
(EventJournal<J> journal, int partitionId)
hazelcast/src/main/java/com/hazelcast/internal/journal/EventJournalReadOperation.java:156
↓ 2 callers
Method
readNestedType
(Converter converter, ObjectDataInput in, Map<String, QueryDat
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/QueryDataType.java:382
↓ 2 callers
Method
readNextPartition
()
hazelcast/src/main/java/com/hazelcast/jet/impl/connector/ReadMapOrCacheP.java:229
↓ 2 callers
Method
readNullablePartitionIdSet
(ObjectDataInput in)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/SerializationUtil.java:466
↓ 2 callers
Method
readObjectData
()
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/CompatibilitySerializationServiceTest.java:91
↓ 2 callers
Method
readObjectTypeMetadata
(QueryDataType type, ObjectDataInput in)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/QueryDataType.java:376
↓ 2 callers
Method
readOnJoinOp
(ObjectDataInput in)
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/operations/FinalizeJoinOp.java:227
↓ 2 callers
Method
readOrLoadItem
Reads the item at the specified sequence or loads it from the ringbuffer store if one is enabled. The type of the returned object is equal to the ring
hazelcast/src/main/java/com/hazelcast/ringbuffer/impl/RingbufferContainer.java:543
↓ 2 callers
Method
readPayloadFromUrl
(String id, URL url)
hazelcast/src/main/java/com/hazelcast/internal/namespace/impl/ResourceDefinitionImpl.java:79
↓ 2 callers
Method
readProperties
()
hazelcast/src/main/java/com/hazelcast/internal/diagnostics/OperationHeartbeatPlugin.java:82
↓ 2 callers
Method
readRecordStoreData
(String mapName, ObjectDataInput in)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/MapReplicationStateHolder.java:432
↓ 2 callers
Method
readRemoteCacheP
Returns a supplier of processors for {@link Sources#remoteCache(String, ClientConfig)}.
hazelcast/src/main/java/com/hazelcast/jet/core/processor/SourceProcessors.java:222
↓ 2 callers
Method
readResourceToString
(String resource)
hazelcast/src/test/java/com/hazelcast/config/XmlYamlConfigBuilderEqualsTest.java:121
↓ 2 callers
Method
readShort
See the general contract of the {@code readShort} method of {@code DataInput}. <p> Bytes for this operation are read from the contained input stream.
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/ByteArrayObjectDataInput.java:358
↓ 2 callers
Method
readShort
()
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/ObjectDataInputStream.java:105
↓ 2 callers
Method
readShortB
(ByteAccessStrategy<R> strategy, R resource, long offset)
hazelcast/src/main/java/com/hazelcast/internal/memory/impl/EndiannessUtil.java:98
↓ 2 callers
Method
readShortB
(byte[] buffer, int pos)
hazelcast/src/main/java/com/hazelcast/internal/nio/Bits.java:115
↓ 2 callers
Method
readStaticFieldInternal
(Class<?> clazz, String fieldName)
hazelcast/src/main/java/com/hazelcast/jet/impl/util/ReflectionUtils.java:148
↓ 2 callers
Method
readStreamAndPutCompressedToMap
( String resourceName, Map<String, byte[]> map, InputStream in )
hazelcast/src/main/java/com/hazelcast/jet/impl/JobRepository.java:351
↓ 2 callers
Method
readString
()
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/ByteArrayObjectDataInput.java:588
↓ 2 callers
Method
readString
()
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/ObjectDataInputStream.java:314
↓ 2 callers
Method
readStringInternal
()
hazelcast/src/main/java/com/hazelcast/internal/json/JsonParser.java:303
↓ 2 callers
Method
readSubject
(@Nonnull ObjectDataInput input)
hazelcast/src/main/java/com/hazelcast/jet/impl/util/ImdgUtil.java:163
↓ 2 callers
Method
readTags
(BiConsumer<String, String> tagReader)
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/MetricDescriptorImpl.java:183
↓ 2 callers
Method
readThroughCache
(Data key)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheRecordStore.java:1033
↓ 2 callers
Method
readValueUnderLock
Reads value field of an entry under lock. Called if value field ever appears to be null. This is possible only if a compiler happens to reorder a Hash
hazelcast/src/main/java/com/hazelcast/internal/util/ConcurrentReferenceHashMap.java:624
↓ 2 callers
Method
readVersions
Reads the cluster and WAN protocol version from the serialised stream and sets them on the {@code in} object. @param in the input stream containing t
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/VersionedDataSerializableSerializer.java:277
↓ 2 callers
Method
reader
(Portable portable)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/portable/portablereader/DefaultPortableReaderSpecTest.java:924
↓ 2 callers
Method
readerWriterFor
Returns the reader writer for the given {@code type}. @param clazz Top level class @param type Class to return the reader writer for @pa
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/compact/zeroconfig/ValueReaderWriters.java:178
↓ 2 callers
Method
recalculatePartitions
Resets the partition target data (called only on init and after failure to retry)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/InvokeOnLocalPartitions.java:76
↓ 2 callers
Method
receive
()
hazelcast/src/main/java/com/hazelcast/spi/discovery/multicast/impl/MulticastDiscoveryReceiver.java:40
↓ 2 callers
Method
recomputeWindow
(long frameTs)
hazelcast/src/main/java/com/hazelcast/jet/impl/processor/SlidingWindowP.java:420
↓ 2 callers
Method
reconnectIfNecessary
()
hazelcast/src/main/java/com/hazelcast/jet/impl/connector/WriteJdbcP.java:312
↓ 2 callers
Method
reconstructOptions
(Map<String, String> options)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/parse/UnparseUtil.java:70
↓ 2 callers
Method
record
(int i)
extensions/avro/src/test/java/com/hazelcast/jet/avro/AvroSourceTest.java:194
↓ 2 callers
Method
recordIndexDefinition
Records the given index definition in this indexes without creating an index. @param config Index configuration.
hazelcast/src/main/java/com/hazelcast/query/impl/IndexRegistry.java:219
↓ 2 callers
Method
recordPhase
(JobPhase phase)
hazelcast/src/main/java/com/hazelcast/jet/impl/JobClassLoaderService.java:342
↓ 2 callers
Method
recordProvider
()
hazelcast/src/test/java/com/hazelcast/test/jdbc/TestDatabaseProvider.java:107
↓ 2 callers
Method
recoverAndCommitFn
()
hazelcast/src/main/java/com/hazelcast/jet/impl/processor/TwoPhaseSnapshotCommitUtility.java:117
↓ 2 callers
Method
recoverTransaction
(KafkaTransactionId txnId, boolean commit)
extensions/kafka/src/main/java/com/hazelcast/jet/kafka/impl/WriteKafkaP.java:185
↓ 2 callers
Method
recreateIfExists
(@Nonnull String id)
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/init/Contexts.java:331
↓ 2 callers
Method
reduce
(Collection<AccumulatedResults> results)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/task/map/AbstractMapQueryMessageTask.java:90
↓ 2 callers
Method
reduceInto
(MultiResult<Object> collector, Object currentObject)
hazelcast/src/main/java/com/hazelcast/query/impl/getters/AbstractMultiValueGetter.java:182
↓ 2 callers
Method
reducePrimitiveArrayInto
@param add Consumer that primitives will be passed to @param primitiveArray primitive array to read from @return false if primitive array i
hazelcast/src/main/java/com/hazelcast/query/impl/getters/ExtractorHelper.java:129
↓ 2 callers
Method
reflectClass
Returns the class Jet will deserialize data into (using reflection). Null if not set.
hazelcast/src/main/java/com/hazelcast/jet/pipeline/file/AvroFileFormat.java:68
↓ 2 callers
Method
refresh
()
hazelcast/src/main/java/com/hazelcast/internal/server/tcp/TcpServerConnectionManagerBase.java:393
↓ 2 callers
Method
refreshCachedOwnedPartitions
()
hazelcast/src/main/java/com/hazelcast/map/impl/MapServiceContext.java:176
↓ 2 callers
Method
refreshTransaction
(MongoTransaction transaction, boolean commit)
extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/impl/WriteMongoP.java:436
↓ 2 callers
Method
regenerateUuid
(int partitionId)
hazelcast/src/main/java/com/hazelcast/internal/nearcache/impl/invalidation/MetaDataGenerator.java:110
↓ 2 callers
Method
regionFrom
(String availabilityZone)
hazelcast/src/main/java/com/hazelcast/aws/AwsClientConfigurator.java:84
↓ 2 callers
Method
register
(int factoryId, DataSerializableFactory factory)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/DataSerializableSerializer.java:96
↓ 2 callers
Method
register
(int factoryId, DataSerializableFactory factory)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/VersionedDataSerializableSerializer.java:106
↓ 2 callers
Method
register
(int factoryId, PortableFactory factory)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/portable/PortableHookLoader.java:79
↓ 2 callers
Method
register
(AtomicReference<HazelcastInstance[]> ref, HazelcastInstance instance)
hazelcast/src/main/java/com/hazelcast/instance/impl/OutOfMemoryErrorDispatcher.java:79
↓ 2 callers
Method
register0
(Class clazz, String typeName, CompactSerializer explicitSerializer)
hazelcast/src/main/java/com/hazelcast/config/CompactSerializationConfig.java:205
↓ 2 callers
Method
registerCacheObject
Registers the provided {@link javax.cache.management.CacheMXBean} or {@link javax.cache.management.CacheStatisticsMXBean} implementations if not regis
hazelcast/src/main/java/com/hazelcast/cache/impl/MXBeanUtil.java:50
↓ 2 callers
Method
registerCallback
(InternalCompletableFuture<T> future, final Iterator<InternalCompletableFutu
hazelcast/src/main/java/com/hazelcast/internal/util/futures/ChainingFuture.java:47
↓ 2 callers
Method
registerConfigLocally
Register a dynamic configuration in a local member. @param newConfig Configuration to register. @param configCheckMode behaviour when a config
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/ClusterWideConfigurationService.java:306
↓ 2 callers
Method
registerDistributedObject
(DistributedObject distributedObject)
hazelcast/src/main/java/com/hazelcast/internal/jmx/ManagementService.java:144
↓ 2 callers
Method
registerDoubleMetric
(String name, final int value)
hazelcast/src/test/java/com/hazelcast/internal/metrics/impl/RenderTest.java:55
↓ 2 callers
Method
registerEngineName
(String name, ScriptEngineFactory factory)
hazelcast/src/main/java/com/hazelcast/osgi/impl/OSGiScriptEngineManager.java:231
↓ 2 callers
Method
registerInvalidationListener
(EventHandler handler, String nameWithPrefix)
hazelcast/src/test/java/com/hazelcast/client/cache/ClientCacheClearTest.java:167
↓ 2 callers
Method
registerJetExceptions
Called during startup to make our exceptions known to Hazelcast serialization
hazelcast/src/main/java/com/hazelcast/jet/impl/util/ExceptionUtil.java:118
↓ 2 callers
Method
registerJvmNameAndPidMetric
(HazelcastClientInstanceImpl client)
hazelcast/src/test/java/com/hazelcast/client/test/TestHazelcastFactory.java:95
↓ 2 callers
Method
registerListener
Adds a listener to be called when a {@see Table} is added, removed or changed.
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/schema/TableResolver.java:55
↓ 2 callers
Method
registerListener
Registers given listener if it's a known type. @param listener listener instance @return true if listener is registered, false otherwise
hazelcast/src/main/java/com/hazelcast/instance/impl/NodeExtension.java:379
↓ 2 callers
Method
registerListener0
Registers the listener for events matching the service name, topic and filter on local member. @param serviceName the service name for which we are r
hazelcast/src/main/java/com/hazelcast/spi/impl/eventservice/impl/EventServiceImpl.java:284
↓ 2 callers
Method
registerListenerAsync
Registers the listener for events matching the service name, topic and filter. It will register only for events published on this node and then the re
hazelcast/src/main/java/com/hazelcast/spi/impl/eventservice/impl/EventServiceImpl.java:326
↓ 2 callers
Method
registerListeners
(CacheConfig<K, V> cacheConfig, ICache<K, V> source)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractHazelcastCacheManager.java:406
↓ 2 callers
Method
registerLocalListener
(PartitionEventListener<?> adapter, String topic)
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/PartitionEventManager.java:200
↓ 2 callers
Method
registerLongMetric
(String name, final int value)
hazelcast/src/test/java/com/hazelcast/internal/metrics/impl/RenderTest.java:49
↓ 2 callers
Method
registerPartitionLostListener
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/partition/PartitionLostListenerStressTest.java:144
↓ 2 callers
Method
registerProcessor
(Class<? extends Result> clazz, ResultProcessor processor)
hazelcast/src/main/java/com/hazelcast/map/impl/query/ResultProcessorRegistry.java:30
↓ 2 callers
Method
registerServiceInternal
(String clazz, TestServiceReference serviceReference)
hazelcast/src/test/java/com/hazelcast/osgi/TestBundleContext.java:95
↓ 2 callers
Method
registerSomePlugins
(Diagnostics diagnostics)
hazelcast/src/test/java/com/hazelcast/internal/diagnostics/DiagnosticsTest.java:230
↓ 2 callers
Method
registerStaticProbe
(S source, MetricDescriptor descriptor, String name, ProbeLevel level,
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/MetricsRegistryImpl.java:175
↓ 2 callers
Method
registerStaticProbeWithoutUnit
(S source, String name, ProbeLevel level, ProbeFunction function)
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/MetricsRegistryImpl.java:214
↓ 2 callers
Method
rehash
(final int newCapacity)
hazelcast/src/main/java/com/hazelcast/internal/util/collection/Object2LongHashMap.java:560
↓ 2 callers
Method
rehash
(final int newCapacity)
hazelcast/src/main/java/com/hazelcast/internal/util/collection/Long2ObjectHashMap.java:325
↓ 2 callers
Method
rehash
(final int newCapacity)
hazelcast/src/main/java/com/hazelcast/internal/util/collection/Int2ObjectHashMap.java:325
↓ 2 callers
Method
releaseLocksOwnedBy
(final UUID uuid)
hazelcast/src/main/java/com/hazelcast/internal/locksupport/LockSupportServiceImpl.java:152
← previous
next →
20,401–20,500 of 147,315, ranked by callers