bulk

package
v25.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 6, 2025 License: Apache-2.0 Imports: 54 Imported by: 0

Documentation

Index

Constants

View Source
const BulkBadgerDefaults = "compression=snappy; numgoroutines=8;"

Variables

Bulk is the sub-command invoked when running "dgraph bulk".

Functions

func RunBulkLoader

func RunBulkLoader(opt BulkOptions)

Types

type BulkOptions

type BulkOptions struct {
	DataFiles        string
	DataFormat       string
	SchemaFile       string
	GqlSchemaFile    string
	OutDir           string
	ReplaceOutDir    bool
	TmpDir           string
	NumGoroutines    int
	MapBufSize       uint64
	PartitionBufSize int64
	SkipMapPhase     bool
	CleanupTmp       bool
	NumReducers      int
	Version          bool
	StoreXids        bool
	ZeroAddr         string
	ConnStr          string
	HttpAddr         string
	IgnoreErrors     bool
	CustomTokenizers string
	NewUids          bool
	ClientDir        string
	Encrypted        bool
	EncryptedOut     bool

	MapShards    int
	ReduceShards int

	Namespace uint64

	// ........... Badger options ..........
	// EncryptionKey is the key used for encryption.
	EncryptionKey x.Sensitive
	// Badger options.
	Badger badger.Options
	// contains filtered or unexported fields
}

type MapEntry

type MapEntry []byte

func (MapEntry) Key

func (me MapEntry) Key() []byte

func (MapEntry) Plist

func (me MapEntry) Plist() []byte

func (MapEntry) Size

func (me MapEntry) Size() int

func (MapEntry) Uid

func (me MapEntry) Uid() uint64

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL