streaming

Documentation

Index

• type InstantStreamOutput
  • func NewInstantStreamOutput(streamID *execution.StreamID) *InstantStreamOutput
  • func (o *InstantStreamOutput) AddRecord(ctx context.Context, tx storage.StateTransaction, inputIndex int, ...) error
  • func (o *InstantStreamOutput) Close(ctx context.Context, storage storage.Storage) error
  • func (o *InstantStreamOutput) GetEndOfStream(ctx context.Context, tx storage.StateTransaction) (bool, error)
  • func (o *InstantStreamOutput) GetErrorMessage(ctx context.Context, tx storage.StateTransaction) (string, error)
  • func (o *InstantStreamOutput) GetWatermark(ctx context.Context, tx storage.StateTransaction) (time.Time, error)
  • func (o *InstantStreamOutput) MarkEndOfStream(ctx context.Context, tx storage.StateTransaction) error
  • func (o *InstantStreamOutput) MarkError(ctx context.Context, tx storage.StateTransaction, err error) error
  • func (o *InstantStreamOutput) Next(ctx context.Context, tx storage.StateTransaction) (*execution.Record, error)
  • func (o *InstantStreamOutput) ReadyForMore(ctx context.Context, tx storage.StateTransaction) error
  • func (o *InstantStreamOutput) TriggerKeys(ctx context.Context, tx storage.StateTransaction, batchSize int) (int, error)
  • func (o *InstantStreamOutput) UpdateWatermark(ctx context.Context, tx storage.StateTransaction, watermark time.Time) error
• type StreamPrinter
  • func NewStreamPrinter(stateStorage storage.Storage, recordSink execution.IntermediateRecordStore, ...) *StreamPrinter
  • func (sp *StreamPrinter) Run(ctx context.Context) error

Types

type InstantStreamOutput

type InstantStreamOutput struct {
	StreamID *execution.StreamID
}

func NewInstantStreamOutput

func NewInstantStreamOutput(streamID *execution.StreamID) *InstantStreamOutput

func (*InstantStreamOutput) AddRecord

func (o *InstantStreamOutput) AddRecord(ctx context.Context, tx storage.StateTransaction, inputIndex int, record *execution.Record) error

func (*InstantStreamOutput) Close

func (o *InstantStreamOutput) Close(ctx context.Context, storage storage.Storage) error

func (*InstantStreamOutput) GetEndOfStream

func (o *InstantStreamOutput) GetEndOfStream(ctx context.Context, tx storage.StateTransaction) (bool, error)

func (*InstantStreamOutput) GetErrorMessage

func (o *InstantStreamOutput) GetErrorMessage(ctx context.Context, tx storage.StateTransaction) (string, error)

func (*InstantStreamOutput) GetWatermark

func (o *InstantStreamOutput) GetWatermark(ctx context.Context, tx storage.StateTransaction) (time.Time, error)

func (*InstantStreamOutput) MarkEndOfStream

func (o *InstantStreamOutput) MarkEndOfStream(ctx context.Context, tx storage.StateTransaction) error

func (*InstantStreamOutput) MarkError

func (o *InstantStreamOutput) MarkError(ctx context.Context, tx storage.StateTransaction, err error) error

func (*InstantStreamOutput) Next

func (o *InstantStreamOutput) Next(ctx context.Context, tx storage.StateTransaction) (*execution.Record, error)

func (*InstantStreamOutput) ReadyForMore

func (o *InstantStreamOutput) ReadyForMore(ctx context.Context, tx storage.StateTransaction) error

func (*InstantStreamOutput) TriggerKeys

func (o *InstantStreamOutput) TriggerKeys(ctx context.Context, tx storage.StateTransaction, batchSize int) (int, error)

func (*InstantStreamOutput) UpdateWatermark

func (o *InstantStreamOutput) UpdateWatermark(ctx context.Context, tx storage.StateTransaction, watermark time.Time) error

type StreamPrinter

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

func NewStreamPrinter

func NewStreamPrinter(stateStorage storage.Storage, recordSink execution.IntermediateRecordStore, printFn func(record *execution.Record)) *StreamPrinter

func (*StreamPrinter) Run

func (sp *StreamPrinter) Run(ctx context.Context) error