MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

⨍ Functions 147,315◇ Types & classes 15,944
↓ 2 callersMethodcreateQueryCacheListenerAdaptor
Wraps a user defined {@link com.hazelcast.map.listener.MapListener} into a {@link com.hazelcast.map.impl.ListenerAdapter}. @param mapListener a {@lin
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/subscriber/QueryCacheEventListenerAdapters.java:65
↓ 2 callersMethodcreateQueueCapacityController
()
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/writebehind/WriteBehindQueueTest.java:234
↓ 2 callersMethodcreateReader
(BufferObjectDataInput in, int factoryId, int classId, int version,
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/portable/PortableSerializer.java:157
↓ 2 callersMethodcreateRecord
(InMemoryFormat format, String value)
hazelcast/src/test/java/com/hazelcast/cache/CacheSerializationTest.java:167
↓ 2 callersMethodcreateRecord
(Object value, long creationTime, long expiryTime)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheRecordStore.java:342
↓ 2 callersMethodcreateRecord
Creates new {@link QueryCacheRecord}. @param value {@link Data} value @return an instance of {@link QueryCacheRecord}
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/subscriber/record/QueryCacheRecordFactory.java:32
↓ 2 callersMethodcreateReflectively
(ProtocolType protocolType, String name)
hazelcast/src/test/java/com/hazelcast/config/AdvancedNetworkConfigTest.java:158
↓ 2 callersMethodcreateRegistry
()
hazelcast/src/test/java/com/hazelcast/test/TestHazelcastInstanceFactory.java:137
↓ 2 callersMethodcreateRemoveIfSameOperation
(String name, Data dataKey, Data value)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/MapOperationProvider.java:60
↓ 2 callersMethodcreateRemoveOperation
(Data key, Data value, int completionId)
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheOperationProvider.java:47
↓ 2 callersMethodcreateReplaceIfSameOperation
(String name, Data dataKey, Data expect, Data update)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/MapOperationProvider.java:62
↓ 2 callersMethodcreateReplaceOperation
(Data key, Data oldValue, Data newValue, ExpiryPolicy policy, int completionId)
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheOperationProvider.java:51
↓ 2 callersMethodcreateReplaceOperation
(String name, Data dataKey, Data value)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/MapOperationProvider.java:58
↓ 2 callersMethodcreateReplicationTxExceptionHandler
(final ILogger logger)
hazelcast/src/main/java/com/hazelcast/transaction/impl/TransactionImpl.java:475
↓ 2 callersMethodcreateResult
(Query query, Collection<Integer> partitions)
hazelcast/src/main/java/com/hazelcast/map/impl/query/QueryRunner.java:248
↓ 2 callersMethodcreateRowMetadata
( List<String> columnNames, List<QueryDataType> columnTypes, List<RelDataT
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/CalciteSqlOptimizerImpl.java:869
↓ 2 callersMethodcreateRunnable
(Step step, State state)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/steps/engine/StepSupplier.java:125
↓ 2 callersMethodcreateScheduler
(ObjectNamespace namespace)
hazelcast/src/main/java/com/hazelcast/internal/locksupport/LockStoreContainer.java:101
↓ 2 callersMethodcreateSchema
(String typeName, List<FieldDescriptor> fields)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/CustomTypeFactory.java:281
↓ 2 callersMethodcreateSchemaRegistry
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/kafka/KafkaSqlTestSupport.java:73
↓ 2 callersMethodcreateSelector
(List<ClientBwListEntryDTO> entries)
hazelcast/src/main/java/com/hazelcast/internal/management/ClientBwListConfigHandler.java:73
↓ 2 callersMethodcreateSerializationConfiguredClient
()
hazelcast/src/test/java/com/hazelcast/client/cardinality/ClientCardinalityEstimatorTest.java:62
↓ 2 callersMethodcreateSerializationService
(@Nullable String key)
hazelcast/src/test/java/com/hazelcast/nio/serialization/compatibility/BinaryCompatibilityTest.java:147
↓ 2 callersMethodcreateSerializationService
(String lookupPolicyName)
hazelcast/src/test/java/com/hazelcast/query/impl/getters/ExtractorsTest.java:208
↓ 2 callersMethodcreateSerializationServiceBuilder
()
hazelcast/src/test/java/com/hazelcast/nio/PacketIOHelperTest.java:73
↓ 2 callersMethodcreateServerConfig
(String mapName, boolean liteMember)
hazelcast/src/test/java/com/hazelcast/client/map/impl/nearcache/MapNearCacheInvalidationFromClientTest.java:204
↓ 2 callersMethodcreateService
(Class<T> service)
hazelcast/src/main/java/com/hazelcast/spi/impl/servicemanager/impl/ServiceManagerImpl.java:194
↓ 2 callersMethodcreateServiceProxyFactory
(Class<T> service)
hazelcast/src/main/java/com/hazelcast/client/impl/clientside/DefaultClientExtension.java:211
↓ 2 callersMethodcreateSetTtlOperation
(String name, Data key, long ttl)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/MapOperationProvider.java:54
↓ 2 callersMethodcreateSharedAttributes
()
hazelcast/src/main/java/com/hazelcast/aws/AwsEc2Api.java:244
↓ 2 callersMethodcreateShiftDownMigration
(int partitionId, int oldReplicaIndex, int newReplicaIndex,
hazelcast/src/test/java/com/hazelcast/internal/partition/impl/MigrationCommitServiceTest.java:323
↓ 2 callersMethodcreateSimpleEntryView
()
hazelcast/src/main/java/com/hazelcast/map/impl/EntryViews.java:34
↓ 2 callersMethodcreateSimpleTcpIpConfig
(String clusterName)
hazelcast/src/test/java/com/hazelcast/cluster/SplitBrainHandlerTest.java:797
↓ 2 callersMethodcreateSizeOperationFactory
()
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheOperationProvider.java:90
↓ 2 callersMethodcreateSocketConnection
(Address target)
hazelcast/src/main/java/com/hazelcast/client/impl/connection/tcp/TcpClientConnectionManager.java:804
↓ 2 callersMethodcreateSocketInterceptorConfig
()
hazelcast/src/test/java/com/hazelcast/internal/dynamicconfig/DynamicConfigYamlGeneratorTest.java:299
↓ 2 callersMethodcreateSocketInterceptorConfig
()
hazelcast/src/test/java/com/hazelcast/config/ConfigXmlGeneratorTest.java:325
↓ 2 callersMethodcreateSourceConnector
()
extensions/kafka-connect/src/main/java/com/hazelcast/jet/kafka/connect/impl/SourceConnectorWrapper.java:116
↓ 2 callersMethodcreateSpiedMemberSchemaService
()
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/schema/CompactSchemaReplicationSlowTest.java:107
↓ 2 callersMethodcreateSplitBrainProtectionFunctionProxy
(long maxNoHeartbeatMillis, long hearbeatIntervalMillis)
hazelcast/src/test/java/com/hazelcast/splitbrainprotection/impl/ProbabilisticSplitBrainProtectionFunctionTest.java:117
↓ 2 callersMethodcreateSql
(String objectName, String... columns)
hazelcast/src/test/java/com/hazelcast/test/jdbc/JdbcObjectProvider.java:98
↓ 2 callersMethodcreateSqlColumnMetadata
(String name, int type, boolean isNullableExists, boolean nullability)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/CustomTypeFactory.java:262
↓ 2 callersMethodcreateSqlSummary
(String query, boolean unbounded)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/CustomTypeFactory.java:319
↓ 2 callersMethodcreateSqlToRelConverter
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/parse/QueryConverter.java:153
↓ 2 callersMethodcreateState
()
hazelcast/src/test/java/com/hazelcast/internal/management/TimedMemberStateTest.java:148
↓ 2 callersMethodcreateStats
(String name)
hazelcast/src/main/java/com/hazelcast/multimap/impl/MultiMapService.java:424
↓ 2 callersMethodcreateStoreEvent
(E source)
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/writebehind/StoreEvent.java:42
↓ 2 callersMethodcreateStrategy
(String xmlFileName)
hazelcast/src/test/java/com/hazelcast/gcp/GcpDiscoveryStrategyFactoryTest.java:60
↓ 2 callersMethodcreateStrategy
(String xmlFileName)
hazelcast/src/test/java/com/hazelcast/azure/AzureDiscoveryStrategyFactoryTest.java:60
↓ 2 callersMethodcreateStrategy
(Map<String, Comparable> props)
hazelcast/src/test/java/com/hazelcast/aws/AwsDiscoveryStrategyFactoryTest.java:51
↓ 2 callersMethodcreateSynchronizedWriteBehindQueue
(WriteBehindQueue<T> queue)
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/writebehind/WriteBehindQueues.java:48
↓ 2 callersMethodcreateTable
(Object[]... values)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlUnionTest.java:382
↓ 2 callersMethodcreateTable
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/aggregate/JsonSqlAggregateTest.java:304
↓ 2 callersMethodcreateTable
( @Nonnull NodeEngine nodeEngine, @Nonnull String schemaName, @Nonnull Str
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/generator/StreamSqlConnector.java:71
↓ 2 callersMethodcreateTarget
(boolean key)
hazelcast-sql/src/test/java/com/hazelcast/sql/impl/extract/GenericQueryTargetTest.java:107
↓ 2 callersMethodcreateTestClass
()
hazelcast/src/test/java/com/hazelcast/test/OverridePropertyRuleMockTest.java:92
↓ 2 callersMethodcreateTestEnvironment
(boolean loopbackMode)
hazelcast/src/test/java/com/hazelcast/instance/MulticastLoopbackModeTest.java:66
↓ 2 callersMethodcreateTestFile
()
hazelcast/src/test/java/com/hazelcast/jet/pipeline/SourceBuilderTest.java:581
↓ 2 callersMethodcreateTestStats
()
hazelcast/src/test/java/com/hazelcast/internal/monitor/impl/LocalSetStatsImplTest.java:53
↓ 2 callersMethodcreateTestStats
()
hazelcast/src/test/java/com/hazelcast/internal/monitor/impl/LocalListStatsImplTest.java:53
↓ 2 callersMethodcreateTextCommandService
()
hazelcast/src/main/java/com/hazelcast/instance/impl/NodeExtension.java:398
↓ 2 callersMethodcreateThreads
(HazelcastInstance instance, int threadCount, String in, String out,
hazelcast/src/test/java/com/hazelcast/collection/impl/txnqueue/TransactionQueueTest.java:426
↓ 2 callersMethodcreateTimedExpiryPolicyFactoryConfig
(int expiryPolicyType, D
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/CustomTypeFactory.java:90
↓ 2 callersMethodcreateTimedMemberStateFactory
Creates a TimedMemberStateFactory for a given Hazelcast instance @param instance The instance to associate with the timed member state factory @return
hazelcast/src/main/java/com/hazelcast/instance/impl/NodeExtension.java:394
↓ 2 callersMethodcreateTpcServerBootstrap
()
hazelcast/src/main/java/com/hazelcast/instance/impl/NodeExtension.java:445
↓ 2 callersMethodcreateTransactionContext
(Xid xid)
hazelcast/src/main/java/com/hazelcast/client/impl/proxy/txn/xa/XAResourceProxy.java:94
↓ 2 callersMethodcreateTransactionContext
(Xid xid)
hazelcast/src/main/java/com/hazelcast/transaction/impl/xa/XAResourceImpl.java:113
↓ 2 callersMethodcreateTryPutOperation
(String name, Data dataKey, Data value, long timeout)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/MapOperationProvider.java:46
↓ 2 callersMethodcreateTryRemoveOperation
(String name, Data dataKey, long timeout)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/MapOperationProvider.java:56
↓ 2 callersMethodcreateTxnDeleteOperation
(String name, Data dataKey, long version)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/MapOperationProvider.java:110
↓ 2 callersMethodcreateTxnFn
()
hazelcast/src/main/java/com/hazelcast/jet/impl/processor/TwoPhaseSnapshotCommitUtility.java:113
↓ 2 callersMethodcreateValue
()
hazelcast/src/test/java/com/hazelcast/replicatedmap/standalone/SimpleReplicatedMapTest.java:148
↓ 2 callersMethodcreateValue
()
hazelcast/src/test/java/com/hazelcast/map/standalone/SimpleMapTest.java:151
↓ 2 callersMethodcreateVersion
(byte major, byte minor)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/CustomTypeFactory.java:406
↓ 2 callersMethodcreateVisitor
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/DagBuildContextImpl.java:104
↓ 2 callersMethodcreateWithCLIJetProxy
(@Nonnull HazelcastInstance instance)
hazelcast/src/main/java/com/hazelcast/instance/impl/BootstrappedInstanceProxyFactory.java:31
↓ 2 callersMethodcreateWriter
(Path file)
hazelcast/src/main/java/com/hazelcast/jet/impl/connector/WriteFileP.java:293
↓ 2 callersMethodcreateYamlMapping
()
hazelcast/src/test/java/com/hazelcast/internal/yaml/YamlToJsonConverterTest.java:97
↓ 2 callersMethodcredentialsFailed
Triggered after an {@link #attemptingToConnectToAddress(Address)} event if the member doesn't accept the credentials presented by the client.
hazelcast/src/main/java/com/hazelcast/client/impl/management/ClientConnectionProcessListener.java:95
↓ 2 callersMethodcurrentSnapshotId
()
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/SnapshotContext.java:165
↓ 2 callersMethodcurrentTimeFormatted
()
hazelcast/src/main/java/com/hazelcast/jet/impl/connector/WriteFileP.java:305
↓ 2 callersMethodcurrentZone
()
hazelcast/src/test/java/com/hazelcast/gcp/GcpMetadataApiTest.java:63
↓ 2 callersMethodcustomizeJobConfig
(JobConfig config)
hazelcast/src/test/java/com/hazelcast/jet/core/IndeterminateSnapshotTest.java:269
↓ 2 callersMethodcutOffPointZero
(String string)
hazelcast/src/main/java/com/hazelcast/internal/json/Json.java:323
↓ 2 callersMethodcycle
Increment the `value`. If equal to `max`, set to 0. Returns the new value.
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/processors/StreamToStreamJoinP.java:422
↓ 2 callersMethoddataConnectionNameWithoutSchema
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/parse/SqlCreateMapping.java:103
↓ 2 callersMethoddataConnectionNames
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/schema/DataConnectionStorage.java:57
↓ 2 callersMethoddataConnectionType
()
hazelcast/src/test/java/com/hazelcast/test/jdbc/TestDatabaseProvider.java:88
↓ 2 callersMethoddataPersistenceConfig
()
hazelcast/src/test/java/com/hazelcast/internal/dynamicconfig/AbstractDynamicConfigGeneratorTest.java:1278
↓ 2 callersMethoddataSourceSupplier
Sets the supplier of {@link javax.sql.DataSource} or {@link javax.sql.XADataSource}. One dataSource instance will be created on each member. For exact
hazelcast/src/main/java/com/hazelcast/jet/pipeline/JdbcSinkBuilder.java:143
↓ 2 callersMethoddateToTimestamp
Convert DATE to TIMESTAMP as per ANSI standard. @param date Date. @return Timestamp with the same date at midnight.
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/converter/AbstractTemporalConverter.java:45
↓ 2 callersMethoddealWithThroughputExceeded
(@Nonnull String message)
extensions/kinesis/src/main/java/com/hazelcast/jet/kinesis/impl/sink/KinesisSinkP.java:267
↓ 2 callersMethoddebugInfo
(Object deserialized, Data serialized)
hazelcast/src/main/java/com/hazelcast/internal/journal/DeserializingEntry.java:73
↓ 2 callersMethoddecode
(ClientMessage.ForwardFrameIterator iterator)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/custom/MemoryTierConfigCodec.java:49
↓ 2 callersMethoddecode
(ClientMessage.ForwardFrameIterator iterator)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/custom/CPMemberCodec.java:57
↓ 2 callersMethoddecode
(ClientMessage.ForwardFrameIterator iterator)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/custom/AddressCodec.java:55
↓ 2 callersMethoddecode
(ClientMessage.ForwardFrameIterator iterator)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/custom/CapacityCodec.java:55
↓ 2 callersMethoddecode
(ClientMessage.ForwardFrameIterator iterator)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/custom/MigrationStateCodec.java:59
↓ 2 callersMethoddecode
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/ErrorsCodec.java:49
↓ 2 callersMethoddecode
(ClientMessage.ForwardFrameIterator iterator)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/EntryListUUIDListIntegerCodec.java:47
← previousnext →17,401–17,500 of 147,315, ranked by callers