Fix the doc

maropu · Jun 19, 2015 · 4762c34 · 4762c34
1 parent 0336579
commit 4762c34
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/docs/streaming-flume-integration.md b/docs/streaming-flume-integration.md
@@ -143,6 +143,9 @@ configuring Flume agents.
 
 		addresses = [([sink machine hostname 1], [sink port 1]), ([sink machine hostname 2], [sink port 2])]
 		flumeStream = FlumeUtils.createPollingStream(streamingContext, addresses)
+
+	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.
+	See the [API docs](api/python/pyspark.streaming.html#pyspark.streaming.flume.FlumeUtils).
 	</div>
 	</div>