Method overwriteTableBatch

plugins/destination/mysql/client/write.go:121–123

(ctx context.Context, msgs message.WriteInserts)

}

func (c *Client) overwriteTableBatch(ctx context.Context, msgs message.WriteInserts) error {
	return c.writeResources(ctx, true, msgs[0].GetTable(), msgs)
}

func (c *Client) Write(ctx context.Context, res <-chan message.WriteMessage) error {
	if err := c.writer.Write(ctx, res); err != nil {