MCPcopy Create free account

hub / github.com/airbnb/SpinalTap / functions

Functions687 in github.com/airbnb/SpinalTap

⨍ Functions 687◇ Types & classes 189
↓ 1 callersMethodwithLargeMessage
(final boolean largeMessageEnabled)
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/destination/DestinationBuilder.java:83
↓ 1 callersMethodwithName
(@NonNull final String name)
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/destination/DestinationBuilder.java:61
↓ 1 callersMethodwithNextPosition
(long nextPosition)
spinaltap-model/src/main/java/com/airbnb/spinaltap/mysql/BinlogFilePos.java:150
↓ 1 callersMethodwithPosition
(long position)
spinaltap-model/src/main/java/com/airbnb/spinaltap/mysql/BinlogFilePos.java:145
↓ 1 callersMethodwithProducerConfig
(final Map<String, Object> producerConfig)
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/destination/DestinationBuilder.java:78
↓ 1 callersMethodwithServerUUID
(String serverUUID)
spinaltap-model/src/main/java/com/airbnb/spinaltap/mysql/BinlogFilePos.java:160
↓ 1 callersMethodwithTopicNamePrefix
(@NonNull final String topicNamePrefix)
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/destination/DestinationBuilder.java:46
↓ 1 callersMethodwithValidation
()
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/destination/DestinationBuilder.java:73
MethodAbstractDataStoreSource
( String name, SourceMetrics metrics, Mapper<E, List<? extends Mutation<?>>> mutationMapper,
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/source/AbstractDataStoreSource.java:28
MethodAbstractMysqlConfiguration
( @NonNull final String name, final String type, final String instanceTag, @NonNull fi
spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/config/AbstractMysqlConfiguration.java:15
MethodAttributeValueDeserializationException
( final String attributeName, final String tableName, final Throwable cause)
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/exception/AttributeValueDeserializationException.java:17
MethodBinaryLogConnectorSource
( @NonNull final String name, @NonNull final MysqlConfiguration config, final TlsConfigurati
spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/binlog_connector/BinaryLogConnectorSource.java:46
MethodBinlogEvent
(long tableId, long serverId, long timestamp, BinlogFilePos binlogFilePos)
spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/event/BinlogEvent.java:20
MethodBinlogFilePos
(long fileNumber)
spinaltap-model/src/main/java/com/airbnb/spinaltap/mysql/BinlogFilePos.java:42
MethodBufferedDestination
( @NonNull final String name, @Min(1) final int bufferSize, @NonNull final Destination desti
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/destination/BufferedDestination.java:43
MethodColumnDeserializationException
( final String columnName, final String tableName, final Throwable cause)
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/exception/ColumnDeserializationException.java:16
MethodDeleteEvent
( long tableId, long serverId, long timestamp, BinlogFilePos filePos, List<Seria
spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/event/DeleteEvent.java:16
MethodDeleteMutationMapper
(final String sourceId)
spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/mutation/mapper/DeleteMutationMapper.java:18
MethodDeleteMutationMapper
( @NonNull final DataSource dataSource, @NonNull final TableCache tableCache, @NonNull final
spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/event/mapper/DeleteMutationMapper.java:29
MethodDestinationException
(String message, Throwable cause)
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/exception/DestinationException.java:10
MethodDestinationMetrics
( String sourceName, String sourceType, TaggedMetricRegistry metricRegistry)
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/destination/DestinationMetrics.java:50
MethodDestinationPool
( @NonNull final KeyProvider<Mutation<?>, String> keyProvider, @NonNull final List<Destination> de
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/destination/DestinationPool.java:47
MethodDropwizardCounter
(com.codahale.metrics.Counter... counters)
spinaltap-common/src/main/java/com/airbnb/common/metrics/DropwizardCounter.java:15
MethodDropwizardHistogram
(com.codahale.metrics.Histogram... histograms)
spinaltap-common/src/main/java/com/airbnb/common/metrics/DropwizardHistogram.java:15
MethodEntityDeserializationException
(String message, Throwable cause)
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/exception/EntityDeserializationException.java:10
MethodGTIDEvent
(long serverId, long timestamp, BinlogFilePos filePos, String gtid)
spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/event/GTIDEvent.java:14
MethodGtidSet
(String gtidSetString)
spinaltap-model/src/main/java/com/airbnb/spinaltap/mysql/GtidSet.java:33
MethodInsertMutationMapper
(String sourceId)
spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/mutation/mapper/InsertMutationMapper.java:18
MethodInsertMutationMapper
( @NonNull final DataSource dataSource, @NonNull final TableCache tableCache, @NonNull final
spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/event/mapper/InsertMutationMapper.java:29
MethodInvalidBinlogPositionException
(final String message)
spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/exception/InvalidBinlogPositionException.java:16
MethodKafkaDestination
()
spinaltap-kafka/src/test/java/com/airbnb/spinaltap/kafka/KafkaDestinationTest.java:109
MethodKafkaDestination
( final String prefix, final KafkaProducerConfiguration producerConfig, final BatchMapper<Mu
spinaltap-kafka/src/main/java/com/airbnb/spinaltap/kafka/KafkaDestination.java:45
MethodMySQLDBNamePrefixAdder
(TokenStream tokens)
spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/schema/MysqlSchemaDatabase.java:185
MethodMysqlConfiguration
( @NonNull final String name, @NonNull final List<String> canonicalTableNames, @NonNull fina
spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/config/MysqlConfiguration.java:49
MethodMysqlDeleteMutation
(MysqlMutationMetadata metadata, Row row)
spinaltap-model/src/main/java/com/airbnb/spinaltap/mysql/mutation/MysqlDeleteMutation.java:12
MethodMysqlDestinationMetrics
( @NonNull final String sourceName, @NonNull final TaggedMetricRegistry metricRegistry)
spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/MysqlDestinationMetrics.java:25
MethodMysqlInsertMutation
(MysqlMutationMetadata metadata, Row row)
spinaltap-model/src/main/java/com/airbnb/spinaltap/mysql/mutation/MysqlInsertMutation.java:11
MethodMysqlMutation
(MysqlMutationMetadata metadata, Mutation.Type type, Row row)
spinaltap-model/src/main/java/com/airbnb/spinaltap/mysql/mutation/MysqlMutation.java:15
MethodMysqlMutationMetadata
( DataSource dataSource, BinlogFilePos filePos, Table table, long serverId, long
spinaltap-model/src/main/java/com/airbnb/spinaltap/mysql/mutation/MysqlMutationMetadata.java:33
MethodMysqlPipeFactory
( @NonNull final String mysqlUser, @NonNull final String mysqlPassword, @Min(0) final long m
spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/MysqlPipeFactory.java:51
MethodMysqlSchemaManagerFactory
( final String username, final String password, final MysqlSchemaStoreConfiguration configur
spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/schema/MysqlSchemaManagerFactory.java:21
MethodMysqlSource
( @NonNull final String name, @NonNull final DataSource dataSource, @NonNull final Set<Strin
spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/MysqlSource.java:89
MethodMysqlSourceMetrics
(final String sourceName, final TaggedMetricRegistry metricRegistry)
spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/MysqlSourceMetrics.java:70
MethodMysqlSourceState
( final long lastTimestamp, final long lastOffset, final long currentLeaderEpoch, fina
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/source/MysqlSourceState.java:38
MethodMysqlUpdateMutation
( final MysqlMutationMetadata metadata, final Row previousRow, final Row row)
spinaltap-model/src/main/java/com/airbnb/spinaltap/mysql/mutation/MysqlUpdateMutation.java:24
MethodPipeMetrics
(String sourceName, TaggedMetricRegistry metricRegistry)
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/pipe/PipeMetrics.java:21
MethodQueryEvent
( long serverId, long timestamp, BinlogFilePos filePos, String database, String sql)
spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/event/QueryEvent.java:15
MethodSourceConfiguration
( @NonNull final String name, final String type, final String instanceTag, @NonNull fi
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/config/SourceConfiguration.java:23
MethodSourceException
(String message, Throwable cause)
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/exception/SourceException.java:10
MethodSourceMetrics
( String sourceName, String sourceType, TaggedMetricRegistry taggedMetricRegistry)
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/source/SourceMetrics.java:41
MethodSpinalTapMetrics
(TaggedMetricRegistry metricRegistry)
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/metrics/SpinalTapMetrics.java:44
MethodSpinaltapException
(String message)
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/exception/SpinaltapException.java:10
MethodStartEvent
(long serverId, long timestamp, BinlogFilePos filePos)
spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/event/StartEvent.java:10
MethodStateHistory
( @NonNull final String sourceName, @NonNull final Repository<Collection<S>> repository, @No
spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/StateHistory.java:47
MethodTable
( long id, String name, String database, List<ColumnMetadata> columnMetadatas, L
spinaltap-model/src/main/java/com/airbnb/spinaltap/mysql/mutation/schema/Table.java:43
MethodTableMapEvent
( long tableId, long serverId, long timestamp, BinlogFilePos filePos, String dat
spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/event/TableMapEvent.java:19
MethodTaggedMetricRegistry
()
spinaltap-common/src/main/java/com/airbnb/common/metrics/TaggedMetricRegistry.java:33
MethodTaggedMetricRegistryFactory
()
spinaltap-common/src/main/java/com/airbnb/common/metrics/TaggedMetricRegistryFactory.java:24
MethodTestDestination
()
spinaltap-common/src/test/java/com/airbnb/spinaltap/common/destination/AbstractDestinationTest.java:109
MethodTestRepository
(MysqlSourceState... states)
spinaltap-mysql/src/test/java/com/airbnb/spinaltap/mysql/StateHistoryTest.java:137
MethodTestSource
()
spinaltap-mysql/src/test/java/com/airbnb/spinaltap/mysql/MysqlSourceTest.java:242
MethodTestSource
(SourceMetrics metrics)
spinaltap-common/src/test/java/com/airbnb/spinaltap/common/source/AbstractSourceTest.java:138
MethodTransaction
(long timestamp, long offset, BinlogFilePos position)
spinaltap-model/src/main/java/com/airbnb/spinaltap/mysql/Transaction.java:19
MethodUUIDSet
(String uuid, List<Interval> intervals)
spinaltap-model/src/main/java/com/airbnb/spinaltap/mysql/GtidSet.java:91
MethodUpdateEvent
( long tableId, long serverId, long timestamp, BinlogFilePos filePos, List<Map.E
spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/event/UpdateEvent.java:17
MethodUpdateMutationMapper
(final String sourceId)
spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/mutation/mapper/UpdateMutationMapper.java:18
MethodUpdateMutationMapper
( @NonNull final DataSource dataSource, @NonNull final TableCache tableCache, @NonNull final
spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/event/mapper/UpdateMutationMapper.java:34
MethodWriteEvent
( long tableId, long serverId, long timestamp, BinlogFilePos filePos, List<Seria
spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/event/WriteEvent.java:16
MethodXidEvent
(long serverId, long timestamp, BinlogFilePos filePos, long xid)
spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/event/XidEvent.java:14
MethodaddListener
(@NonNull final Listener listener)
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/destination/ListenableDestination.java:20
MethodaddListener
(@NonNull final Listener listener)
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/source/ListenableSource.java:20
MethodaddPipe
Registers a pipe for the given resource. @param name the resource name @param pipe the pipe
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/pipe/PipeManager.java:46
Methodanswer
(InvocationOnMock invocation)
spinaltap-mysql/src/test/java/com/airbnb/spinaltap/mysql/StateRepositoryTest.java:37
Methodapply
(@NonNull final BinlogEvent event)
spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/event/filter/DuplicateFilter.java:25
Methodapply
(@NonNull final BinlogEvent event)
spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/event/filter/EventTypeFilter.java:39
Methodapply
(@NonNull final BinlogEvent event)
spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/event/filter/TableFilter.java:25
Methodapply
Applies the mapping function on the list of objects. @param objects the objects to map. @return the mapped objects.
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/util/BatchMapper.java:23
Methodapply
(T currentValue, T newValue)
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/util/Repository.java:50
Methodapply
Applies the joiner on a pair of objects @param first the first object to join @param second the second object to join @return the resulting joined ob
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/util/Joiner.java:25
Methodapply
Applies the filters on the object. @param object the object to filter. @return {@code true} if all filter conditions pass, {@code false} otherwise.
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/util/ChainedFilter.java:33
Methodapply
Applies the joiner on a triplet of objects. @param first the first object to join. @param second the second object to join. @param third the third ob
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/util/ThreeWayJoiner.java:27
Methodarchive
()
spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/schema/MysqlSchemaStore.java:234
Methodarchive
()
spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/schema/MysqlSchemaManager.java:240
Methodbuild
()
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/util/ClassBasedMapper.java:42
Methodcheckpoint
(Mutation<?> mutation)
spinaltap-common/src/test/java/com/airbnb/spinaltap/common/source/ListenableSourceTest.java:63
Methodcheckpoint
()
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/pipe/PipeMetrics.java:45
Methodcheckpoint
()
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/source/SourceMetrics.java:70
Methodcheckpoint
(Mutation<?> mutation)
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/source/AbstractSource.java:84
Methodclear
Clears the state history
spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/StateHistory.java:103
Methodclear
Clears the cache by invalidating all entries.
spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/TableCache.java:70
Methodclear
()
spinaltap-common/src/test/java/com/airbnb/spinaltap/common/destination/ListenableDestinationTest.java:62
Methodclear
()
spinaltap-common/src/test/java/com/airbnb/spinaltap/common/destination/DestinationPoolTest.java:170
Methodclear
()
spinaltap-common/src/test/java/com/airbnb/spinaltap/common/source/ListenableSourceTest.java:60
Methodclear
()
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/destination/DestinationPool.java:126
Methodclear
()
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/destination/AbstractDestination.java:113
Methodclear
()
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/destination/DestinationMetrics.java:146
Methodclear
()
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/destination/BufferedDestination.java:193
Methodclear
()
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/metrics/SpinalTapMetrics.java:143
Methodclear
()
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/source/SourceMetrics.java:112
Methodclear
()
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/source/AbstractSource.java:102
← previousnext →301–400 of 687, ranked by callers