file

README

Google Cloud Storage

This sink supports writing to the local file system. It can can be enabled by adding the following configuration in the tables section:

tables:
  eventlog:
    compact:                               # enable compaction
      interval: 60                         # compact every 60 seconds
      nameFunc: "s3://bucket/namefunc.lua" # file name function
      file:                                # sink to use
        dir: "/output"                     # the output directory
...

Documentation

Index

• type Writer
  • func New(directory, filter, encoding string, monitor monitor.Monitor) (*Writer, error)
  • func (w *Writer) Write(key key.Key, blocks []block.Block) error

Types

type Writer

type Writer struct {
	*base.Writer
	// contains filtered or unexported fields
}

Writer represents a local file writer.

func New

func New(directory, filter, encoding string, monitor monitor.Monitor) (*Writer, error)

New creates a new writer.

func (*Writer) Write

func (w *Writer) Write(key key.Key, blocks []block.Block) error

Write writes the data to the sink.