v3ioStream: v3io Stream Trigger

On This Page

Reads records from Iguazio Continuous Data Platform v3io streams.

Attributes

Path Type Description
partitions list of int List of partitions on which this function receives events
seekTo string At which point in the stream to read. One of “earliest”, “latest” (defaults to “latest”)
readBatchSize int How many records to read from the stream in a single request (defaults to 64)
pollingIntervalMs int How many milliseconds to wait between reads of the partition (defaults to 500)
username string The v3io username
password string The v3io password

Example

triggers:
  myv3ioStream:
    kind: v3ioStream
    url: http://10.0.0.1:8081/1/v3io-stream-test-baqlmrr9vnp3fmf5fc60
    attributes:
      partitions: [0, 1, 2]
      numContainerWorkers: 1
      seekTo: earliest
      readBatchSize: 64
      pollingIntervalMs: 250
      username: myusername
      password: mypassword