remove
The remove
proc is used to remove only the field names specified from every
point in the stream.
... | remove(*fieldnames) | ...
Argument | Description | Required? |
---|---|---|
*fieldnames | list of field names to remove in each point | No, default: None |
remove just the time field
from flume import *
(
emit(limit=5)
| put(count=count())
| remove('time')
| write('stdio')
).execute()
The above would produce the output:
{"count": 1}
{"count": 2}
{"count": 3}
{"count": 4}
{"count": 5}