Repository: flink Updated Branches: refs/heads/master 15ae922ad -> 6f3723e83
[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/6f3723e8 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6f3723e8 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/6f3723e8 Branch: refs/heads/master Commit: 6f3723e83ff7f2b862a3f57cebbc78060937a2b8 Parents: 813c258 Author: Andrea Sella <[email protected]> Authored: Thu Feb 23 10:53:56 2017 +0100 Committer: Stephan Ewen <[email protected]> Committed: Fri Feb 24 12:15:18 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/6f3723e8/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>
