You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2017/02/23 16:45:59 UTC
flink git commit: [FLINK-5885] [docs] Fix Cassandra Scala snippet
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 <an...@radicalbit.io>
Authored: Thu Feb 23 10:53:56 2017 +0100
Committer: Stephan Ewen <se...@apache.org>
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>