Method appendTableBatch

plugins/destination/mysql/client/write.go:117–119

(ctx context.Context, resources message.WriteInserts)

}

func (c *Client) appendTableBatch(ctx context.Context, resources message.WriteInserts) error {
	return c.writeResources(ctx, false, resources[0].GetTable(), resources)
}

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