Repository: flink Updated Branches: refs/heads/release-1.2 b5ec14641 -> d8c2447bd
[FLINK-5885] [docs] Fix Cassandra Scala snippet This closes #3400 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d8c2447b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d8c2447b Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/d8c2447b Branch: refs/heads/release-1.2 Commit: d8c2447bdc0614d02fcdb01eb33f5bab7b26a8c5 Parents: b5ec146 Author: Andrea Sella <[email protected]> Authored: Thu Feb 23 10:53:56 2017 +0100 Committer: Stephan Ewen <[email protected]> Committed: Thu Feb 23 17:45:11 2017 +0100 ---------------------------------------------------------------------- docs/dev/connectors/cassandra.md | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/d8c2447b/docs/dev/connectors/cassandra.md ---------------------------------------------------------------------- diff --git a/docs/dev/connectors/cassandra.md b/docs/dev/connectors/cassandra.md index 7f76b72..c897779 100644 --- a/docs/dev/connectors/cassandra.md +++ b/docs/dev/connectors/cassandra.md @@ -100,12 +100,11 @@ CassandraSink.addSink(input) CassandraSink.addSink(input) .setQuery("INSERT INTO example.values (id, counter) values (?, ?);") .setClusterBuilder(new ClusterBuilder() { - @Override - public Cluster buildCluster(Cluster.Builder builder) { - return builder.addContactPoint("127.0.0.1").build(); + override def buildCluster(builder: Cluster.Builder): Cluster = { + builder.addContactPoint("127.0.0.1").build() } }) - .build(); + .build() {% endhighlight %} </div> </div>
