hbase

Documentation

Index

• Constants
• type HbaseStore
  • func (store *HbaseStore) BeginTransaction(ctx context.Context) (context.Context, error)
  • func (store *HbaseStore) CommitTransaction(ctx context.Context) error
  • func (store *HbaseStore) DeleteEntry(ctx context.Context, path util.FullPath) (err error)
  • func (store *HbaseStore) DeleteFolderChildren(ctx context.Context, path util.FullPath) (err error)
  • func (store *HbaseStore) FindEntry(ctx context.Context, path util.FullPath) (entry *filer.Entry, err error)
  • func (store *HbaseStore) GetName() string
  • func (store *HbaseStore) Initialize(configuration util.Configuration, prefix string) (err error)
  • func (store *HbaseStore) InsertEntry(ctx context.Context, entry *filer.Entry) error
  • func (store *HbaseStore) KvDelete(ctx context.Context, key []byte) (err error)
  • func (store *HbaseStore) KvGet(ctx context.Context, key []byte) (value []byte, err error)
  • func (store *HbaseStore) KvPut(ctx context.Context, key []byte, value []byte) (err error)
  • func (store *HbaseStore) ListDirectoryEntries(ctx context.Context, dirPath util.FullPath, startFileName string, ...) (string, error)
  • func (store *HbaseStore) ListDirectoryPrefixedEntries(ctx context.Context, dirPath util.FullPath, startFileName string, ...) (lastFileName string, err error)
  • func (store *HbaseStore) RollbackTransaction(ctx context.Context) error
  • func (store *HbaseStore) Shutdown()
  • func (store *HbaseStore) UpdateEntry(ctx context.Context, entry *filer.Entry) (err error)

Constants

const (
	COLUMN_NAME = "a"
)

Types

type HbaseStore

type HbaseStore struct {
	Client gohbase.Client
	// contains filtered or unexported fields
}

func (*HbaseStore) BeginTransaction

func (store *HbaseStore) BeginTransaction(ctx context.Context) (context.Context, error)

func (*HbaseStore) CommitTransaction

func (store *HbaseStore) CommitTransaction(ctx context.Context) error

func (*HbaseStore) DeleteEntry

func (store *HbaseStore) DeleteEntry(ctx context.Context, path util.FullPath) (err error)

func (*HbaseStore) DeleteFolderChildren

func (store *HbaseStore) DeleteFolderChildren(ctx context.Context, path util.FullPath) (err error)

func (*HbaseStore) FindEntry

func (store *HbaseStore) FindEntry(ctx context.Context, path util.FullPath) (entry *filer.Entry, err error)

func (*HbaseStore) GetName

func (store *HbaseStore) GetName() string

func (*HbaseStore) Initialize

func (store *HbaseStore) Initialize(configuration util.Configuration, prefix string) (err error)

func (*HbaseStore) InsertEntry

func (store *HbaseStore) InsertEntry(ctx context.Context, entry *filer.Entry) error

func (*HbaseStore) KvDelete

func (store *HbaseStore) KvDelete(ctx context.Context, key []byte) (err error)

func (*HbaseStore) KvGet

func (store *HbaseStore) KvGet(ctx context.Context, key []byte) (value []byte, err error)

func (*HbaseStore) KvPut

func (store *HbaseStore) KvPut(ctx context.Context, key []byte, value []byte) (err error)

func (*HbaseStore) ListDirectoryEntries

func (store *HbaseStore) ListDirectoryEntries(ctx context.Context, dirPath util.FullPath, startFileName string, includeStartFile bool, limit int64, eachEntryFunc filer.ListEachEntryFunc) (string, error)

func (*HbaseStore) ListDirectoryPrefixedEntries

func (store *HbaseStore) ListDirectoryPrefixedEntries(ctx context.Context, dirPath util.FullPath, startFileName string, includeStartFile bool, limit int64, prefix string, eachEntryFunc filer.ListEachEntryFunc) (lastFileName string, err error)

func (*HbaseStore) RollbackTransaction

func (store *HbaseStore) RollbackTransaction(ctx context.Context) error

func (*HbaseStore) Shutdown

func (store *HbaseStore) Shutdown()

func (*HbaseStore) UpdateEntry

func (store *HbaseStore) UpdateEntry(ctx context.Context, entry *filer.Entry) (err error)