MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

↓ 3 callersMethodcreateGetOperation
(Data key, ExpiryPolicy policy)
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheOperationProvider.java:41
↓ 3 callersMethodcreateHazelcastInstance
(Config config)
hazelcast/src/main/java/com/hazelcast/osgi/impl/HazelcastOSGiServiceImpl.java:99
↓ 3 callersMethodcreateInboundHandlers
(EndpointQualifier qualifier, ServerConnection connection)
hazelcast/src/main/java/com/hazelcast/internal/server/ServerContext.java:122
↓ 3 callersMethodcreateIndexFilterForSingleRange
(Range<?> range, QueryDataType hazelcastType)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/index/IndexResolver.java:735
↓ 3 callersMethodcreateIndexesFromRecordedDefinitions
Creates indexes according to the index definitions stored inside this indexes.
hazelcast/src/main/java/com/hazelcast/query/impl/IndexRegistry.java:235
↓ 3 callersMethodcreateInnerDTO
()
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/CompactTestUtil.java:121
↓ 3 callersMethodcreateInput
(Data data, InternalSerializationService service,
hazelcast/src/main/java/com/hazelcast/internal/serialization/InputOutputFactory.java:26
↓ 3 callersMethodcreateInstanceAndGetMap
()
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/PostProcessingMapStoreTest.java:179
↓ 3 callersMethodcreateInstances
(int nodeCount)
hazelcast/src/test/java/com/hazelcast/partition/AbstractPartitionLostListenerTest.java:121
↓ 3 callersMethodcreateIterator
(Connection connection)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/jdbc/join/JoinPredicateScanResultSetIteratorTest.java:122
↓ 3 callersMethodcreateJobConfigWithEnabledMetrics
(String jobName)
hazelcast/src/test/java/com/hazelcast/jet/core/metrics/JobLifecycleMetricsTest.java:299
↓ 3 callersMethodcreateJoiner
(Node node)
hazelcast/src/main/java/com/hazelcast/instance/impl/NodeContext.java:38
↓ 3 callersMethodcreateJsonValue
(String type, int innerValue)
hazelcast/src/test/java/com/hazelcast/json/internal/JsonMetadataCreationMigrationTest.java:131
↓ 3 callersMethodcreateKey
(KeyType keyType, int i)
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/AbstractNearCachePreloaderTest.java:419
↓ 3 callersMethodcreateLazyEvictableEntryView
Returns an entry-view instance populated with default values of fields.
hazelcast/src/test/java/com/hazelcast/map/impl/recordstore/LazyEvictableEntryViewTest.java:66
↓ 3 callersMethodcreateListener
(boolean lossTolerant, Consumer<Message<T>> messageLi
hazelcast/src/test/java/com/hazelcast/client/topic/ClientReliableTopicOnClusterRestartTest.java:194
↓ 3 callersMethodcreateLocalMembersViewMetadata
()
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/MembershipManager.java:607
↓ 3 callersMethodcreateLoggerFactory
(String preferredType)
hazelcast/src/main/java/com/hazelcast/logging/Logger.java:229
↓ 3 callersMethodcreateMainPortable
()
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/portable/integration/AbstractGenericRecordIntegrationTest.java:304
↓ 3 callersMethodcreateMapSizeOperationFactory
(String name)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/MapOperationProvider.java:170
↓ 3 callersMethodcreateMapStoreSingleColumnAsValue
()
extensions/mapstore/src/test/java/com/hazelcast/mapstore/GenericMapStoreBasicIT.java:507
↓ 3 callersMethodcreateMapping
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlTestSupportTest.java:99
↓ 3 callersMethodcreateMembers
()
hazelcast/src/test/java/com/hazelcast/internal/partition/membergroup/MemberGroupFactoryTest.java:218
↓ 3 callersMethodcreateMembersWithNoMetadata
()
hazelcast/src/test/java/com/hazelcast/internal/partition/membergroup/MemberGroupFactoryTest.java:73
↓ 3 callersMethodcreateMessageTask
(ClientMessage clientMessage)
hazelcast/src/test/java/com/hazelcast/client/impl/protocol/task/dynamicconfig/AddMapConfigMessageTaskTest.java:178
↓ 3 callersMethodcreateMessageTask
(ClientMessage clientMessage)
hazelcast/src/test/java/com/hazelcast/client/impl/protocol/task/management/SetDiagnosticsConfigMessageTaskTest.java:46
↓ 3 callersMethodcreateMockHazelcastProperties
(HazelcastProperty property, String stringValue)
hazelcast/src/test/java/com/hazelcast/query/impl/predicates/QueryOptimizerFactoryTest.java:59
↓ 3 callersMethodcreateNamedConfig
(String name, String... attributes)
hazelcast/src/test/java/com/hazelcast/map/impl/query/IndexCreateTest.java:224
↓ 3 callersMethodcreateNearCacheContext
Creates the {@link NearCacheTestContext} with only a Near Cache instance used by the Near Cache tests. @param <K> key type of the created {@link com.
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/AbstractNearCachePreloaderTest.java:137
↓ 3 callersMethodcreateNewConfig
(String mapName)
hazelcast/src/test/java/com/hazelcast/client/map/ClientMapLoadAllTest.java:154
↓ 3 callersMethodcreateNewPortableInstance
(int factoryId, int classId)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/portable/PortableSerializer.java:110
↓ 3 callersMethodcreateNode
(TestHazelcastInstanceFactory instanceFactory)
hazelcast/src/test/java/com/hazelcast/map/MapIndexBackupTest.java:101
↓ 3 callersMethodcreateNode
(TestHazelcastInstanceFactory instanceFactory)
hazelcast/src/test/java/com/hazelcast/map/MapIndexLifecycleTest.java:292
↓ 3 callersMethodcreateNonFragmentedReplicationOperations
non-fragmented service replication operation preparation is always executed on partition operation thread
hazelcast/src/main/java/com/hazelcast/internal/partition/operation/AbstractPartitionOperation.java:68
↓ 3 callersMethodcreateNullableType
(RelDataTypeFactory typeFactory, RelDataType type)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/validate/types/HazelcastTypeUtils.java:178
↓ 3 callersMethodcreateOperation
(boolean fail)
hazelcast/src/test/java/com/hazelcast/transaction/impl/MockTransactionLogRecord.java:85
↓ 3 callersMethodcreateOutboundHandlers
(EndpointQualifier qualifier, ServerConnection connection)
hazelcast/src/main/java/com/hazelcast/internal/server/ServerContext.java:124
↓ 3 callersMethodcreateOutput
(int size, InternalSerializationService service)
hazelcast/src/main/java/com/hazelcast/internal/serialization/InputOutputFactory.java:39
↓ 3 callersMethodcreatePartitionRunner
Creates an OperationRunner for a given partition. This OperationRunner will only execute generic operations and operations for that given partition.
hazelcast/src/main/java/com/hazelcast/spi/impl/operationexecutor/OperationRunnerFactory.java:35
↓ 3 callersMethodcreatePartitionState
(int partitionId, PartitionReplica... replicas)
hazelcast/src/test/java/com/hazelcast/internal/partition/PartitionRuntimeStateTest.java:90
↓ 3 callersMethodcreatePartitionState
Creates the current partition runtime state. May return {@code null} if the node should fetch the most recent partition table (e.g. this node is a new
hazelcast/src/main/java/com/hazelcast/internal/partition/InternalPartitionService.java:114
↓ 3 callersMethodcreatePausedMigrationCluster
(final TestHazelcastInstanceFactory factory, @Nulla
hazelcast/src/test/java/com/hazelcast/partition/PartitionMigrationListenerTest.java:456
↓ 3 callersMethodcreatePlainSourceBuilder
()
hazelcast/src/test/java/com/hazelcast/jet/pipeline/StreamSourceStageTest.java:82
↓ 3 callersMethodcreatePredicate
(String sql)
hazelcast/src/main/java/com/hazelcast/query/impl/predicates/SqlPredicate.java:139
↓ 3 callersMethodcreatePutIfAbsentOperation
(String name, Data key, Data value, long ttl, long maxIdle)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/MapOperationProvider.java:50
↓ 3 callersMethodcreatePutOperation
(String name, Data key, Data value, long ttl, long maxIdle)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/MapOperationProvider.java:44
↓ 3 callersMethodcreatePutTransientOperation
(String name, Data key, Data value, long ttl, long maxIdle)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/MapOperationProvider.java:52
↓ 3 callersMethodcreateQueryOperation
(Query query)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/MapOperationProvider.java:91
↓ 3 callersMethodcreateQueryPartitionOperation
(Query query)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/MapOperationProvider.java:93
↓ 3 callersMethodcreateRecordStore
(MapContainer mapContainer, int partitionId, MapKeyLoader keyLoader)
hazelcast/src/main/java/com/hazelcast/map/impl/MapServiceContext.java:162
↓ 3 callersMethodcreateRemoteClient
Creates a remote client using {@code dataConnectionName} or {@code clientXml} in order, depending on availability.
hazelcast/src/main/java/com/hazelcast/jet/impl/util/Util.java:870
↓ 3 callersMethodcreateRemoveAllOperationFactory
(Set<Data> keySet, Integer completionId)
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheOperationProvider.java:88
↓ 3 callersMethodcreateRemoveOperation
(String name, Data key)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/MapOperationProvider.java:64
↓ 3 callersMethodcreateReplicationOperations
(PartitionReplicationEvent event, boolean nonFra
hazelcast/src/main/java/com/hazelcast/internal/partition/operation/AbstractPartitionOperation.java:83
↓ 3 callersMethodcreateResourcesJarFile
(File jarFile)
hazelcast/src/test/java/com/hazelcast/test/JarUtil.java:37
↓ 3 callersMethodcreateResponseAssertTask
(final String message, final TextProtocolClient client, final String expectedSubstring)
hazelcast/src/test/java/com/hazelcast/internal/nio/ascii/AbstractTextProtocolsTestBase.java:39
↓ 3 callersMethodcreateSSLContext
(String ksFile, String ksType, char[] ksPass, String tsFile, St
extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/dataconnection/SslConf.java:144
↓ 3 callersMethodcreateSchemaQuery
(String schemaName)
hazelcast/src/test/java/com/hazelcast/test/jdbc/JdbcObjectProvider.java:69
↓ 3 callersMethodcreateSchemaService
Creates and returns a schema service for the member side that is able to replicate schemas across the cluster. @return the member schema service
hazelcast/src/main/java/com/hazelcast/instance/impl/NodeExtension.java:228
↓ 3 callersMethodcreateSchemaWithData
(int schemaSuffix)
extensions/cdc-postgres/src/test/java/com/hazelcast/jet/cdc/postgres/PostgresCdcWhiteBlackListIntegrationTest.java:281
↓ 3 callersMethodcreateServerSocketChannel
Creates and binds {@code ServerSocketChannel} using {@code bindAddress} and {@code initialPort}. <p> If the {@code initialPort} is in use, then an ava
hazelcast/src/main/java/com/hazelcast/instance/impl/ServerSocketHelper.java:66
↓ 3 callersMethodcreateServiceConfig
(int backupCount)
hazelcast/src/test/java/com/hazelcast/internal/partition/service/TestMigrationAwareService.java:37
↓ 3 callersMethodcreateSetExpiryPolicyOperation
(List<Data> keys, Data expiryPolicy)
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheOperationProvider.java:80
↓ 3 callersMethodcreateSetOperation
(String name, Data dataKey, Data value, long ttl, long maxIdle)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/MapOperationProvider.java:48
↓ 3 callersMethodcreateSimpleMap
(K key, V value)
hazelcast/src/test/java/com/hazelcast/client/impl/protocol/task/AuthenticationKeyValuePairConstantsTest.java:201
↓ 3 callersMethodcreateSingleLiteMember
()
hazelcast/src/test/java/com/hazelcast/replicatedmap/ReplicatedMapLiteMemberTest.java:103
↓ 3 callersMethodcreateSnapshot
(int memberListVersion, Collection<MemberInfo> memberInfos, UUID clusterUuid)
hazelcast/src/main/java/com/hazelcast/client/impl/spi/impl/ClientClusterServiceImpl.java:254
↓ 3 callersMethodcreateStoreFile
(int keyCount, KeyType keyType)
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/AbstractNearCachePreloaderTest.java:233
↓ 3 callersMethodcreateTable
(String connectionUrl, String tableName)
extensions/kafka-connect/src/test/java/com/hazelcast/jet/kafka/connect/KafkaConnectJdbcIT.java:420
↓ 3 callersMethodcreateTableWithData
()
extensions/cdc-mysql/src/test/java/com/hazelcast/jet/cdc/mysql/MySqlCdcListenBeforeExistIntegrationTest.java:154
↓ 3 callersMethodcreateTableWithData
(String schema, String table)
extensions/cdc-postgres/src/test/java/com/hazelcast/jet/cdc/postgres/PostgresCdcListenBeforeExistsIntegrationTest.java:159
↓ 3 callersMethodcreateTaskRunner
()
extensions/kafka-connect/src/main/java/com/hazelcast/jet/kafka/connect/impl/SourceConnectorWrapper.java:188
↓ 3 callersMethodcreateTimestampedSourceBuilder
()
hazelcast/src/test/java/com/hazelcast/jet/pipeline/StreamSourceStageTest.java:70
↓ 3 callersMethodcreateTransactionalObject
(String name, Transaction transaction)
hazelcast/src/main/java/com/hazelcast/internal/services/TransactionalService.java:31
↓ 3 callersMethodcreateType
(SqlTypeName typeName)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/validate/types/HazelcastTypeFactory.java:129
↓ 3 callersMethodcreateUnitUnderTest
(Properties properties, HazelcastInstance instance,
extensions/mapstore/src/test/java/com/hazelcast/mapstore/GenericMapLoaderTest.java:795
↓ 3 callersMethodcreateValue
()
hazelcast/src/test/java/com/hazelcast/map/standalone/SimpleFunctionalMapTest.java:122
↓ 3 callersMethodcreationTime
Returns the timestamp of when the session was created
hazelcast/src/main/java/com/hazelcast/cp/session/CPSession.java:87
↓ 3 callersMethodcredentialsEc2
()
hazelcast/src/test/java/com/hazelcast/aws/AwsMetadataApiTest.java:196
↓ 3 callersMethodcurrent
()
hazelcast/src/main/java/com/hazelcast/internal/partition/operation/ServiceNamespacesContext.java:115
↓ 3 callersMethodcurrentThreadId
()
hazelcast/src/main/java/com/hazelcast/client/impl/proxy/txn/xa/XAResourceProxy.java:233
↓ 3 callersMethodcurrentThreadId
()
hazelcast/src/main/java/com/hazelcast/transaction/impl/xa/XAResourceImpl.java:316
↓ 3 callersMethodcurrentTimestamp
(Clock clock)
hazelcast/src/main/java/com/hazelcast/aws/AwsRequestUtils.java:40
↓ 3 callersMethodcurrentZone
()
hazelcast/src/main/java/com/hazelcast/gcp/GcpMetadataApi.java:52
↓ 3 callersMethoddataConnectionName
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/kafka/KafkaTable.java:81
↓ 3 callersMethoddatestamp
(String timestamp)
hazelcast/src/main/java/com/hazelcast/aws/AwsRequestSigner.java:161
↓ 3 callersMethoddeRegisterInvocation
remove invocation @param callId invocation id
hazelcast/src/main/java/com/hazelcast/client/impl/spi/impl/ClientInvocationServiceInternal.java:63
↓ 3 callersMethoddebeziumJson
Creates a CDC source that streams change data from a Debezium-supported database to a Hazelcast Jet pipeline. <p> Differs from the {@link #debezium(St
extensions/cdc-debezium/src/main/java/com/hazelcast/jet/cdc/DebeziumCdcSources.java:105
↓ 3 callersMethoddecode
(ClientMessage.ForwardFrameIterator iterator)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/custom/DataPersistenceConfigCodec.java:55
↓ 3 callersMethoddecode
(ClientMessage.ForwardFrameIterator iterator)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/custom/PagingPredicateHolderCodec.java:63
↓ 3 callersMethoddecode
(ClientMessage.ForwardFrameIterator iterator)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/custom/XidCodec.java:56
↓ 3 callersMethoddecode
(ClientMessage.ForwardFrameIterator iterator)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/custom/VectorDocumentCodec.java:50
↓ 3 callersMethoddecode
(ClientMessage.ForwardFrameIterator iterator)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/custom/EvictionConfigHolderCodec.java:58
↓ 3 callersMethoddecodeFloat
(byte[] buffer, int pos)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/FixedSizeTypesCodec.java:155
↓ 3 callersMethoddecrementLatchAndHandle
(int count)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/InvokeOnPartitions.java:108
↓ 3 callersMethoddecrypt
Decrypts given encrypted variable. @param encryptedStr the encrypted value @return the decrypted value @throws Exception in case of any exceptional c
hazelcast/src/main/java/com/hazelcast/config/replacer/AbstractPbeReplacer.java:141
↓ 3 callersMethoddeductFn
()
hazelcast/src/main/java/com/hazelcast/jet/impl/aggregate/AggregateOperationImpl.java:94
↓ 3 callersMethoddefine
(String name, byte[] bytecode)
hazelcast/src/main/java/com/hazelcast/internal/usercodedeployment/impl/ClassSource.java:51
↓ 3 callersMethoddelay
(long ms)
hazelcast/src/test/java/com/hazelcast/jet/impl/execution/WatermarkCoalescer_IntegrationTest.java:169
↓ 3 callersMethoddelete
(File file)
hazelcast/src/test/java/com/hazelcast/jet/impl/JobRepositoryTest.java:224
← previousnext →13,801–13,900 of 147,315, ranked by callers