Skip to content

Commit 4762c34

Browse files
committed
Fix the doc
1 parent 0336579 commit 4762c34

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

docs/streaming-flume-integration.md

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -143,6 +143,9 @@ configuring Flume agents.
143143

144144
addresses = [([sink machine hostname 1], [sink port 1]), ([sink machine hostname 2], [sink port 2])]
145145
flumeStream = FlumeUtils.createPollingStream(streamingContext, addresses)
146+
147+
By default, the Python API will decode Flume event body as UTF8 encoded strings. You can specify your custom decoding function to decode the body byte arrays in Flume events to any arbitrary data type.
148+
See the [API docs](api/python/pyspark.streaming.html#pyspark.streaming.flume.FlumeUtils).
146149
</div>
147150
</div>
148151

0 commit comments

Comments
 (0)