MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

↓ 2 callersMethodreadFromIndexAsStringEnableSlicingPipeline
( String index, SupplierEx<RestClientBuilder> elasticSupplier, IList<Strin
extensions/elasticsearch/elasticsearch-7/src/test/java/com/hazelcast/jet/elastic/pipeline/CommonElasticSourcesPipeline.java:151
↓ 2 callersMethodreadFromIndexAsStringPipeline
( String index, SupplierEx<RestClientBuilder> elasticSupplier, IList<Strin
extensions/elasticsearch/elasticsearch-7/src/test/java/com/hazelcast/jet/elastic/pipeline/CommonElasticSourcesPipeline.java:38
↓ 2 callersMethodreadFromJournal
(final EventJournalTestContext<K, V, EJ_TYPE> context, final AtomicReference<
hazelcast/src/test/java/com/hazelcast/journal/AbstractEventJournalExpiringTest.java:134
↓ 2 callersMethodreadFromJournal
(int partition, long offset)
hazelcast/src/main/java/com/hazelcast/jet/impl/connector/StreamEventJournalP.java:342
↓ 2 callersMethodreadFromStreamAndAssert
(InputStream is)
hazelcast/src/test/java/com/hazelcast/jet/impl/deployment/LoadResource.java:64
↓ 2 callersMethodreadFully
(byte[] b)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/ObjectDataInputStream.java:75
↓ 2 callersMethodreadInt
(BufferingInputStream bis)
hazelcast/src/main/java/com/hazelcast/internal/nearcache/impl/preloader/NearCachePreloader.java:260
↓ 2 callersMethodreadInt
(byte[] bytes, int offset)
hazelcast/src/main/java/com/hazelcast/jet/impl/serialization/PlainMemoryReader.java:31
↓ 2 callersMethodreadInt
(byte[] bytes, int offset)
hazelcast/src/main/java/com/hazelcast/jet/impl/serialization/UnsafeMemoryReader.java:36
↓ 2 callersMethodreadInternal
(ObjectDataInput in)
hazelcast/src/test/java/com/hazelcast/internal/util/ParallelOperationInvokerTest.java:349
↓ 2 callersMethodreadInternal
(ObjectDataInput in, Class<?> aClass)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/DataSerializableSerializer.java:127
↓ 2 callersMethodreadJSONObject
(String absPath)
hazelcast/src/test/java/com/hazelcast/config/AbstractYamlSchemaTest.java:64
↓ 2 callersMethodreadJdbcProcessorFn
( FunctionEx<ProcessorSupplier.Context, ? extends Connection> newConnectionFn, ToResul
hazelcast/src/main/java/com/hazelcast/jet/impl/connector/ReadJdbcP.java:185
↓ 2 callersMethodreadLength
(int beginPosition)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/compact/CompactInternalGenericRecord.java:893
↓ 2 callersMethodreadLocalMapSupplier
(@Nonnull String mapName)
hazelcast/src/main/java/com/hazelcast/jet/impl/connector/HazelcastReaders.java:181
↓ 2 callersMethodreadLong
()
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/ObjectDataInputStream.java:128
↓ 2 callersMethodreadLong
(byte[] bytes, int offset)
hazelcast/src/main/java/com/hazelcast/jet/impl/serialization/PlainMemoryReader.java:36
↓ 2 callersMethodreadLong
(byte[] bytes, int offset)
hazelcast/src/main/java/com/hazelcast/jet/impl/serialization/UnsafeMemoryReader.java:42
↓ 2 callersMethodreadMany
(RingbufferContainer ringbuffer)
hazelcast/src/main/java/com/hazelcast/ringbuffer/impl/operations/ReadManyOperation.java:105
↓ 2 callersMethodreadMany
(EventJournal<J> journal, int partitionId)
hazelcast/src/main/java/com/hazelcast/internal/journal/EventJournalReadOperation.java:156
↓ 2 callersMethodreadNestedType
(Converter converter, ObjectDataInput in, Map<String, QueryDat
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/QueryDataType.java:382
↓ 2 callersMethodreadNextPartition
()
hazelcast/src/main/java/com/hazelcast/jet/impl/connector/ReadMapOrCacheP.java:229
↓ 2 callersMethodreadNullablePartitionIdSet
(ObjectDataInput in)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/SerializationUtil.java:466
↓ 2 callersMethodreadObjectData
()
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/CompatibilitySerializationServiceTest.java:91
↓ 2 callersMethodreadObjectTypeMetadata
(QueryDataType type, ObjectDataInput in)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/QueryDataType.java:376
↓ 2 callersMethodreadOnJoinOp
(ObjectDataInput in)
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/operations/FinalizeJoinOp.java:227
↓ 2 callersMethodreadOrLoadItem
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 callersMethodreadPayloadFromUrl
(String id, URL url)
hazelcast/src/main/java/com/hazelcast/internal/namespace/impl/ResourceDefinitionImpl.java:79
↓ 2 callersMethodreadProperties
()
hazelcast/src/main/java/com/hazelcast/internal/diagnostics/OperationHeartbeatPlugin.java:82
↓ 2 callersMethodreadRecordStoreData
(String mapName, ObjectDataInput in)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/MapReplicationStateHolder.java:432
↓ 2 callersMethodreadRemoteCacheP
Returns a supplier of processors for {@link Sources#remoteCache(String, ClientConfig)}.
hazelcast/src/main/java/com/hazelcast/jet/core/processor/SourceProcessors.java:222
↓ 2 callersMethodreadResourceToString
(String resource)
hazelcast/src/test/java/com/hazelcast/config/XmlYamlConfigBuilderEqualsTest.java:121
↓ 2 callersMethodreadShort
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 callersMethodreadShort
()
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/ObjectDataInputStream.java:105
↓ 2 callersMethodreadShortB
(ByteAccessStrategy<R> strategy, R resource, long offset)
hazelcast/src/main/java/com/hazelcast/internal/memory/impl/EndiannessUtil.java:98
↓ 2 callersMethodreadShortB
(byte[] buffer, int pos)
hazelcast/src/main/java/com/hazelcast/internal/nio/Bits.java:115
↓ 2 callersMethodreadStaticFieldInternal
(Class<?> clazz, String fieldName)
hazelcast/src/main/java/com/hazelcast/jet/impl/util/ReflectionUtils.java:148
↓ 2 callersMethodreadStreamAndPutCompressedToMap
( String resourceName, Map<String, byte[]> map, InputStream in )
hazelcast/src/main/java/com/hazelcast/jet/impl/JobRepository.java:351
↓ 2 callersMethodreadString
()
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/ByteArrayObjectDataInput.java:588
↓ 2 callersMethodreadString
()
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/ObjectDataInputStream.java:314
↓ 2 callersMethodreadStringInternal
()
hazelcast/src/main/java/com/hazelcast/internal/json/JsonParser.java:303
↓ 2 callersMethodreadSubject
(@Nonnull ObjectDataInput input)
hazelcast/src/main/java/com/hazelcast/jet/impl/util/ImdgUtil.java:163
↓ 2 callersMethodreadTags
(BiConsumer<String, String> tagReader)
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/MetricDescriptorImpl.java:183
↓ 2 callersMethodreadThroughCache
(Data key)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheRecordStore.java:1033
↓ 2 callersMethodreadValueUnderLock
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 callersMethodreadVersions
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 callersMethodreader
(Portable portable)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/portable/portablereader/DefaultPortableReaderSpecTest.java:924
↓ 2 callersMethodreaderWriterFor
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 callersMethodrecalculatePartitions
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 callersMethodreceive
()
hazelcast/src/main/java/com/hazelcast/spi/discovery/multicast/impl/MulticastDiscoveryReceiver.java:40
↓ 2 callersMethodrecomputeWindow
(long frameTs)
hazelcast/src/main/java/com/hazelcast/jet/impl/processor/SlidingWindowP.java:420
↓ 2 callersMethodreconnectIfNecessary
()
hazelcast/src/main/java/com/hazelcast/jet/impl/connector/WriteJdbcP.java:312
↓ 2 callersMethodreconstructOptions
(Map<String, String> options)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/parse/UnparseUtil.java:70
↓ 2 callersMethodrecord
(int i)
extensions/avro/src/test/java/com/hazelcast/jet/avro/AvroSourceTest.java:194
↓ 2 callersMethodrecordIndexDefinition
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 callersMethodrecordPhase
(JobPhase phase)
hazelcast/src/main/java/com/hazelcast/jet/impl/JobClassLoaderService.java:342
↓ 2 callersMethodrecordProvider
()
hazelcast/src/test/java/com/hazelcast/test/jdbc/TestDatabaseProvider.java:107
↓ 2 callersMethodrecoverAndCommitFn
()
hazelcast/src/main/java/com/hazelcast/jet/impl/processor/TwoPhaseSnapshotCommitUtility.java:117
↓ 2 callersMethodrecoverTransaction
(KafkaTransactionId txnId, boolean commit)
extensions/kafka/src/main/java/com/hazelcast/jet/kafka/impl/WriteKafkaP.java:185
↓ 2 callersMethodrecreateIfExists
(@Nonnull String id)
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/init/Contexts.java:331
↓ 2 callersMethodreduce
(Collection<AccumulatedResults> results)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/task/map/AbstractMapQueryMessageTask.java:90
↓ 2 callersMethodreduceInto
(MultiResult<Object> collector, Object currentObject)
hazelcast/src/main/java/com/hazelcast/query/impl/getters/AbstractMultiValueGetter.java:182
↓ 2 callersMethodreducePrimitiveArrayInto
@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 callersMethodreflectClass
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 callersMethodrefresh
()
hazelcast/src/main/java/com/hazelcast/internal/server/tcp/TcpServerConnectionManagerBase.java:393
↓ 2 callersMethodrefreshCachedOwnedPartitions
()
hazelcast/src/main/java/com/hazelcast/map/impl/MapServiceContext.java:176
↓ 2 callersMethodrefreshTransaction
(MongoTransaction transaction, boolean commit)
extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/impl/WriteMongoP.java:436
↓ 2 callersMethodregenerateUuid
(int partitionId)
hazelcast/src/main/java/com/hazelcast/internal/nearcache/impl/invalidation/MetaDataGenerator.java:110
↓ 2 callersMethodregionFrom
(String availabilityZone)
hazelcast/src/main/java/com/hazelcast/aws/AwsClientConfigurator.java:84
↓ 2 callersMethodregister
(int factoryId, DataSerializableFactory factory)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/DataSerializableSerializer.java:96
↓ 2 callersMethodregister
(int factoryId, DataSerializableFactory factory)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/VersionedDataSerializableSerializer.java:106
↓ 2 callersMethodregister
(int factoryId, PortableFactory factory)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/portable/PortableHookLoader.java:79
↓ 2 callersMethodregister
(AtomicReference<HazelcastInstance[]> ref, HazelcastInstance instance)
hazelcast/src/main/java/com/hazelcast/instance/impl/OutOfMemoryErrorDispatcher.java:79
↓ 2 callersMethodregister0
(Class clazz, String typeName, CompactSerializer explicitSerializer)
hazelcast/src/main/java/com/hazelcast/config/CompactSerializationConfig.java:205
↓ 2 callersMethodregisterCacheObject
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 callersMethodregisterCallback
(InternalCompletableFuture<T> future, final Iterator<InternalCompletableFutu
hazelcast/src/main/java/com/hazelcast/internal/util/futures/ChainingFuture.java:47
↓ 2 callersMethodregisterConfigLocally
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 callersMethodregisterDistributedObject
(DistributedObject distributedObject)
hazelcast/src/main/java/com/hazelcast/internal/jmx/ManagementService.java:144
↓ 2 callersMethodregisterDoubleMetric
(String name, final int value)
hazelcast/src/test/java/com/hazelcast/internal/metrics/impl/RenderTest.java:55
↓ 2 callersMethodregisterEngineName
(String name, ScriptEngineFactory factory)
hazelcast/src/main/java/com/hazelcast/osgi/impl/OSGiScriptEngineManager.java:231
↓ 2 callersMethodregisterInvalidationListener
(EventHandler handler, String nameWithPrefix)
hazelcast/src/test/java/com/hazelcast/client/cache/ClientCacheClearTest.java:167
↓ 2 callersMethodregisterJetExceptions
Called during startup to make our exceptions known to Hazelcast serialization
hazelcast/src/main/java/com/hazelcast/jet/impl/util/ExceptionUtil.java:118
↓ 2 callersMethodregisterJvmNameAndPidMetric
(HazelcastClientInstanceImpl client)
hazelcast/src/test/java/com/hazelcast/client/test/TestHazelcastFactory.java:95
↓ 2 callersMethodregisterListener
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 callersMethodregisterListener
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 callersMethodregisterListener0
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 callersMethodregisterListenerAsync
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 callersMethodregisterListeners
(CacheConfig<K, V> cacheConfig, ICache<K, V> source)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractHazelcastCacheManager.java:406
↓ 2 callersMethodregisterLocalListener
(PartitionEventListener<?> adapter, String topic)
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/PartitionEventManager.java:200
↓ 2 callersMethodregisterLongMetric
(String name, final int value)
hazelcast/src/test/java/com/hazelcast/internal/metrics/impl/RenderTest.java:49
↓ 2 callersMethodregisterPartitionLostListener
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/partition/PartitionLostListenerStressTest.java:144
↓ 2 callersMethodregisterProcessor
(Class<? extends Result> clazz, ResultProcessor processor)
hazelcast/src/main/java/com/hazelcast/map/impl/query/ResultProcessorRegistry.java:30
↓ 2 callersMethodregisterServiceInternal
(String clazz, TestServiceReference serviceReference)
hazelcast/src/test/java/com/hazelcast/osgi/TestBundleContext.java:95
↓ 2 callersMethodregisterSomePlugins
(Diagnostics diagnostics)
hazelcast/src/test/java/com/hazelcast/internal/diagnostics/DiagnosticsTest.java:230
↓ 2 callersMethodregisterStaticProbe
(S source, MetricDescriptor descriptor, String name, ProbeLevel level,
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/MetricsRegistryImpl.java:175
↓ 2 callersMethodregisterStaticProbeWithoutUnit
(S source, String name, ProbeLevel level, ProbeFunction function)
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/MetricsRegistryImpl.java:214
↓ 2 callersMethodrehash
(final int newCapacity)
hazelcast/src/main/java/com/hazelcast/internal/util/collection/Object2LongHashMap.java:560
↓ 2 callersMethodrehash
(final int newCapacity)
hazelcast/src/main/java/com/hazelcast/internal/util/collection/Long2ObjectHashMap.java:325
↓ 2 callersMethodrehash
(final int newCapacity)
hazelcast/src/main/java/com/hazelcast/internal/util/collection/Int2ObjectHashMap.java:325
↓ 2 callersMethodreleaseLocksOwnedBy
(final UUID uuid)
hazelcast/src/main/java/com/hazelcast/internal/locksupport/LockSupportServiceImpl.java:152
← previousnext →20,401–20,500 of 147,315, ranked by callers