file

package

v0.0.1 Latest Latest Go to latest Published: Aug 19, 2019 License: Apache-2.0 Imports: 7 Imported by: 1

Details

This section is empty.

View Source

var ByteStreamType = reflect.TypeOf((*ByteStream)(nil)).Elem()

This section is empty.

type ByteStream interface {
	Read(bytes *[]byte) int // 0 means eof, -1 means error
}

type LocalFileByteStream struct {
	// contains filtered or unexported fields
}

func (bs *LocalFileByteStream) Read(bytes *[]byte) int

type Reader struct{}

func (r *Reader) InType() reflect.Type

func (r *Reader) Materialize() func(input interface{}) interface{}

func (r *Reader) OutType() reflect.Type

type Source struct {
	Path string
}

func (s *Source) Commit(goconnect.Watermark, *goconnect.Context) error

func (s *Source) OutType() reflect.Type

func (s *Source) Run(ctx *goconnect.Context)

type Text struct {
}

func (r *Text) InType() reflect.Type

func (r *Text) Materialize() func(input *goconnect.Element, context goconnect.PContext)

func (r *Text) OutType() reflect.Type