MCPcopy Create free account

hub / github.com/airbnb/SpinalTap / functions

Functions687 in github.com/airbnb/SpinalTap

⨍ Functions 687◇ Types & classes 189
MethodonStart
Action to perform after the {@link Destination} has started.
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/destination/Destination.java:64
MethodonStart
()
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/destination/DestinationBuilder.java:135
MethodonStart
()
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/source/AbstractSource.java:164
Methodopen
()
spinaltap-common/src/test/java/com/airbnb/spinaltap/common/destination/DestinationPoolTest.java:160
Methodopen
()
spinaltap-common/src/test/java/com/airbnb/spinaltap/common/source/ListenableSourceTest.java:54
Methodopen
()
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/pipe/PipeMetrics.java:29
Methodopen
()
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/destination/AbstractDestination.java:100
Methodopen
()
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/destination/ListenableDestination.java:42
Methodopen
()
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/destination/BufferedDestination.java:149
Methodopen
()
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/source/AbstractSource.java:40
MethodoutOfOrder
(Mutation<?> mutation)
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/destination/DestinationMetrics.java:142
MethodoutOfOrder
(SourceEvent event)
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/source/SourceMetrics.java:104
MethodoverridingProps
()
spinaltap-kafka/src/test/java/com/airbnb/spinaltap/kafka/KafkaDestinationTest.java:76
Methodpublish
(List<Mutation<?>> MUTATIONS)
spinaltap-common/src/test/java/com/airbnb/spinaltap/common/destination/AbstractDestinationTest.java:118
MethodpublishOutOfOrder
(String tpName)
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/destination/DestinationMetrics.java:108
MethodpublishRecordTooLarge
(String tpName)
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/destination/DestinationMetrics.java:115
MethodregisterAll
(MetricSet metrics)
spinaltap-common/src/main/java/com/airbnb/common/metrics/TaggedMetricRegistry.java:131
Methodremove
()
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/util/ZookeeperRepository.java:56
Methodremove
(String name)
spinaltap-common/src/main/java/com/airbnb/common/metrics/TaggedMetricRegistry.java:61
MethodremoveListener
Removes a {@link Listener} from the destination.
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/destination/Destination.java:35
MethodremoveListener
(@NonNull final Listener listener)
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/destination/ListenableDestination.java:25
MethodremoveListener
(@NonNull final Listener listener)
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/source/ListenableSource.java:25
Methodreset
()
spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/validator/MutationSchemaValidator.java:47
Methodsend
(List<? extends Mutation<?>> mutations)
spinaltap-common/src/test/java/com/airbnb/spinaltap/common/destination/ListenableDestinationTest.java:51
Methodsend
(List<? extends Mutation<?>> mutations)
spinaltap-common/src/test/java/com/airbnb/spinaltap/common/destination/DestinationPoolTest.java:150
Methodsend
(@NonNull final List<? extends Mutation<?>> mutations)
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/destination/AbstractDestination.java:35
Methodsend
Adds a list of {@link Mutation}s to the buffer, to be sent to the underlying {@link Destination}. This action is blocking, i.e. thread will wait if th
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/destination/BufferedDestination.java:68
Methodset
(Collection<MysqlSourceState> states)
spinaltap-mysql/src/test/java/com/airbnb/spinaltap/mysql/StateHistoryTest.java:151
MethodsetPartitions
(int partitions)
spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/config/MysqlConfiguration.java:119
MethodsetPosition
(@NonNull final BinlogFilePos pos)
spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/binlog_connector/BinaryLogConnectorSource.java:135
MethodsetUp
()
spinaltap-mysql/src/test/java/com/airbnb/spinaltap/mysql/binlog_connector/BinaryLogConnectorEventMapperTest.java:50
MethodsetUp
()
spinaltap-mysql/src/test/java/com/airbnb/spinaltap/mysql/schema/MysqlSchemaManagerTest.java:91
MethodsetUp
()
spinaltap-mysql/src/test/java/com/airbnb/spinaltap/mysql/schema/MysqlSchemaStoreTest.java:120
MethodsetUp
()
spinaltap-mysql/src/test/java/com/airbnb/spinaltap/mysql/event/mapper/MysqlMutationMapperTest.java:88
MethodsetUp
()
spinaltap-kafka/src/test/java/com/airbnb/spinaltap/kafka/KafkaDestinationTest.java:66
MethodsetUp
()
spinaltap-common/src/test/java/com/airbnb/spinaltap/common/pipe/PipeTest.java:24
MethodsetUp
()
spinaltap-common/src/test/java/com/airbnb/spinaltap/common/destination/BufferedDestinationTest.java:33
MethodsetUp
()
spinaltap-common/src/test/java/com/airbnb/spinaltap/common/destination/AbstractDestinationTest.java:39
MethodsetUp
()
spinaltap-common/src/test/java/com/airbnb/spinaltap/common/source/AbstractSourceTest.java:30
MethodsetUp
()
spinaltap-common/src/test/java/com/airbnb/spinaltap/common/validator/MutationOrderValidatorTest.java:24
Methodsize
()
spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/event/UpdateEvent.java:28
Methodsize
()
spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/event/DeleteEvent.java:27
Methodstart
()
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/pipe/PipeMetrics.java:37
Methodstart
Starts all {@link Pipe}s for all managed resources.
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/pipe/PipeManager.java:136
Methodstart
()
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/destination/DestinationMetrics.java:76
Methodstart
()
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/source/AbstractDataStoreSource.java:36
Methodstart
()
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/source/SourceMetrics.java:62
Methodstop
()
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/pipe/PipeMetrics.java:41
Methodstop
()
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/source/AbstractDataStoreSource.java:54
Methodstop
()
spinaltap-common/src/main/java/com/airbnb/spinaltap/common/source/SourceMetrics.java:66
MethodtearDown
()
spinaltap-kafka/src/test/java/com/airbnb/spinaltap/kafka/KafkaDestinationTest.java:71
Methodtest
()
spinaltap-mysql/src/test/java/com/airbnb/spinaltap/mysql/StateHistoryTest.java:27
Methodtest
()
spinaltap-mysql/src/test/java/com/airbnb/spinaltap/mysql/TableCacheTest.java:75
Methodtest
()
spinaltap-common/src/test/java/com/airbnb/spinaltap/common/destination/ListenableDestinationTest.java:21
Methodtest
()
spinaltap-common/src/test/java/com/airbnb/spinaltap/common/source/ListenableSourceTest.java:19
MethodtestAddAndRemoveScalarColumns
()
spinaltap-model/src/test/java/com/airbnb/spinaltap/MutationTest.java:17
MethodtestAddRemovePipe
()
spinaltap-common/src/test/java/com/airbnb/spinaltap/common/pipe/PipeManagerTest.java:20
MethodtestAddSourcePrefixAlterTable
()
spinaltap-mysql/src/test/java/com/airbnb/spinaltap/mysql/schema/MysqlSchemaDatabaseTest.java:113
MethodtestAddSourcePrefixCreateDatabase
()
spinaltap-mysql/src/test/java/com/airbnb/spinaltap/mysql/schema/MysqlSchemaDatabaseTest.java:174
MethodtestAddSourcePrefixCreateIndex
()
spinaltap-mysql/src/test/java/com/airbnb/spinaltap/mysql/schema/MysqlSchemaDatabaseTest.java:205
MethodtestAddSourcePrefixCreateTable
()
spinaltap-mysql/src/test/java/com/airbnb/spinaltap/mysql/schema/MysqlSchemaDatabaseTest.java:21
MethodtestAddSourcePrefixDropDatabase
()
spinaltap-mysql/src/test/java/com/airbnb/spinaltap/mysql/schema/MysqlSchemaDatabaseTest.java:196
MethodtestAddSourcePrefixDropIndex
()
spinaltap-mysql/src/test/java/com/airbnb/spinaltap/mysql/schema/MysqlSchemaDatabaseTest.java:216
MethodtestAddSourcePrefixDropTable
()
spinaltap-mysql/src/test/java/com/airbnb/spinaltap/mysql/schema/MysqlSchemaDatabaseTest.java:157
MethodtestAddSourcePrefixRenameTable
()
spinaltap-mysql/src/test/java/com/airbnb/spinaltap/mysql/schema/MysqlSchemaDatabaseTest.java:139
MethodtestAlterTable
()
spinaltap-mysql/src/test/java/com/airbnb/spinaltap/mysql/schema/MysqlSchemaManagerTest.java:163
MethodtestAsColumnValues
()
spinaltap-model/src/test/java/com/airbnb/spinaltap/mysql/mutation/MysqlUpdateMutationTest.java:19
MethodtestBlockSQLCommentsRemoval
()
spinaltap-mysql/src/test/java/com/airbnb/spinaltap/mysql/schema/MysqlSchemaUtilTest.java:12
MethodtestBuildBufferedDestination
()
spinaltap-common/src/test/java/com/airbnb/spinaltap/common/destination/DestinationBuilderTest.java:33
MethodtestBuildDestinationPool
()
spinaltap-common/src/test/java/com/airbnb/spinaltap/common/destination/DestinationBuilderTest.java:42
MethodtestCheckpoint
()
spinaltap-common/src/test/java/com/airbnb/spinaltap/common/pipe/PipeTest.java:80
MethodtestCollapseIntervals
()
spinaltap-model/src/test/java/com/airbnb/spinaltap/GtidSetTest.java:41
MethodtestCommitCheckpoint
()
spinaltap-mysql/src/test/java/com/airbnb/spinaltap/mysql/MysqlSourceTest.java:197
MethodtestCompare
()
spinaltap-model/src/test/java/com/airbnb/spinaltap/mysql/BinlogFilePosTest.java:15
MethodtestCompareWithGTID
()
spinaltap-model/src/test/java/com/airbnb/spinaltap/mysql/BinlogFilePosTest.java:27
MethodtestCompositePrimaryKey
()
spinaltap-model/src/test/java/com/airbnb/spinaltap/mysql/schema/RowTest.java:85
MethodtestCompressSchemaStore
()
spinaltap-mysql/src/test/java/com/airbnb/spinaltap/mysql/schema/MysqlSchemaStoreTest.java:172
MethodtestConstructor
()
spinaltap-model/src/test/java/com/airbnb/spinaltap/mysql/BinlogFilePosTest.java:46
MethodtestCreateDatabase
()
spinaltap-mysql/src/test/java/com/airbnb/spinaltap/mysql/schema/MysqlSchemaManagerTest.java:225
MethodtestCreateTable
()
spinaltap-mysql/src/test/java/com/airbnb/spinaltap/mysql/schema/MysqlSchemaManagerTest.java:113
MethodtestDeleteEvent
()
spinaltap-mysql/src/test/java/com/airbnb/spinaltap/mysql/binlog_connector/BinaryLogConnectorEventMapperTest.java:98
MethodtestDeleteMutation
()
spinaltap-mysql/src/test/java/com/airbnb/spinaltap/mysql/event/mapper/MysqlMutationMapperTest.java:308
MethodtestDeserializeColumn
()
spinaltap-mysql/src/test/java/com/airbnb/spinaltap/mysql/ColumnSerializationUtilTest.java:39
MethodtestDeserializeMysqlConfiguration
()
spinaltap-mysql/src/test/java/com/airbnb/spinaltap/mysql/util/JsonSerializationTest.java:107
MethodtestDeserialzeBinlogFilePosWithoutGTID
()
spinaltap-mysql/src/test/java/com/airbnb/spinaltap/mysql/util/JsonSerializationTest.java:58
MethodtestDropDatabase
()
spinaltap-mysql/src/test/java/com/airbnb/spinaltap/mysql/schema/MysqlSchemaManagerTest.java:248
MethodtestDropTable
()
spinaltap-mysql/src/test/java/com/airbnb/spinaltap/mysql/schema/MysqlSchemaManagerTest.java:140
MethodtestEmptyFilter
()
spinaltap-common/src/test/java/com/airbnb/spinaltap/common/util/ChainedFilterTest.java:29
MethodtestEmptyHistory
()
spinaltap-mysql/src/test/java/com/airbnb/spinaltap/mysql/StateHistoryTest.java:48
MethodtestEmptySet
()
spinaltap-model/src/test/java/com/airbnb/spinaltap/GtidSetTest.java:17
MethodtestEquals
()
spinaltap-model/src/test/java/com/airbnb/spinaltap/GtidSetTest.java:22
MethodtestEventFilter
()
spinaltap-mysql/src/test/java/com/airbnb/spinaltap/mysql/event/filter/MysqlEventFilterTest.java:37
MethodtestEventInOrder
()
spinaltap-mysql/src/test/java/com/airbnb/spinaltap/mysql/EventOrderValidatorTest.java:22
MethodtestEventOutOfOrder
()
spinaltap-mysql/src/test/java/com/airbnb/spinaltap/mysql/EventOrderValidatorTest.java:37
MethodtestFailingFilter
()
spinaltap-common/src/test/java/com/airbnb/spinaltap/common/util/ChainedFilterTest.java:13
MethodtestFormatDescriptionEvent
()
spinaltap-mysql/src/test/java/com/airbnb/spinaltap/mysql/binlog_connector/BinaryLogConnectorEventMapperTest.java:182
MethodtestGetKey
()
spinaltap-mysql/src/test/java/com/airbnb/spinaltap/mysql/mutation/MysqlKeyProviderTest.java:33
MethodtestGetNullKey
()
spinaltap-mysql/src/test/java/com/airbnb/spinaltap/mysql/mutation/MysqlKeyProviderTest.java:43
MethodtestGetState
()
spinaltap-mysql/src/test/java/com/airbnb/spinaltap/mysql/MysqlSourceTest.java:91
MethodtestIgnoredEvents
()
spinaltap-mysql/src/test/java/com/airbnb/spinaltap/mysql/binlog_connector/BinaryLogConnectorEventMapperTest.java:198
← previousnext →501–600 of 687, ranked by callers