hdfsprotocol

Documentation

Index

• Constants
• func Builder(optionYaml []byte) (source.ResourceClient, source.RequestAdapter, []source.Hook, error)
• func NewHDFSSourceClient(opts ...HDFSSourceClientOption) source.ResourceClient
• type HDFSSourceClientOption

Constants

const (
	HDFSClient = "hdfs"
)

Functions

func Builder

func Builder(optionYaml []byte) (source.ResourceClient, source.RequestAdapter, []source.Hook, error)

func NewHDFSSourceClient

func NewHDFSSourceClient(opts ...HDFSSourceClientOption) source.ResourceClient

Types

type HDFSSourceClientOption

type HDFSSourceClientOption func(p *hdfsSourceClient)