Documentation ¶
Index ¶
- type 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type InstantStreamOutput ¶
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) 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
Click to show internal directories.
Click to hide internal directories.