func NewSchemaUpdateTask(config *SchemaUpdaterConfig) (*SchemaUpdateTask, error) {
	cqlClient, err := newCQLClient(config)
	if err != nil {
		return nil, err
	}
	return &SchemaUpdateTask{
		config:    config,
		cqlClient: cqlClient,
	}, nil
}
NewSchemaUpdateTask creates and returns a new SchemaUpdateTask
package cassandra
import (
	"crypto/md5"
	"encoding/hex"
	"encoding/json"
	"fmt"
	"io/ioutil"
	"path/filepath"
	"strings"
	log "github.com/sirupsen/logrus"
)
type (
	SchemaUpdateTask struct {
		config    *SchemaUpdaterConfig
		cqlClient CQLClient
	}
	Manifest struct {
		CurrVersion          int64
		MinCompatibleVersion int64
		Description          string
		SchemaUpdateCqlFiles []string
		md5                  string
	}
)
var (
	whitelistedCQLPrefixes = [2]string{"CREATE", "ALTER"}
)